> ROOT_DIR=/tmp/go-bench-away-job-e77c8277-5616-45f1-9f12-32d5f0de87ca-3685806307 > OUTPUT_FILE=/tmp/go-bench-away-job-e77c8277-5616-45f1-9f12-32d5f0de87ca-3685806307/results.txt > SHA_FILE=/tmp/go-bench-away-job-e77c8277-5616-45f1-9f12-32d5f0de87ca-3685806307/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-e77c8277-5616-45f1-9f12-32d5f0de87ca-3685806307/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=v2.14.3 > 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: v2.14.3 to /tmp/go-bench-away-job-e77c8277-5616-45f1-9f12-32d5f0de87ca-3685806307/source.git SHA of v2.14.3: 54a1a0713438ef03e7401c1537f6495b11af0d18 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-build1262408198=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-e77c8277-5616-45f1-9f12-32d5f0de87ca-3685806307/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 49053382 79.74 ns/op 137.95 MB/s Benchmark______Pub0b_Payload-16 46514976 74.11 ns/op 148.44 MB/s Benchmark______Pub0b_Payload-16 46158187 73.41 ns/op 149.85 MB/s Benchmark______Pub0b_Payload-16 45354442 73.23 ns/op 150.22 MB/s Benchmark______Pub0b_Payload-16 46001808 73.24 ns/op 150.20 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46305790 73.70 ns/op 257.81 MB/s Benchmark______Pub8b_Payload-16 46046353 73.80 ns/op 257.44 MB/s Benchmark______Pub8b_Payload-16 44674003 73.83 ns/op 257.34 MB/s Benchmark______Pub8b_Payload-16 46056273 73.85 ns/op 257.29 MB/s Benchmark______Pub8b_Payload-16 48615776 73.71 ns/op 257.76 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 45777508 77.44 ns/op 568.18 MB/s Benchmark_____Pub32b_Payload-16 43701428 77.51 ns/op 567.70 MB/s Benchmark_____Pub32b_Payload-16 46518831 78.07 ns/op 563.57 MB/s Benchmark_____Pub32b_Payload-16 38118000 83.16 ns/op 529.12 MB/s Benchmark_____Pub32b_Payload-16 43819042 78.11 ns/op 563.32 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 35012912 86.38 ns/op 1632.40 MB/s Benchmark____Pub128B_Payload-16 39110349 87.32 ns/op 1614.84 MB/s Benchmark____Pub128B_Payload-16 41158278 86.63 ns/op 1627.58 MB/s Benchmark____Pub128B_Payload-16 39182532 89.62 ns/op 1573.22 MB/s Benchmark____Pub128B_Payload-16 39745106 86.87 ns/op 1623.03 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 32039556 94.51 ns/op 2846.35 MB/s Benchmark____Pub256B_Payload-16 32239236 95.52 ns/op 2816.11 MB/s Benchmark____Pub256B_Payload-16 35634946 95.69 ns/op 2811.06 MB/s Benchmark____Pub256B_Payload-16 35192571 97.93 ns/op 2747.00 MB/s Benchmark____Pub256B_Payload-16 36394437 95.45 ns/op 2818.37 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23725774 153.5 ns/op 6760.16 MB/s Benchmark______Pub1K_Payload-16 25460488 143.2 ns/op 7246.58 MB/s Benchmark______Pub1K_Payload-16 25462012 138.5 ns/op 7494.69 MB/s Benchmark______Pub1K_Payload-16 26469988 144.3 ns/op 7194.59 MB/s Benchmark______Pub1K_Payload-16 21738860 142.9 ns/op 7261.50 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5437656 632.6 ns/op 6496.72 MB/s Benchmark______Pub4K_Payload-16 5373648 622.2 ns/op 6605.97 MB/s Benchmark______Pub4K_Payload-16 5655123 620.5 ns/op 6623.80 MB/s Benchmark______Pub4K_Payload-16 5509804 614.1 ns/op 6692.77 MB/s Benchmark______Pub4K_Payload-16 5682490 614.9 ns/op 6683.56 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2692909 1284 ns/op 6393.09 MB/s Benchmark______Pub8K_Payload-16 2777990 1281 ns/op 6404.24 MB/s Benchmark______Pub8K_Payload-16 2706718 1289 ns/op 6364.59 MB/s Benchmark______Pub8K_Payload-16 2773684 1285 ns/op 6385.28 MB/s Benchmark______Pub8K_Payload-16 2782837 1282 ns/op 6398.92 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 664633 5353 ns/op 6124.80 MB/s Benchmark_____Pub32K_Payload-16 556723 5530 ns/op 5928.20 MB/s Benchmark_____Pub32K_Payload-16 523414 6066 ns/op 5404.27 MB/s Benchmark_____Pub32K_Payload-16 550616 5493 ns/op 5968.02 MB/s Benchmark_____Pub32K_Payload-16 674408 5484 ns/op 5977.99 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32787226 91.73 ns/op 119.92 MB/s Benchmark__AuthPub0b_Payload-16 36284018 93.98 ns/op 117.05 MB/s Benchmark__AuthPub0b_Payload-16 34370476 93.79 ns/op 117.29 MB/s Benchmark__AuthPub0b_Payload-16 34408923 94.08 ns/op 116.93 MB/s Benchmark__AuthPub0b_Payload-16 36377916 92.57 ns/op 118.83 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15446688 227.6 ns/op Benchmark_____________PubSub-16 15661290 226.9 ns/op Benchmark_____________PubSub-16 15729894 226.4 ns/op Benchmark_____________PubSub-16 15524763 226.9 ns/op Benchmark_____________PubSub-16 15546698 226.3 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15495184 225.9 ns/op Benchmark_____PubSubTwoConns-16 15839607 225.8 ns/op Benchmark_____PubSubTwoConns-16 15691178 225.6 ns/op Benchmark_____PubSubTwoConns-16 15628374 226.7 ns/op Benchmark_____PubSubTwoConns-16 15590419 226.1 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:38662->127.0.0.1:38795: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34324->127.0.0.1:42223: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50044->127.0.0.1:37281: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42962->127.0.0.1:44463: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:53788->127.0.0.1:37351: 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 14609152 242.9 ns/op Benchmark_____PubTwoQueueSub-16 14615488 242.8 ns/op Benchmark_____PubTwoQueueSub-16 14464208 242.5 ns/op Benchmark_____PubTwoQueueSub-16 14562124 243.6 ns/op Benchmark_____PubTwoQueueSub-16 14389536 242.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14640015 243.8 ns/op Benchmark____PubFourQueueSub-16 14652475 243.0 ns/op Benchmark____PubFourQueueSub-16 14643038 243.5 ns/op Benchmark____PubFourQueueSub-16 14584210 243.2 ns/op Benchmark____PubFourQueueSub-16 14718736 243.2 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14499072 243.5 ns/op Benchmark___PubEightQueueSub-16 14476761 241.7 ns/op Benchmark___PubEightQueueSub-16 14551645 243.2 ns/op Benchmark___PubEightQueueSub-16 14558028 243.6 ns/op Benchmark___PubEightQueueSub-16 14452237 242.8 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23274 155312 ns/op Benchmark_PubSub512kTwoConns-16 23054 166130 ns/op Benchmark_PubSub512kTwoConns-16 22894 156118 ns/op Benchmark_PubSub512kTwoConns-16 23163 155728 ns/op Benchmark_PubSub512kTwoConns-16 23176 156426 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15154208 228.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15451638 228.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15381235 228.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 15262436 229.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15304092 229.6 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15344230 228.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15010347 229.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15101378 230.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15217162 229.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15187738 229.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11491246 309.5 ns/op Benchmark____RoutedPubSub_0b-16 11607193 309.6 ns/op Benchmark____RoutedPubSub_0b-16 11531218 307.2 ns/op Benchmark____RoutedPubSub_0b-16 11471416 304.2 ns/op Benchmark____RoutedPubSub_0b-16 11106091 308.7 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6792152 533.9 ns/op Benchmark____RoutedPubSub_1K-16 6736773 535.8 ns/op Benchmark____RoutedPubSub_1K-16 6792609 535.6 ns/op Benchmark____RoutedPubSub_1K-16 6816882 521.7 ns/op Benchmark____RoutedPubSub_1K-16 6651483 533.5 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85875 42626 ns/op Benchmark__RoutedPubSub_100K-16 84093 41841 ns/op Benchmark__RoutedPubSub_100K-16 80763 43090 ns/op Benchmark__RoutedPubSub_100K-16 85785 43411 ns/op Benchmark__RoutedPubSub_100K-16 83965 42035 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9968901 312.5 ns/op Benchmark____Routed2QueueSub-16 9818654 315.9 ns/op Benchmark____Routed2QueueSub-16 9963784 314.8 ns/op Benchmark____Routed2QueueSub-16 9806322 317.7 ns/op Benchmark____Routed2QueueSub-16 9847504 315.6 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9634419 323.8 ns/op Benchmark____Routed4QueueSub-16 9457840 321.2 ns/op Benchmark____Routed4QueueSub-16 9582790 313.1 ns/op Benchmark____Routed4QueueSub-16 9770098 320.2 ns/op Benchmark____Routed4QueueSub-16 9513229 315.4 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 11186874 326.1 ns/op Benchmark____Routed8QueueSub-16 9236884 325.1 ns/op Benchmark____Routed8QueueSub-16 9204508 331.7 ns/op Benchmark____Routed8QueueSub-16 9491824 329.3 ns/op Benchmark____Routed8QueueSub-16 11082439 327.5 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 10603324 336.3 ns/op Benchmark___Routed16QueueSub-16 10631108 340.2 ns/op Benchmark___Routed16QueueSub-16 9120156 337.7 ns/op Benchmark___Routed16QueueSub-16 9068535 340.3 ns/op Benchmark___Routed16QueueSub-16 8949758 340.7 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 7775766 552.1 ns/op Benchmark____________RouteCompressOff-16 6527054 546.4 ns/op Benchmark____________RouteCompressOff-16 6448630 548.0 ns/op Benchmark____________RouteCompressOff-16 6640231 545.1 ns/op Benchmark____________RouteCompressOff-16 6591885 549.3 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6367822 548.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6437330 549.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6560834 547.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6423134 547.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6538317 469.4 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6471884 545.0 ns/op Benchmark_________RouteCompressS2Fast-16 6456103 543.8 ns/op Benchmark_________RouteCompressS2Fast-16 6502287 482.6 ns/op Benchmark_________RouteCompressS2Fast-16 6452863 542.6 ns/op Benchmark_________RouteCompressS2Fast-16 6504927 548.0 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6525982 549.1 ns/op Benchmark_______RouteCompressS2Better-16 6298932 541.0 ns/op Benchmark_______RouteCompressS2Better-16 6434734 550.8 ns/op Benchmark_______RouteCompressS2Better-16 6546762 536.0 ns/op Benchmark_______RouteCompressS2Better-16 6659742 548.5 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6436671 548.6 ns/op Benchmark_________RouteCompressS2Best-16 6511256 544.8 ns/op Benchmark_________RouteCompressS2Best-16 6368124 549.9 ns/op Benchmark_________RouteCompressS2Best-16 6512475 540.8 ns/op Benchmark_________RouteCompressS2Best-16 6414154 552.1 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4601539 760.3 ns/op 327.48 MB/s Benchmark______FanOut_8x1x10-16 4644994 761.4 ns/op 327.01 MB/s Benchmark______FanOut_8x1x10-16 4721754 762.7 ns/op 326.46 MB/s Benchmark______FanOut_8x1x10-16 4713318 762.0 ns/op 326.79 MB/s Benchmark______FanOut_8x1x10-16 4705810 761.0 ns/op 327.19 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 553453 6090 ns/op 380.80 MB/s Benchmark_____FanOut_8x1x100-16 541672 6040 ns/op 383.92 MB/s Benchmark_____FanOut_8x1x100-16 519451 5984 ns/op 387.50 MB/s Benchmark_____FanOut_8x1x100-16 545696 6213 ns/op 373.27 MB/s Benchmark_____FanOut_8x1x100-16 531573 6065 ns/op 382.35 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48470 73612 ns/op 312.71 MB/s Benchmark____FanOut_8x10x100-16 48836 73690 ns/op 312.38 MB/s Benchmark____FanOut_8x10x100-16 49045 73647 ns/op 312.56 MB/s Benchmark____FanOut_8x10x100-16 48855 73531 ns/op 313.05 MB/s Benchmark____FanOut_8x10x100-16 48387 74100 ns/op 310.65 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5684 587834 ns/op 408.31 MB/s Benchmark___FanOut_8x10x1000-16 5972 605052 ns/op 396.69 MB/s Benchmark___FanOut_8x10x1000-16 6133 588488 ns/op 407.86 MB/s Benchmark___FanOut_8x10x1000-16 5895 592291 ns/op 405.24 MB/s Benchmark___FanOut_8x10x1000-16 6045 586619 ns/op 409.16 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4947 697738 ns/op 329.66 MB/s Benchmark___FanOut_8x100x100-16 5044 701508 ns/op 327.89 MB/s Benchmark___FanOut_8x100x100-16 5132 697038 ns/op 329.99 MB/s Benchmark___FanOut_8x100x100-16 4974 707551 ns/op 325.09 MB/s Benchmark___FanOut_8x100x100-16 5055 695503 ns/op 330.72 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 588 6298702 ns/op 381.03 MB/s Benchmark__FanOut_8x100x1000-16 590 6000420 ns/op 399.98 MB/s Benchmark__FanOut_8x100x1000-16 580 6050078 ns/op 396.69 MB/s Benchmark__FanOut_8x100x1000-16 592 6120659 ns/op 392.12 MB/s Benchmark__FanOut_8x100x1000-16 585 6036800 ns/op 397.56 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 534 6719220 ns/op 372.07 MB/s Benchmark__FanOut_8x10x10000-16 531 6675276 ns/op 374.52 MB/s Benchmark__FanOut_8x10x10000-16 542 6679335 ns/op 374.29 MB/s Benchmark__FanOut_8x10x10000-16 538 6582595 ns/op 379.79 MB/s Benchmark__FanOut_8x10x10000-16 532 6660006 ns/op 375.38 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 957 3701855 ns/op 310.66 MB/s Benchmark___FanOut_8x500x100-16 967 3706481 ns/op 310.27 MB/s Benchmark___FanOut_8x500x100-16 961 3738539 ns/op 307.61 MB/s Benchmark___FanOut_8x500x100-16 967 3702392 ns/op 310.62 MB/s Benchmark___FanOut_8x500x100-16 964 3699480 ns/op 310.86 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 353966 9485 ns/op 1543.66 MB/s Benchmark___FanOut_128x1x100-16 360544 9444 ns/op 1550.22 MB/s Benchmark___FanOut_128x1x100-16 372064 9492 ns/op 1542.53 MB/s Benchmark___FanOut_128x1x100-16 360895 9503 ns/op 1540.75 MB/s Benchmark___FanOut_128x1x100-16 356829 9400 ns/op 1557.57 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32852 109344 ns/op 1327.37 MB/s Benchmark__FanOut_128x10x100-16 33086 109522 ns/op 1325.23 MB/s Benchmark__FanOut_128x10x100-16 32959 109067 ns/op 1330.75 MB/s Benchmark__FanOut_128x10x100-16 32916 109537 ns/op 1325.04 MB/s Benchmark__FanOut_128x10x100-16 33052 110054 ns/op 1318.82 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4005 866673 ns/op 1684.77 MB/s Benchmark_FanOut_128x10x1000-16 3964 858799 ns/op 1700.21 MB/s Benchmark_FanOut_128x10x1000-16 4012 860676 ns/op 1696.51 MB/s Benchmark_FanOut_128x10x1000-16 4101 855908 ns/op 1705.96 MB/s Benchmark_FanOut_128x10x1000-16 4141 856300 ns/op 1705.17 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3525 992657 ns/op 1460.87 MB/s Benchmark_FanOut_128x100x100-16 3602 998270 ns/op 1452.65 MB/s Benchmark_FanOut_128x100x100-16 3574 998521 ns/op 1452.29 MB/s Benchmark_FanOut_128x100x100-16 3535 1001182 ns/op 1448.43 MB/s Benchmark_FanOut_128x100x100-16 3549 1004698 ns/op 1443.36 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 402 9086470 ns/op 1606.80 MB/s BenchmarkFanOut_128x100x1000-16 396 9163902 ns/op 1593.22 MB/s BenchmarkFanOut_128x100x1000-16 388 9213450 ns/op 1584.66 MB/s BenchmarkFanOut_128x100x1000-16 391 9148961 ns/op 1595.83 MB/s BenchmarkFanOut_128x100x1000-16 391 9075757 ns/op 1608.70 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 379 9563629 ns/op 1537.09 MB/s BenchmarkFanOut_128x10x10000-16 370 9575046 ns/op 1535.26 MB/s BenchmarkFanOut_128x10x10000-16 378 9570180 ns/op 1536.04 MB/s BenchmarkFanOut_128x10x10000-16 376 9522946 ns/op 1543.65 MB/s BenchmarkFanOut_128x10x10000-16 378 9556768 ns/op 1538.19 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 684 5206628 ns/op 1392.48 MB/s BenchmarkFanOut__128x500x100-16 669 5205629 ns/op 1392.75 MB/s BenchmarkFanOut__128x500x100-16 674 5210570 ns/op 1391.43 MB/s BenchmarkFanOut__128x500x100-16 685 5209778 ns/op 1391.64 MB/s BenchmarkFanOut__128x500x100-16 673 5184106 ns/op 1398.53 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1958 1826680 ns/op 2896.25 MB/s Benchmark_FanOut_512x100x100-16 1954 1824590 ns/op 2899.57 MB/s Benchmark_FanOut_512x100x100-16 1962 1820135 ns/op 2906.67 MB/s Benchmark_FanOut_512x100x100-16 1944 1842155 ns/op 2871.92 MB/s Benchmark_FanOut_512x100x100-16 1934 1828572 ns/op 2893.25 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 217 16502712 ns/op 3211.63 MB/s Benchmark__FanOut_512x100x1k-16 214 16633323 ns/op 3186.41 MB/s Benchmark__FanOut_512x100x1k-16 218 16603778 ns/op 3192.08 MB/s Benchmark__FanOut_512x100x1k-16 219 16372945 ns/op 3237.08 MB/s Benchmark__FanOut_512x100x1k-16 217 16544300 ns/op 3203.55 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3050 1145176 ns/op 9108.67 MB/s Benchmark____FanOut_1kx10x1k-16 2960 1154712 ns/op 9033.45 MB/s Benchmark____FanOut_1kx10x1k-16 3254 1125485 ns/op 9268.04 MB/s Benchmark____FanOut_1kx10x1k-16 3034 1146091 ns/op 9101.41 MB/s Benchmark____FanOut_1kx10x1k-16 3098 1155883 ns/op 9024.30 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2860 1257154 ns/op 8289.39 MB/s Benchmark__FanOut_1kx100x100-16 2740 1248405 ns/op 8347.48 MB/s Benchmark__FanOut_1kx100x100-16 2751 1239778 ns/op 8405.57 MB/s Benchmark__FanOut_1kx100x100-16 2850 1237935 ns/op 8418.08 MB/s Benchmark__FanOut_1kx100x100-16 2790 1239129 ns/op 8409.97 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4412582 770.3 ns/op 323.24 MB/s Benchmark_____RFanOut_8x1x10-16 4497606 778.0 ns/op 320.06 MB/s Benchmark_____RFanOut_8x1x10-16 4444489 761.3 ns/op 327.05 MB/s Benchmark_____RFanOut_8x1x10-16 4522635 768.0 ns/op 324.20 MB/s Benchmark_____RFanOut_8x1x10-16 4625961 769.9 ns/op 323.42 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 554802 6318 ns/op 367.07 MB/s Benchmark____RFanOut_8x1x100-16 517818 6280 ns/op 369.27 MB/s Benchmark____RFanOut_8x1x100-16 517148 6304 ns/op 367.84 MB/s Benchmark____RFanOut_8x1x100-16 544920 6254 ns/op 370.79 MB/s Benchmark____RFanOut_8x1x100-16 568544 6327 ns/op 366.51 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48742 73836 ns/op 311.76 MB/s Benchmark___RFanOut_8x10x100-16 48411 74194 ns/op 310.25 MB/s Benchmark___RFanOut_8x10x100-16 48362 73993 ns/op 311.10 MB/s Benchmark___RFanOut_8x10x100-16 47887 74267 ns/op 309.95 MB/s Benchmark___RFanOut_8x10x100-16 48286 74143 ns/op 310.47 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6067 591178 ns/op 406.00 MB/s Benchmark__RFanOut_8x10x1000-16 6001 588725 ns/op 407.69 MB/s Benchmark__RFanOut_8x10x1000-16 6028 588835 ns/op 407.62 MB/s Benchmark__RFanOut_8x10x1000-16 5960 590791 ns/op 406.27 MB/s Benchmark__RFanOut_8x10x1000-16 5516 586550 ns/op 409.20 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5047 696405 ns/op 330.29 MB/s Benchmark__RFanOut_8x100x100-16 5090 698626 ns/op 329.24 MB/s Benchmark__RFanOut_8x100x100-16 5017 698889 ns/op 329.12 MB/s Benchmark__RFanOut_8x100x100-16 4972 708393 ns/op 324.71 MB/s Benchmark__RFanOut_8x100x100-16 5095 700616 ns/op 328.31 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 579 6019489 ns/op 398.71 MB/s Benchmark_RFanOut_8x100x1000-16 579 6154468 ns/op 389.96 MB/s Benchmark_RFanOut_8x100x1000-16 589 6070835 ns/op 395.34 MB/s Benchmark_RFanOut_8x100x1000-16 582 6022194 ns/op 398.53 MB/s Benchmark_RFanOut_8x100x1000-16 572 6052396 ns/op 396.54 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 529 6596411 ns/op 379.00 MB/s Benchmark_RFanOut_8x10x10000-16 534 6667550 ns/op 374.95 MB/s Benchmark_RFanOut_8x10x10000-16 531 6666909 ns/op 374.99 MB/s Benchmark_RFanOut_8x10x10000-16 540 6693886 ns/op 373.48 MB/s Benchmark_RFanOut_8x10x10000-16 542 6613783 ns/op 378.00 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3296 1128794 ns/op 9240.87 MB/s Benchmark_RFanOut_1kx10x1000-16 3116 1138492 ns/op 9162.15 MB/s Benchmark_RFanOut_1kx10x1000-16 3175 1137000 ns/op 9174.17 MB/s Benchmark_RFanOut_1kx10x1000-16 3128 1153527 ns/op 9042.74 MB/s Benchmark_RFanOut_1kx10x1000-16 3166 1131779 ns/op 9216.50 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7018976 504.2 ns/op 4121.28 MB/s Benchmark_____FanIn_1kx100x1-16 6945180 504.6 ns/op 4118.05 MB/s Benchmark_____FanIn_1kx100x1-16 7009521 504.7 ns/op 4117.69 MB/s Benchmark_____FanIn_1kx100x1-16 6979947 504.4 ns/op 4119.98 MB/s Benchmark_____FanIn_1kx100x1-16 6991056 503.2 ns/op 4129.73 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2629932 1361 ns/op 6041.24 MB/s Benchmark_____FanIn_4kx100x1-16 2626017 1373 ns/op 5987.93 MB/s Benchmark_____FanIn_4kx100x1-16 2626290 1364 ns/op 6026.61 MB/s Benchmark_____FanIn_4kx100x1-16 2596560 1371 ns/op 5996.53 MB/s Benchmark_____FanIn_4kx100x1-16 2623606 1371 ns/op 5997.87 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1715491 2118 ns/op 7749.10 MB/s Benchmark_____FanIn_8kx100x1-16 1722856 2127 ns/op 7718.66 MB/s Benchmark_____FanIn_8kx100x1-16 1727626 2112 ns/op 7773.37 MB/s Benchmark_____FanIn_8kx100x1-16 1717192 2122 ns/op 7734.44 MB/s Benchmark_____FanIn_8kx100x1-16 1698964 2097 ns/op 7827.12 MB/s Benchmark____FanIn_16kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 195221103 vs 14239348200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42980->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42824->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42846->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43280->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43158->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43388->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43286->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42736->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42904->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43510->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_16kx100x1-16 Benchmark____FanIn_16kx100x1-16 878468 4125 ns/op 7951.66 MB/s Benchmark____FanIn_16kx100x1-16 866203 4406 ns/op 7444.38 MB/s Benchmark____FanIn_16kx100x1-16 869601 4128 ns/op 7945.50 MB/s Benchmark____FanIn_16kx100x1-16 876339 4141 ns/op 7921.64 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 2203367436 vs 11124344100 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49126->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 167718 19678 ns/op 6662.30 MB/s Benchmark____FanIn_64kx100x1-16 169437 20009 ns/op 6552.27 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 2416021368 vs 10973572200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57248->127.0.0.1:5222: write: connection reset by peer 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: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:57196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57290->127.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:57106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57156->127.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:57754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57028->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:57498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57632->127.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:57534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57474->127.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:57262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57512->127.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:57070->127.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:57836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57124->127.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:57812->127.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:57898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57206->127.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:57648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57118->127.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:57928->127.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: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:57822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57074->127.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:57526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57344->127.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:57048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57194->127.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:57630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57186->127.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:57670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57698->127.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:57306->127.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:57318->127.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:57728->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: 4278250992 vs 10803134400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60450->127.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:60312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60206->127.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:59990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60662->127.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:59848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60362->127.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_64kx100x1-16 Benchmark___FanIn_128kx100x1 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:60588->127.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: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: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:60270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59974->127.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:60130->127.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: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:60746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60384->127.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:59864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60422->127.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: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:60670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60200->127.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: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: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:60048->127.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: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: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:60234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60326->127.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: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: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: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:60652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60436->127.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: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:59920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60250->127.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: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: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:60298->127.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:59966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60372->127.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:60016->127.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: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:60064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60144->127.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:60750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60472->127.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:60334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59876->127.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:60602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59836->127.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 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60712->127.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: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:59884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59914->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1073233830 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39908->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: 92156270 vs 11693228000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43146->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: 297967570 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44554->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: 464845140 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46908->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:46830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46202->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: 854706800 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48266->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5572916 639.2 ns/op 444.29 MB/s Benchmark___BumpPubCount_1x3-16 5563185 641.8 ns/op 442.48 MB/s Benchmark___BumpPubCount_1x3-16 5557447 639.0 ns/op 444.46 MB/s Benchmark___BumpPubCount_1x3-16 5528760 644.8 ns/op 440.46 MB/s Benchmark___BumpPubCount_1x3-16 5591286 638.9 ns/op 444.54 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5320731 667.9 ns/op 425.22 MB/s Benchmark___BumpPubCount_2x3-16 5293641 672.1 ns/op 422.58 MB/s Benchmark___BumpPubCount_2x3-16 5299183 672.1 ns/op 422.54 MB/s Benchmark___BumpPubCount_2x3-16 5340474 672.3 ns/op 422.42 MB/s Benchmark___BumpPubCount_2x3-16 5320458 670.7 ns/op 423.41 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5581692 649.7 ns/op 437.09 MB/s Benchmark___BumpPubCount_5x3-16 5615728 641.5 ns/op 442.68 MB/s Benchmark___BumpPubCount_5x3-16 5365022 641.7 ns/op 442.57 MB/s Benchmark___BumpPubCount_5x3-16 5293521 644.0 ns/op 441.02 MB/s Benchmark___BumpPubCount_5x3-16 5309344 638.9 ns/op 444.50 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5562058 644.8 ns/op 440.42 MB/s Benchmark__BumpPubCount_10x3-16 5606923 644.4 ns/op 440.73 MB/s Benchmark__BumpPubCount_10x3-16 5596748 642.3 ns/op 442.14 MB/s Benchmark__BumpPubCount_10x3-16 5591569 645.3 ns/op 440.10 MB/s Benchmark__BumpPubCount_10x3-16 5574555 641.8 ns/op 442.51 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12472918 267.7 ns/op 3884.57 MB/s Benchmark____GWs_Opt_1kx01x0-16 12712392 274.4 ns/op 3789.68 MB/s Benchmark____GWs_Opt_1kx01x0-16 12696836 272.3 ns/op 3818.87 MB/s Benchmark____GWs_Opt_1kx01x0-16 12687908 265.8 ns/op 3912.84 MB/s Benchmark____GWs_Opt_1kx01x0-16 12152356 274.3 ns/op 3790.94 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10365127 340.2 ns/op 6067.69 MB/s Benchmark____GWs_Opt_2kx01x0-16 10697416 344.6 ns/op 5989.83 MB/s Benchmark____GWs_Opt_2kx01x0-16 10817406 337.2 ns/op 6121.70 MB/s Benchmark____GWs_Opt_2kx01x0-16 10809294 327.0 ns/op 6312.34 MB/s Benchmark____GWs_Opt_2kx01x0-16 11043693 332.4 ns/op 6209.02 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5723587 648.9 ns/op 6337.03 MB/s Benchmark____GWs_Opt_4kx01x0-16 5765050 629.8 ns/op 6529.51 MB/s Benchmark____GWs_Opt_4kx01x0-16 5756522 613.1 ns/op 6707.43 MB/s Benchmark____GWs_Opt_4kx01x0-16 5641318 626.6 ns/op 6561.89 MB/s Benchmark____GWs_Opt_4kx01x0-16 5366872 646.9 ns/op 6356.07 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28127679 111.9 ns/op 9292.45 MB/s Benchmark____GWs_Opt_1kx10x0-16 31769528 111.4 ns/op 9338.14 MB/s Benchmark____GWs_Opt_1kx10x0-16 27876620 115.1 ns/op 9034.28 MB/s Benchmark____GWs_Opt_1kx10x0-16 30451080 120.0 ns/op 8663.75 MB/s Benchmark____GWs_Opt_1kx10x0-16 30481393 112.4 ns/op 9253.94 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 8642946 890.4 ns/op 2317.95 MB/s Benchmark____GWs_Opt_2kx10x0-16 25097688 145.3 ns/op 14204.94 MB/s Benchmark____GWs_Opt_2kx10x0-16 25723768 147.7 ns/op 13973.96 MB/s Benchmark____GWs_Opt_2kx10x0-16 23849048 147.2 ns/op 14023.60 MB/s Benchmark____GWs_Opt_2kx10x0-16 24909010 141.6 ns/op 14578.67 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 10253786 296.3 ns/op 13878.58 MB/s Benchmark____GWs_Opt_4kx10x0-16 11088531 294.3 ns/op 13970.41 MB/s Benchmark____GWs_Opt_4kx10x0-16 12636843 287.6 ns/op 14296.43 MB/s Benchmark____GWs_Opt_4kx10x0-16 12629044 319.7 ns/op 12860.16 MB/s Benchmark____GWs_Opt_4kx10x0-16 7754046 395.8 ns/op 10389.46 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6429405 536.3 ns/op 5826.92 MB/s Benchmark____GWs_Opt_1kx01x1-16 6433170 550.2 ns/op 5679.45 MB/s Benchmark____GWs_Opt_1kx01x1-16 6647500 545.2 ns/op 5731.51 MB/s Benchmark____GWs_Opt_1kx01x1-16 6765390 539.3 ns/op 5794.08 MB/s Benchmark____GWs_Opt_1kx01x1-16 6696360 545.6 ns/op 5727.23 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4622890 752.5 ns/op 8234.94 MB/s Benchmark____GWs_Opt_2kx01x1-16 4630494 752.7 ns/op 8233.19 MB/s Benchmark____GWs_Opt_2kx01x1-16 4650760 772.0 ns/op 8027.21 MB/s Benchmark____GWs_Opt_2kx01x1-16 4441912 757.0 ns/op 8186.28 MB/s Benchmark____GWs_Opt_2kx01x1-16 4744951 758.0 ns/op 8175.41 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2560579 1383 ns/op 8925.07 MB/s Benchmark____GWs_Opt_4kx01x1-16 2630382 1375 ns/op 8976.91 MB/s Benchmark____GWs_Opt_4kx01x1-16 2585689 1464 ns/op 8427.90 MB/s Benchmark____GWs_Opt_4kx01x1-16 2627796 1381 ns/op 8938.89 MB/s Benchmark____GWs_Opt_4kx01x1-16 2616552 1461 ns/op 8448.98 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6488104 548.3 ns/op 5699.36 MB/s Benchmark____GWs_Opt_1kx10x1-16 6551299 549.2 ns/op 5690.01 MB/s Benchmark____GWs_Opt_1kx10x1-16 6220735 553.8 ns/op 5643.23 MB/s Benchmark____GWs_Opt_1kx10x1-16 6624721 552.8 ns/op 5652.55 MB/s Benchmark____GWs_Opt_1kx10x1-16 5593212 554.2 ns/op 5638.56 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4156680 838.8 ns/op 7387.99 MB/s Benchmark____GWs_Opt_2kx10x1-16 4762707 840.2 ns/op 7375.96 MB/s Benchmark____GWs_Opt_2kx10x1-16 4286127 838.7 ns/op 7388.66 MB/s Benchmark____GWs_Opt_2kx10x1-16 4247524 846.2 ns/op 7323.17 MB/s Benchmark____GWs_Opt_2kx10x1-16 4060798 860.0 ns/op 7205.68 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2505920 1645 ns/op 7502.58 MB/s Benchmark____GWs_Opt_4kx10x1-16 2511652 1404 ns/op 8792.42 MB/s Benchmark____GWs_Opt_4kx10x1-16 2398009 1509 ns/op 8180.87 MB/s Benchmark____GWs_Opt_4kx10x1-16 2336593 1554 ns/op 7942.83 MB/s Benchmark____GWs_Opt_4kx10x1-16 2577836 1533 ns/op 8050.71 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 10820664 287.2 ns/op 3620.93 MB/s Benchmark____GWs_Int_1kx01x0-16 12445416 282.2 ns/op 3685.20 MB/s Benchmark____GWs_Int_1kx01x0-16 12713061 293.1 ns/op 3548.63 MB/s Benchmark____GWs_Int_1kx01x0-16 12252735 304.4 ns/op 3416.98 MB/s Benchmark____GWs_Int_1kx01x0-16 12360976 288.5 ns/op 3604.80 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10353219 370.7 ns/op 5567.18 MB/s Benchmark____GWs_Int_2kx01x0-16 10624963 357.1 ns/op 5780.51 MB/s Benchmark____GWs_Int_2kx01x0-16 10316564 349.6 ns/op 5904.35 MB/s Benchmark____GWs_Int_2kx01x0-16 10555581 354.4 ns/op 5824.68 MB/s Benchmark____GWs_Int_2kx01x0-16 9989121 351.1 ns/op 5879.43 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5614878 653.3 ns/op 6293.74 MB/s Benchmark____GWs_Int_4kx01x0-16 5700526 661.2 ns/op 6219.13 MB/s Benchmark____GWs_Int_4kx01x0-16 5734363 643.9 ns/op 6386.24 MB/s Benchmark____GWs_Int_4kx01x0-16 5765002 729.4 ns/op 5637.24 MB/s Benchmark____GWs_Int_4kx01x0-16 5655271 645.7 ns/op 6368.04 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31849538 111.4 ns/op 9332.12 MB/s Benchmark____GWs_Int_1kx10x0-16 30481851 113.6 ns/op 9154.30 MB/s Benchmark____GWs_Int_1kx10x0-16 31550844 110.6 ns/op 9401.12 MB/s Benchmark____GWs_Int_1kx10x0-16 32099928 115.8 ns/op 8978.42 MB/s Benchmark____GWs_Int_1kx10x0-16 30953151 115.7 ns/op 8990.30 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25042386 160.0 ns/op 12903.33 MB/s Benchmark____GWs_Int_2kx10x0-16 24454404 166.1 ns/op 12427.73 MB/s Benchmark____GWs_Int_2kx10x0-16 26092034 149.8 ns/op 13776.84 MB/s Benchmark____GWs_Int_2kx10x0-16 25612869 144.1 ns/op 14327.31 MB/s Benchmark____GWs_Int_2kx10x0-16 25348938 161.2 ns/op 12801.53 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11377233 284.7 ns/op 14441.02 MB/s Benchmark____GWs_Int_4kx10x0-16 12087463 288.1 ns/op 14274.62 MB/s Benchmark____GWs_Int_4kx10x0-16 11601690 350.1 ns/op 11746.45 MB/s Benchmark____GWs_Int_4kx10x0-16 13149442 360.7 ns/op 11400.67 MB/s Benchmark____GWs_Int_4kx10x0-16 12929276 284.1 ns/op 14473.35 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6555310 554.3 ns/op 5638.25 MB/s Benchmark____GWs_Int_1kx01x1-16 6464701 552.5 ns/op 5655.66 MB/s Benchmark____GWs_Int_1kx01x1-16 6278989 567.1 ns/op 5510.28 MB/s Benchmark____GWs_Int_1kx01x1-16 6711842 553.4 ns/op 5646.50 MB/s Benchmark____GWs_Int_1kx01x1-16 6428570 555.4 ns/op 5626.45 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4872028 766.7 ns/op 8082.49 MB/s Benchmark____GWs_Int_2kx01x1-16 4872621 754.2 ns/op 8216.60 MB/s Benchmark____GWs_Int_2kx01x1-16 4518571 774.6 ns/op 7999.82 MB/s Benchmark____GWs_Int_2kx01x1-16 4647312 762.1 ns/op 8131.97 MB/s Benchmark____GWs_Int_2kx01x1-16 4702782 768.4 ns/op 8064.73 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2572077 1391 ns/op 8868.91 MB/s Benchmark____GWs_Int_4kx01x1-16 2619680 1381 ns/op 8939.30 MB/s Benchmark____GWs_Int_4kx01x1-16 2533423 1395 ns/op 8845.20 MB/s Benchmark____GWs_Int_4kx01x1-16 2251045 1363 ns/op 9055.11 MB/s Benchmark____GWs_Int_4kx01x1-16 2625756 1378 ns/op 8955.61 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6575982 563.0 ns/op 5550.77 MB/s Benchmark____GWs_Int_1kx10x1-16 6598972 542.4 ns/op 5761.31 MB/s Benchmark____GWs_Int_1kx10x1-16 6676590 557.1 ns/op 5609.76 MB/s Benchmark____GWs_Int_1kx10x1-16 6540928 559.8 ns/op 5582.13 MB/s Benchmark____GWs_Int_1kx10x1-16 6540092 574.0 ns/op 5444.31 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4307253 835.4 ns/op 7417.92 MB/s Benchmark____GWs_Int_2kx10x1-16 4165789 871.7 ns/op 7109.36 MB/s Benchmark____GWs_Int_2kx10x1-16 4235793 837.0 ns/op 7403.82 MB/s Benchmark____GWs_Int_2kx10x1-16 4155992 866.6 ns/op 7151.06 MB/s Benchmark____GWs_Int_2kx10x1-16 4080906 838.4 ns/op 7391.05 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2284948 1575 ns/op 7835.27 MB/s Benchmark____GWs_Int_4kx10x1-16 2473034 1651 ns/op 7476.75 MB/s Benchmark____GWs_Int_4kx10x1-16 2346566 1808 ns/op 6824.42 MB/s Benchmark____GWs_Int_4kx10x1-16 2333010 1495 ns/op 8252.23 MB/s Benchmark____GWs_Int_4kx10x1-16 2400008 1647 ns/op 7494.22 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8502568 425.4 ns/op 239.79 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8808909 425.3 ns/op 239.84 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8291659 427.2 ns/op 238.79 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8412916 429.5 ns/op 237.51 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8249522 427.9 ns/op 238.36 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 635898 5046 ns/op 35.08 MB/s Benchmark__GWs_Reqs_1SubEach-16 776704 5161 ns/op 34.30 MB/s Benchmark__GWs_Reqs_1SubEach-16 746625 5305 ns/op 33.37 MB/s Benchmark__GWs_Reqs_1SubEach-16 763935 5356 ns/op 33.05 MB/s Benchmark__GWs_Reqs_1SubEach-16 760742 5235 ns/op 33.81 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2063.952s ❌ Non-zero exit code: 1