> ROOT_DIR=/tmp/go-bench-away-job-7e6d84cf-d4a0-4f7f-91e2-6e2056fcf18c-4228215845 > OUTPUT_FILE=/tmp/go-bench-away-job-7e6d84cf-d4a0-4f7f-91e2-6e2056fcf18c-4228215845/results.txt > SHA_FILE=/tmp/go-bench-away-job-7e6d84cf-d4a0-4f7f-91e2-6e2056fcf18c-4228215845/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-7e6d84cf-d4a0-4f7f-91e2-6e2056fcf18c-4228215845/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-7e6d84cf-d4a0-4f7f-91e2-6e2056fcf18c-4228215845/source.git SHA of main: 920367039bd51f662b78bc783c6c007d0b6c2a7a 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-build148749245=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-7e6d84cf-d4a0-4f7f-91e2-6e2056fcf18c-4228215845/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 42642607 71.15 ns/op 154.60 MB/s Benchmark______Pub0b_Payload-16 50734599 67.47 ns/op 163.04 MB/s Benchmark______Pub0b_Payload-16 50643550 67.30 ns/op 163.45 MB/s Benchmark______Pub0b_Payload-16 50560645 67.39 ns/op 163.22 MB/s Benchmark______Pub0b_Payload-16 50927232 67.38 ns/op 163.25 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 52820390 68.19 ns/op 278.64 MB/s Benchmark______Pub8b_Payload-16 52749115 68.26 ns/op 278.35 MB/s Benchmark______Pub8b_Payload-16 46307772 67.65 ns/op 280.85 MB/s Benchmark______Pub8b_Payload-16 49824444 68.00 ns/op 279.39 MB/s Benchmark______Pub8b_Payload-16 49921870 67.85 ns/op 280.04 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 47279692 72.07 ns/op 610.55 MB/s Benchmark_____Pub32b_Payload-16 47461809 72.04 ns/op 610.78 MB/s Benchmark_____Pub32b_Payload-16 49839282 72.34 ns/op 608.27 MB/s Benchmark_____Pub32b_Payload-16 47237761 72.25 ns/op 608.98 MB/s Benchmark_____Pub32b_Payload-16 47412825 72.14 ns/op 609.89 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 44485854 81.43 ns/op 1731.48 MB/s Benchmark____Pub128B_Payload-16 44019392 81.28 ns/op 1734.70 MB/s Benchmark____Pub128B_Payload-16 36184020 83.08 ns/op 1697.08 MB/s Benchmark____Pub128B_Payload-16 42372480 81.22 ns/op 1736.08 MB/s Benchmark____Pub128B_Payload-16 40605626 81.31 ns/op 1734.01 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 40255838 90.08 ns/op 2986.25 MB/s Benchmark____Pub256B_Payload-16 34075608 89.95 ns/op 2990.59 MB/s Benchmark____Pub256B_Payload-16 38255403 89.06 ns/op 3020.43 MB/s Benchmark____Pub256B_Payload-16 40436602 93.94 ns/op 2863.63 MB/s Benchmark____Pub256B_Payload-16 34468412 89.74 ns/op 2997.60 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23999042 134.5 ns/op 7718.52 MB/s Benchmark______Pub1K_Payload-16 24014061 145.1 ns/op 7155.64 MB/s Benchmark______Pub1K_Payload-16 26901308 134.0 ns/op 7747.25 MB/s Benchmark______Pub1K_Payload-16 22692308 143.3 ns/op 7244.81 MB/s Benchmark______Pub1K_Payload-16 23540764 133.4 ns/op 7780.43 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5560416 637.0 ns/op 6452.45 MB/s Benchmark______Pub4K_Payload-16 5562148 623.2 ns/op 6595.02 MB/s Benchmark______Pub4K_Payload-16 5583702 628.7 ns/op 6536.84 MB/s Benchmark______Pub4K_Payload-16 5627412 632.2 ns/op 6500.82 MB/s Benchmark______Pub4K_Payload-16 5425132 631.8 ns/op 6504.93 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2761867 1280 ns/op 6409.58 MB/s Benchmark______Pub8K_Payload-16 2817511 1283 ns/op 6397.93 MB/s Benchmark______Pub8K_Payload-16 2772134 1284 ns/op 6392.41 MB/s Benchmark______Pub8K_Payload-16 2699150 1287 ns/op 6373.70 MB/s Benchmark______Pub8K_Payload-16 2747708 1296 ns/op 6332.69 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 662817 5430 ns/op 6037.24 MB/s Benchmark_____Pub32K_Payload-16 666081 5552 ns/op 5905.09 MB/s Benchmark_____Pub32K_Payload-16 564620 5454 ns/op 6010.54 MB/s Benchmark_____Pub32K_Payload-16 562014 6829 ns/op 4800.33 MB/s Benchmark_____Pub32K_Payload-16 653002 5360 ns/op 6115.68 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 34518730 87.45 ns/op 125.79 MB/s Benchmark__AuthPub0b_Payload-16 34780542 87.27 ns/op 126.04 MB/s Benchmark__AuthPub0b_Payload-16 39252512 87.12 ns/op 126.27 MB/s Benchmark__AuthPub0b_Payload-16 39158868 87.04 ns/op 126.38 MB/s Benchmark__AuthPub0b_Payload-16 39286514 87.37 ns/op 125.90 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 17152832 206.7 ns/op Benchmark_____________PubSub-16 17037676 207.8 ns/op Benchmark_____________PubSub-16 17198101 206.8 ns/op Benchmark_____________PubSub-16 16939874 207.4 ns/op Benchmark_____________PubSub-16 16899819 206.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 17106675 205.6 ns/op Benchmark_____PubSubTwoConns-16 17352046 206.0 ns/op Benchmark_____PubSubTwoConns-16 17300728 205.8 ns/op Benchmark_____PubSubTwoConns-16 17032413 206.2 ns/op Benchmark_____PubSubTwoConns-16 17155891 205.1 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50162->127.0.0.1:44049: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50560->127.0.0.1:44893: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:55672->127.0.0.1:41789: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:32992->127.0.0.1:42735: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42992->127.0.0.1:43331: 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 15822672 226.2 ns/op Benchmark_____PubTwoQueueSub-16 15599200 227.2 ns/op Benchmark_____PubTwoQueueSub-16 15589300 227.1 ns/op Benchmark_____PubTwoQueueSub-16 15556138 227.3 ns/op Benchmark_____PubTwoQueueSub-16 15760587 226.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15556170 226.5 ns/op Benchmark____PubFourQueueSub-16 15656954 227.0 ns/op Benchmark____PubFourQueueSub-16 15781537 227.3 ns/op Benchmark____PubFourQueueSub-16 15584614 226.2 ns/op Benchmark____PubFourQueueSub-16 15653528 227.6 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15780152 226.6 ns/op Benchmark___PubEightQueueSub-16 15666114 227.1 ns/op Benchmark___PubEightQueueSub-16 15670674 226.8 ns/op Benchmark___PubEightQueueSub-16 15757090 225.5 ns/op Benchmark___PubEightQueueSub-16 15592251 226.9 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22377 155787 ns/op Benchmark_PubSub512kTwoConns-16 23068 156942 ns/op Benchmark_PubSub512kTwoConns-16 23053 156433 ns/op Benchmark_PubSub512kTwoConns-16 22941 156726 ns/op Benchmark_PubSub512kTwoConns-16 23031 155957 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16639750 209.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 16704649 209.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 16673700 209.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 16721108 208.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 16781740 208.3 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16585284 209.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 16859740 208.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 16870770 208.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 16669260 208.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 16537342 208.9 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 12332618 290.6 ns/op Benchmark____RoutedPubSub_0b-16 12200810 286.5 ns/op Benchmark____RoutedPubSub_0b-16 12235029 290.0 ns/op Benchmark____RoutedPubSub_0b-16 12160567 293.6 ns/op Benchmark____RoutedPubSub_0b-16 12473337 291.2 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6870302 508.7 ns/op Benchmark____RoutedPubSub_1K-16 6624753 515.3 ns/op Benchmark____RoutedPubSub_1K-16 6883358 489.4 ns/op Benchmark____RoutedPubSub_1K-16 7151890 513.8 ns/op Benchmark____RoutedPubSub_1K-16 7074580 504.0 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84850 43406 ns/op Benchmark__RoutedPubSub_100K-16 87206 42326 ns/op Benchmark__RoutedPubSub_100K-16 83722 42509 ns/op Benchmark__RoutedPubSub_100K-16 85305 42372 ns/op Benchmark__RoutedPubSub_100K-16 88244 45431 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 12216242 294.0 ns/op Benchmark____Routed2QueueSub-16 10119490 302.3 ns/op Benchmark____Routed2QueueSub-16 10231297 297.3 ns/op Benchmark____Routed2QueueSub-16 10172115 295.3 ns/op Benchmark____Routed2QueueSub-16 11906700 296.0 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 10008810 300.2 ns/op Benchmark____Routed4QueueSub-16 9782253 310.1 ns/op Benchmark____Routed4QueueSub-16 9903268 306.5 ns/op Benchmark____Routed4QueueSub-16 11806531 299.7 ns/op Benchmark____Routed4QueueSub-16 11980658 304.5 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 10133125 318.3 ns/op Benchmark____Routed8QueueSub-16 9744266 309.1 ns/op Benchmark____Routed8QueueSub-16 9681085 314.1 ns/op Benchmark____Routed8QueueSub-16 9908241 312.2 ns/op Benchmark____Routed8QueueSub-16 11771462 308.4 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 9273930 328.6 ns/op Benchmark___Routed16QueueSub-16 9440100 332.4 ns/op Benchmark___Routed16QueueSub-16 9293966 329.9 ns/op Benchmark___Routed16QueueSub-16 9103088 336.4 ns/op Benchmark___Routed16QueueSub-16 9257089 327.9 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6788112 528.2 ns/op Benchmark____________RouteCompressOff-16 6650197 487.5 ns/op Benchmark____________RouteCompressOff-16 6637263 529.0 ns/op Benchmark____________RouteCompressOff-16 6859544 463.8 ns/op Benchmark____________RouteCompressOff-16 6443858 533.7 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6543712 544.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6445768 536.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6455686 538.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6581882 537.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6708504 530.6 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6665828 491.2 ns/op Benchmark_________RouteCompressS2Fast-16 6702156 534.7 ns/op Benchmark_________RouteCompressS2Fast-16 6688930 541.3 ns/op Benchmark_________RouteCompressS2Fast-16 6596774 527.3 ns/op Benchmark_________RouteCompressS2Fast-16 6699098 527.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6603685 526.8 ns/op Benchmark_______RouteCompressS2Better-16 6492354 536.7 ns/op Benchmark_______RouteCompressS2Better-16 6590473 533.4 ns/op Benchmark_______RouteCompressS2Better-16 6835861 533.3 ns/op Benchmark_______RouteCompressS2Better-16 6646435 594.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6712099 531.7 ns/op Benchmark_________RouteCompressS2Best-16 6689682 533.4 ns/op Benchmark_________RouteCompressS2Best-16 6709141 533.2 ns/op Benchmark_________RouteCompressS2Best-16 6749985 533.4 ns/op Benchmark_________RouteCompressS2Best-16 6746319 534.4 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5236519 689.2 ns/op 361.31 MB/s Benchmark______FanOut_8x1x10-16 5244066 692.5 ns/op 359.55 MB/s Benchmark______FanOut_8x1x10-16 5221959 689.0 ns/op 361.38 MB/s Benchmark______FanOut_8x1x10-16 5213328 683.9 ns/op 364.08 MB/s Benchmark______FanOut_8x1x10-16 5181682 687.0 ns/op 362.45 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 635706 5322 ns/op 435.71 MB/s Benchmark_____FanOut_8x1x100-16 625645 5337 ns/op 434.54 MB/s Benchmark_____FanOut_8x1x100-16 631196 5342 ns/op 434.10 MB/s Benchmark_____FanOut_8x1x100-16 595492 5283 ns/op 438.98 MB/s Benchmark_____FanOut_8x1x100-16 628304 5352 ns/op 433.27 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 52568 68075 ns/op 338.14 MB/s Benchmark____FanOut_8x10x100-16 52874 68094 ns/op 338.05 MB/s Benchmark____FanOut_8x10x100-16 52635 68107 ns/op 337.98 MB/s Benchmark____FanOut_8x10x100-16 52293 68044 ns/op 338.30 MB/s Benchmark____FanOut_8x10x100-16 52471 68471 ns/op 336.19 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6314 535082 ns/op 448.57 MB/s Benchmark___FanOut_8x10x1000-16 6682 535876 ns/op 447.90 MB/s Benchmark___FanOut_8x10x1000-16 6322 539399 ns/op 444.98 MB/s Benchmark___FanOut_8x10x1000-16 6367 535598 ns/op 448.13 MB/s Benchmark___FanOut_8x10x1000-16 6258 532881 ns/op 450.42 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5554 631817 ns/op 364.06 MB/s Benchmark___FanOut_8x100x100-16 5563 633372 ns/op 363.17 MB/s Benchmark___FanOut_8x100x100-16 5527 632640 ns/op 363.59 MB/s Benchmark___FanOut_8x100x100-16 5512 633168 ns/op 363.28 MB/s Benchmark___FanOut_8x100x100-16 5473 634568 ns/op 362.48 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 661 5539840 ns/op 433.23 MB/s Benchmark__FanOut_8x100x1000-16 661 5461611 ns/op 439.43 MB/s Benchmark__FanOut_8x100x1000-16 660 5526465 ns/op 434.28 MB/s Benchmark__FanOut_8x100x1000-16 627 5449914 ns/op 440.38 MB/s Benchmark__FanOut_8x100x1000-16 644 5588439 ns/op 429.46 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 596 5852017 ns/op 427.21 MB/s Benchmark__FanOut_8x10x10000-16 619 5827806 ns/op 428.98 MB/s Benchmark__FanOut_8x10x10000-16 608 5844171 ns/op 427.78 MB/s Benchmark__FanOut_8x10x10000-16 603 5848051 ns/op 427.50 MB/s Benchmark__FanOut_8x10x10000-16 621 5818599 ns/op 429.66 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1054 3368876 ns/op 341.37 MB/s Benchmark___FanOut_8x500x100-16 1054 3388140 ns/op 339.42 MB/s Benchmark___FanOut_8x500x100-16 1047 3406154 ns/op 337.63 MB/s Benchmark___FanOut_8x500x100-16 1048 3390722 ns/op 339.17 MB/s Benchmark___FanOut_8x500x100-16 1048 3385554 ns/op 339.68 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 386407 8898 ns/op 1645.46 MB/s Benchmark___FanOut_128x1x100-16 385117 8874 ns/op 1649.84 MB/s Benchmark___FanOut_128x1x100-16 388600 8896 ns/op 1645.88 MB/s Benchmark___FanOut_128x1x100-16 387981 8925 ns/op 1640.40 MB/s Benchmark___FanOut_128x1x100-16 382015 8896 ns/op 1645.86 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 35096 102885 ns/op 1410.71 MB/s Benchmark__FanOut_128x10x100-16 34900 103631 ns/op 1400.56 MB/s Benchmark__FanOut_128x10x100-16 34904 103449 ns/op 1403.02 MB/s Benchmark__FanOut_128x10x100-16 34605 104119 ns/op 1393.99 MB/s Benchmark__FanOut_128x10x100-16 34770 103284 ns/op 1405.27 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4426 804253 ns/op 1815.52 MB/s Benchmark_FanOut_128x10x1000-16 4293 799221 ns/op 1826.96 MB/s Benchmark_FanOut_128x10x1000-16 4494 800917 ns/op 1823.09 MB/s Benchmark_FanOut_128x10x1000-16 4430 803547 ns/op 1817.12 MB/s Benchmark_FanOut_128x10x1000-16 4333 804295 ns/op 1815.43 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3685 953594 ns/op 1520.71 MB/s Benchmark_FanOut_128x100x100-16 3750 945911 ns/op 1533.06 MB/s Benchmark_FanOut_128x100x100-16 3674 947228 ns/op 1530.93 MB/s Benchmark_FanOut_128x100x100-16 3698 945095 ns/op 1534.39 MB/s Benchmark_FanOut_128x100x100-16 3693 946210 ns/op 1532.58 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 417 8472465 ns/op 1723.25 MB/s BenchmarkFanOut_128x100x1000-16 422 8394751 ns/op 1739.20 MB/s BenchmarkFanOut_128x100x1000-16 420 8495439 ns/op 1718.59 MB/s BenchmarkFanOut_128x100x1000-16 415 8432273 ns/op 1731.46 MB/s BenchmarkFanOut_128x100x1000-16 417 8564676 ns/op 1704.69 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 405 8753757 ns/op 1679.30 MB/s BenchmarkFanOut_128x10x10000-16 405 8831529 ns/op 1664.51 MB/s BenchmarkFanOut_128x10x10000-16 416 8776924 ns/op 1674.86 MB/s BenchmarkFanOut_128x10x10000-16 409 8830576 ns/op 1664.69 MB/s BenchmarkFanOut_128x10x10000-16 408 8796008 ns/op 1671.23 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 715 4980536 ns/op 1455.70 MB/s BenchmarkFanOut__128x500x100-16 711 4982764 ns/op 1455.04 MB/s BenchmarkFanOut__128x500x100-16 709 4977475 ns/op 1456.59 MB/s BenchmarkFanOut__128x500x100-16 721 4965345 ns/op 1460.15 MB/s BenchmarkFanOut__128x500x100-16 720 4982098 ns/op 1455.24 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 2023 1776124 ns/op 2978.69 MB/s Benchmark_FanOut_512x100x100-16 2040 1773852 ns/op 2982.51 MB/s Benchmark_FanOut_512x100x100-16 1977 1759955 ns/op 3006.06 MB/s Benchmark_FanOut_512x100x100-16 1971 1770870 ns/op 2987.53 MB/s Benchmark_FanOut_512x100x100-16 1995 1770779 ns/op 2987.68 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 223 16119289 ns/op 3288.02 MB/s Benchmark__FanOut_512x100x1k-16 220 16196287 ns/op 3272.39 MB/s Benchmark__FanOut_512x100x1k-16 224 16081030 ns/op 3295.84 MB/s Benchmark__FanOut_512x100x1k-16 222 16143219 ns/op 3283.14 MB/s Benchmark__FanOut_512x100x1k-16 220 16093434 ns/op 3293.30 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3289 1101384 ns/op 9470.84 MB/s Benchmark____FanOut_1kx10x1k-16 3160 1103081 ns/op 9456.27 MB/s Benchmark____FanOut_1kx10x1k-16 3145 1097432 ns/op 9504.95 MB/s Benchmark____FanOut_1kx10x1k-16 2944 1085200 ns/op 9612.09 MB/s Benchmark____FanOut_1kx10x1k-16 2798 1122417 ns/op 9293.37 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2976 1197274 ns/op 8703.97 MB/s Benchmark__FanOut_1kx100x100-16 2972 1188247 ns/op 8770.09 MB/s Benchmark__FanOut_1kx100x100-16 2902 1197061 ns/op 8705.52 MB/s Benchmark__FanOut_1kx100x100-16 2893 1193020 ns/op 8735.00 MB/s Benchmark__FanOut_1kx100x100-16 2940 1196067 ns/op 8712.76 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 5009334 682.2 ns/op 365.01 MB/s Benchmark_____RFanOut_8x1x10-16 4905577 684.6 ns/op 363.74 MB/s Benchmark_____RFanOut_8x1x10-16 5000208 690.8 ns/op 360.44 MB/s Benchmark_____RFanOut_8x1x10-16 4967174 688.9 ns/op 361.45 MB/s Benchmark_____RFanOut_8x1x10-16 4866162 686.8 ns/op 362.54 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 621050 5265 ns/op 440.47 MB/s Benchmark____RFanOut_8x1x100-16 582128 5256 ns/op 441.21 MB/s Benchmark____RFanOut_8x1x100-16 586216 5310 ns/op 436.76 MB/s Benchmark____RFanOut_8x1x100-16 596113 5383 ns/op 430.80 MB/s Benchmark____RFanOut_8x1x100-16 572191 5332 ns/op 434.90 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 52731 67949 ns/op 338.77 MB/s Benchmark___RFanOut_8x10x100-16 53059 68479 ns/op 336.14 MB/s Benchmark___RFanOut_8x10x100-16 52396 69162 ns/op 332.83 MB/s Benchmark___RFanOut_8x10x100-16 52488 68092 ns/op 338.06 MB/s Benchmark___RFanOut_8x10x100-16 52585 67986 ns/op 338.59 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6794 535986 ns/op 447.81 MB/s Benchmark__RFanOut_8x10x1000-16 6630 542944 ns/op 442.07 MB/s Benchmark__RFanOut_8x10x1000-16 6430 532358 ns/op 450.86 MB/s Benchmark__RFanOut_8x10x1000-16 6404 535632 ns/op 448.10 MB/s Benchmark__RFanOut_8x10x1000-16 6847 535735 ns/op 448.02 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5487 636005 ns/op 361.66 MB/s Benchmark__RFanOut_8x100x100-16 5515 642644 ns/op 357.93 MB/s Benchmark__RFanOut_8x100x100-16 5478 633663 ns/op 363.00 MB/s Benchmark__RFanOut_8x100x100-16 5604 635873 ns/op 361.74 MB/s Benchmark__RFanOut_8x100x100-16 5550 635524 ns/op 361.94 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 638 5471779 ns/op 438.62 MB/s Benchmark_RFanOut_8x100x1000-16 637 5524710 ns/op 434.42 MB/s Benchmark_RFanOut_8x100x1000-16 626 5618829 ns/op 427.14 MB/s Benchmark_RFanOut_8x100x1000-16 640 5553486 ns/op 432.16 MB/s Benchmark_RFanOut_8x100x1000-16 644 5643730 ns/op 425.25 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 598 5880137 ns/op 425.16 MB/s Benchmark_RFanOut_8x10x10000-16 588 5953047 ns/op 419.96 MB/s Benchmark_RFanOut_8x10x10000-16 621 5851163 ns/op 427.27 MB/s Benchmark_RFanOut_8x10x10000-16 600 5918534 ns/op 422.41 MB/s Benchmark_RFanOut_8x10x10000-16 614 5874609 ns/op 425.56 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3100 1120275 ns/op 9311.14 MB/s Benchmark_RFanOut_1kx10x1000-16 3228 1117398 ns/op 9335.11 MB/s Benchmark_RFanOut_1kx10x1000-16 3094 1120569 ns/op 9308.70 MB/s Benchmark_RFanOut_1kx10x1000-16 3258 1093533 ns/op 9538.84 MB/s Benchmark_RFanOut_1kx10x1000-16 3340 1079336 ns/op 9664.31 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7221658 486.1 ns/op 4274.92 MB/s Benchmark_____FanIn_1kx100x1-16 7228339 485.5 ns/op 4280.18 MB/s Benchmark_____FanIn_1kx100x1-16 7203050 488.3 ns/op 4255.88 MB/s Benchmark_____FanIn_1kx100x1-16 7179206 487.2 ns/op 4264.96 MB/s Benchmark_____FanIn_1kx100x1-16 7226708 484.8 ns/op 4286.52 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2601562 1344 ns/op 6119.76 MB/s Benchmark_____FanIn_4kx100x1-16 2699565 1345 ns/op 6113.69 MB/s Benchmark_____FanIn_4kx100x1-16 2693236 1333 ns/op 6166.80 MB/s Benchmark_____FanIn_4kx100x1-16 2674826 1340 ns/op 6135.51 MB/s Benchmark_____FanIn_4kx100x1-16 2678510 1346 ns/op 6109.12 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1705878 2071 ns/op 7924.37 MB/s Benchmark_____FanIn_8kx100x1-16 1719472 2086 ns/op 7867.49 MB/s Benchmark_____FanIn_8kx100x1-16 1701330 2074 ns/op 7914.59 MB/s Benchmark_____FanIn_8kx100x1-16 1724666 2097 ns/op 7828.22 MB/s Benchmark_____FanIn_8kx100x1-16 1714680 2123 ns/op 7730.28 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 883677 4089 ns/op 8021.52 MB/s Benchmark____FanIn_16kx100x1-16 882608 4136 ns/op 7931.22 MB/s Benchmark____FanIn_16kx100x1-16 862033 4143 ns/op 7916.56 MB/s Benchmark____FanIn_16kx100x1-16 889538 4086 ns/op 8027.79 MB/s Benchmark____FanIn_16kx100x1-16 872893 4124 ns/op 7953.52 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 163352 19886 ns/op 6592.73 MB/s Benchmark____FanIn_64kx100x1-16 170395 19667 ns/op 6666.14 MB/s Benchmark____FanIn_64kx100x1-16 156237 19753 ns/op 6637.03 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 3233795043 vs 11137454700 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55156->127.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:55108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54766->127.0.0.1:5222: write: connection reset by peer 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:54914->127.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:55158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55062->127.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:54940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54550->127.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:54500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55050->127.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: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:55140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55092->127.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: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:55148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55010->127.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: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:54780->127.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: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:55208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:55022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55180->127.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: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:54712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54976->127.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:54468->127.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:54516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54640->127.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:54608->127.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:54618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:55094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54848->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 170236 19680 ns/op 6661.85 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1357830220 vs 11811209000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:34998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34452->127.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:34368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:34732->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34218->127.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:34874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:34168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34274->127.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:34506->127.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:34318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:35036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34534->127.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:34560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34412->127.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:34896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34246->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: 2101372700 vs 11798100000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36874->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:36894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36876->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: 793094500 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39430->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:38846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39016->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: 200567700 vs 11535920000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41528->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:41700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42070->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: 902947920 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43194->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5905014 605.5 ns/op 469.04 MB/s Benchmark___BumpPubCount_1x3-16 5863742 605.7 ns/op 468.91 MB/s Benchmark___BumpPubCount_1x3-16 5904880 604.6 ns/op 469.73 MB/s Benchmark___BumpPubCount_1x3-16 6010575 604.8 ns/op 469.58 MB/s Benchmark___BumpPubCount_1x3-16 5937400 603.8 ns/op 470.36 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5639487 635.3 ns/op 447.03 MB/s Benchmark___BumpPubCount_2x3-16 5630898 642.9 ns/op 441.77 MB/s Benchmark___BumpPubCount_2x3-16 5628270 629.0 ns/op 451.50 MB/s Benchmark___BumpPubCount_2x3-16 5613456 635.1 ns/op 447.16 MB/s Benchmark___BumpPubCount_2x3-16 5604614 634.7 ns/op 447.46 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5641688 610.7 ns/op 465.03 MB/s Benchmark___BumpPubCount_5x3-16 5842812 612.2 ns/op 463.89 MB/s Benchmark___BumpPubCount_5x3-16 5570941 611.5 ns/op 464.42 MB/s Benchmark___BumpPubCount_5x3-16 5616603 613.2 ns/op 463.17 MB/s Benchmark___BumpPubCount_5x3-16 5532348 613.0 ns/op 463.31 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5939056 607.3 ns/op 467.64 MB/s Benchmark__BumpPubCount_10x3-16 5905957 609.2 ns/op 466.15 MB/s Benchmark__BumpPubCount_10x3-16 5901403 615.3 ns/op 461.57 MB/s Benchmark__BumpPubCount_10x3-16 5913894 609.0 ns/op 466.33 MB/s Benchmark__BumpPubCount_10x3-16 5081094 607.1 ns/op 467.79 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12624652 267.2 ns/op 3891.90 MB/s Benchmark____GWs_Opt_1kx01x0-16 11523496 264.5 ns/op 3931.47 MB/s Benchmark____GWs_Opt_1kx01x0-16 13185340 266.3 ns/op 3905.03 MB/s Benchmark____GWs_Opt_1kx01x0-16 13309617 262.0 ns/op 3969.24 MB/s Benchmark____GWs_Opt_1kx01x0-16 13583919 269.3 ns/op 3862.05 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10708334 322.6 ns/op 6397.39 MB/s Benchmark____GWs_Opt_2kx01x0-16 10850335 327.8 ns/op 6297.43 MB/s Benchmark____GWs_Opt_2kx01x0-16 10990591 341.0 ns/op 6053.45 MB/s Benchmark____GWs_Opt_2kx01x0-16 11095454 319.6 ns/op 6458.46 MB/s Benchmark____GWs_Opt_2kx01x0-16 10318269 333.6 ns/op 6187.42 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5831828 619.3 ns/op 6639.56 MB/s Benchmark____GWs_Opt_4kx01x0-16 5889784 589.4 ns/op 6976.56 MB/s Benchmark____GWs_Opt_4kx01x0-16 5849632 596.8 ns/op 6889.66 MB/s Benchmark____GWs_Opt_4kx01x0-16 6099049 591.7 ns/op 6949.28 MB/s Benchmark____GWs_Opt_4kx01x0-16 5735330 617.9 ns/op 6654.73 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29115594 114.4 ns/op 9087.48 MB/s Benchmark____GWs_Opt_1kx10x0-16 30729939 111.3 ns/op 9346.67 MB/s Benchmark____GWs_Opt_1kx10x0-16 31543515 115.1 ns/op 9036.14 MB/s Benchmark____GWs_Opt_1kx10x0-16 32672443 117.7 ns/op 8838.15 MB/s Benchmark____GWs_Opt_1kx10x0-16 28783126 111.6 ns/op 9320.31 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24003649 142.0 ns/op 14536.40 MB/s Benchmark____GWs_Opt_2kx10x0-16 24381147 171.9 ns/op 12004.51 MB/s Benchmark____GWs_Opt_2kx10x0-16 23385627 139.0 ns/op 14851.29 MB/s Benchmark____GWs_Opt_2kx10x0-16 23123636 155.0 ns/op 13315.47 MB/s Benchmark____GWs_Opt_2kx10x0-16 24898092 140.0 ns/op 14738.36 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 10985247 288.6 ns/op 14249.55 MB/s Benchmark____GWs_Opt_4kx10x0-16 9007786 348.5 ns/op 11799.33 MB/s Benchmark____GWs_Opt_4kx10x0-16 12806308 293.4 ns/op 14015.23 MB/s Benchmark____GWs_Opt_4kx10x0-16 11988062 295.1 ns/op 13933.31 MB/s Benchmark____GWs_Opt_4kx10x0-16 9501780 372.8 ns/op 11030.01 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6720321 528.0 ns/op 5918.12 MB/s Benchmark____GWs_Opt_1kx01x1-16 6753583 528.2 ns/op 5916.20 MB/s Benchmark____GWs_Opt_1kx01x1-16 6837171 525.8 ns/op 5943.41 MB/s Benchmark____GWs_Opt_1kx01x1-16 6688221 529.7 ns/op 5899.52 MB/s Benchmark____GWs_Opt_1kx01x1-16 6676389 533.3 ns/op 5859.42 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4814235 739.0 ns/op 8385.97 MB/s Benchmark____GWs_Opt_2kx01x1-16 4364881 746.2 ns/op 8304.86 MB/s Benchmark____GWs_Opt_2kx01x1-16 4906076 736.1 ns/op 8419.12 MB/s Benchmark____GWs_Opt_2kx01x1-16 4868965 734.8 ns/op 8433.58 MB/s Benchmark____GWs_Opt_2kx01x1-16 4665116 746.6 ns/op 8299.86 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2621643 1421 ns/op 8687.71 MB/s Benchmark____GWs_Opt_4kx01x1-16 2690161 1355 ns/op 9104.41 MB/s Benchmark____GWs_Opt_4kx01x1-16 2628270 1347 ns/op 9159.33 MB/s Benchmark____GWs_Opt_4kx01x1-16 2686441 1349 ns/op 9149.00 MB/s Benchmark____GWs_Opt_4kx01x1-16 2610642 1355 ns/op 9108.61 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6618654 539.8 ns/op 5789.03 MB/s Benchmark____GWs_Opt_1kx10x1-16 6864168 538.7 ns/op 5800.90 MB/s Benchmark____GWs_Opt_1kx10x1-16 6417172 543.5 ns/op 5749.99 MB/s Benchmark____GWs_Opt_1kx10x1-16 6680613 541.1 ns/op 5774.90 MB/s Benchmark____GWs_Opt_1kx10x1-16 6530460 544.5 ns/op 5738.73 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4257736 829.3 ns/op 7472.95 MB/s Benchmark____GWs_Opt_2kx10x1-16 4247901 837.2 ns/op 7402.41 MB/s Benchmark____GWs_Opt_2kx10x1-16 3980980 821.6 ns/op 7542.34 MB/s Benchmark____GWs_Opt_2kx10x1-16 4105231 837.8 ns/op 7396.77 MB/s Benchmark____GWs_Opt_2kx10x1-16 4251458 896.2 ns/op 6914.85 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2267464 1560 ns/op 7912.63 MB/s Benchmark____GWs_Opt_4kx10x1-16 2438468 1506 ns/op 8192.65 MB/s Benchmark____GWs_Opt_4kx10x1-16 2375892 1517 ns/op 8137.05 MB/s Benchmark____GWs_Opt_4kx10x1-16 2392192 1483 ns/op 8322.60 MB/s Benchmark____GWs_Opt_4kx10x1-16 2507090 1518 ns/op 8131.31 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 13047889 279.5 ns/op 3721.12 MB/s Benchmark____GWs_Int_1kx01x0-16 12738015 279.8 ns/op 3716.38 MB/s Benchmark____GWs_Int_1kx01x0-16 12245774 287.9 ns/op 3612.98 MB/s Benchmark____GWs_Int_1kx01x0-16 12985602 271.4 ns/op 3831.99 MB/s Benchmark____GWs_Int_1kx01x0-16 12584782 277.8 ns/op 3743.88 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10762432 346.3 ns/op 5959.69 MB/s Benchmark____GWs_Int_2kx01x0-16 10327794 337.6 ns/op 6114.24 MB/s Benchmark____GWs_Int_2kx01x0-16 10352414 357.0 ns/op 5781.27 MB/s Benchmark____GWs_Int_2kx01x0-16 10350812 347.3 ns/op 5942.68 MB/s Benchmark____GWs_Int_2kx01x0-16 10681440 353.7 ns/op 5834.73 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5864366 615.6 ns/op 6680.08 MB/s Benchmark____GWs_Int_4kx01x0-16 5936977 621.7 ns/op 6614.57 MB/s Benchmark____GWs_Int_4kx01x0-16 5828649 623.9 ns/op 6590.61 MB/s Benchmark____GWs_Int_4kx01x0-16 5922308 629.3 ns/op 6533.94 MB/s Benchmark____GWs_Int_4kx01x0-16 5578416 597.0 ns/op 6888.04 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30944383 110.6 ns/op 9404.35 MB/s Benchmark____GWs_Int_1kx10x0-16 31777218 113.5 ns/op 9167.00 MB/s Benchmark____GWs_Int_1kx10x0-16 32322924 111.7 ns/op 9312.56 MB/s Benchmark____GWs_Int_1kx10x0-16 31420957 110.1 ns/op 9450.22 MB/s Benchmark____GWs_Int_1kx10x0-16 31760235 111.0 ns/op 9373.41 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24093015 170.0 ns/op 12141.90 MB/s Benchmark____GWs_Int_2kx10x0-16 26204658 150.4 ns/op 13720.17 MB/s Benchmark____GWs_Int_2kx10x0-16 24195090 150.1 ns/op 13753.07 MB/s Benchmark____GWs_Int_2kx10x0-16 25596525 141.3 ns/op 14603.90 MB/s Benchmark____GWs_Int_2kx10x0-16 25471066 142.6 ns/op 14474.05 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13245944 285.4 ns/op 14408.39 MB/s Benchmark____GWs_Int_4kx10x0-16 10967937 318.7 ns/op 12902.45 MB/s Benchmark____GWs_Int_4kx10x0-16 13264032 294.6 ns/op 13956.43 MB/s Benchmark____GWs_Int_4kx10x0-16 13517498 298.8 ns/op 13762.20 MB/s Benchmark____GWs_Int_4kx10x0-16 10463565 291.4 ns/op 14111.11 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6795498 536.6 ns/op 5823.47 MB/s Benchmark____GWs_Int_1kx01x1-16 6701556 537.2 ns/op 5817.57 MB/s Benchmark____GWs_Int_1kx01x1-16 6865677 538.1 ns/op 5807.41 MB/s Benchmark____GWs_Int_1kx01x1-16 6728463 541.7 ns/op 5768.48 MB/s Benchmark____GWs_Int_1kx01x1-16 6676150 539.1 ns/op 5796.81 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4810300 746.6 ns/op 8300.82 MB/s Benchmark____GWs_Int_2kx01x1-16 4861777 752.6 ns/op 8234.30 MB/s Benchmark____GWs_Int_2kx01x1-16 4764058 818.7 ns/op 7568.99 MB/s Benchmark____GWs_Int_2kx01x1-16 4657916 761.1 ns/op 8141.67 MB/s Benchmark____GWs_Int_2kx01x1-16 4643386 751.6 ns/op 8244.95 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2385400 1343 ns/op 9189.10 MB/s Benchmark____GWs_Int_4kx01x1-16 2700052 1504 ns/op 8202.84 MB/s Benchmark____GWs_Int_4kx01x1-16 2712919 1339 ns/op 9218.58 MB/s Benchmark____GWs_Int_4kx01x1-16 2634607 1436 ns/op 8591.55 MB/s Benchmark____GWs_Int_4kx01x1-16 2662405 1344 ns/op 9183.12 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6792626 526.9 ns/op 5930.72 MB/s Benchmark____GWs_Int_1kx10x1-16 6276277 605.1 ns/op 5164.76 MB/s Benchmark____GWs_Int_1kx10x1-16 6811618 536.7 ns/op 5822.93 MB/s Benchmark____GWs_Int_1kx10x1-16 6658960 537.1 ns/op 5817.97 MB/s Benchmark____GWs_Int_1kx10x1-16 6786001 532.6 ns/op 5866.95 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4156747 835.6 ns/op 7415.96 MB/s Benchmark____GWs_Int_2kx10x1-16 4304480 833.8 ns/op 7432.47 MB/s Benchmark____GWs_Int_2kx10x1-16 4322756 827.7 ns/op 7487.26 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:48596->127.0.0.1:40179: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x1-16 Benchmark____GWs_Int_2kx10x1-16 4414238 830.8 ns/op 7458.76 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2417988 1517 ns/op 8134.31 MB/s Benchmark____GWs_Int_4kx10x1-16 2440188 1522 ns/op 8110.36 MB/s Benchmark____GWs_Int_4kx10x1-16 2378851 1475 ns/op 8368.22 MB/s Benchmark____GWs_Int_4kx10x1-16 2429034 1515 ns/op 8146.00 MB/s Benchmark____GWs_Int_4kx10x1-16 2285721 1510 ns/op 8172.82 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8542300 422.0 ns/op 241.73 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8915475 418.7 ns/op 243.63 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8896411 423.7 ns/op 240.76 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8556194 421.4 ns/op 242.05 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8834932 427.6 ns/op 238.53 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 659682 4706 ns/op 37.61 MB/s Benchmark__GWs_Reqs_1SubEach-16 839732 4880 ns/op 36.27 MB/s Benchmark__GWs_Reqs_1SubEach-16 774601 4812 ns/op 36.78 MB/s Benchmark__GWs_Reqs_1SubEach-16 838508 4919 ns/op 35.98 MB/s Benchmark__GWs_Reqs_1SubEach-16 822655 4840 ns/op 36.57 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2086.197s ❌ Non-zero exit code: 1