> ROOT_DIR=/tmp/go-bench-away-job-fe80c866-2609-46f0-8440-30c411aad3ee-466042882 > OUTPUT_FILE=/tmp/go-bench-away-job-fe80c866-2609-46f0-8440-30c411aad3ee-466042882/results.txt > SHA_FILE=/tmp/go-bench-away-job-fe80c866-2609-46f0-8440-30c411aad3ee-466042882/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-fe80c866-2609-46f0-8440-30c411aad3ee-466042882/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.26.3/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-fe80c866-2609-46f0-8440-30c411aad3ee-466042882/source.git SHA of main: 146b0be65b3591e925cce61ce9d2cae32cdeb227 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-build2342523431=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-fe80c866-2609-46f0-8440-30c411aad3ee-466042882/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 48271730 72.66 ns/op 151.40 MB/s Benchmark______Pub0b_Payload-16 46617628 72.81 ns/op 151.09 MB/s Benchmark______Pub0b_Payload-16 46766817 72.66 ns/op 151.39 MB/s Benchmark______Pub0b_Payload-16 49570066 72.65 ns/op 151.40 MB/s Benchmark______Pub0b_Payload-16 47177073 72.66 ns/op 151.38 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 44022206 73.39 ns/op 258.89 MB/s Benchmark______Pub8b_Payload-16 46352966 73.36 ns/op 259.00 MB/s Benchmark______Pub8b_Payload-16 46503134 75.20 ns/op 252.66 MB/s Benchmark______Pub8b_Payload-16 46511217 73.35 ns/op 259.03 MB/s Benchmark______Pub8b_Payload-16 45411711 75.39 ns/op 252.02 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44108799 78.56 ns/op 560.10 MB/s Benchmark_____Pub32b_Payload-16 44306425 77.54 ns/op 567.46 MB/s Benchmark_____Pub32b_Payload-16 44099078 76.96 ns/op 571.74 MB/s Benchmark_____Pub32b_Payload-16 44351701 77.24 ns/op 569.62 MB/s Benchmark_____Pub32b_Payload-16 42617422 77.26 ns/op 569.51 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38184382 86.55 ns/op 1629.18 MB/s Benchmark____Pub128B_Payload-16 41910292 86.28 ns/op 1634.25 MB/s Benchmark____Pub128B_Payload-16 39018404 86.33 ns/op 1633.35 MB/s Benchmark____Pub128B_Payload-16 39456846 86.06 ns/op 1638.38 MB/s Benchmark____Pub128B_Payload-16 39711026 86.16 ns/op 1636.47 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36211134 96.13 ns/op 2798.34 MB/s Benchmark____Pub256B_Payload-16 31781193 98.15 ns/op 2740.60 MB/s Benchmark____Pub256B_Payload-16 32845782 94.87 ns/op 2835.45 MB/s Benchmark____Pub256B_Payload-16 32534050 100.2 ns/op 2684.56 MB/s Benchmark____Pub256B_Payload-16 35315436 94.26 ns/op 2853.74 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23751927 147.0 ns/op 7058.96 MB/s Benchmark______Pub1K_Payload-16 26178321 152.5 ns/op 6806.50 MB/s Benchmark______Pub1K_Payload-16 24369783 147.6 ns/op 7032.92 MB/s Benchmark______Pub1K_Payload-16 25102686 143.3 ns/op 7241.88 MB/s Benchmark______Pub1K_Payload-16 24277298 136.3 ns/op 7615.98 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5652291 613.9 ns/op 6695.23 MB/s Benchmark______Pub4K_Payload-16 5669905 631.9 ns/op 6503.72 MB/s Benchmark______Pub4K_Payload-16 5497958 621.6 ns/op 6611.62 MB/s Benchmark______Pub4K_Payload-16 5844571 622.5 ns/op 6602.60 MB/s Benchmark______Pub4K_Payload-16 5741643 623.7 ns/op 6589.67 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2770951 1265 ns/op 6487.64 MB/s Benchmark______Pub8K_Payload-16 2754430 1274 ns/op 6443.32 MB/s Benchmark______Pub8K_Payload-16 2766856 1274 ns/op 6440.86 MB/s Benchmark______Pub8K_Payload-16 2707544 1291 ns/op 6357.83 MB/s Benchmark______Pub8K_Payload-16 2746203 1286 ns/op 6380.22 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 592311 5436 ns/op 6030.24 MB/s Benchmark_____Pub32K_Payload-16 650817 5449 ns/op 6015.89 MB/s Benchmark_____Pub32K_Payload-16 657128 5503 ns/op 5957.30 MB/s Benchmark_____Pub32K_Payload-16 659738 5527 ns/op 5931.47 MB/s Benchmark_____Pub32K_Payload-16 657307 5324 ns/op 6157.21 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31767571 95.18 ns/op 115.57 MB/s Benchmark__AuthPub0b_Payload-16 36191984 94.97 ns/op 115.83 MB/s Benchmark__AuthPub0b_Payload-16 32344809 94.61 ns/op 116.27 MB/s Benchmark__AuthPub0b_Payload-16 35935028 94.89 ns/op 115.92 MB/s Benchmark__AuthPub0b_Payload-16 36065859 96.00 ns/op 114.58 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15628546 227.1 ns/op Benchmark_____________PubSub-16 15822434 227.8 ns/op Benchmark_____________PubSub-16 15599304 226.9 ns/op Benchmark_____________PubSub-16 15520038 227.6 ns/op Benchmark_____________PubSub-16 15692594 226.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15554721 227.5 ns/op Benchmark_____PubSubTwoConns-16 15486109 227.6 ns/op Benchmark_____PubSubTwoConns-16 15196004 227.9 ns/op Benchmark_____PubSubTwoConns-16 15673740 227.0 ns/op Benchmark_____PubSubTwoConns-16 15583659 226.1 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:39804->127.0.0.1:45993: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58658->127.0.0.1:43207: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34112->127.0.0.1:43759: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33408->127.0.0.1:35801: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43970->127.0.0.1:35701: 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 14637519 243.9 ns/op Benchmark_____PubTwoQueueSub-16 14539168 244.5 ns/op Benchmark_____PubTwoQueueSub-16 14580859 243.4 ns/op Benchmark_____PubTwoQueueSub-16 14465604 244.0 ns/op Benchmark_____PubTwoQueueSub-16 14749797 251.5 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14391853 243.2 ns/op Benchmark____PubFourQueueSub-16 14504618 244.0 ns/op Benchmark____PubFourQueueSub-16 14648142 244.1 ns/op Benchmark____PubFourQueueSub-16 14694001 251.6 ns/op Benchmark____PubFourQueueSub-16 14521803 244.6 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14668390 244.0 ns/op Benchmark___PubEightQueueSub-16 14520015 242.7 ns/op Benchmark___PubEightQueueSub-16 14481760 242.6 ns/op Benchmark___PubEightQueueSub-16 14612121 242.3 ns/op Benchmark___PubEightQueueSub-16 14589187 242.8 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23023 154495 ns/op Benchmark_PubSub512kTwoConns-16 23000 155223 ns/op Benchmark_PubSub512kTwoConns-16 23127 155458 ns/op bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 475547356 vs 5243080000 --- FAIL: Benchmark_PubSub512kTwoConns-16 Benchmark_PubSub512kTwoConns-16 21552 167350 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15214334 229.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15141241 228.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15083073 230.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15509283 230.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15262779 229.9 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15099242 229.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15399336 230.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15025910 228.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15301020 229.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15166234 228.8 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11477596 311.9 ns/op Benchmark____RoutedPubSub_0b-16 11262916 313.3 ns/op Benchmark____RoutedPubSub_0b-16 11263642 315.1 ns/op Benchmark____RoutedPubSub_0b-16 11335308 316.1 ns/op Benchmark____RoutedPubSub_0b-16 11211094 313.3 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6637101 534.1 ns/op Benchmark____RoutedPubSub_1K-16 6587127 581.5 ns/op Benchmark____RoutedPubSub_1K-16 6544845 541.9 ns/op Benchmark____RoutedPubSub_1K-16 6634959 540.3 ns/op Benchmark____RoutedPubSub_1K-16 6676076 541.4 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 78600 46877 ns/op Benchmark__RoutedPubSub_100K-16 76701 47973 ns/op Benchmark__RoutedPubSub_100K-16 76693 46828 ns/op Benchmark__RoutedPubSub_100K-16 71887 50469 ns/op Benchmark__RoutedPubSub_100K-16 74982 50566 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9779028 314.2 ns/op Benchmark____Routed2QueueSub-16 9838672 314.4 ns/op Benchmark____Routed2QueueSub-16 9609876 313.7 ns/op Benchmark____Routed2QueueSub-16 9775108 313.8 ns/op Benchmark____Routed2QueueSub-16 9610945 323.6 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9696331 322.9 ns/op Benchmark____Routed4QueueSub-16 9588902 327.0 ns/op Benchmark____Routed4QueueSub-16 9375192 320.1 ns/op Benchmark____Routed4QueueSub-16 9721911 317.4 ns/op Benchmark____Routed4QueueSub-16 9653772 323.2 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9438084 328.2 ns/op Benchmark____Routed8QueueSub-16 9190671 337.1 ns/op Benchmark____Routed8QueueSub-16 9111158 341.5 ns/op Benchmark____Routed8QueueSub-16 9250340 330.4 ns/op Benchmark____Routed8QueueSub-16 10835217 328.3 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8942688 342.2 ns/op Benchmark___Routed16QueueSub-16 8918311 356.8 ns/op Benchmark___Routed16QueueSub-16 8841579 348.8 ns/op Benchmark___Routed16QueueSub-16 8886638 344.6 ns/op Benchmark___Routed16QueueSub-16 8771415 349.2 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6166670 565.5 ns/op Benchmark____________RouteCompressOff-16 6283947 570.2 ns/op Benchmark____________RouteCompressOff-16 6082459 567.3 ns/op Benchmark____________RouteCompressOff-16 6405892 573.5 ns/op Benchmark____________RouteCompressOff-16 6193550 572.4 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6134910 565.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6221509 564.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6175825 573.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6240276 558.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6281917 563.6 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6370812 573.5 ns/op Benchmark_________RouteCompressS2Fast-16 6213738 570.7 ns/op Benchmark_________RouteCompressS2Fast-16 6277014 572.8 ns/op Benchmark_________RouteCompressS2Fast-16 6111114 563.9 ns/op Benchmark_________RouteCompressS2Fast-16 6236320 568.8 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6329080 566.3 ns/op Benchmark_______RouteCompressS2Better-16 6307017 570.0 ns/op Benchmark_______RouteCompressS2Better-16 6391394 563.9 ns/op Benchmark_______RouteCompressS2Better-16 6163432 569.9 ns/op Benchmark_______RouteCompressS2Better-16 6281176 568.8 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6316348 569.5 ns/op Benchmark_________RouteCompressS2Best-16 6256840 567.5 ns/op Benchmark_________RouteCompressS2Best-16 6387676 569.7 ns/op Benchmark_________RouteCompressS2Best-16 6311178 564.9 ns/op Benchmark_________RouteCompressS2Best-16 6245266 564.0 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4614841 769.7 ns/op 323.49 MB/s Benchmark______FanOut_8x1x10-16 4655595 775.6 ns/op 321.03 MB/s Benchmark______FanOut_8x1x10-16 4645638 772.9 ns/op 322.15 MB/s Benchmark______FanOut_8x1x10-16 4645488 771.5 ns/op 322.74 MB/s Benchmark______FanOut_8x1x10-16 4658742 766.2 ns/op 325.00 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 569007 6254 ns/op 370.82 MB/s Benchmark_____FanOut_8x1x100-16 524175 6108 ns/op 379.69 MB/s Benchmark_____FanOut_8x1x100-16 553678 6131 ns/op 378.24 MB/s Benchmark_____FanOut_8x1x100-16 514204 6099 ns/op 380.21 MB/s Benchmark_____FanOut_8x1x100-16 530640 6117 ns/op 379.13 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47025 75443 ns/op 305.12 MB/s Benchmark____FanOut_8x10x100-16 48082 76772 ns/op 299.83 MB/s Benchmark____FanOut_8x10x100-16 47732 76084 ns/op 302.55 MB/s Benchmark____FanOut_8x10x100-16 48111 75165 ns/op 306.25 MB/s Benchmark____FanOut_8x10x100-16 47833 74979 ns/op 307.00 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5942 595544 ns/op 403.02 MB/s Benchmark___FanOut_8x10x1000-16 5862 602533 ns/op 398.35 MB/s Benchmark___FanOut_8x10x1000-16 5853 621707 ns/op 386.06 MB/s Benchmark___FanOut_8x10x1000-16 5833 596610 ns/op 402.30 MB/s Benchmark___FanOut_8x10x1000-16 5960 598057 ns/op 401.33 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5023 715914 ns/op 321.29 MB/s Benchmark___FanOut_8x100x100-16 5052 709170 ns/op 324.35 MB/s Benchmark___FanOut_8x100x100-16 4993 708403 ns/op 324.70 MB/s Benchmark___FanOut_8x100x100-16 4995 715096 ns/op 321.66 MB/s Benchmark___FanOut_8x100x100-16 5101 713109 ns/op 322.56 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 573 6103596 ns/op 393.21 MB/s Benchmark__FanOut_8x100x1000-16 585 6089922 ns/op 394.10 MB/s Benchmark__FanOut_8x100x1000-16 562 6265339 ns/op 383.06 MB/s Benchmark__FanOut_8x100x1000-16 582 6124614 ns/op 391.86 MB/s Benchmark__FanOut_8x100x1000-16 583 6365175 ns/op 377.05 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 529 6794288 ns/op 367.96 MB/s Benchmark__FanOut_8x10x10000-16 535 6807261 ns/op 367.26 MB/s Benchmark__FanOut_8x10x10000-16 519 6745091 ns/op 370.64 MB/s Benchmark__FanOut_8x10x10000-16 534 6800008 ns/op 367.65 MB/s Benchmark__FanOut_8x10x10000-16 514 6683780 ns/op 374.04 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 952 3747580 ns/op 306.87 MB/s Benchmark___FanOut_8x500x100-16 951 3773801 ns/op 304.74 MB/s Benchmark___FanOut_8x500x100-16 936 3754791 ns/op 306.28 MB/s Benchmark___FanOut_8x500x100-16 949 3738362 ns/op 307.63 MB/s Benchmark___FanOut_8x500x100-16 949 3760217 ns/op 305.84 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 352788 9652 ns/op 1516.85 MB/s Benchmark___FanOut_128x1x100-16 347390 9617 ns/op 1522.48 MB/s Benchmark___FanOut_128x1x100-16 344739 9586 ns/op 1527.27 MB/s Benchmark___FanOut_128x1x100-16 349026 9558 ns/op 1531.84 MB/s Benchmark___FanOut_128x1x100-16 358845 9593 ns/op 1526.17 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32569 110405 ns/op 1314.62 MB/s Benchmark__FanOut_128x10x100-16 32533 110749 ns/op 1310.54 MB/s Benchmark__FanOut_128x10x100-16 32468 111180 ns/op 1305.46 MB/s Benchmark__FanOut_128x10x100-16 32608 109909 ns/op 1320.55 MB/s Benchmark__FanOut_128x10x100-16 32072 111868 ns/op 1297.43 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3949 878288 ns/op 1662.49 MB/s Benchmark_FanOut_128x10x1000-16 4106 879316 ns/op 1660.54 MB/s Benchmark_FanOut_128x10x1000-16 4020 880666 ns/op 1658.00 MB/s Benchmark_FanOut_128x10x1000-16 4124 884754 ns/op 1650.33 MB/s Benchmark_FanOut_128x10x1000-16 4062 891707 ns/op 1637.47 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3464 1012868 ns/op 1431.72 MB/s Benchmark_FanOut_128x100x100-16 3489 1008383 ns/op 1438.09 MB/s Benchmark_FanOut_128x100x100-16 3498 1016998 ns/op 1425.90 MB/s Benchmark_FanOut_128x100x100-16 3483 1020451 ns/op 1421.08 MB/s Benchmark_FanOut_128x100x100-16 3476 1014829 ns/op 1428.95 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 388 9325418 ns/op 1565.63 MB/s BenchmarkFanOut_128x100x1000-16 381 9238759 ns/op 1580.31 MB/s BenchmarkFanOut_128x100x1000-16 382 9289783 ns/op 1571.63 MB/s BenchmarkFanOut_128x100x1000-16 396 9360801 ns/op 1559.71 MB/s BenchmarkFanOut_128x100x1000-16 380 9289448 ns/op 1571.69 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 368 9598038 ns/op 1531.58 MB/s BenchmarkFanOut_128x10x10000-16 374 9535194 ns/op 1541.67 MB/s BenchmarkFanOut_128x10x10000-16 374 9685527 ns/op 1517.74 MB/s BenchmarkFanOut_128x10x10000-16 378 9516903 ns/op 1544.64 MB/s BenchmarkFanOut_128x10x10000-16 373 9552380 ns/op 1538.90 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 675 5258332 ns/op 1378.79 MB/s BenchmarkFanOut__128x500x100-16 678 5255033 ns/op 1379.66 MB/s BenchmarkFanOut__128x500x100-16 664 5267776 ns/op 1376.32 MB/s BenchmarkFanOut__128x500x100-16 679 5267275 ns/op 1376.45 MB/s BenchmarkFanOut__128x500x100-16 672 5236855 ns/op 1384.45 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1936 1836865 ns/op 2880.19 MB/s Benchmark_FanOut_512x100x100-16 1914 1841720 ns/op 2872.60 MB/s Benchmark_FanOut_512x100x100-16 1928 1848592 ns/op 2861.92 MB/s Benchmark_FanOut_512x100x100-16 1929 1847798 ns/op 2863.15 MB/s Benchmark_FanOut_512x100x100-16 1917 1857394 ns/op 2848.36 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16774238 ns/op 3159.64 MB/s Benchmark__FanOut_512x100x1k-16 216 16646136 ns/op 3183.95 MB/s Benchmark__FanOut_512x100x1k-16 214 16726460 ns/op 3168.66 MB/s Benchmark__FanOut_512x100x1k-16 214 16605495 ns/op 3191.75 MB/s Benchmark__FanOut_512x100x1k-16 213 16690593 ns/op 3175.47 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2803 1138422 ns/op 9162.72 MB/s Benchmark____FanOut_1kx10x1k-16 3039 1153203 ns/op 9045.28 MB/s Benchmark____FanOut_1kx10x1k-16 3086 1154334 ns/op 9036.41 MB/s Benchmark____FanOut_1kx10x1k-16 3216 1159983 ns/op 8992.41 MB/s Benchmark____FanOut_1kx10x1k-16 3096 1156431 ns/op 9020.03 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2714 1253746 ns/op 8311.92 MB/s Benchmark__FanOut_1kx100x100-16 2818 1254085 ns/op 8309.67 MB/s Benchmark__FanOut_1kx100x100-16 2798 1252623 ns/op 8319.37 MB/s Benchmark__FanOut_1kx100x100-16 2738 1270278 ns/op 8203.75 MB/s Benchmark__FanOut_1kx100x100-16 2785 1258152 ns/op 8282.81 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4546814 768.3 ns/op 324.10 MB/s Benchmark_____RFanOut_8x1x10-16 4363915 789.4 ns/op 315.44 MB/s Benchmark_____RFanOut_8x1x10-16 4553528 772.1 ns/op 322.52 MB/s Benchmark_____RFanOut_8x1x10-16 4490472 791.5 ns/op 314.60 MB/s Benchmark_____RFanOut_8x1x10-16 4543352 789.2 ns/op 315.52 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 524125 6125 ns/op 378.63 MB/s Benchmark____RFanOut_8x1x100-16 531682 6401 ns/op 362.26 MB/s Benchmark____RFanOut_8x1x100-16 507883 6470 ns/op 358.43 MB/s Benchmark____RFanOut_8x1x100-16 521256 6396 ns/op 362.58 MB/s Benchmark____RFanOut_8x1x100-16 508669 6313 ns/op 367.34 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48062 74815 ns/op 307.68 MB/s Benchmark___RFanOut_8x10x100-16 48070 74425 ns/op 309.29 MB/s Benchmark___RFanOut_8x10x100-16 48026 74407 ns/op 309.37 MB/s Benchmark___RFanOut_8x10x100-16 48206 74561 ns/op 308.73 MB/s Benchmark___RFanOut_8x10x100-16 47764 76389 ns/op 301.34 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5761 597630 ns/op 401.62 MB/s Benchmark__RFanOut_8x10x1000-16 5893 598365 ns/op 401.12 MB/s Benchmark__RFanOut_8x10x1000-16 5989 602468 ns/op 398.39 MB/s Benchmark__RFanOut_8x10x1000-16 5876 599500 ns/op 400.37 MB/s Benchmark__RFanOut_8x10x1000-16 5882 597314 ns/op 401.83 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5007 713523 ns/op 322.37 MB/s Benchmark__RFanOut_8x100x100-16 4951 707868 ns/op 324.95 MB/s Benchmark__RFanOut_8x100x100-16 4948 711723 ns/op 323.19 MB/s Benchmark__RFanOut_8x100x100-16 5060 714161 ns/op 322.08 MB/s Benchmark__RFanOut_8x100x100-16 4948 709830 ns/op 324.05 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 572 6287430 ns/op 381.72 MB/s Benchmark_RFanOut_8x100x1000-16 561 6134885 ns/op 391.21 MB/s Benchmark_RFanOut_8x100x1000-16 574 6197753 ns/op 387.24 MB/s Benchmark_RFanOut_8x100x1000-16 579 6177605 ns/op 388.50 MB/s Benchmark_RFanOut_8x100x1000-16 573 6345254 ns/op 378.24 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 529 6788684 ns/op 368.26 MB/s Benchmark_RFanOut_8x10x10000-16 538 6821202 ns/op 366.51 MB/s Benchmark_RFanOut_8x10x10000-16 525 6734168 ns/op 371.24 MB/s Benchmark_RFanOut_8x10x10000-16 534 6726728 ns/op 371.65 MB/s Benchmark_RFanOut_8x10x10000-16 529 6789319 ns/op 368.23 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3216 1151148 ns/op 9061.42 MB/s Benchmark_RFanOut_1kx10x1000-16 3067 1169134 ns/op 8922.02 MB/s Benchmark_RFanOut_1kx10x1000-16 3228 1162328 ns/op 8974.26 MB/s Benchmark_RFanOut_1kx10x1000-16 3135 1182228 ns/op 8823.20 MB/s Benchmark_RFanOut_1kx10x1000-16 3062 1166985 ns/op 8938.45 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6933919 506.9 ns/op 4099.70 MB/s Benchmark_____FanIn_1kx100x1-16 6965280 506.1 ns/op 4105.90 MB/s Benchmark_____FanIn_1kx100x1-16 6903249 506.5 ns/op 4102.73 MB/s Benchmark_____FanIn_1kx100x1-16 6956416 504.7 ns/op 4117.01 MB/s Benchmark_____FanIn_1kx100x1-16 6871974 508.4 ns/op 4087.28 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2579128 1354 ns/op 6070.91 MB/s Benchmark_____FanIn_4kx100x1-16 2660522 1345 ns/op 6112.28 MB/s Benchmark_____FanIn_4kx100x1-16 2630836 1367 ns/op 6014.19 MB/s Benchmark_____FanIn_4kx100x1-16 2649472 1365 ns/op 6023.18 MB/s Benchmark_____FanIn_4kx100x1-16 2654836 1356 ns/op 6063.10 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1687058 2137 ns/op 7679.69 MB/s Benchmark_____FanIn_8kx100x1-16 1686524 2113 ns/op 7766.83 MB/s Benchmark_____FanIn_8kx100x1-16 1693615 2099 ns/op 7819.61 MB/s Benchmark_____FanIn_8kx100x1-16 1737427 2105 ns/op 7797.54 MB/s Benchmark_____FanIn_8kx100x1-16 1695475 2116 ns/op 7756.43 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 875436 4089 ns/op 8022.33 MB/s Benchmark____FanIn_16kx100x1-16 863674 4137 ns/op 7929.09 MB/s Benchmark____FanIn_16kx100x1-16 873199 4126 ns/op 7950.33 MB/s Benchmark____FanIn_16kx100x1-16 865386 4100 ns/op 7999.54 MB/s Benchmark____FanIn_16kx100x1-16 876421 4145 ns/op 7912.52 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 171492 19732 ns/op 6644.33 MB/s Benchmark____FanIn_64kx100x1-16 157048 19712 ns/op 6651.06 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 9081188196 vs 11098122900 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42036->127.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:42670->127.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:42146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42220->127.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: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: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:42356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42306->127.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:42144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42564->127.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:42250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42656->127.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:41990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42094->127.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:41976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42110->127.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:42072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42368->127.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: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:42214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:42406->127.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:42616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42492->127.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: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:42550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42122->127.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:42258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42390->127.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: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:42020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42710->127.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: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:42774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42314->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: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: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:42816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42066->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 165778 19936 ns/op 6576.16 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 6581848965 vs 11124344100 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38052->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38016->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 327856090 vs 11667010000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41370->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:40780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40948->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 707230550 vs 1310900000 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:42556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42644->127.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:42988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42884->127.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:43172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42802->127.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:42724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42606->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: 1521430540 vs 11365503000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45388->127.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:45822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:45582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45272->127.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:45670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45286->127.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:45268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45948->127.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:45240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45596->127.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:45410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:45908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45192->127.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:45594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45486->127.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:45862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45464->127.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:45870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45906->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: 313174010 vs 11640792000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48026->127.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:47946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48178->127.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:48236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48480->127.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:48270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47886->127.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:47828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48542->127.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 --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48430->127.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:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 257722940 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50390->127.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:49660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49912->127.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:49826->127.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:50428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49808->127.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: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:50098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:49984->127.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:50054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50150->127.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:50312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49930->127.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:49710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50020->127.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: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:50212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49998->127.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:50402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50420->127.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:50164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50216->127.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:50426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50188->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5525553 650.1 ns/op 436.86 MB/s Benchmark___BumpPubCount_1x3-16 5484530 643.7 ns/op 441.19 MB/s Benchmark___BumpPubCount_1x3-16 5568735 647.8 ns/op 438.42 MB/s Benchmark___BumpPubCount_1x3-16 5536797 644.4 ns/op 440.73 MB/s Benchmark___BumpPubCount_1x3-16 5552928 648.6 ns/op 437.84 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5321199 672.2 ns/op 422.51 MB/s Benchmark___BumpPubCount_2x3-16 5284039 671.2 ns/op 423.10 MB/s Benchmark___BumpPubCount_2x3-16 5312536 677.7 ns/op 419.09 MB/s Benchmark___BumpPubCount_2x3-16 5301325 672.1 ns/op 422.54 MB/s Benchmark___BumpPubCount_2x3-16 5336934 677.2 ns/op 419.36 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5550628 650.1 ns/op 436.88 MB/s Benchmark___BumpPubCount_5x3-16 5609884 641.8 ns/op 442.49 MB/s Benchmark___BumpPubCount_5x3-16 5347813 642.1 ns/op 442.26 MB/s Benchmark___BumpPubCount_5x3-16 5573450 643.2 ns/op 441.57 MB/s Benchmark___BumpPubCount_5x3-16 4607809 653.8 ns/op 434.35 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5619879 642.0 ns/op 442.39 MB/s Benchmark__BumpPubCount_10x3-16 5585342 641.9 ns/op 442.45 MB/s Benchmark__BumpPubCount_10x3-16 5612750 644.3 ns/op 440.80 MB/s Benchmark__BumpPubCount_10x3-16 5564484 642.4 ns/op 442.09 MB/s Benchmark__BumpPubCount_10x3-16 5576304 644.2 ns/op 440.87 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11989311 267.4 ns/op 3889.13 MB/s Benchmark____GWs_Opt_1kx01x0-16 13241139 281.2 ns/op 3698.52 MB/s Benchmark____GWs_Opt_1kx01x0-16 12564144 271.1 ns/op 3836.57 MB/s Benchmark____GWs_Opt_1kx01x0-16 11161738 270.5 ns/op 3844.60 MB/s Benchmark____GWs_Opt_1kx01x0-16 12841176 274.1 ns/op 3793.88 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10259598 353.0 ns/op 5847.68 MB/s Benchmark____GWs_Opt_2kx01x0-16 9746968 324.0 ns/op 6370.65 MB/s Benchmark____GWs_Opt_2kx01x0-16 10109366 318.7 ns/op 6476.64 MB/s Benchmark____GWs_Opt_2kx01x0-16 10033976 329.2 ns/op 6269.28 MB/s Benchmark____GWs_Opt_2kx01x0-16 9520984 323.8 ns/op 6375.04 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5618700 607.7 ns/op 6767.00 MB/s Benchmark____GWs_Opt_4kx01x0-16 5752970 625.3 ns/op 6576.12 MB/s Benchmark____GWs_Opt_4kx01x0-16 5613224 619.8 ns/op 6634.63 MB/s Benchmark____GWs_Opt_4kx01x0-16 5726562 625.9 ns/op 6569.40 MB/s Benchmark____GWs_Opt_4kx01x0-16 5943523 624.5 ns/op 6584.75 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30591811 110.3 ns/op 9428.70 MB/s Benchmark____GWs_Opt_1kx10x0-16 32805012 113.7 ns/op 9143.48 MB/s Benchmark____GWs_Opt_1kx10x0-16 31949017 113.7 ns/op 9149.54 MB/s Benchmark____GWs_Opt_1kx10x0-16 30933985 110.8 ns/op 9387.92 MB/s Benchmark____GWs_Opt_1kx10x0-16 28714489 111.9 ns/op 9289.90 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 18102856 171.9 ns/op 12007.14 MB/s Benchmark____GWs_Opt_2kx10x0-16 25147941 155.9 ns/op 13238.07 MB/s Benchmark____GWs_Opt_2kx10x0-16 22914628 143.3 ns/op 14404.13 MB/s Benchmark____GWs_Opt_2kx10x0-16 25005735 156.2 ns/op 13216.89 MB/s Benchmark____GWs_Opt_2kx10x0-16 25270752 147.6 ns/op 13986.60 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11752603 282.4 ns/op 14559.04 MB/s Benchmark____GWs_Opt_4kx10x0-16 11833428 286.6 ns/op 14347.51 MB/s Benchmark____GWs_Opt_4kx10x0-16 12714406 310.8 ns/op 13228.90 MB/s Benchmark____GWs_Opt_4kx10x0-16 12309360 310.2 ns/op 13254.78 MB/s Benchmark____GWs_Opt_4kx10x0-16 12387840 300.2 ns/op 13696.89 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6603090 543.9 ns/op 5746.04 MB/s Benchmark____GWs_Opt_1kx01x1-16 6468214 553.0 ns/op 5651.41 MB/s Benchmark____GWs_Opt_1kx01x1-16 6618198 540.0 ns/op 5787.28 MB/s Benchmark____GWs_Opt_1kx01x1-16 6608845 548.3 ns/op 5699.39 MB/s Benchmark____GWs_Opt_1kx01x1-16 5860602 555.5 ns/op 5625.22 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4589862 766.6 ns/op 8083.38 MB/s Benchmark____GWs_Opt_2kx01x1-16 4734817 859.8 ns/op 7207.23 MB/s Benchmark____GWs_Opt_2kx01x1-16 4799715 766.6 ns/op 8084.17 MB/s Benchmark____GWs_Opt_2kx01x1-16 4660999 768.5 ns/op 8064.09 MB/s Benchmark____GWs_Opt_2kx01x1-16 4696840 767.3 ns/op 8076.59 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2639370 1389 ns/op 8883.24 MB/s Benchmark____GWs_Opt_4kx01x1-16 2520604 1456 ns/op 8477.24 MB/s Benchmark____GWs_Opt_4kx01x1-16 2631648 1356 ns/op 9099.34 MB/s Benchmark____GWs_Opt_4kx01x1-16 2656282 1362 ns/op 9063.49 MB/s Benchmark____GWs_Opt_4kx01x1-16 2587543 1421 ns/op 8683.70 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6154395 560.7 ns/op 5573.01 MB/s Benchmark____GWs_Opt_1kx10x1-16 6561298 553.2 ns/op 5648.86 MB/s Benchmark____GWs_Opt_1kx10x1-16 6519240 564.2 ns/op 5538.71 MB/s Benchmark____GWs_Opt_1kx10x1-16 6635635 562.5 ns/op 5555.30 MB/s Benchmark____GWs_Opt_1kx10x1-16 6185992 574.0 ns/op 5444.14 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4049414 844.7 ns/op 7336.10 MB/s Benchmark____GWs_Opt_2kx10x1-16 3976190 863.8 ns/op 7173.70 MB/s Benchmark____GWs_Opt_2kx10x1-16 4121337 846.3 ns/op 7322.13 MB/s Benchmark____GWs_Opt_2kx10x1-16 4180147 907.0 ns/op 6832.59 MB/s Benchmark____GWs_Opt_2kx10x1-16 3961234 841.0 ns/op 7368.99 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2376246 1530 ns/op 8064.01 MB/s Benchmark____GWs_Opt_4kx10x1-16 2400772 1539 ns/op 8019.42 MB/s Benchmark____GWs_Opt_4kx10x1-16 2358363 1546 ns/op 7982.01 MB/s Benchmark____GWs_Opt_4kx10x1-16 2372396 1487 ns/op 8299.78 MB/s Benchmark____GWs_Opt_4kx10x1-16 2357592 1623 ns/op 7603.41 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12108027 285.7 ns/op 3639.92 MB/s Benchmark____GWs_Int_1kx01x0-16 12474613 282.9 ns/op 3676.84 MB/s Benchmark____GWs_Int_1kx01x0-16 11985993 289.7 ns/op 3590.13 MB/s Benchmark____GWs_Int_1kx01x0-16 12444290 287.5 ns/op 3616.85 MB/s Benchmark____GWs_Int_1kx01x0-16 11638828 292.2 ns/op 3559.68 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9207811 349.5 ns/op 5905.36 MB/s Benchmark____GWs_Int_2kx01x0-16 9416972 371.2 ns/op 5561.07 MB/s Benchmark____GWs_Int_2kx01x0-16 10224021 351.4 ns/op 5872.99 MB/s Benchmark____GWs_Int_2kx01x0-16 9965420 365.5 ns/op 5647.39 MB/s Benchmark____GWs_Int_2kx01x0-16 10243876 361.7 ns/op 5706.46 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5736564 645.7 ns/op 6368.38 MB/s Benchmark____GWs_Int_4kx01x0-16 5772830 622.4 ns/op 6606.85 MB/s Benchmark____GWs_Int_4kx01x0-16 5920180 628.1 ns/op 6547.14 MB/s Benchmark____GWs_Int_4kx01x0-16 5407555 634.7 ns/op 6478.85 MB/s Benchmark____GWs_Int_4kx01x0-16 5745268 701.5 ns/op 5861.63 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31256305 110.3 ns/op 9432.34 MB/s Benchmark____GWs_Int_1kx10x0-16 31830667 109.8 ns/op 9474.34 MB/s Benchmark____GWs_Int_1kx10x0-16 27544796 110.9 ns/op 9374.26 MB/s Benchmark____GWs_Int_1kx10x0-16 26778709 112.4 ns/op 9252.12 MB/s Benchmark____GWs_Int_1kx10x0-16 31391121 114.4 ns/op 9090.70 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25123466 143.0 ns/op 14437.14 MB/s Benchmark____GWs_Int_2kx10x0-16 25290580 146.6 ns/op 14079.22 MB/s Benchmark____GWs_Int_2kx10x0-16 24859120 147.5 ns/op 13996.71 MB/s Benchmark____GWs_Int_2kx10x0-16 21087487 145.3 ns/op 14201.54 MB/s Benchmark____GWs_Int_2kx10x0-16 26558092 142.4 ns/op 14492.76 MB/s Benchmark____GWs_Int_4kx10x0 bench_test.go:55: Failed read: read tcp 127.0.0.1:51132->127.0.0.1:35361: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 bench_test.go:55: Failed read: read tcp 127.0.0.1:54354->127.0.0.1:35495: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 13054437 317.9 ns/op 12936.42 MB/s Benchmark____GWs_Int_4kx10x0-16 12952585 281.1 ns/op 14629.47 MB/s Benchmark____GWs_Int_4kx10x0-16 12813956 823.8 ns/op 4991.56 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6474097 558.0 ns/op 5600.09 MB/s Benchmark____GWs_Int_1kx01x1-16 6488290 560.7 ns/op 5572.96 MB/s Benchmark____GWs_Int_1kx01x1-16 6671649 565.5 ns/op 5526.05 MB/s Benchmark____GWs_Int_1kx01x1-16 6475621 555.3 ns/op 5627.34 MB/s Benchmark____GWs_Int_1kx01x1-16 6506895 554.8 ns/op 5633.03 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4580799 784.8 ns/op 7896.58 MB/s Benchmark____GWs_Int_2kx01x1-16 4572890 778.4 ns/op 7961.28 MB/s Benchmark____GWs_Int_2kx01x1-16 4653986 767.3 ns/op 8076.40 MB/s Benchmark____GWs_Int_2kx01x1-16 4594104 762.4 ns/op 8127.80 MB/s Benchmark____GWs_Int_2kx01x1-16 4265563 772.2 ns/op 8025.03 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2622184 1383 ns/op 8924.03 MB/s Benchmark____GWs_Int_4kx01x1-16 2674866 1568 ns/op 7870.05 MB/s Benchmark____GWs_Int_4kx01x1-16 2701075 1368 ns/op 9023.38 MB/s Benchmark____GWs_Int_4kx01x1-16 2649738 1386 ns/op 8904.89 MB/s Benchmark____GWs_Int_4kx01x1-16 2640820 1497 ns/op 8245.45 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6178585 563.3 ns/op 5547.73 MB/s Benchmark____GWs_Int_1kx10x1-16 5918124 560.8 ns/op 5572.20 MB/s Benchmark____GWs_Int_1kx10x1-16 6579920 566.0 ns/op 5521.17 MB/s Benchmark____GWs_Int_1kx10x1-16 6217492 579.5 ns/op 5392.88 MB/s Benchmark____GWs_Int_1kx10x1-16 6049792 558.4 ns/op 5596.70 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4117281 848.9 ns/op 7300.44 MB/s Benchmark____GWs_Int_2kx10x1-16 4183912 842.3 ns/op 7356.93 MB/s Benchmark____GWs_Int_2kx10x1-16 4184182 844.6 ns/op 7337.33 MB/s Benchmark____GWs_Int_2kx10x1-16 3861234 845.1 ns/op 7332.82 MB/s Benchmark____GWs_Int_2kx10x1-16 4124809 853.7 ns/op 7259.17 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2361590 1777 ns/op 6943.56 MB/s Benchmark____GWs_Int_4kx10x1-16 2355332 1779 ns/op 6935.85 MB/s Benchmark____GWs_Int_4kx10x1-16 2364646 1514 ns/op 8153.71 MB/s Benchmark____GWs_Int_4kx10x1-16 2244919 1501 ns/op 8223.32 MB/s Benchmark____GWs_Int_4kx10x1-16 2257435 1582 ns/op 7802.18 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8079423 428.2 ns/op 238.18 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8545996 437.1 ns/op 233.34 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8103937 440.4 ns/op 231.60 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8263186 432.2 ns/op 236.03 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8237125 439.6 ns/op 232.03 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 713980 5122 ns/op 34.56 MB/s Benchmark__GWs_Reqs_1SubEach-16 762681 5355 ns/op 33.05 MB/s Benchmark__GWs_Reqs_1SubEach-16 770402 5320 ns/op 33.27 MB/s Benchmark__GWs_Reqs_1SubEach-16 761688 5219 ns/op 33.91 MB/s Benchmark__GWs_Reqs_1SubEach-16 771236 5336 ns/op 33.17 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2071.052s ❌ Non-zero exit code: 1