> ROOT_DIR=/tmp/go-bench-away-job-72dd4bee-1e2e-4403-856d-9ce833463e53-997340484 > OUTPUT_FILE=/tmp/go-bench-away-job-72dd4bee-1e2e-4403-856d-9ce833463e53-997340484/results.txt > SHA_FILE=/tmp/go-bench-away-job-72dd4bee-1e2e-4403-856d-9ce833463e53-997340484/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-72dd4bee-1e2e-4403-856d-9ce833463e53-997340484/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=v2.12.0 > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.25.4/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: v2.12.0 to /tmp/go-bench-away-job-72dd4bee-1e2e-4403-856d-9ce833463e53-997340484/source.git SHA of v2.12.0: 1629aa5db771adcefe2a5aa40b41688c55007181 Go runtime: go version go1.26.0 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-build3629573084=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-72dd4bee-1e2e-4403-856d-9ce833463e53-997340484/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.25.4' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.25.4/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.0' 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 54330051 66.10 ns/op 166.42 MB/s Benchmark______Pub0b_Payload-16 51134994 65.96 ns/op 166.78 MB/s Benchmark______Pub0b_Payload-16 51139348 68.67 ns/op 160.19 MB/s Benchmark______Pub0b_Payload-16 51275588 66.17 ns/op 166.24 MB/s Benchmark______Pub0b_Payload-16 51286954 66.12 ns/op 166.37 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 50474265 66.89 ns/op 284.03 MB/s Benchmark______Pub8b_Payload-16 53390706 66.54 ns/op 285.56 MB/s Benchmark______Pub8b_Payload-16 50918354 70.11 ns/op 271.01 MB/s Benchmark______Pub8b_Payload-16 49402758 67.51 ns/op 281.44 MB/s Benchmark______Pub8b_Payload-16 50601272 66.70 ns/op 284.86 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 47302806 72.02 ns/op 610.97 MB/s Benchmark_____Pub32b_Payload-16 46920542 71.81 ns/op 612.75 MB/s Benchmark_____Pub32b_Payload-16 47115889 72.05 ns/op 610.67 MB/s Benchmark_____Pub32b_Payload-16 46902184 72.96 ns/op 603.08 MB/s Benchmark_____Pub32b_Payload-16 45724759 71.71 ns/op 613.57 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 41530609 83.18 ns/op 1695.09 MB/s Benchmark____Pub128B_Payload-16 40613947 81.08 ns/op 1738.95 MB/s Benchmark____Pub128B_Payload-16 36005547 83.46 ns/op 1689.46 MB/s Benchmark____Pub128B_Payload-16 41811564 81.43 ns/op 1731.63 MB/s Benchmark____Pub128B_Payload-16 41974332 83.96 ns/op 1679.28 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 38483773 99.37 ns/op 2706.94 MB/s Benchmark____Pub256B_Payload-16 38782510 88.09 ns/op 3053.67 MB/s Benchmark____Pub256B_Payload-16 37346683 89.29 ns/op 3012.69 MB/s Benchmark____Pub256B_Payload-16 33977128 89.27 ns/op 3013.42 MB/s Benchmark____Pub256B_Payload-16 37714734 88.63 ns/op 3035.16 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 22141544 145.9 ns/op 7116.43 MB/s Benchmark______Pub1K_Payload-16 24412663 130.2 ns/op 7972.09 MB/s Benchmark______Pub1K_Payload-16 26374728 136.3 ns/op 7618.14 MB/s Benchmark______Pub1K_Payload-16 27808588 139.3 ns/op 7450.01 MB/s Benchmark______Pub1K_Payload-16 24150322 130.1 ns/op 7977.21 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5418195 636.7 ns/op 6455.45 MB/s Benchmark______Pub4K_Payload-16 5543739 630.9 ns/op 6514.28 MB/s Benchmark______Pub4K_Payload-16 5353388 626.6 ns/op 6559.13 MB/s Benchmark______Pub4K_Payload-16 5307094 624.4 ns/op 6582.84 MB/s Benchmark______Pub4K_Payload-16 5601589 636.7 ns/op 6454.81 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2719861 1283 ns/op 6394.63 MB/s Benchmark______Pub8K_Payload-16 2724092 1288 ns/op 6372.96 MB/s Benchmark______Pub8K_Payload-16 2679403 1286 ns/op 6382.92 MB/s Benchmark______Pub8K_Payload-16 2733153 1276 ns/op 6428.63 MB/s Benchmark______Pub8K_Payload-16 2753137 1280 ns/op 6412.88 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 725193 5399 ns/op 6071.75 MB/s Benchmark_____Pub32K_Payload-16 658677 5455 ns/op 6009.91 MB/s Benchmark_____Pub32K_Payload-16 670660 5389 ns/op 6083.02 MB/s Benchmark_____Pub32K_Payload-16 669888 5267 ns/op 6223.66 MB/s Benchmark_____Pub32K_Payload-16 674574 5526 ns/op 5932.02 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 24937720 123.1 ns/op 89.37 MB/s Benchmark__AuthPub0b_Payload-16 26116592 123.2 ns/op 89.26 MB/s Benchmark__AuthPub0b_Payload-16 25822936 122.9 ns/op 89.48 MB/s Benchmark__AuthPub0b_Payload-16 27797612 122.9 ns/op 89.49 MB/s Benchmark__AuthPub0b_Payload-16 26075619 123.2 ns/op 89.29 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 16904779 209.1 ns/op Benchmark_____________PubSub-16 16950543 209.1 ns/op Benchmark_____________PubSub-16 16983489 209.4 ns/op Benchmark_____________PubSub-16 17019768 209.5 ns/op Benchmark_____________PubSub-16 16612262 208.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 16970329 207.7 ns/op Benchmark_____PubSubTwoConns-16 17146988 208.8 ns/op Benchmark_____PubSubTwoConns-16 17065735 208.5 ns/op Benchmark_____PubSubTwoConns-16 17189892 208.7 ns/op Benchmark_____PubSubTwoConns-16 16747525 208.4 ns/op Benchmark__PubServiceImports bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:34808->127.0.0.1:46701: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:49800->127.0.0.1:35217: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:58356->127.0.0.1:41765: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:51680->127.0.0.1:33583: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:55880->127.0.0.1:41703: 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 15465738 227.9 ns/op Benchmark_____PubTwoQueueSub-16 15517230 228.6 ns/op Benchmark_____PubTwoQueueSub-16 15630924 227.6 ns/op Benchmark_____PubTwoQueueSub-16 15543735 227.4 ns/op Benchmark_____PubTwoQueueSub-16 15691653 227.1 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15595417 228.2 ns/op Benchmark____PubFourQueueSub-16 15448708 227.4 ns/op Benchmark____PubFourQueueSub-16 15486943 227.3 ns/op Benchmark____PubFourQueueSub-16 15629052 227.3 ns/op Benchmark____PubFourQueueSub-16 15552507 227.2 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15549223 227.6 ns/op Benchmark___PubEightQueueSub-16 15551197 227.2 ns/op Benchmark___PubEightQueueSub-16 15940756 225.4 ns/op Benchmark___PubEightQueueSub-16 15702724 226.6 ns/op Benchmark___PubEightQueueSub-16 15521295 227.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22802 154426 ns/op Benchmark_PubSub512kTwoConns-16 23134 155716 ns/op Benchmark_PubSub512kTwoConns-16 23082 154757 ns/op Benchmark_PubSub512kTwoConns-16 23108 155349 ns/op Benchmark_PubSub512kTwoConns-16 22956 156101 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16401164 211.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 16092110 209.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 16518999 211.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 16481439 211.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 16439329 211.0 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16419218 210.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 16304737 211.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 16395463 211.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 16544875 210.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 16229199 211.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 12332715 288.2 ns/op Benchmark____RoutedPubSub_0b-16 12399724 281.8 ns/op Benchmark____RoutedPubSub_0b-16 12359094 292.0 ns/op Benchmark____RoutedPubSub_0b-16 12403123 289.9 ns/op Benchmark____RoutedPubSub_0b-16 12262504 293.5 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6416414 516.5 ns/op Benchmark____RoutedPubSub_1K-16 6419743 529.0 ns/op Benchmark____RoutedPubSub_1K-16 6850708 523.3 ns/op Benchmark____RoutedPubSub_1K-16 6872718 527.3 ns/op Benchmark____RoutedPubSub_1K-16 6512886 528.5 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85821 41680 ns/op Benchmark__RoutedPubSub_100K-16 82686 41291 ns/op Benchmark__RoutedPubSub_100K-16 83310 41924 ns/op Benchmark__RoutedPubSub_100K-16 80398 43587 ns/op Benchmark__RoutedPubSub_100K-16 81456 43056 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 10412293 337.0 ns/op Benchmark____Routed2QueueSub-16 10477552 341.7 ns/op Benchmark____Routed2QueueSub-16 10652814 337.7 ns/op Benchmark____Routed2QueueSub-16 10662716 346.2 ns/op Benchmark____Routed2QueueSub-16 10337236 338.1 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 8434746 356.5 ns/op Benchmark____Routed4QueueSub-16 10003903 348.4 ns/op Benchmark____Routed4QueueSub-16 10447407 343.6 ns/op Benchmark____Routed4QueueSub-16 10415604 342.2 ns/op Benchmark____Routed4QueueSub-16 10396046 341.0 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9975522 356.8 ns/op Benchmark____Routed8QueueSub-16 8497226 358.4 ns/op Benchmark____Routed8QueueSub-16 8406854 370.0 ns/op Benchmark____Routed8QueueSub-16 8435198 361.9 ns/op Benchmark____Routed8QueueSub-16 10032067 353.9 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8111445 379.2 ns/op Benchmark___Routed16QueueSub-16 8117743 380.3 ns/op Benchmark___Routed16QueueSub-16 8179474 381.3 ns/op Benchmark___Routed16QueueSub-16 8122510 377.7 ns/op Benchmark___Routed16QueueSub-16 8116356 377.5 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 7282580 453.0 ns/op Benchmark____________RouteCompressOff-16 7255785 461.7 ns/op Benchmark____________RouteCompressOff-16 7393014 464.6 ns/op Benchmark____________RouteCompressOff-16 7255302 470.2 ns/op Benchmark____________RouteCompressOff-16 7149784 463.6 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6580243 485.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 7066270 472.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6935618 479.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 7300680 475.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6982840 471.6 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 7016047 474.2 ns/op Benchmark_________RouteCompressS2Fast-16 6984524 461.9 ns/op Benchmark_________RouteCompressS2Fast-16 6925078 457.6 ns/op Benchmark_________RouteCompressS2Fast-16 7150191 475.3 ns/op Benchmark_________RouteCompressS2Fast-16 6751210 468.5 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6955911 472.9 ns/op Benchmark_______RouteCompressS2Better-16 7240323 468.5 ns/op Benchmark_______RouteCompressS2Better-16 6885520 467.4 ns/op Benchmark_______RouteCompressS2Better-16 7175946 463.3 ns/op Benchmark_______RouteCompressS2Better-16 7172695 467.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 7166346 470.9 ns/op Benchmark_________RouteCompressS2Best-16 7211773 466.5 ns/op Benchmark_________RouteCompressS2Best-16 6844435 464.7 ns/op Benchmark_________RouteCompressS2Best-16 7119507 472.9 ns/op Benchmark_________RouteCompressS2Best-16 6936218 464.0 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5164060 688.0 ns/op 361.90 MB/s Benchmark______FanOut_8x1x10-16 5163382 690.5 ns/op 360.59 MB/s Benchmark______FanOut_8x1x10-16 5159220 686.1 ns/op 362.90 MB/s Benchmark______FanOut_8x1x10-16 5215976 690.1 ns/op 360.81 MB/s Benchmark______FanOut_8x1x10-16 5190231 688.3 ns/op 361.78 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 619552 5342 ns/op 434.08 MB/s Benchmark_____FanOut_8x1x100-16 604558 5323 ns/op 435.64 MB/s Benchmark_____FanOut_8x1x100-16 646218 5346 ns/op 433.79 MB/s Benchmark_____FanOut_8x1x100-16 636501 5330 ns/op 435.12 MB/s Benchmark_____FanOut_8x1x100-16 643766 5348 ns/op 433.60 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 53103 67745 ns/op 339.79 MB/s Benchmark____FanOut_8x10x100-16 52983 67763 ns/op 339.70 MB/s Benchmark____FanOut_8x10x100-16 53172 67584 ns/op 340.60 MB/s Benchmark____FanOut_8x10x100-16 52936 67599 ns/op 340.52 MB/s Benchmark____FanOut_8x10x100-16 53058 67542 ns/op 340.81 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6856 533817 ns/op 449.63 MB/s Benchmark___FanOut_8x10x1000-16 6703 526141 ns/op 456.19 MB/s Benchmark___FanOut_8x10x1000-16 6488 532949 ns/op 450.36 MB/s Benchmark___FanOut_8x10x1000-16 6441 529642 ns/op 453.17 MB/s Benchmark___FanOut_8x10x1000-16 6577 530240 ns/op 452.66 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5611 632884 ns/op 363.45 MB/s Benchmark___FanOut_8x100x100-16 5539 632017 ns/op 363.94 MB/s Benchmark___FanOut_8x100x100-16 5548 632612 ns/op 363.60 MB/s Benchmark___FanOut_8x100x100-16 5580 632030 ns/op 363.94 MB/s Benchmark___FanOut_8x100x100-16 5617 632326 ns/op 363.77 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 648 5510382 ns/op 435.54 MB/s Benchmark__FanOut_8x100x1000-16 627 5471508 ns/op 438.64 MB/s Benchmark__FanOut_8x100x1000-16 655 5469761 ns/op 438.78 MB/s Benchmark__FanOut_8x100x1000-16 628 5550388 ns/op 432.41 MB/s Benchmark__FanOut_8x100x1000-16 621 5502816 ns/op 436.14 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 620 5881688 ns/op 425.05 MB/s Benchmark__FanOut_8x10x10000-16 597 5798702 ns/op 431.13 MB/s Benchmark__FanOut_8x10x10000-16 620 5898493 ns/op 423.84 MB/s Benchmark__FanOut_8x10x10000-16 614 5889773 ns/op 424.47 MB/s Benchmark__FanOut_8x10x10000-16 600 5894865 ns/op 424.10 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1033 3401759 ns/op 338.07 MB/s Benchmark___FanOut_8x500x100-16 1041 3399518 ns/op 338.29 MB/s Benchmark___FanOut_8x500x100-16 1045 3421235 ns/op 336.14 MB/s Benchmark___FanOut_8x500x100-16 1050 3405825 ns/op 337.66 MB/s Benchmark___FanOut_8x500x100-16 1044 3402258 ns/op 338.02 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 375010 8824 ns/op 1659.26 MB/s Benchmark___FanOut_128x1x100-16 392221 8806 ns/op 1662.71 MB/s Benchmark___FanOut_128x1x100-16 397234 8827 ns/op 1658.68 MB/s Benchmark___FanOut_128x1x100-16 365310 8886 ns/op 1647.61 MB/s Benchmark___FanOut_128x1x100-16 386462 8823 ns/op 1659.35 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 35038 102456 ns/op 1416.62 MB/s Benchmark__FanOut_128x10x100-16 34893 102306 ns/op 1418.70 MB/s Benchmark__FanOut_128x10x100-16 35310 102158 ns/op 1420.75 MB/s Benchmark__FanOut_128x10x100-16 35050 101890 ns/op 1424.49 MB/s Benchmark__FanOut_128x10x100-16 35126 102373 ns/op 1417.77 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4594 794968 ns/op 1836.73 MB/s Benchmark_FanOut_128x10x1000-16 4582 789828 ns/op 1848.68 MB/s Benchmark_FanOut_128x10x1000-16 4468 791234 ns/op 1845.40 MB/s Benchmark_FanOut_128x10x1000-16 4484 784055 ns/op 1862.29 MB/s Benchmark_FanOut_128x10x1000-16 4473 791558 ns/op 1844.64 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3804 935837 ns/op 1549.57 MB/s Benchmark_FanOut_128x100x100-16 3770 934545 ns/op 1551.71 MB/s Benchmark_FanOut_128x100x100-16 3828 940156 ns/op 1542.45 MB/s Benchmark_FanOut_128x100x100-16 3796 936327 ns/op 1548.75 MB/s Benchmark_FanOut_128x100x100-16 3811 935763 ns/op 1549.69 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 428 8479493 ns/op 1721.82 MB/s BenchmarkFanOut_128x100x1000-16 422 8484787 ns/op 1720.74 MB/s BenchmarkFanOut_128x100x1000-16 423 8440783 ns/op 1729.71 MB/s BenchmarkFanOut_128x100x1000-16 427 8441159 ns/op 1729.64 MB/s BenchmarkFanOut_128x100x1000-16 418 8511046 ns/op 1715.43 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 406 8812184 ns/op 1668.16 MB/s BenchmarkFanOut_128x10x10000-16 408 8806582 ns/op 1669.22 MB/s BenchmarkFanOut_128x10x10000-16 411 8816379 ns/op 1667.37 MB/s BenchmarkFanOut_128x10x10000-16 409 8810756 ns/op 1668.43 MB/s BenchmarkFanOut_128x10x10000-16 410 8794800 ns/op 1671.46 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 715 4978145 ns/op 1456.39 MB/s BenchmarkFanOut__128x500x100-16 706 4975442 ns/op 1457.19 MB/s BenchmarkFanOut__128x500x100-16 716 5008012 ns/op 1447.71 MB/s BenchmarkFanOut__128x500x100-16 716 4976124 ns/op 1456.99 MB/s BenchmarkFanOut__128x500x100-16 716 4967316 ns/op 1459.57 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 2022 1778562 ns/op 2974.61 MB/s Benchmark_FanOut_512x100x100-16 1995 1762130 ns/op 3002.35 MB/s Benchmark_FanOut_512x100x100-16 1989 1757097 ns/op 3010.95 MB/s Benchmark_FanOut_512x100x100-16 2038 1751317 ns/op 3020.88 MB/s Benchmark_FanOut_512x100x100-16 2010 1763355 ns/op 3000.26 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 224 16034171 ns/op 3305.47 MB/s Benchmark__FanOut_512x100x1k-16 225 15751718 ns/op 3364.75 MB/s Benchmark__FanOut_512x100x1k-16 226 16040045 ns/op 3304.26 MB/s Benchmark__FanOut_512x100x1k-16 223 15985377 ns/op 3315.56 MB/s Benchmark__FanOut_512x100x1k-16 226 15901984 ns/op 3332.95 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2982 1096554 ns/op 9512.56 MB/s Benchmark____FanOut_1kx10x1k-16 3114 1090022 ns/op 9569.57 MB/s Benchmark____FanOut_1kx10x1k-16 2992 1103525 ns/op 9452.47 MB/s Benchmark____FanOut_1kx10x1k-16 3380 1096540 ns/op 9512.68 MB/s Benchmark____FanOut_1kx10x1k-16 3519 1104323 ns/op 9445.64 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2881 1204718 ns/op 8650.19 MB/s Benchmark__FanOut_1kx100x100-16 2908 1200576 ns/op 8680.03 MB/s Benchmark__FanOut_1kx100x100-16 2935 1191291 ns/op 8747.68 MB/s Benchmark__FanOut_1kx100x100-16 2898 1196975 ns/op 8706.15 MB/s Benchmark__FanOut_1kx100x100-16 2884 1195538 ns/op 8716.61 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4633964 750.7 ns/op 331.70 MB/s Benchmark_____RFanOut_8x1x10-16 4597125 748.8 ns/op 332.52 MB/s Benchmark_____RFanOut_8x1x10-16 4560747 750.5 ns/op 331.76 MB/s Benchmark_____RFanOut_8x1x10-16 4636867 759.9 ns/op 327.67 MB/s Benchmark_____RFanOut_8x1x10-16 4654986 753.5 ns/op 330.44 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 592388 5424 ns/op 427.58 MB/s Benchmark____RFanOut_8x1x100-16 597468 5439 ns/op 426.34 MB/s Benchmark____RFanOut_8x1x100-16 614684 5381 ns/op 430.96 MB/s Benchmark____RFanOut_8x1x100-16 626900 5387 ns/op 430.45 MB/s Benchmark____RFanOut_8x1x100-16 593432 5402 ns/op 429.26 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 53236 67835 ns/op 339.34 MB/s Benchmark___RFanOut_8x10x100-16 52914 67522 ns/op 340.91 MB/s Benchmark___RFanOut_8x10x100-16 52623 67533 ns/op 340.86 MB/s Benchmark___RFanOut_8x10x100-16 51438 67691 ns/op 340.06 MB/s Benchmark___RFanOut_8x10x100-16 53000 68050 ns/op 338.26 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6644 536847 ns/op 447.09 MB/s Benchmark__RFanOut_8x10x1000-16 6657 531381 ns/op 451.69 MB/s Benchmark__RFanOut_8x10x1000-16 6610 531384 ns/op 451.69 MB/s Benchmark__RFanOut_8x10x1000-16 6278 530763 ns/op 452.21 MB/s Benchmark__RFanOut_8x10x1000-16 6795 532311 ns/op 450.90 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5535 631397 ns/op 364.30 MB/s Benchmark__RFanOut_8x100x100-16 5536 630348 ns/op 364.91 MB/s Benchmark__RFanOut_8x100x100-16 5604 633473 ns/op 363.11 MB/s Benchmark__RFanOut_8x100x100-16 5605 627984 ns/op 366.28 MB/s Benchmark__RFanOut_8x100x100-16 5632 632350 ns/op 363.75 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 663 5479122 ns/op 438.03 MB/s Benchmark_RFanOut_8x100x1000-16 655 5504374 ns/op 436.02 MB/s Benchmark_RFanOut_8x100x1000-16 637 5521495 ns/op 434.67 MB/s Benchmark_RFanOut_8x100x1000-16 642 5461996 ns/op 439.40 MB/s Benchmark_RFanOut_8x100x1000-16 648 5505350 ns/op 435.94 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 616 5777605 ns/op 432.71 MB/s Benchmark_RFanOut_8x10x10000-16 613 5843636 ns/op 427.82 MB/s Benchmark_RFanOut_8x10x10000-16 602 5824278 ns/op 429.24 MB/s Benchmark_RFanOut_8x10x10000-16 613 5881793 ns/op 425.04 MB/s Benchmark_RFanOut_8x10x10000-16 601 5868170 ns/op 426.03 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2888 1096692 ns/op 9511.37 MB/s Benchmark_RFanOut_1kx10x1000-16 3448 1131350 ns/op 9219.99 MB/s Benchmark_RFanOut_1kx10x1000-16 3322 1120950 ns/op 9305.54 MB/s Benchmark_RFanOut_1kx10x1000-16 2842 1087853 ns/op 9588.64 MB/s Benchmark_RFanOut_1kx10x1000-16 3376 1109246 ns/op 9403.72 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7271139 486.5 ns/op 4271.49 MB/s Benchmark_____FanIn_1kx100x1-16 7213833 484.9 ns/op 4285.22 MB/s Benchmark_____FanIn_1kx100x1-16 7274458 485.5 ns/op 4280.51 MB/s Benchmark_____FanIn_1kx100x1-16 7266463 487.4 ns/op 4263.87 MB/s Benchmark_____FanIn_1kx100x1-16 7288540 486.6 ns/op 4270.24 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2648494 1361 ns/op 6042.79 MB/s Benchmark_____FanIn_4kx100x1-16 2648830 1332 ns/op 6171.72 MB/s Benchmark_____FanIn_4kx100x1-16 2654487 1344 ns/op 6115.71 MB/s Benchmark_____FanIn_4kx100x1-16 2698460 1339 ns/op 6141.95 MB/s Benchmark_____FanIn_4kx100x1-16 2716039 1336 ns/op 6153.86 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1745605 2108 ns/op 7786.78 MB/s Benchmark_____FanIn_8kx100x1-16 1740200 2088 ns/op 7862.53 MB/s Benchmark_____FanIn_8kx100x1-16 1718151 2074 ns/op 7913.31 MB/s Benchmark_____FanIn_8kx100x1-16 1729828 2085 ns/op 7870.80 MB/s Benchmark_____FanIn_8kx100x1-16 1736402 2079 ns/op 7893.64 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 875439 4093 ns/op 8014.15 MB/s Benchmark____FanIn_16kx100x1-16 875506 4113 ns/op 7975.22 MB/s Benchmark____FanIn_16kx100x1-16 885381 4096 ns/op 8006.86 MB/s Benchmark____FanIn_16kx100x1-16 846528 4142 ns/op 7919.16 MB/s Benchmark____FanIn_16kx100x1-16 867458 4111 ns/op 7978.15 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 172064 19941 ns/op 6574.71 MB/s Benchmark____FanIn_64kx100x1-16 166285 19812 ns/op 6617.57 MB/s Benchmark____FanIn_64kx100x1-16 175252 19835 ns/op 6609.72 MB/s Benchmark____FanIn_64kx100x1-16 169755 19817 ns/op 6615.62 MB/s Benchmark____FanIn_64kx100x1-16 172834 19858 ns/op 6602.08 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 339654190 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:47666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:48156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:47492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:48318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:48160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:48084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:47548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:48130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47766->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: 281319140 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:49872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:49578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:49544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:49556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:49424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:49220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:50018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49588->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: 3489353620 vs 11601465000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40022->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: 283023310 vs 1310900000 bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:41942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:41892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:42388->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: 424076150 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43866->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 6015559 591.0 ns/op 480.51 MB/s Benchmark___BumpPubCount_1x3-16 6075271 600.2 ns/op 473.17 MB/s Benchmark___BumpPubCount_1x3-16 6068908 595.4 ns/op 477.01 MB/s Benchmark___BumpPubCount_1x3-16 6004407 597.2 ns/op 475.55 MB/s Benchmark___BumpPubCount_1x3-16 6036753 593.4 ns/op 478.59 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5681420 628.3 ns/op 452.00 MB/s Benchmark___BumpPubCount_2x3-16 5654859 628.5 ns/op 451.88 MB/s Benchmark___BumpPubCount_2x3-16 5615236 631.2 ns/op 449.94 MB/s Benchmark___BumpPubCount_2x3-16 5559538 630.6 ns/op 450.40 MB/s Benchmark___BumpPubCount_2x3-16 5651196 630.4 ns/op 450.52 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5866435 609.7 ns/op 465.80 MB/s Benchmark___BumpPubCount_5x3-16 5841112 611.2 ns/op 464.69 MB/s Benchmark___BumpPubCount_5x3-16 5739766 612.3 ns/op 463.82 MB/s Benchmark___BumpPubCount_5x3-16 5689588 609.3 ns/op 466.09 MB/s Benchmark___BumpPubCount_5x3-16 5581209 611.3 ns/op 464.61 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5310849 599.2 ns/op 473.97 MB/s Benchmark__BumpPubCount_10x3-16 5947226 599.8 ns/op 473.47 MB/s Benchmark__BumpPubCount_10x3-16 5950394 611.4 ns/op 464.51 MB/s Benchmark__BumpPubCount_10x3-16 5950269 598.2 ns/op 474.75 MB/s Benchmark__BumpPubCount_10x3-16 5979790 603.6 ns/op 470.50 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12659378 266.8 ns/op 3897.82 MB/s Benchmark____GWs_Opt_1kx01x0-16 12854792 279.6 ns/op 3720.20 MB/s Benchmark____GWs_Opt_1kx01x0-16 12542763 263.6 ns/op 3945.73 MB/s Benchmark____GWs_Opt_1kx01x0-16 11161674 270.6 ns/op 3843.44 MB/s Benchmark____GWs_Opt_1kx01x0-16 13682876 267.5 ns/op 3887.26 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10402341 313.0 ns/op 6594.25 MB/s Benchmark____GWs_Opt_2kx01x0-16 10885468 320.0 ns/op 6449.53 MB/s Benchmark____GWs_Opt_2kx01x0-16 9375872 330.7 ns/op 6241.76 MB/s Benchmark____GWs_Opt_2kx01x0-16 10818990 335.2 ns/op 6157.07 MB/s Benchmark____GWs_Opt_2kx01x0-16 10917165 350.1 ns/op 5894.74 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5866740 627.3 ns/op 6555.27 MB/s Benchmark____GWs_Opt_4kx01x0-16 5964474 677.3 ns/op 6070.74 MB/s Benchmark____GWs_Opt_4kx01x0-16 5711337 607.8 ns/op 6765.88 MB/s Benchmark____GWs_Opt_4kx01x0-16 5676240 614.4 ns/op 6692.40 MB/s Benchmark____GWs_Opt_4kx01x0-16 5917333 613.4 ns/op 6704.06 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28030693 108.3 ns/op 9605.56 MB/s Benchmark____GWs_Opt_1kx10x0-16 32522974 111.6 ns/op 9317.53 MB/s Benchmark____GWs_Opt_1kx10x0-16 32274516 133.8 ns/op 7774.81 MB/s Benchmark____GWs_Opt_1kx10x0-16 30155982 105.4 ns/op 9865.91 MB/s Benchmark____GWs_Opt_1kx10x0-16 32753911 112.9 ns/op 9213.48 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 21651184 144.9 ns/op 14242.77 MB/s Benchmark____GWs_Opt_2kx10x0-16 26478394 154.7 ns/op 13341.31 MB/s Benchmark____GWs_Opt_2kx10x0-16 22713813 151.3 ns/op 13644.68 MB/s Benchmark____GWs_Opt_2kx10x0-16 25131908 144.0 ns/op 14330.75 MB/s Benchmark____GWs_Opt_2kx10x0-16 25994925 151.0 ns/op 13671.40 MB/s Benchmark____GWs_Opt_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:56458->127.0.0.1:43773: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:52228->127.0.0.1:37387: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 9003279 371.9 ns/op 11055.68 MB/s Benchmark____GWs_Opt_4kx10x0-16 11549012 335.5 ns/op 12256.48 MB/s Benchmark____GWs_Opt_4kx10x0-16 10856304 292.0 ns/op 14082.08 MB/s Benchmark____GWs_Opt_4kx10x0-16 12412680 287.7 ns/op 14294.33 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6228729 557.9 ns/op 5601.38 MB/s Benchmark____GWs_Opt_1kx01x1-16 6385699 542.4 ns/op 5761.90 MB/s Benchmark____GWs_Opt_1kx01x1-16 6409622 567.9 ns/op 5502.83 MB/s Benchmark____GWs_Opt_1kx01x1-16 6105153 545.5 ns/op 5729.16 MB/s Benchmark____GWs_Opt_1kx01x1-16 5868680 567.6 ns/op 5505.58 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4314044 830.5 ns/op 7461.38 MB/s Benchmark____GWs_Opt_2kx01x1-16 4343000 806.3 ns/op 7686.02 MB/s Benchmark____GWs_Opt_2kx01x1-16 4563490 817.8 ns/op 7577.57 MB/s Benchmark____GWs_Opt_2kx01x1-16 4252332 817.6 ns/op 7579.35 MB/s Benchmark____GWs_Opt_2kx01x1-16 4385457 879.3 ns/op 7047.91 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2469964 1488 ns/op 8296.30 MB/s Benchmark____GWs_Opt_4kx01x1-16 2528316 1409 ns/op 8757.57 MB/s Benchmark____GWs_Opt_4kx01x1-16 2210874 1432 ns/op 8619.99 MB/s Benchmark____GWs_Opt_4kx01x1-16 2559546 1676 ns/op 7364.70 MB/s Benchmark____GWs_Opt_4kx01x1-16 2455326 1416 ns/op 8714.52 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 5867618 582.5 ns/op 5365.15 MB/s Benchmark____GWs_Opt_1kx10x1-16 5947508 591.6 ns/op 5282.43 MB/s Benchmark____GWs_Opt_1kx10x1-16 5986008 581.9 ns/op 5370.69 MB/s Benchmark____GWs_Opt_1kx10x1-16 5799807 584.1 ns/op 5350.13 MB/s Benchmark____GWs_Opt_1kx10x1-16 5904811 573.6 ns/op 5448.00 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4011556 860.7 ns/op 7199.68 MB/s Benchmark____GWs_Opt_2kx10x1-16 3982184 874.6 ns/op 7085.83 MB/s Benchmark____GWs_Opt_2kx10x1-16 4069004 866.9 ns/op 7148.78 MB/s Benchmark____GWs_Opt_2kx10x1-16 3717916 859.6 ns/op 7209.06 MB/s Benchmark____GWs_Opt_2kx10x1-16 3995178 865.4 ns/op 7160.92 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2279352 1631 ns/op 7565.28 MB/s Benchmark____GWs_Opt_4kx10x1-16 2252634 1550 ns/op 7963.08 MB/s Benchmark____GWs_Opt_4kx10x1-16 2324532 1548 ns/op 7972.95 MB/s Benchmark____GWs_Opt_4kx10x1-16 2255048 1555 ns/op 7935.88 MB/s Benchmark____GWs_Opt_4kx10x1-16 2263359 1550 ns/op 7964.14 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 13137921 286.6 ns/op 3628.18 MB/s Benchmark____GWs_Int_1kx01x0-16 12924429 273.5 ns/op 3801.94 MB/s Benchmark____GWs_Int_1kx01x0-16 12924199 272.5 ns/op 3815.91 MB/s Benchmark____GWs_Int_1kx01x0-16 12209166 279.0 ns/op 3727.17 MB/s Benchmark____GWs_Int_1kx01x0-16 13093420 285.8 ns/op 3639.39 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10467352 349.0 ns/op 5913.30 MB/s Benchmark____GWs_Int_2kx01x0-16 10763149 349.7 ns/op 5902.98 MB/s Benchmark____GWs_Int_2kx01x0-16 10445365 341.2 ns/op 6050.06 MB/s Benchmark____GWs_Int_2kx01x0-16 10183436 354.3 ns/op 5825.39 MB/s Benchmark____GWs_Int_2kx01x0-16 10410816 351.6 ns/op 5869.99 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5778019 623.4 ns/op 6596.61 MB/s Benchmark____GWs_Int_4kx01x0-16 5752480 613.9 ns/op 6698.12 MB/s Benchmark____GWs_Int_4kx01x0-16 6030264 642.2 ns/op 6403.31 MB/s Benchmark____GWs_Int_4kx01x0-16 5657431 628.3 ns/op 6544.76 MB/s Benchmark____GWs_Int_4kx01x0-16 5725224 636.7 ns/op 6458.15 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32636920 121.2 ns/op 8582.76 MB/s Benchmark____GWs_Int_1kx10x0-16 30430132 108.4 ns/op 9598.28 MB/s Benchmark____GWs_Int_1kx10x0-16 30982875 109.3 ns/op 9513.07 MB/s Benchmark____GWs_Int_1kx10x0-16 30022648 108.8 ns/op 9560.60 MB/s Benchmark____GWs_Int_1kx10x0-16 31494626 120.2 ns/op 8655.57 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25681580 138.5 ns/op 14898.91 MB/s Benchmark____GWs_Int_2kx10x0-16 22139986 141.3 ns/op 14609.30 MB/s Benchmark____GWs_Int_2kx10x0-16 22511491 143.9 ns/op 14347.69 MB/s Benchmark____GWs_Int_2kx10x0-16 26248982 144.4 ns/op 14288.95 MB/s Benchmark____GWs_Int_2kx10x0-16 25968487 141.8 ns/op 14553.34 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13267281 305.2 ns/op 13473.75 MB/s Benchmark____GWs_Int_4kx10x0-16 13204454 345.5 ns/op 11902.82 MB/s Benchmark____GWs_Int_4kx10x0-16 11307249 311.8 ns/op 13186.82 MB/s Benchmark____GWs_Int_4kx10x0-16 13109622 319.1 ns/op 12886.23 MB/s Benchmark____GWs_Int_4kx10x0-16 11478104 275.3 ns/op 14936.70 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6311888 576.5 ns/op 5420.76 MB/s Benchmark____GWs_Int_1kx01x1-16 6387355 573.7 ns/op 5446.82 MB/s Benchmark____GWs_Int_1kx01x1-16 6348424 579.3 ns/op 5394.15 MB/s Benchmark____GWs_Int_1kx01x1-16 6029419 567.6 ns/op 5505.77 MB/s Benchmark____GWs_Int_1kx01x1-16 6418921 573.4 ns/op 5450.25 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4474749 1024 ns/op 6053.18 MB/s Benchmark____GWs_Int_2kx01x1-16 4200696 815.9 ns/op 7595.41 MB/s Benchmark____GWs_Int_2kx01x1-16 4536134 817.2 ns/op 7582.79 MB/s Benchmark____GWs_Int_2kx01x1-16 4177976 826.3 ns/op 7499.71 MB/s Benchmark____GWs_Int_2kx01x1-16 4570258 799.4 ns/op 7752.26 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2519858 1781 ns/op 6929.29 MB/s Benchmark____GWs_Int_4kx01x1-16 2576852 1533 ns/op 8049.61 MB/s Benchmark____GWs_Int_4kx01x1-16 2176334 1532 ns/op 8057.44 MB/s Benchmark____GWs_Int_4kx01x1-16 2452152 1470 ns/op 8395.33 MB/s Benchmark____GWs_Int_4kx01x1-16 2178474 1404 ns/op 8790.35 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 5911837 579.4 ns/op 5393.93 MB/s Benchmark____GWs_Int_1kx10x1-16 6186368 572.4 ns/op 5459.04 MB/s Benchmark____GWs_Int_1kx10x1-16 5931632 578.6 ns/op 5400.52 MB/s Benchmark____GWs_Int_1kx10x1-16 5881144 587.0 ns/op 5323.43 MB/s Benchmark____GWs_Int_1kx10x1-16 6073303 583.0 ns/op 5360.31 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4007983 926.0 ns/op 6692.57 MB/s Benchmark____GWs_Int_2kx10x1-16 4068190 887.4 ns/op 6983.19 MB/s Benchmark____GWs_Int_2kx10x1-16 3985627 869.1 ns/op 7130.21 MB/s Benchmark____GWs_Int_2kx10x1-16 4023274 874.0 ns/op 7090.16 MB/s Benchmark____GWs_Int_2kx10x1-16 4169253 866.0 ns/op 7156.18 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2222050 1570 ns/op 7858.85 MB/s Benchmark____GWs_Int_4kx10x1-16 2277835 1571 ns/op 7857.17 MB/s Benchmark____GWs_Int_4kx10x1-16 2340342 1649 ns/op 7483.09 MB/s Benchmark____GWs_Int_4kx10x1-16 2317101 1624 ns/op 7599.58 MB/s Benchmark____GWs_Int_4kx10x1-16 2314539 1593 ns/op 7747.27 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8426059 443.4 ns/op 230.02 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8056105 440.9 ns/op 231.37 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8321412 444.3 ns/op 229.58 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8115686 437.2 ns/op 233.31 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8348983 436.5 ns/op 233.66 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 650910 4714 ns/op 37.55 MB/s Benchmark__GWs_Reqs_1SubEach-16 843283 4856 ns/op 36.45 MB/s Benchmark__GWs_Reqs_1SubEach-16 811429 4915 ns/op 36.02 MB/s Benchmark__GWs_Reqs_1SubEach-16 791168 4938 ns/op 35.84 MB/s Benchmark__GWs_Reqs_1SubEach-16 757677 5091 ns/op 34.76 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2122.098s ❌ Non-zero exit code: 1