> ROOT_DIR=/tmp/go-bench-away-job-38778b51-1b23-4690-aec1-96b6ef11f3e7-397989634 > OUTPUT_FILE=/tmp/go-bench-away-job-38778b51-1b23-4690-aec1-96b6ef11f3e7-397989634/results.txt > SHA_FILE=/tmp/go-bench-away-job-38778b51-1b23-4690-aec1-96b6ef11f3e7-397989634/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-38778b51-1b23-4690-aec1-96b6ef11f3e7-397989634/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.26.3/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-38778b51-1b23-4690-aec1-96b6ef11f3e7-397989634/source.git SHA of main: 26b1e7ad9b90049ae8ad302f67486a18ff731044 Go runtime: go version go1.26.3 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build88400454=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-38778b51-1b23-4690-aec1-96b6ef11f3e7-397989634/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.26.3' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.26.3/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.3' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 50018962 72.20 ns/op 152.35 MB/s Benchmark______Pub0b_Payload-16 47158219 72.09 ns/op 152.58 MB/s Benchmark______Pub0b_Payload-16 47117472 78.18 ns/op 140.70 MB/s Benchmark______Pub0b_Payload-16 47403460 72.08 ns/op 152.61 MB/s Benchmark______Pub0b_Payload-16 47591994 72.06 ns/op 152.64 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 44811096 72.64 ns/op 261.56 MB/s Benchmark______Pub8b_Payload-16 46617009 72.87 ns/op 260.74 MB/s Benchmark______Pub8b_Payload-16 46591066 72.91 ns/op 260.58 MB/s Benchmark______Pub8b_Payload-16 44483994 72.81 ns/op 260.96 MB/s Benchmark______Pub8b_Payload-16 46585230 73.70 ns/op 257.79 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44358231 76.92 ns/op 572.03 MB/s Benchmark_____Pub32b_Payload-16 44390696 76.86 ns/op 572.50 MB/s Benchmark_____Pub32b_Payload-16 44164293 77.14 ns/op 570.39 MB/s Benchmark_____Pub32b_Payload-16 38169878 90.30 ns/op 487.28 MB/s Benchmark_____Pub32b_Payload-16 42714070 77.27 ns/op 569.42 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39737422 86.59 ns/op 1628.32 MB/s Benchmark____Pub128B_Payload-16 39489417 88.19 ns/op 1598.90 MB/s Benchmark____Pub128B_Payload-16 34686704 89.73 ns/op 1571.42 MB/s Benchmark____Pub128B_Payload-16 39080386 86.55 ns/op 1629.16 MB/s Benchmark____Pub128B_Payload-16 34010355 88.52 ns/op 1592.79 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 32218413 94.42 ns/op 2848.83 MB/s Benchmark____Pub256B_Payload-16 36943400 94.17 ns/op 2856.45 MB/s Benchmark____Pub256B_Payload-16 32389359 98.60 ns/op 2728.29 MB/s Benchmark____Pub256B_Payload-16 35811207 96.26 ns/op 2794.46 MB/s Benchmark____Pub256B_Payload-16 35825473 95.50 ns/op 2816.67 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25597717 145.2 ns/op 7148.45 MB/s Benchmark______Pub1K_Payload-16 24491899 168.0 ns/op 6177.12 MB/s Benchmark______Pub1K_Payload-16 24533797 144.5 ns/op 7184.44 MB/s Benchmark______Pub1K_Payload-16 24682569 136.3 ns/op 7614.10 MB/s Benchmark______Pub1K_Payload-16 25098573 140.4 ns/op 7395.23 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5671818 621.1 ns/op 6617.74 MB/s Benchmark______Pub4K_Payload-16 5532966 613.8 ns/op 6695.51 MB/s Benchmark______Pub4K_Payload-16 5806788 615.4 ns/op 6678.60 MB/s Benchmark______Pub4K_Payload-16 5461328 626.7 ns/op 6557.67 MB/s Benchmark______Pub4K_Payload-16 5410274 618.9 ns/op 6640.56 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2798556 1272 ns/op 6449.42 MB/s Benchmark______Pub8K_Payload-16 2775369 1275 ns/op 6437.54 MB/s Benchmark______Pub8K_Payload-16 2747040 1286 ns/op 6378.65 MB/s Benchmark______Pub8K_Payload-16 2838247 1277 ns/op 6425.78 MB/s Benchmark______Pub8K_Payload-16 2773210 1280 ns/op 6408.56 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 559971 5478 ns/op 5984.22 MB/s Benchmark_____Pub32K_Payload-16 644554 5447 ns/op 6018.47 MB/s Benchmark_____Pub32K_Payload-16 663662 5421 ns/op 6046.87 MB/s Benchmark_____Pub32K_Payload-16 601633 5573 ns/op 5882.47 MB/s Benchmark_____Pub32K_Payload-16 491262 7327 ns/op 4474.54 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 30990788 98.82 ns/op 111.31 MB/s Benchmark__AuthPub0b_Payload-16 36319722 98.53 ns/op 111.64 MB/s Benchmark__AuthPub0b_Payload-16 34937234 98.34 ns/op 111.85 MB/s Benchmark__AuthPub0b_Payload-16 35837268 94.73 ns/op 116.11 MB/s Benchmark__AuthPub0b_Payload-16 36102285 94.83 ns/op 116.00 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15374442 230.2 ns/op Benchmark_____________PubSub-16 15216452 230.9 ns/op Benchmark_____________PubSub-16 15197550 231.5 ns/op Benchmark_____________PubSub-16 15249404 232.2 ns/op Benchmark_____________PubSub-16 15284124 231.2 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15261050 229.3 ns/op Benchmark_____PubSubTwoConns-16 15445854 229.6 ns/op Benchmark_____PubSubTwoConns-16 15324243 229.0 ns/op Benchmark_____PubSubTwoConns-16 15489586 229.2 ns/op Benchmark_____PubSubTwoConns-16 15346476 229.3 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46424->127.0.0.1:46533: write: broken pipe --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42964->127.0.0.1:39349: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58878->127.0.0.1:36613: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51236->127.0.0.1:37911: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41764->127.0.0.1:43421: 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 14228286 249.3 ns/op Benchmark_____PubTwoQueueSub-16 14228654 249.6 ns/op Benchmark_____PubTwoQueueSub-16 14361369 249.0 ns/op Benchmark_____PubTwoQueueSub-16 14281478 249.0 ns/op Benchmark_____PubTwoQueueSub-16 14222562 248.8 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14155382 250.0 ns/op Benchmark____PubFourQueueSub-16 14316651 249.5 ns/op Benchmark____PubFourQueueSub-16 14173640 249.5 ns/op Benchmark____PubFourQueueSub-16 14276796 248.5 ns/op Benchmark____PubFourQueueSub-16 14233030 249.7 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14213775 249.5 ns/op Benchmark___PubEightQueueSub-16 14285882 248.2 ns/op Benchmark___PubEightQueueSub-16 14135047 249.5 ns/op Benchmark___PubEightQueueSub-16 14231284 249.5 ns/op Benchmark___PubEightQueueSub-16 14090264 250.7 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22842 155777 ns/op Benchmark_PubSub512kTwoConns-16 23056 156243 ns/op Benchmark_PubSub512kTwoConns-16 23077 155555 ns/op Benchmark_PubSub512kTwoConns-16 23016 166928 ns/op Benchmark_PubSub512kTwoConns-16 23193 155254 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14950374 232.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15124740 233.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15113490 233.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 14879316 233.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15025228 234.5 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14938392 234.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15158154 233.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15160885 231.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 14931007 234.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15000529 233.1 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11631289 313.7 ns/op Benchmark____RoutedPubSub_0b-16 10875297 316.0 ns/op Benchmark____RoutedPubSub_0b-16 11218411 317.0 ns/op Benchmark____RoutedPubSub_0b-16 11127868 318.1 ns/op Benchmark____RoutedPubSub_0b-16 11218498 317.5 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6520596 545.6 ns/op Benchmark____RoutedPubSub_1K-16 6547782 603.2 ns/op Benchmark____RoutedPubSub_1K-16 6361593 551.8 ns/op Benchmark____RoutedPubSub_1K-16 6303202 545.4 ns/op Benchmark____RoutedPubSub_1K-16 6764788 562.5 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85438 41412 ns/op Benchmark__RoutedPubSub_100K-16 85849 41858 ns/op Benchmark__RoutedPubSub_100K-16 83622 42983 ns/op Benchmark__RoutedPubSub_100K-16 78943 44047 ns/op Benchmark__RoutedPubSub_100K-16 86323 43434 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9759411 322.8 ns/op Benchmark____Routed2QueueSub-16 9633566 321.9 ns/op Benchmark____Routed2QueueSub-16 9679670 327.9 ns/op Benchmark____Routed2QueueSub-16 9462604 319.9 ns/op Benchmark____Routed2QueueSub-16 9640533 321.8 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9484173 338.2 ns/op Benchmark____Routed4QueueSub-16 9437380 326.7 ns/op Benchmark____Routed4QueueSub-16 9221444 327.6 ns/op Benchmark____Routed4QueueSub-16 9354186 325.5 ns/op Benchmark____Routed4QueueSub-16 9189757 326.6 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 10867581 329.7 ns/op Benchmark____Routed8QueueSub-16 9044104 340.5 ns/op Benchmark____Routed8QueueSub-16 10765406 337.8 ns/op Benchmark____Routed8QueueSub-16 9030634 336.4 ns/op Benchmark____Routed8QueueSub-16 9136869 333.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8588098 349.4 ns/op Benchmark___Routed16QueueSub-16 8463658 360.5 ns/op Benchmark___Routed16QueueSub-16 8751928 357.6 ns/op Benchmark___Routed16QueueSub-16 8590608 352.8 ns/op Benchmark___Routed16QueueSub-16 8672696 359.9 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6332991 549.4 ns/op Benchmark____________RouteCompressOff-16 6499147 548.8 ns/op Benchmark____________RouteCompressOff-16 6428558 555.2 ns/op Benchmark____________RouteCompressOff-16 6389029 556.9 ns/op Benchmark____________RouteCompressOff-16 6335018 555.3 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6314473 561.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6529771 554.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6289683 555.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6353084 554.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6453739 556.1 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6441150 554.9 ns/op Benchmark_________RouteCompressS2Fast-16 6287397 546.9 ns/op Benchmark_________RouteCompressS2Fast-16 6439287 466.1 ns/op Benchmark_________RouteCompressS2Fast-16 6340720 549.4 ns/op Benchmark_________RouteCompressS2Fast-16 6518492 477.2 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6245202 557.8 ns/op Benchmark_______RouteCompressS2Better-16 6446602 587.6 ns/op Benchmark_______RouteCompressS2Better-16 6454305 554.8 ns/op Benchmark_______RouteCompressS2Better-16 6612985 556.3 ns/op Benchmark_______RouteCompressS2Better-16 6541899 549.3 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6351672 562.3 ns/op Benchmark_________RouteCompressS2Best-16 6506636 553.8 ns/op Benchmark_________RouteCompressS2Best-16 6381124 520.5 ns/op Benchmark_________RouteCompressS2Best-16 6248551 556.4 ns/op Benchmark_________RouteCompressS2Best-16 6491390 551.9 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4594819 779.0 ns/op 319.64 MB/s Benchmark______FanOut_8x1x10-16 4528652 775.6 ns/op 321.06 MB/s Benchmark______FanOut_8x1x10-16 4590558 776.7 ns/op 320.60 MB/s Benchmark______FanOut_8x1x10-16 4551898 783.4 ns/op 317.86 MB/s Benchmark______FanOut_8x1x10-16 4611572 774.7 ns/op 321.40 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 535266 6294 ns/op 368.44 MB/s Benchmark_____FanOut_8x1x100-16 534918 6241 ns/op 371.59 MB/s Benchmark_____FanOut_8x1x100-16 528157 6299 ns/op 368.15 MB/s Benchmark_____FanOut_8x1x100-16 541999 6238 ns/op 371.74 MB/s Benchmark_____FanOut_8x1x100-16 545835 6189 ns/op 374.71 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 46693 76178 ns/op 302.18 MB/s Benchmark____FanOut_8x10x100-16 46429 76134 ns/op 302.35 MB/s Benchmark____FanOut_8x10x100-16 46810 76264 ns/op 301.83 MB/s Benchmark____FanOut_8x10x100-16 47059 76410 ns/op 301.26 MB/s Benchmark____FanOut_8x10x100-16 46954 76112 ns/op 302.43 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5347 624120 ns/op 384.57 MB/s Benchmark___FanOut_8x10x1000-16 5598 626353 ns/op 383.20 MB/s Benchmark___FanOut_8x10x1000-16 5640 618303 ns/op 388.19 MB/s Benchmark___FanOut_8x10x1000-16 5702 620178 ns/op 387.02 MB/s Benchmark___FanOut_8x10x1000-16 5512 618459 ns/op 388.09 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4932 730406 ns/op 314.92 MB/s Benchmark___FanOut_8x100x100-16 4701 735208 ns/op 312.86 MB/s Benchmark___FanOut_8x100x100-16 4886 729632 ns/op 315.25 MB/s Benchmark___FanOut_8x100x100-16 4869 732717 ns/op 313.93 MB/s Benchmark___FanOut_8x100x100-16 4910 728052 ns/op 315.94 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 549 6406258 ns/op 374.64 MB/s Benchmark__FanOut_8x100x1000-16 549 6590914 ns/op 364.14 MB/s Benchmark__FanOut_8x100x1000-16 546 6552269 ns/op 366.29 MB/s Benchmark__FanOut_8x100x1000-16 528 6430468 ns/op 373.23 MB/s Benchmark__FanOut_8x100x1000-16 544 6479096 ns/op 370.42 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 512 6900112 ns/op 362.32 MB/s Benchmark__FanOut_8x10x10000-16 522 7022301 ns/op 356.01 MB/s Benchmark__FanOut_8x10x10000-16 518 6996629 ns/op 357.32 MB/s Benchmark__FanOut_8x10x10000-16 518 7069641 ns/op 353.63 MB/s Benchmark__FanOut_8x10x10000-16 510 6922686 ns/op 361.13 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 912 3903884 ns/op 294.58 MB/s Benchmark___FanOut_8x500x100-16 925 3875290 ns/op 296.76 MB/s Benchmark___FanOut_8x500x100-16 919 3859105 ns/op 298.00 MB/s Benchmark___FanOut_8x500x100-16 910 3892795 ns/op 295.42 MB/s Benchmark___FanOut_8x500x100-16 915 3880432 ns/op 296.36 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 358927 9661 ns/op 1515.42 MB/s Benchmark___FanOut_128x1x100-16 365424 9587 ns/op 1527.19 MB/s Benchmark___FanOut_128x1x100-16 351859 9625 ns/op 1521.18 MB/s Benchmark___FanOut_128x1x100-16 356312 9699 ns/op 1509.47 MB/s Benchmark___FanOut_128x1x100-16 360277 9730 ns/op 1504.65 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 31752 112064 ns/op 1295.16 MB/s Benchmark__FanOut_128x10x100-16 31945 112846 ns/op 1286.18 MB/s Benchmark__FanOut_128x10x100-16 31808 112253 ns/op 1292.98 MB/s Benchmark__FanOut_128x10x100-16 32017 112254 ns/op 1292.97 MB/s Benchmark__FanOut_128x10x100-16 31812 112676 ns/op 1288.13 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4008 920019 ns/op 1587.08 MB/s Benchmark_FanOut_128x10x1000-16 3942 902319 ns/op 1618.21 MB/s Benchmark_FanOut_128x10x1000-16 3744 916780 ns/op 1592.68 MB/s Benchmark_FanOut_128x10x1000-16 3974 909177 ns/op 1606.00 MB/s Benchmark_FanOut_128x10x1000-16 3706 920894 ns/op 1585.57 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3434 1040871 ns/op 1393.20 MB/s Benchmark_FanOut_128x100x100-16 3448 1036550 ns/op 1399.01 MB/s Benchmark_FanOut_128x100x100-16 3408 1035011 ns/op 1401.09 MB/s Benchmark_FanOut_128x100x100-16 3468 1032794 ns/op 1404.09 MB/s Benchmark_FanOut_128x100x100-16 3412 1041285 ns/op 1392.65 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 368 9629733 ns/op 1516.15 MB/s BenchmarkFanOut_128x100x1000-16 362 9750798 ns/op 1497.33 MB/s BenchmarkFanOut_128x100x1000-16 372 9630187 ns/op 1516.08 MB/s BenchmarkFanOut_128x100x1000-16 362 9608907 ns/op 1519.44 MB/s BenchmarkFanOut_128x100x1000-16 370 9646364 ns/op 1513.54 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 362 9965809 ns/op 1475.06 MB/s BenchmarkFanOut_128x10x10000-16 361 9951383 ns/op 1477.20 MB/s BenchmarkFanOut_128x10x10000-16 367 10071992 ns/op 1459.51 MB/s BenchmarkFanOut_128x10x10000-16 367 9916217 ns/op 1482.43 MB/s BenchmarkFanOut_128x10x10000-16 358 9849869 ns/op 1492.42 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 658 5395000 ns/op 1343.86 MB/s BenchmarkFanOut__128x500x100-16 654 5400445 ns/op 1342.51 MB/s BenchmarkFanOut__128x500x100-16 668 5418515 ns/op 1338.03 MB/s BenchmarkFanOut__128x500x100-16 666 5408374 ns/op 1340.54 MB/s BenchmarkFanOut__128x500x100-16 652 5435335 ns/op 1333.89 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1923 1872156 ns/op 2825.90 MB/s Benchmark_FanOut_512x100x100-16 1924 1872722 ns/op 2825.04 MB/s Benchmark_FanOut_512x100x100-16 1914 1866081 ns/op 2835.10 MB/s Benchmark_FanOut_512x100x100-16 1958 1867691 ns/op 2832.66 MB/s Benchmark_FanOut_512x100x100-16 1898 1874918 ns/op 2821.74 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 211 16880867 ns/op 3139.68 MB/s Benchmark__FanOut_512x100x1k-16 214 16895534 ns/op 3136.95 MB/s Benchmark__FanOut_512x100x1k-16 213 16828960 ns/op 3149.36 MB/s Benchmark__FanOut_512x100x1k-16 213 16982623 ns/op 3120.87 MB/s Benchmark__FanOut_512x100x1k-16 213 16829190 ns/op 3149.32 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3086 1165417 ns/op 8950.48 MB/s Benchmark____FanOut_1kx10x1k-16 3003 1165470 ns/op 8950.07 MB/s Benchmark____FanOut_1kx10x1k-16 3116 1153704 ns/op 9041.35 MB/s Benchmark____FanOut_1kx10x1k-16 3110 1178478 ns/op 8851.28 MB/s Benchmark____FanOut_1kx10x1k-16 2847 1165622 ns/op 8948.90 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2755 1278556 ns/op 8150.63 MB/s Benchmark__FanOut_1kx100x100-16 2779 1274823 ns/op 8174.50 MB/s Benchmark__FanOut_1kx100x100-16 2702 1266450 ns/op 8228.54 MB/s Benchmark__FanOut_1kx100x100-16 2737 1274532 ns/op 8176.37 MB/s Benchmark__FanOut_1kx100x100-16 2748 1273580 ns/op 8182.47 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4471684 794.1 ns/op 313.57 MB/s Benchmark_____RFanOut_8x1x10-16 4511823 777.5 ns/op 320.24 MB/s Benchmark_____RFanOut_8x1x10-16 4412306 808.7 ns/op 307.90 MB/s Benchmark_____RFanOut_8x1x10-16 4452958 785.2 ns/op 317.12 MB/s Benchmark_____RFanOut_8x1x10-16 4357806 787.1 ns/op 316.34 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 537370 6383 ns/op 363.31 MB/s Benchmark____RFanOut_8x1x100-16 504182 6316 ns/op 367.16 MB/s Benchmark____RFanOut_8x1x100-16 507668 6253 ns/op 370.86 MB/s Benchmark____RFanOut_8x1x100-16 518029 6295 ns/op 368.39 MB/s Benchmark____RFanOut_8x1x100-16 504481 6389 ns/op 362.97 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46491 80031 ns/op 287.63 MB/s Benchmark___RFanOut_8x10x100-16 47014 76729 ns/op 300.00 MB/s Benchmark___RFanOut_8x10x100-16 46718 76848 ns/op 299.54 MB/s Benchmark___RFanOut_8x10x100-16 46680 77626 ns/op 296.54 MB/s Benchmark___RFanOut_8x10x100-16 46939 76974 ns/op 299.05 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5596 623460 ns/op 384.98 MB/s Benchmark__RFanOut_8x10x1000-16 5614 638111 ns/op 376.14 MB/s Benchmark__RFanOut_8x10x1000-16 5497 630595 ns/op 380.62 MB/s Benchmark__RFanOut_8x10x1000-16 5515 636159 ns/op 377.29 MB/s Benchmark__RFanOut_8x10x1000-16 5406 627732 ns/op 382.36 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4903 729197 ns/op 315.44 MB/s Benchmark__RFanOut_8x100x100-16 4814 724813 ns/op 317.35 MB/s Benchmark__RFanOut_8x100x100-16 4890 731575 ns/op 314.42 MB/s Benchmark__RFanOut_8x100x100-16 4798 727800 ns/op 316.05 MB/s Benchmark__RFanOut_8x100x100-16 4875 735033 ns/op 312.94 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 543 6427721 ns/op 373.39 MB/s Benchmark_RFanOut_8x100x1000-16 546 6559556 ns/op 365.88 MB/s Benchmark_RFanOut_8x100x1000-16 544 6574069 ns/op 365.07 MB/s Benchmark_RFanOut_8x100x1000-16 547 6530593 ns/op 367.50 MB/s Benchmark_RFanOut_8x100x1000-16 537 6500786 ns/op 369.19 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 498 6883777 ns/op 363.18 MB/s Benchmark_RFanOut_8x10x10000-16 498 6962439 ns/op 359.07 MB/s Benchmark_RFanOut_8x10x10000-16 511 7037300 ns/op 355.25 MB/s Benchmark_RFanOut_8x10x10000-16 507 6894764 ns/op 362.60 MB/s Benchmark_RFanOut_8x10x10000-16 508 6959764 ns/op 359.21 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2995 1170850 ns/op 8908.95 MB/s Benchmark_RFanOut_1kx10x1000-16 2832 1176331 ns/op 8867.44 MB/s Benchmark_RFanOut_1kx10x1000-16 2994 1154875 ns/op 9032.18 MB/s Benchmark_RFanOut_1kx10x1000-16 2914 1155344 ns/op 9028.52 MB/s Benchmark_RFanOut_1kx10x1000-16 3048 1149124 ns/op 9077.38 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6961155 507.2 ns/op 4097.37 MB/s Benchmark_____FanIn_1kx100x1-16 6973845 506.6 ns/op 4101.75 MB/s Benchmark_____FanIn_1kx100x1-16 6936800 506.8 ns/op 4099.96 MB/s Benchmark_____FanIn_1kx100x1-16 6859532 505.9 ns/op 4107.42 MB/s Benchmark_____FanIn_1kx100x1-16 6961942 506.7 ns/op 4101.33 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2620863 1370 ns/op 6001.35 MB/s Benchmark_____FanIn_4kx100x1-16 2661788 1387 ns/op 5929.48 MB/s Benchmark_____FanIn_4kx100x1-16 2595070 1382 ns/op 5948.38 MB/s Benchmark_____FanIn_4kx100x1-16 2607688 1364 ns/op 6027.03 MB/s Benchmark_____FanIn_4kx100x1-16 2574470 1367 ns/op 6016.74 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1709472 2115 ns/op 7761.97 MB/s Benchmark_____FanIn_8kx100x1-16 1712536 2124 ns/op 7727.33 MB/s Benchmark_____FanIn_8kx100x1-16 1696262 2096 ns/op 7832.74 MB/s Benchmark_____FanIn_8kx100x1-16 1699394 2131 ns/op 7702.10 MB/s Benchmark_____FanIn_8kx100x1-16 1708078 2095 ns/op 7835.14 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 858710 4140 ns/op 7923.40 MB/s Benchmark____FanIn_16kx100x1-16 857493 4115 ns/op 7970.22 MB/s Benchmark____FanIn_16kx100x1-16 870829 4275 ns/op 7673.03 MB/s Benchmark____FanIn_16kx100x1-16 869083 4130 ns/op 7942.43 MB/s Benchmark____FanIn_16kx100x1-16 864336 4153 ns/op 7898.35 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 4736597568 vs 11144010000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47998->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47396->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 162997 19896 ns/op 6589.44 MB/s Benchmark____FanIn_64kx100x1-16 173233 20047 ns/op 6539.93 MB/s Benchmark____FanIn_64kx100x1-16 166462 19964 ns/op 6567.00 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7237444518 vs 10953906300 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56182->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55806->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: 1271048640 vs 11142650000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59044->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58514->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58974->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59078->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: 990909310 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60734->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: 786802180 vs 11011560000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:34758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:34994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:34950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34528->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:34760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:34624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34828->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: 377801380 vs 11378612000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:37760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:37734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:37676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37704->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37892->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: 588069740 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:39442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:39306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39156->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39258->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5480806 646.0 ns/op 439.65 MB/s Benchmark___BumpPubCount_1x3-16 5552881 648.1 ns/op 438.20 MB/s Benchmark___BumpPubCount_1x3-16 5538486 639.4 ns/op 444.18 MB/s Benchmark___BumpPubCount_1x3-16 5589692 641.1 ns/op 442.98 MB/s Benchmark___BumpPubCount_1x3-16 5614623 634.1 ns/op 447.89 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5250858 677.4 ns/op 419.22 MB/s Benchmark___BumpPubCount_2x3-16 5322297 677.4 ns/op 419.22 MB/s Benchmark___BumpPubCount_2x3-16 5282620 678.9 ns/op 418.30 MB/s Benchmark___BumpPubCount_2x3-16 5270432 680.9 ns/op 417.07 MB/s Benchmark___BumpPubCount_2x3-16 5280394 677.2 ns/op 419.36 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5522461 647.9 ns/op 438.35 MB/s Benchmark___BumpPubCount_5x3-16 5067586 651.5 ns/op 435.91 MB/s Benchmark___BumpPubCount_5x3-16 5328249 647.4 ns/op 438.66 MB/s Benchmark___BumpPubCount_5x3-16 5533044 646.7 ns/op 439.15 MB/s Benchmark___BumpPubCount_5x3-16 5306593 647.8 ns/op 438.43 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5519289 650.1 ns/op 436.89 MB/s Benchmark__BumpPubCount_10x3-16 5529046 651.5 ns/op 435.91 MB/s Benchmark__BumpPubCount_10x3-16 5525967 649.7 ns/op 437.14 MB/s Benchmark__BumpPubCount_10x3-16 5496825 649.1 ns/op 437.56 MB/s Benchmark__BumpPubCount_10x3-16 5509489 647.4 ns/op 438.69 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12287072 278.2 ns/op 3738.96 MB/s Benchmark____GWs_Opt_1kx01x0-16 12415308 280.9 ns/op 3702.46 MB/s Benchmark____GWs_Opt_1kx01x0-16 12204878 271.3 ns/op 3833.25 MB/s Benchmark____GWs_Opt_1kx01x0-16 12235772 279.2 ns/op 3724.49 MB/s Benchmark____GWs_Opt_1kx01x0-16 12965290 278.9 ns/op 3729.02 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10570293 347.5 ns/op 5938.94 MB/s Benchmark____GWs_Opt_2kx01x0-16 10510206 363.5 ns/op 5678.03 MB/s Benchmark____GWs_Opt_2kx01x0-16 10697660 358.5 ns/op 5757.82 MB/s Benchmark____GWs_Opt_2kx01x0-16 10400328 343.7 ns/op 6004.95 MB/s Benchmark____GWs_Opt_2kx01x0-16 10546556 337.4 ns/op 6117.67 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5821623 620.8 ns/op 6623.54 MB/s Benchmark____GWs_Opt_4kx01x0-16 5536136 662.1 ns/op 6210.89 MB/s Benchmark____GWs_Opt_4kx01x0-16 5744052 632.1 ns/op 6505.80 MB/s Benchmark____GWs_Opt_4kx01x0-16 5468731 631.3 ns/op 6513.75 MB/s Benchmark____GWs_Opt_4kx01x0-16 5837917 607.5 ns/op 6769.24 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 27961891 112.9 ns/op 9214.61 MB/s Benchmark____GWs_Opt_1kx10x0-16 32401898 114.7 ns/op 9069.35 MB/s Benchmark____GWs_Opt_1kx10x0-16 31168078 113.1 ns/op 9195.46 MB/s Benchmark____GWs_Opt_1kx10x0-16 30753176 109.6 ns/op 9487.34 MB/s Benchmark____GWs_Opt_1kx10x0-16 30110545 116.6 ns/op 8920.99 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25067592 175.9 ns/op 11733.16 MB/s Benchmark____GWs_Opt_2kx10x0-16 23771589 146.0 ns/op 14140.19 MB/s Benchmark____GWs_Opt_2kx10x0-16 21693232 147.9 ns/op 13954.17 MB/s Benchmark____GWs_Opt_2kx10x0-16 25656076 150.8 ns/op 13682.57 MB/s Benchmark____GWs_Opt_2kx10x0-16 25475613 163.1 ns/op 12656.23 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12164116 341.4 ns/op 12043.73 MB/s Benchmark____GWs_Opt_4kx10x0-16 8297200 421.8 ns/op 9748.47 MB/s Benchmark____GWs_Opt_4kx10x0-16 12570150 333.0 ns/op 12349.59 MB/s Benchmark____GWs_Opt_4kx10x0-16 11788213 286.4 ns/op 14355.19 MB/s Benchmark____GWs_Opt_4kx10x0-16 12018367 285.4 ns/op 14409.50 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6570956 555.1 ns/op 5629.11 MB/s Benchmark____GWs_Opt_1kx01x1-16 6288985 552.4 ns/op 5657.50 MB/s Benchmark____GWs_Opt_1kx01x1-16 6447037 556.2 ns/op 5618.35 MB/s Benchmark____GWs_Opt_1kx01x1-16 6485378 555.9 ns/op 5621.02 MB/s Benchmark____GWs_Opt_1kx01x1-16 6522823 554.3 ns/op 5637.97 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4645544 774.3 ns/op 8003.01 MB/s Benchmark____GWs_Opt_2kx01x1-16 4703836 783.7 ns/op 7907.36 MB/s Benchmark____GWs_Opt_2kx01x1-16 4556552 770.7 ns/op 8040.99 MB/s Benchmark____GWs_Opt_2kx01x1-16 4592233 780.2 ns/op 7942.70 MB/s Benchmark____GWs_Opt_2kx01x1-16 4397272 782.1 ns/op 7923.88 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2632911 1375 ns/op 8977.27 MB/s Benchmark____GWs_Opt_4kx01x1-16 2258779 1513 ns/op 8159.09 MB/s Benchmark____GWs_Opt_4kx01x1-16 2640186 1380 ns/op 8941.95 MB/s Benchmark____GWs_Opt_4kx01x1-16 2554032 1359 ns/op 9082.43 MB/s Benchmark____GWs_Opt_4kx01x1-16 2398386 1384 ns/op 8913.89 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6157105 560.0 ns/op 5580.32 MB/s Benchmark____GWs_Opt_1kx10x1-16 6126645 556.9 ns/op 5611.92 MB/s Benchmark____GWs_Opt_1kx10x1-16 6190245 569.8 ns/op 5484.16 MB/s Benchmark____GWs_Opt_1kx10x1-16 6098226 571.1 ns/op 5471.95 MB/s Benchmark____GWs_Opt_1kx10x1-16 5883128 565.8 ns/op 5523.28 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4083303 851.9 ns/op 7274.09 MB/s Benchmark____GWs_Opt_2kx10x1-16 4083715 890.3 ns/op 6960.64 MB/s Benchmark____GWs_Opt_2kx10x1-16 4032699 855.1 ns/op 7247.06 MB/s Benchmark____GWs_Opt_2kx10x1-16 4053120 849.5 ns/op 7294.78 MB/s Benchmark____GWs_Opt_2kx10x1-16 4111636 867.3 ns/op 7144.86 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2350345 1509 ns/op 8176.68 MB/s Benchmark____GWs_Opt_4kx10x1-16 2325897 1536 ns/op 8036.32 MB/s Benchmark____GWs_Opt_4kx10x1-16 2206323 1531 ns/op 8060.80 MB/s Benchmark____GWs_Opt_4kx10x1-16 2273558 1518 ns/op 8130.07 MB/s Benchmark____GWs_Opt_4kx10x1-16 2289955 1522 ns/op 8108.11 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12854006 295.4 ns/op 3520.26 MB/s Benchmark____GWs_Int_1kx01x0-16 12064633 297.7 ns/op 3493.11 MB/s Benchmark____GWs_Int_1kx01x0-16 10899576 291.8 ns/op 3563.92 MB/s Benchmark____GWs_Int_1kx01x0-16 12635995 282.4 ns/op 3683.15 MB/s Benchmark____GWs_Int_1kx01x0-16 12493263 289.7 ns/op 3589.75 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10199814 370.9 ns/op 5564.42 MB/s Benchmark____GWs_Int_2kx01x0-16 10200909 348.7 ns/op 5919.41 MB/s Benchmark____GWs_Int_2kx01x0-16 10016552 367.2 ns/op 5621.41 MB/s Benchmark____GWs_Int_2kx01x0-16 9711766 348.1 ns/op 5930.06 MB/s Benchmark____GWs_Int_2kx01x0-16 10106828 363.5 ns/op 5678.81 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5889099 622.6 ns/op 6604.27 MB/s Benchmark____GWs_Int_4kx01x0-16 5411762 622.0 ns/op 6611.37 MB/s Benchmark____GWs_Int_4kx01x0-16 5660596 619.9 ns/op 6633.82 MB/s Benchmark____GWs_Int_4kx01x0-16 5648980 644.2 ns/op 6382.84 MB/s Benchmark____GWs_Int_4kx01x0-16 5863081 621.9 ns/op 6611.46 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31653073 111.6 ns/op 9315.53 MB/s Benchmark____GWs_Int_1kx10x0-16 30384597 114.1 ns/op 9114.51 MB/s Benchmark____GWs_Int_1kx10x0-16 30013858 112.2 ns/op 9268.58 MB/s Benchmark____GWs_Int_1kx10x0-16 31627621 109.0 ns/op 9542.16 MB/s Benchmark____GWs_Int_1kx10x0-16 32944993 112.1 ns/op 9278.23 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24478366 148.3 ns/op 13919.86 MB/s Benchmark____GWs_Int_2kx10x0-16 25927206 142.6 ns/op 14473.57 MB/s Benchmark____GWs_Int_2kx10x0-16 25698541 143.9 ns/op 14347.32 MB/s Benchmark____GWs_Int_2kx10x0-16 21213073 162.5 ns/op 12699.10 MB/s Benchmark____GWs_Int_2kx10x0-16 25175539 142.1 ns/op 14529.56 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13175874 305.3 ns/op 13468.89 MB/s Benchmark____GWs_Int_4kx10x0-16 11896848 303.1 ns/op 13564.84 MB/s Benchmark____GWs_Int_4kx10x0-16 12078511 293.8 ns/op 13997.34 MB/s Benchmark____GWs_Int_4kx10x0-16 13181124 280.5 ns/op 14661.70 MB/s Benchmark____GWs_Int_4kx10x0-16 11570910 363.6 ns/op 11308.65 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6437242 563.2 ns/op 5549.11 MB/s Benchmark____GWs_Int_1kx01x1-16 6221176 567.8 ns/op 5503.98 MB/s Benchmark____GWs_Int_1kx01x1-16 6610515 565.5 ns/op 5526.55 MB/s Benchmark____GWs_Int_1kx01x1-16 6312616 576.2 ns/op 5423.34 MB/s Benchmark____GWs_Int_1kx01x1-16 6390338 568.9 ns/op 5493.05 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4658978 805.6 ns/op 7692.19 MB/s Benchmark____GWs_Int_2kx01x1-16 4579621 887.7 ns/op 6981.28 MB/s Benchmark____GWs_Int_2kx01x1-16 4659556 771.1 ns/op 8036.25 MB/s Benchmark____GWs_Int_2kx01x1-16 4607710 773.3 ns/op 8013.50 MB/s Benchmark____GWs_Int_2kx01x1-16 4660556 777.4 ns/op 7971.19 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2540563 1375 ns/op 8977.56 MB/s Benchmark____GWs_Int_4kx01x1-16 2615656 2060 ns/op 5990.57 MB/s Benchmark____GWs_Int_4kx01x1-16 2602526 1402 ns/op 8801.36 MB/s Benchmark____GWs_Int_4kx01x1-16 2682484 1571 ns/op 7853.96 MB/s Benchmark____GWs_Int_4kx01x1-16 2564779 1386 ns/op 8901.12 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6273410 560.8 ns/op 5572.44 MB/s Benchmark____GWs_Int_1kx10x1-16 6321726 561.6 ns/op 5564.83 MB/s Benchmark____GWs_Int_1kx10x1-16 6594402 563.7 ns/op 5543.35 MB/s Benchmark____GWs_Int_1kx10x1-16 5941862 559.6 ns/op 5584.13 MB/s Benchmark____GWs_Int_1kx10x1-16 6218035 566.7 ns/op 5514.70 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 3960579 850.7 ns/op 7285.00 MB/s Benchmark____GWs_Int_2kx10x1-16 4025425 845.7 ns/op 7327.54 MB/s Benchmark____GWs_Int_2kx10x1-16 4225663 883.4 ns/op 7014.73 MB/s Benchmark____GWs_Int_2kx10x1-16 4079811 1032 ns/op 6004.97 MB/s Benchmark____GWs_Int_2kx10x1-16 4032874 926.5 ns/op 6688.91 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2324043 1531 ns/op 8062.89 MB/s Benchmark____GWs_Int_4kx10x1-16 2292301 1500 ns/op 8229.63 MB/s Benchmark____GWs_Int_4kx10x1-16 2313865 1528 ns/op 8076.34 MB/s Benchmark____GWs_Int_4kx10x1-16 1979468 1573 ns/op 7844.43 MB/s Benchmark____GWs_Int_4kx10x1-16 2293960 1553 ns/op 7944.55 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 7962913 437.3 ns/op 233.27 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8140886 448.5 ns/op 227.41 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8308282 441.5 ns/op 231.05 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8221285 440.7 ns/op 231.46 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8662548 456.8 ns/op 223.28 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 717483 5099 ns/op 34.71 MB/s Benchmark__GWs_Reqs_1SubEach-16 762132 5367 ns/op 32.98 MB/s Benchmark__GWs_Reqs_1SubEach-16 743907 5221 ns/op 33.90 MB/s Benchmark__GWs_Reqs_1SubEach-16 773653 5326 ns/op 33.24 MB/s Benchmark__GWs_Reqs_1SubEach-16 732264 5259 ns/op 33.65 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2070.024s ❌ Non-zero exit code: 1