ln := newLocalListener(b)
defer ln.Close()
+ N := b.N
+
var serr error
go func() {
- for i := 0; i < b.N; i++ {
+ for i := 0; i < N; i++ {
sconn, err := ln.Accept()
if err != nil {
serr = err
buf := make([]byte, 1<<16)
chunks := int(math.Ceil(float64(totalBytes) / float64(len(buf))))
- for i := 0; i < b.N; i++ {
+ for i := 0; i < N; i++ {
conn, err := Dial("tcp", ln.Addr().String(), &clientConfig)
if err != nil {
b.Fatal(err)
ln := newLocalListener(b)
defer ln.Close()
+ N := b.N
+
var serr error
go func() {
- for i := 0; i < b.N; i++ {
+ for i := 0; i < N; i++ {
sconn, err := ln.Accept()
if err != nil {
serr = err
buf := make([]byte, 16384)
peek := make([]byte, 1)
- for i := 0; i < b.N; i++ {
+ for i := 0; i < N; i++ {
conn, err := Dial("tcp", ln.Addr().String(), &clientConfig)
if err != nil {
b.Fatal(err)