Multi-threaded Evio

evio.go

package main

import (
	"log"
	"runtime"

	"github.com/tidwall/evio"
)

func main() {
	const responseString = "HTTP/1.1 200 OK\r\nContent-Type: text/plain\r\nContent-Length: 12\r\n\r\nHello World\r\n"
	responseBuffer := []byte(responseString)

	buffer := make([]byte, 0, len(responseBuffer)*10000)
	for i := 0; i < 10000; i++ {
		buffer = append(buffer, responseBuffer...)
	}

	var events evio.Events
	events.Serving = func(s evio.Server) (action evio.Action) {
		log.Printf("serving %s\n", s.Addrs[0])
		return
	}
	events.Opened = func(id int, info evio.Info) (out []byte, opts evio.Options, ctx interface{}, action evio.Action) {
		// Reuse the input buffer on Data callbacks to avoid unneeded alloc.
		opts.ReuseInputBuffer = true
		return
	}
	events.Data = func(id int, ctx interface{}, in []byte) (out []byte, action evio.Action) {
		// Calculate how many requests we have. Each request is 40 bytes.
		// Yes this is a hack but this benchmark is measuring pure IO performance
		// of evio so don't judge me.
		numberOfRequests := len(in) / 40
		out = buffer[:numberOfRequests*len(responseBuffer)]
		return
	}
	events.NumLoops = runtime.NumCPU() / 2
	evio.Serve(events, "tcp://0.0.0.0:8000?reuseport=true")
}