> ROOT_DIR=/tmp/go-bench-away-job-4c9677f6-b85a-4d99-90f1-8ec170e6d4ba-2348498196 > OUTPUT_FILE=/tmp/go-bench-away-job-4c9677f6-b85a-4d99-90f1-8ec170e6d4ba-2348498196/results.txt > SHA_FILE=/tmp/go-bench-away-job-4c9677f6-b85a-4d99-90f1-8ec170e6d4ba-2348498196/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-4c9677f6-b85a-4d99-90f1-8ec170e6d4ba-2348498196/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=v2.14.1 > 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: v2.14.1 to /tmp/go-bench-away-job-4c9677f6-b85a-4d99-90f1-8ec170e6d4ba-2348498196/source.git SHA of v2.14.1: fb32a3531f11a1c36b6e43ec5d7d341fc14f053e 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-build110333237=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-4c9677f6-b85a-4d99-90f1-8ec170e6d4ba-2348498196/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 48127162 74.49 ns/op 147.67 MB/s Benchmark______Pub0b_Payload-16 45988195 74.51 ns/op 147.64 MB/s Benchmark______Pub0b_Payload-16 45850522 76.69 ns/op 143.43 MB/s Benchmark______Pub0b_Payload-16 45523718 74.86 ns/op 146.94 MB/s Benchmark______Pub0b_Payload-16 45418699 74.65 ns/op 147.35 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 44958009 75.17 ns/op 252.78 MB/s Benchmark______Pub8b_Payload-16 47744112 76.33 ns/op 248.92 MB/s Benchmark______Pub8b_Payload-16 45008059 75.25 ns/op 252.51 MB/s Benchmark______Pub8b_Payload-16 45673395 75.32 ns/op 252.26 MB/s Benchmark______Pub8b_Payload-16 44891029 75.35 ns/op 252.17 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 42588448 80.22 ns/op 548.46 MB/s Benchmark_____Pub32b_Payload-16 37078749 82.47 ns/op 533.55 MB/s Benchmark_____Pub32b_Payload-16 42751428 83.49 ns/op 526.98 MB/s Benchmark_____Pub32b_Payload-16 42193693 80.79 ns/op 544.64 MB/s Benchmark_____Pub32b_Payload-16 42716950 80.52 ns/op 546.47 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38253654 91.84 ns/op 1535.31 MB/s Benchmark____Pub128B_Payload-16 39958860 89.70 ns/op 1571.96 MB/s Benchmark____Pub128B_Payload-16 39735861 91.44 ns/op 1541.92 MB/s Benchmark____Pub128B_Payload-16 33600655 90.83 ns/op 1552.35 MB/s Benchmark____Pub128B_Payload-16 37492138 90.41 ns/op 1559.48 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 34669387 98.88 ns/op 2720.45 MB/s Benchmark____Pub256B_Payload-16 35817382 98.98 ns/op 2717.67 MB/s Benchmark____Pub256B_Payload-16 30402972 99.01 ns/op 2716.97 MB/s Benchmark____Pub256B_Payload-16 31079900 99.39 ns/op 2706.50 MB/s Benchmark____Pub256B_Payload-16 30934238 98.90 ns/op 2719.91 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24425090 149.6 ns/op 6937.38 MB/s Benchmark______Pub1K_Payload-16 23227377 147.6 ns/op 7031.26 MB/s Benchmark______Pub1K_Payload-16 23098684 140.7 ns/op 7378.10 MB/s Benchmark______Pub1K_Payload-16 23913354 141.7 ns/op 7323.02 MB/s Benchmark______Pub1K_Payload-16 22274985 148.4 ns/op 6992.63 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5708082 621.0 ns/op 6617.83 MB/s Benchmark______Pub4K_Payload-16 5692435 614.6 ns/op 6687.74 MB/s Benchmark______Pub4K_Payload-16 5548146 616.0 ns/op 6672.36 MB/s Benchmark______Pub4K_Payload-16 5854008 624.6 ns/op 6579.79 MB/s Benchmark______Pub4K_Payload-16 5446278 620.5 ns/op 6624.03 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2732076 1260 ns/op 6511.57 MB/s Benchmark______Pub8K_Payload-16 2728693 1277 ns/op 6427.81 MB/s Benchmark______Pub8K_Payload-16 2819886 1283 ns/op 6396.53 MB/s Benchmark______Pub8K_Payload-16 2737776 1281 ns/op 6404.57 MB/s Benchmark______Pub8K_Payload-16 2742844 1283 ns/op 6398.41 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 593463 5456 ns/op 6008.61 MB/s Benchmark_____Pub32K_Payload-16 457705 9283 ns/op 3531.40 MB/s Benchmark_____Pub32K_Payload-16 657157 5588 ns/op 5866.67 MB/s Benchmark_____Pub32K_Payload-16 559094 5580 ns/op 5875.13 MB/s Benchmark_____Pub32K_Payload-16 664863 5595 ns/op 5859.15 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 30935812 98.45 ns/op 111.73 MB/s Benchmark__AuthPub0b_Payload-16 31291636 98.13 ns/op 112.10 MB/s Benchmark__AuthPub0b_Payload-16 34789665 98.38 ns/op 111.81 MB/s Benchmark__AuthPub0b_Payload-16 31020542 98.47 ns/op 111.71 MB/s Benchmark__AuthPub0b_Payload-16 34694161 98.14 ns/op 112.09 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15242854 231.8 ns/op Benchmark_____________PubSub-16 15337462 231.9 ns/op Benchmark_____________PubSub-16 15170180 231.6 ns/op Benchmark_____________PubSub-16 15228556 231.8 ns/op Benchmark_____________PubSub-16 15249032 231.3 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15358711 230.5 ns/op Benchmark_____PubSubTwoConns-16 15240037 229.5 ns/op Benchmark_____PubSubTwoConns-16 15487154 231.8 ns/op Benchmark_____PubSubTwoConns-16 15276159 230.6 ns/op Benchmark_____PubSubTwoConns-16 15377158 230.0 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51600->127.0.0.1:45999: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:48790->127.0.0.1:44781: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:60142->127.0.0.1:35493: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59690->127.0.0.1:35857: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:36202->127.0.0.1:40467: 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 14186702 249.5 ns/op Benchmark_____PubTwoQueueSub-16 13985508 250.1 ns/op Benchmark_____PubTwoQueueSub-16 13955535 250.0 ns/op Benchmark_____PubTwoQueueSub-16 14054894 249.9 ns/op Benchmark_____PubTwoQueueSub-16 14204823 249.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14064748 250.3 ns/op Benchmark____PubFourQueueSub-16 14169108 250.8 ns/op Benchmark____PubFourQueueSub-16 14311887 250.7 ns/op Benchmark____PubFourQueueSub-16 14172771 250.1 ns/op Benchmark____PubFourQueueSub-16 13868185 250.2 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14246077 249.2 ns/op Benchmark___PubEightQueueSub-16 14156960 250.2 ns/op Benchmark___PubEightQueueSub-16 14153733 250.5 ns/op Benchmark___PubEightQueueSub-16 14089158 249.7 ns/op Benchmark___PubEightQueueSub-16 14274153 249.9 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23188 155776 ns/op Benchmark_PubSub512kTwoConns-16 22903 169108 ns/op Benchmark_PubSub512kTwoConns-16 22608 158337 ns/op Benchmark_PubSub512kTwoConns-16 22746 159081 ns/op Benchmark_PubSub512kTwoConns-16 22585 159299 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14944515 234.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15006926 234.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15010706 234.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15099140 234.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 14837379 233.8 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14831137 234.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 14929110 234.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 14731812 234.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 14879202 233.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 14929454 235.8 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10879426 320.3 ns/op Benchmark____RoutedPubSub_0b-16 10909634 314.8 ns/op Benchmark____RoutedPubSub_0b-16 11262936 320.7 ns/op Benchmark____RoutedPubSub_0b-16 10956482 319.6 ns/op Benchmark____RoutedPubSub_0b-16 10815380 323.0 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6041514 661.3 ns/op Benchmark____RoutedPubSub_1K-16 6625542 547.3 ns/op Benchmark____RoutedPubSub_1K-16 6598448 545.8 ns/op Benchmark____RoutedPubSub_1K-16 6394983 551.2 ns/op Benchmark____RoutedPubSub_1K-16 6721032 547.0 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 82243 43436 ns/op Benchmark__RoutedPubSub_100K-16 80510 43254 ns/op Benchmark__RoutedPubSub_100K-16 79269 44364 ns/op Benchmark__RoutedPubSub_100K-16 80007 44730 ns/op Benchmark__RoutedPubSub_100K-16 78741 45718 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9829537 319.4 ns/op Benchmark____Routed2QueueSub-16 9652927 318.4 ns/op Benchmark____Routed2QueueSub-16 9840108 320.6 ns/op Benchmark____Routed2QueueSub-16 9503096 325.4 ns/op Benchmark____Routed2QueueSub-16 9507214 320.7 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9603343 328.5 ns/op Benchmark____Routed4QueueSub-16 9623805 322.4 ns/op Benchmark____Routed4QueueSub-16 9323985 325.9 ns/op Benchmark____Routed4QueueSub-16 9610974 330.0 ns/op Benchmark____Routed4QueueSub-16 9394683 326.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9250312 335.3 ns/op Benchmark____Routed8QueueSub-16 9124558 329.0 ns/op Benchmark____Routed8QueueSub-16 9253023 337.0 ns/op Benchmark____Routed8QueueSub-16 9102422 335.8 ns/op Benchmark____Routed8QueueSub-16 10738593 329.3 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8682507 347.6 ns/op Benchmark___Routed16QueueSub-16 8692567 354.5 ns/op Benchmark___Routed16QueueSub-16 8662216 347.5 ns/op Benchmark___Routed16QueueSub-16 8776303 359.1 ns/op Benchmark___Routed16QueueSub-16 9228088 357.4 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6219040 558.6 ns/op Benchmark____________RouteCompressOff-16 6431460 560.9 ns/op Benchmark____________RouteCompressOff-16 6326426 553.4 ns/op Benchmark____________RouteCompressOff-16 6399574 554.9 ns/op Benchmark____________RouteCompressOff-16 6308686 546.0 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6327616 552.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6475533 554.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6343460 552.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6419326 546.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6397058 551.4 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6463945 547.6 ns/op Benchmark_________RouteCompressS2Fast-16 6216094 552.2 ns/op Benchmark_________RouteCompressS2Fast-16 6534883 551.5 ns/op Benchmark_________RouteCompressS2Fast-16 6469470 554.8 ns/op Benchmark_________RouteCompressS2Fast-16 6454333 552.3 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6412137 550.3 ns/op Benchmark_______RouteCompressS2Better-16 6586312 552.9 ns/op Benchmark_______RouteCompressS2Better-16 6396946 550.8 ns/op Benchmark_______RouteCompressS2Better-16 6479468 549.6 ns/op Benchmark_______RouteCompressS2Better-16 6373063 553.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6394218 547.7 ns/op Benchmark_________RouteCompressS2Best-16 6465906 554.1 ns/op Benchmark_________RouteCompressS2Best-16 6460671 554.4 ns/op Benchmark_________RouteCompressS2Best-16 6345339 551.6 ns/op Benchmark_________RouteCompressS2Best-16 6223657 550.7 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4666074 771.3 ns/op 322.84 MB/s Benchmark______FanOut_8x1x10-16 4601941 773.0 ns/op 322.14 MB/s Benchmark______FanOut_8x1x10-16 4636452 768.9 ns/op 323.82 MB/s Benchmark______FanOut_8x1x10-16 4598163 769.2 ns/op 323.70 MB/s Benchmark______FanOut_8x1x10-16 4590386 774.3 ns/op 321.59 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 520876 6282 ns/op 369.17 MB/s Benchmark_____FanOut_8x1x100-16 539064 6112 ns/op 379.44 MB/s Benchmark_____FanOut_8x1x100-16 534600 6280 ns/op 369.27 MB/s Benchmark_____FanOut_8x1x100-16 543247 6118 ns/op 379.02 MB/s Benchmark_____FanOut_8x1x100-16 523696 6125 ns/op 378.60 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47580 74870 ns/op 307.45 MB/s Benchmark____FanOut_8x10x100-16 47805 75232 ns/op 305.97 MB/s Benchmark____FanOut_8x10x100-16 47448 75146 ns/op 306.33 MB/s Benchmark____FanOut_8x10x100-16 47302 75489 ns/op 304.93 MB/s Benchmark____FanOut_8x10x100-16 47210 74889 ns/op 307.38 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6009 606108 ns/op 396.00 MB/s Benchmark___FanOut_8x10x1000-16 5872 609793 ns/op 393.61 MB/s Benchmark___FanOut_8x10x1000-16 5859 607699 ns/op 394.96 MB/s Benchmark___FanOut_8x10x1000-16 5948 604806 ns/op 396.85 MB/s Benchmark___FanOut_8x10x1000-16 5632 605621 ns/op 396.32 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4968 716839 ns/op 320.88 MB/s Benchmark___FanOut_8x100x100-16 5035 719117 ns/op 319.86 MB/s Benchmark___FanOut_8x100x100-16 5012 716452 ns/op 321.05 MB/s Benchmark___FanOut_8x100x100-16 4948 719337 ns/op 319.77 MB/s Benchmark___FanOut_8x100x100-16 4930 714830 ns/op 321.78 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 565 6289157 ns/op 381.61 MB/s Benchmark__FanOut_8x100x1000-16 554 6266719 ns/op 382.98 MB/s Benchmark__FanOut_8x100x1000-16 571 6259545 ns/op 383.42 MB/s Benchmark__FanOut_8x100x1000-16 550 6266913 ns/op 382.97 MB/s Benchmark__FanOut_8x100x1000-16 568 6247553 ns/op 384.15 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 523 6826776 ns/op 366.21 MB/s Benchmark__FanOut_8x10x10000-16 523 6891872 ns/op 362.75 MB/s Benchmark__FanOut_8x10x10000-16 517 6875136 ns/op 363.63 MB/s Benchmark__FanOut_8x10x10000-16 524 6785954 ns/op 368.41 MB/s Benchmark__FanOut_8x10x10000-16 522 6812065 ns/op 367.00 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 938 3805547 ns/op 302.20 MB/s Benchmark___FanOut_8x500x100-16 936 3887322 ns/op 295.84 MB/s Benchmark___FanOut_8x500x100-16 940 3838457 ns/op 299.60 MB/s Benchmark___FanOut_8x500x100-16 936 3816515 ns/op 301.33 MB/s Benchmark___FanOut_8x500x100-16 940 3795204 ns/op 303.02 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 359659 9496 ns/op 1541.79 MB/s Benchmark___FanOut_128x1x100-16 354910 9572 ns/op 1529.56 MB/s Benchmark___FanOut_128x1x100-16 338622 9516 ns/op 1538.49 MB/s Benchmark___FanOut_128x1x100-16 360592 9537 ns/op 1535.23 MB/s Benchmark___FanOut_128x1x100-16 376084 9494 ns/op 1542.13 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32532 111448 ns/op 1302.32 MB/s Benchmark__FanOut_128x10x100-16 32157 111484 ns/op 1301.90 MB/s Benchmark__FanOut_128x10x100-16 32354 112309 ns/op 1292.33 MB/s Benchmark__FanOut_128x10x100-16 32120 110876 ns/op 1309.04 MB/s Benchmark__FanOut_128x10x100-16 32266 111571 ns/op 1300.88 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3948 896437 ns/op 1628.83 MB/s Benchmark_FanOut_128x10x1000-16 3800 879383 ns/op 1660.42 MB/s Benchmark_FanOut_128x10x1000-16 4124 890975 ns/op 1638.81 MB/s Benchmark_FanOut_128x10x1000-16 4036 891945 ns/op 1637.03 MB/s Benchmark_FanOut_128x10x1000-16 3724 890409 ns/op 1639.86 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3543 1014419 ns/op 1429.53 MB/s Benchmark_FanOut_128x100x100-16 3499 1015056 ns/op 1428.63 MB/s Benchmark_FanOut_128x100x100-16 3504 1015438 ns/op 1428.09 MB/s Benchmark_FanOut_128x100x100-16 3526 1013795 ns/op 1430.41 MB/s Benchmark_FanOut_128x100x100-16 3481 1013520 ns/op 1430.80 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 376 9561891 ns/op 1526.91 MB/s BenchmarkFanOut_128x100x1000-16 372 9350838 ns/op 1561.37 MB/s BenchmarkFanOut_128x100x1000-16 380 9508896 ns/op 1535.42 MB/s BenchmarkFanOut_128x100x1000-16 382 9389524 ns/op 1554.94 MB/s BenchmarkFanOut_128x100x1000-16 380 9335518 ns/op 1563.93 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 370 9811167 ns/op 1498.31 MB/s BenchmarkFanOut_128x10x10000-16 367 9712890 ns/op 1513.47 MB/s BenchmarkFanOut_128x10x10000-16 372 9715909 ns/op 1513.00 MB/s BenchmarkFanOut_128x10x10000-16 370 9758708 ns/op 1506.36 MB/s BenchmarkFanOut_128x10x10000-16 372 9775073 ns/op 1503.84 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 673 5319091 ns/op 1363.04 MB/s BenchmarkFanOut__128x500x100-16 669 5267488 ns/op 1376.39 MB/s BenchmarkFanOut__128x500x100-16 666 5312856 ns/op 1364.64 MB/s BenchmarkFanOut__128x500x100-16 673 5297559 ns/op 1368.58 MB/s BenchmarkFanOut__128x500x100-16 661 5327596 ns/op 1360.87 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1927 1843311 ns/op 2870.12 MB/s Benchmark_FanOut_512x100x100-16 1950 1840946 ns/op 2873.81 MB/s Benchmark_FanOut_512x100x100-16 1942 1824276 ns/op 2900.07 MB/s Benchmark_FanOut_512x100x100-16 1933 1843102 ns/op 2870.45 MB/s Benchmark_FanOut_512x100x100-16 1920 1832147 ns/op 2887.61 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16609605 ns/op 3190.96 MB/s Benchmark__FanOut_512x100x1k-16 216 16681330 ns/op 3177.24 MB/s Benchmark__FanOut_512x100x1k-16 216 16604468 ns/op 3191.94 MB/s Benchmark__FanOut_512x100x1k-16 212 16429290 ns/op 3225.98 MB/s Benchmark__FanOut_512x100x1k-16 214 16760139 ns/op 3162.30 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2876 1143982 ns/op 9118.18 MB/s Benchmark____FanOut_1kx10x1k-16 3153 1141283 ns/op 9139.74 MB/s Benchmark____FanOut_1kx10x1k-16 2818 1127926 ns/op 9247.98 MB/s Benchmark____FanOut_1kx10x1k-16 3163 1165158 ns/op 8952.47 MB/s Benchmark____FanOut_1kx10x1k-16 2830 1156607 ns/op 9018.66 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2804 1260263 ns/op 8268.94 MB/s Benchmark__FanOut_1kx100x100-16 2811 1256511 ns/op 8293.63 MB/s Benchmark__FanOut_1kx100x100-16 2780 1255777 ns/op 8298.48 MB/s Benchmark__FanOut_1kx100x100-16 2834 1261804 ns/op 8258.84 MB/s Benchmark__FanOut_1kx100x100-16 2764 1255275 ns/op 8301.79 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4354960 780.5 ns/op 319.04 MB/s Benchmark_____RFanOut_8x1x10-16 4472788 788.3 ns/op 315.87 MB/s Benchmark_____RFanOut_8x1x10-16 4491931 779.3 ns/op 319.50 MB/s Benchmark_____RFanOut_8x1x10-16 4501335 777.0 ns/op 320.48 MB/s Benchmark_____RFanOut_8x1x10-16 4457530 785.2 ns/op 317.11 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 529287 6304 ns/op 367.84 MB/s Benchmark____RFanOut_8x1x100-16 538533 6275 ns/op 369.56 MB/s Benchmark____RFanOut_8x1x100-16 505894 6238 ns/op 371.73 MB/s Benchmark____RFanOut_8x1x100-16 553381 6194 ns/op 374.36 MB/s Benchmark____RFanOut_8x1x100-16 524806 6399 ns/op 362.38 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46761 76595 ns/op 300.53 MB/s Benchmark___RFanOut_8x10x100-16 47587 74769 ns/op 307.87 MB/s Benchmark___RFanOut_8x10x100-16 47112 75382 ns/op 305.37 MB/s Benchmark___RFanOut_8x10x100-16 47990 75736 ns/op 303.94 MB/s Benchmark___RFanOut_8x10x100-16 47532 74689 ns/op 308.20 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5706 607807 ns/op 394.89 MB/s Benchmark__RFanOut_8x10x1000-16 5815 607410 ns/op 395.15 MB/s Benchmark__RFanOut_8x10x1000-16 5662 615014 ns/op 390.27 MB/s Benchmark__RFanOut_8x10x1000-16 5870 609286 ns/op 393.94 MB/s Benchmark__RFanOut_8x10x1000-16 5877 609469 ns/op 393.82 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5011 716656 ns/op 320.96 MB/s Benchmark__RFanOut_8x100x100-16 4993 713240 ns/op 322.50 MB/s Benchmark__RFanOut_8x100x100-16 4956 710562 ns/op 323.71 MB/s Benchmark__RFanOut_8x100x100-16 4960 722592 ns/op 318.32 MB/s Benchmark__RFanOut_8x100x100-16 4897 718157 ns/op 320.29 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 542 6309510 ns/op 380.38 MB/s Benchmark_RFanOut_8x100x1000-16 550 6273084 ns/op 382.59 MB/s Benchmark_RFanOut_8x100x1000-16 573 6378465 ns/op 376.27 MB/s Benchmark_RFanOut_8x100x1000-16 547 6204933 ns/op 386.79 MB/s Benchmark_RFanOut_8x100x1000-16 541 6215035 ns/op 386.16 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 528 6867020 ns/op 364.06 MB/s Benchmark_RFanOut_8x10x10000-16 522 6889792 ns/op 362.86 MB/s Benchmark_RFanOut_8x10x10000-16 525 6782172 ns/op 368.62 MB/s Benchmark_RFanOut_8x10x10000-16 516 6935704 ns/op 360.46 MB/s Benchmark_RFanOut_8x10x10000-16 508 6825138 ns/op 366.30 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2912 1148138 ns/op 9085.18 MB/s Benchmark_RFanOut_1kx10x1000-16 3112 1162620 ns/op 8972.01 MB/s Benchmark_RFanOut_1kx10x1000-16 3021 1145180 ns/op 9108.65 MB/s Benchmark_RFanOut_1kx10x1000-16 3091 1128147 ns/op 9246.17 MB/s Benchmark_RFanOut_1kx10x1000-16 3078 1153875 ns/op 9040.01 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6926212 509.7 ns/op 4076.70 MB/s Benchmark_____FanIn_1kx100x1-16 6837843 512.8 ns/op 4052.65 MB/s Benchmark_____FanIn_1kx100x1-16 6903201 509.1 ns/op 4081.36 MB/s Benchmark_____FanIn_1kx100x1-16 6924435 510.9 ns/op 4067.18 MB/s Benchmark_____FanIn_1kx100x1-16 6913531 509.3 ns/op 4080.40 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2618748 1373 ns/op 5989.40 MB/s Benchmark_____FanIn_4kx100x1-16 2607421 1378 ns/op 5968.08 MB/s Benchmark_____FanIn_4kx100x1-16 2579496 1375 ns/op 5981.50 MB/s Benchmark_____FanIn_4kx100x1-16 2548899 1364 ns/op 6027.65 MB/s Benchmark_____FanIn_4kx100x1-16 2601999 1369 ns/op 6004.73 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1711486 2102 ns/op 7808.15 MB/s Benchmark_____FanIn_8kx100x1-16 1678719 2135 ns/op 7687.74 MB/s Benchmark_____FanIn_8kx100x1-16 1688956 2127 ns/op 7716.34 MB/s Benchmark_____FanIn_8kx100x1-16 1686310 2137 ns/op 7680.37 MB/s Benchmark_____FanIn_8kx100x1-16 1701001 2150 ns/op 7633.74 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 864264 4124 ns/op 7952.48 MB/s Benchmark____FanIn_16kx100x1-16 871261 4193 ns/op 7823.26 MB/s Benchmark____FanIn_16kx100x1-16 859418 4144 ns/op 7916.00 MB/s Benchmark____FanIn_16kx100x1-16 878418 4197 ns/op 7815.11 MB/s Benchmark____FanIn_16kx100x1-16 861872 4163 ns/op 7879.44 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7056387132 vs 11963422500 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50438->127.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:50524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50178->127.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:50430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49968->127.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:50450->127.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: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:49830->127.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:50574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50422->127.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:50022->127.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:49832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50014->127.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:50038->127.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: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:49980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50152->127.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:50490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50264->127.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: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:50218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50576->127.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:50644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50398->127.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:50226->127.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:50496->127.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:50476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50548->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:50568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50400->127.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:50358->127.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:49886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49966->127.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:49916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50514->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 166272 19913 ns/op 6583.87 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 4776912663 vs 6417638700 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55550->127.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:55592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55850->127.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:55984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56090->127.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:56244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56100->127.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: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:56192->127.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:56074->127.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:56152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55530->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 164384 20133 ns/op 6511.89 MB/s Benchmark____FanIn_64kx100x1-16 166426 19890 ns/op 6591.34 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1084114300 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40142->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: 263490900 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42084->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42534->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41898->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42212->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41880->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42048->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42686->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42628->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 173956430 vs 11483484000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45340->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45452->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 330871160 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46814->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: 455275570 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48434->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5558805 644.5 ns/op 440.66 MB/s Benchmark___BumpPubCount_1x3-16 5535332 652.3 ns/op 435.35 MB/s Benchmark___BumpPubCount_1x3-16 5535777 648.4 ns/op 437.98 MB/s Benchmark___BumpPubCount_1x3-16 5547853 647.1 ns/op 438.90 MB/s Benchmark___BumpPubCount_1x3-16 5491536 651.7 ns/op 435.80 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5239857 673.4 ns/op 421.74 MB/s Benchmark___BumpPubCount_2x3-16 5245363 676.1 ns/op 420.04 MB/s Benchmark___BumpPubCount_2x3-16 5334554 679.2 ns/op 418.12 MB/s Benchmark___BumpPubCount_2x3-16 5290686 675.0 ns/op 420.74 MB/s Benchmark___BumpPubCount_2x3-16 5310610 678.2 ns/op 418.77 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5558823 645.9 ns/op 439.72 MB/s Benchmark___BumpPubCount_5x3-16 5318702 645.6 ns/op 439.92 MB/s Benchmark___BumpPubCount_5x3-16 5553122 647.2 ns/op 438.80 MB/s Benchmark___BumpPubCount_5x3-16 5557900 647.5 ns/op 438.62 MB/s Benchmark___BumpPubCount_5x3-16 5538363 648.4 ns/op 438.03 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5543805 649.2 ns/op 437.43 MB/s Benchmark__BumpPubCount_10x3-16 5556559 649.5 ns/op 437.24 MB/s Benchmark__BumpPubCount_10x3-16 5674938 647.8 ns/op 438.42 MB/s Benchmark__BumpPubCount_10x3-16 5503366 649.6 ns/op 437.20 MB/s Benchmark__BumpPubCount_10x3-16 5547309 649.3 ns/op 437.42 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11526868 282.3 ns/op 3684.24 MB/s Benchmark____GWs_Opt_1kx01x0-16 12631302 277.5 ns/op 3747.43 MB/s Benchmark____GWs_Opt_1kx01x0-16 12476272 276.8 ns/op 3757.88 MB/s Benchmark____GWs_Opt_1kx01x0-16 12757945 265.3 ns/op 3919.84 MB/s Benchmark____GWs_Opt_1kx01x0-16 12521497 284.1 ns/op 3660.27 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9862502 331.7 ns/op 6223.27 MB/s Benchmark____GWs_Opt_2kx01x0-16 10730329 337.7 ns/op 6112.65 MB/s Benchmark____GWs_Opt_2kx01x0-16 10389987 347.4 ns/op 5941.25 MB/s Benchmark____GWs_Opt_2kx01x0-16 10711798 338.1 ns/op 6103.86 MB/s Benchmark____GWs_Opt_2kx01x0-16 10009353 336.7 ns/op 6129.46 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5694968 640.1 ns/op 6424.18 MB/s Benchmark____GWs_Opt_4kx01x0-16 5668903 637.8 ns/op 6446.93 MB/s Benchmark____GWs_Opt_4kx01x0-16 5602347 650.7 ns/op 6319.23 MB/s Benchmark____GWs_Opt_4kx01x0-16 5459877 645.1 ns/op 6374.70 MB/s Benchmark____GWs_Opt_4kx01x0-16 5586234 644.3 ns/op 6382.30 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 32516341 110.7 ns/op 9391.23 MB/s Benchmark____GWs_Opt_1kx10x0-16 28640433 112.2 ns/op 9272.78 MB/s Benchmark____GWs_Opt_1kx10x0-16 30581456 111.4 ns/op 9334.36 MB/s Benchmark____GWs_Opt_1kx10x0-16 31129057 118.3 ns/op 8788.07 MB/s Benchmark____GWs_Opt_1kx10x0-16 28460706 114.3 ns/op 9101.43 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25530364 142.4 ns/op 14495.90 MB/s Benchmark____GWs_Opt_2kx10x0-16 23482584 165.3 ns/op 12487.08 MB/s Benchmark____GWs_Opt_2kx10x0-16 25498384 147.8 ns/op 13960.89 MB/s Benchmark____GWs_Opt_2kx10x0-16 23781243 145.6 ns/op 14171.64 MB/s Benchmark____GWs_Opt_2kx10x0-16 23703356 155.3 ns/op 13288.33 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 13156352 287.7 ns/op 14291.96 MB/s Benchmark____GWs_Opt_4kx10x0-16 12205514 307.1 ns/op 13389.58 MB/s Benchmark____GWs_Opt_4kx10x0-16 13116633 301.0 ns/op 13659.99 MB/s Benchmark____GWs_Opt_4kx10x0-16 1000000 13250 ns/op 310.35 MB/s Benchmark____GWs_Opt_4kx10x0-16 12915118 335.2 ns/op 12268.67 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6461764 550.7 ns/op 5674.83 MB/s Benchmark____GWs_Opt_1kx01x1-16 6463286 553.4 ns/op 5646.86 MB/s Benchmark____GWs_Opt_1kx01x1-16 6630859 561.2 ns/op 5568.31 MB/s Benchmark____GWs_Opt_1kx01x1-16 6438732 559.5 ns/op 5584.85 MB/s Benchmark____GWs_Opt_1kx01x1-16 6429200 551.8 ns/op 5663.76 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4688456 798.6 ns/op 7760.28 MB/s Benchmark____GWs_Opt_2kx01x1-16 4714438 766.2 ns/op 8088.26 MB/s Benchmark____GWs_Opt_2kx01x1-16 4661593 765.0 ns/op 8100.44 MB/s Benchmark____GWs_Opt_2kx01x1-16 4701055 765.9 ns/op 8091.38 MB/s Benchmark____GWs_Opt_2kx01x1-16 4520035 1229 ns/op 5042.10 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2496404 1364 ns/op 9045.89 MB/s Benchmark____GWs_Opt_4kx01x1-16 2408685 1383 ns/op 8921.36 MB/s Benchmark____GWs_Opt_4kx01x1-16 2594844 1421 ns/op 8686.83 MB/s Benchmark____GWs_Opt_4kx01x1-16 2549410 1388 ns/op 8888.25 MB/s Benchmark____GWs_Opt_4kx01x1-16 2355859 1402 ns/op 8800.01 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 5938653 567.4 ns/op 5507.75 MB/s Benchmark____GWs_Opt_1kx10x1-16 6157957 568.5 ns/op 5496.63 MB/s Benchmark____GWs_Opt_1kx10x1-16 6132990 565.1 ns/op 5529.74 MB/s Benchmark____GWs_Opt_1kx10x1-16 6169090 563.1 ns/op 5549.52 MB/s Benchmark____GWs_Opt_1kx10x1-16 6211383 562.4 ns/op 5556.97 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4410254 847.4 ns/op 7312.77 MB/s Benchmark____GWs_Opt_2kx10x1-16 4148137 848.1 ns/op 7306.61 MB/s Benchmark____GWs_Opt_2kx10x1-16 4126704 838.5 ns/op 7390.33 MB/s Benchmark____GWs_Opt_2kx10x1-16 4248776 856.8 ns/op 7232.51 MB/s Benchmark____GWs_Opt_2kx10x1-16 4095726 857.1 ns/op 7230.41 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2304589 1482 ns/op 8328.11 MB/s Benchmark____GWs_Opt_4kx10x1-16 2353177 1537 ns/op 8027.75 MB/s Benchmark____GWs_Opt_4kx10x1-16 2123572 1536 ns/op 8034.27 MB/s Benchmark____GWs_Opt_4kx10x1-16 2321919 1514 ns/op 8152.82 MB/s Benchmark____GWs_Opt_4kx10x1-16 2355178 1617 ns/op 7629.95 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12582819 286.3 ns/op 3632.09 MB/s Benchmark____GWs_Int_1kx01x0-16 12462914 296.5 ns/op 3507.16 MB/s Benchmark____GWs_Int_1kx01x0-16 12407708 290.6 ns/op 3579.18 MB/s Benchmark____GWs_Int_1kx01x0-16 12536532 305.8 ns/op 3400.52 MB/s Benchmark____GWs_Int_1kx01x0-16 12451567 301.2 ns/op 3452.64 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10382952 356.6 ns/op 5787.41 MB/s Benchmark____GWs_Int_2kx01x0-16 10123328 353.5 ns/op 5839.43 MB/s Benchmark____GWs_Int_2kx01x0-16 10026316 366.2 ns/op 5637.03 MB/s Benchmark____GWs_Int_2kx01x0-16 9269250 360.3 ns/op 5727.78 MB/s Benchmark____GWs_Int_2kx01x0-16 10019780 357.0 ns/op 5781.58 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5536840 652.4 ns/op 6303.18 MB/s Benchmark____GWs_Int_4kx01x0-16 5524047 656.2 ns/op 6266.12 MB/s Benchmark____GWs_Int_4kx01x0-16 5573484 666.9 ns/op 6165.87 MB/s Benchmark____GWs_Int_4kx01x0-16 5684918 653.8 ns/op 6289.84 MB/s Benchmark____GWs_Int_4kx01x0-16 5504348 651.0 ns/op 6315.96 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31579886 113.3 ns/op 9178.05 MB/s Benchmark____GWs_Int_1kx10x0-16 29907630 113.7 ns/op 9143.07 MB/s Benchmark____GWs_Int_1kx10x0-16 29746437 113.2 ns/op 9186.10 MB/s Benchmark____GWs_Int_1kx10x0-16 30259928 115.9 ns/op 8973.96 MB/s Benchmark____GWs_Int_1kx10x0-16 31107978 111.0 ns/op 9372.99 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 22551770 150.4 ns/op 13720.45 MB/s Benchmark____GWs_Int_2kx10x0-16 25249394 155.6 ns/op 13263.55 MB/s Benchmark____GWs_Int_2kx10x0-16 25749361 138.7 ns/op 14875.77 MB/s Benchmark____GWs_Int_2kx10x0-16 23753685 146.7 ns/op 14072.00 MB/s Benchmark____GWs_Int_2kx10x0-16 25521544 148.4 ns/op 13912.76 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12909373 284.5 ns/op 14453.25 MB/s Benchmark____GWs_Int_4kx10x0-16 10189933 300.9 ns/op 13665.37 MB/s Benchmark____GWs_Int_4kx10x0-16 13382304 293.1 ns/op 14028.25 MB/s Benchmark____GWs_Int_4kx10x0-16 12411860 319.2 ns/op 12882.27 MB/s Benchmark____GWs_Int_4kx10x0-16 13023264 289.3 ns/op 14213.80 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6207876 556.6 ns/op 5614.79 MB/s Benchmark____GWs_Int_1kx01x1-16 6314299 571.3 ns/op 5469.54 MB/s Benchmark____GWs_Int_1kx01x1-16 6534901 561.6 ns/op 5564.11 MB/s Benchmark____GWs_Int_1kx01x1-16 6457792 560.8 ns/op 5572.63 MB/s Benchmark____GWs_Int_1kx01x1-16 6267942 556.0 ns/op 5620.53 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4481620 772.5 ns/op 8021.69 MB/s Benchmark____GWs_Int_2kx01x1-16 4473801 778.1 ns/op 7964.64 MB/s Benchmark____GWs_Int_2kx01x1-16 4478130 780.0 ns/op 7944.45 MB/s Benchmark____GWs_Int_2kx01x1-16 4676101 774.7 ns/op 7999.18 MB/s Benchmark____GWs_Int_2kx01x1-16 4596999 774.9 ns/op 7996.75 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2572803 1410 ns/op 8754.90 MB/s Benchmark____GWs_Int_4kx01x1-16 2510768 1390 ns/op 8879.81 MB/s Benchmark____GWs_Int_4kx01x1-16 2581882 1395 ns/op 8847.96 MB/s Benchmark____GWs_Int_4kx01x1-16 2601609 1392 ns/op 8863.32 MB/s Benchmark____GWs_Int_4kx01x1-16 2475085 1408 ns/op 8764.94 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6174332 569.8 ns/op 5484.12 MB/s Benchmark____GWs_Int_1kx10x1-16 6211023 565.5 ns/op 5526.45 MB/s Benchmark____GWs_Int_1kx10x1-16 6130486 565.3 ns/op 5527.64 MB/s Benchmark____GWs_Int_1kx10x1-16 5911050 556.3 ns/op 5617.64 MB/s Benchmark____GWs_Int_1kx10x1-16 6433339 557.1 ns/op 5609.14 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4167045 849.2 ns/op 7297.07 MB/s Benchmark____GWs_Int_2kx10x1-16 4156542 849.9 ns/op 7291.82 MB/s Benchmark____GWs_Int_2kx10x1-16 4134189 846.0 ns/op 7325.01 MB/s Benchmark____GWs_Int_2kx10x1-16 3866636 849.7 ns/op 7292.86 MB/s Benchmark____GWs_Int_2kx10x1-16 4202097 857.0 ns/op 7231.31 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2162302 1652 ns/op 7469.03 MB/s Benchmark____GWs_Int_4kx10x1-16 2327827 1521 ns/op 8111.08 MB/s Benchmark____GWs_Int_4kx10x1-16 2391144 1699 ns/op 7262.00 MB/s Benchmark____GWs_Int_4kx10x1-16 2329502 1530 ns/op 8065.77 MB/s Benchmark____GWs_Int_4kx10x1-16 2343454 1433 ns/op 8613.84 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8518702 435.9 ns/op 233.98 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8282720 488.6 ns/op 208.74 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8374940 445.2 ns/op 229.12 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7821914 439.3 ns/op 232.17 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8475296 436.5 ns/op 233.66 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 756019 4865 ns/op 36.38 MB/s Benchmark__GWs_Reqs_1SubEach-16 819598 5017 ns/op 35.28 MB/s Benchmark__GWs_Reqs_1SubEach-16 795169 4996 ns/op 35.42 MB/s Benchmark__GWs_Reqs_1SubEach-16 783205 4985 ns/op 35.51 MB/s Benchmark__GWs_Reqs_1SubEach-16 750686 4930 ns/op 35.90 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2077.432s ❌ Non-zero exit code: 1