> ROOT_DIR=/tmp/go-bench-away-job-b9bbd2cb-f2ed-4eef-8226-43463ef3d4f1-2573584272 > OUTPUT_FILE=/tmp/go-bench-away-job-b9bbd2cb-f2ed-4eef-8226-43463ef3d4f1-2573584272/results.txt > SHA_FILE=/tmp/go-bench-away-job-b9bbd2cb-f2ed-4eef-8226-43463ef3d4f1-2573584272/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-b9bbd2cb-f2ed-4eef-8226-43463ef3d4f1-2573584272/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-b9bbd2cb-f2ed-4eef-8226-43463ef3d4f1-2573584272/source.git SHA of main: ab163d5532aa6cd1c18a9bf631938dcf72921746 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-build1022980624=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-b9bbd2cb-f2ed-4eef-8226-43463ef3d4f1-2573584272/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 49389618 72.54 ns/op 151.65 MB/s Benchmark______Pub0b_Payload-16 45273536 72.54 ns/op 151.64 MB/s Benchmark______Pub0b_Payload-16 47052631 72.69 ns/op 151.33 MB/s Benchmark______Pub0b_Payload-16 43467388 75.70 ns/op 145.32 MB/s Benchmark______Pub0b_Payload-16 47039043 72.77 ns/op 151.17 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46519201 73.40 ns/op 258.84 MB/s Benchmark______Pub8b_Payload-16 42978907 73.07 ns/op 260.03 MB/s Benchmark______Pub8b_Payload-16 46298612 73.96 ns/op 256.91 MB/s Benchmark______Pub8b_Payload-16 43104946 73.45 ns/op 258.69 MB/s Benchmark______Pub8b_Payload-16 46500483 73.09 ns/op 259.97 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43896282 82.31 ns/op 534.57 MB/s Benchmark_____Pub32b_Payload-16 45807027 79.18 ns/op 555.72 MB/s Benchmark_____Pub32b_Payload-16 44041851 77.57 ns/op 567.23 MB/s Benchmark_____Pub32b_Payload-16 42653485 79.88 ns/op 550.82 MB/s Benchmark_____Pub32b_Payload-16 43935098 81.63 ns/op 539.04 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39872827 86.15 ns/op 1636.74 MB/s Benchmark____Pub128B_Payload-16 34141107 88.05 ns/op 1601.29 MB/s Benchmark____Pub128B_Payload-16 39767779 88.05 ns/op 1601.39 MB/s Benchmark____Pub128B_Payload-16 38850628 87.37 ns/op 1613.90 MB/s Benchmark____Pub128B_Payload-16 35790988 87.19 ns/op 1617.07 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36985372 94.33 ns/op 2851.64 MB/s Benchmark____Pub256B_Payload-16 36620761 96.71 ns/op 2781.50 MB/s Benchmark____Pub256B_Payload-16 34873561 97.94 ns/op 2746.48 MB/s Benchmark____Pub256B_Payload-16 35601553 103.0 ns/op 2612.00 MB/s Benchmark____Pub256B_Payload-16 35569544 96.52 ns/op 2786.88 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24851380 135.8 ns/op 7643.52 MB/s Benchmark______Pub1K_Payload-16 23890207 135.7 ns/op 7646.57 MB/s Benchmark______Pub1K_Payload-16 26155280 145.8 ns/op 7118.20 MB/s Benchmark______Pub1K_Payload-16 25274163 140.6 ns/op 7381.24 MB/s Benchmark______Pub1K_Payload-16 21329505 146.6 ns/op 7079.21 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5649604 616.4 ns/op 6667.88 MB/s Benchmark______Pub4K_Payload-16 5573208 624.9 ns/op 6576.80 MB/s Benchmark______Pub4K_Payload-16 5590497 618.6 ns/op 6644.00 MB/s Benchmark______Pub4K_Payload-16 5614383 610.0 ns/op 6737.32 MB/s Benchmark______Pub4K_Payload-16 5339007 633.9 ns/op 6483.95 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2702890 1282 ns/op 6401.20 MB/s Benchmark______Pub8K_Payload-16 2775253 1268 ns/op 6469.61 MB/s Benchmark______Pub8K_Payload-16 2744054 1281 ns/op 6404.42 MB/s Benchmark______Pub8K_Payload-16 2799528 1271 ns/op 6454.58 MB/s Benchmark______Pub8K_Payload-16 2753614 1290 ns/op 6360.33 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 637672 5463 ns/op 6001.21 MB/s Benchmark_____Pub32K_Payload-16 532513 8512 ns/op 3851.46 MB/s Benchmark_____Pub32K_Payload-16 659278 5358 ns/op 6118.19 MB/s Benchmark_____Pub32K_Payload-16 657416 5405 ns/op 6065.18 MB/s Benchmark_____Pub32K_Payload-16 678277 5525 ns/op 5933.41 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32303528 94.19 ns/op 116.78 MB/s Benchmark__AuthPub0b_Payload-16 32642541 93.90 ns/op 117.15 MB/s Benchmark__AuthPub0b_Payload-16 36519656 93.75 ns/op 117.33 MB/s Benchmark__AuthPub0b_Payload-16 34849015 93.66 ns/op 117.44 MB/s Benchmark__AuthPub0b_Payload-16 36296821 94.50 ns/op 116.41 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15402592 229.4 ns/op Benchmark_____________PubSub-16 15373222 229.5 ns/op Benchmark_____________PubSub-16 15508093 229.6 ns/op Benchmark_____________PubSub-16 15565848 229.5 ns/op Benchmark_____________PubSub-16 15227740 230.0 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15378592 227.2 ns/op Benchmark_____PubSubTwoConns-16 15512008 227.6 ns/op Benchmark_____PubSubTwoConns-16 15578911 227.8 ns/op Benchmark_____PubSubTwoConns-16 15559118 228.3 ns/op Benchmark_____PubSubTwoConns-16 15576376 229.0 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51968->127.0.0.1:35789: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51850->127.0.0.1:42805: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41270->127.0.0.1:42959: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58256->127.0.0.1:41779: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33452->127.0.0.1:34247: 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 14340171 246.9 ns/op Benchmark_____PubTwoQueueSub-16 14305960 246.8 ns/op Benchmark_____PubTwoQueueSub-16 14406262 246.4 ns/op Benchmark_____PubTwoQueueSub-16 14324678 247.4 ns/op Benchmark_____PubTwoQueueSub-16 14289058 247.8 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14486894 247.1 ns/op Benchmark____PubFourQueueSub-16 14318170 248.1 ns/op Benchmark____PubFourQueueSub-16 14393914 246.8 ns/op Benchmark____PubFourQueueSub-16 14173404 248.0 ns/op Benchmark____PubFourQueueSub-16 14263830 248.6 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14330384 247.9 ns/op Benchmark___PubEightQueueSub-16 14411238 247.6 ns/op Benchmark___PubEightQueueSub-16 14297240 247.5 ns/op Benchmark___PubEightQueueSub-16 14334770 247.7 ns/op Benchmark___PubEightQueueSub-16 14335194 247.8 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23196 154217 ns/op bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 5152899024 vs 5243080000 --- FAIL: Benchmark_PubSub512kTwoConns-16 Benchmark_PubSub512kTwoConns-16 22657 158618 ns/op Benchmark_PubSub512kTwoConns-16 22718 158732 ns/op Benchmark_PubSub512kTwoConns-16 22756 159541 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15193057 231.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15081025 231.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15186216 233.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15111019 231.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 14946558 232.0 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15006908 232.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15169189 229.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 14916742 232.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 14949118 232.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 14971621 231.9 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11440628 317.5 ns/op Benchmark____RoutedPubSub_0b-16 11436650 315.2 ns/op Benchmark____RoutedPubSub_0b-16 11173009 322.0 ns/op Benchmark____RoutedPubSub_0b-16 11297367 321.6 ns/op Benchmark____RoutedPubSub_0b-16 11242111 317.7 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6701355 540.6 ns/op Benchmark____RoutedPubSub_1K-16 6500738 537.6 ns/op Benchmark____RoutedPubSub_1K-16 6565327 541.5 ns/op Benchmark____RoutedPubSub_1K-16 6651774 540.4 ns/op Benchmark____RoutedPubSub_1K-16 6671786 537.9 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 80205 43500 ns/op Benchmark__RoutedPubSub_100K-16 82474 43020 ns/op Benchmark__RoutedPubSub_100K-16 81614 45300 ns/op Benchmark__RoutedPubSub_100K-16 81074 44572 ns/op Benchmark__RoutedPubSub_100K-16 79533 44594 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9965073 320.8 ns/op Benchmark____Routed2QueueSub-16 9650179 312.5 ns/op Benchmark____Routed2QueueSub-16 9673827 320.9 ns/op Benchmark____Routed2QueueSub-16 9640944 320.3 ns/op Benchmark____Routed2QueueSub-16 9733761 311.9 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9435969 320.0 ns/op Benchmark____Routed4QueueSub-16 9619094 319.6 ns/op Benchmark____Routed4QueueSub-16 9505754 319.9 ns/op Benchmark____Routed4QueueSub-16 9799080 325.1 ns/op Benchmark____Routed4QueueSub-16 9645372 328.6 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9282295 325.0 ns/op Benchmark____Routed8QueueSub-16 11042624 322.8 ns/op Benchmark____Routed8QueueSub-16 9283092 330.0 ns/op Benchmark____Routed8QueueSub-16 9397185 324.1 ns/op Benchmark____Routed8QueueSub-16 9268476 324.6 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8778763 343.8 ns/op Benchmark___Routed16QueueSub-16 8751846 346.7 ns/op Benchmark___Routed16QueueSub-16 8652939 351.1 ns/op Benchmark___Routed16QueueSub-16 9006513 348.8 ns/op Benchmark___Routed16QueueSub-16 8836618 341.1 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6385686 557.9 ns/op Benchmark____________RouteCompressOff-16 6335832 557.4 ns/op Benchmark____________RouteCompressOff-16 6442432 555.8 ns/op Benchmark____________RouteCompressOff-16 6182594 553.4 ns/op Benchmark____________RouteCompressOff-16 6638704 547.1 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6251227 554.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6519255 553.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6529971 554.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6354914 557.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6434426 552.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6544896 559.4 ns/op Benchmark_________RouteCompressS2Fast-16 6410058 550.9 ns/op Benchmark_________RouteCompressS2Fast-16 6269436 554.0 ns/op Benchmark_________RouteCompressS2Fast-16 6482881 556.9 ns/op Benchmark_________RouteCompressS2Fast-16 6402531 563.0 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6170984 554.8 ns/op Benchmark_______RouteCompressS2Better-16 6353780 549.8 ns/op Benchmark_______RouteCompressS2Better-16 6524186 551.4 ns/op Benchmark_______RouteCompressS2Better-16 6482090 548.8 ns/op Benchmark_______RouteCompressS2Better-16 6223896 549.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6487014 557.8 ns/op Benchmark_________RouteCompressS2Best-16 6491120 549.1 ns/op Benchmark_________RouteCompressS2Best-16 6587079 547.6 ns/op Benchmark_________RouteCompressS2Best-16 6458082 546.3 ns/op Benchmark_________RouteCompressS2Best-16 6668179 545.6 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4633569 775.3 ns/op 321.17 MB/s Benchmark______FanOut_8x1x10-16 4632369 771.8 ns/op 322.62 MB/s Benchmark______FanOut_8x1x10-16 4614446 773.9 ns/op 321.74 MB/s Benchmark______FanOut_8x1x10-16 4641652 775.6 ns/op 321.03 MB/s Benchmark______FanOut_8x1x10-16 4635823 774.6 ns/op 321.46 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 541812 6169 ns/op 375.90 MB/s Benchmark_____FanOut_8x1x100-16 524074 6171 ns/op 375.80 MB/s Benchmark_____FanOut_8x1x100-16 519326 6286 ns/op 368.94 MB/s Benchmark_____FanOut_8x1x100-16 548856 6241 ns/op 371.59 MB/s Benchmark_____FanOut_8x1x100-16 560217 6274 ns/op 369.62 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47598 75160 ns/op 306.27 MB/s Benchmark____FanOut_8x10x100-16 47541 75354 ns/op 305.48 MB/s Benchmark____FanOut_8x10x100-16 47722 75460 ns/op 305.05 MB/s Benchmark____FanOut_8x10x100-16 47671 75551 ns/op 304.68 MB/s Benchmark____FanOut_8x10x100-16 47565 75481 ns/op 304.97 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5762 609713 ns/op 393.66 MB/s Benchmark___FanOut_8x10x1000-16 5815 606338 ns/op 395.85 MB/s Benchmark___FanOut_8x10x1000-16 5817 659526 ns/op 363.93 MB/s Benchmark___FanOut_8x10x1000-16 5706 609793 ns/op 393.61 MB/s Benchmark___FanOut_8x10x1000-16 5700 611712 ns/op 392.37 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4902 718437 ns/op 320.17 MB/s Benchmark___FanOut_8x100x100-16 4872 722078 ns/op 318.55 MB/s Benchmark___FanOut_8x100x100-16 4909 720698 ns/op 319.16 MB/s Benchmark___FanOut_8x100x100-16 4846 719403 ns/op 319.74 MB/s Benchmark___FanOut_8x100x100-16 4945 720738 ns/op 319.14 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 562 6360277 ns/op 377.35 MB/s Benchmark__FanOut_8x100x1000-16 565 6379341 ns/op 376.22 MB/s Benchmark__FanOut_8x100x1000-16 544 6328988 ns/op 379.21 MB/s Benchmark__FanOut_8x100x1000-16 549 6354614 ns/op 377.68 MB/s Benchmark__FanOut_8x100x1000-16 560 6343624 ns/op 378.34 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 517 6916867 ns/op 361.44 MB/s Benchmark__FanOut_8x10x10000-16 516 6903640 ns/op 362.13 MB/s Benchmark__FanOut_8x10x10000-16 530 6794908 ns/op 367.93 MB/s Benchmark__FanOut_8x10x10000-16 523 6819874 ns/op 366.58 MB/s Benchmark__FanOut_8x10x10000-16 516 6824227 ns/op 366.34 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 922 3816205 ns/op 301.35 MB/s Benchmark___FanOut_8x500x100-16 934 3827096 ns/op 300.49 MB/s Benchmark___FanOut_8x500x100-16 927 3818786 ns/op 301.15 MB/s Benchmark___FanOut_8x500x100-16 925 3827212 ns/op 300.48 MB/s Benchmark___FanOut_8x500x100-16 932 3827494 ns/op 300.46 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 359908 9554 ns/op 1532.40 MB/s Benchmark___FanOut_128x1x100-16 365574 9598 ns/op 1525.50 MB/s Benchmark___FanOut_128x1x100-16 354033 9638 ns/op 1519.11 MB/s Benchmark___FanOut_128x1x100-16 361908 9522 ns/op 1537.53 MB/s Benchmark___FanOut_128x1x100-16 361718 9575 ns/op 1529.13 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32130 112143 ns/op 1294.25 MB/s Benchmark__FanOut_128x10x100-16 32238 112150 ns/op 1294.17 MB/s Benchmark__FanOut_128x10x100-16 32080 111665 ns/op 1299.79 MB/s Benchmark__FanOut_128x10x100-16 32502 111410 ns/op 1302.76 MB/s Benchmark__FanOut_128x10x100-16 32384 111960 ns/op 1296.36 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3927 891888 ns/op 1637.14 MB/s Benchmark_FanOut_128x10x1000-16 3870 894313 ns/op 1632.70 MB/s Benchmark_FanOut_128x10x1000-16 3753 892900 ns/op 1635.28 MB/s Benchmark_FanOut_128x10x1000-16 4050 885033 ns/op 1649.82 MB/s Benchmark_FanOut_128x10x1000-16 3969 889778 ns/op 1641.02 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3547 1022065 ns/op 1418.83 MB/s Benchmark_FanOut_128x100x100-16 3465 1026047 ns/op 1413.33 MB/s Benchmark_FanOut_128x100x100-16 3498 1021922 ns/op 1419.03 MB/s Benchmark_FanOut_128x100x100-16 3457 1023299 ns/op 1417.12 MB/s Benchmark_FanOut_128x100x100-16 3523 1024139 ns/op 1415.96 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 372 9532162 ns/op 1531.67 MB/s BenchmarkFanOut_128x100x1000-16 378 9499682 ns/op 1536.91 MB/s BenchmarkFanOut_128x100x1000-16 375 9417440 ns/op 1550.33 MB/s BenchmarkFanOut_128x100x1000-16 372 9527255 ns/op 1532.46 MB/s BenchmarkFanOut_128x100x1000-16 380 9466210 ns/op 1542.34 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 364 9836683 ns/op 1494.42 MB/s BenchmarkFanOut_128x10x10000-16 367 9794147 ns/op 1500.91 MB/s BenchmarkFanOut_128x10x10000-16 366 9789598 ns/op 1501.61 MB/s BenchmarkFanOut_128x10x10000-16 368 9755544 ns/op 1506.85 MB/s BenchmarkFanOut_128x10x10000-16 366 9740768 ns/op 1509.14 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 658 5375195 ns/op 1348.81 MB/s BenchmarkFanOut__128x500x100-16 664 5361524 ns/op 1352.25 MB/s BenchmarkFanOut__128x500x100-16 661 5339188 ns/op 1357.91 MB/s BenchmarkFanOut__128x500x100-16 660 5334574 ns/op 1359.09 MB/s BenchmarkFanOut__128x500x100-16 667 5344626 ns/op 1356.53 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1934 1851804 ns/op 2856.96 MB/s Benchmark_FanOut_512x100x100-16 1944 1858910 ns/op 2846.04 MB/s Benchmark_FanOut_512x100x100-16 1933 1852085 ns/op 2856.52 MB/s Benchmark_FanOut_512x100x100-16 1911 1859742 ns/op 2844.76 MB/s Benchmark_FanOut_512x100x100-16 1932 1868273 ns/op 2831.77 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 16904107 ns/op 3135.36 MB/s Benchmark__FanOut_512x100x1k-16 213 17102539 ns/op 3098.99 MB/s Benchmark__FanOut_512x100x1k-16 213 16963852 ns/op 3124.32 MB/s Benchmark__FanOut_512x100x1k-16 212 17014720 ns/op 3114.98 MB/s Benchmark__FanOut_512x100x1k-16 212 16829472 ns/op 3149.27 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3232 1157657 ns/op 9010.48 MB/s Benchmark____FanOut_1kx10x1k-16 2950 1161619 ns/op 8979.74 MB/s Benchmark____FanOut_1kx10x1k-16 3168 1151688 ns/op 9057.17 MB/s Benchmark____FanOut_1kx10x1k-16 3122 1158237 ns/op 9005.97 MB/s Benchmark____FanOut_1kx10x1k-16 3014 1160787 ns/op 8986.18 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2713 1267829 ns/op 8219.59 MB/s Benchmark__FanOut_1kx100x100-16 2784 1269098 ns/op 8211.38 MB/s Benchmark__FanOut_1kx100x100-16 2757 1271111 ns/op 8198.37 MB/s Benchmark__FanOut_1kx100x100-16 2754 1264436 ns/op 8241.65 MB/s Benchmark__FanOut_1kx100x100-16 2738 1267323 ns/op 8222.87 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4447813 777.2 ns/op 320.40 MB/s Benchmark_____RFanOut_8x1x10-16 4601300 788.3 ns/op 315.87 MB/s Benchmark_____RFanOut_8x1x10-16 4459197 775.2 ns/op 321.19 MB/s Benchmark_____RFanOut_8x1x10-16 4356535 779.9 ns/op 319.28 MB/s Benchmark_____RFanOut_8x1x10-16 4528850 806.9 ns/op 308.59 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 521238 6293 ns/op 368.51 MB/s Benchmark____RFanOut_8x1x100-16 524402 6216 ns/op 373.07 MB/s Benchmark____RFanOut_8x1x100-16 509509 6242 ns/op 371.51 MB/s Benchmark____RFanOut_8x1x100-16 509151 6591 ns/op 351.82 MB/s Benchmark____RFanOut_8x1x100-16 527053 6281 ns/op 369.18 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47607 77362 ns/op 297.55 MB/s Benchmark___RFanOut_8x10x100-16 47816 75267 ns/op 305.83 MB/s Benchmark___RFanOut_8x10x100-16 46950 75118 ns/op 306.44 MB/s Benchmark___RFanOut_8x10x100-16 47910 75532 ns/op 304.76 MB/s Benchmark___RFanOut_8x10x100-16 47990 75030 ns/op 306.80 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5674 623296 ns/op 385.08 MB/s Benchmark__RFanOut_8x10x1000-16 5533 627197 ns/op 382.68 MB/s Benchmark__RFanOut_8x10x1000-16 5604 607564 ns/op 395.05 MB/s Benchmark__RFanOut_8x10x1000-16 5742 630909 ns/op 380.43 MB/s Benchmark__RFanOut_8x10x1000-16 5808 606100 ns/op 396.01 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4941 725080 ns/op 317.23 MB/s Benchmark__RFanOut_8x100x100-16 4917 712443 ns/op 322.86 MB/s Benchmark__RFanOut_8x100x100-16 4954 711195 ns/op 323.43 MB/s Benchmark__RFanOut_8x100x100-16 4891 722232 ns/op 318.48 MB/s Benchmark__RFanOut_8x100x100-16 4876 719549 ns/op 319.67 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 559 6528101 ns/op 367.64 MB/s Benchmark_RFanOut_8x100x1000-16 542 6270467 ns/op 382.75 MB/s Benchmark_RFanOut_8x100x1000-16 562 6396905 ns/op 375.18 MB/s Benchmark_RFanOut_8x100x1000-16 542 6262740 ns/op 383.22 MB/s Benchmark_RFanOut_8x100x1000-16 550 6266830 ns/op 382.97 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 506 6784885 ns/op 368.47 MB/s Benchmark_RFanOut_8x10x10000-16 526 6768394 ns/op 369.37 MB/s Benchmark_RFanOut_8x10x10000-16 518 6806206 ns/op 367.31 MB/s Benchmark_RFanOut_8x10x10000-16 516 6781740 ns/op 368.64 MB/s Benchmark_RFanOut_8x10x10000-16 512 7066531 ns/op 353.78 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3034 1155268 ns/op 9029.10 MB/s Benchmark_RFanOut_1kx10x1000-16 2901 1160009 ns/op 8992.21 MB/s Benchmark_RFanOut_1kx10x1000-16 2895 1162440 ns/op 8973.40 MB/s Benchmark_RFanOut_1kx10x1000-16 3217 1150791 ns/op 9064.24 MB/s Benchmark_RFanOut_1kx10x1000-16 2943 1154443 ns/op 9035.56 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7007570 505.7 ns/op 4109.28 MB/s Benchmark_____FanIn_1kx100x1-16 6927882 507.4 ns/op 4095.38 MB/s Benchmark_____FanIn_1kx100x1-16 6907603 509.7 ns/op 4076.91 MB/s Benchmark_____FanIn_1kx100x1-16 6870422 509.9 ns/op 4075.17 MB/s Benchmark_____FanIn_1kx100x1-16 6968863 507.7 ns/op 4093.10 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2608964 1353 ns/op 6076.27 MB/s Benchmark_____FanIn_4kx100x1-16 2650136 1359 ns/op 6050.72 MB/s Benchmark_____FanIn_4kx100x1-16 2628854 1372 ns/op 5991.99 MB/s Benchmark_____FanIn_4kx100x1-16 2599371 1373 ns/op 5987.68 MB/s Benchmark_____FanIn_4kx100x1-16 2567454 1366 ns/op 6017.62 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1703793 2102 ns/op 7807.39 MB/s Benchmark_____FanIn_8kx100x1-16 1733732 2104 ns/op 7800.24 MB/s Benchmark_____FanIn_8kx100x1-16 1701442 2135 ns/op 7688.55 MB/s Benchmark_____FanIn_8kx100x1-16 1709511 2127 ns/op 7718.52 MB/s Benchmark_____FanIn_8kx100x1-16 1699130 2121 ns/op 7738.77 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 871336 4143 ns/op 7917.32 MB/s Benchmark____FanIn_16kx100x1-16 870001 4130 ns/op 7942.50 MB/s Benchmark____FanIn_16kx100x1-16 874893 4143 ns/op 7917.52 MB/s Benchmark____FanIn_16kx100x1-16 862742 4133 ns/op 7935.35 MB/s Benchmark____FanIn_16kx100x1-16 862892 4148 ns/op 7907.30 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 169992 20027 ns/op 6546.46 MB/s Benchmark____FanIn_64kx100x1-16 171102 19926 ns/op 6579.58 MB/s Benchmark____FanIn_64kx100x1-16 171817 20094 ns/op 6524.51 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 4919228226 vs 11222673600 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54464->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54316->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 164935 19989 ns/op 6558.73 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 654270190 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60732->127.0.0.1:5222: write: connection reset by peer 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:60882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33062->127.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:33178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33432->127.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:32972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:32956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60810->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: 989729500 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35090->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 149704780 vs 1310900000 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:36482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36692->127.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:36648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36450->127.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:36314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36574->127.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:36462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37084->127.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: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: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:36954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36334->127.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:36814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36636->127.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:36344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36888->127.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:37044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36724->127.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:36780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37098->127.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:1096: Received error on PUB write: write tcp 127.0.0.1:36972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36708->127.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:36640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36248->127.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:36922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36612->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:36438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36524->127.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:36682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36586->127.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:36494->127.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: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:36236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36916->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: 162944870 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38366->127.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:38216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38116->127.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:38362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38134->127.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:38722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38102->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: 1182825070 vs 11483484000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41506->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41146->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5508150 641.5 ns/op 442.72 MB/s Benchmark___BumpPubCount_1x3-16 5555168 645.2 ns/op 440.16 MB/s Benchmark___BumpPubCount_1x3-16 5476048 641.2 ns/op 442.92 MB/s Benchmark___BumpPubCount_1x3-16 5562042 642.6 ns/op 441.95 MB/s Benchmark___BumpPubCount_1x3-16 5509294 645.0 ns/op 440.34 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5249508 682.5 ns/op 416.12 MB/s Benchmark___BumpPubCount_2x3-16 5261892 677.4 ns/op 419.25 MB/s Benchmark___BumpPubCount_2x3-16 5263944 680.6 ns/op 417.27 MB/s Benchmark___BumpPubCount_2x3-16 5225114 682.5 ns/op 416.10 MB/s Benchmark___BumpPubCount_2x3-16 5234222 682.9 ns/op 415.89 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5532325 651.6 ns/op 435.88 MB/s Benchmark___BumpPubCount_5x3-16 5531602 649.1 ns/op 437.53 MB/s Benchmark___BumpPubCount_5x3-16 5519568 647.8 ns/op 438.41 MB/s Benchmark___BumpPubCount_5x3-16 4975688 662.4 ns/op 428.77 MB/s Benchmark___BumpPubCount_5x3-16 5246148 650.6 ns/op 436.49 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5530905 647.7 ns/op 438.49 MB/s Benchmark__BumpPubCount_10x3-16 5543778 651.1 ns/op 436.17 MB/s Benchmark__BumpPubCount_10x3-16 5506428 647.1 ns/op 438.86 MB/s Benchmark__BumpPubCount_10x3-16 5510970 648.4 ns/op 438.02 MB/s Benchmark__BumpPubCount_10x3-16 5505202 646.4 ns/op 439.34 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12259562 270.7 ns/op 3841.31 MB/s Benchmark____GWs_Opt_1kx01x0-16 12570924 271.6 ns/op 3829.45 MB/s Benchmark____GWs_Opt_1kx01x0-16 12830995 282.5 ns/op 3681.91 MB/s Benchmark____GWs_Opt_1kx01x0-16 13045204 280.5 ns/op 3707.35 MB/s Benchmark____GWs_Opt_1kx01x0-16 12882138 277.1 ns/op 3752.77 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10670906 340.9 ns/op 6054.12 MB/s Benchmark____GWs_Opt_2kx01x0-16 10423368 342.9 ns/op 6019.44 MB/s Benchmark____GWs_Opt_2kx01x0-16 9371325 332.1 ns/op 6214.49 MB/s Benchmark____GWs_Opt_2kx01x0-16 9065869 352.2 ns/op 5860.89 MB/s Benchmark____GWs_Opt_2kx01x0-16 10360879 352.9 ns/op 5847.98 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5398214 650.8 ns/op 6318.85 MB/s Benchmark____GWs_Opt_4kx01x0-16 5289484 656.7 ns/op 6262.09 MB/s Benchmark____GWs_Opt_4kx01x0-16 5273294 657.9 ns/op 6250.09 MB/s Benchmark____GWs_Opt_4kx01x0-16 5403387 694.0 ns/op 5925.24 MB/s Benchmark____GWs_Opt_4kx01x0-16 5372718 667.9 ns/op 6156.34 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29183756 108.0 ns/op 9626.04 MB/s Benchmark____GWs_Opt_1kx10x0-16 31864344 118.4 ns/op 8784.15 MB/s Benchmark____GWs_Opt_1kx10x0-16 27131298 114.8 ns/op 9056.47 MB/s Benchmark____GWs_Opt_1kx10x0-16 32340909 114.2 ns/op 9107.99 MB/s Benchmark____GWs_Opt_1kx10x0-16 32169192 110.6 ns/op 9401.29 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24748250 156.2 ns/op 13209.68 MB/s Benchmark____GWs_Opt_2kx10x0-16 22850848 152.1 ns/op 13573.18 MB/s Benchmark____GWs_Opt_2kx10x0-16 26384638 143.7 ns/op 14366.27 MB/s Benchmark____GWs_Opt_2kx10x0-16 24940604 148.4 ns/op 13906.21 MB/s Benchmark____GWs_Opt_2kx10x0-16 23838470 146.3 ns/op 14108.53 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11696055 422.8 ns/op 9725.20 MB/s Benchmark____GWs_Opt_4kx10x0-16 13161458 301.7 ns/op 13631.50 MB/s Benchmark____GWs_Opt_4kx10x0-16 12861121 279.4 ns/op 14719.82 MB/s Benchmark____GWs_Opt_4kx10x0-16 11154118 311.0 ns/op 13222.30 MB/s Benchmark____GWs_Opt_4kx10x0-16 10464043 327.1 ns/op 12572.84 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6815887 552.2 ns/op 5659.33 MB/s Benchmark____GWs_Opt_1kx01x1-16 6626560 901.0 ns/op 3468.50 MB/s Benchmark____GWs_Opt_1kx01x1-16 6506924 552.5 ns/op 5655.86 MB/s Benchmark____GWs_Opt_1kx01x1-16 6489394 546.6 ns/op 5717.53 MB/s Benchmark____GWs_Opt_1kx01x1-16 6689338 562.8 ns/op 5552.41 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4669236 763.1 ns/op 8120.44 MB/s Benchmark____GWs_Opt_2kx01x1-16 4717758 1317 ns/op 4707.16 MB/s Benchmark____GWs_Opt_2kx01x1-16 4777112 762.9 ns/op 8122.62 MB/s Benchmark____GWs_Opt_2kx01x1-16 4590465 760.7 ns/op 8146.78 MB/s Benchmark____GWs_Opt_2kx01x1-16 4617472 764.7 ns/op 8103.43 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2651840 1492 ns/op 8269.55 MB/s Benchmark____GWs_Opt_4kx01x1-16 2604326 2796 ns/op 4414.30 MB/s Benchmark____GWs_Opt_4kx01x1-16 2552775 1405 ns/op 8783.53 MB/s Benchmark____GWs_Opt_4kx01x1-16 2536879 1382 ns/op 8926.70 MB/s Benchmark____GWs_Opt_4kx01x1-16 2644512 1372 ns/op 8995.02 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6620844 581.3 ns/op 5375.45 MB/s Benchmark____GWs_Opt_1kx10x1-16 6439747 556.0 ns/op 5620.48 MB/s Benchmark____GWs_Opt_1kx10x1-16 6048597 568.3 ns/op 5499.25 MB/s Benchmark____GWs_Opt_1kx10x1-16 6317344 566.6 ns/op 5515.78 MB/s Benchmark____GWs_Opt_1kx10x1-16 6548641 556.1 ns/op 5619.12 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4078861 849.8 ns/op 7292.47 MB/s Benchmark____GWs_Opt_2kx10x1-16 4147348 848.6 ns/op 7302.62 MB/s Benchmark____GWs_Opt_2kx10x1-16 4133732 853.6 ns/op 7259.96 MB/s Benchmark____GWs_Opt_2kx10x1-16 4213707 854.9 ns/op 7249.18 MB/s Benchmark____GWs_Opt_2kx10x1-16 4223631 865.0 ns/op 7163.77 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2356605 1505 ns/op 8200.78 MB/s Benchmark____GWs_Opt_4kx10x1-16 2362520 1519 ns/op 8124.31 MB/s Benchmark____GWs_Opt_4kx10x1-16 2285898 1524 ns/op 8095.29 MB/s Benchmark____GWs_Opt_4kx10x1-16 2282043 1531 ns/op 8060.35 MB/s Benchmark____GWs_Opt_4kx10x1-16 2331742 1413 ns/op 8735.57 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12696208 287.4 ns/op 3618.70 MB/s Benchmark____GWs_Int_1kx01x0-16 11748208 285.7 ns/op 3640.76 MB/s Benchmark____GWs_Int_1kx01x0-16 12341720 277.9 ns/op 3741.85 MB/s Benchmark____GWs_Int_1kx01x0-16 12772410 287.7 ns/op 3614.47 MB/s Benchmark____GWs_Int_1kx01x0-16 12722220 295.3 ns/op 3521.27 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10451348 337.6 ns/op 6113.62 MB/s Benchmark____GWs_Int_2kx01x0-16 10264830 353.1 ns/op 5845.46 MB/s Benchmark____GWs_Int_2kx01x0-16 10175806 354.6 ns/op 5820.05 MB/s Benchmark____GWs_Int_2kx01x0-16 10060413 356.3 ns/op 5793.64 MB/s Benchmark____GWs_Int_2kx01x0-16 9038980 363.6 ns/op 5677.25 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5377478 660.9 ns/op 6221.59 MB/s Benchmark____GWs_Int_4kx01x0-16 5400608 670.9 ns/op 6128.82 MB/s Benchmark____GWs_Int_4kx01x0-16 5398346 653.7 ns/op 6290.18 MB/s Benchmark____GWs_Int_4kx01x0-16 5365675 656.6 ns/op 6262.96 MB/s Benchmark____GWs_Int_4kx01x0-16 5484552 675.8 ns/op 6084.50 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31172643 113.2 ns/op 9183.37 MB/s Benchmark____GWs_Int_1kx10x0-16 32010463 116.5 ns/op 8930.15 MB/s Benchmark____GWs_Int_1kx10x0-16 31185957 110.6 ns/op 9402.10 MB/s Benchmark____GWs_Int_1kx10x0-16 26745162 114.2 ns/op 9104.73 MB/s Benchmark____GWs_Int_1kx10x0-16 31619718 115.6 ns/op 8994.38 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25067011 137.5 ns/op 15008.58 MB/s Benchmark____GWs_Int_2kx10x0-16 20924606 154.5 ns/op 13357.84 MB/s Benchmark____GWs_Int_2kx10x0-16 24985089 142.3 ns/op 14501.32 MB/s Benchmark____GWs_Int_2kx10x0-16 21422839 143.2 ns/op 14414.88 MB/s Benchmark____GWs_Int_2kx10x0-16 25844498 135.9 ns/op 15184.43 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 10883708 315.0 ns/op 13054.55 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:55998->127.0.0.1:34129: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12423392 328.1 ns/op 12532.87 MB/s Benchmark____GWs_Int_4kx10x0-16 13144088 278.7 ns/op 14754.08 MB/s Benchmark____GWs_Int_4kx10x0-16 13298101 284.1 ns/op 14472.63 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6497942 559.0 ns/op 5590.38 MB/s Benchmark____GWs_Int_1kx01x1-16 6606049 563.4 ns/op 5546.21 MB/s Benchmark____GWs_Int_1kx01x1-16 6616446 556.3 ns/op 5617.51 MB/s Benchmark____GWs_Int_1kx01x1-16 6432968 575.3 ns/op 5432.17 MB/s Benchmark____GWs_Int_1kx01x1-16 6481821 564.4 ns/op 5536.78 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4638667 834.3 ns/op 7427.45 MB/s Benchmark____GWs_Int_2kx01x1-16 4665834 820.0 ns/op 7556.93 MB/s Benchmark____GWs_Int_2kx01x1-16 4701135 778.4 ns/op 7961.61 MB/s Benchmark____GWs_Int_2kx01x1-16 4529404 768.7 ns/op 8062.07 MB/s Benchmark____GWs_Int_2kx01x1-16 4588441 845.3 ns/op 7331.47 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2529388 1396 ns/op 8839.19 MB/s Benchmark____GWs_Int_4kx01x1-16 2609349 1381 ns/op 8934.81 MB/s Benchmark____GWs_Int_4kx01x1-16 2607153 1391 ns/op 8871.90 MB/s Benchmark____GWs_Int_4kx01x1-16 2409910 1390 ns/op 8876.79 MB/s Benchmark____GWs_Int_4kx01x1-16 2195458 1381 ns/op 8938.24 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6265868 557.3 ns/op 5607.51 MB/s Benchmark____GWs_Int_1kx10x1-16 6563838 560.0 ns/op 5580.18 MB/s Benchmark____GWs_Int_1kx10x1-16 6551089 564.2 ns/op 5538.81 MB/s Benchmark____GWs_Int_1kx10x1-16 6265766 556.6 ns/op 5614.11 MB/s Benchmark____GWs_Int_1kx10x1-16 6230529 554.7 ns/op 5633.95 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4209787 872.4 ns/op 7103.34 MB/s Benchmark____GWs_Int_2kx10x1-16 3963307 853.6 ns/op 7259.61 MB/s Benchmark____GWs_Int_2kx10x1-16 4108424 938.1 ns/op 6605.99 MB/s Benchmark____GWs_Int_2kx10x1-16 4128594 853.8 ns/op 7258.30 MB/s Benchmark____GWs_Int_2kx10x1-16 4209220 847.3 ns/op 7314.01 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2329465 1583 ns/op 7795.91 MB/s Benchmark____GWs_Int_4kx10x1-16 2355529 1556 ns/op 7933.55 MB/s Benchmark____GWs_Int_4kx10x1-16 2144750 1526 ns/op 8089.08 MB/s Benchmark____GWs_Int_4kx10x1-16 2336007 1539 ns/op 8020.95 MB/s Benchmark____GWs_Int_4kx10x1-16 2311959 1509 ns/op 8178.69 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8267058 432.6 ns/op 235.79 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8446578 434.8 ns/op 234.58 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8358157 427.7 ns/op 238.50 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8178096 438.8 ns/op 232.46 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8488603 427.3 ns/op 238.73 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 629125 5039 ns/op 35.13 MB/s Benchmark__GWs_Reqs_1SubEach-16 789584 5197 ns/op 34.06 MB/s Benchmark__GWs_Reqs_1SubEach-16 736584 5176 ns/op 34.20 MB/s Benchmark__GWs_Reqs_1SubEach-16 711433 5386 ns/op 32.86 MB/s Benchmark__GWs_Reqs_1SubEach-16 627674 5264 ns/op 33.62 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2069.393s ❌ Non-zero exit code: 1