> ROOT_DIR=/tmp/go-bench-away-job-dc707589-4681-45e9-867e-9851d111fa37-2810327590 > OUTPUT_FILE=/tmp/go-bench-away-job-dc707589-4681-45e9-867e-9851d111fa37-2810327590/results.txt > SHA_FILE=/tmp/go-bench-away-job-dc707589-4681-45e9-867e-9851d111fa37-2810327590/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-dc707589-4681-45e9-867e-9851d111fa37-2810327590/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.26.3/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-dc707589-4681-45e9-867e-9851d111fa37-2810327590/source.git SHA of main: 6d6edf754ee049fbbf915db0e894a8dddb3f7e3a Go runtime: go version go1.26.3 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build3685832404=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-dc707589-4681-45e9-867e-9851d111fa37-2810327590/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.26.3' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.26.3/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.3' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 40412726 75.54 ns/op 145.62 MB/s Benchmark______Pub0b_Payload-16 50147504 71.72 ns/op 153.37 MB/s Benchmark______Pub0b_Payload-16 46755381 78.35 ns/op 140.40 MB/s Benchmark______Pub0b_Payload-16 43699509 71.97 ns/op 152.83 MB/s Benchmark______Pub0b_Payload-16 50061615 71.81 ns/op 153.19 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46661431 72.71 ns/op 261.33 MB/s Benchmark______Pub8b_Payload-16 44485741 72.51 ns/op 262.04 MB/s Benchmark______Pub8b_Payload-16 46510617 72.51 ns/op 262.04 MB/s Benchmark______Pub8b_Payload-16 49557568 72.75 ns/op 261.16 MB/s Benchmark______Pub8b_Payload-16 40288921 78.12 ns/op 243.22 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 42858646 77.41 ns/op 568.41 MB/s Benchmark_____Pub32b_Payload-16 44248897 82.73 ns/op 531.87 MB/s Benchmark_____Pub32b_Payload-16 44555108 76.73 ns/op 573.41 MB/s Benchmark_____Pub32b_Payload-16 44566822 76.66 ns/op 573.97 MB/s Benchmark_____Pub32b_Payload-16 40747017 76.61 ns/op 574.35 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 40388505 86.52 ns/op 1629.75 MB/s Benchmark____Pub128B_Payload-16 40039956 87.41 ns/op 1613.07 MB/s Benchmark____Pub128B_Payload-16 41960386 85.83 ns/op 1642.80 MB/s Benchmark____Pub128B_Payload-16 39934332 90.70 ns/op 1554.64 MB/s Benchmark____Pub128B_Payload-16 41196151 87.19 ns/op 1617.12 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35932956 93.83 ns/op 2867.00 MB/s Benchmark____Pub256B_Payload-16 37203439 95.01 ns/op 2831.27 MB/s Benchmark____Pub256B_Payload-16 35508064 94.52 ns/op 2845.91 MB/s Benchmark____Pub256B_Payload-16 37114764 93.48 ns/op 2877.66 MB/s Benchmark____Pub256B_Payload-16 32220096 93.41 ns/op 2879.69 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25012689 145.5 ns/op 7133.43 MB/s Benchmark______Pub1K_Payload-16 23840283 149.1 ns/op 6959.93 MB/s Benchmark______Pub1K_Payload-16 24946640 157.5 ns/op 6590.81 MB/s Benchmark______Pub1K_Payload-16 21610908 141.3 ns/op 7347.46 MB/s Benchmark______Pub1K_Payload-16 24598822 135.0 ns/op 7687.12 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5425782 623.7 ns/op 6589.26 MB/s Benchmark______Pub4K_Payload-16 5440064 619.5 ns/op 6634.57 MB/s Benchmark______Pub4K_Payload-16 5801894 614.2 ns/op 6691.76 MB/s Benchmark______Pub4K_Payload-16 5446682 621.8 ns/op 6609.53 MB/s Benchmark______Pub4K_Payload-16 5579017 628.2 ns/op 6542.88 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2731950 1288 ns/op 6369.95 MB/s Benchmark______Pub8K_Payload-16 2808742 1278 ns/op 6419.49 MB/s Benchmark______Pub8K_Payload-16 2738689 1291 ns/op 6358.25 MB/s Benchmark______Pub8K_Payload-16 2807460 1274 ns/op 6442.95 MB/s Benchmark______Pub8K_Payload-16 2723961 1270 ns/op 6463.21 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 649623 5419 ns/op 6049.77 MB/s Benchmark_____Pub32K_Payload-16 642723 5443 ns/op 6022.66 MB/s Benchmark_____Pub32K_Payload-16 661831 5311 ns/op 6172.33 MB/s Benchmark_____Pub32K_Payload-16 652946 5459 ns/op 6005.85 MB/s Benchmark_____Pub32K_Payload-16 651919 5528 ns/op 5930.09 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32883633 91.47 ns/op 120.25 MB/s Benchmark__AuthPub0b_Payload-16 37238026 91.87 ns/op 119.74 MB/s Benchmark__AuthPub0b_Payload-16 33332413 91.39 ns/op 120.36 MB/s Benchmark__AuthPub0b_Payload-16 37325748 91.26 ns/op 120.54 MB/s Benchmark__AuthPub0b_Payload-16 36568218 91.92 ns/op 119.66 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15392625 229.3 ns/op Benchmark_____________PubSub-16 15505482 228.0 ns/op Benchmark_____________PubSub-16 15560316 228.7 ns/op Benchmark_____________PubSub-16 15599095 228.9 ns/op Benchmark_____________PubSub-16 15459223 229.6 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15497162 227.6 ns/op Benchmark_____PubSubTwoConns-16 15505470 227.6 ns/op Benchmark_____PubSubTwoConns-16 15296252 228.4 ns/op Benchmark_____PubSubTwoConns-16 15468102 228.6 ns/op Benchmark_____PubSubTwoConns-16 15496754 230.6 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41012->127.0.0.1:38203: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:45410->127.0.0.1:42161: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51136->127.0.0.1:42541: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50664->127.0.0.1:37049: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41136->127.0.0.1:44711: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 Benchmark___PubSubAccsImport bench_test.go:58: Failed read of PONG: -ERR 'Authorization Violation' --- FAIL: Benchmark___PubSubAccsImport Benchmark_____PubTwoQueueSub Benchmark_____PubTwoQueueSub-16 14125455 248.2 ns/op Benchmark_____PubTwoQueueSub-16 14303954 249.6 ns/op Benchmark_____PubTwoQueueSub-16 14388945 248.4 ns/op Benchmark_____PubTwoQueueSub-16 14308830 248.2 ns/op Benchmark_____PubTwoQueueSub-16 14303863 247.9 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14316214 247.2 ns/op Benchmark____PubFourQueueSub-16 14353380 248.7 ns/op Benchmark____PubFourQueueSub-16 14333167 247.7 ns/op Benchmark____PubFourQueueSub-16 14377990 248.6 ns/op Benchmark____PubFourQueueSub-16 14307426 248.8 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14314104 248.4 ns/op Benchmark___PubEightQueueSub-16 14248824 248.8 ns/op Benchmark___PubEightQueueSub-16 14287334 248.1 ns/op Benchmark___PubEightQueueSub-16 14318355 248.7 ns/op Benchmark___PubEightQueueSub-16 14355774 249.0 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23286 157131 ns/op Benchmark_PubSub512kTwoConns-16 22918 157079 ns/op Benchmark_PubSub512kTwoConns-16 23118 158344 ns/op Benchmark_PubSub512kTwoConns-16 22783 156050 ns/op Benchmark_PubSub512kTwoConns-16 22836 156652 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15167869 232.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15037138 232.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15123712 229.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15062698 232.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15154552 231.8 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15087234 230.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 14973199 232.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 14971941 231.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15218210 231.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 14923898 231.9 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11082320 313.4 ns/op Benchmark____RoutedPubSub_0b-16 11297102 317.7 ns/op Benchmark____RoutedPubSub_0b-16 11257885 310.4 ns/op Benchmark____RoutedPubSub_0b-16 11031502 312.9 ns/op Benchmark____RoutedPubSub_0b-16 11513310 311.2 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6716691 526.5 ns/op Benchmark____RoutedPubSub_1K-16 6545541 544.4 ns/op Benchmark____RoutedPubSub_1K-16 6616723 540.2 ns/op Benchmark____RoutedPubSub_1K-16 6695083 544.0 ns/op Benchmark____RoutedPubSub_1K-16 6575095 701.8 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84250 42441 ns/op Benchmark__RoutedPubSub_100K-16 72139 43928 ns/op Benchmark__RoutedPubSub_100K-16 73496 48411 ns/op Benchmark__RoutedPubSub_100K-16 72573 49131 ns/op Benchmark__RoutedPubSub_100K-16 71026 48931 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9511707 329.7 ns/op Benchmark____Routed2QueueSub-16 9533847 316.2 ns/op Benchmark____Routed2QueueSub-16 9544932 320.7 ns/op Benchmark____Routed2QueueSub-16 9308779 322.6 ns/op Benchmark____Routed2QueueSub-16 9722862 320.0 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9330663 323.8 ns/op Benchmark____Routed4QueueSub-16 9528567 328.8 ns/op Benchmark____Routed4QueueSub-16 9332191 324.0 ns/op Benchmark____Routed4QueueSub-16 9472040 327.8 ns/op Benchmark____Routed4QueueSub-16 9528176 325.6 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9433530 333.5 ns/op Benchmark____Routed8QueueSub-16 9066097 331.1 ns/op Benchmark____Routed8QueueSub-16 9124222 333.4 ns/op Benchmark____Routed8QueueSub-16 9267394 329.6 ns/op Benchmark____Routed8QueueSub-16 9016672 333.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8762968 343.3 ns/op Benchmark___Routed16QueueSub-16 8873251 348.2 ns/op Benchmark___Routed16QueueSub-16 8909757 348.6 ns/op Benchmark___Routed16QueueSub-16 8888625 349.6 ns/op Benchmark___Routed16QueueSub-16 8656938 357.1 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6511468 553.7 ns/op Benchmark____________RouteCompressOff-16 6313305 527.1 ns/op Benchmark____________RouteCompressOff-16 6468258 551.5 ns/op Benchmark____________RouteCompressOff-16 6633900 476.3 ns/op Benchmark____________RouteCompressOff-16 6334867 548.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6366081 546.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6480981 548.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6502060 550.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6353098 552.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 7784880 482.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6252172 550.7 ns/op Benchmark_________RouteCompressS2Fast-16 6499010 490.8 ns/op Benchmark_________RouteCompressS2Fast-16 5982734 561.5 ns/op Benchmark_________RouteCompressS2Fast-16 6418303 553.3 ns/op Benchmark_________RouteCompressS2Fast-16 6354802 552.9 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6340434 556.6 ns/op Benchmark_______RouteCompressS2Better-16 6453382 554.0 ns/op Benchmark_______RouteCompressS2Better-16 6467800 552.5 ns/op Benchmark_______RouteCompressS2Better-16 6325675 480.9 ns/op Benchmark_______RouteCompressS2Better-16 6375168 533.3 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6452470 548.1 ns/op Benchmark_________RouteCompressS2Best-16 6500370 554.2 ns/op Benchmark_________RouteCompressS2Best-16 6339316 553.8 ns/op Benchmark_________RouteCompressS2Best-16 6427882 545.2 ns/op Benchmark_________RouteCompressS2Best-16 6396310 550.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4604473 790.7 ns/op 314.92 MB/s Benchmark______FanOut_8x1x10-16 4616937 779.3 ns/op 319.51 MB/s Benchmark______FanOut_8x1x10-16 4617709 781.9 ns/op 318.45 MB/s Benchmark______FanOut_8x1x10-16 4595452 777.6 ns/op 320.22 MB/s Benchmark______FanOut_8x1x10-16 4575546 779.6 ns/op 319.40 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 530427 6166 ns/op 376.07 MB/s Benchmark_____FanOut_8x1x100-16 549796 6193 ns/op 374.47 MB/s Benchmark_____FanOut_8x1x100-16 550662 6342 ns/op 365.66 MB/s Benchmark_____FanOut_8x1x100-16 538987 6190 ns/op 374.66 MB/s Benchmark_____FanOut_8x1x100-16 546385 6176 ns/op 375.51 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 46806 76599 ns/op 300.51 MB/s Benchmark____FanOut_8x10x100-16 47007 76925 ns/op 299.24 MB/s Benchmark____FanOut_8x10x100-16 46689 76198 ns/op 302.10 MB/s Benchmark____FanOut_8x10x100-16 47134 76463 ns/op 301.05 MB/s Benchmark____FanOut_8x10x100-16 47096 76382 ns/op 301.37 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5773 615951 ns/op 389.67 MB/s Benchmark___FanOut_8x10x1000-16 5628 626235 ns/op 383.27 MB/s Benchmark___FanOut_8x10x1000-16 5751 640157 ns/op 374.94 MB/s Benchmark___FanOut_8x10x1000-16 5760 617906 ns/op 388.44 MB/s Benchmark___FanOut_8x10x1000-16 5722 620092 ns/op 387.07 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4963 732517 ns/op 314.01 MB/s Benchmark___FanOut_8x100x100-16 4870 735417 ns/op 312.77 MB/s Benchmark___FanOut_8x100x100-16 4846 729954 ns/op 315.11 MB/s Benchmark___FanOut_8x100x100-16 4766 731520 ns/op 314.44 MB/s Benchmark___FanOut_8x100x100-16 4802 733832 ns/op 313.45 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 550 6463895 ns/op 371.30 MB/s Benchmark__FanOut_8x100x1000-16 548 6506987 ns/op 368.84 MB/s Benchmark__FanOut_8x100x1000-16 546 6449344 ns/op 372.13 MB/s Benchmark__FanOut_8x100x1000-16 548 6445275 ns/op 372.37 MB/s Benchmark__FanOut_8x100x1000-16 546 6516559 ns/op 368.30 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 490 6929770 ns/op 360.77 MB/s Benchmark__FanOut_8x10x10000-16 507 6991186 ns/op 357.60 MB/s Benchmark__FanOut_8x10x10000-16 519 6975820 ns/op 358.38 MB/s Benchmark__FanOut_8x10x10000-16 520 7022031 ns/op 356.03 MB/s Benchmark__FanOut_8x10x10000-16 508 6893470 ns/op 362.66 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 910 3859376 ns/op 297.98 MB/s Benchmark___FanOut_8x500x100-16 921 3890863 ns/op 295.57 MB/s Benchmark___FanOut_8x500x100-16 924 3876866 ns/op 296.64 MB/s Benchmark___FanOut_8x500x100-16 921 3878836 ns/op 296.49 MB/s Benchmark___FanOut_8x500x100-16 919 3886278 ns/op 295.92 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 346587 9650 ns/op 1517.22 MB/s Benchmark___FanOut_128x1x100-16 346557 9785 ns/op 1496.24 MB/s Benchmark___FanOut_128x1x100-16 349922 9631 ns/op 1520.22 MB/s Benchmark___FanOut_128x1x100-16 355826 9630 ns/op 1520.38 MB/s Benchmark___FanOut_128x1x100-16 356358 9666 ns/op 1514.77 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 31998 112757 ns/op 1287.20 MB/s Benchmark__FanOut_128x10x100-16 31813 112747 ns/op 1287.32 MB/s Benchmark__FanOut_128x10x100-16 31699 112923 ns/op 1285.31 MB/s Benchmark__FanOut_128x10x100-16 31407 113120 ns/op 1283.07 MB/s Benchmark__FanOut_128x10x100-16 31742 114808 ns/op 1264.21 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3828 913170 ns/op 1598.98 MB/s Benchmark_FanOut_128x10x1000-16 3939 904043 ns/op 1615.12 MB/s Benchmark_FanOut_128x10x1000-16 3652 903084 ns/op 1616.84 MB/s Benchmark_FanOut_128x10x1000-16 3756 913702 ns/op 1598.05 MB/s Benchmark_FanOut_128x10x1000-16 3882 908218 ns/op 1607.70 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3478 1034924 ns/op 1401.20 MB/s Benchmark_FanOut_128x100x100-16 3364 1034333 ns/op 1402.01 MB/s Benchmark_FanOut_128x100x100-16 3375 1039320 ns/op 1395.28 MB/s Benchmark_FanOut_128x100x100-16 3376 1039545 ns/op 1394.98 MB/s Benchmark_FanOut_128x100x100-16 3396 1034342 ns/op 1401.99 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 370 9612647 ns/op 1518.85 MB/s BenchmarkFanOut_128x100x1000-16 372 9682484 ns/op 1507.89 MB/s BenchmarkFanOut_128x100x1000-16 368 9609157 ns/op 1519.40 MB/s BenchmarkFanOut_128x100x1000-16 374 9748784 ns/op 1497.64 MB/s BenchmarkFanOut_128x100x1000-16 368 9715860 ns/op 1502.71 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 360 9913826 ns/op 1482.79 MB/s BenchmarkFanOut_128x10x10000-16 363 9921533 ns/op 1481.64 MB/s BenchmarkFanOut_128x10x10000-16 362 9809417 ns/op 1498.57 MB/s BenchmarkFanOut_128x10x10000-16 366 10032043 ns/op 1465.32 MB/s BenchmarkFanOut_128x10x10000-16 363 9946857 ns/op 1477.87 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 658 5457298 ns/op 1328.52 MB/s BenchmarkFanOut__128x500x100-16 657 5430118 ns/op 1335.17 MB/s BenchmarkFanOut__128x500x100-16 657 5434391 ns/op 1334.12 MB/s BenchmarkFanOut__128x500x100-16 658 5433751 ns/op 1334.28 MB/s BenchmarkFanOut__128x500x100-16 650 5420754 ns/op 1337.48 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1918 1867002 ns/op 2833.70 MB/s Benchmark_FanOut_512x100x100-16 1909 1867673 ns/op 2832.68 MB/s Benchmark_FanOut_512x100x100-16 1935 1879380 ns/op 2815.04 MB/s Benchmark_FanOut_512x100x100-16 1933 1881066 ns/op 2812.51 MB/s Benchmark_FanOut_512x100x100-16 1926 1858038 ns/op 2847.37 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 211 17282844 ns/op 3066.66 MB/s Benchmark__FanOut_512x100x1k-16 211 17061290 ns/op 3106.48 MB/s Benchmark__FanOut_512x100x1k-16 214 16680732 ns/op 3177.35 MB/s Benchmark__FanOut_512x100x1k-16 208 16780222 ns/op 3158.51 MB/s Benchmark__FanOut_512x100x1k-16 210 16918167 ns/op 3132.76 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2956 1151934 ns/op 9055.24 MB/s Benchmark____FanOut_1kx10x1k-16 3088 1152087 ns/op 9054.04 MB/s Benchmark____FanOut_1kx10x1k-16 2954 1186104 ns/op 8794.37 MB/s Benchmark____FanOut_1kx10x1k-16 3013 1175716 ns/op 8872.08 MB/s Benchmark____FanOut_1kx10x1k-16 3097 1180164 ns/op 8838.63 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2740 1282478 ns/op 8125.70 MB/s Benchmark__FanOut_1kx100x100-16 2672 1276883 ns/op 8161.31 MB/s Benchmark__FanOut_1kx100x100-16 2716 1282687 ns/op 8124.38 MB/s Benchmark__FanOut_1kx100x100-16 2697 1280465 ns/op 8138.48 MB/s Benchmark__FanOut_1kx100x100-16 2707 1280166 ns/op 8140.38 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4490869 793.6 ns/op 313.77 MB/s Benchmark_____RFanOut_8x1x10-16 4410841 782.4 ns/op 318.25 MB/s Benchmark_____RFanOut_8x1x10-16 4431644 804.7 ns/op 309.44 MB/s Benchmark_____RFanOut_8x1x10-16 4246789 793.8 ns/op 313.68 MB/s Benchmark_____RFanOut_8x1x10-16 4395307 782.5 ns/op 318.22 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 500988 6655 ns/op 348.47 MB/s Benchmark____RFanOut_8x1x100-16 518781 6325 ns/op 366.64 MB/s Benchmark____RFanOut_8x1x100-16 527836 6353 ns/op 365.03 MB/s Benchmark____RFanOut_8x1x100-16 547597 6415 ns/op 361.49 MB/s Benchmark____RFanOut_8x1x100-16 507402 6377 ns/op 363.64 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46144 77863 ns/op 295.64 MB/s Benchmark___RFanOut_8x10x100-16 46372 77291 ns/op 297.82 MB/s Benchmark___RFanOut_8x10x100-16 47001 76860 ns/op 299.49 MB/s Benchmark___RFanOut_8x10x100-16 46176 78893 ns/op 291.77 MB/s Benchmark___RFanOut_8x10x100-16 46477 78999 ns/op 291.38 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5787 632592 ns/op 379.42 MB/s Benchmark__RFanOut_8x10x1000-16 5620 622121 ns/op 385.81 MB/s Benchmark__RFanOut_8x10x1000-16 5598 639836 ns/op 375.13 MB/s Benchmark__RFanOut_8x10x1000-16 5612 628284 ns/op 382.02 MB/s Benchmark__RFanOut_8x10x1000-16 5582 649848 ns/op 369.35 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4836 740168 ns/op 310.77 MB/s Benchmark__RFanOut_8x100x100-16 4852 723707 ns/op 317.83 MB/s Benchmark__RFanOut_8x100x100-16 4824 729489 ns/op 315.32 MB/s Benchmark__RFanOut_8x100x100-16 4759 726142 ns/op 316.77 MB/s Benchmark__RFanOut_8x100x100-16 4832 723138 ns/op 318.08 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 536 6468014 ns/op 371.06 MB/s Benchmark_RFanOut_8x100x1000-16 550 6427085 ns/op 373.42 MB/s Benchmark_RFanOut_8x100x1000-16 543 6481595 ns/op 370.28 MB/s Benchmark_RFanOut_8x100x1000-16 550 6568396 ns/op 365.39 MB/s Benchmark_RFanOut_8x100x1000-16 542 6526215 ns/op 367.75 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 518 6984836 ns/op 357.92 MB/s Benchmark_RFanOut_8x10x10000-16 519 7000587 ns/op 357.12 MB/s Benchmark_RFanOut_8x10x10000-16 522 6968012 ns/op 358.79 MB/s Benchmark_RFanOut_8x10x10000-16 517 7029512 ns/op 355.65 MB/s Benchmark_RFanOut_8x10x10000-16 508 6880805 ns/op 363.33 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3172 1171097 ns/op 8907.07 MB/s Benchmark_RFanOut_1kx10x1000-16 2941 1146147 ns/op 9100.96 MB/s Benchmark_RFanOut_1kx10x1000-16 3027 1163289 ns/op 8966.85 MB/s Benchmark_RFanOut_1kx10x1000-16 3056 1169879 ns/op 8916.34 MB/s Benchmark_RFanOut_1kx10x1000-16 2850 1164217 ns/op 8959.70 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6849650 510.2 ns/op 4073.02 MB/s Benchmark_____FanIn_1kx100x1-16 6898056 511.1 ns/op 4065.54 MB/s Benchmark_____FanIn_1kx100x1-16 6842455 510.6 ns/op 4069.43 MB/s Benchmark_____FanIn_1kx100x1-16 6852136 509.9 ns/op 4075.69 MB/s Benchmark_____FanIn_1kx100x1-16 6891510 511.9 ns/op 4059.03 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2575138 1376 ns/op 5977.31 MB/s Benchmark_____FanIn_4kx100x1-16 2570655 1362 ns/op 6035.89 MB/s Benchmark_____FanIn_4kx100x1-16 2653910 1360 ns/op 6044.53 MB/s Benchmark_____FanIn_4kx100x1-16 2530306 1352 ns/op 6081.08 MB/s Benchmark_____FanIn_4kx100x1-16 2584706 1369 ns/op 6005.66 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1683394 2128 ns/op 7711.97 MB/s Benchmark_____FanIn_8kx100x1-16 1697686 2088 ns/op 7862.42 MB/s Benchmark_____FanIn_8kx100x1-16 1707405 2109 ns/op 7782.09 MB/s Benchmark_____FanIn_8kx100x1-16 1712744 2138 ns/op 7675.93 MB/s Benchmark_____FanIn_8kx100x1-16 1680775 2112 ns/op 7773.07 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 862021 4148 ns/op 7906.93 MB/s Benchmark____FanIn_16kx100x1-16 861452 4135 ns/op 7931.65 MB/s Benchmark____FanIn_16kx100x1-16 875092 4159 ns/op 7886.14 MB/s Benchmark____FanIn_16kx100x1-16 879062 4193 ns/op 7822.08 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 288427986 vs 14124541200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33062->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33380->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_16kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32850->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60820->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 164440 19682 ns/op 6661.07 MB/s Benchmark____FanIn_64kx100x1-16 166260 19770 ns/op 6631.62 MB/s Benchmark____FanIn_64kx100x1-16 159654 19923 ns/op 6580.44 MB/s Benchmark____FanIn_64kx100x1-16 168825 19929 ns/op 6578.43 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1820996787 vs 10999793400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46702->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46588->127.0.0.1:5222: write: connection reset by peer Benchmark___FanIn_128kx100x1 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46670->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 607602150 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48346->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48390->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1060780280 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50234->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50324->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50422->127.0.0.1:5222: write: broken pipe bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 351190110 vs 11483484000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53052->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1083327760 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55392->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 155997100 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56908->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5430782 650.5 ns/op 436.57 MB/s Benchmark___BumpPubCount_1x3-16 5526801 649.4 ns/op 437.32 MB/s Benchmark___BumpPubCount_1x3-16 5523903 651.0 ns/op 436.24 MB/s Benchmark___BumpPubCount_1x3-16 5530899 646.8 ns/op 439.08 MB/s Benchmark___BumpPubCount_1x3-16 5553829 648.9 ns/op 437.69 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5134112 688.0 ns/op 412.80 MB/s Benchmark___BumpPubCount_2x3-16 5215916 682.1 ns/op 416.38 MB/s Benchmark___BumpPubCount_2x3-16 5186944 683.8 ns/op 415.35 MB/s Benchmark___BumpPubCount_2x3-16 5174736 686.8 ns/op 413.54 MB/s Benchmark___BumpPubCount_2x3-16 5136205 680.1 ns/op 417.57 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5460909 655.3 ns/op 433.39 MB/s Benchmark___BumpPubCount_5x3-16 5370976 653.7 ns/op 434.48 MB/s Benchmark___BumpPubCount_5x3-16 5512184 651.3 ns/op 436.04 MB/s Benchmark___BumpPubCount_5x3-16 5433644 654.4 ns/op 434.01 MB/s Benchmark___BumpPubCount_5x3-16 5083036 654.5 ns/op 433.91 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5460765 654.9 ns/op 433.67 MB/s Benchmark__BumpPubCount_10x3-16 5486955 655.9 ns/op 432.97 MB/s Benchmark__BumpPubCount_10x3-16 5499572 654.9 ns/op 433.63 MB/s Benchmark__BumpPubCount_10x3-16 5502871 655.8 ns/op 433.03 MB/s Benchmark__BumpPubCount_10x3-16 5479260 652.9 ns/op 434.99 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12461667 268.9 ns/op 3867.74 MB/s Benchmark____GWs_Opt_1kx01x0-16 11519259 271.5 ns/op 3830.62 MB/s Benchmark____GWs_Opt_1kx01x0-16 12663100 271.1 ns/op 3835.78 MB/s Benchmark____GWs_Opt_1kx01x0-16 12625170 272.1 ns/op 3822.70 MB/s Benchmark____GWs_Opt_1kx01x0-16 12458660 273.4 ns/op 3803.66 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9394736 343.8 ns/op 6002.64 MB/s Benchmark____GWs_Opt_2kx01x0-16 10543389 341.2 ns/op 6049.96 MB/s Benchmark____GWs_Opt_2kx01x0-16 10686666 334.3 ns/op 6173.61 MB/s Benchmark____GWs_Opt_2kx01x0-16 10455747 343.6 ns/op 6007.17 MB/s Benchmark____GWs_Opt_2kx01x0-16 10372928 341.0 ns/op 6053.38 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5320216 642.5 ns/op 6400.05 MB/s Benchmark____GWs_Opt_4kx01x0-16 5246319 726.4 ns/op 5661.03 MB/s Benchmark____GWs_Opt_4kx01x0-16 5222750 649.9 ns/op 6327.25 MB/s Benchmark____GWs_Opt_4kx01x0-16 5228264 649.9 ns/op 6326.65 MB/s Benchmark____GWs_Opt_4kx01x0-16 5252746 645.4 ns/op 6370.81 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 27172197 116.9 ns/op 8895.69 MB/s Benchmark____GWs_Opt_1kx10x0-16 31648946 114.4 ns/op 9091.88 MB/s Benchmark____GWs_Opt_1kx10x0-16 31243323 114.0 ns/op 9121.37 MB/s Benchmark____GWs_Opt_1kx10x0-16 31356662 107.3 ns/op 9689.76 MB/s Benchmark____GWs_Opt_1kx10x0-16 32489983 115.9 ns/op 8975.34 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 21684290 154.8 ns/op 13332.06 MB/s Benchmark____GWs_Opt_2kx10x0-16 25917066 142.5 ns/op 14480.76 MB/s Benchmark____GWs_Opt_2kx10x0-16 25178773 143.5 ns/op 14380.64 MB/s Benchmark____GWs_Opt_2kx10x0-16 20868751 150.9 ns/op 13680.14 MB/s Benchmark____GWs_Opt_2kx10x0-16 24896641 169.3 ns/op 12190.15 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 13084261 300.4 ns/op 13686.97 MB/s Benchmark____GWs_Opt_4kx10x0-16 12466819 291.8 ns/op 14090.28 MB/s Benchmark____GWs_Opt_4kx10x0-16 12596924 298.5 ns/op 13775.09 MB/s Benchmark____GWs_Opt_4kx10x0-16 11730759 344.0 ns/op 11952.20 MB/s Benchmark____GWs_Opt_4kx10x0-16 12688957 327.9 ns/op 12539.02 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6491876 567.5 ns/op 5506.73 MB/s Benchmark____GWs_Opt_1kx01x1-16 6541836 554.1 ns/op 5639.66 MB/s Benchmark____GWs_Opt_1kx01x1-16 6530421 563.4 ns/op 5546.33 MB/s Benchmark____GWs_Opt_1kx01x1-16 6528351 561.8 ns/op 5562.60 MB/s Benchmark____GWs_Opt_1kx01x1-16 6433209 564.9 ns/op 5531.65 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4574068 1105 ns/op 5606.69 MB/s Benchmark____GWs_Opt_2kx01x1-16 4425258 819.9 ns/op 7558.49 MB/s Benchmark____GWs_Opt_2kx01x1-16 4620438 2366 ns/op 2618.85 MB/s Benchmark____GWs_Opt_2kx01x1-16 4458252 793.9 ns/op 7806.15 MB/s Benchmark____GWs_Opt_2kx01x1-16 4655534 770.0 ns/op 8047.92 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2463819 1404 ns/op 8790.38 MB/s Benchmark____GWs_Opt_4kx01x1-16 2590184 1385 ns/op 8908.89 MB/s Benchmark____GWs_Opt_4kx01x1-16 2580021 1373 ns/op 8991.08 MB/s Benchmark____GWs_Opt_4kx01x1-16 2571440 1421 ns/op 8683.56 MB/s Benchmark____GWs_Opt_4kx01x1-16 2590095 1395 ns/op 8846.06 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6155917 561.1 ns/op 5569.41 MB/s Benchmark____GWs_Opt_1kx10x1-16 6038496 568.6 ns/op 5496.21 MB/s Benchmark____GWs_Opt_1kx10x1-16 6008911 560.6 ns/op 5574.84 MB/s Benchmark____GWs_Opt_1kx10x1-16 5999847 556.6 ns/op 5614.71 MB/s Benchmark____GWs_Opt_1kx10x1-16 6030368 565.8 ns/op 5523.35 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4061977 842.9 ns/op 7351.85 MB/s Benchmark____GWs_Opt_2kx10x1-16 4130848 855.8 ns/op 7240.93 MB/s Benchmark____GWs_Opt_2kx10x1-16 4090155 858.7 ns/op 7217.11 MB/s Benchmark____GWs_Opt_2kx10x1-16 4114761 857.9 ns/op 7223.74 MB/s Benchmark____GWs_Opt_2kx10x1-16 4236585 863.5 ns/op 7176.69 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2220012 1550 ns/op 7960.29 MB/s Benchmark____GWs_Opt_4kx10x1-16 2132132 1539 ns/op 8020.68 MB/s Benchmark____GWs_Opt_4kx10x1-16 2312749 1559 ns/op 7915.45 MB/s Benchmark____GWs_Opt_4kx10x1-16 2283615 1524 ns/op 8098.47 MB/s Benchmark____GWs_Opt_4kx10x1-16 2317444 1552 ns/op 7949.47 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12869874 303.2 ns/op 3430.50 MB/s Benchmark____GWs_Int_1kx01x0-16 12951088 291.1 ns/op 3572.90 MB/s Benchmark____GWs_Int_1kx01x0-16 12801590 298.2 ns/op 3487.76 MB/s Benchmark____GWs_Int_1kx01x0-16 12760737 284.6 ns/op 3654.45 MB/s Benchmark____GWs_Int_1kx01x0-16 12314983 276.2 ns/op 3765.64 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10122379 369.7 ns/op 5583.26 MB/s Benchmark____GWs_Int_2kx01x0-16 9741752 347.8 ns/op 5933.97 MB/s Benchmark____GWs_Int_2kx01x0-16 9807572 369.1 ns/op 5592.27 MB/s Benchmark____GWs_Int_2kx01x0-16 10230992 360.1 ns/op 5731.17 MB/s Benchmark____GWs_Int_2kx01x0-16 10341578 365.8 ns/op 5641.96 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5373104 670.6 ns/op 6131.61 MB/s Benchmark____GWs_Int_4kx01x0-16 5202094 667.6 ns/op 6159.64 MB/s Benchmark____GWs_Int_4kx01x0-16 5122326 670.7 ns/op 6130.49 MB/s Benchmark____GWs_Int_4kx01x0-16 5318820 669.0 ns/op 6146.71 MB/s Benchmark____GWs_Int_4kx01x0-16 5523702 729.6 ns/op 5635.72 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31501784 115.8 ns/op 8982.15 MB/s Benchmark____GWs_Int_1kx10x0-16 32016828 123.2 ns/op 8441.57 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:40348->127.0.0.1:39511: use of closed network connection --- FAIL: Benchmark____GWs_Int_1kx10x0-16 Benchmark____GWs_Int_1kx10x0-16 31484840 111.7 ns/op 9313.81 MB/s Benchmark____GWs_Int_1kx10x0-16 28491678 112.8 ns/op 9219.93 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 21443061 149.2 ns/op 13832.15 MB/s Benchmark____GWs_Int_2kx10x0-16 25696080 143.5 ns/op 14387.17 MB/s Benchmark____GWs_Int_2kx10x0-16 25849509 153.6 ns/op 13436.72 MB/s Benchmark____GWs_Int_2kx10x0-16 25220580 144.2 ns/op 14317.93 MB/s Benchmark____GWs_Int_2kx10x0-16 23107134 145.2 ns/op 14215.37 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12384440 318.4 ns/op 12916.21 MB/s Benchmark____GWs_Int_4kx10x0-16 12139812 317.7 ns/op 12945.00 MB/s Benchmark____GWs_Int_4kx10x0-16 13146584 331.4 ns/op 12406.30 MB/s Benchmark____GWs_Int_4kx10x0-16 13072126 289.7 ns/op 14192.85 MB/s Benchmark____GWs_Int_4kx10x0-16 12704196 291.7 ns/op 14098.94 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6559201 561.9 ns/op 5561.98 MB/s Benchmark____GWs_Int_1kx01x1-16 6410074 559.5 ns/op 5585.08 MB/s Benchmark____GWs_Int_1kx01x1-16 6330838 568.5 ns/op 5496.80 MB/s Benchmark____GWs_Int_1kx01x1-16 6238663 564.6 ns/op 5535.24 MB/s Benchmark____GWs_Int_1kx01x1-16 6455526 570.5 ns/op 5478.01 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4471269 774.3 ns/op 8003.55 MB/s Benchmark____GWs_Int_2kx01x1-16 4619091 894.5 ns/op 6928.26 MB/s Benchmark____GWs_Int_2kx01x1-16 4565656 784.1 ns/op 7903.62 MB/s Benchmark____GWs_Int_2kx01x1-16 4656550 800.2 ns/op 7744.45 MB/s Benchmark____GWs_Int_2kx01x1-16 4597186 793.8 ns/op 7806.53 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2586262 1386 ns/op 8905.53 MB/s Benchmark____GWs_Int_4kx01x1-16 2559129 1400 ns/op 8817.45 MB/s Benchmark____GWs_Int_4kx01x1-16 2591608 1405 ns/op 8781.90 MB/s Benchmark____GWs_Int_4kx01x1-16 2522689 1468 ns/op 8404.19 MB/s Benchmark____GWs_Int_4kx01x1-16 2449568 1779 ns/op 6937.71 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6369108 568.7 ns/op 5495.28 MB/s Benchmark____GWs_Int_1kx10x1-16 5803962 569.4 ns/op 5488.18 MB/s Benchmark____GWs_Int_1kx10x1-16 6026896 617.7 ns/op 5058.74 MB/s Benchmark____GWs_Int_1kx10x1-16 6189936 561.6 ns/op 5564.31 MB/s Benchmark____GWs_Int_1kx10x1-16 6050378 568.3 ns/op 5498.65 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4095798 862.6 ns/op 7183.78 MB/s Benchmark____GWs_Int_2kx10x1-16 4171850 861.5 ns/op 7193.60 MB/s Benchmark____GWs_Int_2kx10x1-16 4075850 885.4 ns/op 6999.22 MB/s Benchmark____GWs_Int_2kx10x1-16 4177411 861.9 ns/op 7189.93 MB/s Benchmark____GWs_Int_2kx10x1-16 4079302 850.7 ns/op 7284.35 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2327785 1541 ns/op 8006.34 MB/s Benchmark____GWs_Int_4kx10x1-16 2274039 1527 ns/op 8084.04 MB/s Benchmark____GWs_Int_4kx10x1-16 2261619 1580 ns/op 7812.66 MB/s Benchmark____GWs_Int_4kx10x1-16 2419602 1528 ns/op 8074.00 MB/s Benchmark____GWs_Int_4kx10x1-16 2309828 1516 ns/op 8140.14 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8055411 438.1 ns/op 232.83 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8221249 443.8 ns/op 229.82 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8203852 442.2 ns/op 230.64 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8317465 443.2 ns/op 230.13 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8536394 434.0 ns/op 235.02 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 603157 5038 ns/op 35.13 MB/s Benchmark__GWs_Reqs_1SubEach-16 744628 5148 ns/op 34.38 MB/s Benchmark__GWs_Reqs_1SubEach-16 767738 5365 ns/op 32.99 MB/s Benchmark__GWs_Reqs_1SubEach-16 727340 5249 ns/op 33.72 MB/s Benchmark__GWs_Reqs_1SubEach-16 743665 5265 ns/op 33.62 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2077.536s ❌ Non-zero exit code: 1