> ROOT_DIR=/tmp/go-bench-away-job-bdd3b9b7-33bf-42f4-9347-8204158386d0-1587882210 > OUTPUT_FILE=/tmp/go-bench-away-job-bdd3b9b7-33bf-42f4-9347-8204158386d0-1587882210/results.txt > SHA_FILE=/tmp/go-bench-away-job-bdd3b9b7-33bf-42f4-9347-8204158386d0-1587882210/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-bdd3b9b7-33bf-42f4-9347-8204158386d0-1587882210/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-bdd3b9b7-33bf-42f4-9347-8204158386d0-1587882210/source.git SHA of main: ccd898ea86accf40861f1dd651df8e7fb9c0e5f3 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-build589197582=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-bdd3b9b7-33bf-42f4-9347-8204158386d0-1587882210/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 40025538 76.49 ns/op 143.80 MB/s Benchmark______Pub0b_Payload-16 46154792 73.82 ns/op 149.00 MB/s Benchmark______Pub0b_Payload-16 44918058 73.91 ns/op 148.83 MB/s Benchmark______Pub0b_Payload-16 46272450 74.22 ns/op 148.22 MB/s Benchmark______Pub0b_Payload-16 46066772 74.17 ns/op 148.31 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45396403 74.59 ns/op 254.72 MB/s Benchmark______Pub8b_Payload-16 45662416 74.65 ns/op 254.51 MB/s Benchmark______Pub8b_Payload-16 48330974 74.51 ns/op 254.99 MB/s Benchmark______Pub8b_Payload-16 48347088 74.41 ns/op 255.33 MB/s Benchmark______Pub8b_Payload-16 45268062 74.63 ns/op 254.60 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 37930270 79.59 ns/op 552.81 MB/s Benchmark_____Pub32b_Payload-16 39538638 78.67 ns/op 559.30 MB/s Benchmark_____Pub32b_Payload-16 43550665 78.39 ns/op 561.32 MB/s Benchmark_____Pub32b_Payload-16 42707996 78.13 ns/op 563.20 MB/s Benchmark_____Pub32b_Payload-16 43723123 78.26 ns/op 562.24 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 37112019 88.47 ns/op 1593.71 MB/s Benchmark____Pub128B_Payload-16 38282010 87.91 ns/op 1603.96 MB/s Benchmark____Pub128B_Payload-16 40966308 87.78 ns/op 1606.27 MB/s Benchmark____Pub128B_Payload-16 34014933 88.43 ns/op 1594.52 MB/s Benchmark____Pub128B_Payload-16 39092092 90.86 ns/op 1551.79 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 33481900 95.87 ns/op 2805.93 MB/s Benchmark____Pub256B_Payload-16 31227426 99.00 ns/op 2717.30 MB/s Benchmark____Pub256B_Payload-16 34669959 102.0 ns/op 2636.32 MB/s Benchmark____Pub256B_Payload-16 35708906 97.94 ns/op 2746.46 MB/s Benchmark____Pub256B_Payload-16 35809834 98.31 ns/op 2736.33 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23846952 141.7 ns/op 7324.27 MB/s Benchmark______Pub1K_Payload-16 25436065 145.0 ns/op 7158.46 MB/s Benchmark______Pub1K_Payload-16 25213309 140.1 ns/op 7408.63 MB/s Benchmark______Pub1K_Payload-16 23196824 137.0 ns/op 7577.57 MB/s Benchmark______Pub1K_Payload-16 24429933 141.6 ns/op 7327.96 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5501131 637.7 ns/op 6444.75 MB/s Benchmark______Pub4K_Payload-16 5537798 614.6 ns/op 6687.25 MB/s Benchmark______Pub4K_Payload-16 5495571 631.0 ns/op 6513.30 MB/s Benchmark______Pub4K_Payload-16 5767238 620.7 ns/op 6621.34 MB/s Benchmark______Pub4K_Payload-16 5499861 624.2 ns/op 6584.82 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2750565 1273 ns/op 6446.13 MB/s Benchmark______Pub8K_Payload-16 2757807 1281 ns/op 6406.73 MB/s Benchmark______Pub8K_Payload-16 2667102 1293 ns/op 6345.31 MB/s Benchmark______Pub8K_Payload-16 2769301 1271 ns/op 6458.57 MB/s Benchmark______Pub8K_Payload-16 2761197 1271 ns/op 6456.05 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 659530 6180 ns/op 5304.27 MB/s Benchmark_____Pub32K_Payload-16 533665 10578 ns/op 3099.05 MB/s Benchmark_____Pub32K_Payload-16 599616 5517 ns/op 5941.73 MB/s Benchmark_____Pub32K_Payload-16 671455 5434 ns/op 6032.66 MB/s Benchmark_____Pub32K_Payload-16 553562 5548 ns/op 5909.45 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31868847 95.84 ns/op 114.78 MB/s Benchmark__AuthPub0b_Payload-16 35902683 95.62 ns/op 115.04 MB/s Benchmark__AuthPub0b_Payload-16 35918869 95.60 ns/op 115.07 MB/s Benchmark__AuthPub0b_Payload-16 33988885 95.26 ns/op 115.48 MB/s Benchmark__AuthPub0b_Payload-16 34308099 104.3 ns/op 105.50 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15558446 228.1 ns/op Benchmark_____________PubSub-16 15449040 228.5 ns/op Benchmark_____________PubSub-16 15450541 228.7 ns/op Benchmark_____________PubSub-16 15539007 229.4 ns/op Benchmark_____________PubSub-16 15483688 228.8 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15774493 225.7 ns/op Benchmark_____PubSubTwoConns-16 15683208 226.3 ns/op Benchmark_____PubSubTwoConns-16 15685964 226.5 ns/op Benchmark_____PubSubTwoConns-16 15504890 226.1 ns/op Benchmark_____PubSubTwoConns-16 15597818 226.2 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34348->127.0.0.1:37615: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58034->127.0.0.1:35039: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:45902->127.0.0.1:43461: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:47904->127.0.0.1:40209: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42402->127.0.0.1:40881: 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 14275390 247.9 ns/op Benchmark_____PubTwoQueueSub-16 14246714 247.4 ns/op Benchmark_____PubTwoQueueSub-16 14289426 247.8 ns/op Benchmark_____PubTwoQueueSub-16 14299762 248.0 ns/op Benchmark_____PubTwoQueueSub-16 14274171 248.0 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14216181 248.1 ns/op Benchmark____PubFourQueueSub-16 14355913 248.4 ns/op Benchmark____PubFourQueueSub-16 14109063 247.5 ns/op Benchmark____PubFourQueueSub-16 14243692 247.8 ns/op Benchmark____PubFourQueueSub-16 14251304 247.4 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14302658 247.3 ns/op Benchmark___PubEightQueueSub-16 14329060 247.2 ns/op Benchmark___PubEightQueueSub-16 14449953 247.0 ns/op Benchmark___PubEightQueueSub-16 14270007 248.3 ns/op Benchmark___PubEightQueueSub-16 14218490 246.2 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23056 154860 ns/op Benchmark_PubSub512kTwoConns-16 22930 156544 ns/op Benchmark_PubSub512kTwoConns-16 22846 156675 ns/op Benchmark_PubSub512kTwoConns-16 22862 156571 ns/op Benchmark_PubSub512kTwoConns-16 23302 155946 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15023220 229.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15220359 231.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15170234 231.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15174361 230.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15050670 231.2 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15167216 230.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15149128 231.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15168422 232.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15224215 230.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15237294 230.8 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10906177 322.0 ns/op Benchmark____RoutedPubSub_0b-16 11176186 318.7 ns/op Benchmark____RoutedPubSub_0b-16 11205420 320.3 ns/op Benchmark____RoutedPubSub_0b-16 11435422 320.6 ns/op Benchmark____RoutedPubSub_0b-16 11090139 323.9 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6532062 542.3 ns/op Benchmark____RoutedPubSub_1K-16 6569614 540.2 ns/op Benchmark____RoutedPubSub_1K-16 6615631 902.5 ns/op Benchmark____RoutedPubSub_1K-16 6553227 539.2 ns/op Benchmark____RoutedPubSub_1K-16 6569364 538.1 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 83576 43327 ns/op Benchmark__RoutedPubSub_100K-16 89971 46612 ns/op Benchmark__RoutedPubSub_100K-16 69324 47292 ns/op Benchmark__RoutedPubSub_100K-16 79224 46118 ns/op Benchmark__RoutedPubSub_100K-16 78253 45621 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9354792 335.9 ns/op Benchmark____Routed2QueueSub-16 9852439 320.1 ns/op Benchmark____Routed2QueueSub-16 9558220 333.9 ns/op Benchmark____Routed2QueueSub-16 9617688 323.8 ns/op Benchmark____Routed2QueueSub-16 9529014 329.3 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9421612 332.3 ns/op Benchmark____Routed4QueueSub-16 9316093 327.0 ns/op Benchmark____Routed4QueueSub-16 9099672 335.4 ns/op Benchmark____Routed4QueueSub-16 9273024 330.5 ns/op Benchmark____Routed4QueueSub-16 9087139 334.9 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9247480 336.4 ns/op Benchmark____Routed8QueueSub-16 9184713 342.1 ns/op Benchmark____Routed8QueueSub-16 9206604 334.2 ns/op Benchmark____Routed8QueueSub-16 8984629 340.1 ns/op Benchmark____Routed8QueueSub-16 8880000 341.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8845975 352.2 ns/op Benchmark___Routed16QueueSub-16 8608860 355.6 ns/op Benchmark___Routed16QueueSub-16 8499704 360.7 ns/op Benchmark___Routed16QueueSub-16 8654647 357.7 ns/op Benchmark___Routed16QueueSub-16 8437720 361.6 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6246276 547.3 ns/op Benchmark____________RouteCompressOff-16 6258060 558.4 ns/op Benchmark____________RouteCompressOff-16 6332641 557.9 ns/op Benchmark____________RouteCompressOff-16 6218478 552.6 ns/op Benchmark____________RouteCompressOff-16 6375688 557.7 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6422952 555.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6319534 552.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6430783 558.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6211942 556.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6324076 554.7 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6205215 555.1 ns/op Benchmark_________RouteCompressS2Fast-16 6465004 548.3 ns/op Benchmark_________RouteCompressS2Fast-16 6230563 558.2 ns/op Benchmark_________RouteCompressS2Fast-16 6440917 562.4 ns/op Benchmark_________RouteCompressS2Fast-16 6363255 556.9 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6363681 557.6 ns/op Benchmark_______RouteCompressS2Better-16 6299443 556.1 ns/op Benchmark_______RouteCompressS2Better-16 6371425 554.9 ns/op Benchmark_______RouteCompressS2Better-16 6391354 559.0 ns/op Benchmark_______RouteCompressS2Better-16 6640161 560.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6506106 557.2 ns/op Benchmark_________RouteCompressS2Best-16 6340882 547.3 ns/op Benchmark_________RouteCompressS2Best-16 6465670 555.8 ns/op Benchmark_________RouteCompressS2Best-16 6291564 558.6 ns/op Benchmark_________RouteCompressS2Best-16 6511292 554.6 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4674061 769.0 ns/op 323.81 MB/s Benchmark______FanOut_8x1x10-16 4653771 767.7 ns/op 324.35 MB/s Benchmark______FanOut_8x1x10-16 4675677 767.8 ns/op 324.30 MB/s Benchmark______FanOut_8x1x10-16 4657051 772.3 ns/op 322.40 MB/s Benchmark______FanOut_8x1x10-16 4663032 770.9 ns/op 322.99 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 556632 6049 ns/op 383.37 MB/s Benchmark_____FanOut_8x1x100-16 551803 6059 ns/op 382.74 MB/s Benchmark_____FanOut_8x1x100-16 560043 6069 ns/op 382.09 MB/s Benchmark_____FanOut_8x1x100-16 554365 6102 ns/op 380.06 MB/s Benchmark_____FanOut_8x1x100-16 557601 6054 ns/op 383.06 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48187 74720 ns/op 308.07 MB/s Benchmark____FanOut_8x10x100-16 48532 74118 ns/op 310.57 MB/s Benchmark____FanOut_8x10x100-16 48372 75349 ns/op 305.50 MB/s Benchmark____FanOut_8x10x100-16 48312 74209 ns/op 310.19 MB/s Benchmark____FanOut_8x10x100-16 47611 74001 ns/op 311.06 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6031 599265 ns/op 400.52 MB/s Benchmark___FanOut_8x10x1000-16 5972 600171 ns/op 399.92 MB/s Benchmark___FanOut_8x10x1000-16 5906 604124 ns/op 397.30 MB/s Benchmark___FanOut_8x10x1000-16 5676 593396 ns/op 404.48 MB/s Benchmark___FanOut_8x10x1000-16 5368 594187 ns/op 403.94 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5040 712033 ns/op 323.05 MB/s Benchmark___FanOut_8x100x100-16 5076 727621 ns/op 316.12 MB/s Benchmark___FanOut_8x100x100-16 4938 706548 ns/op 325.55 MB/s Benchmark___FanOut_8x100x100-16 4952 707366 ns/op 325.18 MB/s Benchmark___FanOut_8x100x100-16 5025 705839 ns/op 325.88 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 573 6122906 ns/op 391.97 MB/s Benchmark__FanOut_8x100x1000-16 568 6114482 ns/op 392.51 MB/s Benchmark__FanOut_8x100x1000-16 584 6118959 ns/op 392.23 MB/s Benchmark__FanOut_8x100x1000-16 582 6102998 ns/op 393.25 MB/s Benchmark__FanOut_8x100x1000-16 579 6101659 ns/op 393.34 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 541 6810318 ns/op 367.09 MB/s Benchmark__FanOut_8x10x10000-16 518 6684927 ns/op 373.98 MB/s Benchmark__FanOut_8x10x10000-16 532 6735672 ns/op 371.16 MB/s Benchmark__FanOut_8x10x10000-16 531 6644146 ns/op 376.27 MB/s Benchmark__FanOut_8x10x10000-16 537 6723936 ns/op 371.81 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 938 3774086 ns/op 304.71 MB/s Benchmark___FanOut_8x500x100-16 940 3749896 ns/op 306.68 MB/s Benchmark___FanOut_8x500x100-16 950 3771111 ns/op 304.95 MB/s Benchmark___FanOut_8x500x100-16 946 3767264 ns/op 305.27 MB/s Benchmark___FanOut_8x500x100-16 952 3771830 ns/op 304.90 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 355324 9603 ns/op 1524.59 MB/s Benchmark___FanOut_128x1x100-16 369158 9505 ns/op 1540.29 MB/s Benchmark___FanOut_128x1x100-16 364131 9479 ns/op 1544.57 MB/s Benchmark___FanOut_128x1x100-16 361131 9571 ns/op 1529.79 MB/s Benchmark___FanOut_128x1x100-16 354216 9493 ns/op 1542.23 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32168 111573 ns/op 1300.86 MB/s Benchmark__FanOut_128x10x100-16 32484 111313 ns/op 1303.90 MB/s Benchmark__FanOut_128x10x100-16 32754 110799 ns/op 1309.95 MB/s Benchmark__FanOut_128x10x100-16 32911 109845 ns/op 1321.33 MB/s Benchmark__FanOut_128x10x100-16 32426 111226 ns/op 1304.92 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4117 874319 ns/op 1670.03 MB/s Benchmark_FanOut_128x10x1000-16 3958 883925 ns/op 1651.88 MB/s Benchmark_FanOut_128x10x1000-16 4092 878822 ns/op 1661.48 MB/s Benchmark_FanOut_128x10x1000-16 3860 877750 ns/op 1663.50 MB/s Benchmark_FanOut_128x10x1000-16 3828 874011 ns/op 1670.62 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3488 1012575 ns/op 1432.13 MB/s Benchmark_FanOut_128x100x100-16 3499 1010623 ns/op 1434.90 MB/s Benchmark_FanOut_128x100x100-16 3508 1019044 ns/op 1423.04 MB/s Benchmark_FanOut_128x100x100-16 3474 1009808 ns/op 1436.06 MB/s Benchmark_FanOut_128x100x100-16 3507 1008766 ns/op 1437.54 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 393 9371189 ns/op 1557.98 MB/s BenchmarkFanOut_128x100x1000-16 385 9237616 ns/op 1580.51 MB/s BenchmarkFanOut_128x100x1000-16 390 9224775 ns/op 1582.71 MB/s BenchmarkFanOut_128x100x1000-16 374 9352742 ns/op 1561.05 MB/s BenchmarkFanOut_128x100x1000-16 390 9293396 ns/op 1571.02 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 373 9841743 ns/op 1493.65 MB/s BenchmarkFanOut_128x10x10000-16 374 9548876 ns/op 1539.46 MB/s BenchmarkFanOut_128x10x10000-16 372 9630136 ns/op 1526.47 MB/s BenchmarkFanOut_128x10x10000-16 368 9671421 ns/op 1519.96 MB/s BenchmarkFanOut_128x10x10000-16 370 9610650 ns/op 1529.57 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 675 5269166 ns/op 1375.96 MB/s BenchmarkFanOut__128x500x100-16 664 5280684 ns/op 1372.95 MB/s BenchmarkFanOut__128x500x100-16 675 5296495 ns/op 1368.86 MB/s BenchmarkFanOut__128x500x100-16 676 5297502 ns/op 1368.60 MB/s BenchmarkFanOut__128x500x100-16 663 5282910 ns/op 1372.38 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1946 1845655 ns/op 2866.47 MB/s Benchmark_FanOut_512x100x100-16 1902 1846930 ns/op 2864.50 MB/s Benchmark_FanOut_512x100x100-16 1950 1848260 ns/op 2862.44 MB/s Benchmark_FanOut_512x100x100-16 1972 1844643 ns/op 2868.05 MB/s Benchmark_FanOut_512x100x100-16 1951 1843228 ns/op 2870.25 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 216 16657322 ns/op 3181.82 MB/s Benchmark__FanOut_512x100x1k-16 213 16794610 ns/op 3155.81 MB/s Benchmark__FanOut_512x100x1k-16 212 16591131 ns/op 3194.51 MB/s Benchmark__FanOut_512x100x1k-16 213 16629084 ns/op 3187.22 MB/s Benchmark__FanOut_512x100x1k-16 214 16795125 ns/op 3155.71 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2665 1142091 ns/op 9133.28 MB/s Benchmark____FanOut_1kx10x1k-16 3213 1196046 ns/op 8721.27 MB/s Benchmark____FanOut_1kx10x1k-16 3081 1146467 ns/op 9098.42 MB/s Benchmark____FanOut_1kx10x1k-16 3008 1126954 ns/op 9255.95 MB/s Benchmark____FanOut_1kx10x1k-16 3240 1149162 ns/op 9077.08 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2772 1254972 ns/op 8303.80 MB/s Benchmark__FanOut_1kx100x100-16 2820 1257314 ns/op 8288.33 MB/s Benchmark__FanOut_1kx100x100-16 2731 1254965 ns/op 8303.85 MB/s Benchmark__FanOut_1kx100x100-16 2800 1252358 ns/op 8321.13 MB/s Benchmark__FanOut_1kx100x100-16 2835 1250235 ns/op 8335.27 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4507053 775.4 ns/op 321.13 MB/s Benchmark_____RFanOut_8x1x10-16 4499556 769.9 ns/op 323.43 MB/s Benchmark_____RFanOut_8x1x10-16 4534642 783.5 ns/op 317.79 MB/s Benchmark_____RFanOut_8x1x10-16 4432486 792.2 ns/op 314.33 MB/s Benchmark_____RFanOut_8x1x10-16 4529098 766.0 ns/op 325.06 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 566881 6019 ns/op 385.28 MB/s Benchmark____RFanOut_8x1x100-16 519363 6166 ns/op 376.11 MB/s Benchmark____RFanOut_8x1x100-16 539402 6018 ns/op 385.33 MB/s Benchmark____RFanOut_8x1x100-16 553425 6119 ns/op 378.98 MB/s Benchmark____RFanOut_8x1x100-16 542872 6143 ns/op 377.52 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48728 73889 ns/op 311.54 MB/s Benchmark___RFanOut_8x10x100-16 48652 73704 ns/op 312.32 MB/s Benchmark___RFanOut_8x10x100-16 48764 73817 ns/op 311.84 MB/s Benchmark___RFanOut_8x10x100-16 48693 73729 ns/op 312.21 MB/s Benchmark___RFanOut_8x10x100-16 48325 74125 ns/op 310.54 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5913 588532 ns/op 407.83 MB/s Benchmark__RFanOut_8x10x1000-16 6204 587268 ns/op 408.70 MB/s Benchmark__RFanOut_8x10x1000-16 6160 591930 ns/op 405.49 MB/s Benchmark__RFanOut_8x10x1000-16 6004 585595 ns/op 409.87 MB/s Benchmark__RFanOut_8x10x1000-16 6019 590596 ns/op 406.40 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5038 697839 ns/op 329.62 MB/s Benchmark__RFanOut_8x100x100-16 5029 699327 ns/op 328.91 MB/s Benchmark__RFanOut_8x100x100-16 5072 698446 ns/op 329.33 MB/s Benchmark__RFanOut_8x100x100-16 5085 699843 ns/op 328.67 MB/s Benchmark__RFanOut_8x100x100-16 5001 704314 ns/op 326.59 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 589 6048614 ns/op 396.79 MB/s Benchmark_RFanOut_8x100x1000-16 597 6011767 ns/op 399.22 MB/s Benchmark_RFanOut_8x100x1000-16 579 5995090 ns/op 400.33 MB/s Benchmark_RFanOut_8x100x1000-16 598 6062078 ns/op 395.91 MB/s Benchmark_RFanOut_8x100x1000-16 584 6040691 ns/op 397.31 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 535 6532086 ns/op 382.73 MB/s Benchmark_RFanOut_8x10x10000-16 536 6591682 ns/op 379.27 MB/s Benchmark_RFanOut_8x10x10000-16 532 6536456 ns/op 382.47 MB/s Benchmark_RFanOut_8x10x10000-16 552 6590086 ns/op 379.36 MB/s Benchmark_RFanOut_8x10x10000-16 553 6657947 ns/op 375.49 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3177 1118012 ns/op 9329.99 MB/s Benchmark_RFanOut_1kx10x1000-16 3019 1137512 ns/op 9170.04 MB/s Benchmark_RFanOut_1kx10x1000-16 2991 1150118 ns/op 9069.53 MB/s Benchmark_RFanOut_1kx10x1000-16 3273 1147579 ns/op 9089.61 MB/s Benchmark_RFanOut_1kx10x1000-16 3141 1155264 ns/op 9029.14 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7076749 504.9 ns/op 4115.42 MB/s Benchmark_____FanIn_1kx100x1-16 7075849 503.8 ns/op 4125.06 MB/s Benchmark_____FanIn_1kx100x1-16 6992358 503.3 ns/op 4128.43 MB/s Benchmark_____FanIn_1kx100x1-16 6981072 505.1 ns/op 4114.35 MB/s Benchmark_____FanIn_1kx100x1-16 6958390 504.0 ns/op 4123.31 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2683640 1355 ns/op 6069.58 MB/s Benchmark_____FanIn_4kx100x1-16 2666386 1352 ns/op 6081.32 MB/s Benchmark_____FanIn_4kx100x1-16 2635507 1378 ns/op 5966.03 MB/s Benchmark_____FanIn_4kx100x1-16 2591808 1357 ns/op 6059.50 MB/s Benchmark_____FanIn_4kx100x1-16 2667802 1357 ns/op 6060.30 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1695939 2100 ns/op 7815.11 MB/s Benchmark_____FanIn_8kx100x1-16 1700318 2099 ns/op 7818.25 MB/s Benchmark_____FanIn_8kx100x1-16 1695622 2073 ns/op 7916.47 MB/s Benchmark_____FanIn_8kx100x1-16 1697089 2120 ns/op 7742.57 MB/s Benchmark_____FanIn_8kx100x1-16 1693796 2135 ns/op 7686.69 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 875923 4135 ns/op 7932.04 MB/s Benchmark____FanIn_16kx100x1-16 870883 4159 ns/op 7885.97 MB/s Benchmark____FanIn_16kx100x1-16 864094 4187 ns/op 7833.47 MB/s Benchmark____FanIn_16kx100x1-16 867848 4172 ns/op 7862.61 MB/s Benchmark____FanIn_16kx100x1-16 878680 4130 ns/op 7942.80 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 167632 19971 ns/op 6564.80 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1311518871 vs 10776913200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60884->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1041309405 vs 11268560700 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35388->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35366->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34864->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 159686 20063 ns/op 6534.73 MB/s Benchmark____FanIn_64kx100x1-16 171360 19859 ns/op 6601.73 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 432597000 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46812->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46868->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46606->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:46996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46430->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: 333492960 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:48666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48130->127.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: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:48708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48072->127.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:48498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48526->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: 668952270 vs 11627683000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51162->127.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:50986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50766->127.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:50882->127.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: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: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:51332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50852->127.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:50930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50674->127.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 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:50980->127.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:50994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50728->127.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:51462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51236->127.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:51380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50704->127.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:51110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51428->127.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:50732->127.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:50886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51068->127.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:50800->127.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: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:51084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51296->127.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:51148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51250->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: 600785470 vs 11522811000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54092->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54024->127.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:53506->127.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:53440->127.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:53968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53494->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53988->127.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:53394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53830->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:53444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53630->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: 236224180 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55198->127.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:55924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55964->127.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:55628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55720->127.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:55696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:55552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55494->127.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: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:55988->127.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: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:55572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55910->127.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:55414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55458->127.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:55232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55704->127.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:55250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55688->127.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:55626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55894->127.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:55772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:55208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55654->127.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:55754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55462->127.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:55850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55228->127.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:55614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55646->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5581346 641.4 ns/op 442.81 MB/s Benchmark___BumpPubCount_1x3-16 5581466 647.3 ns/op 438.77 MB/s Benchmark___BumpPubCount_1x3-16 5553949 639.0 ns/op 444.46 MB/s Benchmark___BumpPubCount_1x3-16 5617213 642.5 ns/op 442.00 MB/s Benchmark___BumpPubCount_1x3-16 5583364 644.4 ns/op 440.74 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5328825 670.6 ns/op 423.51 MB/s Benchmark___BumpPubCount_2x3-16 5302340 670.1 ns/op 423.82 MB/s Benchmark___BumpPubCount_2x3-16 5245449 669.8 ns/op 424.01 MB/s Benchmark___BumpPubCount_2x3-16 5286628 673.2 ns/op 421.88 MB/s Benchmark___BumpPubCount_2x3-16 5311147 679.4 ns/op 418.02 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5475742 647.8 ns/op 438.41 MB/s Benchmark___BumpPubCount_5x3-16 5576724 649.3 ns/op 437.43 MB/s Benchmark___BumpPubCount_5x3-16 5211092 649.9 ns/op 437.01 MB/s Benchmark___BumpPubCount_5x3-16 5540376 645.3 ns/op 440.14 MB/s Benchmark___BumpPubCount_5x3-16 5552011 647.8 ns/op 438.40 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5570209 644.3 ns/op 440.79 MB/s Benchmark__BumpPubCount_10x3-16 4754607 645.5 ns/op 439.97 MB/s Benchmark__BumpPubCount_10x3-16 5574129 646.5 ns/op 439.30 MB/s Benchmark__BumpPubCount_10x3-16 5554722 643.2 ns/op 441.51 MB/s Benchmark__BumpPubCount_10x3-16 5557599 652.7 ns/op 435.12 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12313868 270.6 ns/op 3842.91 MB/s Benchmark____GWs_Opt_1kx01x0-16 12661807 275.9 ns/op 3769.88 MB/s Benchmark____GWs_Opt_1kx01x0-16 12698432 273.2 ns/op 3807.00 MB/s Benchmark____GWs_Opt_1kx01x0-16 12532938 276.5 ns/op 3761.91 MB/s Benchmark____GWs_Opt_1kx01x0-16 11330096 286.7 ns/op 3627.67 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10835754 374.1 ns/op 5516.61 MB/s Benchmark____GWs_Opt_2kx01x0-16 10839067 340.4 ns/op 6062.61 MB/s Benchmark____GWs_Opt_2kx01x0-16 10238834 324.4 ns/op 6363.14 MB/s Benchmark____GWs_Opt_2kx01x0-16 10175728 344.0 ns/op 5999.62 MB/s Benchmark____GWs_Opt_2kx01x0-16 10357302 358.8 ns/op 5752.29 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5921934 611.9 ns/op 6719.69 MB/s Benchmark____GWs_Opt_4kx01x0-16 5702884 621.4 ns/op 6617.24 MB/s Benchmark____GWs_Opt_4kx01x0-16 5622482 632.3 ns/op 6503.29 MB/s Benchmark____GWs_Opt_4kx01x0-16 5956876 628.9 ns/op 6538.88 MB/s Benchmark____GWs_Opt_4kx01x0-16 5865081 626.3 ns/op 6565.46 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30242284 117.6 ns/op 8841.79 MB/s Benchmark____GWs_Opt_1kx10x0-16 29684924 110.2 ns/op 9434.06 MB/s Benchmark____GWs_Opt_1kx10x0-16 31099596 116.2 ns/op 8949.36 MB/s Benchmark____GWs_Opt_1kx10x0-16 29356628 112.0 ns/op 9282.45 MB/s Benchmark____GWs_Opt_1kx10x0-16 30083281 117.2 ns/op 8874.62 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23993775 146.3 ns/op 14109.73 MB/s Benchmark____GWs_Opt_2kx10x0-16 21048080 146.4 ns/op 14099.25 MB/s Benchmark____GWs_Opt_2kx10x0-16 23568474 166.1 ns/op 12426.65 MB/s Benchmark____GWs_Opt_2kx10x0-16 24213151 189.4 ns/op 10895.47 MB/s Benchmark____GWs_Opt_2kx10x0-16 25883899 140.1 ns/op 14729.71 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11226224 299.3 ns/op 13738.85 MB/s Benchmark____GWs_Opt_4kx10x0-16 12752310 311.6 ns/op 13197.58 MB/s Benchmark____GWs_Opt_4kx10x0-16 12560814 306.4 ns/op 13419.55 MB/s Benchmark____GWs_Opt_4kx10x0-16 12493634 287.0 ns/op 14329.06 MB/s Benchmark____GWs_Opt_4kx10x0-16 12617932 333.2 ns/op 12341.46 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6617871 546.3 ns/op 5720.32 MB/s Benchmark____GWs_Opt_1kx01x1-16 6547228 548.7 ns/op 5695.22 MB/s Benchmark____GWs_Opt_1kx01x1-16 6311360 555.4 ns/op 5626.32 MB/s Benchmark____GWs_Opt_1kx01x1-16 6490105 565.1 ns/op 5529.84 MB/s Benchmark____GWs_Opt_1kx01x1-16 6361426 554.4 ns/op 5637.00 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4567914 762.2 ns/op 8129.95 MB/s Benchmark____GWs_Opt_2kx01x1-16 4724860 759.4 ns/op 8160.39 MB/s Benchmark____GWs_Opt_2kx01x1-16 4681358 766.7 ns/op 8083.09 MB/s Benchmark____GWs_Opt_2kx01x1-16 4731698 896.5 ns/op 6912.70 MB/s Benchmark____GWs_Opt_2kx01x1-16 4564558 840.7 ns/op 7371.51 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2612388 1366 ns/op 9034.59 MB/s Benchmark____GWs_Opt_4kx01x1-16 2231817 1372 ns/op 8994.69 MB/s Benchmark____GWs_Opt_4kx01x1-16 2638329 1519 ns/op 8121.79 MB/s Benchmark____GWs_Opt_4kx01x1-16 2547918 1386 ns/op 8904.80 MB/s Benchmark____GWs_Opt_4kx01x1-16 2571114 1363 ns/op 9056.25 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6481002 559.8 ns/op 5582.58 MB/s Benchmark____GWs_Opt_1kx10x1-16 6584512 557.0 ns/op 5610.56 MB/s Benchmark____GWs_Opt_1kx10x1-16 5926312 544.8 ns/op 5735.90 MB/s Benchmark____GWs_Opt_1kx10x1-16 6616834 563.2 ns/op 5549.12 MB/s Benchmark____GWs_Opt_1kx10x1-16 6421852 564.1 ns/op 5539.80 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4177048 852.9 ns/op 7265.81 MB/s Benchmark____GWs_Opt_2kx10x1-16 4013169 858.9 ns/op 7215.21 MB/s Benchmark____GWs_Opt_2kx10x1-16 4643718 865.4 ns/op 7160.60 MB/s Benchmark____GWs_Opt_2kx10x1-16 4129378 789.8 ns/op 7845.99 MB/s Benchmark____GWs_Opt_2kx10x1-16 4725466 853.5 ns/op 7260.33 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2342792 1509 ns/op 8179.54 MB/s Benchmark____GWs_Opt_4kx10x1-16 2447023 1518 ns/op 8130.82 MB/s Benchmark____GWs_Opt_4kx10x1-16 2333085 1542 ns/op 8005.41 MB/s Benchmark____GWs_Opt_4kx10x1-16 2273131 1540 ns/op 8013.46 MB/s Benchmark____GWs_Opt_4kx10x1-16 2349409 1699 ns/op 7265.62 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12550440 301.3 ns/op 3452.02 MB/s Benchmark____GWs_Int_1kx01x0-16 12418257 289.9 ns/op 3587.90 MB/s Benchmark____GWs_Int_1kx01x0-16 12770926 287.4 ns/op 3618.08 MB/s Benchmark____GWs_Int_1kx01x0-16 12472665 283.5 ns/op 3667.79 MB/s Benchmark____GWs_Int_1kx01x0-16 11369488 296.0 ns/op 3513.36 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9989481 370.9 ns/op 5565.30 MB/s Benchmark____GWs_Int_2kx01x0-16 9601615 353.6 ns/op 5837.83 MB/s Benchmark____GWs_Int_2kx01x0-16 9396727 359.4 ns/op 5742.89 MB/s Benchmark____GWs_Int_2kx01x0-16 10450351 357.4 ns/op 5775.44 MB/s Benchmark____GWs_Int_2kx01x0-16 9406528 375.1 ns/op 5502.27 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5831480 613.7 ns/op 6699.82 MB/s Benchmark____GWs_Int_4kx01x0-16 5510905 818.1 ns/op 5026.00 MB/s Benchmark____GWs_Int_4kx01x0-16 5806756 639.9 ns/op 6426.28 MB/s Benchmark____GWs_Int_4kx01x0-16 5351380 620.9 ns/op 6622.35 MB/s Benchmark____GWs_Int_4kx01x0-16 5537289 629.8 ns/op 6528.56 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31654345 115.7 ns/op 8989.43 MB/s Benchmark____GWs_Int_1kx10x0-16 29042100 111.9 ns/op 9294.89 MB/s Benchmark____GWs_Int_1kx10x0-16 30816376 113.1 ns/op 9196.32 MB/s Benchmark____GWs_Int_1kx10x0-16 31646365 112.3 ns/op 9263.15 MB/s Benchmark____GWs_Int_1kx10x0-16 30588362 112.1 ns/op 9274.46 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25753659 142.1 ns/op 14530.06 MB/s Benchmark____GWs_Int_2kx10x0-16 23936917 148.0 ns/op 13946.97 MB/s Benchmark____GWs_Int_2kx10x0-16 25198276 148.8 ns/op 13871.77 MB/s Benchmark____GWs_Int_2kx10x0-16 24616591 138.9 ns/op 14859.59 MB/s Benchmark____GWs_Int_2kx10x0-16 24953916 141.0 ns/op 14638.66 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11441284 289.7 ns/op 14192.24 MB/s Benchmark____GWs_Int_4kx10x0-16 12421309 330.4 ns/op 12445.55 MB/s Benchmark____GWs_Int_4kx10x0-16 13230132 303.1 ns/op 13567.13 MB/s Benchmark____GWs_Int_4kx10x0-16 13337910 295.1 ns/op 13936.60 MB/s Benchmark____GWs_Int_4kx10x0-16 13157223 300.3 ns/op 13691.79 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6462603 560.2 ns/op 5578.51 MB/s Benchmark____GWs_Int_1kx01x1-16 6322047 556.2 ns/op 5618.84 MB/s Benchmark____GWs_Int_1kx01x1-16 6526143 560.9 ns/op 5571.13 MB/s Benchmark____GWs_Int_1kx01x1-16 6719984 557.6 ns/op 5604.13 MB/s Benchmark____GWs_Int_1kx01x1-16 6314174 565.4 ns/op 5527.46 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4624590 855.1 ns/op 7247.08 MB/s Benchmark____GWs_Int_2kx01x1-16 4630246 854.1 ns/op 7255.44 MB/s Benchmark____GWs_Int_2kx01x1-16 4731834 775.3 ns/op 7993.19 MB/s Benchmark____GWs_Int_2kx01x1-16 4660152 771.9 ns/op 8028.51 MB/s Benchmark____GWs_Int_2kx01x1-16 4726647 766.9 ns/op 8080.13 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2664381 1389 ns/op 8882.44 MB/s Benchmark____GWs_Int_4kx01x1-16 2620096 1506 ns/op 8194.49 MB/s Benchmark____GWs_Int_4kx01x1-16 2542677 1508 ns/op 8183.12 MB/s Benchmark____GWs_Int_4kx01x1-16 2384306 1373 ns/op 8986.26 MB/s Benchmark____GWs_Int_4kx01x1-16 2603607 2308 ns/op 5346.18 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6562460 569.1 ns/op 5490.68 MB/s Benchmark____GWs_Int_1kx10x1-16 6554896 565.2 ns/op 5529.09 MB/s Benchmark____GWs_Int_1kx10x1-16 6283951 563.2 ns/op 5548.96 MB/s Benchmark____GWs_Int_1kx10x1-16 6055363 561.5 ns/op 5565.29 MB/s Benchmark____GWs_Int_1kx10x1-16 6194362 553.9 ns/op 5641.84 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4145761 855.8 ns/op 7241.15 MB/s Benchmark____GWs_Int_2kx10x1-16 4139970 847.3 ns/op 7313.46 MB/s Benchmark____GWs_Int_2kx10x1-16 4223394 854.0 ns/op 7256.41 MB/s Benchmark____GWs_Int_2kx10x1-16 4193683 831.6 ns/op 7451.97 MB/s Benchmark____GWs_Int_2kx10x1-16 4259869 844.9 ns/op 7334.79 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2231610 1563 ns/op 7897.73 MB/s Benchmark____GWs_Int_4kx10x1-16 2177859 1528 ns/op 8075.19 MB/s Benchmark____GWs_Int_4kx10x1-16 2363704 1537 ns/op 8029.56 MB/s Benchmark____GWs_Int_4kx10x1-16 2316426 1517 ns/op 8135.25 MB/s Benchmark____GWs_Int_4kx10x1-16 2230233 1564 ns/op 7891.49 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8011764 449.8 ns/op 226.75 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8493073 446.2 ns/op 228.61 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7850852 439.6 ns/op 232.01 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8071554 444.0 ns/op 229.74 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8293389 443.4 ns/op 230.06 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 721154 5144 ns/op 34.41 MB/s Benchmark__GWs_Reqs_1SubEach-16 716605 5260 ns/op 33.65 MB/s Benchmark__GWs_Reqs_1SubEach-16 725586 5217 ns/op 33.93 MB/s Benchmark__GWs_Reqs_1SubEach-16 755314 5299 ns/op 33.40 MB/s Benchmark__GWs_Reqs_1SubEach-16 758944 5393 ns/op 32.82 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2068.991s ❌ Non-zero exit code: 1