> ROOT_DIR=/tmp/go-bench-away-job-9f83b47a-30df-4863-a896-0b8d81b09e8a-3824598686 > OUTPUT_FILE=/tmp/go-bench-away-job-9f83b47a-30df-4863-a896-0b8d81b09e8a-3824598686/results.txt > SHA_FILE=/tmp/go-bench-away-job-9f83b47a-30df-4863-a896-0b8d81b09e8a-3824598686/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-9f83b47a-30df-4863-a896-0b8d81b09e8a-3824598686/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.26.3/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-9f83b47a-30df-4863-a896-0b8d81b09e8a-3824598686/source.git SHA of main: a948cef028a8facbce473b422c344c133f7333ab Go runtime: go version go1.26.3 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build1159644287=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-9f83b47a-30df-4863-a896-0b8d81b09e8a-3824598686/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.26.3' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.26.3/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.3' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 40374771 78.00 ns/op 141.02 MB/s Benchmark______Pub0b_Payload-16 47070979 71.60 ns/op 153.64 MB/s Benchmark______Pub0b_Payload-16 47684109 71.62 ns/op 153.59 MB/s Benchmark______Pub0b_Payload-16 47134215 74.94 ns/op 146.79 MB/s Benchmark______Pub0b_Payload-16 45507537 71.73 ns/op 153.35 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 49794820 72.41 ns/op 262.41 MB/s Benchmark______Pub8b_Payload-16 47294103 75.32 ns/op 252.27 MB/s Benchmark______Pub8b_Payload-16 46904782 72.35 ns/op 262.60 MB/s Benchmark______Pub8b_Payload-16 46816677 72.27 ns/op 262.90 MB/s Benchmark______Pub8b_Payload-16 47284314 72.32 ns/op 262.72 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44508561 76.09 ns/op 578.28 MB/s Benchmark_____Pub32b_Payload-16 39000595 80.14 ns/op 549.02 MB/s Benchmark_____Pub32b_Payload-16 44848804 76.23 ns/op 577.20 MB/s Benchmark_____Pub32b_Payload-16 44476413 76.26 ns/op 576.98 MB/s Benchmark_____Pub32b_Payload-16 44658770 76.68 ns/op 573.80 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 37270783 86.30 ns/op 1633.79 MB/s Benchmark____Pub128B_Payload-16 41876396 89.68 ns/op 1572.24 MB/s Benchmark____Pub128B_Payload-16 38889938 85.93 ns/op 1640.95 MB/s Benchmark____Pub128B_Payload-16 40153336 86.35 ns/op 1632.86 MB/s Benchmark____Pub128B_Payload-16 39434851 85.66 ns/op 1645.97 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 32259829 95.93 ns/op 2804.12 MB/s Benchmark____Pub256B_Payload-16 36572695 93.83 ns/op 2866.78 MB/s Benchmark____Pub256B_Payload-16 32457093 97.48 ns/op 2759.62 MB/s Benchmark____Pub256B_Payload-16 38481784 99.48 ns/op 2703.99 MB/s Benchmark____Pub256B_Payload-16 35487801 95.05 ns/op 2829.99 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 22066027 141.2 ns/op 7352.84 MB/s Benchmark______Pub1K_Payload-16 25622838 139.5 ns/op 7440.59 MB/s Benchmark______Pub1K_Payload-16 26651990 138.3 ns/op 7506.13 MB/s Benchmark______Pub1K_Payload-16 20396871 155.7 ns/op 6667.46 MB/s Benchmark______Pub1K_Payload-16 26223033 139.5 ns/op 7441.85 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5692191 615.9 ns/op 6673.16 MB/s Benchmark______Pub4K_Payload-16 5558605 618.0 ns/op 6649.98 MB/s Benchmark______Pub4K_Payload-16 5602708 613.7 ns/op 6696.61 MB/s Benchmark______Pub4K_Payload-16 5482950 627.9 ns/op 6545.36 MB/s Benchmark______Pub4K_Payload-16 5720676 623.0 ns/op 6596.91 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2785867 1287 ns/op 6373.78 MB/s Benchmark______Pub8K_Payload-16 2704339 1278 ns/op 6421.76 MB/s Benchmark______Pub8K_Payload-16 2612125 1272 ns/op 6449.93 MB/s Benchmark______Pub8K_Payload-16 2708775 1276 ns/op 6432.07 MB/s Benchmark______Pub8K_Payload-16 2832764 1280 ns/op 6412.14 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 694123 5440 ns/op 6026.44 MB/s Benchmark_____Pub32K_Payload-16 611138 5461 ns/op 6002.91 MB/s Benchmark_____Pub32K_Payload-16 658986 5445 ns/op 6020.51 MB/s Benchmark_____Pub32K_Payload-16 654708 5575 ns/op 5880.76 MB/s Benchmark_____Pub32K_Payload-16 576540 5455 ns/op 6009.51 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31124786 98.03 ns/op 112.21 MB/s Benchmark__AuthPub0b_Payload-16 35255901 97.96 ns/op 112.29 MB/s Benchmark__AuthPub0b_Payload-16 35564110 97.33 ns/op 113.01 MB/s Benchmark__AuthPub0b_Payload-16 34470072 97.81 ns/op 112.46 MB/s Benchmark__AuthPub0b_Payload-16 35405012 97.61 ns/op 112.69 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15595569 228.9 ns/op Benchmark_____________PubSub-16 15248220 228.6 ns/op Benchmark_____________PubSub-16 15492891 228.6 ns/op Benchmark_____________PubSub-16 15497656 228.8 ns/op Benchmark_____________PubSub-16 15486558 229.3 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15654532 226.8 ns/op Benchmark_____PubSubTwoConns-16 15417124 228.0 ns/op Benchmark_____PubSubTwoConns-16 15729302 227.1 ns/op Benchmark_____PubSubTwoConns-16 15514680 227.8 ns/op Benchmark_____PubSubTwoConns-16 15486909 228.9 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:37806->127.0.0.1:34469: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59908->127.0.0.1:44083: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43592->127.0.0.1:41931: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:39322->127.0.0.1:41667: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:52842->127.0.0.1:44357: 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 14230592 247.9 ns/op Benchmark_____PubTwoQueueSub-16 14333734 247.7 ns/op Benchmark_____PubTwoQueueSub-16 14440975 248.4 ns/op Benchmark_____PubTwoQueueSub-16 14414688 247.5 ns/op Benchmark_____PubTwoQueueSub-16 14272654 247.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14270634 247.2 ns/op Benchmark____PubFourQueueSub-16 14361292 247.3 ns/op Benchmark____PubFourQueueSub-16 14334561 248.2 ns/op Benchmark____PubFourQueueSub-16 14263136 248.6 ns/op Benchmark____PubFourQueueSub-16 14354767 247.4 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14409645 247.9 ns/op Benchmark___PubEightQueueSub-16 14381527 248.5 ns/op Benchmark___PubEightQueueSub-16 14278768 245.5 ns/op Benchmark___PubEightQueueSub-16 14453850 248.2 ns/op Benchmark___PubEightQueueSub-16 14246416 248.6 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23050 155908 ns/op Benchmark_PubSub512kTwoConns-16 23074 156283 ns/op Benchmark_PubSub512kTwoConns-16 23053 155895 ns/op Benchmark_PubSub512kTwoConns-16 22742 156069 ns/op Benchmark_PubSub512kTwoConns-16 22782 156764 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15092175 231.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 14976918 231.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15108531 232.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15123120 231.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15173486 231.1 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14869443 231.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15195282 232.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 14841769 231.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15188428 231.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15134368 231.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11205711 317.9 ns/op Benchmark____RoutedPubSub_0b-16 11105067 313.6 ns/op Benchmark____RoutedPubSub_0b-16 11135238 314.6 ns/op Benchmark____RoutedPubSub_0b-16 11230143 320.2 ns/op Benchmark____RoutedPubSub_0b-16 10766516 318.2 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6590912 1554 ns/op Benchmark____RoutedPubSub_1K-16 6697173 542.5 ns/op Benchmark____RoutedPubSub_1K-16 6618033 790.7 ns/op Benchmark____RoutedPubSub_1K-16 6490314 546.3 ns/op Benchmark____RoutedPubSub_1K-16 6752814 536.1 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 83908 42215 ns/op Benchmark__RoutedPubSub_100K-16 83230 41790 ns/op Benchmark__RoutedPubSub_100K-16 85524 42298 ns/op Benchmark__RoutedPubSub_100K-16 77589 46054 ns/op Benchmark__RoutedPubSub_100K-16 79237 44390 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11510946 321.4 ns/op Benchmark____Routed2QueueSub-16 9472754 328.3 ns/op Benchmark____Routed2QueueSub-16 9509451 322.8 ns/op Benchmark____Routed2QueueSub-16 9673881 317.0 ns/op Benchmark____Routed2QueueSub-16 9916826 315.7 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9610845 321.0 ns/op Benchmark____Routed4QueueSub-16 9634118 320.2 ns/op Benchmark____Routed4QueueSub-16 9756918 322.3 ns/op Benchmark____Routed4QueueSub-16 9484797 320.8 ns/op Benchmark____Routed4QueueSub-16 9368348 323.9 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9226447 332.9 ns/op Benchmark____Routed8QueueSub-16 11048679 326.1 ns/op Benchmark____Routed8QueueSub-16 10994782 327.2 ns/op Benchmark____Routed8QueueSub-16 9245104 332.3 ns/op Benchmark____Routed8QueueSub-16 9384920 334.6 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8923816 344.0 ns/op Benchmark___Routed16QueueSub-16 8964520 352.0 ns/op Benchmark___Routed16QueueSub-16 8825493 344.1 ns/op Benchmark___Routed16QueueSub-16 8904399 349.3 ns/op Benchmark___Routed16QueueSub-16 8915212 352.6 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6545548 550.5 ns/op Benchmark____________RouteCompressOff-16 6491383 549.2 ns/op Benchmark____________RouteCompressOff-16 6437602 546.4 ns/op Benchmark____________RouteCompressOff-16 6104311 547.7 ns/op Benchmark____________RouteCompressOff-16 6545702 554.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6409624 548.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6485811 549.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6362523 551.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6460550 546.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6361077 549.2 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6378258 558.5 ns/op Benchmark_________RouteCompressS2Fast-16 6489754 552.2 ns/op Benchmark_________RouteCompressS2Fast-16 6539875 544.8 ns/op Benchmark_________RouteCompressS2Fast-16 6495199 555.3 ns/op Benchmark_________RouteCompressS2Fast-16 6467073 547.1 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6328064 549.7 ns/op Benchmark_______RouteCompressS2Better-16 6505256 550.5 ns/op Benchmark_______RouteCompressS2Better-16 6377404 551.5 ns/op Benchmark_______RouteCompressS2Better-16 6308570 560.8 ns/op Benchmark_______RouteCompressS2Better-16 6600444 545.7 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6427376 559.0 ns/op Benchmark_________RouteCompressS2Best-16 6489621 554.3 ns/op Benchmark_________RouteCompressS2Best-16 6376400 553.2 ns/op Benchmark_________RouteCompressS2Best-16 6462454 552.8 ns/op Benchmark_________RouteCompressS2Best-16 6411115 548.3 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4643644 776.3 ns/op 320.74 MB/s Benchmark______FanOut_8x1x10-16 4683027 769.0 ns/op 323.81 MB/s Benchmark______FanOut_8x1x10-16 4581676 769.6 ns/op 323.54 MB/s Benchmark______FanOut_8x1x10-16 4660185 768.7 ns/op 323.94 MB/s Benchmark______FanOut_8x1x10-16 4655386 768.8 ns/op 323.89 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 534356 6173 ns/op 375.65 MB/s Benchmark_____FanOut_8x1x100-16 525205 6229 ns/op 372.29 MB/s Benchmark_____FanOut_8x1x100-16 553239 6120 ns/op 378.93 MB/s Benchmark_____FanOut_8x1x100-16 544976 6144 ns/op 377.42 MB/s Benchmark_____FanOut_8x1x100-16 537206 6139 ns/op 377.78 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47192 76699 ns/op 300.12 MB/s Benchmark____FanOut_8x10x100-16 46657 76328 ns/op 301.58 MB/s Benchmark____FanOut_8x10x100-16 46995 76362 ns/op 301.45 MB/s Benchmark____FanOut_8x10x100-16 46651 76365 ns/op 301.43 MB/s Benchmark____FanOut_8x10x100-16 46930 76454 ns/op 301.08 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5695 630634 ns/op 380.60 MB/s Benchmark___FanOut_8x10x1000-16 5547 622200 ns/op 385.76 MB/s Benchmark___FanOut_8x10x1000-16 5674 625374 ns/op 383.80 MB/s Benchmark___FanOut_8x10x1000-16 5648 628375 ns/op 381.97 MB/s Benchmark___FanOut_8x10x1000-16 5583 626739 ns/op 382.96 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4879 729361 ns/op 315.37 MB/s Benchmark___FanOut_8x100x100-16 4898 728766 ns/op 315.63 MB/s Benchmark___FanOut_8x100x100-16 4875 729091 ns/op 315.49 MB/s Benchmark___FanOut_8x100x100-16 4863 737273 ns/op 311.99 MB/s Benchmark___FanOut_8x100x100-16 4854 729378 ns/op 315.36 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 542 6472546 ns/op 370.80 MB/s Benchmark__FanOut_8x100x1000-16 553 6489501 ns/op 369.83 MB/s Benchmark__FanOut_8x100x1000-16 548 6593934 ns/op 363.97 MB/s Benchmark__FanOut_8x100x1000-16 540 6547863 ns/op 366.53 MB/s Benchmark__FanOut_8x100x1000-16 547 6511216 ns/op 368.60 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 516 6881822 ns/op 363.28 MB/s Benchmark__FanOut_8x10x10000-16 519 6899535 ns/op 362.35 MB/s Benchmark__FanOut_8x10x10000-16 524 6925680 ns/op 360.98 MB/s Benchmark__FanOut_8x10x10000-16 508 6993273 ns/op 357.49 MB/s Benchmark__FanOut_8x10x10000-16 500 7054285 ns/op 354.40 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 919 3863084 ns/op 297.69 MB/s Benchmark___FanOut_8x500x100-16 914 3852122 ns/op 298.54 MB/s Benchmark___FanOut_8x500x100-16 927 3865304 ns/op 297.52 MB/s Benchmark___FanOut_8x500x100-16 918 3854043 ns/op 298.39 MB/s Benchmark___FanOut_8x500x100-16 918 3860877 ns/op 297.86 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 363993 9531 ns/op 1536.10 MB/s Benchmark___FanOut_128x1x100-16 345324 9561 ns/op 1531.40 MB/s Benchmark___FanOut_128x1x100-16 350779 9584 ns/op 1527.65 MB/s Benchmark___FanOut_128x1x100-16 361078 9592 ns/op 1526.45 MB/s Benchmark___FanOut_128x1x100-16 371973 9565 ns/op 1530.67 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32250 111990 ns/op 1296.02 MB/s Benchmark__FanOut_128x10x100-16 31863 112844 ns/op 1286.21 MB/s Benchmark__FanOut_128x10x100-16 32120 111962 ns/op 1296.34 MB/s Benchmark__FanOut_128x10x100-16 32082 111974 ns/op 1296.20 MB/s Benchmark__FanOut_128x10x100-16 31960 112796 ns/op 1286.76 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3969 901924 ns/op 1618.92 MB/s Benchmark_FanOut_128x10x1000-16 3945 911833 ns/op 1601.33 MB/s Benchmark_FanOut_128x10x1000-16 3972 899118 ns/op 1623.97 MB/s Benchmark_FanOut_128x10x1000-16 3994 911289 ns/op 1602.28 MB/s Benchmark_FanOut_128x10x1000-16 3730 899141 ns/op 1623.93 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3392 1034425 ns/op 1401.88 MB/s Benchmark_FanOut_128x100x100-16 3421 1029383 ns/op 1408.75 MB/s Benchmark_FanOut_128x100x100-16 3409 1027955 ns/op 1410.70 MB/s Benchmark_FanOut_128x100x100-16 3394 1034999 ns/op 1401.10 MB/s Benchmark_FanOut_128x100x100-16 3414 1028151 ns/op 1410.44 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 372 9487492 ns/op 1538.88 MB/s BenchmarkFanOut_128x100x1000-16 373 9529309 ns/op 1532.13 MB/s BenchmarkFanOut_128x100x1000-16 374 9560394 ns/op 1527.15 MB/s BenchmarkFanOut_128x100x1000-16 375 9666550 ns/op 1510.38 MB/s BenchmarkFanOut_128x100x1000-16 376 9515366 ns/op 1534.38 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 367 9856442 ns/op 1491.42 MB/s BenchmarkFanOut_128x10x10000-16 362 9822800 ns/op 1496.53 MB/s BenchmarkFanOut_128x10x10000-16 367 9867813 ns/op 1489.71 MB/s BenchmarkFanOut_128x10x10000-16 368 9786014 ns/op 1502.16 MB/s BenchmarkFanOut_128x10x10000-16 368 9829471 ns/op 1495.52 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 664 5355441 ns/op 1353.79 MB/s BenchmarkFanOut__128x500x100-16 664 5349315 ns/op 1355.34 MB/s BenchmarkFanOut__128x500x100-16 657 5336914 ns/op 1358.49 MB/s BenchmarkFanOut__128x500x100-16 674 5360386 ns/op 1352.54 MB/s BenchmarkFanOut__128x500x100-16 667 5355758 ns/op 1353.71 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1899 1862215 ns/op 2840.98 MB/s Benchmark_FanOut_512x100x100-16 1923 1859946 ns/op 2844.45 MB/s Benchmark_FanOut_512x100x100-16 1923 1867442 ns/op 2833.03 MB/s Benchmark_FanOut_512x100x100-16 1942 1862915 ns/op 2839.92 MB/s Benchmark_FanOut_512x100x100-16 1898 1874016 ns/op 2823.09 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 16918641 ns/op 3132.67 MB/s Benchmark__FanOut_512x100x1k-16 213 17157999 ns/op 3088.97 MB/s Benchmark__FanOut_512x100x1k-16 213 16986052 ns/op 3120.24 MB/s Benchmark__FanOut_512x100x1k-16 210 17049830 ns/op 3108.57 MB/s Benchmark__FanOut_512x100x1k-16 211 17059171 ns/op 3106.86 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3154 1162215 ns/op 8975.13 MB/s Benchmark____FanOut_1kx10x1k-16 2914 1177868 ns/op 8855.87 MB/s Benchmark____FanOut_1kx10x1k-16 2796 1154135 ns/op 9037.97 MB/s Benchmark____FanOut_1kx10x1k-16 3076 1160859 ns/op 8985.62 MB/s Benchmark____FanOut_1kx10x1k-16 3246 1180307 ns/op 8837.56 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2716 1277831 ns/op 8155.25 MB/s Benchmark__FanOut_1kx100x100-16 2751 1267910 ns/op 8219.07 MB/s Benchmark__FanOut_1kx100x100-16 2782 1277221 ns/op 8159.15 MB/s Benchmark__FanOut_1kx100x100-16 2731 1274512 ns/op 8176.49 MB/s Benchmark__FanOut_1kx100x100-16 2700 1268785 ns/op 8213.40 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4503944 796.9 ns/op 312.48 MB/s Benchmark_____RFanOut_8x1x10-16 4480814 782.3 ns/op 318.30 MB/s Benchmark_____RFanOut_8x1x10-16 4474363 785.9 ns/op 316.85 MB/s Benchmark_____RFanOut_8x1x10-16 4376559 784.5 ns/op 317.40 MB/s Benchmark_____RFanOut_8x1x10-16 4461550 784.7 ns/op 317.31 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 557088 6286 ns/op 368.92 MB/s Benchmark____RFanOut_8x1x100-16 545904 6223 ns/op 372.67 MB/s Benchmark____RFanOut_8x1x100-16 532578 6208 ns/op 373.57 MB/s Benchmark____RFanOut_8x1x100-16 508958 6241 ns/op 371.56 MB/s Benchmark____RFanOut_8x1x100-16 554450 6215 ns/op 373.13 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46243 76892 ns/op 299.37 MB/s Benchmark___RFanOut_8x10x100-16 47352 76577 ns/op 300.60 MB/s Benchmark___RFanOut_8x10x100-16 47179 76846 ns/op 299.55 MB/s Benchmark___RFanOut_8x10x100-16 46782 76371 ns/op 301.41 MB/s Benchmark___RFanOut_8x10x100-16 46749 77671 ns/op 296.36 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5512 632344 ns/op 379.57 MB/s Benchmark__RFanOut_8x10x1000-16 5528 637469 ns/op 376.52 MB/s Benchmark__RFanOut_8x10x1000-16 5535 623632 ns/op 384.87 MB/s Benchmark__RFanOut_8x10x1000-16 5592 626467 ns/op 383.13 MB/s Benchmark__RFanOut_8x10x1000-16 5605 630859 ns/op 380.46 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4849 723378 ns/op 317.98 MB/s Benchmark__RFanOut_8x100x100-16 4812 723750 ns/op 317.82 MB/s Benchmark__RFanOut_8x100x100-16 4819 726239 ns/op 316.73 MB/s Benchmark__RFanOut_8x100x100-16 4801 724021 ns/op 317.70 MB/s Benchmark__RFanOut_8x100x100-16 4830 724623 ns/op 317.43 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 555 6554030 ns/op 366.19 MB/s Benchmark_RFanOut_8x100x1000-16 543 6579100 ns/op 364.79 MB/s Benchmark_RFanOut_8x100x1000-16 552 6549240 ns/op 366.46 MB/s Benchmark_RFanOut_8x100x1000-16 556 6480761 ns/op 370.33 MB/s Benchmark_RFanOut_8x100x1000-16 548 6647696 ns/op 361.03 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 508 7000349 ns/op 357.13 MB/s Benchmark_RFanOut_8x10x10000-16 501 7057594 ns/op 354.23 MB/s Benchmark_RFanOut_8x10x10000-16 508 6882078 ns/op 363.27 MB/s Benchmark_RFanOut_8x10x10000-16 516 7013997 ns/op 356.43 MB/s Benchmark_RFanOut_8x10x10000-16 518 6923712 ns/op 361.08 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3180 1162146 ns/op 8975.67 MB/s Benchmark_RFanOut_1kx10x1000-16 2901 1167273 ns/op 8936.25 MB/s Benchmark_RFanOut_1kx10x1000-16 2836 1165103 ns/op 8952.89 MB/s Benchmark_RFanOut_1kx10x1000-16 3031 1177913 ns/op 8855.52 MB/s Benchmark_RFanOut_1kx10x1000-16 2964 1151524 ns/op 9058.46 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6918690 508.3 ns/op 4088.23 MB/s Benchmark_____FanIn_1kx100x1-16 6903708 507.7 ns/op 4092.76 MB/s Benchmark_____FanIn_1kx100x1-16 7021730 506.7 ns/op 4101.19 MB/s Benchmark_____FanIn_1kx100x1-16 6942264 508.0 ns/op 4090.68 MB/s Benchmark_____FanIn_1kx100x1-16 6921970 506.5 ns/op 4102.56 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2613362 1369 ns/op 6005.99 MB/s Benchmark_____FanIn_4kx100x1-16 2628436 1381 ns/op 5952.63 MB/s Benchmark_____FanIn_4kx100x1-16 2635807 1365 ns/op 6025.36 MB/s Benchmark_____FanIn_4kx100x1-16 2632719 1364 ns/op 6027.41 MB/s Benchmark_____FanIn_4kx100x1-16 2638329 1363 ns/op 6031.09 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1698583 2107 ns/op 7789.44 MB/s Benchmark_____FanIn_8kx100x1-16 1717111 2146 ns/op 7648.79 MB/s Benchmark_____FanIn_8kx100x1-16 1705138 2124 ns/op 7728.37 MB/s Benchmark_____FanIn_8kx100x1-16 1696915 2100 ns/op 7817.39 MB/s Benchmark_____FanIn_8kx100x1-16 1703864 2134 ns/op 7691.68 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 859996 4902 ns/op 6691.23 MB/s Benchmark____FanIn_16kx100x1-16 861580 4143 ns/op 7917.37 MB/s Benchmark____FanIn_16kx100x1-16 859899 4217 ns/op 7778.24 MB/s Benchmark____FanIn_16kx100x1-16 850048 4140 ns/op 7923.60 MB/s Benchmark____FanIn_16kx100x1-16 860359 4150 ns/op 7904.46 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 167914 20099 ns/op 6522.78 MB/s Benchmark____FanIn_64kx100x1-16 170890 19952 ns/op 6571.13 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1702214751 vs 11196452400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37602->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37130->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 169578 19780 ns/op 6628.22 MB/s Benchmark____FanIn_64kx100x1-16 168238 19864 ns/op 6600.11 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1061435730 vs 11549029000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38232->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38130->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 571421310 vs 1310900000 bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:39886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:39690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:39922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:40084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:39666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:40052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:39580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:39820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39526->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: 706837280 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:41862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42062->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: 105789630 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:43072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:43124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:43160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:43654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:43774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:43570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:43772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43782->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: 407952080 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44858->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44746->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45510->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5441948 650.9 ns/op 436.32 MB/s Benchmark___BumpPubCount_1x3-16 5543073 646.9 ns/op 439.03 MB/s Benchmark___BumpPubCount_1x3-16 5540890 645.8 ns/op 439.74 MB/s Benchmark___BumpPubCount_1x3-16 5555559 642.9 ns/op 441.74 MB/s Benchmark___BumpPubCount_1x3-16 5466854 653.6 ns/op 434.51 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5243937 672.9 ns/op 422.07 MB/s Benchmark___BumpPubCount_2x3-16 5190430 682.8 ns/op 415.96 MB/s Benchmark___BumpPubCount_2x3-16 5229708 685.4 ns/op 414.37 MB/s Benchmark___BumpPubCount_2x3-16 5270330 683.7 ns/op 415.39 MB/s Benchmark___BumpPubCount_2x3-16 5224788 682.0 ns/op 416.40 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5493862 655.8 ns/op 433.04 MB/s Benchmark___BumpPubCount_5x3-16 5504940 649.4 ns/op 437.33 MB/s Benchmark___BumpPubCount_5x3-16 5466606 647.4 ns/op 438.65 MB/s Benchmark___BumpPubCount_5x3-16 5507232 650.3 ns/op 436.69 MB/s Benchmark___BumpPubCount_5x3-16 5517198 651.1 ns/op 436.19 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5520679 650.5 ns/op 436.57 MB/s Benchmark__BumpPubCount_10x3-16 5495680 650.7 ns/op 436.48 MB/s Benchmark__BumpPubCount_10x3-16 5515724 654.0 ns/op 434.24 MB/s Benchmark__BumpPubCount_10x3-16 5486814 652.5 ns/op 435.27 MB/s Benchmark__BumpPubCount_10x3-16 5508733 650.7 ns/op 436.45 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12317739 286.5 ns/op 3630.22 MB/s Benchmark____GWs_Opt_1kx01x0-16 11802325 274.4 ns/op 3790.30 MB/s Benchmark____GWs_Opt_1kx01x0-16 12384566 278.2 ns/op 3738.72 MB/s Benchmark____GWs_Opt_1kx01x0-16 12239656 277.8 ns/op 3743.64 MB/s Benchmark____GWs_Opt_1kx01x0-16 12162682 281.6 ns/op 3692.85 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10642363 351.7 ns/op 5867.84 MB/s Benchmark____GWs_Opt_2kx01x0-16 9025952 340.3 ns/op 6065.54 MB/s Benchmark____GWs_Opt_2kx01x0-16 10186912 338.5 ns/op 6097.50 MB/s Benchmark____GWs_Opt_2kx01x0-16 10206170 339.4 ns/op 6081.40 MB/s Benchmark____GWs_Opt_2kx01x0-16 9172320 351.6 ns/op 5870.22 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5311740 661.5 ns/op 6216.60 MB/s Benchmark____GWs_Opt_4kx01x0-16 5239878 661.6 ns/op 6215.61 MB/s Benchmark____GWs_Opt_4kx01x0-16 5238624 660.3 ns/op 6227.51 MB/s Benchmark____GWs_Opt_4kx01x0-16 5346594 653.3 ns/op 6294.44 MB/s Benchmark____GWs_Opt_4kx01x0-16 5130790 712.4 ns/op 5772.09 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30105351 110.8 ns/op 9386.57 MB/s Benchmark____GWs_Opt_1kx10x0-16 29814270 110.4 ns/op 9421.40 MB/s Benchmark____GWs_Opt_1kx10x0-16 32103332 110.2 ns/op 9437.92 MB/s Benchmark____GWs_Opt_1kx10x0-16 33293844 111.4 ns/op 9335.12 MB/s Benchmark____GWs_Opt_1kx10x0-16 33362491 113.1 ns/op 9195.66 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25841558 146.2 ns/op 14119.98 MB/s Benchmark____GWs_Opt_2kx10x0-16 21928994 149.0 ns/op 13850.38 MB/s Benchmark____GWs_Opt_2kx10x0-16 25686268 164.1 ns/op 12578.18 MB/s Benchmark____GWs_Opt_2kx10x0-16 21292282 141.5 ns/op 14588.59 MB/s Benchmark____GWs_Opt_2kx10x0-16 22600477 147.9 ns/op 13953.23 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 9246127 344.4 ns/op 11938.62 MB/s Benchmark____GWs_Opt_4kx10x0-16 12421086 283.9 ns/op 14484.98 MB/s Benchmark____GWs_Opt_4kx10x0-16 10611748 311.5 ns/op 13199.11 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:46386->127.0.0.1:37425: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 12371970 308.0 ns/op 13351.46 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6226986 552.3 ns/op 5658.34 MB/s Benchmark____GWs_Opt_1kx01x1-16 6509110 555.5 ns/op 5625.62 MB/s Benchmark____GWs_Opt_1kx01x1-16 6754064 554.6 ns/op 5634.19 MB/s Benchmark____GWs_Opt_1kx01x1-16 6301380 552.6 ns/op 5654.71 MB/s Benchmark____GWs_Opt_1kx01x1-16 6422656 556.5 ns/op 5615.66 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4574743 777.2 ns/op 7972.99 MB/s Benchmark____GWs_Opt_2kx01x1-16 4526186 768.2 ns/op 8067.00 MB/s Benchmark____GWs_Opt_2kx01x1-16 4574964 766.6 ns/op 8083.93 MB/s Benchmark____GWs_Opt_2kx01x1-16 4570148 767.6 ns/op 8073.55 MB/s Benchmark____GWs_Opt_2kx01x1-16 4651148 1025 ns/op 6047.49 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2496471 1392 ns/op 8867.38 MB/s Benchmark____GWs_Opt_4kx01x1-16 2600210 1383 ns/op 8922.16 MB/s Benchmark____GWs_Opt_4kx01x1-16 2608982 1405 ns/op 8785.00 MB/s Benchmark____GWs_Opt_4kx01x1-16 2599117 1379 ns/op 8946.98 MB/s Benchmark____GWs_Opt_4kx01x1-16 2646591 1387 ns/op 8898.77 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6535989 560.8 ns/op 5572.26 MB/s Benchmark____GWs_Opt_1kx10x1-16 6458193 565.9 ns/op 5522.19 MB/s Benchmark____GWs_Opt_1kx10x1-16 6557138 558.3 ns/op 5597.34 MB/s Benchmark____GWs_Opt_1kx10x1-16 6142402 556.4 ns/op 5616.18 MB/s Benchmark____GWs_Opt_1kx10x1-16 6210384 561.6 ns/op 5564.39 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4237413 849.1 ns/op 7298.05 MB/s Benchmark____GWs_Opt_2kx10x1-16 4107928 862.4 ns/op 7185.90 MB/s Benchmark____GWs_Opt_2kx10x1-16 4120425 852.1 ns/op 7272.28 MB/s Benchmark____GWs_Opt_2kx10x1-16 4201959 854.5 ns/op 7252.48 MB/s Benchmark____GWs_Opt_2kx10x1-16 4135333 850.7 ns/op 7284.43 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2406301 1545 ns/op 7988.01 MB/s Benchmark____GWs_Opt_4kx10x1-16 2385890 1588 ns/op 7769.77 MB/s Benchmark____GWs_Opt_4kx10x1-16 2299862 1521 ns/op 8114.47 MB/s Benchmark____GWs_Opt_4kx10x1-16 2382956 1535 ns/op 8040.96 MB/s Benchmark____GWs_Opt_4kx10x1-16 2345749 1515 ns/op 8145.84 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11040192 294.1 ns/op 3535.85 MB/s Benchmark____GWs_Int_1kx01x0-16 12561326 290.0 ns/op 3586.53 MB/s Benchmark____GWs_Int_1kx01x0-16 12161072 285.8 ns/op 3639.53 MB/s Benchmark____GWs_Int_1kx01x0-16 11941279 288.8 ns/op 3601.51 MB/s Benchmark____GWs_Int_1kx01x0-16 12220029 283.0 ns/op 3674.32 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10088804 345.1 ns/op 5981.01 MB/s Benchmark____GWs_Int_2kx01x0-16 10424140 355.5 ns/op 5806.48 MB/s Benchmark____GWs_Int_2kx01x0-16 10153178 365.6 ns/op 5645.24 MB/s Benchmark____GWs_Int_2kx01x0-16 10255555 348.5 ns/op 5922.17 MB/s Benchmark____GWs_Int_2kx01x0-16 8999947 353.3 ns/op 5842.25 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5287227 706.4 ns/op 5820.74 MB/s Benchmark____GWs_Int_4kx01x0-16 5569626 677.3 ns/op 6071.13 MB/s Benchmark____GWs_Int_4kx01x0-16 5598414 676.3 ns/op 6080.02 MB/s Benchmark____GWs_Int_4kx01x0-16 5399215 698.0 ns/op 5891.05 MB/s Benchmark____GWs_Int_4kx01x0-16 5478628 677.8 ns/op 6066.61 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32563932 110.2 ns/op 9437.31 MB/s Benchmark____GWs_Int_1kx10x0-16 31344478 118.4 ns/op 8781.92 MB/s Benchmark____GWs_Int_1kx10x0-16 31477077 114.0 ns/op 9121.48 MB/s Benchmark____GWs_Int_1kx10x0-16 31003857 111.0 ns/op 9370.89 MB/s Benchmark____GWs_Int_1kx10x0-16 33188715 114.2 ns/op 9105.62 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 22858274 154.4 ns/op 13367.79 MB/s Benchmark____GWs_Int_2kx10x0-16 25909704 147.6 ns/op 13980.76 MB/s Benchmark____GWs_Int_2kx10x0-16 26264971 150.1 ns/op 13752.45 MB/s Benchmark____GWs_Int_2kx10x0-16 25746486 160.1 ns/op 12892.04 MB/s Benchmark____GWs_Int_2kx10x0-16 25083510 145.2 ns/op 14211.73 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13136340 300.8 ns/op 13669.43 MB/s Benchmark____GWs_Int_4kx10x0-16 11200846 284.0 ns/op 14478.96 MB/s Benchmark____GWs_Int_4kx10x0-16 13025058 297.6 ns/op 13815.41 MB/s Benchmark____GWs_Int_4kx10x0-16 13219033 304.3 ns/op 13513.60 MB/s Benchmark____GWs_Int_4kx10x0-16 12584600 283.7 ns/op 14493.82 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6356772 559.8 ns/op 5582.36 MB/s Benchmark____GWs_Int_1kx01x1-16 6435339 558.8 ns/op 5591.96 MB/s Benchmark____GWs_Int_1kx01x1-16 6414080 571.0 ns/op 5473.21 MB/s Benchmark____GWs_Int_1kx01x1-16 6446282 554.8 ns/op 5632.25 MB/s Benchmark____GWs_Int_1kx01x1-16 6343146 559.2 ns/op 5588.35 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4640623 771.3 ns/op 8034.86 MB/s Benchmark____GWs_Int_2kx01x1-16 4583974 767.7 ns/op 8072.05 MB/s Benchmark____GWs_Int_2kx01x1-16 4582386 763.4 ns/op 8117.12 MB/s Benchmark____GWs_Int_2kx01x1-16 4620403 762.1 ns/op 8131.95 MB/s Benchmark____GWs_Int_2kx01x1-16 4620344 779.2 ns/op 7952.91 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2537574 1396 ns/op 8841.53 MB/s Benchmark____GWs_Int_4kx01x1-16 2640208 1410 ns/op 8755.52 MB/s Benchmark____GWs_Int_4kx01x1-16 2615910 1390 ns/op 8876.34 MB/s Benchmark____GWs_Int_4kx01x1-16 2621606 1397 ns/op 8833.96 MB/s Benchmark____GWs_Int_4kx01x1-16 2613048 1399 ns/op 8823.40 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6539509 564.7 ns/op 5534.39 MB/s Benchmark____GWs_Int_1kx10x1-16 6264237 563.1 ns/op 5550.07 MB/s Benchmark____GWs_Int_1kx10x1-16 6418149 556.9 ns/op 5611.57 MB/s Benchmark____GWs_Int_1kx10x1-16 6306556 569.3 ns/op 5489.05 MB/s Benchmark____GWs_Int_1kx10x1-16 5959180 558.9 ns/op 5591.33 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 3853220 849.7 ns/op 7292.83 MB/s Benchmark____GWs_Int_2kx10x1-16 4152121 879.2 ns/op 7048.19 MB/s Benchmark____GWs_Int_2kx10x1-16 4238691 859.4 ns/op 7210.79 MB/s Benchmark____GWs_Int_2kx10x1-16 4162179 850.6 ns/op 7285.75 MB/s Benchmark____GWs_Int_2kx10x1-16 4125494 850.8 ns/op 7283.46 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2279612 1718 ns/op 7185.18 MB/s Benchmark____GWs_Int_4kx10x1-16 2360448 1524 ns/op 8099.72 MB/s Benchmark____GWs_Int_4kx10x1-16 2105250 1527 ns/op 8081.76 MB/s Benchmark____GWs_Int_4kx10x1-16 2327781 1570 ns/op 7861.17 MB/s Benchmark____GWs_Int_4kx10x1-16 2324654 1652 ns/op 7470.86 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8149311 442.9 ns/op 230.29 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8008909 437.0 ns/op 233.39 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8081646 434.9 ns/op 234.54 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8055160 437.2 ns/op 233.29 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8035497 436.7 ns/op 233.57 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 606690 5060 ns/op 34.98 MB/s Benchmark__GWs_Reqs_1SubEach-16 783363 5233 ns/op 33.82 MB/s Benchmark__GWs_Reqs_1SubEach-16 756454 5244 ns/op 33.75 MB/s Benchmark__GWs_Reqs_1SubEach-16 762916 5358 ns/op 33.04 MB/s Benchmark__GWs_Reqs_1SubEach-16 753350 5237 ns/op 33.80 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2073.612s ❌ Non-zero exit code: 1