> ROOT_DIR=/tmp/go-bench-away-job-cc76377d-b630-4558-ad4a-c1c532b63aae-2973500644 > OUTPUT_FILE=/tmp/go-bench-away-job-cc76377d-b630-4558-ad4a-c1c532b63aae-2973500644/results.txt > SHA_FILE=/tmp/go-bench-away-job-cc76377d-b630-4558-ad4a-c1c532b63aae-2973500644/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-cc76377d-b630-4558-ad4a-c1c532b63aae-2973500644/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.25.4/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-cc76377d-b630-4558-ad4a-c1c532b63aae-2973500644/source.git SHA of main: 51fbade1ed5aa9cd026e6be57ad9b0c6272f6709 Go runtime: go version go1.26.0 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-build3962056576=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-cc76377d-b630-4558-ad4a-c1c532b63aae-2973500644/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.25.4' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.25.4/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.0' 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 53416674 67.49 ns/op 162.98 MB/s Benchmark______Pub0b_Payload-16 50038412 66.91 ns/op 164.41 MB/s Benchmark______Pub0b_Payload-16 50147485 67.81 ns/op 162.22 MB/s Benchmark______Pub0b_Payload-16 46614988 67.98 ns/op 161.82 MB/s Benchmark______Pub0b_Payload-16 50866160 67.70 ns/op 162.49 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 49674980 68.00 ns/op 279.40 MB/s Benchmark______Pub8b_Payload-16 52913451 69.09 ns/op 275.01 MB/s Benchmark______Pub8b_Payload-16 49246914 67.91 ns/op 279.79 MB/s Benchmark______Pub8b_Payload-16 49450076 67.94 ns/op 279.66 MB/s Benchmark______Pub8b_Payload-16 49604829 67.83 ns/op 280.13 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 47153505 72.45 ns/op 607.28 MB/s Benchmark_____Pub32b_Payload-16 46222093 72.40 ns/op 607.75 MB/s Benchmark_____Pub32b_Payload-16 49606009 73.28 ns/op 600.48 MB/s Benchmark_____Pub32b_Payload-16 44729388 72.50 ns/op 606.89 MB/s Benchmark_____Pub32b_Payload-16 46815044 72.62 ns/op 605.89 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 36791784 82.18 ns/op 1715.85 MB/s Benchmark____Pub128B_Payload-16 41896239 83.60 ns/op 1686.56 MB/s Benchmark____Pub128B_Payload-16 36570781 88.47 ns/op 1593.84 MB/s Benchmark____Pub128B_Payload-16 41635296 81.77 ns/op 1724.28 MB/s Benchmark____Pub128B_Payload-16 43986686 81.97 ns/op 1720.14 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 40544036 91.46 ns/op 2941.02 MB/s Benchmark____Pub256B_Payload-16 40224105 91.04 ns/op 2954.66 MB/s Benchmark____Pub256B_Payload-16 33388278 90.40 ns/op 2975.55 MB/s Benchmark____Pub256B_Payload-16 39816376 91.12 ns/op 2952.14 MB/s Benchmark____Pub256B_Payload-16 32873499 99.90 ns/op 2692.79 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 28068039 137.5 ns/op 7548.55 MB/s Benchmark______Pub1K_Payload-16 23385486 135.9 ns/op 7638.64 MB/s Benchmark______Pub1K_Payload-16 21816910 145.0 ns/op 7160.27 MB/s Benchmark______Pub1K_Payload-16 26895604 136.5 ns/op 7602.25 MB/s Benchmark______Pub1K_Payload-16 24148846 145.5 ns/op 7135.84 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5524466 620.0 ns/op 6629.50 MB/s Benchmark______Pub4K_Payload-16 5540895 622.1 ns/op 6606.76 MB/s Benchmark______Pub4K_Payload-16 5785875 629.1 ns/op 6532.96 MB/s Benchmark______Pub4K_Payload-16 5477775 615.8 ns/op 6674.16 MB/s Benchmark______Pub4K_Payload-16 5768911 630.9 ns/op 6514.79 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2814817 1285 ns/op 6386.26 MB/s Benchmark______Pub8K_Payload-16 2754459 1280 ns/op 6408.97 MB/s Benchmark______Pub8K_Payload-16 2779632 1288 ns/op 6372.85 MB/s Benchmark______Pub8K_Payload-16 2732665 1281 ns/op 6405.05 MB/s Benchmark______Pub8K_Payload-16 2811370 1274 ns/op 6440.42 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 660313 5343 ns/op 6135.19 MB/s Benchmark_____Pub32K_Payload-16 654619 5398 ns/op 6073.15 MB/s Benchmark_____Pub32K_Payload-16 669038 5505 ns/op 5955.61 MB/s Benchmark_____Pub32K_Payload-16 666308 5431 ns/op 6035.94 MB/s Benchmark_____Pub32K_Payload-16 670357 5664 ns/op 5787.71 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 41003336 87.59 ns/op 125.59 MB/s Benchmark__AuthPub0b_Payload-16 39012330 87.52 ns/op 125.68 MB/s Benchmark__AuthPub0b_Payload-16 38613632 87.83 ns/op 125.24 MB/s Benchmark__AuthPub0b_Payload-16 39007173 87.86 ns/op 125.20 MB/s Benchmark__AuthPub0b_Payload-16 35694283 88.11 ns/op 124.85 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 16728708 211.4 ns/op Benchmark_____________PubSub-16 16764212 212.6 ns/op Benchmark_____________PubSub-16 16761961 211.6 ns/op Benchmark_____________PubSub-16 16750746 211.8 ns/op Benchmark_____________PubSub-16 16738194 212.1 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 16852945 211.0 ns/op Benchmark_____PubSubTwoConns-16 16711002 211.2 ns/op Benchmark_____PubSubTwoConns-16 16866985 210.1 ns/op Benchmark_____PubSubTwoConns-16 16858940 211.0 ns/op Benchmark_____PubSubTwoConns-16 16866248 211.0 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50534->127.0.0.1:40685: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40170->127.0.0.1:38819: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:52490->127.0.0.1:39841: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43120->127.0.0.1:40101: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40338->127.0.0.1:33395: 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 15718242 227.6 ns/op Benchmark_____PubTwoQueueSub-16 15521498 226.9 ns/op Benchmark_____PubTwoQueueSub-16 15575792 228.7 ns/op Benchmark_____PubTwoQueueSub-16 15438915 227.9 ns/op Benchmark_____PubTwoQueueSub-16 15457315 227.9 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15451114 227.9 ns/op Benchmark____PubFourQueueSub-16 15601167 227.6 ns/op Benchmark____PubFourQueueSub-16 15584587 227.7 ns/op Benchmark____PubFourQueueSub-16 15542023 228.1 ns/op Benchmark____PubFourQueueSub-16 15450366 227.6 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15527043 227.9 ns/op Benchmark___PubEightQueueSub-16 15565195 227.9 ns/op Benchmark___PubEightQueueSub-16 15584665 228.6 ns/op Benchmark___PubEightQueueSub-16 15647216 226.2 ns/op Benchmark___PubEightQueueSub-16 15576434 228.5 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23292 156170 ns/op Benchmark_PubSub512kTwoConns-16 22914 151985 ns/op Benchmark_PubSub512kTwoConns-16 23200 152291 ns/op Benchmark_PubSub512kTwoConns-16 23288 151482 ns/op Benchmark_PubSub512kTwoConns-16 23644 154415 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16294298 213.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 16196113 214.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 16461609 213.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 16462239 213.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 16439784 214.2 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16331923 214.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 16265372 213.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 16305290 213.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 16331659 214.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 16291381 214.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11951521 297.7 ns/op Benchmark____RoutedPubSub_0b-16 12189349 295.7 ns/op Benchmark____RoutedPubSub_0b-16 11965514 299.7 ns/op Benchmark____RoutedPubSub_0b-16 11858847 286.8 ns/op Benchmark____RoutedPubSub_0b-16 11621706 282.5 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 7020256 481.2 ns/op Benchmark____RoutedPubSub_1K-16 6837660 513.8 ns/op Benchmark____RoutedPubSub_1K-16 6961959 518.4 ns/op Benchmark____RoutedPubSub_1K-16 6839000 552.5 ns/op Benchmark____RoutedPubSub_1K-16 6829368 511.9 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84340 42330 ns/op Benchmark__RoutedPubSub_100K-16 79982 43756 ns/op Benchmark__RoutedPubSub_100K-16 85456 44005 ns/op Benchmark__RoutedPubSub_100K-16 79137 45948 ns/op Benchmark__RoutedPubSub_100K-16 76210 45095 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11661708 301.0 ns/op Benchmark____Routed2QueueSub-16 11861870 299.9 ns/op Benchmark____Routed2QueueSub-16 10166799 305.5 ns/op Benchmark____Routed2QueueSub-16 11885200 309.5 ns/op Benchmark____Routed2QueueSub-16 9992820 305.9 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 11654401 306.0 ns/op Benchmark____Routed4QueueSub-16 11293890 305.9 ns/op Benchmark____Routed4QueueSub-16 9436698 318.0 ns/op Benchmark____Routed4QueueSub-16 9769804 314.3 ns/op Benchmark____Routed4QueueSub-16 9846145 305.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9454562 325.2 ns/op Benchmark____Routed8QueueSub-16 9747366 318.3 ns/op Benchmark____Routed8QueueSub-16 9456169 324.4 ns/op Benchmark____Routed8QueueSub-16 11474295 317.2 ns/op Benchmark____Routed8QueueSub-16 11418658 311.5 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 9074522 338.1 ns/op Benchmark___Routed16QueueSub-16 9114909 335.2 ns/op Benchmark___Routed16QueueSub-16 9335988 335.9 ns/op Benchmark___Routed16QueueSub-16 9437664 337.9 ns/op Benchmark___Routed16QueueSub-16 9260932 339.6 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6759903 529.1 ns/op Benchmark____________RouteCompressOff-16 6676468 526.9 ns/op Benchmark____________RouteCompressOff-16 6920941 449.0 ns/op Benchmark____________RouteCompressOff-16 6935382 518.5 ns/op Benchmark____________RouteCompressOff-16 6703582 528.7 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6786987 475.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6566286 533.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6634068 532.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6698668 504.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6646478 533.6 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6702998 469.5 ns/op Benchmark_________RouteCompressS2Fast-16 6819162 527.4 ns/op Benchmark_________RouteCompressS2Fast-16 6703485 521.1 ns/op Benchmark_________RouteCompressS2Fast-16 6815253 525.3 ns/op Benchmark_________RouteCompressS2Fast-16 6685957 463.5 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6786394 524.4 ns/op Benchmark_______RouteCompressS2Better-16 6817501 533.7 ns/op Benchmark_______RouteCompressS2Better-16 8177764 524.0 ns/op Benchmark_______RouteCompressS2Better-16 6797271 490.2 ns/op Benchmark_______RouteCompressS2Better-16 6740930 529.4 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6806641 521.4 ns/op Benchmark_________RouteCompressS2Best-16 6802819 527.0 ns/op Benchmark_________RouteCompressS2Best-16 6887017 526.0 ns/op Benchmark_________RouteCompressS2Best-16 6814916 462.4 ns/op Benchmark_________RouteCompressS2Best-16 6650757 486.5 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5170303 682.3 ns/op 364.96 MB/s Benchmark______FanOut_8x1x10-16 5189892 682.5 ns/op 364.82 MB/s Benchmark______FanOut_8x1x10-16 5255846 688.1 ns/op 361.85 MB/s Benchmark______FanOut_8x1x10-16 5291702 683.3 ns/op 364.41 MB/s Benchmark______FanOut_8x1x10-16 5207370 682.5 ns/op 364.82 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 620289 5287 ns/op 438.65 MB/s Benchmark_____FanOut_8x1x100-16 649945 5311 ns/op 436.65 MB/s Benchmark_____FanOut_8x1x100-16 636399 5287 ns/op 438.64 MB/s Benchmark_____FanOut_8x1x100-16 630849 5358 ns/op 432.83 MB/s Benchmark_____FanOut_8x1x100-16 605104 5321 ns/op 435.80 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 52868 68186 ns/op 337.59 MB/s Benchmark____FanOut_8x10x100-16 52406 68063 ns/op 338.20 MB/s Benchmark____FanOut_8x10x100-16 53016 68155 ns/op 337.75 MB/s Benchmark____FanOut_8x10x100-16 52652 68085 ns/op 338.09 MB/s Benchmark____FanOut_8x10x100-16 52826 67868 ns/op 339.17 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6786 536560 ns/op 447.33 MB/s Benchmark___FanOut_8x10x1000-16 6812 531451 ns/op 451.63 MB/s Benchmark___FanOut_8x10x1000-16 6382 537858 ns/op 446.25 MB/s Benchmark___FanOut_8x10x1000-16 6835 530575 ns/op 452.38 MB/s Benchmark___FanOut_8x10x1000-16 6717 532802 ns/op 450.48 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5595 630926 ns/op 364.57 MB/s Benchmark___FanOut_8x100x100-16 5551 631352 ns/op 364.33 MB/s Benchmark___FanOut_8x100x100-16 5428 634135 ns/op 362.73 MB/s Benchmark___FanOut_8x100x100-16 5558 629775 ns/op 365.24 MB/s Benchmark___FanOut_8x100x100-16 5583 634287 ns/op 362.64 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 637 5574471 ns/op 430.54 MB/s Benchmark__FanOut_8x100x1000-16 630 5530929 ns/op 433.93 MB/s Benchmark__FanOut_8x100x1000-16 652 5526126 ns/op 434.30 MB/s Benchmark__FanOut_8x100x1000-16 637 5550288 ns/op 432.41 MB/s Benchmark__FanOut_8x100x1000-16 638 5524573 ns/op 434.43 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 598 5804645 ns/op 430.69 MB/s Benchmark__FanOut_8x10x10000-16 598 5885670 ns/op 424.76 MB/s Benchmark__FanOut_8x10x10000-16 606 5951198 ns/op 420.09 MB/s Benchmark__FanOut_8x10x10000-16 603 5954846 ns/op 419.83 MB/s Benchmark__FanOut_8x10x10000-16 589 5826118 ns/op 429.11 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1044 3397889 ns/op 338.45 MB/s Benchmark___FanOut_8x500x100-16 1033 3441164 ns/op 334.19 MB/s Benchmark___FanOut_8x500x100-16 1021 3390728 ns/op 339.17 MB/s Benchmark___FanOut_8x500x100-16 1026 3415833 ns/op 336.67 MB/s Benchmark___FanOut_8x500x100-16 1044 3402635 ns/op 337.98 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 376856 8842 ns/op 1655.76 MB/s Benchmark___FanOut_128x1x100-16 378570 8880 ns/op 1648.76 MB/s Benchmark___FanOut_128x1x100-16 375703 8911 ns/op 1642.96 MB/s Benchmark___FanOut_128x1x100-16 389449 8933 ns/op 1638.99 MB/s Benchmark___FanOut_128x1x100-16 386857 8840 ns/op 1656.24 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 34686 103292 ns/op 1405.15 MB/s Benchmark__FanOut_128x10x100-16 34714 102799 ns/op 1411.88 MB/s Benchmark__FanOut_128x10x100-16 34828 103039 ns/op 1408.61 MB/s Benchmark__FanOut_128x10x100-16 34780 102857 ns/op 1411.10 MB/s Benchmark__FanOut_128x10x100-16 34951 102301 ns/op 1418.76 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4401 783819 ns/op 1862.85 MB/s Benchmark_FanOut_128x10x1000-16 4550 792932 ns/op 1841.45 MB/s Benchmark_FanOut_128x10x1000-16 4383 788122 ns/op 1852.68 MB/s Benchmark_FanOut_128x10x1000-16 4186 798293 ns/op 1829.08 MB/s Benchmark_FanOut_128x10x1000-16 4327 797891 ns/op 1830.00 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3826 945736 ns/op 1533.35 MB/s Benchmark_FanOut_128x100x100-16 3704 940660 ns/op 1541.62 MB/s Benchmark_FanOut_128x100x100-16 3789 940939 ns/op 1541.16 MB/s Benchmark_FanOut_128x100x100-16 3742 940777 ns/op 1541.43 MB/s Benchmark_FanOut_128x100x100-16 3702 939771 ns/op 1543.08 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 421 8469857 ns/op 1723.78 MB/s BenchmarkFanOut_128x100x1000-16 416 8462825 ns/op 1725.21 MB/s BenchmarkFanOut_128x100x1000-16 424 8531070 ns/op 1711.41 MB/s BenchmarkFanOut_128x100x1000-16 420 8409833 ns/op 1736.08 MB/s BenchmarkFanOut_128x100x1000-16 417 8457884 ns/op 1726.22 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 405 8869574 ns/op 1657.37 MB/s BenchmarkFanOut_128x10x10000-16 408 8906746 ns/op 1650.45 MB/s BenchmarkFanOut_128x10x10000-16 405 8850207 ns/op 1660.99 MB/s BenchmarkFanOut_128x10x10000-16 409 8802099 ns/op 1670.07 MB/s BenchmarkFanOut_128x10x10000-16 404 8835675 ns/op 1663.73 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 716 4958129 ns/op 1462.27 MB/s BenchmarkFanOut__128x500x100-16 714 4975681 ns/op 1457.12 MB/s BenchmarkFanOut__128x500x100-16 712 4931027 ns/op 1470.31 MB/s BenchmarkFanOut__128x500x100-16 718 4951284 ns/op 1464.30 MB/s BenchmarkFanOut__128x500x100-16 712 4976695 ns/op 1456.82 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 2004 1783024 ns/op 2967.16 MB/s Benchmark_FanOut_512x100x100-16 2024 1782427 ns/op 2968.16 MB/s Benchmark_FanOut_512x100x100-16 1998 1780331 ns/op 2971.65 MB/s Benchmark_FanOut_512x100x100-16 2004 1779968 ns/op 2972.26 MB/s Benchmark_FanOut_512x100x100-16 2005 1778580 ns/op 2974.58 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 222 16017353 ns/op 3308.94 MB/s Benchmark__FanOut_512x100x1k-16 225 15921506 ns/op 3328.86 MB/s Benchmark__FanOut_512x100x1k-16 225 16062751 ns/op 3299.59 MB/s Benchmark__FanOut_512x100x1k-16 225 15833744 ns/op 3347.31 MB/s Benchmark__FanOut_512x100x1k-16 222 16100898 ns/op 3291.77 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3175 1117522 ns/op 9334.08 MB/s Benchmark____FanOut_1kx10x1k-16 3166 1096941 ns/op 9509.21 MB/s Benchmark____FanOut_1kx10x1k-16 2937 1100909 ns/op 9474.93 MB/s Benchmark____FanOut_1kx10x1k-16 3234 1090119 ns/op 9568.71 MB/s Benchmark____FanOut_1kx10x1k-16 3315 1116373 ns/op 9343.69 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2906 1183059 ns/op 8808.56 MB/s Benchmark__FanOut_1kx100x100-16 2943 1200459 ns/op 8680.88 MB/s Benchmark__FanOut_1kx100x100-16 2899 1195559 ns/op 8716.46 MB/s Benchmark__FanOut_1kx100x100-16 2902 1202750 ns/op 8664.34 MB/s Benchmark__FanOut_1kx100x100-16 2955 1190547 ns/op 8753.15 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4982091 688.9 ns/op 361.46 MB/s Benchmark_____RFanOut_8x1x10-16 5048556 740.6 ns/op 336.20 MB/s Benchmark_____RFanOut_8x1x10-16 4989525 698.2 ns/op 356.61 MB/s Benchmark_____RFanOut_8x1x10-16 4938867 705.1 ns/op 353.15 MB/s Benchmark_____RFanOut_8x1x10-16 4974682 694.5 ns/op 358.54 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 608022 5287 ns/op 438.60 MB/s Benchmark____RFanOut_8x1x100-16 592068 5447 ns/op 425.75 MB/s Benchmark____RFanOut_8x1x100-16 649233 5251 ns/op 441.63 MB/s Benchmark____RFanOut_8x1x100-16 586182 5260 ns/op 440.89 MB/s Benchmark____RFanOut_8x1x100-16 617391 5246 ns/op 442.09 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 52125 69201 ns/op 332.64 MB/s Benchmark___RFanOut_8x10x100-16 52540 67995 ns/op 338.54 MB/s Benchmark___RFanOut_8x10x100-16 52012 67822 ns/op 339.40 MB/s Benchmark___RFanOut_8x10x100-16 52665 68009 ns/op 338.47 MB/s Benchmark___RFanOut_8x10x100-16 52302 67810 ns/op 339.46 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6556 545111 ns/op 440.31 MB/s Benchmark__RFanOut_8x10x1000-16 6774 538312 ns/op 445.87 MB/s Benchmark__RFanOut_8x10x1000-16 6254 539624 ns/op 444.79 MB/s Benchmark__RFanOut_8x10x1000-16 6337 541229 ns/op 443.47 MB/s Benchmark__RFanOut_8x10x1000-16 6708 549559 ns/op 436.75 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5592 641371 ns/op 358.64 MB/s Benchmark__RFanOut_8x100x100-16 5587 646118 ns/op 356.00 MB/s Benchmark__RFanOut_8x100x100-16 5404 638033 ns/op 360.51 MB/s Benchmark__RFanOut_8x100x100-16 5532 634116 ns/op 362.74 MB/s Benchmark__RFanOut_8x100x100-16 5451 636658 ns/op 361.29 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 648 5541039 ns/op 433.14 MB/s Benchmark_RFanOut_8x100x1000-16 633 5520032 ns/op 434.78 MB/s Benchmark_RFanOut_8x100x1000-16 651 5605420 ns/op 428.16 MB/s Benchmark_RFanOut_8x100x1000-16 630 5553885 ns/op 432.13 MB/s Benchmark_RFanOut_8x100x1000-16 649 5576901 ns/op 430.35 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 607 5908805 ns/op 423.10 MB/s Benchmark_RFanOut_8x10x10000-16 618 5918352 ns/op 422.42 MB/s Benchmark_RFanOut_8x10x10000-16 594 5885101 ns/op 424.80 MB/s Benchmark_RFanOut_8x10x10000-16 595 5943663 ns/op 420.62 MB/s Benchmark_RFanOut_8x10x10000-16 615 6002057 ns/op 416.53 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3392 1115660 ns/op 9349.65 MB/s Benchmark_RFanOut_1kx10x1000-16 3405 1083796 ns/op 9624.54 MB/s Benchmark_RFanOut_1kx10x1000-16 3296 1107900 ns/op 9415.14 MB/s Benchmark_RFanOut_1kx10x1000-16 3204 1096042 ns/op 9517.00 MB/s Benchmark_RFanOut_1kx10x1000-16 3271 1110644 ns/op 9391.88 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7228062 486.3 ns/op 4273.22 MB/s Benchmark_____FanIn_1kx100x1-16 7238508 487.5 ns/op 4262.17 MB/s Benchmark_____FanIn_1kx100x1-16 7113124 488.1 ns/op 4257.57 MB/s Benchmark_____FanIn_1kx100x1-16 7242408 486.5 ns/op 4271.53 MB/s Benchmark_____FanIn_1kx100x1-16 7176829 486.5 ns/op 4270.90 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2682735 1339 ns/op 6142.22 MB/s Benchmark_____FanIn_4kx100x1-16 2669590 1350 ns/op 6088.67 MB/s Benchmark_____FanIn_4kx100x1-16 2716531 1358 ns/op 6056.28 MB/s Benchmark_____FanIn_4kx100x1-16 2685028 1326 ns/op 6201.94 MB/s Benchmark_____FanIn_4kx100x1-16 2651682 1329 ns/op 6188.18 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1730204 2102 ns/op 7806.94 MB/s Benchmark_____FanIn_8kx100x1-16 1729124 2110 ns/op 7780.86 MB/s Benchmark_____FanIn_8kx100x1-16 1716964 2094 ns/op 7837.15 MB/s Benchmark_____FanIn_8kx100x1-16 1707025 2074 ns/op 7913.91 MB/s Benchmark_____FanIn_8kx100x1-16 1725723 2095 ns/op 7835.15 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 869042 4118 ns/op 7965.92 MB/s Benchmark____FanIn_16kx100x1-16 870388 4220 ns/op 7772.99 MB/s Benchmark____FanIn_16kx100x1-16 867025 4135 ns/op 7931.91 MB/s Benchmark____FanIn_16kx100x1-16 869019 4130 ns/op 7942.29 MB/s Benchmark____FanIn_16kx100x1-16 868696 4139 ns/op 7923.72 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 172401 19942 ns/op 6574.19 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7091720199 vs 11085012300 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57324->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 167562 19765 ns/op 6633.16 MB/s Benchmark____FanIn_64kx100x1-16 161570 19732 ns/op 6644.11 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7231610301 vs 11052235800 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53044->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52912->127.0.0.1:5222: write: connection reset by peer Benchmark___FanIn_128kx100x1 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53016->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: 914221660 vs 11522811000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54670->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54104->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54684->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: 398906870 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56610->127.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:56498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56792->127.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:56512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56128->127.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:56132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56796->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: 389992750 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57876->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58484->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:58084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58334->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: 1779153480 vs 8874793000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33040->127.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:60868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:60472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60770->127.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: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:60444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:60682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60950->127.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: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:33066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:60824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60894->127.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:32960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32916->127.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:60978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32796->127.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:60604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:60554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:33018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33096->127.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:33080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60648->127.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: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:32844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60888->127.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:32856->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: 705002020 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34472->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34636->127.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:34328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:34220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34086->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34290->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5979325 595.5 ns/op 476.90 MB/s Benchmark___BumpPubCount_1x3-16 5987552 595.6 ns/op 476.80 MB/s Benchmark___BumpPubCount_1x3-16 5976738 595.2 ns/op 477.18 MB/s Benchmark___BumpPubCount_1x3-16 5972376 596.6 ns/op 476.03 MB/s Benchmark___BumpPubCount_1x3-16 5985516 594.2 ns/op 477.98 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5647489 632.7 ns/op 448.89 MB/s Benchmark___BumpPubCount_2x3-16 5659834 630.6 ns/op 450.36 MB/s Benchmark___BumpPubCount_2x3-16 5648042 632.1 ns/op 449.29 MB/s Benchmark___BumpPubCount_2x3-16 5690191 633.7 ns/op 448.18 MB/s Benchmark___BumpPubCount_2x3-16 5627096 633.5 ns/op 448.28 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5827963 612.0 ns/op 464.07 MB/s Benchmark___BumpPubCount_5x3-16 5840358 612.3 ns/op 463.83 MB/s Benchmark___BumpPubCount_5x3-16 5857998 613.2 ns/op 463.14 MB/s Benchmark___BumpPubCount_5x3-16 5870257 611.0 ns/op 464.81 MB/s Benchmark___BumpPubCount_5x3-16 5783342 611.5 ns/op 464.43 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5875792 607.5 ns/op 467.53 MB/s Benchmark__BumpPubCount_10x3-16 5922636 614.6 ns/op 462.07 MB/s Benchmark__BumpPubCount_10x3-16 5842920 610.0 ns/op 465.60 MB/s Benchmark__BumpPubCount_10x3-16 5966539 605.9 ns/op 468.74 MB/s Benchmark__BumpPubCount_10x3-16 5888385 605.8 ns/op 468.79 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11877379 279.3 ns/op 3724.01 MB/s Benchmark____GWs_Opt_1kx01x0-16 12359517 279.0 ns/op 3727.78 MB/s Benchmark____GWs_Opt_1kx01x0-16 12823959 285.5 ns/op 3642.72 MB/s Benchmark____GWs_Opt_1kx01x0-16 12459504 285.7 ns/op 3640.45 MB/s Benchmark____GWs_Opt_1kx01x0-16 11247632 279.8 ns/op 3716.42 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10530868 346.5 ns/op 5956.98 MB/s Benchmark____GWs_Opt_2kx01x0-16 10941589 336.2 ns/op 6139.20 MB/s Benchmark____GWs_Opt_2kx01x0-16 10339827 365.4 ns/op 5648.20 MB/s Benchmark____GWs_Opt_2kx01x0-16 10387760 343.6 ns/op 6006.29 MB/s Benchmark____GWs_Opt_2kx01x0-16 10266506 330.7 ns/op 6242.02 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5805240 726.1 ns/op 5662.99 MB/s Benchmark____GWs_Opt_4kx01x0-16 5723599 608.1 ns/op 6762.52 MB/s Benchmark____GWs_Opt_4kx01x0-16 5823519 605.3 ns/op 6793.51 MB/s Benchmark____GWs_Opt_4kx01x0-16 5597512 609.6 ns/op 6745.54 MB/s Benchmark____GWs_Opt_4kx01x0-16 5864769 616.6 ns/op 6669.35 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 31102893 112.5 ns/op 9241.86 MB/s Benchmark____GWs_Opt_1kx10x0-16 28802203 110.6 ns/op 9405.67 MB/s Benchmark____GWs_Opt_1kx10x0-16 30684260 123.7 ns/op 8404.13 MB/s Benchmark____GWs_Opt_1kx10x0-16 30523584 108.2 ns/op 9614.10 MB/s Benchmark____GWs_Opt_1kx10x0-16 32003997 118.4 ns/op 8784.26 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23195017 157.6 ns/op 13100.36 MB/s Benchmark____GWs_Opt_2kx10x0-16 25347681 162.4 ns/op 12710.18 MB/s Benchmark____GWs_Opt_2kx10x0-16 21776224 150.7 ns/op 13696.62 MB/s Benchmark____GWs_Opt_2kx10x0-16 26445050 145.9 ns/op 14149.39 MB/s Benchmark____GWs_Opt_2kx10x0-16 23207788 171.8 ns/op 12013.92 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 10292564 297.0 ns/op 13845.15 MB/s Benchmark____GWs_Opt_4kx10x0-16 12384937 285.2 ns/op 14419.78 MB/s Benchmark____GWs_Opt_4kx10x0-16 10719246 291.6 ns/op 14099.60 MB/s Benchmark____GWs_Opt_4kx10x0-16 10149300 325.0 ns/op 12653.18 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:41070->127.0.0.1:41329: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:56490->127.0.0.1:44867: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6517933 547.1 ns/op 5712.09 MB/s Benchmark____GWs_Opt_1kx01x1-16 6721346 538.7 ns/op 5800.53 MB/s Benchmark____GWs_Opt_1kx01x1-16 6568719 543.1 ns/op 5754.43 MB/s Benchmark____GWs_Opt_1kx01x1-16 6393428 545.2 ns/op 5732.08 MB/s Benchmark____GWs_Opt_1kx01x1-16 6617812 552.0 ns/op 5660.94 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4767248 749.6 ns/op 8266.91 MB/s Benchmark____GWs_Opt_2kx01x1-16 4711687 752.4 ns/op 8235.97 MB/s Benchmark____GWs_Opt_2kx01x1-16 4783287 737.6 ns/op 8401.90 MB/s Benchmark____GWs_Opt_2kx01x1-16 4779688 740.8 ns/op 8365.72 MB/s Benchmark____GWs_Opt_2kx01x1-16 4803044 756.7 ns/op 8189.38 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2585366 1353 ns/op 9121.55 MB/s Benchmark____GWs_Opt_4kx01x1-16 2332832 1431 ns/op 8623.14 MB/s Benchmark____GWs_Opt_4kx01x1-16 2662683 1354 ns/op 9117.59 MB/s Benchmark____GWs_Opt_4kx01x1-16 2701399 1339 ns/op 9215.14 MB/s Benchmark____GWs_Opt_4kx01x1-16 2686324 1348 ns/op 9155.14 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6868974 565.9 ns/op 5522.31 MB/s Benchmark____GWs_Opt_1kx10x1-16 6347569 543.6 ns/op 5749.24 MB/s Benchmark____GWs_Opt_1kx10x1-16 6697198 536.8 ns/op 5821.79 MB/s Benchmark____GWs_Opt_1kx10x1-16 6809151 540.0 ns/op 5786.78 MB/s Benchmark____GWs_Opt_1kx10x1-16 6537974 528.2 ns/op 5916.53 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 3894904 825.5 ns/op 7506.89 MB/s Benchmark____GWs_Opt_2kx10x1-16 4345374 820.2 ns/op 7555.75 MB/s Benchmark____GWs_Opt_2kx10x1-16 4296639 830.8 ns/op 7459.34 MB/s Benchmark____GWs_Opt_2kx10x1-16 4163180 837.9 ns/op 7396.29 MB/s Benchmark____GWs_Opt_2kx10x1-16 4204219 836.0 ns/op 7413.04 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2359516 1496 ns/op 8250.64 MB/s Benchmark____GWs_Opt_4kx10x1-16 2430669 1513 ns/op 8155.24 MB/s Benchmark____GWs_Opt_4kx10x1-16 2625735 1530 ns/op 8065.74 MB/s Benchmark____GWs_Opt_4kx10x1-16 2347183 1502 ns/op 8215.08 MB/s Benchmark____GWs_Opt_4kx10x1-16 2271945 1418 ns/op 8704.30 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12616866 289.6 ns/op 3591.24 MB/s Benchmark____GWs_Int_1kx01x0-16 12536348 289.9 ns/op 3587.38 MB/s Benchmark____GWs_Int_1kx01x0-16 12495799 294.8 ns/op 3528.39 MB/s Benchmark____GWs_Int_1kx01x0-16 12382254 282.9 ns/op 3675.83 MB/s Benchmark____GWs_Int_1kx01x0-16 12870601 284.5 ns/op 3655.92 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9674054 357.3 ns/op 5776.80 MB/s Benchmark____GWs_Int_2kx01x0-16 10187202 375.7 ns/op 5493.44 MB/s Benchmark____GWs_Int_2kx01x0-16 10196647 363.6 ns/op 5676.75 MB/s Benchmark____GWs_Int_2kx01x0-16 10127432 364.6 ns/op 5661.41 MB/s Benchmark____GWs_Int_2kx01x0-16 9605812 339.2 ns/op 6085.71 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5741972 638.3 ns/op 6441.90 MB/s Benchmark____GWs_Int_4kx01x0-16 6082683 624.5 ns/op 6584.40 MB/s Benchmark____GWs_Int_4kx01x0-16 5957034 621.3 ns/op 6618.89 MB/s Benchmark____GWs_Int_4kx01x0-16 5748516 628.3 ns/op 6544.72 MB/s Benchmark____GWs_Int_4kx01x0-16 5568650 637.8 ns/op 6447.62 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32043770 114.1 ns/op 9117.54 MB/s Benchmark____GWs_Int_1kx10x0-16 32783472 125.1 ns/op 8314.32 MB/s Benchmark____GWs_Int_1kx10x0-16 32363068 112.5 ns/op 9246.38 MB/s Benchmark____GWs_Int_1kx10x0-16 31653408 112.5 ns/op 9247.09 MB/s Benchmark____GWs_Int_1kx10x0-16 32172782 110.2 ns/op 9441.27 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 26121541 139.6 ns/op 14782.86 MB/s Benchmark____GWs_Int_2kx10x0-16 24352808 173.0 ns/op 11931.37 MB/s Benchmark____GWs_Int_2kx10x0-16 25415276 139.4 ns/op 14801.54 MB/s Benchmark____GWs_Int_2kx10x0-16 25921059 159.6 ns/op 12929.81 MB/s Benchmark____GWs_Int_2kx10x0-16 25808916 141.2 ns/op 14618.79 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 6858079 464.7 ns/op 8848.64 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:43720->127.0.0.1:44391: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:43556->127.0.0.1:37773: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 bench_test.go:158: Error on read: read tcp 127.0.0.1:39306->127.0.0.1:45895: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:40604->127.0.0.1:40169: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 7223563 419.5 ns/op 9801.87 MB/s Benchmark____GWs_Int_4kx10x0-16 13121605 308.9 ns/op 13313.01 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6499568 553.0 ns/op 5650.90 MB/s Benchmark____GWs_Int_1kx01x1-16 6840879 549.3 ns/op 5688.68 MB/s Benchmark____GWs_Int_1kx01x1-16 6550676 549.2 ns/op 5689.73 MB/s Benchmark____GWs_Int_1kx01x1-16 6562405 541.8 ns/op 5767.96 MB/s Benchmark____GWs_Int_1kx01x1-16 6627411 549.0 ns/op 5691.70 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4857342 749.4 ns/op 8269.37 MB/s Benchmark____GWs_Int_2kx01x1-16 4639606 756.6 ns/op 8190.98 MB/s Benchmark____GWs_Int_2kx01x1-16 4830814 747.6 ns/op 8289.20 MB/s Benchmark____GWs_Int_2kx01x1-16 4889209 752.1 ns/op 8239.16 MB/s Benchmark____GWs_Int_2kx01x1-16 4838881 749.5 ns/op 8268.62 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2715408 1357 ns/op 9093.91 MB/s Benchmark____GWs_Int_4kx01x1-16 2698160 1348 ns/op 9156.07 MB/s Benchmark____GWs_Int_4kx01x1-16 2693749 1357 ns/op 9094.39 MB/s Benchmark____GWs_Int_4kx01x1-16 2442986 1343 ns/op 9187.17 MB/s Benchmark____GWs_Int_4kx01x1-16 2663352 1419 ns/op 8694.30 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6740432 541.0 ns/op 5775.87 MB/s Benchmark____GWs_Int_1kx10x1-16 6796041 544.0 ns/op 5744.60 MB/s Benchmark____GWs_Int_1kx10x1-16 6257355 551.4 ns/op 5667.67 MB/s Benchmark____GWs_Int_1kx10x1-16 6709239 538.9 ns/op 5798.84 MB/s Benchmark____GWs_Int_1kx10x1-16 6114411 540.0 ns/op 5786.55 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4204530 818.9 ns/op 7567.87 MB/s Benchmark____GWs_Int_2kx10x1-16 4115524 821.1 ns/op 7546.86 MB/s Benchmark____GWs_Int_2kx10x1-16 4290553 840.1 ns/op 7376.28 MB/s Benchmark____GWs_Int_2kx10x1-16 4368981 796.9 ns/op 7776.80 MB/s Benchmark____GWs_Int_2kx10x1-16 4214227 830.1 ns/op 7465.67 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2407166 1473 ns/op 8377.86 MB/s Benchmark____GWs_Int_4kx10x1-16 2399349 1689 ns/op 7306.49 MB/s Benchmark____GWs_Int_4kx10x1-16 2431788 1505 ns/op 8201.49 MB/s Benchmark____GWs_Int_4kx10x1-16 2167476 1520 ns/op 8116.77 MB/s Benchmark____GWs_Int_4kx10x1-16 2338500 1501 ns/op 8221.48 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8294288 426.3 ns/op 239.25 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8222120 464.7 ns/op 219.49 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8407748 429.4 ns/op 237.54 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8432535 432.0 ns/op 236.11 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8366228 435.5 ns/op 234.23 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 654733 4755 ns/op 37.22 MB/s Benchmark__GWs_Reqs_1SubEach-16 803642 4939 ns/op 35.84 MB/s Benchmark__GWs_Reqs_1SubEach-16 821509 5015 ns/op 35.30 MB/s Benchmark__GWs_Reqs_1SubEach-16 741013 5020 ns/op 35.26 MB/s Benchmark__GWs_Reqs_1SubEach-16 863809 5064 ns/op 34.95 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2182.338s ❌ Non-zero exit code: 1