> ROOT_DIR=/tmp/go-bench-away-job-07b72bff-e436-471b-8a04-3030a16eb8d0-2971707057 > OUTPUT_FILE=/tmp/go-bench-away-job-07b72bff-e436-471b-8a04-3030a16eb8d0-2971707057/results.txt > SHA_FILE=/tmp/go-bench-away-job-07b72bff-e436-471b-8a04-3030a16eb8d0-2971707057/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-07b72bff-e436-471b-8a04-3030a16eb8d0-2971707057/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-07b72bff-e436-471b-8a04-3030a16eb8d0-2971707057/source.git SHA of main: 40359273926ae1b238b8b50270a867fa742bb13e 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-build4095662455=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-07b72bff-e436-471b-8a04-3030a16eb8d0-2971707057/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 48354824 72.48 ns/op 151.77 MB/s Benchmark______Pub0b_Payload-16 47052694 72.54 ns/op 151.63 MB/s Benchmark______Pub0b_Payload-16 47242093 72.34 ns/op 152.07 MB/s Benchmark______Pub0b_Payload-16 47232451 72.44 ns/op 151.85 MB/s Benchmark______Pub0b_Payload-16 43648198 72.95 ns/op 150.79 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46824004 73.39 ns/op 258.88 MB/s Benchmark______Pub8b_Payload-16 49323897 72.86 ns/op 260.79 MB/s Benchmark______Pub8b_Payload-16 46697744 72.95 ns/op 260.45 MB/s Benchmark______Pub8b_Payload-16 46459372 73.12 ns/op 259.86 MB/s Benchmark______Pub8b_Payload-16 46828702 73.20 ns/op 259.58 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 38295273 78.79 ns/op 558.47 MB/s Benchmark_____Pub32b_Payload-16 46739746 77.73 ns/op 566.08 MB/s Benchmark_____Pub32b_Payload-16 44270658 77.66 ns/op 566.55 MB/s Benchmark_____Pub32b_Payload-16 44168053 77.21 ns/op 569.84 MB/s Benchmark_____Pub32b_Payload-16 44413803 76.78 ns/op 573.10 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 34997630 86.02 ns/op 1639.21 MB/s Benchmark____Pub128B_Payload-16 39026894 86.12 ns/op 1637.27 MB/s Benchmark____Pub128B_Payload-16 34634871 88.43 ns/op 1594.42 MB/s Benchmark____Pub128B_Payload-16 34793550 86.31 ns/op 1633.64 MB/s Benchmark____Pub128B_Payload-16 40954935 87.55 ns/op 1610.45 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36644390 93.84 ns/op 2866.73 MB/s Benchmark____Pub256B_Payload-16 32777068 93.76 ns/op 2868.88 MB/s Benchmark____Pub256B_Payload-16 32789482 101.2 ns/op 2658.61 MB/s Benchmark____Pub256B_Payload-16 33444960 94.65 ns/op 2842.18 MB/s Benchmark____Pub256B_Payload-16 32383740 94.34 ns/op 2851.24 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 22075732 141.0 ns/op 7362.89 MB/s Benchmark______Pub1K_Payload-16 23846968 137.0 ns/op 7578.48 MB/s Benchmark______Pub1K_Payload-16 23812897 133.7 ns/op 7765.44 MB/s Benchmark______Pub1K_Payload-16 25830004 136.4 ns/op 7610.02 MB/s Benchmark______Pub1K_Payload-16 24522716 133.1 ns/op 7798.00 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5592014 620.3 ns/op 6625.89 MB/s Benchmark______Pub4K_Payload-16 5528894 605.7 ns/op 6785.50 MB/s Benchmark______Pub4K_Payload-16 5222208 622.1 ns/op 6606.74 MB/s Benchmark______Pub4K_Payload-16 5877880 618.9 ns/op 6640.75 MB/s Benchmark______Pub4K_Payload-16 5546131 632.0 ns/op 6503.51 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2810145 1280 ns/op 6411.63 MB/s Benchmark______Pub8K_Payload-16 2756785 1288 ns/op 6371.23 MB/s Benchmark______Pub8K_Payload-16 2790532 1277 ns/op 6424.92 MB/s Benchmark______Pub8K_Payload-16 2822838 1274 ns/op 6441.31 MB/s Benchmark______Pub8K_Payload-16 2781487 1285 ns/op 6386.37 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 660150 5411 ns/op 6058.41 MB/s Benchmark_____Pub32K_Payload-16 674872 5484 ns/op 5978.04 MB/s Benchmark_____Pub32K_Payload-16 663360 5479 ns/op 5983.93 MB/s Benchmark_____Pub32K_Payload-16 677586 5568 ns/op 5887.76 MB/s Benchmark_____Pub32K_Payload-16 647794 5614 ns/op 5839.84 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32179771 95.50 ns/op 115.18 MB/s Benchmark__AuthPub0b_Payload-16 35715565 96.59 ns/op 113.89 MB/s Benchmark__AuthPub0b_Payload-16 34067535 96.53 ns/op 113.95 MB/s Benchmark__AuthPub0b_Payload-16 34631953 95.62 ns/op 115.03 MB/s Benchmark__AuthPub0b_Payload-16 35705359 96.16 ns/op 114.39 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15683437 225.1 ns/op Benchmark_____________PubSub-16 15614665 225.2 ns/op Benchmark_____________PubSub-16 15819652 225.0 ns/op Benchmark_____________PubSub-16 15693384 225.9 ns/op Benchmark_____________PubSub-16 15827490 225.4 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15900651 223.5 ns/op Benchmark_____PubSubTwoConns-16 15759481 223.3 ns/op Benchmark_____PubSubTwoConns-16 15745190 223.2 ns/op Benchmark_____PubSubTwoConns-16 15904198 223.2 ns/op Benchmark_____PubSubTwoConns-16 15812850 223.8 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:55338->127.0.0.1:43451: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33782->127.0.0.1:44501: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:47422->127.0.0.1:33127: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:56316->127.0.0.1:36555: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:39606->127.0.0.1:34553: 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 14607615 242.9 ns/op Benchmark_____PubTwoQueueSub-16 14484945 243.2 ns/op Benchmark_____PubTwoQueueSub-16 14519796 243.7 ns/op Benchmark_____PubTwoQueueSub-16 14651067 242.7 ns/op Benchmark_____PubTwoQueueSub-16 14614842 243.5 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14539408 243.9 ns/op Benchmark____PubFourQueueSub-16 14658270 243.8 ns/op Benchmark____PubFourQueueSub-16 14276786 242.3 ns/op Benchmark____PubFourQueueSub-16 14473563 242.1 ns/op Benchmark____PubFourQueueSub-16 14642484 243.6 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14656068 242.2 ns/op Benchmark___PubEightQueueSub-16 14785999 243.1 ns/op Benchmark___PubEightQueueSub-16 14704771 242.8 ns/op Benchmark___PubEightQueueSub-16 14632419 242.7 ns/op Benchmark___PubEightQueueSub-16 14618403 243.3 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23245 154840 ns/op Benchmark_PubSub512kTwoConns-16 23065 155370 ns/op Benchmark_PubSub512kTwoConns-16 23011 155293 ns/op Benchmark_PubSub512kTwoConns-16 23202 155061 ns/op Benchmark_PubSub512kTwoConns-16 23186 156348 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15272755 228.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15608874 226.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15431868 226.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15411598 226.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15459866 226.3 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15405206 228.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15475815 226.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15382526 227.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15439839 226.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15480262 226.5 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11819570 307.2 ns/op Benchmark____RoutedPubSub_0b-16 11619565 309.9 ns/op Benchmark____RoutedPubSub_0b-16 11327727 311.2 ns/op Benchmark____RoutedPubSub_0b-16 11220493 308.9 ns/op Benchmark____RoutedPubSub_0b-16 11390391 314.6 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6533502 522.7 ns/op Benchmark____RoutedPubSub_1K-16 6734718 538.8 ns/op Benchmark____RoutedPubSub_1K-16 6737516 535.3 ns/op Benchmark____RoutedPubSub_1K-16 6673512 532.6 ns/op Benchmark____RoutedPubSub_1K-16 6622694 534.7 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 86312 41997 ns/op Benchmark__RoutedPubSub_100K-16 83053 43138 ns/op Benchmark__RoutedPubSub_100K-16 82622 42167 ns/op Benchmark__RoutedPubSub_100K-16 80032 44796 ns/op Benchmark__RoutedPubSub_100K-16 84771 44601 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11543372 314.8 ns/op Benchmark____Routed2QueueSub-16 9767494 322.5 ns/op Benchmark____Routed2QueueSub-16 9689104 318.0 ns/op Benchmark____Routed2QueueSub-16 9760004 318.6 ns/op Benchmark____Routed2QueueSub-16 9383053 322.1 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9605734 319.4 ns/op Benchmark____Routed4QueueSub-16 9478022 319.2 ns/op Benchmark____Routed4QueueSub-16 9338365 323.9 ns/op Benchmark____Routed4QueueSub-16 9422733 319.1 ns/op Benchmark____Routed4QueueSub-16 9505846 319.0 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9151054 333.3 ns/op Benchmark____Routed8QueueSub-16 10937895 324.7 ns/op Benchmark____Routed8QueueSub-16 9154669 332.1 ns/op Benchmark____Routed8QueueSub-16 9351540 333.2 ns/op Benchmark____Routed8QueueSub-16 8976310 335.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8643908 349.0 ns/op Benchmark___Routed16QueueSub-16 8859376 348.8 ns/op Benchmark___Routed16QueueSub-16 8866754 353.4 ns/op Benchmark___Routed16QueueSub-16 8747553 343.5 ns/op Benchmark___Routed16QueueSub-16 8780637 342.6 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6497076 549.7 ns/op Benchmark____________RouteCompressOff-16 6366277 545.8 ns/op Benchmark____________RouteCompressOff-16 6650126 545.5 ns/op Benchmark____________RouteCompressOff-16 6437906 552.5 ns/op Benchmark____________RouteCompressOff-16 6356859 549.3 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6328729 544.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6374287 548.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6653980 542.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6451519 547.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6417170 550.1 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6323889 548.8 ns/op Benchmark_________RouteCompressS2Fast-16 6283561 543.7 ns/op Benchmark_________RouteCompressS2Fast-16 6346784 544.3 ns/op Benchmark_________RouteCompressS2Fast-16 6510256 555.7 ns/op Benchmark_________RouteCompressS2Fast-16 6479290 553.0 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6572509 545.9 ns/op Benchmark_______RouteCompressS2Better-16 6532778 552.6 ns/op Benchmark_______RouteCompressS2Better-16 6508588 553.6 ns/op Benchmark_______RouteCompressS2Better-16 6577965 547.5 ns/op Benchmark_______RouteCompressS2Better-16 6507667 543.8 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6576051 546.0 ns/op Benchmark_________RouteCompressS2Best-16 6589488 543.4 ns/op Benchmark_________RouteCompressS2Best-16 6609792 548.3 ns/op Benchmark_________RouteCompressS2Best-16 6478741 546.0 ns/op Benchmark_________RouteCompressS2Best-16 6485564 543.2 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4710633 758.9 ns/op 328.09 MB/s Benchmark______FanOut_8x1x10-16 4684194 776.4 ns/op 320.72 MB/s Benchmark______FanOut_8x1x10-16 4702484 761.8 ns/op 326.88 MB/s Benchmark______FanOut_8x1x10-16 4730379 767.1 ns/op 324.61 MB/s Benchmark______FanOut_8x1x10-16 4735531 760.4 ns/op 327.46 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 520131 6095 ns/op 380.45 MB/s Benchmark_____FanOut_8x1x100-16 583494 6094 ns/op 380.53 MB/s Benchmark_____FanOut_8x1x100-16 525607 6099 ns/op 380.24 MB/s Benchmark_____FanOut_8x1x100-16 544543 6055 ns/op 383.01 MB/s Benchmark_____FanOut_8x1x100-16 570206 6026 ns/op 384.85 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48364 74814 ns/op 307.68 MB/s Benchmark____FanOut_8x10x100-16 47212 74532 ns/op 308.85 MB/s Benchmark____FanOut_8x10x100-16 46740 74714 ns/op 308.09 MB/s Benchmark____FanOut_8x10x100-16 48318 75191 ns/op 306.14 MB/s Benchmark____FanOut_8x10x100-16 48397 74994 ns/op 306.94 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5942 593793 ns/op 404.21 MB/s Benchmark___FanOut_8x10x1000-16 5678 621194 ns/op 386.38 MB/s Benchmark___FanOut_8x10x1000-16 5695 594588 ns/op 403.67 MB/s Benchmark___FanOut_8x10x1000-16 6064 611050 ns/op 392.80 MB/s Benchmark___FanOut_8x10x1000-16 5994 649079 ns/op 369.78 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5095 706742 ns/op 325.46 MB/s Benchmark___FanOut_8x100x100-16 4936 705867 ns/op 325.87 MB/s Benchmark___FanOut_8x100x100-16 4945 707548 ns/op 325.09 MB/s Benchmark___FanOut_8x100x100-16 4953 714382 ns/op 321.98 MB/s Benchmark___FanOut_8x100x100-16 4930 706360 ns/op 325.64 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 573 6208235 ns/op 386.59 MB/s Benchmark__FanOut_8x100x1000-16 580 6149481 ns/op 390.28 MB/s Benchmark__FanOut_8x100x1000-16 580 6115884 ns/op 392.42 MB/s Benchmark__FanOut_8x100x1000-16 582 6143180 ns/op 390.68 MB/s Benchmark__FanOut_8x100x1000-16 580 6097907 ns/op 393.58 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 529 6799882 ns/op 367.66 MB/s Benchmark__FanOut_8x10x10000-16 517 6823066 ns/op 366.41 MB/s Benchmark__FanOut_8x10x10000-16 519 6841524 ns/op 365.42 MB/s Benchmark__FanOut_8x10x10000-16 535 6650750 ns/op 375.90 MB/s Benchmark__FanOut_8x10x10000-16 525 6685703 ns/op 373.94 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 934 3750377 ns/op 306.64 MB/s Benchmark___FanOut_8x500x100-16 955 3746412 ns/op 306.97 MB/s Benchmark___FanOut_8x500x100-16 948 3779243 ns/op 304.30 MB/s Benchmark___FanOut_8x500x100-16 955 3757371 ns/op 306.07 MB/s Benchmark___FanOut_8x500x100-16 960 3743946 ns/op 307.17 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 355020 9537 ns/op 1535.19 MB/s Benchmark___FanOut_128x1x100-16 371378 9426 ns/op 1553.26 MB/s Benchmark___FanOut_128x1x100-16 371824 9483 ns/op 1543.89 MB/s Benchmark___FanOut_128x1x100-16 361119 9480 ns/op 1544.36 MB/s Benchmark___FanOut_128x1x100-16 357226 9520 ns/op 1537.97 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32718 110365 ns/op 1315.09 MB/s Benchmark__FanOut_128x10x100-16 32538 110500 ns/op 1313.49 MB/s Benchmark__FanOut_128x10x100-16 32553 110026 ns/op 1319.15 MB/s Benchmark__FanOut_128x10x100-16 32641 110312 ns/op 1315.73 MB/s Benchmark__FanOut_128x10x100-16 32607 110263 ns/op 1316.31 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4033 867244 ns/op 1683.66 MB/s Benchmark_FanOut_128x10x1000-16 3974 882385 ns/op 1654.77 MB/s Benchmark_FanOut_128x10x1000-16 4186 867222 ns/op 1683.70 MB/s Benchmark_FanOut_128x10x1000-16 3927 876175 ns/op 1666.50 MB/s Benchmark_FanOut_128x10x1000-16 3969 874009 ns/op 1670.62 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3510 1008557 ns/op 1437.84 MB/s Benchmark_FanOut_128x100x100-16 3544 1012033 ns/op 1432.90 MB/s Benchmark_FanOut_128x100x100-16 3529 1008031 ns/op 1438.59 MB/s Benchmark_FanOut_128x100x100-16 3453 1010142 ns/op 1435.58 MB/s Benchmark_FanOut_128x100x100-16 3446 1013078 ns/op 1431.42 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 381 9339793 ns/op 1563.22 MB/s BenchmarkFanOut_128x100x1000-16 384 9223400 ns/op 1582.95 MB/s BenchmarkFanOut_128x100x1000-16 380 9405096 ns/op 1552.36 MB/s BenchmarkFanOut_128x100x1000-16 382 9205055 ns/op 1586.10 MB/s BenchmarkFanOut_128x100x1000-16 379 9168890 ns/op 1592.36 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 376 9644721 ns/op 1524.16 MB/s BenchmarkFanOut_128x10x10000-16 372 9661563 ns/op 1521.51 MB/s BenchmarkFanOut_128x10x10000-16 374 9615138 ns/op 1528.85 MB/s BenchmarkFanOut_128x10x10000-16 373 9657272 ns/op 1522.18 MB/s BenchmarkFanOut_128x10x10000-16 373 9684964 ns/op 1517.83 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 678 5273875 ns/op 1374.73 MB/s BenchmarkFanOut__128x500x100-16 673 5240238 ns/op 1383.55 MB/s BenchmarkFanOut__128x500x100-16 673 5276313 ns/op 1374.09 MB/s BenchmarkFanOut__128x500x100-16 657 5251679 ns/op 1380.54 MB/s BenchmarkFanOut__128x500x100-16 668 5253040 ns/op 1380.18 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1952 1841440 ns/op 2873.04 MB/s Benchmark_FanOut_512x100x100-16 1962 1854057 ns/op 2853.49 MB/s Benchmark_FanOut_512x100x100-16 1934 1842963 ns/op 2870.66 MB/s Benchmark_FanOut_512x100x100-16 1921 1849967 ns/op 2859.79 MB/s Benchmark_FanOut_512x100x100-16 1941 1839777 ns/op 2875.63 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16738009 ns/op 3166.48 MB/s Benchmark__FanOut_512x100x1k-16 214 16725856 ns/op 3168.78 MB/s Benchmark__FanOut_512x100x1k-16 216 16604999 ns/op 3191.84 MB/s Benchmark__FanOut_512x100x1k-16 212 16816614 ns/op 3151.68 MB/s Benchmark__FanOut_512x100x1k-16 213 16669787 ns/op 3179.44 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2988 1161758 ns/op 8978.67 MB/s Benchmark____FanOut_1kx10x1k-16 3172 1185728 ns/op 8797.16 MB/s Benchmark____FanOut_1kx10x1k-16 3232 1138744 ns/op 9160.13 MB/s Benchmark____FanOut_1kx10x1k-16 3099 1144049 ns/op 9117.65 MB/s Benchmark____FanOut_1kx10x1k-16 3031 1156805 ns/op 9017.11 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2782 1269526 ns/op 8208.60 MB/s Benchmark__FanOut_1kx100x100-16 2791 1254251 ns/op 8308.58 MB/s Benchmark__FanOut_1kx100x100-16 2798 1255129 ns/op 8302.76 MB/s Benchmark__FanOut_1kx100x100-16 2869 1257848 ns/op 8284.82 MB/s Benchmark__FanOut_1kx100x100-16 2790 1256114 ns/op 8296.25 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4595232 777.0 ns/op 320.47 MB/s Benchmark_____RFanOut_8x1x10-16 4562845 789.3 ns/op 315.47 MB/s Benchmark_____RFanOut_8x1x10-16 4365967 768.9 ns/op 323.85 MB/s Benchmark_____RFanOut_8x1x10-16 4558418 772.7 ns/op 322.25 MB/s Benchmark_____RFanOut_8x1x10-16 4566938 769.6 ns/op 323.54 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 532116 6354 ns/op 364.96 MB/s Benchmark____RFanOut_8x1x100-16 522110 6057 ns/op 382.88 MB/s Benchmark____RFanOut_8x1x100-16 528157 6310 ns/op 367.52 MB/s Benchmark____RFanOut_8x1x100-16 531463 6093 ns/op 380.62 MB/s Benchmark____RFanOut_8x1x100-16 544112 6146 ns/op 377.29 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47776 75734 ns/op 303.95 MB/s Benchmark___RFanOut_8x10x100-16 48183 74341 ns/op 309.64 MB/s Benchmark___RFanOut_8x10x100-16 48169 76486 ns/op 300.96 MB/s Benchmark___RFanOut_8x10x100-16 48003 74959 ns/op 307.09 MB/s Benchmark___RFanOut_8x10x100-16 47599 74547 ns/op 308.78 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5958 597734 ns/op 401.55 MB/s Benchmark__RFanOut_8x10x1000-16 5772 596563 ns/op 402.34 MB/s Benchmark__RFanOut_8x10x1000-16 6020 601937 ns/op 398.74 MB/s Benchmark__RFanOut_8x10x1000-16 5793 601002 ns/op 399.36 MB/s Benchmark__RFanOut_8x10x1000-16 6048 600981 ns/op 399.38 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5044 706502 ns/op 325.57 MB/s Benchmark__RFanOut_8x100x100-16 4928 707597 ns/op 325.07 MB/s Benchmark__RFanOut_8x100x100-16 4905 708697 ns/op 324.57 MB/s Benchmark__RFanOut_8x100x100-16 4981 715163 ns/op 321.63 MB/s Benchmark__RFanOut_8x100x100-16 4962 709016 ns/op 324.42 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 572 6142497 ns/op 390.72 MB/s Benchmark_RFanOut_8x100x1000-16 578 6171483 ns/op 388.89 MB/s Benchmark_RFanOut_8x100x1000-16 556 6279392 ns/op 382.21 MB/s Benchmark_RFanOut_8x100x1000-16 558 6209853 ns/op 386.49 MB/s Benchmark_RFanOut_8x100x1000-16 571 6133478 ns/op 391.30 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 531 6868863 ns/op 363.96 MB/s Benchmark_RFanOut_8x10x10000-16 526 6767054 ns/op 369.44 MB/s Benchmark_RFanOut_8x10x10000-16 510 6851496 ns/op 364.89 MB/s Benchmark_RFanOut_8x10x10000-16 531 6740371 ns/op 370.90 MB/s Benchmark_RFanOut_8x10x10000-16 526 6690499 ns/op 373.67 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2998 1166235 ns/op 8944.20 MB/s Benchmark_RFanOut_1kx10x1000-16 3049 1151032 ns/op 9062.34 MB/s Benchmark_RFanOut_1kx10x1000-16 3178 1164010 ns/op 8961.30 MB/s Benchmark_RFanOut_1kx10x1000-16 3237 1128293 ns/op 9244.97 MB/s Benchmark_RFanOut_1kx10x1000-16 3238 1153690 ns/op 9041.46 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6965722 503.9 ns/op 4124.20 MB/s Benchmark_____FanIn_1kx100x1-16 6961164 502.8 ns/op 4132.90 MB/s Benchmark_____FanIn_1kx100x1-16 7022259 503.4 ns/op 4127.98 MB/s Benchmark_____FanIn_1kx100x1-16 6964342 502.8 ns/op 4133.26 MB/s Benchmark_____FanIn_1kx100x1-16 7038826 501.0 ns/op 4147.44 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2656179 1367 ns/op 6014.06 MB/s Benchmark_____FanIn_4kx100x1-16 2581478 1354 ns/op 6072.38 MB/s Benchmark_____FanIn_4kx100x1-16 2605353 1352 ns/op 6081.09 MB/s Benchmark_____FanIn_4kx100x1-16 2652542 1369 ns/op 6007.26 MB/s Benchmark_____FanIn_4kx100x1-16 2607805 1359 ns/op 6048.04 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1681946 2159 ns/op 7601.10 MB/s Benchmark_____FanIn_8kx100x1-16 1693906 2114 ns/op 7763.40 MB/s Benchmark_____FanIn_8kx100x1-16 1700113 2122 ns/op 7734.42 MB/s Benchmark_____FanIn_8kx100x1-16 1729866 2122 ns/op 7736.41 MB/s Benchmark_____FanIn_8kx100x1-16 1670946 2084 ns/op 7875.83 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 870829 4197 ns/op 7814.70 MB/s Benchmark____FanIn_16kx100x1-16 874372 4180 ns/op 7846.75 MB/s Benchmark____FanIn_16kx100x1-16 861926 4122 ns/op 7957.03 MB/s Benchmark____FanIn_16kx100x1-16 875659 4118 ns/op 7965.64 MB/s Benchmark____FanIn_16kx100x1-16 877281 4212 ns/op 7787.48 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 172870 19931 ns/op 6577.78 MB/s Benchmark____FanIn_64kx100x1-16 171400 20130 ns/op 6512.91 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7885239264 vs 11085012300 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49654->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:49632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50328->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 165099 19849 ns/op 6605.04 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 5991085329 vs 10855576800 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56736->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 208564190 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58680->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: 344897790 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60000->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: 467598030 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33962->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33934->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: 256149860 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35444->127.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:35668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36122->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: 444395100 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37380->127.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:37032->127.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:37464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37758->127.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:37908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37408->127.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:37360->127.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:37216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37258->127.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:37754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37356->127.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:37648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:37844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37158->127.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: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:37200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37332->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37816->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37420->127.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:37586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37266->127.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:37752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37924->127.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:37772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37874->127.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:37268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:37484->127.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: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: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:37780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37300->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5609404 637.1 ns/op 445.77 MB/s Benchmark___BumpPubCount_1x3-16 5593658 637.5 ns/op 445.48 MB/s Benchmark___BumpPubCount_1x3-16 5570113 638.6 ns/op 444.71 MB/s Benchmark___BumpPubCount_1x3-16 5570716 634.0 ns/op 447.92 MB/s Benchmark___BumpPubCount_1x3-16 5607939 636.0 ns/op 446.55 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5406259 667.2 ns/op 425.69 MB/s Benchmark___BumpPubCount_2x3-16 5323574 668.6 ns/op 424.77 MB/s Benchmark___BumpPubCount_2x3-16 5343301 672.3 ns/op 422.44 MB/s Benchmark___BumpPubCount_2x3-16 5307778 669.1 ns/op 424.46 MB/s Benchmark___BumpPubCount_2x3-16 5357854 664.7 ns/op 427.26 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5621847 641.3 ns/op 442.85 MB/s Benchmark___BumpPubCount_5x3-16 5446866 643.3 ns/op 441.44 MB/s Benchmark___BumpPubCount_5x3-16 5143495 638.4 ns/op 444.87 MB/s Benchmark___BumpPubCount_5x3-16 5553292 643.1 ns/op 441.64 MB/s Benchmark___BumpPubCount_5x3-16 5615354 643.4 ns/op 441.41 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5570082 644.3 ns/op 440.80 MB/s Benchmark__BumpPubCount_10x3-16 5584435 643.7 ns/op 441.19 MB/s Benchmark__BumpPubCount_10x3-16 5552907 642.6 ns/op 441.97 MB/s Benchmark__BumpPubCount_10x3-16 5614208 642.6 ns/op 441.95 MB/s Benchmark__BumpPubCount_10x3-16 5291300 643.5 ns/op 441.35 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12297982 269.2 ns/op 3863.41 MB/s Benchmark____GWs_Opt_1kx01x0-16 12839616 270.1 ns/op 3850.09 MB/s Benchmark____GWs_Opt_1kx01x0-16 13251459 269.0 ns/op 3865.55 MB/s Benchmark____GWs_Opt_1kx01x0-16 12726094 272.7 ns/op 3813.50 MB/s Benchmark____GWs_Opt_1kx01x0-16 12637825 269.0 ns/op 3865.49 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10623976 330.0 ns/op 6254.89 MB/s Benchmark____GWs_Opt_2kx01x0-16 10902621 333.1 ns/op 6195.49 MB/s Benchmark____GWs_Opt_2kx01x0-16 11158958 348.5 ns/op 5923.22 MB/s Benchmark____GWs_Opt_2kx01x0-16 10968408 321.9 ns/op 6411.16 MB/s Benchmark____GWs_Opt_2kx01x0-16 11196241 330.5 ns/op 6245.70 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5785515 611.0 ns/op 6729.59 MB/s Benchmark____GWs_Opt_4kx01x0-16 5872826 629.5 ns/op 6532.42 MB/s Benchmark____GWs_Opt_4kx01x0-16 5744550 632.8 ns/op 6497.78 MB/s Benchmark____GWs_Opt_4kx01x0-16 5769000 633.6 ns/op 6490.15 MB/s Benchmark____GWs_Opt_4kx01x0-16 5637555 613.3 ns/op 6704.28 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28793176 112.1 ns/op 9276.52 MB/s Benchmark____GWs_Opt_1kx10x0-16 32334388 113.3 ns/op 9182.43 MB/s Benchmark____GWs_Opt_1kx10x0-16 27960303 110.5 ns/op 9411.12 MB/s Benchmark____GWs_Opt_1kx10x0-16 32330030 115.6 ns/op 8998.36 MB/s Benchmark____GWs_Opt_1kx10x0-16 31496143 110.7 ns/op 9397.32 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 18436462 186.4 ns/op 11071.23 MB/s Benchmark____GWs_Opt_2kx10x0-16 25594075 164.2 ns/op 12566.92 MB/s Benchmark____GWs_Opt_2kx10x0-16 24459631 156.5 ns/op 13185.26 MB/s Benchmark____GWs_Opt_2kx10x0-16 24546811 144.4 ns/op 14297.54 MB/s Benchmark____GWs_Opt_2kx10x0-16 20577720 162.6 ns/op 12696.63 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12518931 352.6 ns/op 11661.45 MB/s Benchmark____GWs_Opt_4kx10x0-16 12212462 333.9 ns/op 12314.08 MB/s Benchmark____GWs_Opt_4kx10x0-16 12306315 307.9 ns/op 13355.53 MB/s Benchmark____GWs_Opt_4kx10x0-16 13151791 331.9 ns/op 12389.87 MB/s Benchmark____GWs_Opt_4kx10x0-16 12736408 286.3 ns/op 14362.67 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6545066 547.1 ns/op 5712.05 MB/s Benchmark____GWs_Opt_1kx01x1-16 6801955 544.2 ns/op 5742.83 MB/s Benchmark____GWs_Opt_1kx01x1-16 6570170 550.9 ns/op 5672.07 MB/s Benchmark____GWs_Opt_1kx01x1-16 6589947 541.3 ns/op 5773.41 MB/s Benchmark____GWs_Opt_1kx01x1-16 6437265 545.9 ns/op 5724.41 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4627504 759.9 ns/op 8155.36 MB/s Benchmark____GWs_Opt_2kx01x1-16 4764490 772.6 ns/op 8021.24 MB/s Benchmark____GWs_Opt_2kx01x1-16 4398655 771.9 ns/op 8028.50 MB/s Benchmark____GWs_Opt_2kx01x1-16 4476782 768.3 ns/op 8065.60 MB/s Benchmark____GWs_Opt_2kx01x1-16 4659502 755.3 ns/op 8204.91 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2615761 1401 ns/op 8808.37 MB/s Benchmark____GWs_Opt_4kx01x1-16 2676039 1378 ns/op 8956.75 MB/s Benchmark____GWs_Opt_4kx01x1-16 2618076 1380 ns/op 8943.98 MB/s Benchmark____GWs_Opt_4kx01x1-16 2528617 1391 ns/op 8874.08 MB/s Benchmark____GWs_Opt_4kx01x1-16 2578372 1378 ns/op 8955.31 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6000484 555.8 ns/op 5622.74 MB/s Benchmark____GWs_Opt_1kx10x1-16 6101937 554.5 ns/op 5636.13 MB/s Benchmark____GWs_Opt_1kx10x1-16 6567724 555.4 ns/op 5626.56 MB/s Benchmark____GWs_Opt_1kx10x1-16 6238647 555.7 ns/op 5623.05 MB/s Benchmark____GWs_Opt_1kx10x1-16 6574562 553.5 ns/op 5645.47 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4111135 840.9 ns/op 7369.51 MB/s Benchmark____GWs_Opt_2kx10x1-16 4207222 831.2 ns/op 7455.77 MB/s Benchmark____GWs_Opt_2kx10x1-16 4261666 856.3 ns/op 7237.33 MB/s Benchmark____GWs_Opt_2kx10x1-16 4114568 852.7 ns/op 7267.87 MB/s Benchmark____GWs_Opt_2kx10x1-16 3991530 852.9 ns/op 7265.94 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2574147 1534 ns/op 8046.98 MB/s Benchmark____GWs_Opt_4kx10x1-16 2420800 1530 ns/op 8066.46 MB/s Benchmark____GWs_Opt_4kx10x1-16 2298385 1522 ns/op 8107.82 MB/s Benchmark____GWs_Opt_4kx10x1-16 2368345 1524 ns/op 8095.60 MB/s Benchmark____GWs_Opt_4kx10x1-16 2302710 1463 ns/op 8438.14 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12812162 285.6 ns/op 3641.81 MB/s Benchmark____GWs_Int_1kx01x0-16 11987071 294.2 ns/op 3535.49 MB/s Benchmark____GWs_Int_1kx01x0-16 12468116 285.8 ns/op 3638.90 MB/s Benchmark____GWs_Int_1kx01x0-16 12456171 286.9 ns/op 3624.41 MB/s Benchmark____GWs_Int_1kx01x0-16 12812629 277.6 ns/op 3746.21 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9874552 348.6 ns/op 5921.40 MB/s Benchmark____GWs_Int_2kx01x0-16 9916070 347.9 ns/op 5932.10 MB/s Benchmark____GWs_Int_2kx01x0-16 10421298 352.1 ns/op 5862.71 MB/s Benchmark____GWs_Int_2kx01x0-16 10218747 346.8 ns/op 5950.95 MB/s Benchmark____GWs_Int_2kx01x0-16 9879303 360.8 ns/op 5720.35 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5711342 635.2 ns/op 6473.30 MB/s Benchmark____GWs_Int_4kx01x0-16 5855996 613.9 ns/op 6697.91 MB/s Benchmark____GWs_Int_4kx01x0-16 5570560 719.4 ns/op 5715.63 MB/s Benchmark____GWs_Int_4kx01x0-16 5692186 639.5 ns/op 6430.06 MB/s Benchmark____GWs_Int_4kx01x0-16 5797021 638.5 ns/op 6439.86 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31260774 110.7 ns/op 9392.08 MB/s Benchmark____GWs_Int_1kx10x0-16 26640645 114.5 ns/op 9080.32 MB/s Benchmark____GWs_Int_1kx10x0-16 31310976 122.6 ns/op 8485.26 MB/s Benchmark____GWs_Int_1kx10x0-16 30303843 111.7 ns/op 9308.68 MB/s Benchmark____GWs_Int_1kx10x0-16 26939792 112.9 ns/op 9209.19 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24380214 138.8 ns/op 14875.17 MB/s Benchmark____GWs_Int_2kx10x0-16 26360942 148.5 ns/op 13903.16 MB/s Benchmark____GWs_Int_2kx10x0-16 21541095 162.2 ns/op 12726.26 MB/s Benchmark____GWs_Int_2kx10x0-16 23368910 138.0 ns/op 14960.92 MB/s Benchmark____GWs_Int_2kx10x0-16 24802723 142.1 ns/op 14530.08 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11046337 332.1 ns/op 12380.08 MB/s Benchmark____GWs_Int_4kx10x0-16 11966001 296.5 ns/op 13868.46 MB/s Benchmark____GWs_Int_4kx10x0-16 12885884 298.9 ns/op 13756.00 MB/s Benchmark____GWs_Int_4kx10x0-16 11116550 278.7 ns/op 14755.82 MB/s Benchmark____GWs_Int_4kx10x0-16 13138929 278.2 ns/op 14780.34 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6574568 558.3 ns/op 5597.42 MB/s Benchmark____GWs_Int_1kx01x1-16 6324619 554.3 ns/op 5637.54 MB/s Benchmark____GWs_Int_1kx01x1-16 6313257 548.6 ns/op 5696.83 MB/s Benchmark____GWs_Int_1kx01x1-16 6507466 722.6 ns/op 4324.61 MB/s Benchmark____GWs_Int_1kx01x1-16 6324364 564.9 ns/op 5532.23 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4724647 773.7 ns/op 8009.71 MB/s Benchmark____GWs_Int_2kx01x1-16 4655919 787.2 ns/op 7872.38 MB/s Benchmark____GWs_Int_2kx01x1-16 4782842 770.0 ns/op 8047.61 MB/s Benchmark____GWs_Int_2kx01x1-16 4650856 786.3 ns/op 7881.44 MB/s Benchmark____GWs_Int_2kx01x1-16 4689004 767.1 ns/op 8078.80 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2630133 1571 ns/op 7853.48 MB/s Benchmark____GWs_Int_4kx01x1-16 2282158 1380 ns/op 8945.18 MB/s Benchmark____GWs_Int_4kx01x1-16 2595909 1382 ns/op 8931.46 MB/s Benchmark____GWs_Int_4kx01x1-16 2568511 1379 ns/op 8946.43 MB/s Benchmark____GWs_Int_4kx01x1-16 2630595 1439 ns/op 8574.90 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6106639 572.7 ns/op 5456.74 MB/s Benchmark____GWs_Int_1kx10x1-16 6407398 550.6 ns/op 5675.86 MB/s Benchmark____GWs_Int_1kx10x1-16 6083248 552.2 ns/op 5658.88 MB/s Benchmark____GWs_Int_1kx10x1-16 6549520 552.6 ns/op 5655.09 MB/s Benchmark____GWs_Int_1kx10x1-16 6545073 562.8 ns/op 5552.69 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 3938884 848.0 ns/op 7308.11 MB/s Benchmark____GWs_Int_2kx10x1-16 4213840 855.8 ns/op 7240.89 MB/s Benchmark____GWs_Int_2kx10x1-16 4134712 849.4 ns/op 7296.14 MB/s Benchmark____GWs_Int_2kx10x1-16 4228408 840.2 ns/op 7375.56 MB/s Benchmark____GWs_Int_2kx10x1-16 4226698 838.9 ns/op 7386.79 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2324905 1502 ns/op 8216.02 MB/s Benchmark____GWs_Int_4kx10x1-16 2351955 1515 ns/op 8148.27 MB/s Benchmark____GWs_Int_4kx10x1-16 2392190 1542 ns/op 8004.31 MB/s Benchmark____GWs_Int_4kx10x1-16 2368516 1527 ns/op 8083.45 MB/s Benchmark____GWs_Int_4kx10x1-16 2334312 1652 ns/op 7469.27 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8390510 428.0 ns/op 238.31 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8370979 428.6 ns/op 237.99 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8496826 431.7 ns/op 236.25 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8330554 423.0 ns/op 241.14 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8577702 428.8 ns/op 237.85 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 729714 5076 ns/op 34.87 MB/s Benchmark__GWs_Reqs_1SubEach-16 755338 5438 ns/op 32.55 MB/s Benchmark__GWs_Reqs_1SubEach-16 741733 5173 ns/op 34.22 MB/s Benchmark__GWs_Reqs_1SubEach-16 790602 5258 ns/op 33.66 MB/s Benchmark__GWs_Reqs_1SubEach-16 750763 5221 ns/op 33.90 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2082.804s ❌ Non-zero exit code: 1