> ROOT_DIR=/tmp/go-bench-away-job-3b16b868-9eab-4333-b4ad-0babe05b5873-4209467986 > OUTPUT_FILE=/tmp/go-bench-away-job-3b16b868-9eab-4333-b4ad-0babe05b5873-4209467986/results.txt > SHA_FILE=/tmp/go-bench-away-job-3b16b868-9eab-4333-b4ad-0babe05b5873-4209467986/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-3b16b868-9eab-4333-b4ad-0babe05b5873-4209467986/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.26.3/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-3b16b868-9eab-4333-b4ad-0babe05b5873-4209467986/source.git SHA of main: b7aeab5cbada5fd2d9ffd8fbaab44faa172e400f Go runtime: go version go1.26.3 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build3807199872=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-3b16b868-9eab-4333-b4ad-0babe05b5873-4209467986/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.26.3' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.26.3/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.3' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 49202678 72.80 ns/op 151.09 MB/s Benchmark______Pub0b_Payload-16 45846984 72.79 ns/op 151.11 MB/s Benchmark______Pub0b_Payload-16 45180459 72.97 ns/op 150.75 MB/s Benchmark______Pub0b_Payload-16 45744084 72.95 ns/op 150.80 MB/s Benchmark______Pub0b_Payload-16 46455752 72.64 ns/op 151.43 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46391386 73.55 ns/op 258.34 MB/s Benchmark______Pub8b_Payload-16 46277076 74.20 ns/op 256.05 MB/s Benchmark______Pub8b_Payload-16 46394636 73.88 ns/op 257.18 MB/s Benchmark______Pub8b_Payload-16 46125313 73.58 ns/op 258.20 MB/s Benchmark______Pub8b_Payload-16 45984895 73.67 ns/op 257.92 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 46314370 77.77 ns/op 565.73 MB/s Benchmark_____Pub32b_Payload-16 43860982 79.04 ns/op 556.70 MB/s Benchmark_____Pub32b_Payload-16 46036776 77.54 ns/op 567.48 MB/s Benchmark_____Pub32b_Payload-16 46134307 77.56 ns/op 567.32 MB/s Benchmark_____Pub32b_Payload-16 46379024 77.97 ns/op 564.31 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39388600 87.17 ns/op 1617.56 MB/s Benchmark____Pub128B_Payload-16 38326909 90.09 ns/op 1565.17 MB/s Benchmark____Pub128B_Payload-16 34336128 87.74 ns/op 1606.98 MB/s Benchmark____Pub128B_Payload-16 38685062 87.29 ns/op 1615.33 MB/s Benchmark____Pub128B_Payload-16 38421790 87.38 ns/op 1613.72 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36568198 95.26 ns/op 2823.77 MB/s Benchmark____Pub256B_Payload-16 36015872 96.08 ns/op 2799.86 MB/s Benchmark____Pub256B_Payload-16 36123154 97.59 ns/op 2756.32 MB/s Benchmark____Pub256B_Payload-16 31854375 95.10 ns/op 2828.47 MB/s Benchmark____Pub256B_Payload-16 36487627 94.66 ns/op 2841.76 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24085142 146.8 ns/op 7072.10 MB/s Benchmark______Pub1K_Payload-16 23272653 150.1 ns/op 6917.68 MB/s Benchmark______Pub1K_Payload-16 22417444 141.9 ns/op 7315.71 MB/s Benchmark______Pub1K_Payload-16 24442198 144.3 ns/op 7194.68 MB/s Benchmark______Pub1K_Payload-16 23937871 139.5 ns/op 7439.25 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5680362 612.1 ns/op 6714.20 MB/s Benchmark______Pub4K_Payload-16 5733312 632.4 ns/op 6499.04 MB/s Benchmark______Pub4K_Payload-16 5659282 624.2 ns/op 6584.04 MB/s Benchmark______Pub4K_Payload-16 5767282 614.5 ns/op 6687.97 MB/s Benchmark______Pub4K_Payload-16 5440280 624.8 ns/op 6577.76 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2794816 1272 ns/op 6452.20 MB/s Benchmark______Pub8K_Payload-16 2791963 1280 ns/op 6409.36 MB/s Benchmark______Pub8K_Payload-16 2810139 1280 ns/op 6409.14 MB/s Benchmark______Pub8K_Payload-16 2710581 1283 ns/op 6396.12 MB/s Benchmark______Pub8K_Payload-16 2730612 1270 ns/op 6462.09 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 667306 5365 ns/op 6110.46 MB/s Benchmark_____Pub32K_Payload-16 604510 5434 ns/op 6033.12 MB/s Benchmark_____Pub32K_Payload-16 662978 5442 ns/op 6023.66 MB/s Benchmark_____Pub32K_Payload-16 657936 5351 ns/op 6126.61 MB/s Benchmark_____Pub32K_Payload-16 661966 5549 ns/op 5907.77 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32191840 94.37 ns/op 116.56 MB/s Benchmark__AuthPub0b_Payload-16 36146460 94.37 ns/op 116.56 MB/s Benchmark__AuthPub0b_Payload-16 36303120 95.07 ns/op 115.71 MB/s Benchmark__AuthPub0b_Payload-16 36107190 94.25 ns/op 116.71 MB/s Benchmark__AuthPub0b_Payload-16 36404626 94.09 ns/op 116.91 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15459625 228.6 ns/op Benchmark_____________PubSub-16 15153176 229.6 ns/op Benchmark_____________PubSub-16 15287209 230.4 ns/op Benchmark_____________PubSub-16 15345950 229.9 ns/op Benchmark_____________PubSub-16 15393776 230.8 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15590626 228.5 ns/op Benchmark_____PubSubTwoConns-16 15344184 229.4 ns/op Benchmark_____PubSubTwoConns-16 15492536 229.2 ns/op Benchmark_____PubSubTwoConns-16 15427932 228.1 ns/op Benchmark_____PubSubTwoConns-16 15562114 229.0 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:39618->127.0.0.1:39231: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:60252->127.0.0.1:39463: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:56724->127.0.0.1:41741: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41542->127.0.0.1:35877: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:44668->127.0.0.1:45645: 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 14393409 247.9 ns/op Benchmark_____PubTwoQueueSub-16 14247068 247.9 ns/op Benchmark_____PubTwoQueueSub-16 14241027 247.5 ns/op Benchmark_____PubTwoQueueSub-16 14280493 247.9 ns/op Benchmark_____PubTwoQueueSub-16 14275356 248.2 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14433350 248.1 ns/op Benchmark____PubFourQueueSub-16 14443290 247.7 ns/op Benchmark____PubFourQueueSub-16 14217037 248.6 ns/op Benchmark____PubFourQueueSub-16 14247981 248.0 ns/op Benchmark____PubFourQueueSub-16 14243505 247.9 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14201109 248.9 ns/op Benchmark___PubEightQueueSub-16 14321674 248.9 ns/op Benchmark___PubEightQueueSub-16 14396652 249.2 ns/op Benchmark___PubEightQueueSub-16 14343986 248.8 ns/op Benchmark___PubEightQueueSub-16 14311483 248.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23250 155782 ns/op Benchmark_PubSub512kTwoConns-16 22980 155572 ns/op Benchmark_PubSub512kTwoConns-16 23210 155322 ns/op Benchmark_PubSub512kTwoConns-16 23284 155464 ns/op Benchmark_PubSub512kTwoConns-16 23097 155887 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15009465 232.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 14885384 232.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 14980946 230.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 14969199 231.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15089812 230.2 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15146256 231.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 14964835 231.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 14960703 232.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15194352 230.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15021231 232.6 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11630023 311.6 ns/op Benchmark____RoutedPubSub_0b-16 11614371 318.8 ns/op Benchmark____RoutedPubSub_0b-16 11222884 309.9 ns/op Benchmark____RoutedPubSub_0b-16 11300959 315.0 ns/op Benchmark____RoutedPubSub_0b-16 10981396 314.6 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6513421 531.9 ns/op Benchmark____RoutedPubSub_1K-16 6470858 533.7 ns/op Benchmark____RoutedPubSub_1K-16 6760118 540.2 ns/op Benchmark____RoutedPubSub_1K-16 6795272 543.4 ns/op Benchmark____RoutedPubSub_1K-16 6672176 532.2 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 83868 42839 ns/op Benchmark__RoutedPubSub_100K-16 83696 42114 ns/op Benchmark__RoutedPubSub_100K-16 86896 42138 ns/op Benchmark__RoutedPubSub_100K-16 87712 43335 ns/op Benchmark__RoutedPubSub_100K-16 73984 49262 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9684687 317.9 ns/op Benchmark____Routed2QueueSub-16 9747013 314.4 ns/op Benchmark____Routed2QueueSub-16 9602432 318.0 ns/op Benchmark____Routed2QueueSub-16 9797470 314.8 ns/op Benchmark____Routed2QueueSub-16 9861007 319.5 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9386226 323.2 ns/op Benchmark____Routed4QueueSub-16 11301673 327.3 ns/op Benchmark____Routed4QueueSub-16 9424071 325.6 ns/op Benchmark____Routed4QueueSub-16 9562746 315.4 ns/op Benchmark____Routed4QueueSub-16 10979865 321.7 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9152206 328.3 ns/op Benchmark____Routed8QueueSub-16 9126049 332.3 ns/op Benchmark____Routed8QueueSub-16 11059788 326.6 ns/op Benchmark____Routed8QueueSub-16 10951592 324.9 ns/op Benchmark____Routed8QueueSub-16 9551449 324.4 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 9033703 351.3 ns/op Benchmark___Routed16QueueSub-16 8944141 342.8 ns/op Benchmark___Routed16QueueSub-16 8495257 355.5 ns/op Benchmark___Routed16QueueSub-16 9004458 346.5 ns/op Benchmark___Routed16QueueSub-16 8863408 346.0 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6280992 548.9 ns/op Benchmark____________RouteCompressOff-16 6479389 548.9 ns/op Benchmark____________RouteCompressOff-16 6441886 548.8 ns/op Benchmark____________RouteCompressOff-16 6324954 555.0 ns/op Benchmark____________RouteCompressOff-16 6557068 544.6 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6428565 556.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6534778 546.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6565456 548.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6527623 550.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6468530 550.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6486474 551.7 ns/op Benchmark_________RouteCompressS2Fast-16 6520066 551.4 ns/op Benchmark_________RouteCompressS2Fast-16 6429184 547.0 ns/op Benchmark_________RouteCompressS2Fast-16 6400437 550.0 ns/op Benchmark_________RouteCompressS2Fast-16 6477646 553.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6556810 551.4 ns/op Benchmark_______RouteCompressS2Better-16 6272197 557.0 ns/op Benchmark_______RouteCompressS2Better-16 6426310 543.0 ns/op Benchmark_______RouteCompressS2Better-16 6327574 542.6 ns/op Benchmark_______RouteCompressS2Better-16 6539028 550.9 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6423894 551.2 ns/op Benchmark_________RouteCompressS2Best-16 6548784 547.0 ns/op Benchmark_________RouteCompressS2Best-16 6559966 541.8 ns/op Benchmark_________RouteCompressS2Best-16 6327216 549.1 ns/op Benchmark_________RouteCompressS2Best-16 6354948 546.7 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4714108 773.4 ns/op 321.96 MB/s Benchmark______FanOut_8x1x10-16 4722297 763.4 ns/op 326.19 MB/s Benchmark______FanOut_8x1x10-16 4705650 761.6 ns/op 326.95 MB/s Benchmark______FanOut_8x1x10-16 4635186 762.1 ns/op 326.72 MB/s Benchmark______FanOut_8x1x10-16 4711922 768.6 ns/op 323.98 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 563162 6002 ns/op 386.35 MB/s Benchmark_____FanOut_8x1x100-16 555463 6021 ns/op 385.18 MB/s Benchmark_____FanOut_8x1x100-16 552262 6056 ns/op 382.92 MB/s Benchmark_____FanOut_8x1x100-16 550513 6155 ns/op 376.79 MB/s Benchmark_____FanOut_8x1x100-16 545208 6071 ns/op 381.99 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47647 73947 ns/op 311.29 MB/s Benchmark____FanOut_8x10x100-16 47734 74089 ns/op 310.69 MB/s Benchmark____FanOut_8x10x100-16 48403 74107 ns/op 310.62 MB/s Benchmark____FanOut_8x10x100-16 48462 74006 ns/op 311.04 MB/s Benchmark____FanOut_8x10x100-16 48614 73803 ns/op 311.90 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5823 593934 ns/op 404.12 MB/s Benchmark___FanOut_8x10x1000-16 5875 589238 ns/op 407.34 MB/s Benchmark___FanOut_8x10x1000-16 5766 595080 ns/op 403.34 MB/s Benchmark___FanOut_8x10x1000-16 6002 594168 ns/op 403.96 MB/s Benchmark___FanOut_8x10x1000-16 5971 590751 ns/op 406.29 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5059 701017 ns/op 328.12 MB/s Benchmark___FanOut_8x100x100-16 5071 700460 ns/op 328.38 MB/s Benchmark___FanOut_8x100x100-16 5088 700338 ns/op 328.44 MB/s Benchmark___FanOut_8x100x100-16 4992 701893 ns/op 327.71 MB/s Benchmark___FanOut_8x100x100-16 5066 700442 ns/op 328.39 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 560 6074100 ns/op 395.12 MB/s Benchmark__FanOut_8x100x1000-16 586 6063639 ns/op 395.81 MB/s Benchmark__FanOut_8x100x1000-16 566 6045839 ns/op 396.97 MB/s Benchmark__FanOut_8x100x1000-16 585 6105321 ns/op 393.10 MB/s Benchmark__FanOut_8x100x1000-16 585 6112682 ns/op 392.63 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 535 6645934 ns/op 376.17 MB/s Benchmark__FanOut_8x10x10000-16 526 6558962 ns/op 381.16 MB/s Benchmark__FanOut_8x10x10000-16 542 6566408 ns/op 380.73 MB/s Benchmark__FanOut_8x10x10000-16 541 6695850 ns/op 373.37 MB/s Benchmark__FanOut_8x10x10000-16 535 6620963 ns/op 377.59 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 944 3714022 ns/op 309.64 MB/s Benchmark___FanOut_8x500x100-16 961 3716613 ns/op 309.43 MB/s Benchmark___FanOut_8x500x100-16 957 3719225 ns/op 309.21 MB/s Benchmark___FanOut_8x500x100-16 956 3767578 ns/op 305.24 MB/s Benchmark___FanOut_8x500x100-16 964 3719538 ns/op 309.18 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 369458 9448 ns/op 1549.58 MB/s Benchmark___FanOut_128x1x100-16 357835 9458 ns/op 1548.01 MB/s Benchmark___FanOut_128x1x100-16 383854 9434 ns/op 1551.93 MB/s Benchmark___FanOut_128x1x100-16 370784 9457 ns/op 1548.13 MB/s Benchmark___FanOut_128x1x100-16 367381 9436 ns/op 1551.67 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32599 109684 ns/op 1323.26 MB/s Benchmark__FanOut_128x10x100-16 32664 109329 ns/op 1327.56 MB/s Benchmark__FanOut_128x10x100-16 32773 109345 ns/op 1327.37 MB/s Benchmark__FanOut_128x10x100-16 32770 110082 ns/op 1318.49 MB/s Benchmark__FanOut_128x10x100-16 32850 109384 ns/op 1326.89 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4124 867013 ns/op 1684.10 MB/s Benchmark_FanOut_128x10x1000-16 4077 863470 ns/op 1691.02 MB/s Benchmark_FanOut_128x10x1000-16 3884 877886 ns/op 1663.25 MB/s Benchmark_FanOut_128x10x1000-16 4287 858588 ns/op 1700.63 MB/s Benchmark_FanOut_128x10x1000-16 3908 859273 ns/op 1699.28 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3501 1000752 ns/op 1449.05 MB/s Benchmark_FanOut_128x100x100-16 3538 1003522 ns/op 1445.05 MB/s Benchmark_FanOut_128x100x100-16 3542 1000573 ns/op 1449.31 MB/s Benchmark_FanOut_128x100x100-16 3555 1003096 ns/op 1445.67 MB/s Benchmark_FanOut_128x100x100-16 3483 1015396 ns/op 1428.15 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 400 9158878 ns/op 1594.10 MB/s BenchmarkFanOut_128x100x1000-16 387 9218809 ns/op 1583.73 MB/s BenchmarkFanOut_128x100x1000-16 399 9136225 ns/op 1598.05 MB/s BenchmarkFanOut_128x100x1000-16 391 9183580 ns/op 1589.81 MB/s BenchmarkFanOut_128x100x1000-16 392 9201751 ns/op 1586.67 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 374 9485120 ns/op 1549.81 MB/s BenchmarkFanOut_128x10x10000-16 378 9503819 ns/op 1546.76 MB/s BenchmarkFanOut_128x10x10000-16 375 9499214 ns/op 1547.51 MB/s BenchmarkFanOut_128x10x10000-16 376 9584070 ns/op 1533.81 MB/s BenchmarkFanOut_128x10x10000-16 381 9642106 ns/op 1524.58 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 688 5216257 ns/op 1389.91 MB/s BenchmarkFanOut__128x500x100-16 676 5207635 ns/op 1392.21 MB/s BenchmarkFanOut__128x500x100-16 678 5202289 ns/op 1393.64 MB/s BenchmarkFanOut__128x500x100-16 685 5233549 ns/op 1385.32 MB/s BenchmarkFanOut__128x500x100-16 682 5208915 ns/op 1391.87 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1953 1821839 ns/op 2903.95 MB/s Benchmark_FanOut_512x100x100-16 1935 1797482 ns/op 2943.30 MB/s Benchmark_FanOut_512x100x100-16 1945 1828031 ns/op 2894.11 MB/s Benchmark_FanOut_512x100x100-16 1965 1823629 ns/op 2901.10 MB/s Benchmark_FanOut_512x100x100-16 1927 1829945 ns/op 2891.08 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16779523 ns/op 3158.64 MB/s Benchmark__FanOut_512x100x1k-16 218 16644748 ns/op 3184.22 MB/s Benchmark__FanOut_512x100x1k-16 216 16562769 ns/op 3199.98 MB/s Benchmark__FanOut_512x100x1k-16 214 16456298 ns/op 3220.68 MB/s Benchmark__FanOut_512x100x1k-16 217 16540427 ns/op 3204.30 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2950 1142903 ns/op 9126.79 MB/s Benchmark____FanOut_1kx10x1k-16 2700 1143886 ns/op 9118.95 MB/s Benchmark____FanOut_1kx10x1k-16 3098 1142886 ns/op 9126.93 MB/s Benchmark____FanOut_1kx10x1k-16 2936 1150472 ns/op 9066.75 MB/s Benchmark____FanOut_1kx10x1k-16 2706 1146618 ns/op 9097.22 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2757 1255681 ns/op 8299.11 MB/s Benchmark__FanOut_1kx100x100-16 2818 1245949 ns/op 8363.94 MB/s Benchmark__FanOut_1kx100x100-16 2838 1257498 ns/op 8287.12 MB/s Benchmark__FanOut_1kx100x100-16 2787 1250083 ns/op 8336.28 MB/s Benchmark__FanOut_1kx100x100-16 2787 1247075 ns/op 8356.38 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4547216 786.2 ns/op 316.71 MB/s Benchmark_____RFanOut_8x1x10-16 4385550 757.3 ns/op 328.82 MB/s Benchmark_____RFanOut_8x1x10-16 4340000 771.3 ns/op 322.81 MB/s Benchmark_____RFanOut_8x1x10-16 4526755 764.2 ns/op 325.84 MB/s Benchmark_____RFanOut_8x1x10-16 4361526 767.9 ns/op 324.25 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 526574 6627 ns/op 349.92 MB/s Benchmark____RFanOut_8x1x100-16 521912 6362 ns/op 364.53 MB/s Benchmark____RFanOut_8x1x100-16 555717 6285 ns/op 368.98 MB/s Benchmark____RFanOut_8x1x100-16 531518 6350 ns/op 365.19 MB/s Benchmark____RFanOut_8x1x100-16 528078 6073 ns/op 381.88 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48514 73924 ns/op 311.39 MB/s Benchmark___RFanOut_8x10x100-16 48171 74031 ns/op 310.94 MB/s Benchmark___RFanOut_8x10x100-16 47995 74370 ns/op 309.52 MB/s Benchmark___RFanOut_8x10x100-16 48307 73962 ns/op 311.23 MB/s Benchmark___RFanOut_8x10x100-16 48349 74105 ns/op 310.63 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5754 607005 ns/op 395.42 MB/s Benchmark__RFanOut_8x10x1000-16 5820 591067 ns/op 406.08 MB/s Benchmark__RFanOut_8x10x1000-16 5965 596680 ns/op 402.26 MB/s Benchmark__RFanOut_8x10x1000-16 6112 591803 ns/op 405.57 MB/s Benchmark__RFanOut_8x10x1000-16 5900 597489 ns/op 401.71 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5018 702004 ns/op 327.66 MB/s Benchmark__RFanOut_8x100x100-16 5035 701442 ns/op 327.92 MB/s Benchmark__RFanOut_8x100x100-16 5032 701535 ns/op 327.88 MB/s Benchmark__RFanOut_8x100x100-16 4996 701471 ns/op 327.91 MB/s Benchmark__RFanOut_8x100x100-16 4903 701982 ns/op 327.67 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 556 6133418 ns/op 391.30 MB/s Benchmark_RFanOut_8x100x1000-16 573 6100583 ns/op 393.41 MB/s Benchmark_RFanOut_8x100x1000-16 589 6039156 ns/op 397.41 MB/s Benchmark_RFanOut_8x100x1000-16 586 6107775 ns/op 392.94 MB/s Benchmark_RFanOut_8x100x1000-16 584 6104426 ns/op 393.16 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 531 6660076 ns/op 375.37 MB/s Benchmark_RFanOut_8x10x10000-16 522 6697294 ns/op 373.29 MB/s Benchmark_RFanOut_8x10x10000-16 542 6640786 ns/op 376.46 MB/s Benchmark_RFanOut_8x10x10000-16 529 6686647 ns/op 373.88 MB/s Benchmark_RFanOut_8x10x10000-16 531 6671606 ns/op 374.73 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3158 1134749 ns/op 9192.38 MB/s Benchmark_RFanOut_1kx10x1000-16 3126 1124105 ns/op 9279.42 MB/s Benchmark_RFanOut_1kx10x1000-16 3159 1149834 ns/op 9071.78 MB/s Benchmark_RFanOut_1kx10x1000-16 2776 1148283 ns/op 9084.03 MB/s Benchmark_RFanOut_1kx10x1000-16 3032 1150519 ns/op 9066.38 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7035514 502.1 ns/op 4138.74 MB/s Benchmark_____FanIn_1kx100x1-16 6916542 503.8 ns/op 4125.01 MB/s Benchmark_____FanIn_1kx100x1-16 6974154 502.8 ns/op 4133.11 MB/s Benchmark_____FanIn_1kx100x1-16 6989493 503.5 ns/op 4127.38 MB/s Benchmark_____FanIn_1kx100x1-16 6924938 503.3 ns/op 4128.38 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2675235 1374 ns/op 5982.06 MB/s Benchmark_____FanIn_4kx100x1-16 2666961 1360 ns/op 6043.72 MB/s Benchmark_____FanIn_4kx100x1-16 2599653 1346 ns/op 6109.28 MB/s Benchmark_____FanIn_4kx100x1-16 2596683 1374 ns/op 5983.86 MB/s Benchmark_____FanIn_4kx100x1-16 2647354 1375 ns/op 5978.78 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1714963 2133 ns/op 7695.69 MB/s Benchmark_____FanIn_8kx100x1-16 1716702 2106 ns/op 7793.73 MB/s Benchmark_____FanIn_8kx100x1-16 1733889 2131 ns/op 7702.69 MB/s Benchmark_____FanIn_8kx100x1-16 1696216 2119 ns/op 7745.93 MB/s Benchmark_____FanIn_8kx100x1-16 1722499 2071 ns/op 7925.28 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 860791 4172 ns/op 7862.77 MB/s Benchmark____FanIn_16kx100x1-16 854164 4117 ns/op 7967.03 MB/s Benchmark____FanIn_16kx100x1-16 870786 4154 ns/op 7895.42 MB/s Benchmark____FanIn_16kx100x1-16 869366 4132 ns/op 7938.73 MB/s Benchmark____FanIn_16kx100x1-16 872474 4109 ns/op 7981.91 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 170482 19987 ns/op 6559.58 MB/s Benchmark____FanIn_64kx100x1-16 156508 19716 ns/op 6649.78 MB/s Benchmark____FanIn_64kx100x1-16 169766 19840 ns/op 6608.03 MB/s Benchmark____FanIn_64kx100x1-16 166690 19693 ns/op 6657.38 MB/s Benchmark____FanIn_64kx100x1-16 158983 19957 ns/op 6569.36 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 104347640 vs 11981626000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:33808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34250->127.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: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:33656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34240->127.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:33648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34156->127.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:33898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34194->127.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:34068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33544->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: 167926290 vs 12073389000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36504->127.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:36790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36756->127.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: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: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:36850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36444->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:36606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36254->127.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:36130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36542->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: 95957880 vs 11680119000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39616->127.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:39512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39024->127.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:38928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39428->127.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:38908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39748->127.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:39604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39148->127.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:39272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39396->127.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:39048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39124->127.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:1096: Received error on PUB write: write tcp 127.0.0.1:39310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39642->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:39198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39044->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: 85601770 vs 9661333000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59706->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: 591346990 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33276->127.0.0.1:5222: write: connection reset by peer 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:33480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33484->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:32980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33394->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33074->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5664616 636.3 ns/op 446.33 MB/s Benchmark___BumpPubCount_1x3-16 5594920 633.8 ns/op 448.10 MB/s Benchmark___BumpPubCount_1x3-16 5634244 634.3 ns/op 447.76 MB/s Benchmark___BumpPubCount_1x3-16 5627760 633.5 ns/op 448.34 MB/s Benchmark___BumpPubCount_1x3-16 5646504 637.8 ns/op 445.28 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5335384 667.2 ns/op 425.66 MB/s Benchmark___BumpPubCount_2x3-16 5388852 671.4 ns/op 423.01 MB/s Benchmark___BumpPubCount_2x3-16 5359201 671.8 ns/op 422.73 MB/s Benchmark___BumpPubCount_2x3-16 5373904 667.7 ns/op 425.33 MB/s Benchmark___BumpPubCount_2x3-16 5342887 670.9 ns/op 423.32 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5590201 637.9 ns/op 445.21 MB/s Benchmark___BumpPubCount_5x3-16 5622847 643.7 ns/op 441.19 MB/s Benchmark___BumpPubCount_5x3-16 5590256 640.8 ns/op 443.22 MB/s Benchmark___BumpPubCount_5x3-16 5596678 649.4 ns/op 437.35 MB/s Benchmark___BumpPubCount_5x3-16 5454111 638.7 ns/op 444.65 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5220121 640.5 ns/op 443.44 MB/s Benchmark__BumpPubCount_10x3-16 5344653 641.6 ns/op 442.65 MB/s Benchmark__BumpPubCount_10x3-16 5651618 641.2 ns/op 442.89 MB/s Benchmark__BumpPubCount_10x3-16 5575384 642.6 ns/op 441.95 MB/s Benchmark__BumpPubCount_10x3-16 5607520 643.2 ns/op 441.56 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12202096 284.6 ns/op 3654.26 MB/s Benchmark____GWs_Opt_1kx01x0-16 12859474 269.4 ns/op 3860.98 MB/s Benchmark____GWs_Opt_1kx01x0-16 13118569 281.2 ns/op 3698.97 MB/s Benchmark____GWs_Opt_1kx01x0-16 12771618 276.0 ns/op 3768.12 MB/s Benchmark____GWs_Opt_1kx01x0-16 11975073 284.4 ns/op 3656.82 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10084842 334.0 ns/op 6179.90 MB/s Benchmark____GWs_Opt_2kx01x0-16 11041300 338.7 ns/op 6094.54 MB/s Benchmark____GWs_Opt_2kx01x0-16 9756832 358.5 ns/op 5756.82 MB/s Benchmark____GWs_Opt_2kx01x0-16 10056956 337.7 ns/op 6111.78 MB/s Benchmark____GWs_Opt_2kx01x0-16 10365520 327.9 ns/op 6295.30 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5633556 633.5 ns/op 6491.00 MB/s Benchmark____GWs_Opt_4kx01x0-16 5813661 623.6 ns/op 6593.91 MB/s Benchmark____GWs_Opt_4kx01x0-16 5852160 609.5 ns/op 6746.83 MB/s Benchmark____GWs_Opt_4kx01x0-16 5573848 630.6 ns/op 6520.59 MB/s Benchmark____GWs_Opt_4kx01x0-16 5575851 619.1 ns/op 6642.31 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30827541 108.2 ns/op 9613.09 MB/s Benchmark____GWs_Opt_1kx10x0-16 31516852 112.5 ns/op 9242.05 MB/s Benchmark____GWs_Opt_1kx10x0-16 32037781 116.2 ns/op 8949.54 MB/s Benchmark____GWs_Opt_1kx10x0-16 28229864 114.2 ns/op 9104.96 MB/s Benchmark____GWs_Opt_1kx10x0-16 31900572 108.1 ns/op 9619.33 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 17965600 169.3 ns/op 12191.19 MB/s Benchmark____GWs_Opt_2kx10x0-16 25028218 147.4 ns/op 14005.90 MB/s Benchmark____GWs_Opt_2kx10x0-16 26329772 142.4 ns/op 14493.96 MB/s Benchmark____GWs_Opt_2kx10x0-16 21190148 148.8 ns/op 13873.19 MB/s Benchmark____GWs_Opt_2kx10x0-16 24223168 162.3 ns/op 12714.65 MB/s Benchmark____GWs_Opt_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:53522->127.0.0.1:43921: 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:59766->127.0.0.1:45161: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 12981541 291.6 ns/op 14101.60 MB/s Benchmark____GWs_Opt_4kx10x0-16 12665007 284.8 ns/op 14436.74 MB/s Benchmark____GWs_Opt_4kx10x0-16 12566112 347.1 ns/op 11847.28 MB/s Benchmark____GWs_Opt_4kx10x0-16 12304227 331.5 ns/op 12402.61 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6421636 545.7 ns/op 5726.91 MB/s Benchmark____GWs_Opt_1kx01x1-16 6516578 540.9 ns/op 5777.17 MB/s Benchmark____GWs_Opt_1kx01x1-16 6520294 543.4 ns/op 5751.05 MB/s Benchmark____GWs_Opt_1kx01x1-16 6330116 546.6 ns/op 5717.51 MB/s Benchmark____GWs_Opt_1kx01x1-16 6784514 538.0 ns/op 5808.97 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4691772 755.1 ns/op 8207.37 MB/s Benchmark____GWs_Opt_2kx01x1-16 4889859 763.1 ns/op 8120.83 MB/s Benchmark____GWs_Opt_2kx01x1-16 4710861 777.0 ns/op 7975.69 MB/s Benchmark____GWs_Opt_2kx01x1-16 4744684 786.8 ns/op 7876.29 MB/s Benchmark____GWs_Opt_2kx01x1-16 4663909 770.0 ns/op 8048.35 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2620674 1385 ns/op 8908.59 MB/s Benchmark____GWs_Opt_4kx01x1-16 2623572 1349 ns/op 9144.97 MB/s Benchmark____GWs_Opt_4kx01x1-16 2641885 1678 ns/op 7354.22 MB/s Benchmark____GWs_Opt_4kx01x1-16 2310625 1347 ns/op 9164.33 MB/s Benchmark____GWs_Opt_4kx01x1-16 2649104 1353 ns/op 9122.48 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6487597 543.8 ns/op 5746.66 MB/s Benchmark____GWs_Opt_1kx10x1-16 6298581 554.6 ns/op 5634.55 MB/s Benchmark____GWs_Opt_1kx10x1-16 6655376 543.9 ns/op 5745.28 MB/s Benchmark____GWs_Opt_1kx10x1-16 6646374 543.0 ns/op 5755.04 MB/s Benchmark____GWs_Opt_1kx10x1-16 6723388 554.1 ns/op 5639.65 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4242234 841.1 ns/op 7367.42 MB/s Benchmark____GWs_Opt_2kx10x1-16 4075948 843.4 ns/op 7347.80 MB/s Benchmark____GWs_Opt_2kx10x1-16 4203316 846.7 ns/op 7318.78 MB/s Benchmark____GWs_Opt_2kx10x1-16 4275775 843.2 ns/op 7349.34 MB/s Benchmark____GWs_Opt_2kx10x1-16 4164843 1174 ns/op 5277.82 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2413035 1693 ns/op 7288.13 MB/s Benchmark____GWs_Opt_4kx10x1-16 2393901 1512 ns/op 8164.26 MB/s Benchmark____GWs_Opt_4kx10x1-16 2348140 1511 ns/op 8166.28 MB/s Benchmark____GWs_Opt_4kx10x1-16 2214944 1573 ns/op 7847.43 MB/s Benchmark____GWs_Opt_4kx10x1-16 2399644 1576 ns/op 7829.69 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12050900 302.1 ns/op 3442.88 MB/s Benchmark____GWs_Int_1kx01x0-16 12448531 283.9 ns/op 3663.76 MB/s Benchmark____GWs_Int_1kx01x0-16 10823572 288.7 ns/op 3601.79 MB/s Benchmark____GWs_Int_1kx01x0-16 12659760 286.9 ns/op 3624.67 MB/s Benchmark____GWs_Int_1kx01x0-16 12525124 283.3 ns/op 3670.96 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9913652 351.1 ns/op 5878.34 MB/s Benchmark____GWs_Int_2kx01x0-16 9919005 360.0 ns/op 5733.84 MB/s Benchmark____GWs_Int_2kx01x0-16 10099483 361.6 ns/op 5707.65 MB/s Benchmark____GWs_Int_2kx01x0-16 9131202 351.1 ns/op 5878.84 MB/s Benchmark____GWs_Int_2kx01x0-16 10503026 354.9 ns/op 5815.55 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5079333 616.6 ns/op 6669.14 MB/s Benchmark____GWs_Int_4kx01x0-16 5690076 621.8 ns/op 6613.50 MB/s Benchmark____GWs_Int_4kx01x0-16 5855838 629.5 ns/op 6532.24 MB/s Benchmark____GWs_Int_4kx01x0-16 5187254 636.5 ns/op 6460.01 MB/s Benchmark____GWs_Int_4kx01x0-16 5770672 675.5 ns/op 6087.78 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31379560 109.3 ns/op 9512.74 MB/s Benchmark____GWs_Int_1kx10x0-16 33222198 112.5 ns/op 9244.10 MB/s Benchmark____GWs_Int_1kx10x0-16 31702216 111.6 ns/op 9318.49 MB/s Benchmark____GWs_Int_1kx10x0-16 30389625 121.3 ns/op 8572.49 MB/s Benchmark____GWs_Int_1kx10x0-16 28700726 111.8 ns/op 9301.06 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24459108 146.5 ns/op 14088.73 MB/s Benchmark____GWs_Int_2kx10x0-16 26291811 158.0 ns/op 13061.28 MB/s Benchmark____GWs_Int_2kx10x0-16 23981224 143.4 ns/op 14398.06 MB/s Benchmark____GWs_Int_2kx10x0-16 21614094 142.6 ns/op 14475.29 MB/s Benchmark____GWs_Int_2kx10x0-16 25530861 142.8 ns/op 14454.68 MB/s Benchmark____GWs_Int_4kx10x0 bench_test.go:55: Failed read: read tcp 127.0.0.1:60712->127.0.0.1:36581: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12808202 333.1 ns/op 12345.08 MB/s Benchmark____GWs_Int_4kx10x0-16 12879301 285.6 ns/op 14400.23 MB/s Benchmark____GWs_Int_4kx10x0-16 12484646 282.9 ns/op 14535.13 MB/s Benchmark____GWs_Int_4kx10x0-16 12244854 298.8 ns/op 13760.14 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6469257 553.9 ns/op 5641.45 MB/s Benchmark____GWs_Int_1kx01x1-16 6312218 553.3 ns/op 5648.32 MB/s Benchmark____GWs_Int_1kx01x1-16 6594158 550.7 ns/op 5674.72 MB/s Benchmark____GWs_Int_1kx01x1-16 6584035 579.4 ns/op 5393.26 MB/s Benchmark____GWs_Int_1kx01x1-16 6565166 559.7 ns/op 5583.00 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4760936 765.8 ns/op 8091.92 MB/s Benchmark____GWs_Int_2kx01x1-16 4851014 760.4 ns/op 8149.38 MB/s Benchmark____GWs_Int_2kx01x1-16 4755472 757.9 ns/op 8176.69 MB/s Benchmark____GWs_Int_2kx01x1-16 4723252 769.3 ns/op 8055.43 MB/s Benchmark____GWs_Int_2kx01x1-16 4794126 770.4 ns/op 8043.50 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2648247 1431 ns/op 8621.24 MB/s Benchmark____GWs_Int_4kx01x1-16 2627269 1362 ns/op 9058.07 MB/s Benchmark____GWs_Int_4kx01x1-16 2571483 1363 ns/op 9051.42 MB/s Benchmark____GWs_Int_4kx01x1-16 2655296 1360 ns/op 9077.36 MB/s Benchmark____GWs_Int_4kx01x1-16 2639227 1556 ns/op 7931.59 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6330172 548.5 ns/op 5697.75 MB/s Benchmark____GWs_Int_1kx10x1-16 6627570 551.7 ns/op 5664.69 MB/s Benchmark____GWs_Int_1kx10x1-16 6182130 593.5 ns/op 5264.99 MB/s Benchmark____GWs_Int_1kx10x1-16 6576249 547.3 ns/op 5709.34 MB/s Benchmark____GWs_Int_1kx10x1-16 6553773 548.9 ns/op 5693.44 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4189728 851.8 ns/op 7275.58 MB/s Benchmark____GWs_Int_2kx10x1-16 4312023 840.6 ns/op 7372.54 MB/s Benchmark____GWs_Int_2kx10x1-16 4133359 833.8 ns/op 7431.96 MB/s Benchmark____GWs_Int_2kx10x1-16 4246536 835.7 ns/op 7415.31 MB/s Benchmark____GWs_Int_2kx10x1-16 4164933 864.7 ns/op 7166.36 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2380819 1518 ns/op 8129.70 MB/s Benchmark____GWs_Int_4kx10x1-16 2423955 1494 ns/op 8258.28 MB/s Benchmark____GWs_Int_4kx10x1-16 2418357 1501 ns/op 8220.34 MB/s Benchmark____GWs_Int_4kx10x1-16 2123896 1482 ns/op 8324.62 MB/s Benchmark____GWs_Int_4kx10x1-16 2253237 1511 ns/op 8169.04 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 7875962 438.6 ns/op 232.56 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8569230 439.8 ns/op 231.90 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8176438 436.7 ns/op 233.55 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8561607 441.6 ns/op 230.99 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8206380 433.5 ns/op 235.27 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 617836 5028 ns/op 35.20 MB/s Benchmark__GWs_Reqs_1SubEach-16 770622 5184 ns/op 34.15 MB/s Benchmark__GWs_Reqs_1SubEach-16 739959 5260 ns/op 33.65 MB/s Benchmark__GWs_Reqs_1SubEach-16 795127 5289 ns/op 33.47 MB/s Benchmark__GWs_Reqs_1SubEach-16 769146 5324 ns/op 33.24 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2133.994s ❌ Non-zero exit code: 1