> ROOT_DIR=/tmp/go-bench-away-job-7a9726ec-e390-4a1b-a287-c4c64642512b-386429602 > OUTPUT_FILE=/tmp/go-bench-away-job-7a9726ec-e390-4a1b-a287-c4c64642512b-386429602/results.txt > SHA_FILE=/tmp/go-bench-away-job-7a9726ec-e390-4a1b-a287-c4c64642512b-386429602/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-7a9726ec-e390-4a1b-a287-c4c64642512b-386429602/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-7a9726ec-e390-4a1b-a287-c4c64642512b-386429602/source.git SHA of main: d9dd620b1af65e84efe439357f9cd3ae8e2ad84e 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-build1067494492=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-7a9726ec-e390-4a1b-a287-c4c64642512b-386429602/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 49082452 73.46 ns/op 149.75 MB/s Benchmark______Pub0b_Payload-16 46866680 73.13 ns/op 150.41 MB/s Benchmark______Pub0b_Payload-16 45428677 73.12 ns/op 150.44 MB/s Benchmark______Pub0b_Payload-16 43330101 73.16 ns/op 150.36 MB/s Benchmark______Pub0b_Payload-16 42148794 73.12 ns/op 150.43 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45977088 76.05 ns/op 249.82 MB/s Benchmark______Pub8b_Payload-16 45866800 73.97 ns/op 256.87 MB/s Benchmark______Pub8b_Payload-16 46532916 74.02 ns/op 256.69 MB/s Benchmark______Pub8b_Payload-16 46112517 74.19 ns/op 256.11 MB/s Benchmark______Pub8b_Payload-16 48754839 73.82 ns/op 257.38 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 46226642 77.84 ns/op 565.27 MB/s Benchmark_____Pub32b_Payload-16 43690770 78.43 ns/op 561.01 MB/s Benchmark_____Pub32b_Payload-16 43644111 78.20 ns/op 562.66 MB/s Benchmark_____Pub32b_Payload-16 46165849 78.71 ns/op 559.03 MB/s Benchmark_____Pub32b_Payload-16 43558784 77.80 ns/op 565.55 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38992281 90.07 ns/op 1565.46 MB/s Benchmark____Pub128B_Payload-16 38940512 87.15 ns/op 1617.87 MB/s Benchmark____Pub128B_Payload-16 34726688 89.88 ns/op 1568.83 MB/s Benchmark____Pub128B_Payload-16 37870593 87.25 ns/op 1616.12 MB/s Benchmark____Pub128B_Payload-16 38853078 88.32 ns/op 1596.52 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 34643476 95.78 ns/op 2808.43 MB/s Benchmark____Pub256B_Payload-16 32480618 95.98 ns/op 2802.56 MB/s Benchmark____Pub256B_Payload-16 32040752 95.72 ns/op 2810.41 MB/s Benchmark____Pub256B_Payload-16 36137283 96.03 ns/op 2801.33 MB/s Benchmark____Pub256B_Payload-16 36502954 96.31 ns/op 2793.03 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23365314 134.7 ns/op 7705.18 MB/s Benchmark______Pub1K_Payload-16 25251614 138.5 ns/op 7492.84 MB/s Benchmark______Pub1K_Payload-16 24585224 137.9 ns/op 7526.09 MB/s Benchmark______Pub1K_Payload-16 24736173 143.9 ns/op 7214.78 MB/s Benchmark______Pub1K_Payload-16 25101759 137.5 ns/op 7547.68 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5679576 633.8 ns/op 6484.74 MB/s Benchmark______Pub4K_Payload-16 5438535 627.9 ns/op 6545.32 MB/s Benchmark______Pub4K_Payload-16 5700681 623.2 ns/op 6595.47 MB/s Benchmark______Pub4K_Payload-16 5612864 625.5 ns/op 6570.23 MB/s Benchmark______Pub4K_Payload-16 5649518 619.3 ns/op 6636.49 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2789834 1267 ns/op 6475.69 MB/s Benchmark______Pub8K_Payload-16 2800118 1275 ns/op 6438.47 MB/s Benchmark______Pub8K_Payload-16 2718015 1272 ns/op 6451.62 MB/s Benchmark______Pub8K_Payload-16 2759185 1282 ns/op 6401.55 MB/s Benchmark______Pub8K_Payload-16 2793244 1278 ns/op 6419.63 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 661503 5404 ns/op 6066.12 MB/s Benchmark_____Pub32K_Payload-16 670648 5540 ns/op 5917.03 MB/s Benchmark_____Pub32K_Payload-16 659410 5488 ns/op 5973.28 MB/s Benchmark_____Pub32K_Payload-16 593874 5429 ns/op 6039.02 MB/s Benchmark_____Pub32K_Payload-16 663034 5442 ns/op 6024.17 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32031366 93.94 ns/op 117.10 MB/s Benchmark__AuthPub0b_Payload-16 33326463 95.39 ns/op 115.32 MB/s Benchmark__AuthPub0b_Payload-16 36454746 94.06 ns/op 116.95 MB/s Benchmark__AuthPub0b_Payload-16 38350899 94.04 ns/op 116.98 MB/s Benchmark__AuthPub0b_Payload-16 32573156 94.02 ns/op 117.00 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15454862 227.3 ns/op Benchmark_____________PubSub-16 15512259 227.6 ns/op Benchmark_____________PubSub-16 15563565 228.8 ns/op Benchmark_____________PubSub-16 15477798 228.0 ns/op Benchmark_____________PubSub-16 15354451 228.0 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15514958 225.5 ns/op Benchmark_____PubSubTwoConns-16 15839031 227.9 ns/op Benchmark_____PubSubTwoConns-16 15729261 227.1 ns/op Benchmark_____PubSubTwoConns-16 15514944 226.4 ns/op Benchmark_____PubSubTwoConns-16 15766876 226.1 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:48564->127.0.0.1:33305: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:44266->127.0.0.1:32785: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:52422->127.0.0.1:34441: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:36894->127.0.0.1:32977: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40172->127.0.0.1:36443: 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 14339937 246.8 ns/op Benchmark_____PubTwoQueueSub-16 14405391 248.1 ns/op Benchmark_____PubTwoQueueSub-16 14378659 247.5 ns/op Benchmark_____PubTwoQueueSub-16 14387844 247.7 ns/op Benchmark_____PubTwoQueueSub-16 14354716 248.4 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14433712 248.5 ns/op Benchmark____PubFourQueueSub-16 14389122 248.4 ns/op Benchmark____PubFourQueueSub-16 14321601 248.0 ns/op Benchmark____PubFourQueueSub-16 14448039 248.6 ns/op Benchmark____PubFourQueueSub-16 14185684 248.7 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14109693 247.7 ns/op Benchmark___PubEightQueueSub-16 14294862 248.2 ns/op Benchmark___PubEightQueueSub-16 14302420 248.2 ns/op Benchmark___PubEightQueueSub-16 14268882 248.5 ns/op Benchmark___PubEightQueueSub-16 14308490 248.3 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22894 157616 ns/op Benchmark_PubSub512kTwoConns-16 23074 163871 ns/op Benchmark_PubSub512kTwoConns-16 23224 155033 ns/op Benchmark_PubSub512kTwoConns-16 23113 154556 ns/op Benchmark_PubSub512kTwoConns-16 23174 154758 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15193478 229.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15090015 230.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15204156 230.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15215630 230.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15238362 230.0 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15223137 230.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15186289 229.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15013776 229.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15369836 230.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15245517 232.0 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11195529 318.4 ns/op Benchmark____RoutedPubSub_0b-16 11191312 323.3 ns/op Benchmark____RoutedPubSub_0b-16 11279461 322.3 ns/op Benchmark____RoutedPubSub_0b-16 11172231 322.1 ns/op Benchmark____RoutedPubSub_0b-16 10690454 321.0 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6593922 537.0 ns/op Benchmark____RoutedPubSub_1K-16 6554106 540.0 ns/op Benchmark____RoutedPubSub_1K-16 6543366 547.2 ns/op Benchmark____RoutedPubSub_1K-16 6650629 537.1 ns/op Benchmark____RoutedPubSub_1K-16 6415238 544.5 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85100 42798 ns/op Benchmark__RoutedPubSub_100K-16 85005 41444 ns/op Benchmark__RoutedPubSub_100K-16 86024 41773 ns/op Benchmark__RoutedPubSub_100K-16 84974 42471 ns/op Benchmark__RoutedPubSub_100K-16 87457 41223 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9563510 319.2 ns/op Benchmark____Routed2QueueSub-16 9857589 327.8 ns/op Benchmark____Routed2QueueSub-16 11523398 313.9 ns/op Benchmark____Routed2QueueSub-16 9665764 322.7 ns/op Benchmark____Routed2QueueSub-16 9724239 319.6 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9592009 324.1 ns/op Benchmark____Routed4QueueSub-16 9434635 326.8 ns/op Benchmark____Routed4QueueSub-16 10948148 313.8 ns/op Benchmark____Routed4QueueSub-16 9596107 326.0 ns/op Benchmark____Routed4QueueSub-16 9503457 325.2 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9207588 332.4 ns/op Benchmark____Routed8QueueSub-16 9570105 339.6 ns/op Benchmark____Routed8QueueSub-16 9376581 326.6 ns/op Benchmark____Routed8QueueSub-16 9465054 329.3 ns/op Benchmark____Routed8QueueSub-16 9340207 327.2 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8778193 345.1 ns/op Benchmark___Routed16QueueSub-16 8677557 352.9 ns/op Benchmark___Routed16QueueSub-16 8842735 349.6 ns/op Benchmark___Routed16QueueSub-16 8794329 352.5 ns/op Benchmark___Routed16QueueSub-16 8731456 349.1 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6444240 561.0 ns/op Benchmark____________RouteCompressOff-16 6361035 562.5 ns/op Benchmark____________RouteCompressOff-16 6427490 557.4 ns/op Benchmark____________RouteCompressOff-16 6424084 557.0 ns/op Benchmark____________RouteCompressOff-16 6376552 554.8 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6466970 558.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6416913 547.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6518722 556.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6340004 556.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6387732 589.1 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6194774 557.8 ns/op Benchmark_________RouteCompressS2Fast-16 6359571 560.6 ns/op Benchmark_________RouteCompressS2Fast-16 6131404 558.6 ns/op Benchmark_________RouteCompressS2Fast-16 6342925 556.8 ns/op Benchmark_________RouteCompressS2Fast-16 6421573 558.7 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6361227 558.8 ns/op Benchmark_______RouteCompressS2Better-16 6394120 552.0 ns/op Benchmark_______RouteCompressS2Better-16 6437984 548.6 ns/op Benchmark_______RouteCompressS2Better-16 6460666 549.8 ns/op Benchmark_______RouteCompressS2Better-16 6352975 555.0 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6322467 554.4 ns/op Benchmark_________RouteCompressS2Best-16 6349706 559.1 ns/op Benchmark_________RouteCompressS2Best-16 6609662 549.5 ns/op Benchmark_________RouteCompressS2Best-16 6398140 554.1 ns/op Benchmark_________RouteCompressS2Best-16 6239660 555.4 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4640091 775.6 ns/op 321.05 MB/s Benchmark______FanOut_8x1x10-16 4656676 770.7 ns/op 323.08 MB/s Benchmark______FanOut_8x1x10-16 4646018 764.9 ns/op 325.51 MB/s Benchmark______FanOut_8x1x10-16 4653774 768.9 ns/op 323.82 MB/s Benchmark______FanOut_8x1x10-16 4620471 768.4 ns/op 324.04 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 551328 6075 ns/op 381.73 MB/s Benchmark_____FanOut_8x1x100-16 564006 6072 ns/op 381.92 MB/s Benchmark_____FanOut_8x1x100-16 562495 6092 ns/op 380.64 MB/s Benchmark_____FanOut_8x1x100-16 543372 6052 ns/op 383.15 MB/s Benchmark_____FanOut_8x1x100-16 540553 6100 ns/op 380.15 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47713 74464 ns/op 309.13 MB/s Benchmark____FanOut_8x10x100-16 48374 75413 ns/op 305.24 MB/s Benchmark____FanOut_8x10x100-16 48202 74435 ns/op 309.25 MB/s Benchmark____FanOut_8x10x100-16 48511 74077 ns/op 310.75 MB/s Benchmark____FanOut_8x10x100-16 47995 74578 ns/op 308.66 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5841 604173 ns/op 397.27 MB/s Benchmark___FanOut_8x10x1000-16 5392 592687 ns/op 404.97 MB/s Benchmark___FanOut_8x10x1000-16 6044 594143 ns/op 403.98 MB/s Benchmark___FanOut_8x10x1000-16 6012 593387 ns/op 404.49 MB/s Benchmark___FanOut_8x10x1000-16 5834 598139 ns/op 401.28 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5008 705762 ns/op 325.92 MB/s Benchmark___FanOut_8x100x100-16 4976 705539 ns/op 326.02 MB/s Benchmark___FanOut_8x100x100-16 5016 707454 ns/op 325.14 MB/s Benchmark___FanOut_8x100x100-16 5019 704450 ns/op 326.52 MB/s Benchmark___FanOut_8x100x100-16 5053 704991 ns/op 326.27 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 579 6145508 ns/op 390.53 MB/s Benchmark__FanOut_8x100x1000-16 591 6140312 ns/op 390.86 MB/s Benchmark__FanOut_8x100x1000-16 586 6127036 ns/op 391.71 MB/s Benchmark__FanOut_8x100x1000-16 577 6152237 ns/op 390.11 MB/s Benchmark__FanOut_8x100x1000-16 579 6256004 ns/op 383.63 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 519 6659023 ns/op 375.43 MB/s Benchmark__FanOut_8x10x10000-16 534 6756828 ns/op 370.00 MB/s Benchmark__FanOut_8x10x10000-16 523 6785928 ns/op 368.41 MB/s Benchmark__FanOut_8x10x10000-16 531 6640584 ns/op 376.48 MB/s Benchmark__FanOut_8x10x10000-16 542 6712984 ns/op 372.42 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 942 3751805 ns/op 306.52 MB/s Benchmark___FanOut_8x500x100-16 938 3757481 ns/op 306.06 MB/s Benchmark___FanOut_8x500x100-16 950 3805177 ns/op 302.22 MB/s Benchmark___FanOut_8x500x100-16 948 3753282 ns/op 306.40 MB/s Benchmark___FanOut_8x500x100-16 954 3760547 ns/op 305.81 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 369273 9453 ns/op 1548.80 MB/s Benchmark___FanOut_128x1x100-16 361648 9465 ns/op 1546.90 MB/s Benchmark___FanOut_128x1x100-16 373852 9519 ns/op 1538.07 MB/s Benchmark___FanOut_128x1x100-16 358622 9453 ns/op 1548.79 MB/s Benchmark___FanOut_128x1x100-16 369075 9531 ns/op 1536.08 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32290 111531 ns/op 1301.35 MB/s Benchmark__FanOut_128x10x100-16 32478 110937 ns/op 1308.31 MB/s Benchmark__FanOut_128x10x100-16 32799 110552 ns/op 1312.88 MB/s Benchmark__FanOut_128x10x100-16 32588 110472 ns/op 1313.83 MB/s Benchmark__FanOut_128x10x100-16 32580 110079 ns/op 1318.52 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4071 887809 ns/op 1644.66 MB/s Benchmark_FanOut_128x10x1000-16 3852 875492 ns/op 1667.80 MB/s Benchmark_FanOut_128x10x1000-16 4192 882633 ns/op 1654.30 MB/s Benchmark_FanOut_128x10x1000-16 4159 871864 ns/op 1674.73 MB/s Benchmark_FanOut_128x10x1000-16 4045 871713 ns/op 1675.02 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3561 1009121 ns/op 1437.03 MB/s Benchmark_FanOut_128x100x100-16 3531 1010134 ns/op 1435.59 MB/s Benchmark_FanOut_128x100x100-16 3498 1005501 ns/op 1442.21 MB/s Benchmark_FanOut_128x100x100-16 3510 1010829 ns/op 1434.61 MB/s Benchmark_FanOut_128x100x100-16 3519 1005928 ns/op 1441.60 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 385 9243222 ns/op 1579.55 MB/s BenchmarkFanOut_128x100x1000-16 378 9254173 ns/op 1577.68 MB/s BenchmarkFanOut_128x100x1000-16 381 9208588 ns/op 1585.49 MB/s BenchmarkFanOut_128x100x1000-16 385 9299355 ns/op 1570.02 MB/s BenchmarkFanOut_128x100x1000-16 387 9360636 ns/op 1559.74 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 380 9673959 ns/op 1519.56 MB/s BenchmarkFanOut_128x10x10000-16 376 9581090 ns/op 1534.29 MB/s BenchmarkFanOut_128x10x10000-16 376 9606428 ns/op 1530.24 MB/s BenchmarkFanOut_128x10x10000-16 370 9599818 ns/op 1531.29 MB/s BenchmarkFanOut_128x10x10000-16 372 9634986 ns/op 1525.70 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 664 5273694 ns/op 1374.77 MB/s BenchmarkFanOut__128x500x100-16 669 5252681 ns/op 1380.27 MB/s BenchmarkFanOut__128x500x100-16 674 5302453 ns/op 1367.32 MB/s BenchmarkFanOut__128x500x100-16 684 5291472 ns/op 1370.16 MB/s BenchmarkFanOut__128x500x100-16 663 5258653 ns/op 1378.71 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1917 1842651 ns/op 2871.15 MB/s Benchmark_FanOut_512x100x100-16 1950 1837512 ns/op 2879.18 MB/s Benchmark_FanOut_512x100x100-16 1927 1838539 ns/op 2877.57 MB/s Benchmark_FanOut_512x100x100-16 1942 1836328 ns/op 2881.04 MB/s Benchmark_FanOut_512x100x100-16 1918 1832652 ns/op 2886.81 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 216 16698258 ns/op 3174.02 MB/s Benchmark__FanOut_512x100x1k-16 218 16718525 ns/op 3170.17 MB/s Benchmark__FanOut_512x100x1k-16 218 16783582 ns/op 3157.88 MB/s Benchmark__FanOut_512x100x1k-16 214 16728627 ns/op 3168.25 MB/s Benchmark__FanOut_512x100x1k-16 213 16606847 ns/op 3191.49 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2791 1148634 ns/op 9081.26 MB/s Benchmark____FanOut_1kx10x1k-16 3100 1153389 ns/op 9043.81 MB/s Benchmark____FanOut_1kx10x1k-16 3030 1139650 ns/op 9152.84 MB/s Benchmark____FanOut_1kx10x1k-16 3168 1146433 ns/op 9098.69 MB/s Benchmark____FanOut_1kx10x1k-16 2930 1155702 ns/op 9025.72 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2732 1252724 ns/op 8318.70 MB/s Benchmark__FanOut_1kx100x100-16 2775 1252565 ns/op 8319.76 MB/s Benchmark__FanOut_1kx100x100-16 2836 1257946 ns/op 8284.17 MB/s Benchmark__FanOut_1kx100x100-16 2750 1258403 ns/op 8281.16 MB/s Benchmark__FanOut_1kx100x100-16 2762 1254035 ns/op 8310.01 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4417660 775.0 ns/op 321.31 MB/s Benchmark_____RFanOut_8x1x10-16 4470760 780.1 ns/op 319.17 MB/s Benchmark_____RFanOut_8x1x10-16 4513126 771.0 ns/op 322.98 MB/s Benchmark_____RFanOut_8x1x10-16 4522352 776.2 ns/op 320.81 MB/s Benchmark_____RFanOut_8x1x10-16 4434034 786.5 ns/op 316.59 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 560644 5999 ns/op 386.56 MB/s Benchmark____RFanOut_8x1x100-16 534019 6027 ns/op 384.80 MB/s Benchmark____RFanOut_8x1x100-16 546615 6103 ns/op 379.97 MB/s Benchmark____RFanOut_8x1x100-16 530702 6161 ns/op 376.41 MB/s Benchmark____RFanOut_8x1x100-16 545383 6109 ns/op 379.58 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48736 74030 ns/op 310.94 MB/s Benchmark___RFanOut_8x10x100-16 48508 74064 ns/op 310.80 MB/s Benchmark___RFanOut_8x10x100-16 48631 73989 ns/op 311.11 MB/s Benchmark___RFanOut_8x10x100-16 48423 73685 ns/op 312.40 MB/s Benchmark___RFanOut_8x10x100-16 48954 74043 ns/op 310.89 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6074 591525 ns/op 405.76 MB/s Benchmark__RFanOut_8x10x1000-16 6129 589353 ns/op 407.26 MB/s Benchmark__RFanOut_8x10x1000-16 5982 588643 ns/op 407.75 MB/s Benchmark__RFanOut_8x10x1000-16 5942 588018 ns/op 408.18 MB/s Benchmark__RFanOut_8x10x1000-16 5917 598493 ns/op 401.04 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5046 696867 ns/op 330.08 MB/s Benchmark__RFanOut_8x100x100-16 5060 700178 ns/op 328.52 MB/s Benchmark__RFanOut_8x100x100-16 4929 696850 ns/op 330.08 MB/s Benchmark__RFanOut_8x100x100-16 5076 698093 ns/op 329.50 MB/s Benchmark__RFanOut_8x100x100-16 5080 696445 ns/op 330.28 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 594 6014651 ns/op 399.03 MB/s Benchmark_RFanOut_8x100x1000-16 586 6014878 ns/op 399.01 MB/s Benchmark_RFanOut_8x100x1000-16 591 6004482 ns/op 399.70 MB/s Benchmark_RFanOut_8x100x1000-16 588 6029045 ns/op 398.08 MB/s Benchmark_RFanOut_8x100x1000-16 586 6020192 ns/op 398.66 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 541 6542022 ns/op 382.15 MB/s Benchmark_RFanOut_8x10x10000-16 548 6530489 ns/op 382.82 MB/s Benchmark_RFanOut_8x10x10000-16 535 6510182 ns/op 384.02 MB/s Benchmark_RFanOut_8x10x10000-16 546 6577425 ns/op 380.09 MB/s Benchmark_RFanOut_8x10x10000-16 541 6588845 ns/op 379.43 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3213 1138157 ns/op 9164.85 MB/s Benchmark_RFanOut_1kx10x1000-16 3271 1124271 ns/op 9278.05 MB/s Benchmark_RFanOut_1kx10x1000-16 3268 1158440 ns/op 9004.39 MB/s Benchmark_RFanOut_1kx10x1000-16 2894 1141511 ns/op 9137.92 MB/s Benchmark_RFanOut_1kx10x1000-16 3309 1146272 ns/op 9099.97 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6958299 503.1 ns/op 4130.77 MB/s Benchmark_____FanIn_1kx100x1-16 6950599 504.9 ns/op 4115.43 MB/s Benchmark_____FanIn_1kx100x1-16 6952357 503.5 ns/op 4126.95 MB/s Benchmark_____FanIn_1kx100x1-16 6959377 505.2 ns/op 4113.50 MB/s Benchmark_____FanIn_1kx100x1-16 7022958 503.8 ns/op 4125.03 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2633832 1343 ns/op 6122.83 MB/s Benchmark_____FanIn_4kx100x1-16 2625151 1353 ns/op 6076.30 MB/s Benchmark_____FanIn_4kx100x1-16 2666438 1348 ns/op 6101.16 MB/s Benchmark_____FanIn_4kx100x1-16 2625974 1356 ns/op 6062.83 MB/s Benchmark_____FanIn_4kx100x1-16 2670616 1355 ns/op 6066.62 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1680357 2123 ns/op 7732.60 MB/s Benchmark_____FanIn_8kx100x1-16 1718661 2114 ns/op 7763.29 MB/s Benchmark_____FanIn_8kx100x1-16 1683014 2111 ns/op 7777.24 MB/s Benchmark_____FanIn_8kx100x1-16 1732071 2099 ns/op 7818.93 MB/s Benchmark_____FanIn_8kx100x1-16 1733547 2130 ns/op 7705.38 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 869179 4120 ns/op 7961.97 MB/s Benchmark____FanIn_16kx100x1-16 868444 4160 ns/op 7884.14 MB/s Benchmark____FanIn_16kx100x1-16 860955 4130 ns/op 7941.64 MB/s Benchmark____FanIn_16kx100x1-16 865027 4112 ns/op 7977.50 MB/s Benchmark____FanIn_16kx100x1-16 877234 4183 ns/op 7840.61 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 171472 19866 ns/op 6599.53 MB/s Benchmark____FanIn_64kx100x1-16 161313 19917 ns/op 6582.41 MB/s Benchmark____FanIn_64kx100x1-16 170362 19934 ns/op 6577.04 MB/s Benchmark____FanIn_64kx100x1-16 168477 20182 ns/op 6496.21 MB/s Benchmark____FanIn_64kx100x1-16 171439 19968 ns/op 6565.56 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 450949600 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47912->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 417914920 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49220->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49102->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49224->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 116539010 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51444->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 370853610 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53054->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52612->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:52726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52848->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: 2329338210 vs 11273740000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55796->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5565152 641.6 ns/op 442.62 MB/s Benchmark___BumpPubCount_1x3-16 5552514 642.4 ns/op 442.10 MB/s Benchmark___BumpPubCount_1x3-16 5552788 642.1 ns/op 442.30 MB/s Benchmark___BumpPubCount_1x3-16 5601487 640.7 ns/op 443.23 MB/s Benchmark___BumpPubCount_1x3-16 5600593 640.9 ns/op 443.11 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5337223 676.4 ns/op 419.88 MB/s Benchmark___BumpPubCount_2x3-16 5324659 673.1 ns/op 421.94 MB/s Benchmark___BumpPubCount_2x3-16 5321989 665.5 ns/op 426.73 MB/s Benchmark___BumpPubCount_2x3-16 5297686 669.0 ns/op 424.53 MB/s Benchmark___BumpPubCount_2x3-16 5309942 672.6 ns/op 422.24 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5544032 643.5 ns/op 441.31 MB/s Benchmark___BumpPubCount_5x3-16 5357869 647.5 ns/op 438.62 MB/s Benchmark___BumpPubCount_5x3-16 5526582 642.9 ns/op 441.71 MB/s Benchmark___BumpPubCount_5x3-16 5499240 649.6 ns/op 437.18 MB/s Benchmark___BumpPubCount_5x3-16 5498869 646.8 ns/op 439.06 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5529819 649.1 ns/op 437.55 MB/s Benchmark__BumpPubCount_10x3-16 5545354 649.1 ns/op 437.50 MB/s Benchmark__BumpPubCount_10x3-16 5552539 646.3 ns/op 439.41 MB/s Benchmark__BumpPubCount_10x3-16 5567012 647.3 ns/op 438.77 MB/s Benchmark__BumpPubCount_10x3-16 5575276 646.7 ns/op 439.15 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12195172 273.4 ns/op 3803.52 MB/s Benchmark____GWs_Opt_1kx01x0-16 11822157 285.1 ns/op 3647.58 MB/s Benchmark____GWs_Opt_1kx01x0-16 12761389 270.6 ns/op 3843.67 MB/s Benchmark____GWs_Opt_1kx01x0-16 12390985 276.4 ns/op 3763.17 MB/s Benchmark____GWs_Opt_1kx01x0-16 12276639 272.9 ns/op 3810.50 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 11145476 344.6 ns/op 5989.22 MB/s Benchmark____GWs_Opt_2kx01x0-16 9973130 341.6 ns/op 6041.78 MB/s Benchmark____GWs_Opt_2kx01x0-16 10944744 329.9 ns/op 6257.10 MB/s Benchmark____GWs_Opt_2kx01x0-16 10556804 346.0 ns/op 5965.83 MB/s Benchmark____GWs_Opt_2kx01x0-16 10387147 337.7 ns/op 6111.47 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5722537 630.8 ns/op 6519.17 MB/s Benchmark____GWs_Opt_4kx01x0-16 5646295 636.1 ns/op 6464.43 MB/s Benchmark____GWs_Opt_4kx01x0-16 5517486 622.8 ns/op 6602.29 MB/s Benchmark____GWs_Opt_4kx01x0-16 5765305 630.0 ns/op 6527.50 MB/s Benchmark____GWs_Opt_4kx01x0-16 5694798 631.8 ns/op 6508.62 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28129941 108.8 ns/op 9558.26 MB/s Benchmark____GWs_Opt_1kx10x0-16 30951307 114.5 ns/op 9085.23 MB/s Benchmark____GWs_Opt_1kx10x0-16 28560361 114.9 ns/op 9050.88 MB/s Benchmark____GWs_Opt_1kx10x0-16 30144326 115.1 ns/op 9035.85 MB/s Benchmark____GWs_Opt_1kx10x0-16 28842496 111.3 ns/op 9340.99 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23741049 145.0 ns/op 14234.50 MB/s Benchmark____GWs_Opt_2kx10x0-16 20310873 156.7 ns/op 13175.78 MB/s Benchmark____GWs_Opt_2kx10x0-16 24027718 145.5 ns/op 14182.13 MB/s Benchmark____GWs_Opt_2kx10x0-16 24034716 148.0 ns/op 13946.65 MB/s Benchmark____GWs_Opt_2kx10x0-16 25664340 151.4 ns/op 13634.32 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 13244407 320.6 ns/op 12825.85 MB/s Benchmark____GWs_Opt_4kx10x0-16 9617650 314.5 ns/op 13073.62 MB/s Benchmark____GWs_Opt_4kx10x0-16 12760081 314.3 ns/op 13083.54 MB/s Benchmark____GWs_Opt_4kx10x0-16 12677107 286.1 ns/op 14372.82 MB/s Benchmark____GWs_Opt_4kx10x0-16 12603199 289.0 ns/op 14229.12 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6236702 561.2 ns/op 5567.97 MB/s Benchmark____GWs_Opt_1kx01x1-16 6493182 553.2 ns/op 5648.66 MB/s Benchmark____GWs_Opt_1kx01x1-16 6813493 559.9 ns/op 5581.67 MB/s Benchmark____GWs_Opt_1kx01x1-16 6357886 550.5 ns/op 5676.44 MB/s Benchmark____GWs_Opt_1kx01x1-16 6502304 909.0 ns/op 3437.98 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4657893 771.2 ns/op 8035.80 MB/s Benchmark____GWs_Opt_2kx01x1-16 4731292 770.7 ns/op 8040.66 MB/s Benchmark____GWs_Opt_2kx01x1-16 4519899 816.2 ns/op 7592.60 MB/s Benchmark____GWs_Opt_2kx01x1-16 4489213 772.0 ns/op 8027.34 MB/s Benchmark____GWs_Opt_2kx01x1-16 4256469 768.4 ns/op 8064.41 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2588341 1458 ns/op 8463.45 MB/s Benchmark____GWs_Opt_4kx01x1-16 2632417 1387 ns/op 8897.00 MB/s Benchmark____GWs_Opt_4kx01x1-16 2594181 1396 ns/op 8840.45 MB/s Benchmark____GWs_Opt_4kx01x1-16 2334352 1378 ns/op 8955.99 MB/s Benchmark____GWs_Opt_4kx01x1-16 2528197 1388 ns/op 8888.96 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6590550 569.6 ns/op 5485.96 MB/s Benchmark____GWs_Opt_1kx10x1-16 6040923 555.9 ns/op 5621.21 MB/s Benchmark____GWs_Opt_1kx10x1-16 6243997 588.8 ns/op 5307.55 MB/s Benchmark____GWs_Opt_1kx10x1-16 6439891 554.4 ns/op 5636.29 MB/s Benchmark____GWs_Opt_1kx10x1-16 6598245 556.7 ns/op 5613.62 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4107288 855.5 ns/op 7243.69 MB/s Benchmark____GWs_Opt_2kx10x1-16 4254338 838.7 ns/op 7388.58 MB/s Benchmark____GWs_Opt_2kx10x1-16 4175508 840.6 ns/op 7372.24 MB/s Benchmark____GWs_Opt_2kx10x1-16 4439865 849.1 ns/op 7298.02 MB/s Benchmark____GWs_Opt_2kx10x1-16 3737328 875.1 ns/op 7081.79 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2498953 1506 ns/op 8192.07 MB/s Benchmark____GWs_Opt_4kx10x1-16 2363163 1538 ns/op 8023.55 MB/s Benchmark____GWs_Opt_4kx10x1-16 2349007 1517 ns/op 8134.22 MB/s Benchmark____GWs_Opt_4kx10x1-16 2335616 1573 ns/op 7845.21 MB/s Benchmark____GWs_Opt_4kx10x1-16 2345416 1560 ns/op 7912.17 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11707894 305.0 ns/op 3409.67 MB/s Benchmark____GWs_Int_1kx01x0-16 12446937 287.7 ns/op 3615.20 MB/s Benchmark____GWs_Int_1kx01x0-16 12499556 290.8 ns/op 3576.49 MB/s Benchmark____GWs_Int_1kx01x0-16 12416317 292.0 ns/op 3561.63 MB/s Benchmark____GWs_Int_1kx01x0-16 11453474 283.6 ns/op 3667.71 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 8977250 367.8 ns/op 5611.01 MB/s Benchmark____GWs_Int_2kx01x0-16 10139536 358.5 ns/op 5757.51 MB/s Benchmark____GWs_Int_2kx01x0-16 10179885 356.0 ns/op 5798.55 MB/s Benchmark____GWs_Int_2kx01x0-16 10135897 354.9 ns/op 5816.40 MB/s Benchmark____GWs_Int_2kx01x0-16 9725320 361.7 ns/op 5706.05 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5489770 737.0 ns/op 5579.66 MB/s Benchmark____GWs_Int_4kx01x0-16 5582331 635.8 ns/op 6467.28 MB/s Benchmark____GWs_Int_4kx01x0-16 5718816 660.4 ns/op 6226.71 MB/s Benchmark____GWs_Int_4kx01x0-16 5741446 651.4 ns/op 6312.88 MB/s Benchmark____GWs_Int_4kx01x0-16 5578220 656.9 ns/op 6259.58 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30321472 108.2 ns/op 9609.84 MB/s Benchmark____GWs_Int_1kx10x0-16 28118830 113.7 ns/op 9148.71 MB/s Benchmark____GWs_Int_1kx10x0-16 32518558 114.4 ns/op 9093.49 MB/s Benchmark____GWs_Int_1kx10x0-16 27863632 113.3 ns/op 9182.97 MB/s Benchmark____GWs_Int_1kx10x0-16 28037205 111.8 ns/op 9301.18 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 22376278 147.3 ns/op 14011.96 MB/s Benchmark____GWs_Int_2kx10x0-16 26059465 158.8 ns/op 12993.94 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:55082->127.0.0.1:36877: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 24740084 140.9 ns/op 14646.37 MB/s Benchmark____GWs_Int_2kx10x0-16 25929177 149.2 ns/op 13836.98 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13440973 290.4 ns/op 14161.06 MB/s Benchmark____GWs_Int_4kx10x0-16 13199472 391.6 ns/op 10501.08 MB/s Benchmark____GWs_Int_4kx10x0-16 10875398 339.0 ns/op 12131.30 MB/s Benchmark____GWs_Int_4kx10x0-16 13270812 299.3 ns/op 13739.08 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:33156->127.0.0.1:41997: i/o timeout bench_test.go:167: Did not receive all bytes: 176 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:38690->127.0.0.1:42517: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:38666->127.0.0.1:42517: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6353068 568.9 ns/op 5493.40 MB/s Benchmark____GWs_Int_1kx01x1-16 6387093 564.7 ns/op 5533.88 MB/s Benchmark____GWs_Int_1kx01x1-16 6219492 571.4 ns/op 5469.34 MB/s Benchmark____GWs_Int_1kx01x1-16 6466507 561.5 ns/op 5565.73 MB/s Benchmark____GWs_Int_1kx01x1-16 6451263 563.2 ns/op 5548.51 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4667997 773.7 ns/op 8009.24 MB/s Benchmark____GWs_Int_2kx01x1-16 4510089 769.2 ns/op 8056.86 MB/s Benchmark____GWs_Int_2kx01x1-16 4291562 781.0 ns/op 7934.50 MB/s Benchmark____GWs_Int_2kx01x1-16 4662192 779.1 ns/op 7954.03 MB/s Benchmark____GWs_Int_2kx01x1-16 4670289 778.9 ns/op 7956.04 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2615342 1387 ns/op 8897.85 MB/s Benchmark____GWs_Int_4kx01x1-16 2206089 1376 ns/op 8966.25 MB/s Benchmark____GWs_Int_4kx01x1-16 2474042 1594 ns/op 7743.96 MB/s Benchmark____GWs_Int_4kx01x1-16 2511542 1417 ns/op 8708.50 MB/s Benchmark____GWs_Int_4kx01x1-16 2607673 1388 ns/op 8892.74 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6434554 557.1 ns/op 5609.47 MB/s Benchmark____GWs_Int_1kx10x1-16 6114938 567.5 ns/op 5506.33 MB/s Benchmark____GWs_Int_1kx10x1-16 6131289 568.6 ns/op 5496.22 MB/s Benchmark____GWs_Int_1kx10x1-16 6200703 559.8 ns/op 5582.19 MB/s Benchmark____GWs_Int_1kx10x1-16 6306045 600.5 ns/op 5203.64 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4117610 850.0 ns/op 7290.30 MB/s Benchmark____GWs_Int_2kx10x1-16 3910785 830.9 ns/op 7457.98 MB/s Benchmark____GWs_Int_2kx10x1-16 4196365 840.7 ns/op 7371.34 MB/s Benchmark____GWs_Int_2kx10x1-16 4336458 849.6 ns/op 7293.72 MB/s Benchmark____GWs_Int_2kx10x1-16 4524798 861.2 ns/op 7195.40 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2317874 1661 ns/op 7430.94 MB/s Benchmark____GWs_Int_4kx10x1-16 2278306 1520 ns/op 8120.72 MB/s Benchmark____GWs_Int_4kx10x1-16 2146838 1507 ns/op 8187.39 MB/s Benchmark____GWs_Int_4kx10x1-16 2335293 1499 ns/op 8235.28 MB/s Benchmark____GWs_Int_4kx10x1-16 2343312 1458 ns/op 8466.98 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8239554 435.4 ns/op 234.28 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8033372 439.5 ns/op 232.06 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8193127 440.8 ns/op 231.39 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8104009 442.4 ns/op 230.58 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8455396 437.4 ns/op 233.18 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 720309 5078 ns/op 34.86 MB/s Benchmark__GWs_Reqs_1SubEach-16 743084 5287 ns/op 33.48 MB/s Benchmark__GWs_Reqs_1SubEach-16 766920 5224 ns/op 33.88 MB/s Benchmark__GWs_Reqs_1SubEach-16 774488 5304 ns/op 33.37 MB/s Benchmark__GWs_Reqs_1SubEach-16 736761 5236 ns/op 33.81 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2105.648s ❌ Non-zero exit code: 1