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)
}
}