> ROOT_DIR=/tmp/go-bench-away-job-96558e8c-91f7-42c9-8d0f-93095fcc4635-188139144 > OUTPUT_FILE=/tmp/go-bench-away-job-96558e8c-91f7-42c9-8d0f-93095fcc4635-188139144/results.txt > SHA_FILE=/tmp/go-bench-away-job-96558e8c-91f7-42c9-8d0f-93095fcc4635-188139144/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-96558e8c-91f7-42c9-8d0f-93095fcc4635-188139144/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.26.3/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-96558e8c-91f7-42c9-8d0f-93095fcc4635-188139144/source.git SHA of main: ca6311b2e1da1f20d68ccb68f20a352f3c7799d7 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-build189291261=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-96558e8c-91f7-42c9-8d0f-93095fcc4635-188139144/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 49181455 71.65 ns/op 153.53 MB/s Benchmark______Pub0b_Payload-16 47688022 71.72 ns/op 153.37 MB/s Benchmark______Pub0b_Payload-16 47335218 71.96 ns/op 152.86 MB/s Benchmark______Pub0b_Payload-16 47835870 71.90 ns/op 152.98 MB/s Benchmark______Pub0b_Payload-16 47595684 71.73 ns/op 153.36 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46901601 72.48 ns/op 262.13 MB/s Benchmark______Pub8b_Payload-16 46621588 72.69 ns/op 261.39 MB/s Benchmark______Pub8b_Payload-16 47041886 72.57 ns/op 261.82 MB/s Benchmark______Pub8b_Payload-16 43847030 72.57 ns/op 261.83 MB/s Benchmark______Pub8b_Payload-16 46660858 72.50 ns/op 262.08 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44728790 77.06 ns/op 570.97 MB/s Benchmark_____Pub32b_Payload-16 44589187 76.80 ns/op 572.88 MB/s Benchmark_____Pub32b_Payload-16 44180816 77.09 ns/op 570.76 MB/s Benchmark_____Pub32b_Payload-16 38296252 83.09 ns/op 529.55 MB/s Benchmark_____Pub32b_Payload-16 44159896 76.55 ns/op 574.80 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39039733 86.19 ns/op 1635.84 MB/s Benchmark____Pub128B_Payload-16 34260066 87.91 ns/op 1603.94 MB/s Benchmark____Pub128B_Payload-16 42175599 88.18 ns/op 1598.92 MB/s Benchmark____Pub128B_Payload-16 39971808 87.14 ns/op 1618.02 MB/s Benchmark____Pub128B_Payload-16 42205273 85.46 ns/op 1649.88 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35682685 96.04 ns/op 2800.90 MB/s Benchmark____Pub256B_Payload-16 36303550 96.29 ns/op 2793.73 MB/s Benchmark____Pub256B_Payload-16 36726636 93.44 ns/op 2878.91 MB/s Benchmark____Pub256B_Payload-16 35708697 96.44 ns/op 2789.39 MB/s Benchmark____Pub256B_Payload-16 38570754 96.17 ns/op 2797.17 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 22208418 143.9 ns/op 7212.84 MB/s Benchmark______Pub1K_Payload-16 26164341 147.2 ns/op 7050.79 MB/s Benchmark______Pub1K_Payload-16 25840050 143.3 ns/op 7242.90 MB/s Benchmark______Pub1K_Payload-16 25073652 143.5 ns/op 7231.62 MB/s Benchmark______Pub1K_Payload-16 23725566 148.1 ns/op 7010.33 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5773308 622.8 ns/op 6599.27 MB/s Benchmark______Pub4K_Payload-16 5730738 605.7 ns/op 6785.33 MB/s Benchmark______Pub4K_Payload-16 5458776 621.0 ns/op 6618.38 MB/s Benchmark______Pub4K_Payload-16 5650623 618.8 ns/op 6642.04 MB/s Benchmark______Pub4K_Payload-16 5632905 616.1 ns/op 6671.06 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2743669 1280 ns/op 6410.83 MB/s Benchmark______Pub8K_Payload-16 2787229 1283 ns/op 6397.87 MB/s Benchmark______Pub8K_Payload-16 2796724 1269 ns/op 6468.49 MB/s Benchmark______Pub8K_Payload-16 2843436 1287 ns/op 6375.43 MB/s Benchmark______Pub8K_Payload-16 2819740 1281 ns/op 6406.72 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 673543 5275 ns/op 6214.43 MB/s Benchmark_____Pub32K_Payload-16 612171 5386 ns/op 6086.69 MB/s Benchmark_____Pub32K_Payload-16 566437 5494 ns/op 5967.16 MB/s Benchmark_____Pub32K_Payload-16 587523 6195 ns/op 5291.78 MB/s Benchmark_____Pub32K_Payload-16 667017 5416 ns/op 6053.22 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32471022 94.28 ns/op 116.67 MB/s Benchmark__AuthPub0b_Payload-16 36434450 97.56 ns/op 112.75 MB/s Benchmark__AuthPub0b_Payload-16 36211393 94.17 ns/op 116.81 MB/s Benchmark__AuthPub0b_Payload-16 32300800 93.93 ns/op 117.11 MB/s Benchmark__AuthPub0b_Payload-16 36417468 95.11 ns/op 115.66 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15555603 227.0 ns/op Benchmark_____________PubSub-16 15581020 227.4 ns/op Benchmark_____________PubSub-16 15480801 227.6 ns/op Benchmark_____________PubSub-16 15589328 227.6 ns/op Benchmark_____________PubSub-16 15415912 227.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15648498 225.8 ns/op Benchmark_____PubSubTwoConns-16 15810351 226.0 ns/op Benchmark_____PubSubTwoConns-16 15673758 226.0 ns/op Benchmark_____PubSubTwoConns-16 15778996 227.4 ns/op Benchmark_____PubSubTwoConns-16 15841161 225.8 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:35034->127.0.0.1:41753: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33114->127.0.0.1:38811: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:36502->127.0.0.1:33393: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40002->127.0.0.1:45951: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43450->127.0.0.1:35755: 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 14244951 247.5 ns/op Benchmark_____PubTwoQueueSub-16 14344930 247.3 ns/op Benchmark_____PubTwoQueueSub-16 14193336 247.7 ns/op Benchmark_____PubTwoQueueSub-16 14367428 247.5 ns/op Benchmark_____PubTwoQueueSub-16 14314743 248.1 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14406972 247.8 ns/op Benchmark____PubFourQueueSub-16 14231596 247.2 ns/op Benchmark____PubFourQueueSub-16 14091349 247.6 ns/op Benchmark____PubFourQueueSub-16 14340626 248.5 ns/op Benchmark____PubFourQueueSub-16 14237630 248.1 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14306154 247.5 ns/op Benchmark___PubEightQueueSub-16 14372152 248.0 ns/op Benchmark___PubEightQueueSub-16 14379943 247.7 ns/op Benchmark___PubEightQueueSub-16 14140002 247.6 ns/op Benchmark___PubEightQueueSub-16 14245364 248.2 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23229 154191 ns/op Benchmark_PubSub512kTwoConns-16 23331 154656 ns/op Benchmark_PubSub512kTwoConns-16 22959 154489 ns/op Benchmark_PubSub512kTwoConns-16 23121 155104 ns/op Benchmark_PubSub512kTwoConns-16 22784 155660 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15253954 229.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15220182 228.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15278042 229.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15186794 229.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15243536 228.6 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15319400 228.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15321096 228.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15500821 229.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15169298 229.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15310394 230.7 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11497665 312.6 ns/op Benchmark____RoutedPubSub_0b-16 11192295 314.8 ns/op Benchmark____RoutedPubSub_0b-16 11333916 314.3 ns/op Benchmark____RoutedPubSub_0b-16 11164063 314.6 ns/op Benchmark____RoutedPubSub_0b-16 11264212 313.0 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6619849 543.5 ns/op Benchmark____RoutedPubSub_1K-16 6692697 630.2 ns/op Benchmark____RoutedPubSub_1K-16 6676692 520.3 ns/op Benchmark____RoutedPubSub_1K-16 6505825 544.5 ns/op Benchmark____RoutedPubSub_1K-16 6781716 541.9 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84282 41441 ns/op Benchmark__RoutedPubSub_100K-16 82550 46502 ns/op Benchmark__RoutedPubSub_100K-16 81283 43036 ns/op Benchmark__RoutedPubSub_100K-16 79237 46233 ns/op Benchmark__RoutedPubSub_100K-16 79940 45521 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9763792 324.9 ns/op Benchmark____Routed2QueueSub-16 9625544 317.7 ns/op Benchmark____Routed2QueueSub-16 9511748 325.1 ns/op Benchmark____Routed2QueueSub-16 9738224 327.5 ns/op Benchmark____Routed2QueueSub-16 9593444 322.3 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9599505 321.1 ns/op Benchmark____Routed4QueueSub-16 9459072 326.9 ns/op Benchmark____Routed4QueueSub-16 9636470 318.0 ns/op Benchmark____Routed4QueueSub-16 9541701 326.4 ns/op Benchmark____Routed4QueueSub-16 9400880 320.1 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9338576 331.7 ns/op Benchmark____Routed8QueueSub-16 9238504 332.0 ns/op Benchmark____Routed8QueueSub-16 10849076 335.0 ns/op Benchmark____Routed8QueueSub-16 9237039 333.7 ns/op Benchmark____Routed8QueueSub-16 9001330 334.1 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8760618 351.0 ns/op Benchmark___Routed16QueueSub-16 8902357 345.7 ns/op Benchmark___Routed16QueueSub-16 8801437 349.3 ns/op Benchmark___Routed16QueueSub-16 10198524 349.0 ns/op Benchmark___Routed16QueueSub-16 8555804 352.2 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6508376 554.7 ns/op Benchmark____________RouteCompressOff-16 6471655 553.8 ns/op Benchmark____________RouteCompressOff-16 6408105 550.5 ns/op Benchmark____________RouteCompressOff-16 6457176 554.9 ns/op Benchmark____________RouteCompressOff-16 6410484 546.7 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6377367 558.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6246571 556.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6527040 549.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6147320 550.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6243375 558.9 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6355096 552.6 ns/op Benchmark_________RouteCompressS2Fast-16 6370141 548.8 ns/op Benchmark_________RouteCompressS2Fast-16 6387546 516.0 ns/op Benchmark_________RouteCompressS2Fast-16 6415782 552.4 ns/op Benchmark_________RouteCompressS2Fast-16 6367866 552.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6550104 558.0 ns/op Benchmark_______RouteCompressS2Better-16 6363705 555.0 ns/op Benchmark_______RouteCompressS2Better-16 6293829 550.2 ns/op Benchmark_______RouteCompressS2Better-16 6357580 557.2 ns/op Benchmark_______RouteCompressS2Better-16 6495691 552.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6395221 557.0 ns/op Benchmark_________RouteCompressS2Best-16 6372988 558.3 ns/op Benchmark_________RouteCompressS2Best-16 7544224 492.0 ns/op Benchmark_________RouteCompressS2Best-16 6528010 557.0 ns/op Benchmark_________RouteCompressS2Best-16 6375084 557.2 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4647919 773.8 ns/op 321.78 MB/s Benchmark______FanOut_8x1x10-16 4636978 765.3 ns/op 325.35 MB/s Benchmark______FanOut_8x1x10-16 4635759 765.1 ns/op 325.44 MB/s Benchmark______FanOut_8x1x10-16 4664748 770.7 ns/op 323.10 MB/s Benchmark______FanOut_8x1x10-16 4680187 767.7 ns/op 324.34 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 556552 6122 ns/op 378.81 MB/s Benchmark_____FanOut_8x1x100-16 540100 6102 ns/op 380.02 MB/s Benchmark_____FanOut_8x1x100-16 544502 6121 ns/op 378.86 MB/s Benchmark_____FanOut_8x1x100-16 570973 6190 ns/op 374.66 MB/s Benchmark_____FanOut_8x1x100-16 541555 6110 ns/op 379.52 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 46964 76224 ns/op 301.99 MB/s Benchmark____FanOut_8x10x100-16 47293 76110 ns/op 302.44 MB/s Benchmark____FanOut_8x10x100-16 47286 75920 ns/op 303.20 MB/s Benchmark____FanOut_8x10x100-16 47196 76186 ns/op 302.14 MB/s Benchmark____FanOut_8x10x100-16 47349 76787 ns/op 299.78 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5839 607642 ns/op 395.00 MB/s Benchmark___FanOut_8x10x1000-16 5895 612001 ns/op 392.19 MB/s Benchmark___FanOut_8x10x1000-16 5781 614287 ns/op 390.73 MB/s Benchmark___FanOut_8x10x1000-16 5720 609251 ns/op 393.96 MB/s Benchmark___FanOut_8x10x1000-16 5727 613631 ns/op 391.15 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4920 735492 ns/op 312.74 MB/s Benchmark___FanOut_8x100x100-16 4834 725415 ns/op 317.09 MB/s Benchmark___FanOut_8x100x100-16 4858 724216 ns/op 317.61 MB/s Benchmark___FanOut_8x100x100-16 4872 725730 ns/op 316.95 MB/s Benchmark___FanOut_8x100x100-16 4863 726898 ns/op 316.44 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 567 6331328 ns/op 379.07 MB/s Benchmark__FanOut_8x100x1000-16 559 6343761 ns/op 378.33 MB/s Benchmark__FanOut_8x100x1000-16 561 6329955 ns/op 379.15 MB/s Benchmark__FanOut_8x100x1000-16 552 6317957 ns/op 379.87 MB/s Benchmark__FanOut_8x100x1000-16 566 6419442 ns/op 373.87 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 516 6933327 ns/op 360.58 MB/s Benchmark__FanOut_8x10x10000-16 522 6795153 ns/op 367.91 MB/s Benchmark__FanOut_8x10x10000-16 518 6911998 ns/op 361.69 MB/s Benchmark__FanOut_8x10x10000-16 514 7023140 ns/op 355.97 MB/s Benchmark__FanOut_8x10x10000-16 514 6854053 ns/op 364.75 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 913 3831978 ns/op 300.11 MB/s Benchmark___FanOut_8x500x100-16 925 3828477 ns/op 300.39 MB/s Benchmark___FanOut_8x500x100-16 924 3823241 ns/op 300.80 MB/s Benchmark___FanOut_8x500x100-16 930 3813038 ns/op 301.60 MB/s Benchmark___FanOut_8x500x100-16 930 3816681 ns/op 301.31 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 361466 9532 ns/op 1535.95 MB/s Benchmark___FanOut_128x1x100-16 359802 9696 ns/op 1509.95 MB/s Benchmark___FanOut_128x1x100-16 359280 9577 ns/op 1528.77 MB/s Benchmark___FanOut_128x1x100-16 366306 9537 ns/op 1535.25 MB/s Benchmark___FanOut_128x1x100-16 355504 9548 ns/op 1533.45 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32106 110841 ns/op 1309.45 MB/s Benchmark__FanOut_128x10x100-16 32124 112139 ns/op 1294.29 MB/s Benchmark__FanOut_128x10x100-16 32245 111783 ns/op 1298.41 MB/s Benchmark__FanOut_128x10x100-16 32169 111771 ns/op 1298.56 MB/s Benchmark__FanOut_128x10x100-16 32037 112547 ns/op 1289.60 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4045 889393 ns/op 1641.73 MB/s Benchmark_FanOut_128x10x1000-16 3980 886593 ns/op 1646.91 MB/s Benchmark_FanOut_128x10x1000-16 3861 885203 ns/op 1649.50 MB/s Benchmark_FanOut_128x10x1000-16 3945 897104 ns/op 1627.62 MB/s Benchmark_FanOut_128x10x1000-16 4042 896637 ns/op 1628.46 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3420 1025839 ns/op 1413.62 MB/s Benchmark_FanOut_128x100x100-16 3477 1026953 ns/op 1412.08 MB/s Benchmark_FanOut_128x100x100-16 3465 1029162 ns/op 1409.05 MB/s Benchmark_FanOut_128x100x100-16 3430 1024932 ns/op 1414.87 MB/s Benchmark_FanOut_128x100x100-16 3381 1041566 ns/op 1392.27 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 378 9531718 ns/op 1531.74 MB/s BenchmarkFanOut_128x100x1000-16 370 9469451 ns/op 1541.81 MB/s BenchmarkFanOut_128x100x1000-16 374 9542964 ns/op 1529.94 MB/s BenchmarkFanOut_128x100x1000-16 380 9515647 ns/op 1534.33 MB/s BenchmarkFanOut_128x100x1000-16 374 9460685 ns/op 1543.24 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 366 9766735 ns/op 1505.12 MB/s BenchmarkFanOut_128x10x10000-16 363 9736052 ns/op 1509.87 MB/s BenchmarkFanOut_128x10x10000-16 361 9787024 ns/op 1502.00 MB/s BenchmarkFanOut_128x10x10000-16 369 9842883 ns/op 1493.48 MB/s BenchmarkFanOut_128x10x10000-16 364 9830534 ns/op 1495.36 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 658 5385849 ns/op 1346.15 MB/s BenchmarkFanOut__128x500x100-16 663 5396083 ns/op 1343.59 MB/s BenchmarkFanOut__128x500x100-16 666 5361703 ns/op 1352.21 MB/s BenchmarkFanOut__128x500x100-16 669 5341974 ns/op 1357.20 MB/s BenchmarkFanOut__128x500x100-16 658 5318241 ns/op 1363.26 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1938 1863002 ns/op 2839.78 MB/s Benchmark_FanOut_512x100x100-16 1885 1839960 ns/op 2875.35 MB/s Benchmark_FanOut_512x100x100-16 1920 1851666 ns/op 2857.17 MB/s Benchmark_FanOut_512x100x100-16 1903 1844222 ns/op 2868.70 MB/s Benchmark_FanOut_512x100x100-16 1923 1859020 ns/op 2845.87 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 216 16650392 ns/op 3183.14 MB/s Benchmark__FanOut_512x100x1k-16 214 16778528 ns/op 3158.83 MB/s Benchmark__FanOut_512x100x1k-16 214 16905090 ns/op 3135.18 MB/s Benchmark__FanOut_512x100x1k-16 216 16797585 ns/op 3155.25 MB/s Benchmark__FanOut_512x100x1k-16 214 16764398 ns/op 3161.49 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2998 1147302 ns/op 9091.80 MB/s Benchmark____FanOut_1kx10x1k-16 3136 1160101 ns/op 8991.49 MB/s Benchmark____FanOut_1kx10x1k-16 2973 1152583 ns/op 9050.14 MB/s Benchmark____FanOut_1kx10x1k-16 2769 1150155 ns/op 9069.25 MB/s Benchmark____FanOut_1kx10x1k-16 2970 1169801 ns/op 8916.93 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2751 1267752 ns/op 8220.09 MB/s Benchmark__FanOut_1kx100x100-16 2798 1268030 ns/op 8218.29 MB/s Benchmark__FanOut_1kx100x100-16 2757 1270770 ns/op 8200.57 MB/s Benchmark__FanOut_1kx100x100-16 2786 1269370 ns/op 8209.61 MB/s Benchmark__FanOut_1kx100x100-16 2748 1268993 ns/op 8212.06 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4508400 779.8 ns/op 319.32 MB/s Benchmark_____RFanOut_8x1x10-16 4394230 797.1 ns/op 312.39 MB/s Benchmark_____RFanOut_8x1x10-16 4546393 795.1 ns/op 313.18 MB/s Benchmark_____RFanOut_8x1x10-16 4472774 793.8 ns/op 313.67 MB/s Benchmark_____RFanOut_8x1x10-16 4441874 774.9 ns/op 321.33 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 491223 6286 ns/op 368.94 MB/s Benchmark____RFanOut_8x1x100-16 544612 6223 ns/op 372.62 MB/s Benchmark____RFanOut_8x1x100-16 518293 6258 ns/op 370.58 MB/s Benchmark____RFanOut_8x1x100-16 515610 6284 ns/op 369.05 MB/s Benchmark____RFanOut_8x1x100-16 513817 6199 ns/op 374.08 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47337 76836 ns/op 299.58 MB/s Benchmark___RFanOut_8x10x100-16 46826 76127 ns/op 302.38 MB/s Benchmark___RFanOut_8x10x100-16 46490 78161 ns/op 294.51 MB/s Benchmark___RFanOut_8x10x100-16 46983 76479 ns/op 300.98 MB/s Benchmark___RFanOut_8x10x100-16 47701 76940 ns/op 299.18 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5851 626521 ns/op 383.10 MB/s Benchmark__RFanOut_8x10x1000-16 5608 609547 ns/op 393.77 MB/s Benchmark__RFanOut_8x10x1000-16 5773 612169 ns/op 392.08 MB/s Benchmark__RFanOut_8x10x1000-16 5430 613090 ns/op 391.49 MB/s Benchmark__RFanOut_8x10x1000-16 5752 629964 ns/op 381.00 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4864 722319 ns/op 318.45 MB/s Benchmark__RFanOut_8x100x100-16 4861 723842 ns/op 317.78 MB/s Benchmark__RFanOut_8x100x100-16 4950 719885 ns/op 319.52 MB/s Benchmark__RFanOut_8x100x100-16 4905 714809 ns/op 321.79 MB/s Benchmark__RFanOut_8x100x100-16 4842 721527 ns/op 318.79 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 565 6452927 ns/op 371.93 MB/s Benchmark_RFanOut_8x100x1000-16 547 6429690 ns/op 373.27 MB/s Benchmark_RFanOut_8x100x1000-16 560 6424262 ns/op 373.59 MB/s Benchmark_RFanOut_8x100x1000-16 560 6290223 ns/op 381.55 MB/s Benchmark_RFanOut_8x100x1000-16 562 6543355 ns/op 366.79 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 528 7003141 ns/op 356.99 MB/s Benchmark_RFanOut_8x10x10000-16 530 6822231 ns/op 366.45 MB/s Benchmark_RFanOut_8x10x10000-16 534 6840177 ns/op 365.49 MB/s Benchmark_RFanOut_8x10x10000-16 530 7040996 ns/op 355.07 MB/s Benchmark_RFanOut_8x10x10000-16 534 6853665 ns/op 364.77 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3204 1160337 ns/op 8989.66 MB/s Benchmark_RFanOut_1kx10x1000-16 3036 1163652 ns/op 8964.05 MB/s Benchmark_RFanOut_1kx10x1000-16 3210 1202471 ns/op 8674.67 MB/s Benchmark_RFanOut_1kx10x1000-16 2887 1180964 ns/op 8832.64 MB/s Benchmark_RFanOut_1kx10x1000-16 2953 1176797 ns/op 8863.92 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6878492 505.6 ns/op 4109.98 MB/s Benchmark_____FanIn_1kx100x1-16 6961894 506.0 ns/op 4106.46 MB/s Benchmark_____FanIn_1kx100x1-16 6888871 505.8 ns/op 4108.48 MB/s Benchmark_____FanIn_1kx100x1-16 6971886 514.5 ns/op 4039.12 MB/s Benchmark_____FanIn_1kx100x1-16 6960468 505.3 ns/op 4112.04 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2518321 1351 ns/op 6086.83 MB/s Benchmark_____FanIn_4kx100x1-16 2646511 1355 ns/op 6068.52 MB/s Benchmark_____FanIn_4kx100x1-16 2617574 1368 ns/op 6009.65 MB/s Benchmark_____FanIn_4kx100x1-16 2611442 1365 ns/op 6023.35 MB/s Benchmark_____FanIn_4kx100x1-16 2603647 1354 ns/op 6072.15 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1699378 2104 ns/op 7800.40 MB/s Benchmark_____FanIn_8kx100x1-16 1673701 2116 ns/op 7756.63 MB/s Benchmark_____FanIn_8kx100x1-16 1686208 2109 ns/op 7784.01 MB/s Benchmark_____FanIn_8kx100x1-16 1694259 2093 ns/op 7841.99 MB/s Benchmark_____FanIn_8kx100x1-16 1700391 2131 ns/op 7703.36 MB/s Benchmark____FanIn_16kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 100423323 vs 11754596700 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46130->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45762->127.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:46206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46054->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46092->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46240->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45788->127.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: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:45986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45892->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46050->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45404->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46084->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46156->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45768->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45606->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45700->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45488->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45538->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_16kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45678->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45900->127.0.0.1:5222: write: broken pipe Benchmark____FanIn_16kx100x1-16 876169 4162 ns/op 7880.64 MB/s Benchmark____FanIn_16kx100x1-16 856244 4155 ns/op 7894.81 MB/s Benchmark____FanIn_16kx100x1-16 870506 4188 ns/op 7832.01 MB/s Benchmark____FanIn_16kx100x1-16 848887 4186 ns/op 7834.77 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 161360 19735 ns/op 6643.39 MB/s Benchmark____FanIn_64kx100x1-16 168171 19949 ns/op 6571.82 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 8840412027 vs 10711360200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34660->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 168382 20045 ns/op 6540.55 MB/s Benchmark____FanIn_64kx100x1-16 163730 19957 ns/op 6569.16 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 329298080 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58632->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:59000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58832->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: 177233680 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33134->127.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:60962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32920->127.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: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:33068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:32902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32800->127.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:60590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60830->127.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:32888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32834->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:60650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60942->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: 98317500 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34190->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:34596->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: 1314701610 vs 11732555000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36922->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37284->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:36640->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: 220493380 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39228->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5496612 648.0 ns/op 438.24 MB/s Benchmark___BumpPubCount_1x3-16 5558122 643.8 ns/op 441.13 MB/s Benchmark___BumpPubCount_1x3-16 5517392 645.2 ns/op 440.18 MB/s Benchmark___BumpPubCount_1x3-16 5532279 645.0 ns/op 440.31 MB/s Benchmark___BumpPubCount_1x3-16 5528995 644.6 ns/op 440.57 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5296897 679.7 ns/op 417.82 MB/s Benchmark___BumpPubCount_2x3-16 5274296 680.7 ns/op 417.22 MB/s Benchmark___BumpPubCount_2x3-16 5295880 680.1 ns/op 417.56 MB/s Benchmark___BumpPubCount_2x3-16 5284250 684.6 ns/op 414.86 MB/s Benchmark___BumpPubCount_2x3-16 5239538 683.4 ns/op 415.55 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5373037 660.1 ns/op 430.26 MB/s Benchmark___BumpPubCount_5x3-16 5515358 648.7 ns/op 437.78 MB/s Benchmark___BumpPubCount_5x3-16 5487938 652.1 ns/op 435.49 MB/s Benchmark___BumpPubCount_5x3-16 5528470 650.1 ns/op 436.85 MB/s Benchmark___BumpPubCount_5x3-16 5527321 648.4 ns/op 437.99 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5540956 650.6 ns/op 436.55 MB/s Benchmark__BumpPubCount_10x3-16 5536965 648.8 ns/op 437.73 MB/s Benchmark__BumpPubCount_10x3-16 5498644 649.7 ns/op 437.10 MB/s Benchmark__BumpPubCount_10x3-16 5557742 650.4 ns/op 436.68 MB/s Benchmark__BumpPubCount_10x3-16 5499886 652.2 ns/op 435.48 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12032260 276.1 ns/op 3767.18 MB/s Benchmark____GWs_Opt_1kx01x0-16 12678188 274.9 ns/op 3783.79 MB/s Benchmark____GWs_Opt_1kx01x0-16 12445622 270.6 ns/op 3842.98 MB/s Benchmark____GWs_Opt_1kx01x0-16 13061679 277.6 ns/op 3745.83 MB/s Benchmark____GWs_Opt_1kx01x0-16 13078135 268.8 ns/op 3869.46 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10465653 337.0 ns/op 6125.36 MB/s Benchmark____GWs_Opt_2kx01x0-16 11062273 324.5 ns/op 6360.81 MB/s Benchmark____GWs_Opt_2kx01x0-16 10265476 329.6 ns/op 6262.68 MB/s Benchmark____GWs_Opt_2kx01x0-16 10897178 342.7 ns/op 6022.47 MB/s Benchmark____GWs_Opt_2kx01x0-16 10837467 337.3 ns/op 6119.53 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5646825 612.8 ns/op 6709.94 MB/s Benchmark____GWs_Opt_4kx01x0-16 5550835 609.5 ns/op 6746.63 MB/s Benchmark____GWs_Opt_4kx01x0-16 5535055 625.7 ns/op 6572.36 MB/s Benchmark____GWs_Opt_4kx01x0-16 5333294 621.4 ns/op 6617.59 MB/s Benchmark____GWs_Opt_4kx01x0-16 4753576 640.9 ns/op 6416.29 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28044052 133.0 ns/op 7819.52 MB/s Benchmark____GWs_Opt_1kx10x0-16 31372423 115.0 ns/op 9039.64 MB/s Benchmark____GWs_Opt_1kx10x0-16 31493556 117.3 ns/op 8866.61 MB/s Benchmark____GWs_Opt_1kx10x0-16 28714069 111.0 ns/op 9365.37 MB/s Benchmark____GWs_Opt_1kx10x0-16 31195381 110.3 ns/op 9430.03 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24014740 147.5 ns/op 13989.87 MB/s Benchmark____GWs_Opt_2kx10x0-16 23946074 143.9 ns/op 14348.03 MB/s Benchmark____GWs_Opt_2kx10x0-16 23728291 141.2 ns/op 14614.90 MB/s Benchmark____GWs_Opt_2kx10x0-16 23888731 149.7 ns/op 13788.64 MB/s Benchmark____GWs_Opt_2kx10x0-16 25467270 149.8 ns/op 13779.30 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 13210256 283.7 ns/op 14492.96 MB/s Benchmark____GWs_Opt_4kx10x0-16 10451046 302.5 ns/op 13595.40 MB/s Benchmark____GWs_Opt_4kx10x0-16 11300023 282.0 ns/op 14581.28 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:41754->127.0.0.1:34901: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:46410->127.0.0.1:38175: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 12851244 309.5 ns/op 13285.23 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6416718 560.2 ns/op 5577.97 MB/s Benchmark____GWs_Opt_1kx01x1-16 6594318 565.8 ns/op 5522.68 MB/s Benchmark____GWs_Opt_1kx01x1-16 6529831 553.3 ns/op 5647.52 MB/s Benchmark____GWs_Opt_1kx01x1-16 6541539 557.8 ns/op 5601.97 MB/s Benchmark____GWs_Opt_1kx01x1-16 6289569 553.3 ns/op 5647.60 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4667100 773.5 ns/op 8011.87 MB/s Benchmark____GWs_Opt_2kx01x1-16 4449422 770.8 ns/op 8039.42 MB/s Benchmark____GWs_Opt_2kx01x1-16 4342713 774.6 ns/op 7999.76 MB/s Benchmark____GWs_Opt_2kx01x1-16 4623758 762.8 ns/op 8124.42 MB/s Benchmark____GWs_Opt_2kx01x1-16 4373762 779.0 ns/op 7954.93 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2598332 1379 ns/op 8950.54 MB/s Benchmark____GWs_Opt_4kx01x1-16 2584560 1390 ns/op 8877.90 MB/s Benchmark____GWs_Opt_4kx01x1-16 2624749 1533 ns/op 8051.71 MB/s Benchmark____GWs_Opt_4kx01x1-16 2616309 1397 ns/op 8834.97 MB/s Benchmark____GWs_Opt_4kx01x1-16 2559066 1385 ns/op 8911.69 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6101815 563.2 ns/op 5548.79 MB/s Benchmark____GWs_Opt_1kx10x1-16 6409794 556.2 ns/op 5618.24 MB/s Benchmark____GWs_Opt_1kx10x1-16 5972546 555.2 ns/op 5628.91 MB/s Benchmark____GWs_Opt_1kx10x1-16 6009363 561.4 ns/op 5566.24 MB/s Benchmark____GWs_Opt_1kx10x1-16 6146468 555.3 ns/op 5627.99 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4058665 855.0 ns/op 7248.22 MB/s Benchmark____GWs_Opt_2kx10x1-16 4052412 848.5 ns/op 7303.64 MB/s Benchmark____GWs_Opt_2kx10x1-16 4089868 865.7 ns/op 7158.75 MB/s Benchmark____GWs_Opt_2kx10x1-16 4047433 852.0 ns/op 7273.84 MB/s Benchmark____GWs_Opt_2kx10x1-16 4034067 856.5 ns/op 7235.68 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2410639 1558 ns/op 7921.60 MB/s Benchmark____GWs_Opt_4kx10x1-16 2462427 1590 ns/op 7760.22 MB/s Benchmark____GWs_Opt_4kx10x1-16 2359645 1523 ns/op 8105.39 MB/s Benchmark____GWs_Opt_4kx10x1-16 2309952 1540 ns/op 8013.79 MB/s Benchmark____GWs_Opt_4kx10x1-16 2336868 1542 ns/op 8002.04 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12059961 296.6 ns/op 3506.15 MB/s Benchmark____GWs_Int_1kx01x0-16 11828298 296.0 ns/op 3514.00 MB/s Benchmark____GWs_Int_1kx01x0-16 12579577 288.6 ns/op 3603.31 MB/s Benchmark____GWs_Int_1kx01x0-16 12001345 288.0 ns/op 3611.03 MB/s Benchmark____GWs_Int_1kx01x0-16 11670984 297.9 ns/op 3490.79 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10161306 361.4 ns/op 5711.25 MB/s Benchmark____GWs_Int_2kx01x0-16 10018135 352.6 ns/op 5853.88 MB/s Benchmark____GWs_Int_2kx01x0-16 9146534 353.0 ns/op 5846.40 MB/s Benchmark____GWs_Int_2kx01x0-16 8748667 365.4 ns/op 5648.64 MB/s Benchmark____GWs_Int_2kx01x0-16 10631624 370.5 ns/op 5571.18 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5650836 649.6 ns/op 6329.83 MB/s Benchmark____GWs_Int_4kx01x0-16 5575467 628.1 ns/op 6546.23 MB/s Benchmark____GWs_Int_4kx01x0-16 5522648 651.2 ns/op 6314.90 MB/s Benchmark____GWs_Int_4kx01x0-16 5510800 664.1 ns/op 6191.45 MB/s Benchmark____GWs_Int_4kx01x0-16 5446640 658.0 ns/op 6248.90 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31680218 110.5 ns/op 9410.72 MB/s Benchmark____GWs_Int_1kx10x0-16 30535489 108.8 ns/op 9555.78 MB/s Benchmark____GWs_Int_1kx10x0-16 32454250 111.9 ns/op 9291.30 MB/s Benchmark____GWs_Int_1kx10x0-16 31141556 121.4 ns/op 8569.55 MB/s Benchmark____GWs_Int_1kx10x0-16 31634146 111.2 ns/op 9349.99 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24405081 140.2 ns/op 14726.76 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:45272->127.0.0.1:35911: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 24641595 156.8 ns/op 13159.68 MB/s Benchmark____GWs_Int_2kx10x0-16 24277040 143.7 ns/op 14358.40 MB/s Benchmark____GWs_Int_2kx10x0-16 22718042 141.1 ns/op 14623.29 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12886567 315.7 ns/op 13026.77 MB/s Benchmark____GWs_Int_4kx10x0-16 7801046 445.4 ns/op 9233.14 MB/s Benchmark____GWs_Int_4kx10x0-16 12886122 280.5 ns/op 14658.95 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:52970->127.0.0.1:38897: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:57412->127.0.0.1:42117: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12930678 288.4 ns/op 14256.15 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6026264 569.5 ns/op 5487.28 MB/s Benchmark____GWs_Int_1kx01x1-16 6280236 565.8 ns/op 5523.27 MB/s Benchmark____GWs_Int_1kx01x1-16 6143218 573.1 ns/op 5453.11 MB/s Benchmark____GWs_Int_1kx01x1-16 6223533 565.9 ns/op 5522.66 MB/s Benchmark____GWs_Int_1kx01x1-16 6430533 560.7 ns/op 5573.57 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4620265 774.4 ns/op 8002.80 MB/s Benchmark____GWs_Int_2kx01x1-16 4607354 778.1 ns/op 7964.21 MB/s Benchmark____GWs_Int_2kx01x1-16 4693766 788.8 ns/op 7856.31 MB/s Benchmark____GWs_Int_2kx01x1-16 4543104 769.1 ns/op 8057.67 MB/s Benchmark____GWs_Int_2kx01x1-16 4777345 865.9 ns/op 7156.76 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2616853 1392 ns/op 8866.82 MB/s Benchmark____GWs_Int_4kx01x1-16 2574237 1387 ns/op 8895.45 MB/s Benchmark____GWs_Int_4kx01x1-16 2631152 1399 ns/op 8820.38 MB/s Benchmark____GWs_Int_4kx01x1-16 2207065 1399 ns/op 8822.34 MB/s Benchmark____GWs_Int_4kx01x1-16 2254611 1386 ns/op 8904.11 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6120248 560.1 ns/op 5578.96 MB/s Benchmark____GWs_Int_1kx10x1-16 6036238 563.7 ns/op 5544.00 MB/s Benchmark____GWs_Int_1kx10x1-16 6203043 561.6 ns/op 5564.32 MB/s Benchmark____GWs_Int_1kx10x1-16 6133956 559.1 ns/op 5589.79 MB/s Benchmark____GWs_Int_1kx10x1-16 6119264 563.6 ns/op 5544.33 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4097821 855.0 ns/op 7247.99 MB/s Benchmark____GWs_Int_2kx10x1-16 4429634 913.1 ns/op 6786.76 MB/s Benchmark____GWs_Int_2kx10x1-16 4146879 858.5 ns/op 7218.15 MB/s Benchmark____GWs_Int_2kx10x1-16 4042932 844.1 ns/op 7341.72 MB/s Benchmark____GWs_Int_2kx10x1-16 4138311 839.0 ns/op 7385.84 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2325721 1691 ns/op 7298.09 MB/s Benchmark____GWs_Int_4kx10x1-16 2242920 1548 ns/op 7973.95 MB/s Benchmark____GWs_Int_4kx10x1-16 2378811 1545 ns/op 7987.51 MB/s Benchmark____GWs_Int_4kx10x1-16 2299232 1579 ns/op 7817.66 MB/s Benchmark____GWs_Int_4kx10x1-16 2360306 1507 ns/op 8186.46 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8351065 435.8 ns/op 234.06 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7902627 444.9 ns/op 229.26 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8047076 439.3 ns/op 232.20 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8136874 447.0 ns/op 228.18 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8316487 437.2 ns/op 233.28 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 633921 5105 ns/op 34.67 MB/s Benchmark__GWs_Reqs_1SubEach-16 787947 5231 ns/op 33.83 MB/s Benchmark__GWs_Reqs_1SubEach-16 720249 5288 ns/op 33.47 MB/s Benchmark__GWs_Reqs_1SubEach-16 766790 5338 ns/op 33.16 MB/s Benchmark__GWs_Reqs_1SubEach-16 740265 5201 ns/op 34.03 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2107.546s ❌ Non-zero exit code: 1