> ROOT_DIR=/tmp/go-bench-away-job-84e754b6-cbe0-4cec-8982-51978987298c-2827780987 > OUTPUT_FILE=/tmp/go-bench-away-job-84e754b6-cbe0-4cec-8982-51978987298c-2827780987/results.txt > SHA_FILE=/tmp/go-bench-away-job-84e754b6-cbe0-4cec-8982-51978987298c-2827780987/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-84e754b6-cbe0-4cec-8982-51978987298c-2827780987/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=v2.12.9 > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.25.4/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: v2.12.9 to /tmp/go-bench-away-job-84e754b6-cbe0-4cec-8982-51978987298c-2827780987/source.git SHA of v2.12.9: 376c9296d413fae95e363101f6310e9f1b422521 Go runtime: go version go1.26.0 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-build922188674=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-84e754b6-cbe0-4cec-8982-51978987298c-2827780987/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.25.4' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.25.4/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.0' 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 43101975 72.82 ns/op 151.06 MB/s Benchmark______Pub0b_Payload-16 46832780 73.31 ns/op 150.04 MB/s Benchmark______Pub0b_Payload-16 46953993 73.39 ns/op 149.88 MB/s Benchmark______Pub0b_Payload-16 46630048 73.00 ns/op 150.69 MB/s Benchmark______Pub0b_Payload-16 47099392 72.75 ns/op 151.20 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46162054 73.61 ns/op 258.11 MB/s Benchmark______Pub8b_Payload-16 46177894 73.30 ns/op 259.19 MB/s Benchmark______Pub8b_Payload-16 46414488 73.71 ns/op 257.78 MB/s Benchmark______Pub8b_Payload-16 46332282 73.76 ns/op 257.59 MB/s Benchmark______Pub8b_Payload-16 46726357 73.40 ns/op 258.85 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 40896247 78.57 ns/op 559.98 MB/s Benchmark_____Pub32b_Payload-16 46003774 80.43 ns/op 547.06 MB/s Benchmark_____Pub32b_Payload-16 43606215 77.90 ns/op 564.80 MB/s Benchmark_____Pub32b_Payload-16 43212532 78.15 ns/op 563.05 MB/s Benchmark_____Pub32b_Payload-16 43675060 78.07 ns/op 563.59 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38322276 87.93 ns/op 1603.50 MB/s Benchmark____Pub128B_Payload-16 38934207 88.47 ns/op 1593.83 MB/s Benchmark____Pub128B_Payload-16 38013739 89.33 ns/op 1578.43 MB/s Benchmark____Pub128B_Payload-16 37650080 90.46 ns/op 1558.67 MB/s Benchmark____Pub128B_Payload-16 38095598 89.83 ns/op 1569.69 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 37716668 99.74 ns/op 2696.90 MB/s Benchmark____Pub256B_Payload-16 34042686 96.89 ns/op 2776.20 MB/s Benchmark____Pub256B_Payload-16 32038135 99.25 ns/op 2710.27 MB/s Benchmark____Pub256B_Payload-16 35324142 96.25 ns/op 2794.85 MB/s Benchmark____Pub256B_Payload-16 36333399 95.53 ns/op 2815.79 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24266305 139.4 ns/op 7447.49 MB/s Benchmark______Pub1K_Payload-16 23829648 135.5 ns/op 7662.04 MB/s Benchmark______Pub1K_Payload-16 24764625 136.5 ns/op 7603.98 MB/s Benchmark______Pub1K_Payload-16 23974795 139.4 ns/op 7447.99 MB/s Benchmark______Pub1K_Payload-16 24414186 139.4 ns/op 7446.60 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5377371 622.5 ns/op 6601.92 MB/s Benchmark______Pub4K_Payload-16 5729337 626.9 ns/op 6555.68 MB/s Benchmark______Pub4K_Payload-16 5380486 622.1 ns/op 6606.66 MB/s Benchmark______Pub4K_Payload-16 5651794 617.5 ns/op 6655.46 MB/s Benchmark______Pub4K_Payload-16 5375583 613.7 ns/op 6697.10 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2790409 1282 ns/op 6403.32 MB/s Benchmark______Pub8K_Payload-16 2730597 1275 ns/op 6435.31 MB/s Benchmark______Pub8K_Payload-16 2633910 1274 ns/op 6440.54 MB/s Benchmark______Pub8K_Payload-16 2806290 1279 ns/op 6415.54 MB/s Benchmark______Pub8K_Payload-16 2670646 1276 ns/op 6432.13 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 669706 5433 ns/op 6034.11 MB/s Benchmark_____Pub32K_Payload-16 655033 5428 ns/op 6039.34 MB/s Benchmark_____Pub32K_Payload-16 659167 5473 ns/op 5989.83 MB/s Benchmark_____Pub32K_Payload-16 658964 5404 ns/op 6066.81 MB/s Benchmark_____Pub32K_Payload-16 614941 5501 ns/op 5959.73 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31833730 95.35 ns/op 115.37 MB/s Benchmark__AuthPub0b_Payload-16 37728586 95.31 ns/op 115.41 MB/s Benchmark__AuthPub0b_Payload-16 32903112 95.38 ns/op 115.33 MB/s Benchmark__AuthPub0b_Payload-16 35931637 95.56 ns/op 115.11 MB/s Benchmark__AuthPub0b_Payload-16 31722625 95.73 ns/op 114.91 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15506653 227.9 ns/op Benchmark_____________PubSub-16 15484616 229.0 ns/op Benchmark_____________PubSub-16 15454017 228.6 ns/op Benchmark_____________PubSub-16 15540069 229.7 ns/op Benchmark_____________PubSub-16 15606858 229.2 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15664818 227.5 ns/op Benchmark_____PubSubTwoConns-16 15519170 226.5 ns/op Benchmark_____PubSubTwoConns-16 15459004 229.0 ns/op Benchmark_____PubSubTwoConns-16 15699565 227.5 ns/op Benchmark_____PubSubTwoConns-16 15576301 227.5 ns/op Benchmark__PubServiceImports bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:45482->127.0.0.1:46017: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:57958->127.0.0.1:34735: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:39820->127.0.0.1:43249: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:48546->127.0.0.1:36297: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:39018->127.0.0.1:44117: 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 14356138 247.1 ns/op Benchmark_____PubTwoQueueSub-16 14259578 247.2 ns/op Benchmark_____PubTwoQueueSub-16 14173330 246.3 ns/op Benchmark_____PubTwoQueueSub-16 14198553 247.4 ns/op Benchmark_____PubTwoQueueSub-16 14418110 247.6 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14192338 247.3 ns/op Benchmark____PubFourQueueSub-16 14342721 246.7 ns/op Benchmark____PubFourQueueSub-16 14276809 247.1 ns/op Benchmark____PubFourQueueSub-16 14336284 246.7 ns/op Benchmark____PubFourQueueSub-16 14309869 246.8 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14209942 246.4 ns/op Benchmark___PubEightQueueSub-16 14507389 247.9 ns/op Benchmark___PubEightQueueSub-16 14489872 248.7 ns/op Benchmark___PubEightQueueSub-16 14304478 247.3 ns/op Benchmark___PubEightQueueSub-16 14337541 247.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22944 156326 ns/op Benchmark_PubSub512kTwoConns-16 23038 157282 ns/op Benchmark_PubSub512kTwoConns-16 23079 156163 ns/op Benchmark_PubSub512kTwoConns-16 23068 156251 ns/op Benchmark_PubSub512kTwoConns-16 23000 155558 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15137132 228.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15235388 230.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15376246 230.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15261861 230.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15390524 231.3 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15151917 230.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15133484 230.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15252262 230.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15386455 230.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15239515 229.9 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11026230 308.8 ns/op Benchmark____RoutedPubSub_0b-16 11408043 310.7 ns/op Benchmark____RoutedPubSub_0b-16 11793034 312.3 ns/op Benchmark____RoutedPubSub_0b-16 11362071 310.1 ns/op Benchmark____RoutedPubSub_0b-16 11461940 311.7 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6620306 538.3 ns/op Benchmark____RoutedPubSub_1K-16 6463303 536.8 ns/op Benchmark____RoutedPubSub_1K-16 6523063 550.1 ns/op Benchmark____RoutedPubSub_1K-16 6608810 534.5 ns/op Benchmark____RoutedPubSub_1K-16 3039625 1053 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84138 42795 ns/op Benchmark__RoutedPubSub_100K-16 80886 43046 ns/op Benchmark__RoutedPubSub_100K-16 78540 45437 ns/op Benchmark__RoutedPubSub_100K-16 77450 47032 ns/op Benchmark__RoutedPubSub_100K-16 77953 46754 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9636042 324.5 ns/op Benchmark____Routed2QueueSub-16 9578854 322.3 ns/op Benchmark____Routed2QueueSub-16 11417634 317.0 ns/op Benchmark____Routed2QueueSub-16 11428298 317.4 ns/op Benchmark____Routed2QueueSub-16 11367715 321.0 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9485112 331.0 ns/op Benchmark____Routed4QueueSub-16 11008885 325.2 ns/op Benchmark____Routed4QueueSub-16 9693884 326.2 ns/op Benchmark____Routed4QueueSub-16 9535869 326.3 ns/op Benchmark____Routed4QueueSub-16 9326697 327.9 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 10672563 339.5 ns/op Benchmark____Routed8QueueSub-16 9106038 332.6 ns/op Benchmark____Routed8QueueSub-16 9046876 341.0 ns/op Benchmark____Routed8QueueSub-16 9314347 337.7 ns/op Benchmark____Routed8QueueSub-16 10684894 330.7 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8662885 362.7 ns/op Benchmark___Routed16QueueSub-16 8710213 362.4 ns/op Benchmark___Routed16QueueSub-16 8758371 351.9 ns/op Benchmark___Routed16QueueSub-16 8855584 352.1 ns/op Benchmark___Routed16QueueSub-16 8612172 362.6 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6620554 551.2 ns/op Benchmark____________RouteCompressOff-16 6378122 479.9 ns/op Benchmark____________RouteCompressOff-16 6220077 493.1 ns/op Benchmark____________RouteCompressOff-16 6492372 470.7 ns/op Benchmark____________RouteCompressOff-16 7649319 470.9 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6693106 551.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6603747 551.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6309266 551.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6908313 452.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6327463 550.9 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6491109 551.7 ns/op Benchmark_________RouteCompressS2Fast-16 6342085 481.8 ns/op Benchmark_________RouteCompressS2Fast-16 6406628 556.3 ns/op Benchmark_________RouteCompressS2Fast-16 6428004 508.2 ns/op Benchmark_________RouteCompressS2Fast-16 6457533 553.7 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6470182 549.6 ns/op Benchmark_______RouteCompressS2Better-16 6455061 473.6 ns/op Benchmark_______RouteCompressS2Better-16 6898130 474.6 ns/op Benchmark_______RouteCompressS2Better-16 6496450 558.6 ns/op Benchmark_______RouteCompressS2Better-16 6400186 517.9 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6268588 557.2 ns/op Benchmark_________RouteCompressS2Best-16 6288738 564.1 ns/op Benchmark_________RouteCompressS2Best-16 6484837 563.7 ns/op Benchmark_________RouteCompressS2Best-16 6369771 564.9 ns/op Benchmark_________RouteCompressS2Best-16 6369984 562.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4634096 779.5 ns/op 319.44 MB/s Benchmark______FanOut_8x1x10-16 4621626 776.5 ns/op 320.68 MB/s Benchmark______FanOut_8x1x10-16 4607775 774.9 ns/op 321.33 MB/s Benchmark______FanOut_8x1x10-16 4605556 776.6 ns/op 320.64 MB/s Benchmark______FanOut_8x1x10-16 4621861 772.5 ns/op 322.31 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 531338 6195 ns/op 374.34 MB/s Benchmark_____FanOut_8x1x100-16 555369 6203 ns/op 373.85 MB/s Benchmark_____FanOut_8x1x100-16 535887 6204 ns/op 373.82 MB/s Benchmark_____FanOut_8x1x100-16 550017 6343 ns/op 365.57 MB/s Benchmark_____FanOut_8x1x100-16 544232 6201 ns/op 373.97 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47960 75372 ns/op 305.41 MB/s Benchmark____FanOut_8x10x100-16 47748 75135 ns/op 306.37 MB/s Benchmark____FanOut_8x10x100-16 47918 75310 ns/op 305.66 MB/s Benchmark____FanOut_8x10x100-16 47582 75236 ns/op 305.96 MB/s Benchmark____FanOut_8x10x100-16 47865 75076 ns/op 306.61 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5968 595952 ns/op 402.75 MB/s Benchmark___FanOut_8x10x1000-16 5911 605023 ns/op 396.71 MB/s Benchmark___FanOut_8x10x1000-16 5602 602098 ns/op 398.64 MB/s Benchmark___FanOut_8x10x1000-16 6061 602376 ns/op 398.45 MB/s Benchmark___FanOut_8x10x1000-16 5948 600518 ns/op 399.69 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5149 719943 ns/op 319.50 MB/s Benchmark___FanOut_8x100x100-16 4941 712344 ns/op 322.90 MB/s Benchmark___FanOut_8x100x100-16 4954 709370 ns/op 324.26 MB/s Benchmark___FanOut_8x100x100-16 5017 717731 ns/op 320.48 MB/s Benchmark___FanOut_8x100x100-16 5000 711017 ns/op 323.51 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 572 6177989 ns/op 388.48 MB/s Benchmark__FanOut_8x100x1000-16 574 6167286 ns/op 389.15 MB/s Benchmark__FanOut_8x100x1000-16 583 6136761 ns/op 391.09 MB/s Benchmark__FanOut_8x100x1000-16 567 6149166 ns/op 390.30 MB/s Benchmark__FanOut_8x100x1000-16 572 6150574 ns/op 390.21 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 526 6736558 ns/op 371.11 MB/s Benchmark__FanOut_8x10x10000-16 534 6705615 ns/op 372.82 MB/s Benchmark__FanOut_8x10x10000-16 523 6737234 ns/op 371.08 MB/s Benchmark__FanOut_8x10x10000-16 525 6767150 ns/op 369.43 MB/s Benchmark__FanOut_8x10x10000-16 530 6737873 ns/op 371.04 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 938 3762673 ns/op 305.64 MB/s Benchmark___FanOut_8x500x100-16 948 3758523 ns/op 305.98 MB/s Benchmark___FanOut_8x500x100-16 949 3765254 ns/op 305.43 MB/s Benchmark___FanOut_8x500x100-16 950 3763862 ns/op 305.54 MB/s Benchmark___FanOut_8x500x100-16 948 3758562 ns/op 305.97 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 360874 9652 ns/op 1516.92 MB/s Benchmark___FanOut_128x1x100-16 348453 9703 ns/op 1508.87 MB/s Benchmark___FanOut_128x1x100-16 337624 9691 ns/op 1510.80 MB/s Benchmark___FanOut_128x1x100-16 355191 9657 ns/op 1516.15 MB/s Benchmark___FanOut_128x1x100-16 363756 9716 ns/op 1506.85 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32478 111263 ns/op 1304.49 MB/s Benchmark__FanOut_128x10x100-16 32602 111139 ns/op 1305.94 MB/s Benchmark__FanOut_128x10x100-16 32352 110844 ns/op 1309.42 MB/s Benchmark__FanOut_128x10x100-16 32544 111218 ns/op 1305.02 MB/s Benchmark__FanOut_128x10x100-16 32234 111189 ns/op 1305.35 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4129 886715 ns/op 1646.69 MB/s Benchmark_FanOut_128x10x1000-16 3987 884297 ns/op 1651.19 MB/s Benchmark_FanOut_128x10x1000-16 4107 883073 ns/op 1653.48 MB/s Benchmark_FanOut_128x10x1000-16 3913 884128 ns/op 1651.50 MB/s Benchmark_FanOut_128x10x1000-16 4072 880828 ns/op 1657.69 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3470 1020037 ns/op 1421.66 MB/s Benchmark_FanOut_128x100x100-16 3432 1009809 ns/op 1436.05 MB/s Benchmark_FanOut_128x100x100-16 3439 1016857 ns/op 1426.10 MB/s Benchmark_FanOut_128x100x100-16 3500 1019300 ns/op 1422.68 MB/s Benchmark_FanOut_128x100x100-16 3445 1017904 ns/op 1424.63 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 381 9308169 ns/op 1568.53 MB/s BenchmarkFanOut_128x100x1000-16 382 9403734 ns/op 1552.59 MB/s BenchmarkFanOut_128x100x1000-16 378 9319608 ns/op 1566.60 MB/s BenchmarkFanOut_128x100x1000-16 376 9393164 ns/op 1554.34 MB/s BenchmarkFanOut_128x100x1000-16 381 9341121 ns/op 1563.00 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 368 9676820 ns/op 1519.11 MB/s BenchmarkFanOut_128x10x10000-16 375 9650296 ns/op 1523.28 MB/s BenchmarkFanOut_128x10x10000-16 373 9672564 ns/op 1519.78 MB/s BenchmarkFanOut_128x10x10000-16 372 9668901 ns/op 1520.35 MB/s BenchmarkFanOut_128x10x10000-16 366 9665299 ns/op 1520.92 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 667 5290008 ns/op 1370.53 MB/s BenchmarkFanOut__128x500x100-16 660 5297826 ns/op 1368.51 MB/s BenchmarkFanOut__128x500x100-16 666 5298194 ns/op 1368.42 MB/s BenchmarkFanOut__128x500x100-16 673 5430969 ns/op 1334.96 MB/s BenchmarkFanOut__128x500x100-16 667 5291637 ns/op 1370.11 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1958 1830428 ns/op 2890.32 MB/s Benchmark_FanOut_512x100x100-16 1938 1836016 ns/op 2881.52 MB/s Benchmark_FanOut_512x100x100-16 1911 1860908 ns/op 2842.98 MB/s Benchmark_FanOut_512x100x100-16 1945 1855405 ns/op 2851.41 MB/s Benchmark_FanOut_512x100x100-16 1940 1831797 ns/op 2888.16 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 217 16707631 ns/op 3172.23 MB/s Benchmark__FanOut_512x100x1k-16 214 16874915 ns/op 3140.79 MB/s Benchmark__FanOut_512x100x1k-16 213 16741962 ns/op 3165.73 MB/s Benchmark__FanOut_512x100x1k-16 214 16776045 ns/op 3159.30 MB/s Benchmark__FanOut_512x100x1k-16 216 16794503 ns/op 3155.83 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3126 1148510 ns/op 9082.23 MB/s Benchmark____FanOut_1kx10x1k-16 3205 1157272 ns/op 9013.47 MB/s Benchmark____FanOut_1kx10x1k-16 3234 1158214 ns/op 9006.14 MB/s Benchmark____FanOut_1kx10x1k-16 2986 1136875 ns/op 9175.19 MB/s Benchmark____FanOut_1kx10x1k-16 3146 1157404 ns/op 9012.44 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2746 1259300 ns/op 8275.26 MB/s Benchmark__FanOut_1kx100x100-16 2768 1258037 ns/op 8283.57 MB/s Benchmark__FanOut_1kx100x100-16 2760 1265864 ns/op 8232.35 MB/s Benchmark__FanOut_1kx100x100-16 2732 1253955 ns/op 8310.53 MB/s Benchmark__FanOut_1kx100x100-16 2811 1257832 ns/op 8284.92 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4304559 811.7 ns/op 306.76 MB/s Benchmark_____RFanOut_8x1x10-16 4287970 822.1 ns/op 302.87 MB/s Benchmark_____RFanOut_8x1x10-16 4195251 824.3 ns/op 302.08 MB/s Benchmark_____RFanOut_8x1x10-16 4204503 827.2 ns/op 301.01 MB/s Benchmark_____RFanOut_8x1x10-16 4329019 822.4 ns/op 302.78 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 478360 6680 ns/op 347.14 MB/s Benchmark____RFanOut_8x1x100-16 494416 6609 ns/op 350.88 MB/s Benchmark____RFanOut_8x1x100-16 517592 6768 ns/op 342.65 MB/s Benchmark____RFanOut_8x1x100-16 504993 6641 ns/op 349.22 MB/s Benchmark____RFanOut_8x1x100-16 486049 6638 ns/op 349.37 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 43548 81681 ns/op 281.82 MB/s Benchmark___RFanOut_8x10x100-16 44145 81520 ns/op 282.37 MB/s Benchmark___RFanOut_8x10x100-16 43836 81576 ns/op 282.18 MB/s Benchmark___RFanOut_8x10x100-16 44343 81884 ns/op 281.12 MB/s Benchmark___RFanOut_8x10x100-16 44248 81670 ns/op 281.86 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5080 686437 ns/op 349.66 MB/s Benchmark__RFanOut_8x10x1000-16 5308 675441 ns/op 355.35 MB/s Benchmark__RFanOut_8x10x1000-16 5026 682545 ns/op 351.65 MB/s Benchmark__RFanOut_8x10x1000-16 5281 671461 ns/op 357.46 MB/s Benchmark__RFanOut_8x10x1000-16 5340 677329 ns/op 354.36 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4569 768283 ns/op 299.39 MB/s Benchmark__RFanOut_8x100x100-16 4550 766519 ns/op 300.08 MB/s Benchmark__RFanOut_8x100x100-16 4600 766574 ns/op 300.06 MB/s Benchmark__RFanOut_8x100x100-16 4633 762185 ns/op 301.79 MB/s Benchmark__RFanOut_8x100x100-16 4550 771205 ns/op 298.26 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 507 6959796 ns/op 344.84 MB/s Benchmark_RFanOut_8x100x1000-16 511 6959637 ns/op 344.85 MB/s Benchmark_RFanOut_8x100x1000-16 510 7063375 ns/op 339.78 MB/s Benchmark_RFanOut_8x100x1000-16 510 7062504 ns/op 339.83 MB/s Benchmark_RFanOut_8x100x1000-16 518 6916042 ns/op 347.02 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 494 7255775 ns/op 344.56 MB/s Benchmark_RFanOut_8x10x10000-16 468 7310285 ns/op 341.99 MB/s Benchmark_RFanOut_8x10x10000-16 493 7370347 ns/op 339.20 MB/s Benchmark_RFanOut_8x10x10000-16 480 7489595 ns/op 333.80 MB/s Benchmark_RFanOut_8x10x10000-16 486 7376073 ns/op 338.94 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3024 1172420 ns/op 8897.02 MB/s Benchmark_RFanOut_1kx10x1000-16 3062 1180462 ns/op 8836.41 MB/s Benchmark_RFanOut_1kx10x1000-16 2966 1171222 ns/op 8906.11 MB/s Benchmark_RFanOut_1kx10x1000-16 3081 1183623 ns/op 8812.81 MB/s Benchmark_RFanOut_1kx10x1000-16 3002 1178517 ns/op 8850.98 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6920781 508.1 ns/op 4089.90 MB/s Benchmark_____FanIn_1kx100x1-16 6861820 508.5 ns/op 4086.58 MB/s Benchmark_____FanIn_1kx100x1-16 6880095 511.1 ns/op 4065.92 MB/s Benchmark_____FanIn_1kx100x1-16 6920708 510.3 ns/op 4072.37 MB/s Benchmark_____FanIn_1kx100x1-16 6964882 509.2 ns/op 4081.31 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2614768 1374 ns/op 5984.35 MB/s Benchmark_____FanIn_4kx100x1-16 2616080 1353 ns/op 6076.31 MB/s Benchmark_____FanIn_4kx100x1-16 2599599 1371 ns/op 5996.86 MB/s Benchmark_____FanIn_4kx100x1-16 2604025 1369 ns/op 6007.06 MB/s Benchmark_____FanIn_4kx100x1-16 2619950 1366 ns/op 6019.48 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1687333 2135 ns/op 7688.98 MB/s Benchmark_____FanIn_8kx100x1-16 1677321 2133 ns/op 7695.99 MB/s Benchmark_____FanIn_8kx100x1-16 1692121 2132 ns/op 7698.26 MB/s Benchmark_____FanIn_8kx100x1-16 1697047 2123 ns/op 7730.37 MB/s Benchmark_____FanIn_8kx100x1-16 1703187 2114 ns/op 7765.91 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 849376 4113 ns/op 7974.90 MB/s Benchmark____FanIn_16kx100x1-16 863344 4130 ns/op 7942.71 MB/s Benchmark____FanIn_16kx100x1-16 877473 4155 ns/op 7893.73 MB/s Benchmark____FanIn_16kx100x1-16 866370 4130 ns/op 7941.80 MB/s Benchmark____FanIn_16kx100x1-16 860778 4192 ns/op 7824.33 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 3270963594 vs 11006348700 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:33774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:33932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33804->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 171224 19791 ns/op 6624.49 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 3884015250 vs 10862132100 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:50082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50066->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49986->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 167288 19894 ns/op 6590.12 MB/s Benchmark____FanIn_64kx100x1-16 164788 20021 ns/op 6548.43 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 816559610 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59734->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59678->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: 2785924680 vs 11837427000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34408->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34674->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: 474676890 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36080->127.0.0.1:5222: write: broken pipe bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35948->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: 851822820 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38298->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37844->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: 130827820 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39370->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5506801 648.1 ns/op 438.22 MB/s Benchmark___BumpPubCount_1x3-16 5449705 650.1 ns/op 436.83 MB/s Benchmark___BumpPubCount_1x3-16 5507712 650.1 ns/op 436.86 MB/s Benchmark___BumpPubCount_1x3-16 5532241 650.3 ns/op 436.69 MB/s Benchmark___BumpPubCount_1x3-16 5543098 645.4 ns/op 440.04 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5234227 676.0 ns/op 420.13 MB/s Benchmark___BumpPubCount_2x3-16 5167616 679.8 ns/op 417.77 MB/s Benchmark___BumpPubCount_2x3-16 5282703 677.4 ns/op 419.28 MB/s Benchmark___BumpPubCount_2x3-16 5281167 681.1 ns/op 416.96 MB/s Benchmark___BumpPubCount_2x3-16 5241718 681.1 ns/op 416.99 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5522415 648.8 ns/op 437.75 MB/s Benchmark___BumpPubCount_5x3-16 5526374 655.8 ns/op 433.09 MB/s Benchmark___BumpPubCount_5x3-16 5489431 652.7 ns/op 435.10 MB/s Benchmark___BumpPubCount_5x3-16 5474132 651.0 ns/op 436.23 MB/s Benchmark___BumpPubCount_5x3-16 5398214 652.7 ns/op 435.15 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5531599 651.4 ns/op 436.01 MB/s Benchmark__BumpPubCount_10x3-16 5536291 648.6 ns/op 437.86 MB/s Benchmark__BumpPubCount_10x3-16 5500878 651.5 ns/op 435.92 MB/s Benchmark__BumpPubCount_10x3-16 5480500 649.0 ns/op 437.58 MB/s Benchmark__BumpPubCount_10x3-16 5503642 647.9 ns/op 438.37 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12290397 286.1 ns/op 3635.32 MB/s Benchmark____GWs_Opt_1kx01x0-16 12995594 273.3 ns/op 3805.19 MB/s Benchmark____GWs_Opt_1kx01x0-16 12892428 277.0 ns/op 3754.21 MB/s Benchmark____GWs_Opt_1kx01x0-16 12552696 279.6 ns/op 3720.25 MB/s Benchmark____GWs_Opt_1kx01x0-16 12823304 272.5 ns/op 3816.72 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9812481 323.9 ns/op 6371.72 MB/s Benchmark____GWs_Opt_2kx01x0-16 10958698 343.0 ns/op 6017.48 MB/s Benchmark____GWs_Opt_2kx01x0-16 9914691 340.9 ns/op 6054.43 MB/s Benchmark____GWs_Opt_2kx01x0-16 9469556 342.8 ns/op 6020.86 MB/s Benchmark____GWs_Opt_2kx01x0-16 10799415 338.5 ns/op 6098.22 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5352651 655.9 ns/op 6269.31 MB/s Benchmark____GWs_Opt_4kx01x0-16 5223487 644.1 ns/op 6384.02 MB/s Benchmark____GWs_Opt_4kx01x0-16 4899960 659.5 ns/op 6234.78 MB/s Benchmark____GWs_Opt_4kx01x0-16 5626420 741.2 ns/op 5547.41 MB/s Benchmark____GWs_Opt_4kx01x0-16 5320699 651.2 ns/op 6314.13 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28511545 112.1 ns/op 9273.31 MB/s Benchmark____GWs_Opt_1kx10x0-16 31745119 113.9 ns/op 9128.74 MB/s Benchmark____GWs_Opt_1kx10x0-16 28522386 114.0 ns/op 9123.75 MB/s Benchmark____GWs_Opt_1kx10x0-16 32571228 113.3 ns/op 9178.97 MB/s Benchmark____GWs_Opt_1kx10x0-16 32366836 117.7 ns/op 8838.82 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25567906 156.5 ns/op 13191.47 MB/s Benchmark____GWs_Opt_2kx10x0-16 25475463 163.7 ns/op 12609.17 MB/s Benchmark____GWs_Opt_2kx10x0-16 25638712 159.6 ns/op 12935.45 MB/s Benchmark____GWs_Opt_2kx10x0-16 25220731 142.0 ns/op 14538.59 MB/s Benchmark____GWs_Opt_2kx10x0-16 21275293 149.6 ns/op 13798.50 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 10361166 289.6 ns/op 14198.46 MB/s Benchmark____GWs_Opt_4kx10x0-16 12767936 337.6 ns/op 12178.46 MB/s Benchmark____GWs_Opt_4kx10x0-16 12648615 333.0 ns/op 12349.67 MB/s Benchmark____GWs_Opt_4kx10x0-16 10762747 343.1 ns/op 11984.60 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:50166->127.0.0.1:38963: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:57316->127.0.0.1:33303: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6362337 557.1 ns/op 5609.77 MB/s Benchmark____GWs_Opt_1kx01x1-16 6446329 566.7 ns/op 5513.91 MB/s Benchmark____GWs_Opt_1kx01x1-16 6361149 554.2 ns/op 5638.31 MB/s Benchmark____GWs_Opt_1kx01x1-16 6375934 565.7 ns/op 5524.61 MB/s Benchmark____GWs_Opt_1kx01x1-16 6487026 560.8 ns/op 5571.95 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4719591 773.0 ns/op 8017.09 MB/s Benchmark____GWs_Opt_2kx01x1-16 4763745 775.0 ns/op 7996.30 MB/s Benchmark____GWs_Opt_2kx01x1-16 4774392 784.6 ns/op 7898.38 MB/s Benchmark____GWs_Opt_2kx01x1-16 4642832 775.9 ns/op 7986.91 MB/s Benchmark____GWs_Opt_2kx01x1-16 4586229 771.9 ns/op 8027.96 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2607514 1390 ns/op 8875.35 MB/s Benchmark____GWs_Opt_4kx01x1-16 2639294 1401 ns/op 8809.81 MB/s Benchmark____GWs_Opt_4kx01x1-16 2608182 1877 ns/op 6574.62 MB/s Benchmark____GWs_Opt_4kx01x1-16 2580753 1380 ns/op 8939.85 MB/s Benchmark____GWs_Opt_4kx01x1-16 2523586 1393 ns/op 8857.77 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6347730 569.2 ns/op 5490.29 MB/s Benchmark____GWs_Opt_1kx10x1-16 6095580 561.1 ns/op 5569.78 MB/s Benchmark____GWs_Opt_1kx10x1-16 6317482 569.4 ns/op 5487.78 MB/s Benchmark____GWs_Opt_1kx10x1-16 6193245 569.3 ns/op 5488.72 MB/s Benchmark____GWs_Opt_1kx10x1-16 6430434 564.1 ns/op 5539.62 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4128212 853.4 ns/op 7261.59 MB/s Benchmark____GWs_Opt_2kx10x1-16 4374618 865.8 ns/op 7157.29 MB/s Benchmark____GWs_Opt_2kx10x1-16 4252750 852.0 ns/op 7273.17 MB/s Benchmark____GWs_Opt_2kx10x1-16 4225690 867.1 ns/op 7147.10 MB/s Benchmark____GWs_Opt_2kx10x1-16 4146046 859.0 ns/op 7213.87 MB/s Benchmark____GWs_Opt_4kx10x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1386097108 vs 4114000220 bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:53552->127.0.0.1:42037: use of closed network connection bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:53550->127.0.0.1:42037: use of closed network connection bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:53548->127.0.0.1:42037: use of closed network connection bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:53534->127.0.0.1:42037: use of closed network connection bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:53518->127.0.0.1:42037: use of closed network connection bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:53504->127.0.0.1:42037: use of closed network connection bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:53496->127.0.0.1:42037: use of closed network connection bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:53484->127.0.0.1:42037: use of closed network connection bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:53478->127.0.0.1:42037: use of closed network connection bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:53476->127.0.0.1:42037: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x1-16 Benchmark____GWs_Opt_4kx10x1-16 2332400 1522 ns/op 8109.83 MB/s Benchmark____GWs_Opt_4kx10x1-16 2337123 1557 ns/op 7925.64 MB/s Benchmark____GWs_Opt_4kx10x1-16 2365712 1686 ns/op 7318.74 MB/s Benchmark____GWs_Opt_4kx10x1-16 2328709 1503 ns/op 8212.81 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12673159 289.6 ns/op 3591.76 MB/s Benchmark____GWs_Int_1kx01x0-16 12251715 295.5 ns/op 3519.96 MB/s Benchmark____GWs_Int_1kx01x0-16 12700044 283.3 ns/op 3670.72 MB/s Benchmark____GWs_Int_1kx01x0-16 12660987 284.8 ns/op 3651.47 MB/s Benchmark____GWs_Int_1kx01x0-16 12851134 298.7 ns/op 3481.60 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9990472 369.3 ns/op 5589.46 MB/s Benchmark____GWs_Int_2kx01x0-16 9789808 348.1 ns/op 5929.63 MB/s Benchmark____GWs_Int_2kx01x0-16 9627962 349.2 ns/op 5910.50 MB/s Benchmark____GWs_Int_2kx01x0-16 10438098 355.3 ns/op 5809.67 MB/s Benchmark____GWs_Int_2kx01x0-16 10753238 357.6 ns/op 5771.99 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5418291 697.7 ns/op 5894.02 MB/s Benchmark____GWs_Int_4kx01x0-16 5522284 660.6 ns/op 6224.92 MB/s Benchmark____GWs_Int_4kx01x0-16 5593596 656.6 ns/op 6262.20 MB/s Benchmark____GWs_Int_4kx01x0-16 5619049 721.9 ns/op 5696.17 MB/s Benchmark____GWs_Int_4kx01x0-16 5506386 662.8 ns/op 6204.12 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32035056 111.2 ns/op 9353.35 MB/s Benchmark____GWs_Int_1kx10x0-16 31677756 115.1 ns/op 9037.36 MB/s Benchmark____GWs_Int_1kx10x0-16 31852261 122.2 ns/op 8510.47 MB/s Benchmark____GWs_Int_1kx10x0-16 31273778 119.3 ns/op 8717.49 MB/s Benchmark____GWs_Int_1kx10x0-16 31301160 112.5 ns/op 9241.10 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 21393736 142.1 ns/op 14524.62 MB/s Benchmark____GWs_Int_2kx10x0-16 23991162 139.9 ns/op 14754.22 MB/s Benchmark____GWs_Int_2kx10x0-16 26412854 169.1 ns/op 12207.10 MB/s Benchmark____GWs_Int_2kx10x0-16 25489306 145.3 ns/op 14204.06 MB/s Benchmark____GWs_Int_2kx10x0-16 25535643 139.2 ns/op 14823.69 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12913459 300.0 ns/op 13704.87 MB/s Benchmark____GWs_Int_4kx10x0-16 12715282 329.2 ns/op 12489.77 MB/s Benchmark____GWs_Int_4kx10x0-16 12792822 302.8 ns/op 13577.80 MB/s Benchmark____GWs_Int_4kx10x0-16 9791185 378.9 ns/op 10853.07 MB/s Benchmark____GWs_Int_4kx10x0-16 12465625 287.3 ns/op 14313.22 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6298928 567.3 ns/op 5508.97 MB/s Benchmark____GWs_Int_1kx01x1-16 6266758 566.3 ns/op 5517.83 MB/s Benchmark____GWs_Int_1kx01x1-16 6351358 560.1 ns/op 5579.86 MB/s Benchmark____GWs_Int_1kx01x1-16 6299985 566.6 ns/op 5515.53 MB/s Benchmark____GWs_Int_1kx01x1-16 6477237 572.1 ns/op 5462.75 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4617379 783.7 ns/op 7907.84 MB/s Benchmark____GWs_Int_2kx01x1-16 4715605 786.6 ns/op 7877.85 MB/s Benchmark____GWs_Int_2kx01x1-16 4365204 791.0 ns/op 7834.27 MB/s Benchmark____GWs_Int_2kx01x1-16 4162226 776.6 ns/op 7979.14 MB/s Benchmark____GWs_Int_2kx01x1-16 4656308 774.3 ns/op 8003.56 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2570553 1421 ns/op 8687.21 MB/s Benchmark____GWs_Int_4kx01x1-16 2635094 1400 ns/op 8815.05 MB/s Benchmark____GWs_Int_4kx01x1-16 2629063 1394 ns/op 8853.06 MB/s Benchmark____GWs_Int_4kx01x1-16 2429722 1401 ns/op 8805.98 MB/s Benchmark____GWs_Int_4kx01x1-16 2609722 1412 ns/op 8741.75 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6091707 565.1 ns/op 5530.04 MB/s Benchmark____GWs_Int_1kx10x1-16 6053732 550.8 ns/op 5673.12 MB/s Benchmark____GWs_Int_1kx10x1-16 6567538 565.8 ns/op 5523.63 MB/s Benchmark____GWs_Int_1kx10x1-16 6176852 566.5 ns/op 5516.10 MB/s Benchmark____GWs_Int_1kx10x1-16 6110102 563.1 ns/op 5550.13 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4121533 847.7 ns/op 7310.53 MB/s Benchmark____GWs_Int_2kx10x1-16 4040457 850.9 ns/op 7282.60 MB/s Benchmark____GWs_Int_2kx10x1-16 4102411 854.9 ns/op 7248.98 MB/s Benchmark____GWs_Int_2kx10x1-16 4190894 864.0 ns/op 7172.47 MB/s Benchmark____GWs_Int_2kx10x1-16 4037310 850.7 ns/op 7284.94 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2429541 1542 ns/op 8005.51 MB/s Benchmark____GWs_Int_4kx10x1-16 2315972 1635 ns/op 7549.14 MB/s Benchmark____GWs_Int_4kx10x1-16 2145981 1531 ns/op 8059.64 MB/s Benchmark____GWs_Int_4kx10x1-16 2300330 1522 ns/op 8110.37 MB/s Benchmark____GWs_Int_4kx10x1-16 2343126 1542 ns/op 8004.11 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8200500 437.8 ns/op 232.98 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8278670 433.8 ns/op 235.12 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8083930 437.3 ns/op 233.24 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7834302 436.4 ns/op 233.72 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7975725 466.8 ns/op 218.51 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 650246 4849 ns/op 36.51 MB/s Benchmark__GWs_Reqs_1SubEach-16 841850 4996 ns/op 35.43 MB/s Benchmark__GWs_Reqs_1SubEach-16 806482 5079 ns/op 34.85 MB/s Benchmark__GWs_Reqs_1SubEach-16 757527 4987 ns/op 35.49 MB/s Benchmark__GWs_Reqs_1SubEach-16 765871 5054 ns/op 35.02 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2113.056s ❌ Non-zero exit code: 1