Add benchmarks for chi + sjson (#3734)

frameworks/Go/chi/benchmark_config.json

@@ -46,6 +46,98 @@
       "display_name": "Chi-prefork",
       "notes": "",
       "versus": "go"
+    },
+    "gojay": {
+      "json_url": "/json",
+      "db_url": "/db",
+      "query_url": "/queries?queries=",
+      "fortune_url": "/fortunes",
+      "update_url": "/updates?queries=",
+      "plaintext_url": "/plaintext",
+      "port": 8080,
+      "approach": "Realistic",
+      "classification": "Micro",
+      "database": "Postgres",
+      "framework": "Chi",
+      "language": "Go",
+      "flavor": "None",
+      "orm": "Raw",
+      "platform": "None",
+      "webserver": "None",
+      "os": "Linux",
+      "database_os": "Linux",
+      "display_name": "Chi-gojay",
+      "notes": "",
+      "versus": "go"
+    },
+    "gojay-prefork": {
+      "json_url": "/json",
+      "db_url": "/db",
+      "query_url": "/queries?queries=",
+      "fortune_url": "/fortunes",
+      "update_url": "/updates?queries=",
+      "plaintext_url": "/plaintext",
+      "port": 8080,
+      "approach": "Realistic",
+      "classification": "Micro",
+      "database": "Postgres",
+      "framework": "Chi",
+      "language": "Go",
+      "flavor": "None",
+      "orm": "Raw",
+      "platform": "None",
+      "webserver": "None",
+      "os": "Linux",
+      "database_os": "Linux",
+      "display_name": "Chi-gojay-prefork",
+      "notes": "",
+      "versus": "go"
+    },
+    "sjson": {
+      "json_url": "/json",
+      "db_url": "/db",
+      "query_url": "/queries?queries=",
+      "fortune_url": "/fortunes",
+      "update_url": "/updates?queries=",
+      "plaintext_url": "/plaintext",
+      "port": 8080,
+      "approach": "Realistic",
+      "classification": "Micro",
+      "database": "Postgres",
+      "framework": "Chi",
+      "language": "Go",
+      "flavor": "None",
+      "orm": "Raw",
+      "platform": "None",
+      "webserver": "None",
+      "os": "Linux",
+      "database_os": "Linux",
+      "display_name": "Chi-sjson",
+      "notes": "",
+      "versus": "go"
+    },
+    "sjson-prefork": {
+      "json_url": "/json",
+      "db_url": "/db",
+      "query_url": "/queries?queries=",
+      "fortune_url": "/fortunes",
+      "update_url": "/updates?queries=",
+      "plaintext_url": "/plaintext",
+      "port": 8080,
+      "approach": "Realistic",
+      "classification": "Micro",
+      "database": "Postgres",
+      "framework": "Chi",
+      "language": "Go",
+      "flavor": "None",
+      "orm": "Raw",
+      "platform": "None",
+      "webserver": "None",
+      "os": "Linux",
+      "database_os": "Linux",
+      "display_name": "Chi-sjson-prefork",
+      "notes": "",
+      "versus": "go"
     }
   }]
 }

frameworks/Go/chi/chi-gojay-prefork.dockerfile

@@ -0,0 +1,14 @@
+FROM golang:1.10.1
+
+ADD ./ /chi
+WORKDIR /chi
+
+RUN mkdir bin
+ENV GOPATH /chi
+ENV PATH ${GOPATH}/bin:${PATH}
+
+RUN go get github.com/francoispqt/gojay
+RUN go get github.com/jackc/pgx
+RUN go get github.com/go-chi/chi
+
+CMD go run src/chi-gojay/*.go -prefork

frameworks/Go/chi/chi-gojay.dockerfile

@@ -0,0 +1,14 @@
+FROM golang:1.10.1
+
+ADD ./ /chi
+WORKDIR /chi
+
+RUN mkdir bin
+ENV GOPATH /chi
+ENV PATH ${GOPATH}/bin:${PATH}
+
+RUN go get github.com/francoispqt/gojay
+RUN go get github.com/jackc/pgx
+RUN go get github.com/go-chi/chi
+
+CMD go run src/chi-gojay/*.go

frameworks/Go/chi/chi-sjson-prefork.dockerfile

@@ -0,0 +1,14 @@
+FROM golang:1.10.1
+
+ADD ./ /chi
+WORKDIR /chi
+
+RUN mkdir bin
+ENV GOPATH /chi
+ENV PATH ${GOPATH}/bin:${PATH}
+
+RUN go get github.com/tidwall/sjson
+RUN go get github.com/jackc/pgx
+RUN go get github.com/go-chi/chi
+
+CMD go run src/chi-sjson/*.go -prefork

frameworks/Go/chi/chi-sjson.dockerfile

@@ -0,0 +1,14 @@
+FROM golang:1.10.1
+
+ADD ./ /chi
+WORKDIR /chi
+
+RUN mkdir bin
+ENV GOPATH /chi
+ENV PATH ${GOPATH}/bin:${PATH}
+
+RUN go get github.com/tidwall/sjson
+RUN go get github.com/jackc/pgx
+RUN go get github.com/go-chi/chi
+
+CMD go run src/chi-sjson/*.go

frameworks/Go/chi/src/chi-gojay/db.go

@@ -0,0 +1,47 @@
+package main
+
+import (
+	"flag"
+	"log"
+
+	"github.com/jackc/pgx"
+)
+
+var (
+	defaultDB *pgx.ConnPool
+)
+
+func initDBConnection(pgURL string) {
+	config, err := pgx.ParseConnectionString(pgURL)
+	if err != nil {
+		flag.PrintDefaults()
+		log.Fatalf("Error parsing db URL: %v", err)
+	}
+
+	connPoolConfig := pgx.ConnPoolConfig{
+		ConnConfig:     config,
+		MaxConnections: maxConnectionCount,
+	}
+
+	defaultDB, err = pgx.NewConnPool(connPoolConfig)
+	if err != nil {
+		flag.PrintDefaults()
+		log.Fatalf("Error opening database: %v", err)
+	}
+
+	_, err = defaultDB.Prepare("worldSelect", worldSelect)
+	if err != nil {
+		flag.PrintDefaults()
+		log.Fatal(err)
+	}
+	_, err = defaultDB.Prepare("fortuneSelect", fortuneSelect)
+	if err != nil {
+		flag.PrintDefaults()
+		log.Fatal(err)
+	}
+	_, err = defaultDB.Prepare("worldUpdate", worldUpdate)
+	if err != nil {
+		flag.PrintDefaults()
+		log.Fatal(err)
+	}
+}

frameworks/Go/chi/src/chi-gojay/prefork.go

@@ -0,0 +1,60 @@
+package main
+
+import (
+	"log"
+	"net"
+	"os"
+	"os/exec"
+	"runtime"
+)
+
+func doPrefork(isChild bool, bind string) (listener net.Listener) {
+	var err error
+	var fl *os.File
+	var tcplistener *net.TCPListener
+	if !isChild {
+		var addr *net.TCPAddr
+		addr, err = net.ResolveTCPAddr("tcp", bind)
+		if err != nil {
+			log.Fatal(err)
+		}
+		tcplistener, err = net.ListenTCP("tcp", addr)
+		if err != nil {
+			log.Fatal(err)
+		}
+		fl, err = tcplistener.File()
+		if err != nil {
+			log.Fatal(err)
+		}
+		children := make([]*exec.Cmd, runtime.NumCPU())
+		for i := range children {
+			args := make([]string, len(os.Args)-1)
+			copy(args, os.Args[1:])
+			args = append(args, "-child")
+
+			children[i] = exec.Command(os.Args[0], args...)
+			children[i].Stdout = os.Stdout
+			children[i].Stderr = os.Stderr
+			children[i].ExtraFiles = []*os.File{fl}
+			err = children[i].Start()
+			if err != nil {
+				log.Fatal(err)
+			}
+		}
+		for _, ch := range children {
+			err := ch.Wait()
+			if err != nil {
+				log.Print(err)
+			}
+		}
+		os.Exit(0)
+	} else {
+		fl = os.NewFile(3, "")
+		listener, err = net.FileListener(fl)
+		if err != nil {
+			log.Fatal(err)
+		}
+		runtime.GOMAXPROCS(runtime.NumCPU() / 2)
+	}
+	return listener
+}

frameworks/Go/chi/src/chi-gojay/server.go

@@ -0,0 +1,282 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"html"
+	"io"
+	"io/ioutil"
+	"log"
+	"math/rand"
+	"net"
+	"net/http"
+	"sort"
+	"strconv"
+	"strings"
+
+	"github.com/francoispqt/gojay"
+	"github.com/go-chi/chi"
+	"github.com/jackc/pgx"
+)
+
+const (
+	htmlTemplate = `<!DOCTYPE html>
+<html>
+<head><title>Fortunes</title></head>
+<body><table><tr><th>id</th><th>message</th></tr>%s</table></body>
+</html>`
+	fortuneTemplate = `<tr><td>%d</td><td>%s</td></tr>`
+)
+
+const (
+	// Database
+	worldSelect        = "SELECT id, randomNumber FROM World WHERE id = $1"
+	worldUpdate        = "UPDATE World SET randomNumber = $1 WHERE id = $2"
+	fortuneSelect      = "SELECT id, message FROM Fortune;"
+	worldRowCount      = 10000
+	maxConnectionCount = 256
+
+	helloWorldString    = "Hello, World!"
+	extraFortuneMessage = "Additional fortune added at request time."
+)
+
+var (
+	connectionString = "postgres://benchmarkdbuser:benchmarkdbpass@tfb-database/hello_world?sslmode=disable"
+	bindHost         = ":8080"
+	debugFlag        = false
+	preforkFlag      = false
+	childFlag        = false
+)
+
+// Message is a JSON struct to render a message
+type Message struct {
+	Message string
+}
+
+// MarshalObject encodes the message as JSON
+func (m *Message) MarshalObject(dec *gojay.Encoder) {
+	dec.AddStringKey("message", m.Message)
+}
+
+// IsNil returns true if the object is nil
+func (m *Message) IsNil() bool {
+	return m == nil
+}
+
+// World is a JSON struct to render a random number
+type World struct {
+	ID           uint16 `json:"id"`
+	RandomNumber uint16 `json:"randomNumber"`
+}
+
+// Worlds is a list of World
+type Worlds []World
+
+// MarshalArray marshals the list of worlds
+func (ws Worlds) MarshalArray(enc *gojay.Encoder) {
+	for _, w := range ws {
+		enc.AddObject(&w)
+	}
+}
+
+// IsNil returns true if the object is nil
+func (ws Worlds) IsNil() bool {
+	return ws == nil
+}
+
+// MarshalObject encodes the message as JSON
+func (w *World) MarshalObject(dec *gojay.Encoder) {
+	dec.AddIntKey("id", int(w.ID))
+	dec.AddIntKey("randomNumber", int(w.RandomNumber))
+}
+
+// IsNil returns true if the object is nil
+func (w *World) IsNil() bool {
+	return w == nil
+}
+
+func randomRow() *pgx.Row {
+	return defaultDB.QueryRow("worldSelect", rand.Intn(worldRowCount)+1)
+}
+
+// Fortune renders a fortune in JSON
+type Fortune struct {
+	ID      uint16 `json:"id"`
+	Message string `json:"message"`
+}
+
+// Fortunes is a list of fortunes
+type Fortunes []*Fortune
+
+// Len returns the length of the fortunes list
+func (s Fortunes) Len() int {
+	return len(s)
+}
+
+// Swap swaps fortunes at the given positions
+func (s Fortunes) Swap(i, j int) {
+	s[i], s[j] = s[j], s[i]
+}
+
+// Sets the content type of response. Also adds the Server header.
+func setContentType(w http.ResponseWriter, contentType string) {
+	w.Header().Set("Server", "Chi")
+	w.Header().Set("Content-Type", contentType)
+}
+
+// Test 1: JSON Serialization
+func serializeJSON(w http.ResponseWriter, r *http.Request) {
+	setContentType(w, "application/json")
+
+	_ = gojay.NewEncoder(w).Encode(&Message{helloWorldString})
+}
+
+// Test 2: Single Database Query
+func singleQuery(w http.ResponseWriter, r *http.Request) {
+	world := World{}
+	if err := randomRow().Scan(&world.ID, &world.RandomNumber); err != nil {
+		log.Printf("Error scanning world row: %s", err.Error())
+	}
+
+	setContentType(w, "application/json")
+	_ = gojay.NewEncoder(w).Encode(&world)
+}
+
+// Caps queries parameter between 1 and 500.
+// Non-int values like "foo" and "" become 1.
+func sanitizeQueryParam(queries string) int {
+	n, _ := strconv.Atoi(queries)
+
+	if n <= 0 {
+		return 1
+	}
+
+	if n > 500 {
+		return 500
+	}
+
+	return n
+}
+
+// Test 3: Multiple Database Queries
+func multipleQueries(w http.ResponseWriter, r *http.Request) {
+	queries := sanitizeQueryParam(r.URL.Query().Get("queries"))
+	worlds := make(Worlds, queries)
+
+	for i := 0; i < queries; i++ {
+		if err := randomRow().Scan(&worlds[i].ID, &worlds[i].RandomNumber); err != nil {
+			log.Printf("Error scanning world row: %s", err.Error())
+		}
+	}
+
+	setContentType(w, "application/json")
+	_ = gojay.NewEncoder(w).EncodeArray(worlds)
+}
+
+// Test 4: Fortunes
+func fortunes(w http.ResponseWriter, r *http.Request) {
+	rows, err := defaultDB.Query("fortuneSelect")
+	if err != nil {
+		log.Printf("Error preparing statement: %v", err)
+	}
+
+	fortunes := make(Fortunes, 0, 256)
+
+	for rows.Next() {
+		fortune := Fortune{}
+		if err := rows.Scan(&fortune.ID, &fortune.Message); err != nil {
+			log.Printf("Error scanning fortune row: %s", err.Error())
+		}
+		fortunes = append(fortunes, &fortune)
+	}
+	rows.Close()
+	fortunes = append(fortunes, &Fortune{Message: extraFortuneMessage})
+
+	sort.Slice(fortunes, func(i, j int) bool {
+		return fortunes[i].Message < fortunes[j].Message
+	})
+	setContentType(w, "text/html; charset=utf-8")
+
+	var body strings.Builder
+	for _, fortune := range fortunes {
+		fmt.Fprintf(&body, fortuneTemplate, fortune.ID, html.EscapeString(fortune.Message))
+	}
+
+	fmt.Fprintf(w, htmlTemplate, body.String())
+}
+
+// Test 5: Database Updates
+func dbupdate(w http.ResponseWriter, r *http.Request) {
+	queries := sanitizeQueryParam(r.URL.Query().Get("queries"))
+	worlds := make(Worlds, queries)
+
+	for i := 0; i < queries; i++ {
+		w := &worlds[i]
+		if err := randomRow().Scan(&w.ID, &w.RandomNumber); err != nil {
+			log.Printf("Error scanning world row: %s", err.Error())
+		}
+		worlds[i].RandomNumber = uint16(rand.Intn(worldRowCount) + 1)
+		if _, err := defaultDB.Exec("worldUpdate", w.RandomNumber, w.ID); err != nil {
+			log.Printf("Error updating world row: %s", err.Error())
+		}
+	}
+
+	setContentType(w, "application/json")
+	_ = gojay.NewEncoder(w).EncodeArray(worlds)
+}
+
+// Test 6: Plaintext
+func plaintext(w http.ResponseWriter, r *http.Request) {
+	setContentType(w, "text/plain")
+	_, _ = io.WriteString(w, helloWorldString)
+}
+
+func init() {
+	flag.StringVar(&bindHost, "bind", bindHost, "Set bind host")
+	flag.StringVar(&connectionString, "db", connectionString, "Set database URL")
+	flag.BoolVar(&debugFlag, "debug", false, "Enable debug mode")
+	flag.BoolVar(&preforkFlag, "prefork", false, "Enable prefork mode")
+	flag.BoolVar(&childFlag, "child", false, "Enable child mode")
+	flag.Parse()
+}
+
+func initRouter() http.Handler {
+	r := chi.NewRouter()
+
+	r.Get("/json", serializeJSON)
+	r.Get("/db", singleQuery)
+	r.Get("/queries", multipleQueries)
+	r.Get("/fortunes", fortunes)
+	r.Get("/plaintext", plaintext)
+	r.Get("/updates", dbupdate)
+
+	return r
+}
+
+func startListening(listener net.Listener) error {
+	var err error
+	if !preforkFlag {
+		err = http.ListenAndServe(bindHost, initRouter())
+	} else {
+		err = http.Serve(listener, initRouter())
+	}
+
+	return err
+}
+
+func main() {
+	var listener net.Listener
+	if preforkFlag {
+		listener = doPrefork(childFlag, bindHost)
+	}
+
+	initDBConnection(connectionString)
+
+	if !debugFlag {
+		log.SetOutput(ioutil.Discard)
+	}
+
+	if err := startListening(listener); err != nil {
+		log.Fatal(err)
+	}
+}

frameworks/Go/chi/src/chi-sjson/db.go

@@ -0,0 +1,47 @@
+package main
+
+import (
+	"flag"
+	"log"
+
+	"github.com/jackc/pgx"
+)
+
+var (
+	defaultDB *pgx.ConnPool
+)
+
+func initDBConnection(pgURL string) {
+	config, err := pgx.ParseConnectionString(pgURL)
+	if err != nil {
+		flag.PrintDefaults()
+		log.Fatalf("Error parsing db URL: %v", err)
+	}
+
+	connPoolConfig := pgx.ConnPoolConfig{
+		ConnConfig:     config,
+		MaxConnections: maxConnectionCount,
+	}
+
+	defaultDB, err = pgx.NewConnPool(connPoolConfig)
+	if err != nil {
+		flag.PrintDefaults()
+		log.Fatalf("Error opening database: %v", err)
+	}
+
+	_, err = defaultDB.Prepare("worldSelect", worldSelect)
+	if err != nil {
+		flag.PrintDefaults()
+		log.Fatal(err)
+	}
+	_, err = defaultDB.Prepare("fortuneSelect", fortuneSelect)
+	if err != nil {
+		flag.PrintDefaults()
+		log.Fatal(err)
+	}
+	_, err = defaultDB.Prepare("worldUpdate", worldUpdate)
+	if err != nil {
+		flag.PrintDefaults()
+		log.Fatal(err)
+	}
+}

frameworks/Go/chi/src/chi-sjson/prefork.go

@@ -0,0 +1,60 @@
+package main
+
+import (
+	"log"
+	"net"
+	"os"
+	"os/exec"
+	"runtime"
+)
+
+func doPrefork(isChild bool, bind string) (listener net.Listener) {
+	var err error
+	var fl *os.File
+	var tcplistener *net.TCPListener
+	if !isChild {
+		var addr *net.TCPAddr
+		addr, err = net.ResolveTCPAddr("tcp", bind)
+		if err != nil {
+			log.Fatal(err)
+		}
+		tcplistener, err = net.ListenTCP("tcp", addr)
+		if err != nil {
+			log.Fatal(err)
+		}
+		fl, err = tcplistener.File()
+		if err != nil {
+			log.Fatal(err)
+		}
+		children := make([]*exec.Cmd, runtime.NumCPU())
+		for i := range children {
+			args := make([]string, len(os.Args)-1)
+			copy(args, os.Args[1:])
+			args = append(args, "-child")
+
+			children[i] = exec.Command(os.Args[0], args...)
+			children[i].Stdout = os.Stdout
+			children[i].Stderr = os.Stderr
+			children[i].ExtraFiles = []*os.File{fl}
+			err = children[i].Start()
+			if err != nil {
+				log.Fatal(err)
+			}
+		}
+		for _, ch := range children {
+			err := ch.Wait()
+			if err != nil {
+				log.Print(err)
+			}
+		}
+		os.Exit(0)
+	} else {
+		fl = os.NewFile(3, "")
+		listener, err = net.FileListener(fl)
+		if err != nil {
+			log.Fatal(err)
+		}
+		runtime.GOMAXPROCS(runtime.NumCPU() / 2)
+	}
+	return listener
+}

frameworks/Go/chi/src/chi-sjson/server.go

@@ -0,0 +1,283 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"html"
+	"io"
+	"io/ioutil"
+	"log"
+	"math/rand"
+	"net"
+	"net/http"
+	"sort"
+	"strconv"
+	"strings"
+
+	"github.com/go-chi/chi"
+	"github.com/jackc/pgx"
+	"github.com/tidwall/sjson"
+)
+
+const (
+	htmlTemplate = `<!DOCTYPE html>
+<html>
+<head><title>Fortunes</title></head>
+<body><table><tr><th>id</th><th>message</th></tr>%s</table></body>
+</html>`
+	fortuneTemplate = `<tr><td>%d</td><td>%s</td></tr>`
+)
+
+const (
+	// Database
+	worldSelect        = "SELECT id, randomNumber FROM World WHERE id = $1"
+	worldUpdate        = "UPDATE World SET randomNumber = $1 WHERE id = $2"
+	fortuneSelect      = "SELECT id, message FROM Fortune;"
+	worldRowCount      = 10000
+	maxConnectionCount = 256
+
+	helloWorldString    = "Hello, World!"
+	extraFortuneMessage = "Additional fortune added at request time."
+)
+
+var (
+	connectionString = "postgres://benchmarkdbuser:benchmarkdbpass@tfb-database/hello_world?sslmode=disable"
+	bindHost         = ":8080"
+	debugFlag        = false
+	preforkFlag      = false
+	childFlag        = false
+)
+
+// sjson
+var (
+	messageJSONTmpl = []byte(`{"message": ""}`)
+	worldJSONTmpl   = []byte(`{"id": 0, "randomNumber": 0}`)
+	optimistic      = &sjson.Options{Optimistic: true}
+	inPlace         = &sjson.Options{Optimistic: true, ReplaceInPlace: true}
+)
+
+// Message is a JSON struct to render a message
+type Message struct {
+	Message string
+}
+
+// MarshalJSON marshals the object as json
+func (m Message) MarshalJSON() ([]byte, error) {
+	return sjson.SetBytesOptions(messageJSONTmpl, "message", m.Message, optimistic)
+}
+
+// World is a JSON struct to render a random number
+type World struct {
+	ID           uint16 `json:"id"`
+	RandomNumber uint16 `json:"randomNumber"`
+}
+
+// MarshalJSON marshals the object as json
+func (w World) MarshalJSON() ([]byte, error) {
+	data, _ := sjson.SetBytesOptions(worldJSONTmpl, "id", w.ID, optimistic)
+	return sjson.SetBytesOptions(data, "randomNumber", w.RandomNumber, inPlace)
+}
+
+// Worlds is a list of worlds
+type Worlds []World
+
+// MarshalJSON marshals the object as json
+func (ws Worlds) MarshalJSON() ([]byte, error) {
+	jsonResult := []byte(`[]`)
+
+	for _, w := range ws {
+		jsonResult, _ = sjson.SetBytesOptions(jsonResult, "-1", &w, inPlace)
+	}
+
+	return jsonResult, nil
+}
+
+func randomRow() *pgx.Row {
+	return defaultDB.QueryRow("worldSelect", rand.Intn(worldRowCount)+1)
+}
+
+// Fortune renders a fortune in JSON
+type Fortune struct {
+	ID      uint16 `json:"id"`
+	Message string `json:"message"`
+}
+
+// Fortunes is a list of fortunes
+type Fortunes []*Fortune
+
+// Len returns the length of the fortunes list
+func (s Fortunes) Len() int {
+	return len(s)
+}
+
+// Swap swaps fortunes at the given positions
+func (s Fortunes) Swap(i, j int) {
+	s[i], s[j] = s[j], s[i]
+}
+
+// Sets the content type of response. Also adds the Server header.
+func setContentType(w http.ResponseWriter, contentType string) {
+	w.Header().Set("Server", "Chi")
+	w.Header().Set("Content-Type", contentType)
+}
+
+// Test 1: JSON Serialization
+func serializeJSON(w http.ResponseWriter, r *http.Request) {
+	setContentType(w, "application/json")
+
+	data, _ := Message{helloWorldString}.MarshalJSON()
+	_, _ = w.Write(data)
+}
+
+// Test 2: Single Database Query
+func singleQuery(w http.ResponseWriter, r *http.Request) {
+	world := World{}
+	if err := randomRow().Scan(&world.ID, &world.RandomNumber); err != nil {
+		log.Printf("Error scanning world row: %s", err.Error())
+	}
+
+	setContentType(w, "application/json")
+	data, _ := world.MarshalJSON()
+	_, _ = w.Write(data)
+}
+
+// Caps queries parameter between 1 and 500.
+// Non-int values like "foo" and "" become 1.
+func sanitizeQueryParam(queries string) int {
+	n, _ := strconv.Atoi(queries)
+
+	if n <= 0 {
+		return 1
+	}
+
+	if n > 500 {
+		return 500
+	}
+
+	return n
+}
+
+// Test 3: Multiple Database Queries
+func multipleQueries(w http.ResponseWriter, r *http.Request) {
+	queries := sanitizeQueryParam(r.URL.Query().Get("queries"))
+	worlds := make(Worlds, queries)
+
+	for i := 0; i < queries; i++ {
+		if err := randomRow().Scan(&worlds[i].ID, &worlds[i].RandomNumber); err != nil {
+			log.Printf("Error scanning world row: %s", err.Error())
+		}
+	}
+
+	setContentType(w, "application/json")
+	data, _ := worlds.MarshalJSON()
+	_, _ = w.Write(data)
+}
+
+// Test 4: Fortunes
+func fortunes(w http.ResponseWriter, r *http.Request) {
+	rows, err := defaultDB.Query("fortuneSelect")
+	if err != nil {
+		log.Printf("Error preparing statement: %v", err)
+	}
+
+	fortunes := make(Fortunes, 0, 256)
+
+	for rows.Next() {
+		fortune := Fortune{}
+		if err := rows.Scan(&fortune.ID, &fortune.Message); err != nil {
+			log.Printf("Error scanning fortune row: %s", err.Error())
+		}
+		fortunes = append(fortunes, &fortune)
+	}
+	rows.Close()
+	fortunes = append(fortunes, &Fortune{Message: extraFortuneMessage})
+
+	sort.Slice(fortunes, func(i, j int) bool {
+		return fortunes[i].Message < fortunes[j].Message
+	})
+	setContentType(w, "text/html; charset=utf-8")
+
+	var body strings.Builder
+	for _, fortune := range fortunes {
+		fmt.Fprintf(&body, fortuneTemplate, fortune.ID, html.EscapeString(fortune.Message))
+	}
+
+	fmt.Fprintf(w, htmlTemplate, body.String())
+}
+
+// Test 5: Database Updates
+func dbupdate(w http.ResponseWriter, r *http.Request) {
+	queries := sanitizeQueryParam(r.URL.Query().Get("queries"))
+	worlds := make(Worlds, queries)
+
+	for i := 0; i < queries; i++ {
+		w := &worlds[i]
+		if err := randomRow().Scan(&w.ID, &w.RandomNumber); err != nil {
+			log.Printf("Error scanning world row: %s", err.Error())
+		}
+		worlds[i].RandomNumber = uint16(rand.Intn(worldRowCount) + 1)
+		if _, err := defaultDB.Exec("worldUpdate", w.RandomNumber, w.ID); err != nil {
+			log.Printf("Error updating world row: %s", err.Error())
+		}
+	}
+
+	setContentType(w, "application/json")
+	data, _ := worlds.MarshalJSON()
+	_, _ = w.Write(data)
+}
+
+// Test 6: Plaintext
+func plaintext(w http.ResponseWriter, r *http.Request) {
+	setContentType(w, "text/plain")
+	_, _ = io.WriteString(w, helloWorldString)
+}
+
+func init() {
+	flag.StringVar(&bindHost, "bind", bindHost, "Set bind host")
+	flag.StringVar(&connectionString, "db", connectionString, "Set database URL")
+	flag.BoolVar(&debugFlag, "debug", false, "Enable debug mode")
+	flag.BoolVar(&preforkFlag, "prefork", false, "Enable prefork mode")
+	flag.BoolVar(&childFlag, "child", false, "Enable child mode")
+	flag.Parse()
+}
+
+func initRouter() http.Handler {
+	r := chi.NewRouter()
+
+	r.Get("/json", serializeJSON)
+	r.Get("/db", singleQuery)
+	r.Get("/queries", multipleQueries)
+	r.Get("/fortunes", fortunes)
+	r.Get("/plaintext", plaintext)
+	r.Get("/updates", dbupdate)
+
+	return r
+}
+
+func startListening(listener net.Listener) error {
+	var err error
+	if !preforkFlag {
+		err = http.ListenAndServe(bindHost, initRouter())
+	} else {
+		err = http.Serve(listener, initRouter())
+	}
+
+	return err
+}
+
+func main() {
+	var listener net.Listener
+	if preforkFlag {
+		listener = doPrefork(childFlag, bindHost)
+	}
+
+	initDBConnection(connectionString)
+
+	if !debugFlag {
+		log.SetOutput(ioutil.Discard)
+	}
+
+	if err := startListening(listener); err != nil {
+		log.Fatal(err)
+	}
+}

frameworks/Go/chi/src/chi/prefork.go

@@ -26,7 +26,7 @@ func doPrefork(isChild bool, bind string) (listener net.Listener) {
 		if err != nil {
 			log.Fatal(err)
 		}
-		children := make([]*exec.Cmd, runtime.NumCPU()/2)
+		children := make([]*exec.Cmd, runtime.NumCPU())
 		for i := range children {
 			args := make([]string, len(os.Args)-1)
 			copy(args, os.Args[1:])
@@ -54,7 +54,7 @@ func doPrefork(isChild bool, bind string) (listener net.Listener) {
 		if err != nil {
 			log.Fatal(err)
 		}
-		runtime.GOMAXPROCS(2)
+		runtime.GOMAXPROCS(runtime.NumCPU() / 2)
 	}
 	return listener
 }

frameworks/Go/chi/src/chi/server.go

@@ -46,9 +46,6 @@ var (
 	debugFlag        = false
 	preforkFlag      = false
 	childFlag        = false
-
-	// Database
-	helloWorldMessage = &Message{helloWorldString}
 )
 
 // Message is a JSON struct to render a message
@@ -94,7 +91,7 @@ func setContentType(w http.ResponseWriter, contentType string) {
 // Test 1: JSON Serialization
 func serializeJSON(w http.ResponseWriter, r *http.Request) {
 	setContentType(w, "application/json")
-	_ = json.NewEncoder(w).Encode(helloWorldMessage)
+	_ = json.NewEncoder(w).Encode(Message{helloWorldString})
 }
 
 // Test 2: Single Database Query