func serveBenchRemote()

in cmd/bench/bench.go [109:126]


func serveBenchRemote(l net.Listener, start <-chan struct{}) {
	cnx, err := l.Accept()
	if err != nil {
		logrus.WithError(err).Fatal("redplex/bench: error accepting connection")
		os.Exit(1)
	}

	<-start

	toWrite := []byte{}
	for i := 0; i < 1000; i++ {
		toWrite = append(toWrite, benchData...)
	}

	for {
		cnx.Write(toWrite)
	}
}