> ROOT_DIR=/tmp/go-bench-away-job-e74323db-325e-488a-9c0d-3dacfee143f0-3352075440 > OUTPUT_FILE=/tmp/go-bench-away-job-e74323db-325e-488a-9c0d-3dacfee143f0-3352075440/results.txt > SHA_FILE=/tmp/go-bench-away-job-e74323db-325e-488a-9c0d-3dacfee143f0-3352075440/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-e74323db-325e-488a-9c0d-3dacfee143f0-3352075440/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-e74323db-325e-488a-9c0d-3dacfee143f0-3352075440/source.git SHA of main: a0f68a74a565b974e71aeb219dd97ad86d6af601 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-build1523020731=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-e74323db-325e-488a-9c0d-3dacfee143f0-3352075440/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 50193115 72.22 ns/op 152.32 MB/s Benchmark______Pub0b_Payload-16 47574036 72.00 ns/op 152.78 MB/s Benchmark______Pub0b_Payload-16 47343042 71.65 ns/op 153.53 MB/s Benchmark______Pub0b_Payload-16 47376194 73.28 ns/op 150.11 MB/s Benchmark______Pub0b_Payload-16 47108450 71.80 ns/op 153.20 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45910174 74.20 ns/op 256.05 MB/s Benchmark______Pub8b_Payload-16 49125580 72.49 ns/op 262.10 MB/s Benchmark______Pub8b_Payload-16 43871179 73.44 ns/op 258.73 MB/s Benchmark______Pub8b_Payload-16 47168146 73.46 ns/op 258.65 MB/s Benchmark______Pub8b_Payload-16 45310190 72.91 ns/op 260.60 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44137662 80.32 ns/op 547.83 MB/s Benchmark_____Pub32b_Payload-16 44110694 77.70 ns/op 566.29 MB/s Benchmark_____Pub32b_Payload-16 44637238 77.12 ns/op 570.55 MB/s Benchmark_____Pub32b_Payload-16 44383659 76.95 ns/op 571.81 MB/s Benchmark_____Pub32b_Payload-16 46518465 77.38 ns/op 568.61 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39532711 86.78 ns/op 1624.88 MB/s Benchmark____Pub128B_Payload-16 34513702 90.02 ns/op 1566.24 MB/s Benchmark____Pub128B_Payload-16 34180393 88.37 ns/op 1595.52 MB/s Benchmark____Pub128B_Payload-16 39526382 89.98 ns/op 1567.02 MB/s Benchmark____Pub128B_Payload-16 39377757 86.59 ns/op 1628.29 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 32743542 95.80 ns/op 2807.90 MB/s Benchmark____Pub256B_Payload-16 35334762 97.53 ns/op 2758.05 MB/s Benchmark____Pub256B_Payload-16 32073642 97.23 ns/op 2766.73 MB/s Benchmark____Pub256B_Payload-16 35852697 95.13 ns/op 2827.72 MB/s Benchmark____Pub256B_Payload-16 32074689 94.55 ns/op 2844.94 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23946044 137.1 ns/op 7572.93 MB/s Benchmark______Pub1K_Payload-16 21621690 141.1 ns/op 7354.67 MB/s Benchmark______Pub1K_Payload-16 23112687 144.8 ns/op 7167.73 MB/s Benchmark______Pub1K_Payload-16 26164776 134.7 ns/op 7705.45 MB/s Benchmark______Pub1K_Payload-16 23871753 150.3 ns/op 6906.99 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5764534 626.0 ns/op 6565.44 MB/s Benchmark______Pub4K_Payload-16 5426290 621.0 ns/op 6618.54 MB/s Benchmark______Pub4K_Payload-16 5533276 638.5 ns/op 6436.84 MB/s Benchmark______Pub4K_Payload-16 5527078 614.2 ns/op 6691.22 MB/s Benchmark______Pub4K_Payload-16 5570113 629.7 ns/op 6527.31 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2719916 1268 ns/op 6469.63 MB/s Benchmark______Pub8K_Payload-16 2759128 1278 ns/op 6423.27 MB/s Benchmark______Pub8K_Payload-16 2683524 1283 ns/op 6397.60 MB/s Benchmark______Pub8K_Payload-16 2732524 1278 ns/op 6419.18 MB/s Benchmark______Pub8K_Payload-16 2793174 1271 ns/op 6458.01 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 660254 5318 ns/op 6164.89 MB/s Benchmark_____Pub32K_Payload-16 661080 5479 ns/op 5983.01 MB/s Benchmark_____Pub32K_Payload-16 552240 5443 ns/op 6023.40 MB/s Benchmark_____Pub32K_Payload-16 654949 5321 ns/op 6160.52 MB/s Benchmark_____Pub32K_Payload-16 653830 5409 ns/op 6061.18 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 33212185 90.52 ns/op 121.52 MB/s Benchmark__AuthPub0b_Payload-16 37703881 90.73 ns/op 121.24 MB/s Benchmark__AuthPub0b_Payload-16 37718437 91.31 ns/op 120.46 MB/s Benchmark__AuthPub0b_Payload-16 37673844 94.31 ns/op 116.64 MB/s Benchmark__AuthPub0b_Payload-16 36953755 90.60 ns/op 121.41 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15523212 227.5 ns/op Benchmark_____________PubSub-16 15559574 227.3 ns/op Benchmark_____________PubSub-16 15491188 228.6 ns/op Benchmark_____________PubSub-16 15211430 227.8 ns/op Benchmark_____________PubSub-16 15459044 228.3 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15643297 226.7 ns/op Benchmark_____PubSubTwoConns-16 15290160 227.9 ns/op Benchmark_____PubSubTwoConns-16 15817749 227.8 ns/op Benchmark_____PubSubTwoConns-16 15706033 227.4 ns/op Benchmark_____PubSubTwoConns-16 15359383 226.7 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43530->127.0.0.1:40851: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50196->127.0.0.1:42781: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50144->127.0.0.1:46619: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:53312->127.0.0.1:43361: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49868->127.0.0.1:34837: 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 14378310 243.3 ns/op Benchmark_____PubTwoQueueSub-16 14625868 243.4 ns/op Benchmark_____PubTwoQueueSub-16 14368946 243.9 ns/op Benchmark_____PubTwoQueueSub-16 14573884 244.0 ns/op Benchmark_____PubTwoQueueSub-16 14636786 243.6 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14505177 243.5 ns/op Benchmark____PubFourQueueSub-16 14417670 244.2 ns/op Benchmark____PubFourQueueSub-16 14563695 245.3 ns/op Benchmark____PubFourQueueSub-16 14595994 244.0 ns/op Benchmark____PubFourQueueSub-16 14531625 244.3 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14647639 243.8 ns/op Benchmark___PubEightQueueSub-16 14552450 243.3 ns/op Benchmark___PubEightQueueSub-16 14555450 244.1 ns/op Benchmark___PubEightQueueSub-16 14410303 244.6 ns/op Benchmark___PubEightQueueSub-16 14649793 243.3 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23110 155668 ns/op Benchmark_PubSub512kTwoConns-16 23067 155380 ns/op Benchmark_PubSub512kTwoConns-16 23043 157618 ns/op Benchmark_PubSub512kTwoConns-16 22434 157521 ns/op Benchmark_PubSub512kTwoConns-16 22962 158116 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14922558 228.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15120121 229.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15068498 230.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15009360 230.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15244560 231.1 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15258967 230.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15096925 229.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15217502 231.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15188565 230.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15150808 230.8 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11300466 312.3 ns/op Benchmark____RoutedPubSub_0b-16 11512940 309.3 ns/op Benchmark____RoutedPubSub_0b-16 11248244 310.2 ns/op Benchmark____RoutedPubSub_0b-16 11310978 312.9 ns/op Benchmark____RoutedPubSub_0b-16 11367804 312.1 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6494584 531.8 ns/op Benchmark____RoutedPubSub_1K-16 6699165 550.5 ns/op Benchmark____RoutedPubSub_1K-16 6608479 536.9 ns/op Benchmark____RoutedPubSub_1K-16 6672915 537.8 ns/op Benchmark____RoutedPubSub_1K-16 6564082 528.5 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 87046 45614 ns/op Benchmark__RoutedPubSub_100K-16 84087 45781 ns/op Benchmark__RoutedPubSub_100K-16 77785 42448 ns/op Benchmark__RoutedPubSub_100K-16 86941 42883 ns/op Benchmark__RoutedPubSub_100K-16 85812 43358 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9685437 317.8 ns/op Benchmark____Routed2QueueSub-16 9638522 316.3 ns/op Benchmark____Routed2QueueSub-16 9848554 311.5 ns/op Benchmark____Routed2QueueSub-16 9858775 311.6 ns/op Benchmark____Routed2QueueSub-16 9799405 310.9 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9807134 317.0 ns/op Benchmark____Routed4QueueSub-16 9700999 319.5 ns/op Benchmark____Routed4QueueSub-16 9829344 323.2 ns/op Benchmark____Routed4QueueSub-16 11373484 322.9 ns/op Benchmark____Routed4QueueSub-16 9470100 318.6 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9352770 325.6 ns/op Benchmark____Routed8QueueSub-16 9352377 323.4 ns/op Benchmark____Routed8QueueSub-16 9283720 329.9 ns/op Benchmark____Routed8QueueSub-16 9287763 324.9 ns/op Benchmark____Routed8QueueSub-16 9326985 334.2 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8942876 346.9 ns/op Benchmark___Routed16QueueSub-16 8853024 344.6 ns/op Benchmark___Routed16QueueSub-16 8924412 347.7 ns/op Benchmark___Routed16QueueSub-16 10634365 342.1 ns/op Benchmark___Routed16QueueSub-16 10596381 340.8 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6417252 555.4 ns/op Benchmark____________RouteCompressOff-16 6403276 552.6 ns/op Benchmark____________RouteCompressOff-16 6487544 546.8 ns/op Benchmark____________RouteCompressOff-16 6575509 550.9 ns/op Benchmark____________RouteCompressOff-16 6493002 546.6 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6324909 558.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6639454 554.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6429262 549.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6417762 554.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6167350 549.2 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6381406 552.3 ns/op Benchmark_________RouteCompressS2Fast-16 6414876 548.9 ns/op Benchmark_________RouteCompressS2Fast-16 6553260 547.2 ns/op Benchmark_________RouteCompressS2Fast-16 6447842 546.5 ns/op Benchmark_________RouteCompressS2Fast-16 6499966 551.1 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6243523 546.0 ns/op Benchmark_______RouteCompressS2Better-16 6537549 551.3 ns/op Benchmark_______RouteCompressS2Better-16 6272794 549.5 ns/op Benchmark_______RouteCompressS2Better-16 6379933 553.9 ns/op Benchmark_______RouteCompressS2Better-16 6412238 557.6 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6379266 553.1 ns/op Benchmark_________RouteCompressS2Best-16 6403704 550.2 ns/op Benchmark_________RouteCompressS2Best-16 6491517 550.1 ns/op Benchmark_________RouteCompressS2Best-16 6272120 555.5 ns/op Benchmark_________RouteCompressS2Best-16 6529611 556.1 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4675669 777.2 ns/op 320.36 MB/s Benchmark______FanOut_8x1x10-16 4629367 768.9 ns/op 323.85 MB/s Benchmark______FanOut_8x1x10-16 4623681 769.0 ns/op 323.81 MB/s Benchmark______FanOut_8x1x10-16 4601676 774.1 ns/op 321.68 MB/s Benchmark______FanOut_8x1x10-16 4636522 772.4 ns/op 322.35 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 539094 6114 ns/op 379.32 MB/s Benchmark_____FanOut_8x1x100-16 543506 6183 ns/op 375.05 MB/s Benchmark_____FanOut_8x1x100-16 552247 6347 ns/op 365.36 MB/s Benchmark_____FanOut_8x1x100-16 556617 6108 ns/op 379.64 MB/s Benchmark_____FanOut_8x1x100-16 537548 6147 ns/op 377.23 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47169 77373 ns/op 297.51 MB/s Benchmark____FanOut_8x10x100-16 46924 75470 ns/op 305.01 MB/s Benchmark____FanOut_8x10x100-16 47764 75279 ns/op 305.78 MB/s Benchmark____FanOut_8x10x100-16 46938 75568 ns/op 304.61 MB/s Benchmark____FanOut_8x10x100-16 47707 76009 ns/op 302.84 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5606 603091 ns/op 397.98 MB/s Benchmark___FanOut_8x10x1000-16 5895 603949 ns/op 397.42 MB/s Benchmark___FanOut_8x10x1000-16 5678 638157 ns/op 376.11 MB/s Benchmark___FanOut_8x10x1000-16 6008 613362 ns/op 391.32 MB/s Benchmark___FanOut_8x10x1000-16 5686 610855 ns/op 392.92 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5000 713986 ns/op 322.16 MB/s Benchmark___FanOut_8x100x100-16 4896 717109 ns/op 320.76 MB/s Benchmark___FanOut_8x100x100-16 4918 711879 ns/op 323.12 MB/s Benchmark___FanOut_8x100x100-16 4858 721093 ns/op 318.99 MB/s Benchmark___FanOut_8x100x100-16 4944 716596 ns/op 320.99 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 560 6177819 ns/op 388.49 MB/s Benchmark__FanOut_8x100x1000-16 574 6192293 ns/op 387.58 MB/s Benchmark__FanOut_8x100x1000-16 559 6207541 ns/op 386.63 MB/s Benchmark__FanOut_8x100x1000-16 552 6233228 ns/op 385.04 MB/s Benchmark__FanOut_8x100x1000-16 562 6579634 ns/op 364.76 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 525 6804367 ns/op 367.41 MB/s Benchmark__FanOut_8x10x10000-16 510 6979148 ns/op 358.21 MB/s Benchmark__FanOut_8x10x10000-16 518 6817497 ns/op 366.71 MB/s Benchmark__FanOut_8x10x10000-16 512 7075108 ns/op 353.35 MB/s Benchmark__FanOut_8x10x10000-16 531 6816307 ns/op 366.77 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 926 3791276 ns/op 303.33 MB/s Benchmark___FanOut_8x500x100-16 936 3786791 ns/op 303.69 MB/s Benchmark___FanOut_8x500x100-16 948 3779871 ns/op 304.25 MB/s Benchmark___FanOut_8x500x100-16 940 3828023 ns/op 300.42 MB/s Benchmark___FanOut_8x500x100-16 944 3765898 ns/op 305.38 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 368631 9614 ns/op 1522.93 MB/s Benchmark___FanOut_128x1x100-16 349966 9600 ns/op 1525.16 MB/s Benchmark___FanOut_128x1x100-16 361182 9567 ns/op 1530.39 MB/s Benchmark___FanOut_128x1x100-16 353358 9581 ns/op 1528.09 MB/s Benchmark___FanOut_128x1x100-16 365954 9615 ns/op 1522.68 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 31574 111729 ns/op 1299.04 MB/s Benchmark__FanOut_128x10x100-16 31824 112536 ns/op 1289.73 MB/s Benchmark__FanOut_128x10x100-16 32163 111656 ns/op 1299.90 MB/s Benchmark__FanOut_128x10x100-16 31956 110954 ns/op 1308.12 MB/s Benchmark__FanOut_128x10x100-16 31792 111618 ns/op 1300.34 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3921 883839 ns/op 1652.04 MB/s Benchmark_FanOut_128x10x1000-16 3951 902003 ns/op 1618.78 MB/s Benchmark_FanOut_128x10x1000-16 4024 883552 ns/op 1652.58 MB/s Benchmark_FanOut_128x10x1000-16 4004 888627 ns/op 1643.14 MB/s Benchmark_FanOut_128x10x1000-16 4032 889832 ns/op 1640.92 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3451 1017599 ns/op 1425.06 MB/s Benchmark_FanOut_128x100x100-16 3418 1018507 ns/op 1423.79 MB/s Benchmark_FanOut_128x100x100-16 3499 1020078 ns/op 1421.60 MB/s Benchmark_FanOut_128x100x100-16 3487 1019636 ns/op 1422.22 MB/s Benchmark_FanOut_128x100x100-16 3465 1024731 ns/op 1415.14 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 385 9380087 ns/op 1556.50 MB/s BenchmarkFanOut_128x100x1000-16 384 9574411 ns/op 1524.91 MB/s BenchmarkFanOut_128x100x1000-16 376 9460841 ns/op 1543.22 MB/s BenchmarkFanOut_128x100x1000-16 380 9432128 ns/op 1547.92 MB/s BenchmarkFanOut_128x100x1000-16 387 9379264 ns/op 1556.64 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 369 9660939 ns/op 1521.61 MB/s BenchmarkFanOut_128x10x10000-16 370 9726949 ns/op 1511.28 MB/s BenchmarkFanOut_128x10x10000-16 364 9852850 ns/op 1491.97 MB/s BenchmarkFanOut_128x10x10000-16 369 9824635 ns/op 1496.25 MB/s BenchmarkFanOut_128x10x10000-16 364 9740301 ns/op 1509.21 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 661 5350051 ns/op 1355.15 MB/s BenchmarkFanOut__128x500x100-16 660 5316206 ns/op 1363.78 MB/s BenchmarkFanOut__128x500x100-16 658 5331114 ns/op 1359.97 MB/s BenchmarkFanOut__128x500x100-16 666 5281681 ns/op 1372.70 MB/s BenchmarkFanOut__128x500x100-16 669 5289704 ns/op 1370.61 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1918 1845847 ns/op 2866.18 MB/s Benchmark_FanOut_512x100x100-16 1888 1874518 ns/op 2822.34 MB/s Benchmark_FanOut_512x100x100-16 1922 1852512 ns/op 2855.87 MB/s Benchmark_FanOut_512x100x100-16 1924 1871258 ns/op 2827.26 MB/s Benchmark_FanOut_512x100x100-16 1918 1857364 ns/op 2848.40 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 16779529 ns/op 3158.64 MB/s Benchmark__FanOut_512x100x1k-16 211 17061095 ns/op 3106.51 MB/s Benchmark__FanOut_512x100x1k-16 212 16836444 ns/op 3147.96 MB/s Benchmark__FanOut_512x100x1k-16 213 16730536 ns/op 3167.89 MB/s Benchmark__FanOut_512x100x1k-16 212 17073644 ns/op 3104.23 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2965 1153961 ns/op 9039.34 MB/s Benchmark____FanOut_1kx10x1k-16 3207 1141104 ns/op 9141.18 MB/s Benchmark____FanOut_1kx10x1k-16 3218 1160339 ns/op 8989.65 MB/s Benchmark____FanOut_1kx10x1k-16 3096 1134326 ns/op 9195.80 MB/s Benchmark____FanOut_1kx10x1k-16 2662 1140931 ns/op 9142.56 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2743 1276130 ns/op 8166.12 MB/s Benchmark__FanOut_1kx100x100-16 2743 1264227 ns/op 8243.01 MB/s Benchmark__FanOut_1kx100x100-16 2752 1260785 ns/op 8265.51 MB/s Benchmark__FanOut_1kx100x100-16 2761 1266118 ns/op 8230.70 MB/s Benchmark__FanOut_1kx100x100-16 2793 1265920 ns/op 8231.99 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4516006 765.9 ns/op 325.11 MB/s Benchmark_____RFanOut_8x1x10-16 4421847 799.8 ns/op 311.31 MB/s Benchmark_____RFanOut_8x1x10-16 4455453 794.4 ns/op 313.45 MB/s Benchmark_____RFanOut_8x1x10-16 4483587 794.8 ns/op 313.29 MB/s Benchmark_____RFanOut_8x1x10-16 4365258 836.0 ns/op 297.85 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 527581 6401 ns/op 362.30 MB/s Benchmark____RFanOut_8x1x100-16 590190 6128 ns/op 378.42 MB/s Benchmark____RFanOut_8x1x100-16 506493 6101 ns/op 380.12 MB/s Benchmark____RFanOut_8x1x100-16 542992 6373 ns/op 363.88 MB/s Benchmark____RFanOut_8x1x100-16 503656 6098 ns/op 380.28 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47632 75357 ns/op 305.47 MB/s Benchmark___RFanOut_8x10x100-16 47504 74946 ns/op 307.14 MB/s Benchmark___RFanOut_8x10x100-16 47694 75351 ns/op 305.49 MB/s Benchmark___RFanOut_8x10x100-16 46860 75425 ns/op 305.19 MB/s Benchmark___RFanOut_8x10x100-16 47800 77094 ns/op 298.58 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5800 608218 ns/op 394.63 MB/s Benchmark__RFanOut_8x10x1000-16 5757 607185 ns/op 395.30 MB/s Benchmark__RFanOut_8x10x1000-16 5702 608043 ns/op 394.74 MB/s Benchmark__RFanOut_8x10x1000-16 5601 605749 ns/op 396.24 MB/s Benchmark__RFanOut_8x10x1000-16 5842 636540 ns/op 377.07 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4944 717095 ns/op 320.76 MB/s Benchmark__RFanOut_8x100x100-16 4869 713269 ns/op 322.49 MB/s Benchmark__RFanOut_8x100x100-16 4838 714237 ns/op 322.05 MB/s Benchmark__RFanOut_8x100x100-16 4890 713708 ns/op 322.29 MB/s Benchmark__RFanOut_8x100x100-16 4897 716594 ns/op 320.99 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 562 6268501 ns/op 382.87 MB/s Benchmark_RFanOut_8x100x1000-16 554 6419133 ns/op 373.89 MB/s Benchmark_RFanOut_8x100x1000-16 561 6299642 ns/op 380.98 MB/s Benchmark_RFanOut_8x100x1000-16 572 6248826 ns/op 384.08 MB/s Benchmark_RFanOut_8x100x1000-16 566 6255009 ns/op 383.70 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 514 6786534 ns/op 368.38 MB/s Benchmark_RFanOut_8x10x10000-16 529 6744839 ns/op 370.66 MB/s Benchmark_RFanOut_8x10x10000-16 519 6833575 ns/op 365.84 MB/s Benchmark_RFanOut_8x10x10000-16 532 6844271 ns/op 365.27 MB/s Benchmark_RFanOut_8x10x10000-16 529 6716923 ns/op 372.20 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2989 1171196 ns/op 8906.31 MB/s Benchmark_RFanOut_1kx10x1000-16 2924 1146780 ns/op 9095.94 MB/s Benchmark_RFanOut_1kx10x1000-16 3204 1137866 ns/op 9167.19 MB/s Benchmark_RFanOut_1kx10x1000-16 3132 1156390 ns/op 9020.35 MB/s Benchmark_RFanOut_1kx10x1000-16 3114 1157789 ns/op 9009.45 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6926635 505.9 ns/op 4107.34 MB/s Benchmark_____FanIn_1kx100x1-16 6926575 504.3 ns/op 4120.88 MB/s Benchmark_____FanIn_1kx100x1-16 6963055 505.7 ns/op 4109.44 MB/s Benchmark_____FanIn_1kx100x1-16 6860749 503.4 ns/op 4128.07 MB/s Benchmark_____FanIn_1kx100x1-16 6924357 505.4 ns/op 4111.98 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2583992 1370 ns/op 6000.70 MB/s Benchmark_____FanIn_4kx100x1-16 2603786 1366 ns/op 6017.44 MB/s Benchmark_____FanIn_4kx100x1-16 2528781 1359 ns/op 6049.68 MB/s Benchmark_____FanIn_4kx100x1-16 2616732 1355 ns/op 6066.51 MB/s Benchmark_____FanIn_4kx100x1-16 2666336 1339 ns/op 6142.26 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1714052 2102 ns/op 7809.34 MB/s Benchmark_____FanIn_8kx100x1-16 1694800 2086 ns/op 7868.85 MB/s Benchmark_____FanIn_8kx100x1-16 1677394 2126 ns/op 7719.75 MB/s Benchmark_____FanIn_8kx100x1-16 1718946 2105 ns/op 7797.53 MB/s Benchmark_____FanIn_8kx100x1-16 1659500 2101 ns/op 7811.47 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 863679 4199 ns/op 7812.27 MB/s Benchmark____FanIn_16kx100x1-16 864908 4140 ns/op 7922.21 MB/s Benchmark____FanIn_16kx100x1-16 848397 4086 ns/op 8027.14 MB/s Benchmark____FanIn_16kx100x1-16 871516 4151 ns/op 7902.24 MB/s Benchmark____FanIn_16kx100x1-16 874066 4149 ns/op 7906.01 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 166215 19885 ns/op 6593.06 MB/s Benchmark____FanIn_64kx100x1-16 169048 20161 ns/op 6502.95 MB/s Benchmark____FanIn_64kx100x1-16 166011 19975 ns/op 6563.27 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 3731866737 vs 11137454700 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57004->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 5663844753 vs 11380000800 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60404->127.0.0.1:5222: write: connection reset by peer 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:60550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60288->127.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:60414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60374->127.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:60630->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:59936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59916->127.0.0.1:5222: write: connection reset by peer Benchmark___FanIn_128kx100x1 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60328->127.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:60294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59816->127.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:60594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59762->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: 865325090 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34142->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: 1334102930 vs 11326176000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59862->127.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:60318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60484->127.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:59746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60026->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:60260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59938->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: 435218800 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33490->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33656->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33548->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33924->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33884->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33878->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33882->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33850->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33648->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33534->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:33440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33982->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 328773720 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35662->127.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:35158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35524->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35342->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35558->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35196->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35330->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35708->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:35156->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: 765827780 vs 11562138000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37718->127.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:38528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38566->127.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:38000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37772->127.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:38144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38188->127.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:38254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38216->127.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:38466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38194->127.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:37736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37758->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5520830 646.3 ns/op 439.44 MB/s Benchmark___BumpPubCount_1x3-16 5488126 649.0 ns/op 437.58 MB/s Benchmark___BumpPubCount_1x3-16 5553199 646.4 ns/op 439.36 MB/s Benchmark___BumpPubCount_1x3-16 5523248 644.8 ns/op 440.47 MB/s Benchmark___BumpPubCount_1x3-16 5553741 649.3 ns/op 437.42 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5252874 677.6 ns/op 419.11 MB/s Benchmark___BumpPubCount_2x3-16 5221768 677.9 ns/op 418.96 MB/s Benchmark___BumpPubCount_2x3-16 5235771 675.1 ns/op 420.67 MB/s Benchmark___BumpPubCount_2x3-16 5271986 675.7 ns/op 420.31 MB/s Benchmark___BumpPubCount_2x3-16 5259398 677.9 ns/op 418.94 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5547487 642.4 ns/op 442.07 MB/s Benchmark___BumpPubCount_5x3-16 5538202 642.4 ns/op 442.06 MB/s Benchmark___BumpPubCount_5x3-16 5489125 642.3 ns/op 442.14 MB/s Benchmark___BumpPubCount_5x3-16 5189874 645.5 ns/op 439.97 MB/s Benchmark___BumpPubCount_5x3-16 5580606 655.6 ns/op 433.18 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5619426 644.3 ns/op 440.80 MB/s Benchmark__BumpPubCount_10x3-16 5598150 641.2 ns/op 442.89 MB/s Benchmark__BumpPubCount_10x3-16 5600894 641.9 ns/op 442.41 MB/s Benchmark__BumpPubCount_10x3-16 5585235 641.5 ns/op 442.68 MB/s Benchmark__BumpPubCount_10x3-16 5608111 642.0 ns/op 442.34 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11897846 276.9 ns/op 3755.60 MB/s Benchmark____GWs_Opt_1kx01x0-16 12285082 269.4 ns/op 3860.45 MB/s Benchmark____GWs_Opt_1kx01x0-16 11385937 288.5 ns/op 3604.25 MB/s Benchmark____GWs_Opt_1kx01x0-16 12762297 276.6 ns/op 3760.38 MB/s Benchmark____GWs_Opt_1kx01x0-16 11863014 281.3 ns/op 3697.22 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9519168 332.1 ns/op 6214.72 MB/s Benchmark____GWs_Opt_2kx01x0-16 11089558 342.3 ns/op 6030.08 MB/s Benchmark____GWs_Opt_2kx01x0-16 9447559 341.2 ns/op 6049.11 MB/s Benchmark____GWs_Opt_2kx01x0-16 10046260 335.1 ns/op 6159.40 MB/s Benchmark____GWs_Opt_2kx01x0-16 10844901 318.4 ns/op 6482.76 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5671758 632.6 ns/op 6499.70 MB/s Benchmark____GWs_Opt_4kx01x0-16 5536252 602.2 ns/op 6828.66 MB/s Benchmark____GWs_Opt_4kx01x0-16 5628477 604.2 ns/op 6805.90 MB/s Benchmark____GWs_Opt_4kx01x0-16 5641489 628.1 ns/op 6546.94 MB/s Benchmark____GWs_Opt_4kx01x0-16 5895108 626.1 ns/op 6567.33 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30284173 114.1 ns/op 9117.23 MB/s Benchmark____GWs_Opt_1kx10x0-16 31066918 114.9 ns/op 9054.62 MB/s Benchmark____GWs_Opt_1kx10x0-16 32627890 112.4 ns/op 9253.52 MB/s Benchmark____GWs_Opt_1kx10x0-16 32445548 111.9 ns/op 9293.01 MB/s Benchmark____GWs_Opt_1kx10x0-16 30855980 111.4 ns/op 9338.42 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23446899 144.0 ns/op 14338.28 MB/s Benchmark____GWs_Opt_2kx10x0-16 24207913 140.4 ns/op 14698.76 MB/s Benchmark____GWs_Opt_2kx10x0-16 19050618 169.1 ns/op 12208.76 MB/s Benchmark____GWs_Opt_2kx10x0-16 23281491 147.8 ns/op 13967.72 MB/s Benchmark____GWs_Opt_2kx10x0-16 24357373 148.3 ns/op 13914.53 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12866786 312.2 ns/op 13170.57 MB/s Benchmark____GWs_Opt_4kx10x0-16 12969870 322.6 ns/op 12747.18 MB/s Benchmark____GWs_Opt_4kx10x0-16 13092861 305.1 ns/op 13479.50 MB/s Benchmark____GWs_Opt_4kx10x0-16 11758762 310.6 ns/op 13239.32 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:40974->127.0.0.1:44285: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:60410->127.0.0.1:34089: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6574831 552.9 ns/op 5651.86 MB/s Benchmark____GWs_Opt_1kx01x1-16 6511960 547.8 ns/op 5704.16 MB/s Benchmark____GWs_Opt_1kx01x1-16 6554583 543.4 ns/op 5751.21 MB/s Benchmark____GWs_Opt_1kx01x1-16 6724105 542.0 ns/op 5765.19 MB/s Benchmark____GWs_Opt_1kx01x1-16 6865323 545.2 ns/op 5731.69 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4709018 756.2 ns/op 8194.85 MB/s Benchmark____GWs_Opt_2kx01x1-16 4718028 771.6 ns/op 8031.22 MB/s Benchmark____GWs_Opt_2kx01x1-16 4828803 752.9 ns/op 8230.59 MB/s Benchmark____GWs_Opt_2kx01x1-16 4655521 746.9 ns/op 8296.87 MB/s Benchmark____GWs_Opt_2kx01x1-16 4852947 833.5 ns/op 7435.19 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2376501 1487 ns/op 8296.57 MB/s Benchmark____GWs_Opt_4kx01x1-16 2593976 1343 ns/op 9189.16 MB/s Benchmark____GWs_Opt_4kx01x1-16 2610518 1363 ns/op 9054.46 MB/s Benchmark____GWs_Opt_4kx01x1-16 2666166 1350 ns/op 9140.38 MB/s Benchmark____GWs_Opt_4kx01x1-16 2653222 1359 ns/op 9082.54 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6171891 542.7 ns/op 5757.86 MB/s Benchmark____GWs_Opt_1kx10x1-16 6191536 542.1 ns/op 5764.73 MB/s Benchmark____GWs_Opt_1kx10x1-16 6455937 541.8 ns/op 5768.03 MB/s Benchmark____GWs_Opt_1kx10x1-16 5967927 542.0 ns/op 5766.02 MB/s Benchmark____GWs_Opt_1kx10x1-16 6649149 560.0 ns/op 5580.20 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4423309 839.0 ns/op 7386.26 MB/s Benchmark____GWs_Opt_2kx10x1-16 4184209 812.6 ns/op 7626.51 MB/s Benchmark____GWs_Opt_2kx10x1-16 4315744 826.9 ns/op 7493.80 MB/s Benchmark____GWs_Opt_2kx10x1-16 4208857 841.7 ns/op 7362.85 MB/s Benchmark____GWs_Opt_2kx10x1-16 4262988 827.2 ns/op 7491.50 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2438396 1424 ns/op 8665.62 MB/s Benchmark____GWs_Opt_4kx10x1-16 2368933 1504 ns/op 8204.68 MB/s Benchmark____GWs_Opt_4kx10x1-16 2251632 1672 ns/op 7380.68 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 443065458 vs 10343007620 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:49472->127.0.0.1:45285: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:49466->127.0.0.1:45285: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:49450->127.0.0.1:45285: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:49438->127.0.0.1:45285: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:49426->127.0.0.1:45285: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:49414->127.0.0.1:45285: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:49400->127.0.0.1:45285: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:49390->127.0.0.1:45285: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:49384->127.0.0.1:45285: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:49370->127.0.0.1:45285: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x1-16 Benchmark____GWs_Opt_4kx10x1-16 2485845 1516 ns/op 8138.59 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12094086 301.4 ns/op 3450.87 MB/s Benchmark____GWs_Int_1kx01x0-16 12241270 289.6 ns/op 3591.38 MB/s Benchmark____GWs_Int_1kx01x0-16 12238911 289.9 ns/op 3587.81 MB/s Benchmark____GWs_Int_1kx01x0-16 12790462 282.7 ns/op 3678.75 MB/s Benchmark____GWs_Int_1kx01x0-16 12150158 283.1 ns/op 3673.12 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 8966394 362.6 ns/op 5692.18 MB/s Benchmark____GWs_Int_2kx01x0-16 10463126 366.0 ns/op 5638.97 MB/s Benchmark____GWs_Int_2kx01x0-16 9752487 351.8 ns/op 5867.62 MB/s Benchmark____GWs_Int_2kx01x0-16 10197781 347.7 ns/op 5935.70 MB/s Benchmark____GWs_Int_2kx01x0-16 10611540 356.6 ns/op 5787.45 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5877705 639.1 ns/op 6433.75 MB/s Benchmark____GWs_Int_4kx01x0-16 5653930 649.5 ns/op 6330.95 MB/s Benchmark____GWs_Int_4kx01x0-16 5625900 628.1 ns/op 6546.70 MB/s Benchmark____GWs_Int_4kx01x0-16 5733649 630.5 ns/op 6522.01 MB/s Benchmark____GWs_Int_4kx01x0-16 5863700 614.4 ns/op 6693.12 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30004518 111.4 ns/op 9336.64 MB/s Benchmark____GWs_Int_1kx10x0-16 28614661 112.9 ns/op 9215.56 MB/s Benchmark____GWs_Int_1kx10x0-16 30955154 112.6 ns/op 9232.98 MB/s Benchmark____GWs_Int_1kx10x0-16 31535959 113.4 ns/op 9171.22 MB/s Benchmark____GWs_Int_1kx10x0-16 31833649 111.0 ns/op 9369.63 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25475206 141.6 ns/op 14576.45 MB/s Benchmark____GWs_Int_2kx10x0-16 25792012 150.9 ns/op 13680.74 MB/s Benchmark____GWs_Int_2kx10x0-16 25700368 138.7 ns/op 14880.16 MB/s Benchmark____GWs_Int_2kx10x0-16 20770046 150.7 ns/op 13693.01 MB/s Benchmark____GWs_Int_2kx10x0-16 25193702 146.3 ns/op 14107.78 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12510968 296.8 ns/op 13855.05 MB/s Benchmark____GWs_Int_4kx10x0-16 11199002 286.7 ns/op 14340.63 MB/s Benchmark____GWs_Int_4kx10x0-16 13156082 309.8 ns/op 13272.20 MB/s Benchmark____GWs_Int_4kx10x0-16 13205340 299.6 ns/op 13723.67 MB/s Benchmark____GWs_Int_4kx10x0-16 13060744 288.8 ns/op 14237.51 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6444133 557.0 ns/op 5610.66 MB/s Benchmark____GWs_Int_1kx01x1-16 6509906 549.9 ns/op 5683.00 MB/s Benchmark____GWs_Int_1kx01x1-16 6337455 549.8 ns/op 5684.34 MB/s Benchmark____GWs_Int_1kx01x1-16 6679072 554.8 ns/op 5632.21 MB/s Benchmark____GWs_Int_1kx01x1-16 6498991 550.3 ns/op 5678.42 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4835352 762.0 ns/op 8132.80 MB/s Benchmark____GWs_Int_2kx01x1-16 3774285 818.0 ns/op 7575.67 MB/s Benchmark____GWs_Int_2kx01x1-16 4752082 763.4 ns/op 8117.93 MB/s Benchmark____GWs_Int_2kx01x1-16 4780042 784.5 ns/op 7898.80 MB/s Benchmark____GWs_Int_2kx01x1-16 4628115 909.7 ns/op 6812.04 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2637297 1345 ns/op 9175.50 MB/s Benchmark____GWs_Int_4kx01x1-16 2653602 1605 ns/op 7691.34 MB/s Benchmark____GWs_Int_4kx01x1-16 2596856 1420 ns/op 8689.54 MB/s Benchmark____GWs_Int_4kx01x1-16 2669931 1372 ns/op 8996.87 MB/s Benchmark____GWs_Int_4kx01x1-16 2277782 1362 ns/op 9059.82 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6592554 552.5 ns/op 5655.68 MB/s Benchmark____GWs_Int_1kx10x1-16 6521462 549.5 ns/op 5686.96 MB/s Benchmark____GWs_Int_1kx10x1-16 6607590 545.1 ns/op 5732.66 MB/s Benchmark____GWs_Int_1kx10x1-16 6315571 554.0 ns/op 5641.14 MB/s Benchmark____GWs_Int_1kx10x1-16 6296716 547.2 ns/op 5711.16 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4197996 838.5 ns/op 7390.19 MB/s Benchmark____GWs_Int_2kx10x1-16 4098766 840.2 ns/op 7375.77 MB/s Benchmark____GWs_Int_2kx10x1-16 4344247 838.4 ns/op 7391.64 MB/s Benchmark____GWs_Int_2kx10x1-16 4217228 812.4 ns/op 7628.06 MB/s Benchmark____GWs_Int_2kx10x1-16 4276212 826.0 ns/op 7502.27 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2412892 1490 ns/op 8281.18 MB/s Benchmark____GWs_Int_4kx10x1-16 2140309 1525 ns/op 8093.99 MB/s Benchmark____GWs_Int_4kx10x1-16 2367082 1650 ns/op 7477.56 MB/s Benchmark____GWs_Int_4kx10x1-16 2427813 1520 ns/op 8116.90 MB/s Benchmark____GWs_Int_4kx10x1-16 2390791 1476 ns/op 8363.33 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8253285 431.1 ns/op 236.63 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8498079 429.3 ns/op 237.61 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8356663 430.7 ns/op 236.84 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8173650 436.7 ns/op 233.55 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8285161 431.0 ns/op 236.66 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 628858 5009 ns/op 35.33 MB/s Benchmark__GWs_Reqs_1SubEach-16 788244 5239 ns/op 33.78 MB/s Benchmark__GWs_Reqs_1SubEach-16 729268 5246 ns/op 33.74 MB/s Benchmark__GWs_Reqs_1SubEach-16 737979 5282 ns/op 33.51 MB/s Benchmark__GWs_Reqs_1SubEach-16 764580 5349 ns/op 33.09 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2090.970s ❌ Non-zero exit code: 1