> ROOT_DIR=/tmp/go-bench-away-job-02eab986-1666-4936-8d44-5e619091c829-2926945927 > OUTPUT_FILE=/tmp/go-bench-away-job-02eab986-1666-4936-8d44-5e619091c829-2926945927/results.txt > SHA_FILE=/tmp/go-bench-away-job-02eab986-1666-4936-8d44-5e619091c829-2926945927/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-02eab986-1666-4936-8d44-5e619091c829-2926945927/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-02eab986-1666-4936-8d44-5e619091c829-2926945927/source.git SHA of main: 822c56d17de931b56da507ab0895a21cb5f62eb0 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-build487233563=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-02eab986-1666-4936-8d44-5e619091c829-2926945927/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 50029304 72.19 ns/op 152.37 MB/s Benchmark______Pub0b_Payload-16 47477994 72.06 ns/op 152.66 MB/s Benchmark______Pub0b_Payload-16 47401645 71.64 ns/op 153.54 MB/s Benchmark______Pub0b_Payload-16 47407388 72.93 ns/op 150.83 MB/s Benchmark______Pub0b_Payload-16 47344112 71.66 ns/op 153.51 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46945568 72.35 ns/op 262.62 MB/s Benchmark______Pub8b_Payload-16 49712218 72.33 ns/op 262.69 MB/s Benchmark______Pub8b_Payload-16 46339408 72.30 ns/op 262.79 MB/s Benchmark______Pub8b_Payload-16 46985341 72.49 ns/op 262.11 MB/s Benchmark______Pub8b_Payload-16 47017954 72.29 ns/op 262.83 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44357552 76.59 ns/op 574.51 MB/s Benchmark_____Pub32b_Payload-16 44443578 80.68 ns/op 545.38 MB/s Benchmark_____Pub32b_Payload-16 44430956 78.03 ns/op 563.86 MB/s Benchmark_____Pub32b_Payload-16 44630523 76.78 ns/op 573.05 MB/s Benchmark_____Pub32b_Payload-16 44505681 76.76 ns/op 573.25 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 40032648 86.27 ns/op 1634.45 MB/s Benchmark____Pub128B_Payload-16 39578266 90.57 ns/op 1556.88 MB/s Benchmark____Pub128B_Payload-16 37780224 87.29 ns/op 1615.38 MB/s Benchmark____Pub128B_Payload-16 39883062 85.48 ns/op 1649.57 MB/s Benchmark____Pub128B_Payload-16 38845486 87.31 ns/op 1615.00 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35554786 95.70 ns/op 2810.82 MB/s Benchmark____Pub256B_Payload-16 38472117 94.12 ns/op 2858.12 MB/s Benchmark____Pub256B_Payload-16 31250366 97.92 ns/op 2747.19 MB/s Benchmark____Pub256B_Payload-16 36179131 96.15 ns/op 2797.81 MB/s Benchmark____Pub256B_Payload-16 32357998 97.00 ns/op 2773.10 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23610324 149.9 ns/op 6926.46 MB/s Benchmark______Pub1K_Payload-16 24890283 144.2 ns/op 7199.56 MB/s Benchmark______Pub1K_Payload-16 24296944 145.9 ns/op 7113.09 MB/s Benchmark______Pub1K_Payload-16 24416926 142.0 ns/op 7311.19 MB/s Benchmark______Pub1K_Payload-16 23695347 137.9 ns/op 7524.64 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5613916 630.6 ns/op 6517.35 MB/s Benchmark______Pub4K_Payload-16 5620354 632.8 ns/op 6495.09 MB/s Benchmark______Pub4K_Payload-16 5551960 621.8 ns/op 6609.50 MB/s Benchmark______Pub4K_Payload-16 5598657 623.3 ns/op 6593.73 MB/s Benchmark______Pub4K_Payload-16 5378966 628.9 ns/op 6535.28 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2772075 1285 ns/op 6387.49 MB/s Benchmark______Pub8K_Payload-16 2766232 1276 ns/op 6431.79 MB/s Benchmark______Pub8K_Payload-16 2746251 1272 ns/op 6450.47 MB/s Benchmark______Pub8K_Payload-16 2728786 1285 ns/op 6387.39 MB/s Benchmark______Pub8K_Payload-16 2731406 1291 ns/op 6354.41 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 688194 5420 ns/op 6048.81 MB/s Benchmark_____Pub32K_Payload-16 666009 5517 ns/op 5942.32 MB/s Benchmark_____Pub32K_Payload-16 657202 5536 ns/op 5921.45 MB/s Benchmark_____Pub32K_Payload-16 643238 5522 ns/op 5937.18 MB/s Benchmark_____Pub32K_Payload-16 667296 5658 ns/op 5793.84 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32440195 93.55 ns/op 117.59 MB/s Benchmark__AuthPub0b_Payload-16 36956205 93.50 ns/op 117.64 MB/s Benchmark__AuthPub0b_Payload-16 36720820 92.89 ns/op 118.42 MB/s Benchmark__AuthPub0b_Payload-16 38767296 93.02 ns/op 118.25 MB/s Benchmark__AuthPub0b_Payload-16 32921474 92.93 ns/op 118.37 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15574833 227.6 ns/op Benchmark_____________PubSub-16 15673666 227.5 ns/op Benchmark_____________PubSub-16 15661432 226.3 ns/op Benchmark_____________PubSub-16 15639525 226.8 ns/op Benchmark_____________PubSub-16 15764024 226.2 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15874884 223.8 ns/op Benchmark_____PubSubTwoConns-16 15492698 224.7 ns/op Benchmark_____PubSubTwoConns-16 15585904 224.5 ns/op Benchmark_____PubSubTwoConns-16 15764754 225.4 ns/op Benchmark_____PubSubTwoConns-16 15472935 224.8 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34288->127.0.0.1:45889: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59824->127.0.0.1:32819: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:48666->127.0.0.1:39321: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57364->127.0.0.1:34809: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51342->127.0.0.1:44443: 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 14713131 243.0 ns/op Benchmark_____PubTwoQueueSub-16 14692960 241.4 ns/op Benchmark_____PubTwoQueueSub-16 14564613 242.0 ns/op Benchmark_____PubTwoQueueSub-16 14499410 242.8 ns/op Benchmark_____PubTwoQueueSub-16 14644612 242.1 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14600185 241.6 ns/op Benchmark____PubFourQueueSub-16 14556913 242.7 ns/op Benchmark____PubFourQueueSub-16 14506293 242.4 ns/op Benchmark____PubFourQueueSub-16 14584549 242.0 ns/op Benchmark____PubFourQueueSub-16 14767632 241.3 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14716737 242.2 ns/op Benchmark___PubEightQueueSub-16 14588390 242.8 ns/op Benchmark___PubEightQueueSub-16 14455573 243.9 ns/op Benchmark___PubEightQueueSub-16 14663505 242.6 ns/op Benchmark___PubEightQueueSub-16 14721544 240.5 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22808 158254 ns/op Benchmark_PubSub512kTwoConns-16 22803 157281 ns/op Benchmark_PubSub512kTwoConns-16 21379 158831 ns/op Benchmark_PubSub512kTwoConns-16 22778 158994 ns/op Benchmark_PubSub512kTwoConns-16 22500 159122 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15338871 226.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 14904456 229.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15357219 228.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15326361 230.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15334791 227.8 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15190963 230.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15178640 228.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15489934 227.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15240253 228.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15287230 228.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11494447 315.3 ns/op Benchmark____RoutedPubSub_0b-16 11280662 312.1 ns/op Benchmark____RoutedPubSub_0b-16 11415228 315.0 ns/op Benchmark____RoutedPubSub_0b-16 11569892 310.2 ns/op Benchmark____RoutedPubSub_0b-16 11538235 313.5 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6507622 539.8 ns/op Benchmark____RoutedPubSub_1K-16 6653098 539.5 ns/op Benchmark____RoutedPubSub_1K-16 6653428 507.0 ns/op Benchmark____RoutedPubSub_1K-16 6684000 534.0 ns/op Benchmark____RoutedPubSub_1K-16 6515602 537.0 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 82670 41598 ns/op Benchmark__RoutedPubSub_100K-16 85539 41908 ns/op Benchmark__RoutedPubSub_100K-16 85958 42155 ns/op Benchmark__RoutedPubSub_100K-16 87291 41818 ns/op Benchmark__RoutedPubSub_100K-16 83556 43643 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9844968 313.9 ns/op Benchmark____Routed2QueueSub-16 9402927 319.3 ns/op Benchmark____Routed2QueueSub-16 9703388 314.6 ns/op Benchmark____Routed2QueueSub-16 9913688 317.7 ns/op Benchmark____Routed2QueueSub-16 9762508 316.8 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9390624 324.1 ns/op Benchmark____Routed4QueueSub-16 9607045 320.9 ns/op Benchmark____Routed4QueueSub-16 11316808 320.6 ns/op Benchmark____Routed4QueueSub-16 9690267 316.3 ns/op Benchmark____Routed4QueueSub-16 9614538 319.9 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 11124943 319.6 ns/op Benchmark____Routed8QueueSub-16 9133664 330.4 ns/op Benchmark____Routed8QueueSub-16 9158355 329.4 ns/op Benchmark____Routed8QueueSub-16 9262968 327.9 ns/op Benchmark____Routed8QueueSub-16 9240590 326.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8892853 338.7 ns/op Benchmark___Routed16QueueSub-16 8992314 344.8 ns/op Benchmark___Routed16QueueSub-16 9017898 351.3 ns/op Benchmark___Routed16QueueSub-16 8854417 345.6 ns/op Benchmark___Routed16QueueSub-16 10471275 340.8 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6397814 546.7 ns/op Benchmark____________RouteCompressOff-16 6628982 546.4 ns/op Benchmark____________RouteCompressOff-16 6405680 543.7 ns/op Benchmark____________RouteCompressOff-16 6563398 551.9 ns/op Benchmark____________RouteCompressOff-16 6288973 553.8 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6636740 549.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6436563 514.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6537970 551.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6375346 550.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6663610 550.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6251508 551.3 ns/op Benchmark_________RouteCompressS2Fast-16 6358584 551.1 ns/op Benchmark_________RouteCompressS2Fast-16 6475916 548.2 ns/op Benchmark_________RouteCompressS2Fast-16 6458214 549.1 ns/op Benchmark_________RouteCompressS2Fast-16 6485769 548.4 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6437428 544.8 ns/op Benchmark_______RouteCompressS2Better-16 6470262 553.5 ns/op Benchmark_______RouteCompressS2Better-16 6489061 558.4 ns/op Benchmark_______RouteCompressS2Better-16 6466876 544.3 ns/op Benchmark_______RouteCompressS2Better-16 6450373 549.8 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6323503 544.7 ns/op Benchmark_________RouteCompressS2Best-16 6286042 543.6 ns/op Benchmark_________RouteCompressS2Best-16 6584430 546.8 ns/op Benchmark_________RouteCompressS2Best-16 6591552 549.5 ns/op Benchmark_________RouteCompressS2Best-16 6387554 545.4 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4640083 775.2 ns/op 321.23 MB/s Benchmark______FanOut_8x1x10-16 4613533 777.0 ns/op 320.48 MB/s Benchmark______FanOut_8x1x10-16 4655311 772.3 ns/op 322.41 MB/s Benchmark______FanOut_8x1x10-16 4572018 772.7 ns/op 322.25 MB/s Benchmark______FanOut_8x1x10-16 4626459 772.2 ns/op 322.47 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 568390 6123 ns/op 378.73 MB/s Benchmark_____FanOut_8x1x100-16 549426 6115 ns/op 379.25 MB/s Benchmark_____FanOut_8x1x100-16 549110 6134 ns/op 378.03 MB/s Benchmark_____FanOut_8x1x100-16 535152 6223 ns/op 372.65 MB/s Benchmark_____FanOut_8x1x100-16 560799 6131 ns/op 378.26 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47518 75887 ns/op 303.33 MB/s Benchmark____FanOut_8x10x100-16 47558 77042 ns/op 298.79 MB/s Benchmark____FanOut_8x10x100-16 47391 75936 ns/op 303.14 MB/s Benchmark____FanOut_8x10x100-16 48148 75801 ns/op 303.68 MB/s Benchmark____FanOut_8x10x100-16 47930 75545 ns/op 304.71 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5706 601880 ns/op 398.78 MB/s Benchmark___FanOut_8x10x1000-16 5881 601063 ns/op 399.32 MB/s Benchmark___FanOut_8x10x1000-16 5736 607374 ns/op 395.17 MB/s Benchmark___FanOut_8x10x1000-16 5938 601931 ns/op 398.75 MB/s Benchmark___FanOut_8x10x1000-16 5713 604042 ns/op 397.35 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4969 711019 ns/op 323.51 MB/s Benchmark___FanOut_8x100x100-16 4965 721707 ns/op 318.72 MB/s Benchmark___FanOut_8x100x100-16 4894 715506 ns/op 321.48 MB/s Benchmark___FanOut_8x100x100-16 4915 710735 ns/op 323.64 MB/s Benchmark___FanOut_8x100x100-16 4916 711811 ns/op 323.15 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 573 6175276 ns/op 388.65 MB/s Benchmark__FanOut_8x100x1000-16 576 6172846 ns/op 388.80 MB/s Benchmark__FanOut_8x100x1000-16 578 6188595 ns/op 387.81 MB/s Benchmark__FanOut_8x100x1000-16 577 6193039 ns/op 387.53 MB/s Benchmark__FanOut_8x100x1000-16 573 6164404 ns/op 389.34 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 513 6948953 ns/op 359.77 MB/s Benchmark__FanOut_8x10x10000-16 540 6726782 ns/op 371.65 MB/s Benchmark__FanOut_8x10x10000-16 514 6904894 ns/op 362.06 MB/s Benchmark__FanOut_8x10x10000-16 508 6734491 ns/op 371.23 MB/s Benchmark__FanOut_8x10x10000-16 528 6839569 ns/op 365.52 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 936 3838060 ns/op 299.64 MB/s Benchmark___FanOut_8x500x100-16 948 3790968 ns/op 303.36 MB/s Benchmark___FanOut_8x500x100-16 937 3810534 ns/op 301.80 MB/s Benchmark___FanOut_8x500x100-16 942 3786364 ns/op 303.73 MB/s Benchmark___FanOut_8x500x100-16 936 3781322 ns/op 304.13 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 350278 9594 ns/op 1525.99 MB/s Benchmark___FanOut_128x1x100-16 358623 9593 ns/op 1526.20 MB/s Benchmark___FanOut_128x1x100-16 355784 9631 ns/op 1520.13 MB/s Benchmark___FanOut_128x1x100-16 372781 9573 ns/op 1529.33 MB/s Benchmark___FanOut_128x1x100-16 366463 9630 ns/op 1520.28 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 31897 112213 ns/op 1293.45 MB/s Benchmark__FanOut_128x10x100-16 32424 112321 ns/op 1292.20 MB/s Benchmark__FanOut_128x10x100-16 32295 111796 ns/op 1298.27 MB/s Benchmark__FanOut_128x10x100-16 32276 112381 ns/op 1291.51 MB/s Benchmark__FanOut_128x10x100-16 32302 111101 ns/op 1306.39 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4165 894704 ns/op 1631.98 MB/s Benchmark_FanOut_128x10x1000-16 3853 901883 ns/op 1618.99 MB/s Benchmark_FanOut_128x10x1000-16 3909 880722 ns/op 1657.89 MB/s Benchmark_FanOut_128x10x1000-16 4101 879830 ns/op 1659.57 MB/s Benchmark_FanOut_128x10x1000-16 4024 880831 ns/op 1657.69 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3530 1015396 ns/op 1428.15 MB/s Benchmark_FanOut_128x100x100-16 3484 1012477 ns/op 1432.27 MB/s Benchmark_FanOut_128x100x100-16 3426 1016639 ns/op 1426.41 MB/s Benchmark_FanOut_128x100x100-16 3470 1019289 ns/op 1422.70 MB/s Benchmark_FanOut_128x100x100-16 3429 1017669 ns/op 1424.96 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 386 9544493 ns/op 1529.69 MB/s BenchmarkFanOut_128x100x1000-16 381 9423646 ns/op 1549.31 MB/s BenchmarkFanOut_128x100x1000-16 376 9364199 ns/op 1559.14 MB/s BenchmarkFanOut_128x100x1000-16 382 9425889 ns/op 1548.94 MB/s BenchmarkFanOut_128x100x1000-16 381 9577905 ns/op 1524.36 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 376 9738059 ns/op 1509.56 MB/s BenchmarkFanOut_128x10x10000-16 369 9700232 ns/op 1515.44 MB/s BenchmarkFanOut_128x10x10000-16 369 9846248 ns/op 1492.97 MB/s BenchmarkFanOut_128x10x10000-16 373 9709656 ns/op 1513.97 MB/s BenchmarkFanOut_128x10x10000-16 367 9865060 ns/op 1490.12 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 667 5310290 ns/op 1365.30 MB/s BenchmarkFanOut__128x500x100-16 672 5291799 ns/op 1370.07 MB/s BenchmarkFanOut__128x500x100-16 664 5329290 ns/op 1360.43 MB/s BenchmarkFanOut__128x500x100-16 666 5341732 ns/op 1357.26 MB/s BenchmarkFanOut__128x500x100-16 664 5274413 ns/op 1374.59 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1938 1837301 ns/op 2879.51 MB/s Benchmark_FanOut_512x100x100-16 1892 1857098 ns/op 2848.81 MB/s Benchmark_FanOut_512x100x100-16 1899 1860177 ns/op 2844.10 MB/s Benchmark_FanOut_512x100x100-16 1920 1853759 ns/op 2853.94 MB/s Benchmark_FanOut_512x100x100-16 1958 1844985 ns/op 2867.52 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 216 16858077 ns/op 3143.92 MB/s Benchmark__FanOut_512x100x1k-16 213 16713467 ns/op 3171.13 MB/s Benchmark__FanOut_512x100x1k-16 216 16857745 ns/op 3143.99 MB/s Benchmark__FanOut_512x100x1k-16 213 16832302 ns/op 3148.74 MB/s Benchmark__FanOut_512x100x1k-16 214 16790140 ns/op 3156.65 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3163 1148493 ns/op 9082.37 MB/s Benchmark____FanOut_1kx10x1k-16 2870 1139630 ns/op 9153.00 MB/s Benchmark____FanOut_1kx10x1k-16 2968 1126705 ns/op 9258.01 MB/s Benchmark____FanOut_1kx10x1k-16 3078 1147354 ns/op 9091.39 MB/s Benchmark____FanOut_1kx10x1k-16 2937 1165561 ns/op 8949.37 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2758 1259564 ns/op 8273.53 MB/s Benchmark__FanOut_1kx100x100-16 2737 1260102 ns/op 8269.99 MB/s Benchmark__FanOut_1kx100x100-16 2786 1255760 ns/op 8298.59 MB/s Benchmark__FanOut_1kx100x100-16 2752 1254464 ns/op 8307.17 MB/s Benchmark__FanOut_1kx100x100-16 2731 1276369 ns/op 8164.60 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4446247 778.4 ns/op 319.87 MB/s Benchmark_____RFanOut_8x1x10-16 4395358 795.2 ns/op 313.15 MB/s Benchmark_____RFanOut_8x1x10-16 4505581 779.4 ns/op 319.46 MB/s Benchmark_____RFanOut_8x1x10-16 4336092 768.6 ns/op 323.98 MB/s Benchmark_____RFanOut_8x1x10-16 4322581 795.9 ns/op 312.84 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 533084 6177 ns/op 375.44 MB/s Benchmark____RFanOut_8x1x100-16 490678 6365 ns/op 364.31 MB/s Benchmark____RFanOut_8x1x100-16 514376 6163 ns/op 376.26 MB/s Benchmark____RFanOut_8x1x100-16 534140 6130 ns/op 378.28 MB/s Benchmark____RFanOut_8x1x100-16 536223 6142 ns/op 377.57 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47334 75621 ns/op 304.40 MB/s Benchmark___RFanOut_8x10x100-16 47266 75220 ns/op 306.02 MB/s Benchmark___RFanOut_8x10x100-16 47544 75388 ns/op 305.34 MB/s Benchmark___RFanOut_8x10x100-16 47721 74930 ns/op 307.21 MB/s Benchmark___RFanOut_8x10x100-16 47232 75833 ns/op 303.55 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5550 610891 ns/op 392.90 MB/s Benchmark__RFanOut_8x10x1000-16 5786 607403 ns/op 395.16 MB/s Benchmark__RFanOut_8x10x1000-16 5883 608694 ns/op 394.32 MB/s Benchmark__RFanOut_8x10x1000-16 5761 633310 ns/op 378.99 MB/s Benchmark__RFanOut_8x10x1000-16 5700 609035 ns/op 394.10 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4904 715317 ns/op 321.56 MB/s Benchmark__RFanOut_8x100x100-16 4911 723486 ns/op 317.93 MB/s Benchmark__RFanOut_8x100x100-16 4850 714947 ns/op 321.73 MB/s Benchmark__RFanOut_8x100x100-16 4716 718819 ns/op 320.00 MB/s Benchmark__RFanOut_8x100x100-16 4816 723914 ns/op 317.74 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 570 6329171 ns/op 379.20 MB/s Benchmark_RFanOut_8x100x1000-16 549 6286697 ns/op 381.76 MB/s Benchmark_RFanOut_8x100x1000-16 554 6272823 ns/op 382.61 MB/s Benchmark_RFanOut_8x100x1000-16 559 6295304 ns/op 381.24 MB/s Benchmark_RFanOut_8x100x1000-16 567 6312216 ns/op 380.22 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 528 6921482 ns/op 361.20 MB/s Benchmark_RFanOut_8x10x10000-16 528 6849175 ns/op 365.01 MB/s Benchmark_RFanOut_8x10x10000-16 514 6949865 ns/op 359.72 MB/s Benchmark_RFanOut_8x10x10000-16 523 6851952 ns/op 364.86 MB/s Benchmark_RFanOut_8x10x10000-16 513 6845981 ns/op 365.18 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3069 1157578 ns/op 9011.09 MB/s Benchmark_RFanOut_1kx10x1000-16 3121 1190094 ns/op 8764.88 MB/s Benchmark_RFanOut_1kx10x1000-16 3094 1158100 ns/op 9007.02 MB/s Benchmark_RFanOut_1kx10x1000-16 2907 1161196 ns/op 8983.02 MB/s Benchmark_RFanOut_1kx10x1000-16 3226 1144202 ns/op 9116.43 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7030059 503.9 ns/op 4123.84 MB/s Benchmark_____FanIn_1kx100x1-16 6985159 502.6 ns/op 4134.65 MB/s Benchmark_____FanIn_1kx100x1-16 6984128 503.5 ns/op 4127.44 MB/s Benchmark_____FanIn_1kx100x1-16 7029078 505.0 ns/op 4114.53 MB/s Benchmark_____FanIn_1kx100x1-16 6996336 501.9 ns/op 4140.17 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2621274 1391 ns/op 5911.02 MB/s Benchmark_____FanIn_4kx100x1-16 2653353 1371 ns/op 5998.54 MB/s Benchmark_____FanIn_4kx100x1-16 2654577 1374 ns/op 5983.25 MB/s Benchmark_____FanIn_4kx100x1-16 2666882 1359 ns/op 6052.08 MB/s Benchmark_____FanIn_4kx100x1-16 2596651 1349 ns/op 6093.12 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1655724 2113 ns/op 7768.36 MB/s Benchmark_____FanIn_8kx100x1-16 1724611 2093 ns/op 7843.24 MB/s Benchmark_____FanIn_8kx100x1-16 1735026 2104 ns/op 7803.15 MB/s Benchmark_____FanIn_8kx100x1-16 1691616 2136 ns/op 7682.70 MB/s Benchmark_____FanIn_8kx100x1-16 1722421 2114 ns/op 7765.35 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 884551 4089 ns/op 8022.26 MB/s Benchmark____FanIn_16kx100x1-16 874232 4142 ns/op 7918.64 MB/s Benchmark____FanIn_16kx100x1-16 871508 4119 ns/op 7962.41 MB/s Benchmark____FanIn_16kx100x1-16 850899 4120 ns/op 7960.36 MB/s Benchmark____FanIn_16kx100x1-16 861903 4148 ns/op 7907.90 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 5921205831 vs 11104678200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40484->127.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:40748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40246->127.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:40504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40586->127.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:40250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40374->127.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:40478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40546->127.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:40636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40922->127.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:40954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40192->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:40648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40316->127.0.0.1:5222: write: broken pipe Benchmark____FanIn_64kx100x1-16 166629 19927 ns/op 6579.05 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 510002340 vs 11275116000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46064->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:46052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45826->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 162643 19785 ns/op 6626.39 MB/s Benchmark____FanIn_64kx100x1-16 165793 19859 ns/op 6601.63 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 381209720 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35320->127.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: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:34642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35284->127.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:35056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35142->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: 1034300100 vs 11129541000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37688->127.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:37468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37664->127.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:38044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37902->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:38230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38082->127.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:38258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37494->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: 644831710 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39956->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39352->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39234->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: 975571780 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42052->127.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 --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 331002250 vs 11496593000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44616->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5543143 636.9 ns/op 445.89 MB/s Benchmark___BumpPubCount_1x3-16 5627739 638.1 ns/op 445.09 MB/s Benchmark___BumpPubCount_1x3-16 5615799 643.9 ns/op 441.06 MB/s Benchmark___BumpPubCount_1x3-16 5629762 640.3 ns/op 443.51 MB/s Benchmark___BumpPubCount_1x3-16 5556309 640.7 ns/op 443.25 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5352226 669.9 ns/op 423.97 MB/s Benchmark___BumpPubCount_2x3-16 5335864 668.3 ns/op 424.94 MB/s Benchmark___BumpPubCount_2x3-16 5283027 674.4 ns/op 421.13 MB/s Benchmark___BumpPubCount_2x3-16 5251041 672.4 ns/op 422.35 MB/s Benchmark___BumpPubCount_2x3-16 5350628 676.3 ns/op 419.94 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5598804 641.5 ns/op 442.69 MB/s Benchmark___BumpPubCount_5x3-16 5610424 645.2 ns/op 440.20 MB/s Benchmark___BumpPubCount_5x3-16 5318220 641.3 ns/op 442.86 MB/s Benchmark___BumpPubCount_5x3-16 5614698 642.4 ns/op 442.11 MB/s Benchmark___BumpPubCount_5x3-16 5589274 642.2 ns/op 442.23 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5598930 639.1 ns/op 444.36 MB/s Benchmark__BumpPubCount_10x3-16 5611290 646.3 ns/op 439.46 MB/s Benchmark__BumpPubCount_10x3-16 5630997 641.9 ns/op 442.43 MB/s Benchmark__BumpPubCount_10x3-16 5590557 642.1 ns/op 442.27 MB/s Benchmark__BumpPubCount_10x3-16 5589159 639.8 ns/op 443.86 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12372565 272.5 ns/op 3816.69 MB/s Benchmark____GWs_Opt_1kx01x0-16 11802582 278.2 ns/op 3738.19 MB/s Benchmark____GWs_Opt_1kx01x0-16 12836647 276.0 ns/op 3767.75 MB/s Benchmark____GWs_Opt_1kx01x0-16 13020876 277.2 ns/op 3751.79 MB/s Benchmark____GWs_Opt_1kx01x0-16 13082989 274.2 ns/op 3792.64 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10192437 354.3 ns/op 5825.64 MB/s Benchmark____GWs_Opt_2kx01x0-16 10459099 351.2 ns/op 5877.47 MB/s Benchmark____GWs_Opt_2kx01x0-16 10717239 336.8 ns/op 6128.61 MB/s Benchmark____GWs_Opt_2kx01x0-16 10385325 325.9 ns/op 6334.05 MB/s Benchmark____GWs_Opt_2kx01x0-16 9946521 339.7 ns/op 6075.91 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5816924 613.3 ns/op 6704.84 MB/s Benchmark____GWs_Opt_4kx01x0-16 5801022 606.7 ns/op 6777.63 MB/s Benchmark____GWs_Opt_4kx01x0-16 5841286 621.9 ns/op 6612.03 MB/s Benchmark____GWs_Opt_4kx01x0-16 5833652 603.9 ns/op 6808.81 MB/s Benchmark____GWs_Opt_4kx01x0-16 5843389 604.6 ns/op 6801.34 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29210641 110.8 ns/op 9384.02 MB/s Benchmark____GWs_Opt_1kx10x0-16 31334631 116.1 ns/op 8958.14 MB/s Benchmark____GWs_Opt_1kx10x0-16 29509110 112.5 ns/op 9244.83 MB/s Benchmark____GWs_Opt_1kx10x0-16 27404298 114.9 ns/op 9049.74 MB/s Benchmark____GWs_Opt_1kx10x0-16 28042153 113.8 ns/op 9136.34 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 21794136 153.1 ns/op 13478.61 MB/s Benchmark____GWs_Opt_2kx10x0-16 24534019 140.9 ns/op 14648.99 MB/s Benchmark____GWs_Opt_2kx10x0-16 22585749 161.2 ns/op 12803.80 MB/s Benchmark____GWs_Opt_2kx10x0-16 25510136 142.7 ns/op 14459.24 MB/s Benchmark____GWs_Opt_2kx10x0-16 25286797 148.0 ns/op 13948.71 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 10151517 313.7 ns/op 13109.45 MB/s Benchmark____GWs_Opt_4kx10x0-16 10954641 303.7 ns/op 13539.65 MB/s Benchmark____GWs_Opt_4kx10x0-16 10522815 298.5 ns/op 13774.75 MB/s Benchmark____GWs_Opt_4kx10x0-16 12874398 302.4 ns/op 13595.75 MB/s Benchmark____GWs_Opt_4kx10x0-16 12003370 292.4 ns/op 14060.84 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6607353 549.1 ns/op 5690.73 MB/s Benchmark____GWs_Opt_1kx01x1-16 6694750 550.1 ns/op 5680.98 MB/s Benchmark____GWs_Opt_1kx01x1-16 6672826 552.1 ns/op 5660.19 MB/s Benchmark____GWs_Opt_1kx01x1-16 6722744 557.4 ns/op 5605.95 MB/s Benchmark____GWs_Opt_1kx01x1-16 6566613 546.4 ns/op 5718.84 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4642014 755.9 ns/op 8198.01 MB/s Benchmark____GWs_Opt_2kx01x1-16 4730716 752.6 ns/op 8234.09 MB/s Benchmark____GWs_Opt_2kx01x1-16 4738149 751.0 ns/op 8251.59 MB/s Benchmark____GWs_Opt_2kx01x1-16 4676282 755.6 ns/op 8201.21 MB/s Benchmark____GWs_Opt_2kx01x1-16 4737783 747.3 ns/op 8292.69 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2683543 1356 ns/op 9099.10 MB/s Benchmark____GWs_Opt_4kx01x1-16 2639721 1355 ns/op 9104.57 MB/s Benchmark____GWs_Opt_4kx01x1-16 2666037 1374 ns/op 8984.81 MB/s Benchmark____GWs_Opt_4kx01x1-16 2611044 1376 ns/op 8968.26 MB/s Benchmark____GWs_Opt_4kx01x1-16 2656165 1338 ns/op 9225.31 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6452641 544.9 ns/op 5735.29 MB/s Benchmark____GWs_Opt_1kx10x1-16 6653038 553.6 ns/op 5644.80 MB/s Benchmark____GWs_Opt_1kx10x1-16 6381649 538.9 ns/op 5798.43 MB/s Benchmark____GWs_Opt_1kx10x1-16 6642033 544.3 ns/op 5740.84 MB/s Benchmark____GWs_Opt_1kx10x1-16 6409935 554.2 ns/op 5639.09 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4089021 855.9 ns/op 7240.07 MB/s Benchmark____GWs_Opt_2kx10x1-16 4311416 826.5 ns/op 7497.54 MB/s Benchmark____GWs_Opt_2kx10x1-16 4360357 842.6 ns/op 7354.21 MB/s Benchmark____GWs_Opt_2kx10x1-16 4174258 860.8 ns/op 7199.31 MB/s Benchmark____GWs_Opt_2kx10x1-16 4221645 815.5 ns/op 7599.22 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2288834 1475 ns/op 8366.07 MB/s Benchmark____GWs_Opt_4kx10x1-16 2495896 1568 ns/op 7868.65 MB/s Benchmark____GWs_Opt_4kx10x1-16 2375167 1524 ns/op 8096.52 MB/s Benchmark____GWs_Opt_4kx10x1-16 2410030 1530 ns/op 8063.83 MB/s Benchmark____GWs_Opt_4kx10x1-16 2368214 1534 ns/op 8043.97 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12535462 286.3 ns/op 3633.16 MB/s Benchmark____GWs_Int_1kx01x0-16 12808834 291.7 ns/op 3564.94 MB/s Benchmark____GWs_Int_1kx01x0-16 12701694 294.0 ns/op 3537.68 MB/s Benchmark____GWs_Int_1kx01x0-16 12278518 282.8 ns/op 3677.88 MB/s Benchmark____GWs_Int_1kx01x0-16 12832669 288.8 ns/op 3600.73 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10451829 357.3 ns/op 5777.07 MB/s Benchmark____GWs_Int_2kx01x0-16 10167148 340.6 ns/op 6059.96 MB/s Benchmark____GWs_Int_2kx01x0-16 9687457 369.3 ns/op 5589.54 MB/s Benchmark____GWs_Int_2kx01x0-16 10429629 363.8 ns/op 5672.82 MB/s Benchmark____GWs_Int_2kx01x0-16 9703782 351.0 ns/op 5880.56 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5633529 632.0 ns/op 6506.16 MB/s Benchmark____GWs_Int_4kx01x0-16 5644554 631.2 ns/op 6514.42 MB/s Benchmark____GWs_Int_4kx01x0-16 5871405 631.1 ns/op 6515.98 MB/s Benchmark____GWs_Int_4kx01x0-16 6084777 638.0 ns/op 6445.63 MB/s Benchmark____GWs_Int_4kx01x0-16 5606643 636.3 ns/op 6462.77 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31313300 108.9 ns/op 9547.62 MB/s Benchmark____GWs_Int_1kx10x0-16 31216959 110.8 ns/op 9385.56 MB/s Benchmark____GWs_Int_1kx10x0-16 31099081 114.1 ns/op 9111.89 MB/s Benchmark____GWs_Int_1kx10x0-16 32518503 107.6 ns/op 9664.05 MB/s Benchmark____GWs_Int_1kx10x0-16 30701912 110.3 ns/op 9427.84 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25377685 141.5 ns/op 14583.48 MB/s Benchmark____GWs_Int_2kx10x0-16 25658302 139.5 ns/op 14800.45 MB/s Benchmark____GWs_Int_2kx10x0-16 25529142 149.0 ns/op 13847.87 MB/s Benchmark____GWs_Int_2kx10x0-16 25973222 147.7 ns/op 13970.72 MB/s Benchmark____GWs_Int_2kx10x0-16 25679473 162.6 ns/op 12694.75 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13150348 281.5 ns/op 14607.55 MB/s Benchmark____GWs_Int_4kx10x0-16 13114756 284.8 ns/op 14437.98 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:41486->127.0.0.1:38113: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:55586->127.0.0.1:40037: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 13184017 300.2 ns/op 13696.56 MB/s Benchmark____GWs_Int_4kx10x0-16 12373596 351.7 ns/op 11691.95 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6479660 574.8 ns/op 5437.10 MB/s Benchmark____GWs_Int_1kx01x1-16 6549720 553.2 ns/op 5648.59 MB/s Benchmark____GWs_Int_1kx01x1-16 6331225 559.5 ns/op 5585.26 MB/s Benchmark____GWs_Int_1kx01x1-16 6397819 555.3 ns/op 5628.04 MB/s Benchmark____GWs_Int_1kx01x1-16 6558795 572.1 ns/op 5462.72 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4764928 759.9 ns/op 8154.64 MB/s Benchmark____GWs_Int_2kx01x1-16 4748042 760.3 ns/op 8150.96 MB/s Benchmark____GWs_Int_2kx01x1-16 4692214 765.3 ns/op 8097.40 MB/s Benchmark____GWs_Int_2kx01x1-16 4728154 759.6 ns/op 8158.76 MB/s Benchmark____GWs_Int_2kx01x1-16 4736042 800.8 ns/op 7738.29 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2535906 1366 ns/op 9036.47 MB/s Benchmark____GWs_Int_4kx01x1-16 2633718 1360 ns/op 9075.29 MB/s Benchmark____GWs_Int_4kx01x1-16 2659204 1350 ns/op 9142.15 MB/s Benchmark____GWs_Int_4kx01x1-16 2215737 1445 ns/op 8541.93 MB/s Benchmark____GWs_Int_4kx01x1-16 2618754 1577 ns/op 7826.82 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6534946 552.2 ns/op 5659.05 MB/s Benchmark____GWs_Int_1kx10x1-16 6583814 549.1 ns/op 5691.30 MB/s Benchmark____GWs_Int_1kx10x1-16 6348307 551.7 ns/op 5663.95 MB/s Benchmark____GWs_Int_1kx10x1-16 6397953 588.7 ns/op 5308.40 MB/s Benchmark____GWs_Int_1kx10x1-16 6652702 556.1 ns/op 5619.15 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4067905 837.6 ns/op 7398.49 MB/s Benchmark____GWs_Int_2kx10x1-16 4022619 842.6 ns/op 7354.59 MB/s Benchmark____GWs_Int_2kx10x1-16 4284182 822.6 ns/op 7533.67 MB/s Benchmark____GWs_Int_2kx10x1-16 4135893 777.8 ns/op 7967.26 MB/s Benchmark____GWs_Int_2kx10x1-16 4052980 824.9 ns/op 7512.47 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2391567 1510 ns/op 8175.33 MB/s Benchmark____GWs_Int_4kx10x1-16 2410858 1487 ns/op 8300.84 MB/s Benchmark____GWs_Int_4kx10x1-16 2372754 1450 ns/op 8511.28 MB/s Benchmark____GWs_Int_4kx10x1-16 2513358 1490 ns/op 8281.08 MB/s Benchmark____GWs_Int_4kx10x1-16 2366557 1653 ns/op 7464.16 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8239777 427.9 ns/op 238.38 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8368861 424.6 ns/op 240.25 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8533912 432.6 ns/op 235.78 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8346216 432.2 ns/op 236.00 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8484198 433.6 ns/op 235.23 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 596394 5049 ns/op 35.06 MB/s Benchmark__GWs_Reqs_1SubEach-16 771547 5114 ns/op 34.61 MB/s Benchmark__GWs_Reqs_1SubEach-16 755618 5273 ns/op 33.57 MB/s Benchmark__GWs_Reqs_1SubEach-16 728275 5332 ns/op 33.20 MB/s Benchmark__GWs_Reqs_1SubEach-16 697496 5250 ns/op 33.72 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2092.761s ❌ Non-zero exit code: 1