> ROOT_DIR=/tmp/go-bench-away-job-0fa75623-8902-48ff-bdb9-c74aad7ccf92-1739384898 > OUTPUT_FILE=/tmp/go-bench-away-job-0fa75623-8902-48ff-bdb9-c74aad7ccf92-1739384898/results.txt > SHA_FILE=/tmp/go-bench-away-job-0fa75623-8902-48ff-bdb9-c74aad7ccf92-1739384898/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-0fa75623-8902-48ff-bdb9-c74aad7ccf92-1739384898/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-0fa75623-8902-48ff-bdb9-c74aad7ccf92-1739384898/source.git SHA of main: ccd898ea86accf40861f1dd651df8e7fb9c0e5f3 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-build759016235=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-0fa75623-8902-48ff-bdb9-c74aad7ccf92-1739384898/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 48366698 74.02 ns/op 148.60 MB/s Benchmark______Pub0b_Payload-16 46402555 73.78 ns/op 149.10 MB/s Benchmark______Pub0b_Payload-16 46538833 73.84 ns/op 148.97 MB/s Benchmark______Pub0b_Payload-16 46308447 73.77 ns/op 149.12 MB/s Benchmark______Pub0b_Payload-16 46381122 73.90 ns/op 148.85 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45726193 74.46 ns/op 255.17 MB/s Benchmark______Pub8b_Payload-16 48265660 74.41 ns/op 255.33 MB/s Benchmark______Pub8b_Payload-16 45611089 74.47 ns/op 255.14 MB/s Benchmark______Pub8b_Payload-16 45367704 78.44 ns/op 242.22 MB/s Benchmark______Pub8b_Payload-16 45794026 74.71 ns/op 254.32 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 42668874 78.41 ns/op 561.16 MB/s Benchmark_____Pub32b_Payload-16 43508168 78.30 ns/op 561.93 MB/s Benchmark_____Pub32b_Payload-16 43487985 78.96 ns/op 557.23 MB/s Benchmark_____Pub32b_Payload-16 45463963 78.08 ns/op 563.55 MB/s Benchmark_____Pub32b_Payload-16 43291392 78.67 ns/op 559.30 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39072410 88.44 ns/op 1594.39 MB/s Benchmark____Pub128B_Payload-16 38774559 89.26 ns/op 1579.73 MB/s Benchmark____Pub128B_Payload-16 39372250 89.84 ns/op 1569.41 MB/s Benchmark____Pub128B_Payload-16 40941061 88.77 ns/op 1588.33 MB/s Benchmark____Pub128B_Payload-16 39021748 92.06 ns/op 1531.63 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36021598 103.9 ns/op 2588.27 MB/s Benchmark____Pub256B_Payload-16 34519405 98.63 ns/op 2727.40 MB/s Benchmark____Pub256B_Payload-16 31588818 103.8 ns/op 2591.84 MB/s Benchmark____Pub256B_Payload-16 31716436 96.70 ns/op 2781.87 MB/s Benchmark____Pub256B_Payload-16 33368700 95.06 ns/op 2829.92 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24027337 136.2 ns/op 7622.42 MB/s Benchmark______Pub1K_Payload-16 25446313 144.3 ns/op 7194.84 MB/s Benchmark______Pub1K_Payload-16 23801722 139.9 ns/op 7418.24 MB/s Benchmark______Pub1K_Payload-16 25006972 142.6 ns/op 7277.29 MB/s Benchmark______Pub1K_Payload-16 22854466 145.4 ns/op 7136.78 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5598030 658.0 ns/op 6246.34 MB/s Benchmark______Pub4K_Payload-16 5692017 622.7 ns/op 6599.93 MB/s Benchmark______Pub4K_Payload-16 5563696 614.8 ns/op 6684.80 MB/s Benchmark______Pub4K_Payload-16 5595010 625.1 ns/op 6575.07 MB/s Benchmark______Pub4K_Payload-16 5466694 616.7 ns/op 6664.80 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2804960 1277 ns/op 6427.15 MB/s Benchmark______Pub8K_Payload-16 2801082 1275 ns/op 6434.87 MB/s Benchmark______Pub8K_Payload-16 2724108 1275 ns/op 6435.46 MB/s Benchmark______Pub8K_Payload-16 2762596 1273 ns/op 6448.14 MB/s Benchmark______Pub8K_Payload-16 2800824 1296 ns/op 6330.96 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 558874 5450 ns/op 6014.73 MB/s Benchmark_____Pub32K_Payload-16 667470 5383 ns/op 6089.59 MB/s Benchmark_____Pub32K_Payload-16 669734 5493 ns/op 5968.32 MB/s Benchmark_____Pub32K_Payload-16 587971 5549 ns/op 5907.58 MB/s Benchmark_____Pub32K_Payload-16 652680 5548 ns/op 5908.53 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31771122 97.03 ns/op 113.37 MB/s Benchmark__AuthPub0b_Payload-16 35820202 97.80 ns/op 112.48 MB/s Benchmark__AuthPub0b_Payload-16 31795496 95.38 ns/op 115.33 MB/s Benchmark__AuthPub0b_Payload-16 35811614 95.67 ns/op 114.98 MB/s Benchmark__AuthPub0b_Payload-16 35704275 98.43 ns/op 111.75 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15561643 227.3 ns/op Benchmark_____________PubSub-16 15279668 227.3 ns/op Benchmark_____________PubSub-16 15583292 227.6 ns/op Benchmark_____________PubSub-16 15321412 228.4 ns/op Benchmark_____________PubSub-16 15615099 227.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15689883 227.5 ns/op Benchmark_____PubSubTwoConns-16 15579939 226.5 ns/op Benchmark_____PubSubTwoConns-16 15619807 226.7 ns/op Benchmark_____PubSubTwoConns-16 15745130 226.7 ns/op Benchmark_____PubSubTwoConns-16 15317676 226.2 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:56390->127.0.0.1:39721: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57770->127.0.0.1:42487: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:53882->127.0.0.1:38201: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49476->127.0.0.1:41215: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:54472->127.0.0.1:44447: 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 14284060 247.9 ns/op Benchmark_____PubTwoQueueSub-16 14409601 247.0 ns/op Benchmark_____PubTwoQueueSub-16 14369082 247.4 ns/op Benchmark_____PubTwoQueueSub-16 14556595 247.4 ns/op Benchmark_____PubTwoQueueSub-16 14407802 247.6 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14495416 248.1 ns/op Benchmark____PubFourQueueSub-16 14333894 247.9 ns/op Benchmark____PubFourQueueSub-16 14201656 247.4 ns/op Benchmark____PubFourQueueSub-16 14452833 246.9 ns/op Benchmark____PubFourQueueSub-16 14369475 247.2 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14483906 247.8 ns/op Benchmark___PubEightQueueSub-16 14408360 247.5 ns/op Benchmark___PubEightQueueSub-16 14193090 247.6 ns/op Benchmark___PubEightQueueSub-16 14390000 247.5 ns/op Benchmark___PubEightQueueSub-16 14243667 247.6 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22816 155478 ns/op Benchmark_PubSub512kTwoConns-16 23078 159212 ns/op Benchmark_PubSub512kTwoConns-16 22820 155515 ns/op Benchmark_PubSub512kTwoConns-16 22858 156217 ns/op Benchmark_PubSub512kTwoConns-16 23236 157036 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15033870 229.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15280711 229.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15234876 230.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15187768 231.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15080793 231.0 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15341202 229.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15145486 228.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15105966 230.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15080386 229.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15032421 230.7 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10945806 323.2 ns/op Benchmark____RoutedPubSub_0b-16 10643652 320.8 ns/op Benchmark____RoutedPubSub_0b-16 10737720 322.7 ns/op Benchmark____RoutedPubSub_0b-16 10914760 323.1 ns/op Benchmark____RoutedPubSub_0b-16 11362650 324.9 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6503973 547.2 ns/op Benchmark____RoutedPubSub_1K-16 6373900 545.9 ns/op Benchmark____RoutedPubSub_1K-16 6662805 543.8 ns/op Benchmark____RoutedPubSub_1K-16 6353047 545.9 ns/op Benchmark____RoutedPubSub_1K-16 6490330 537.7 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 83594 42509 ns/op Benchmark__RoutedPubSub_100K-16 80334 45151 ns/op Benchmark__RoutedPubSub_100K-16 79716 46623 ns/op Benchmark__RoutedPubSub_100K-16 77040 49174 ns/op Benchmark__RoutedPubSub_100K-16 75882 49362 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9555315 330.1 ns/op Benchmark____Routed2QueueSub-16 9349842 323.7 ns/op Benchmark____Routed2QueueSub-16 9566354 325.3 ns/op Benchmark____Routed2QueueSub-16 9630255 331.3 ns/op Benchmark____Routed2QueueSub-16 9340332 333.0 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9293596 330.6 ns/op Benchmark____Routed4QueueSub-16 9466447 326.5 ns/op Benchmark____Routed4QueueSub-16 9741429 326.6 ns/op Benchmark____Routed4QueueSub-16 9335666 327.9 ns/op Benchmark____Routed4QueueSub-16 9557488 331.1 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9129015 337.1 ns/op Benchmark____Routed8QueueSub-16 9088923 341.5 ns/op Benchmark____Routed8QueueSub-16 10691224 338.4 ns/op Benchmark____Routed8QueueSub-16 9142936 337.8 ns/op Benchmark____Routed8QueueSub-16 8952200 342.2 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8568342 352.7 ns/op Benchmark___Routed16QueueSub-16 8680123 362.2 ns/op Benchmark___Routed16QueueSub-16 8654696 354.3 ns/op Benchmark___Routed16QueueSub-16 8620083 354.2 ns/op Benchmark___Routed16QueueSub-16 8525028 352.9 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6305811 562.5 ns/op Benchmark____________RouteCompressOff-16 6270620 557.7 ns/op Benchmark____________RouteCompressOff-16 6231884 555.9 ns/op Benchmark____________RouteCompressOff-16 6370831 551.3 ns/op Benchmark____________RouteCompressOff-16 6387392 564.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6306897 564.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6376351 569.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6474452 564.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6317718 563.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6362954 559.0 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6457500 562.9 ns/op Benchmark_________RouteCompressS2Fast-16 6345534 559.5 ns/op Benchmark_________RouteCompressS2Fast-16 6207578 559.0 ns/op Benchmark_________RouteCompressS2Fast-16 6398601 554.9 ns/op Benchmark_________RouteCompressS2Fast-16 6431770 558.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6231415 551.5 ns/op Benchmark_______RouteCompressS2Better-16 6195753 555.3 ns/op Benchmark_______RouteCompressS2Better-16 6253884 551.2 ns/op Benchmark_______RouteCompressS2Better-16 6286260 554.3 ns/op Benchmark_______RouteCompressS2Better-16 6414895 557.3 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6355753 554.1 ns/op Benchmark_________RouteCompressS2Best-16 6338277 562.7 ns/op Benchmark_________RouteCompressS2Best-16 6282060 553.0 ns/op Benchmark_________RouteCompressS2Best-16 6360180 557.8 ns/op Benchmark_________RouteCompressS2Best-16 6204788 554.9 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4660620 770.0 ns/op 323.38 MB/s Benchmark______FanOut_8x1x10-16 4657862 771.1 ns/op 322.91 MB/s Benchmark______FanOut_8x1x10-16 4672825 769.7 ns/op 323.52 MB/s Benchmark______FanOut_8x1x10-16 4638453 769.5 ns/op 323.57 MB/s Benchmark______FanOut_8x1x10-16 4648593 767.8 ns/op 324.30 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 532602 6120 ns/op 378.90 MB/s Benchmark_____FanOut_8x1x100-16 551721 6217 ns/op 373.01 MB/s Benchmark_____FanOut_8x1x100-16 530312 6102 ns/op 380.03 MB/s Benchmark_____FanOut_8x1x100-16 551229 6092 ns/op 380.66 MB/s Benchmark_____FanOut_8x1x100-16 564781 6059 ns/op 382.75 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48055 74086 ns/op 310.71 MB/s Benchmark____FanOut_8x10x100-16 47786 74643 ns/op 308.39 MB/s Benchmark____FanOut_8x10x100-16 48373 74520 ns/op 308.90 MB/s Benchmark____FanOut_8x10x100-16 48060 74979 ns/op 307.01 MB/s Benchmark____FanOut_8x10x100-16 48105 74418 ns/op 309.32 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5701 600836 ns/op 399.47 MB/s Benchmark___FanOut_8x10x1000-16 5804 594175 ns/op 403.95 MB/s Benchmark___FanOut_8x10x1000-16 5932 590659 ns/op 406.36 MB/s Benchmark___FanOut_8x10x1000-16 6056 591774 ns/op 405.59 MB/s Benchmark___FanOut_8x10x1000-16 6052 592268 ns/op 405.25 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5032 705812 ns/op 325.89 MB/s Benchmark___FanOut_8x100x100-16 5116 705949 ns/op 325.83 MB/s Benchmark___FanOut_8x100x100-16 5006 709299 ns/op 324.29 MB/s Benchmark___FanOut_8x100x100-16 5055 704971 ns/op 326.28 MB/s Benchmark___FanOut_8x100x100-16 4976 706480 ns/op 325.58 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 584 6158502 ns/op 389.71 MB/s Benchmark__FanOut_8x100x1000-16 589 6142062 ns/op 390.75 MB/s Benchmark__FanOut_8x100x1000-16 585 6107888 ns/op 392.94 MB/s Benchmark__FanOut_8x100x1000-16 572 6088437 ns/op 394.19 MB/s Benchmark__FanOut_8x100x1000-16 583 6149936 ns/op 390.25 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 508 6787437 ns/op 368.33 MB/s Benchmark__FanOut_8x10x10000-16 528 6759368 ns/op 369.86 MB/s Benchmark__FanOut_8x10x10000-16 531 6685688 ns/op 373.94 MB/s Benchmark__FanOut_8x10x10000-16 537 6787220 ns/op 368.34 MB/s Benchmark__FanOut_8x10x10000-16 524 6714989 ns/op 372.30 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 937 3751860 ns/op 306.52 MB/s Benchmark___FanOut_8x500x100-16 964 3749802 ns/op 306.69 MB/s Benchmark___FanOut_8x500x100-16 957 3745953 ns/op 307.00 MB/s Benchmark___FanOut_8x500x100-16 946 3788597 ns/op 303.55 MB/s Benchmark___FanOut_8x500x100-16 960 3769645 ns/op 305.07 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 355809 9468 ns/op 1546.39 MB/s Benchmark___FanOut_128x1x100-16 366081 9451 ns/op 1549.15 MB/s Benchmark___FanOut_128x1x100-16 364234 9503 ns/op 1540.70 MB/s Benchmark___FanOut_128x1x100-16 359110 9526 ns/op 1536.98 MB/s Benchmark___FanOut_128x1x100-16 360904 9500 ns/op 1541.16 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32784 111422 ns/op 1302.62 MB/s Benchmark__FanOut_128x10x100-16 32510 110498 ns/op 1313.51 MB/s Benchmark__FanOut_128x10x100-16 32551 109823 ns/op 1321.59 MB/s Benchmark__FanOut_128x10x100-16 32816 109866 ns/op 1321.07 MB/s Benchmark__FanOut_128x10x100-16 32641 109756 ns/op 1322.39 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4107 869233 ns/op 1679.80 MB/s Benchmark_FanOut_128x10x1000-16 4017 867148 ns/op 1683.84 MB/s Benchmark_FanOut_128x10x1000-16 3890 868679 ns/op 1680.88 MB/s Benchmark_FanOut_128x10x1000-16 4210 861741 ns/op 1694.41 MB/s Benchmark_FanOut_128x10x1000-16 3788 874923 ns/op 1668.88 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3564 1008885 ns/op 1437.37 MB/s Benchmark_FanOut_128x100x100-16 3482 1010776 ns/op 1434.68 MB/s Benchmark_FanOut_128x100x100-16 3489 1006890 ns/op 1440.22 MB/s Benchmark_FanOut_128x100x100-16 3487 1009355 ns/op 1436.70 MB/s Benchmark_FanOut_128x100x100-16 3487 1011609 ns/op 1433.50 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 388 9275042 ns/op 1574.13 MB/s BenchmarkFanOut_128x100x1000-16 381 9158233 ns/op 1594.21 MB/s BenchmarkFanOut_128x100x1000-16 391 9275484 ns/op 1574.06 MB/s BenchmarkFanOut_128x100x1000-16 379 9300681 ns/op 1569.79 MB/s BenchmarkFanOut_128x100x1000-16 387 9234012 ns/op 1581.13 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 378 9602419 ns/op 1530.88 MB/s BenchmarkFanOut_128x10x10000-16 376 9652085 ns/op 1523.00 MB/s BenchmarkFanOut_128x10x10000-16 373 9617506 ns/op 1528.48 MB/s BenchmarkFanOut_128x10x10000-16 372 9671994 ns/op 1519.87 MB/s BenchmarkFanOut_128x10x10000-16 370 9648139 ns/op 1523.62 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 666 5315388 ns/op 1363.99 MB/s BenchmarkFanOut__128x500x100-16 663 5291560 ns/op 1370.13 MB/s BenchmarkFanOut__128x500x100-16 676 5273114 ns/op 1374.93 MB/s BenchmarkFanOut__128x500x100-16 674 5296827 ns/op 1368.77 MB/s BenchmarkFanOut__128x500x100-16 669 5254247 ns/op 1379.86 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1944 1832510 ns/op 2887.04 MB/s Benchmark_FanOut_512x100x100-16 1935 1854936 ns/op 2852.13 MB/s Benchmark_FanOut_512x100x100-16 1941 1837611 ns/op 2879.02 MB/s Benchmark_FanOut_512x100x100-16 1912 1835340 ns/op 2882.59 MB/s Benchmark_FanOut_512x100x100-16 1928 1834080 ns/op 2884.57 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 16776605 ns/op 3159.19 MB/s Benchmark__FanOut_512x100x1k-16 216 16551766 ns/op 3202.11 MB/s Benchmark__FanOut_512x100x1k-16 218 16531120 ns/op 3206.11 MB/s Benchmark__FanOut_512x100x1k-16 216 16638431 ns/op 3185.43 MB/s Benchmark__FanOut_512x100x1k-16 219 16677046 ns/op 3178.05 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3046 1170442 ns/op 8912.05 MB/s Benchmark____FanOut_1kx10x1k-16 3120 1154278 ns/op 9036.85 MB/s Benchmark____FanOut_1kx10x1k-16 3009 1144891 ns/op 9110.95 MB/s Benchmark____FanOut_1kx10x1k-16 3187 1173644 ns/op 8887.73 MB/s Benchmark____FanOut_1kx10x1k-16 3103 1139291 ns/op 9155.73 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2779 1258745 ns/op 8278.91 MB/s Benchmark__FanOut_1kx100x100-16 2797 1250650 ns/op 8332.50 MB/s Benchmark__FanOut_1kx100x100-16 2797 1257308 ns/op 8288.38 MB/s Benchmark__FanOut_1kx100x100-16 2844 1254507 ns/op 8306.88 MB/s Benchmark__FanOut_1kx100x100-16 2756 1272118 ns/op 8191.88 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4395442 765.8 ns/op 325.17 MB/s Benchmark_____RFanOut_8x1x10-16 4511805 764.4 ns/op 325.74 MB/s Benchmark_____RFanOut_8x1x10-16 4497798 783.2 ns/op 317.93 MB/s Benchmark_____RFanOut_8x1x10-16 4406599 771.6 ns/op 322.72 MB/s Benchmark_____RFanOut_8x1x10-16 4493857 781.6 ns/op 318.58 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 524934 6125 ns/op 378.62 MB/s Benchmark____RFanOut_8x1x100-16 520716 6002 ns/op 386.37 MB/s Benchmark____RFanOut_8x1x100-16 569193 6072 ns/op 381.89 MB/s Benchmark____RFanOut_8x1x100-16 539510 6165 ns/op 376.18 MB/s Benchmark____RFanOut_8x1x100-16 541789 6153 ns/op 376.92 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47956 73820 ns/op 311.83 MB/s Benchmark___RFanOut_8x10x100-16 48296 73857 ns/op 311.67 MB/s Benchmark___RFanOut_8x10x100-16 48518 73776 ns/op 312.01 MB/s Benchmark___RFanOut_8x10x100-16 48824 73666 ns/op 312.48 MB/s Benchmark___RFanOut_8x10x100-16 48715 73967 ns/op 311.20 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5848 588016 ns/op 408.18 MB/s Benchmark__RFanOut_8x10x1000-16 6129 599938 ns/op 400.07 MB/s Benchmark__RFanOut_8x10x1000-16 6034 587306 ns/op 408.68 MB/s Benchmark__RFanOut_8x10x1000-16 6129 593075 ns/op 404.70 MB/s Benchmark__RFanOut_8x10x1000-16 6032 588842 ns/op 407.61 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4965 699575 ns/op 328.80 MB/s Benchmark__RFanOut_8x100x100-16 5004 703305 ns/op 327.05 MB/s Benchmark__RFanOut_8x100x100-16 5002 699571 ns/op 328.80 MB/s Benchmark__RFanOut_8x100x100-16 4996 705035 ns/op 326.25 MB/s Benchmark__RFanOut_8x100x100-16 5053 699738 ns/op 328.72 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 592 6028624 ns/op 398.10 MB/s Benchmark_RFanOut_8x100x1000-16 591 6024670 ns/op 398.37 MB/s Benchmark_RFanOut_8x100x1000-16 590 5993018 ns/op 400.47 MB/s Benchmark_RFanOut_8x100x1000-16 582 5992311 ns/op 400.52 MB/s Benchmark_RFanOut_8x100x1000-16 585 6017314 ns/op 398.85 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 555 6546361 ns/op 381.89 MB/s Benchmark_RFanOut_8x10x10000-16 532 6568128 ns/op 380.63 MB/s Benchmark_RFanOut_8x10x10000-16 552 6554441 ns/op 381.42 MB/s Benchmark_RFanOut_8x10x10000-16 519 6634750 ns/op 376.81 MB/s Benchmark_RFanOut_8x10x10000-16 536 6559673 ns/op 381.12 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3328 1160839 ns/op 8985.78 MB/s Benchmark_RFanOut_1kx10x1000-16 3000 1118898 ns/op 9322.60 MB/s Benchmark_RFanOut_1kx10x1000-16 3132 1117996 ns/op 9330.12 MB/s Benchmark_RFanOut_1kx10x1000-16 2940 1156316 ns/op 9020.92 MB/s Benchmark_RFanOut_1kx10x1000-16 3013 1144166 ns/op 9116.72 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6961160 503.6 ns/op 4125.94 MB/s Benchmark_____FanIn_1kx100x1-16 6955590 502.8 ns/op 4132.51 MB/s Benchmark_____FanIn_1kx100x1-16 6964753 502.2 ns/op 4138.19 MB/s Benchmark_____FanIn_1kx100x1-16 6931742 504.4 ns/op 4119.59 MB/s Benchmark_____FanIn_1kx100x1-16 6964376 503.3 ns/op 4128.54 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2606688 1339 ns/op 6141.73 MB/s Benchmark_____FanIn_4kx100x1-16 2609366 1349 ns/op 6093.02 MB/s Benchmark_____FanIn_4kx100x1-16 2643012 1350 ns/op 6091.13 MB/s Benchmark_____FanIn_4kx100x1-16 2548491 1380 ns/op 5960.00 MB/s Benchmark_____FanIn_4kx100x1-16 2726476 1367 ns/op 6013.42 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1720576 2092 ns/op 7846.76 MB/s Benchmark_____FanIn_8kx100x1-16 1721454 2096 ns/op 7832.40 MB/s Benchmark_____FanIn_8kx100x1-16 1709884 2128 ns/op 7714.46 MB/s Benchmark_____FanIn_8kx100x1-16 1687122 2079 ns/op 7896.18 MB/s Benchmark_____FanIn_8kx100x1-16 1683926 2081 ns/op 7885.89 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 868312 4185 ns/op 7837.93 MB/s Benchmark____FanIn_16kx100x1-16 868478 4113 ns/op 7974.82 MB/s Benchmark____FanIn_16kx100x1-16 883572 4152 ns/op 7899.16 MB/s Benchmark____FanIn_16kx100x1-16 876937 4218 ns/op 7775.37 MB/s Benchmark____FanIn_16kx100x1-16 864840 4163 ns/op 7878.84 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 5918518158 vs 11268560700 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59194->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58632->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58900->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58602->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 163650 20067 ns/op 6533.21 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 5208775827 vs 11484885600 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51108->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51302->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 157370 19987 ns/op 6559.57 MB/s Benchmark____FanIn_64kx100x1-16 150937 20235 ns/op 6479.00 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 249726450 vs 11837427000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34944->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:35506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35230->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: 246187020 vs 11653901000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38052->127.0.0.1:5222: write: 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:37346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37848->127.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:37336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37730->127.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:37334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37856->127.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: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:37714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:37420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:37660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37760->127.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: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: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: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: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:37304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38056->127.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:38106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37958->127.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: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:38132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:38082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:37432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37468->127.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:37968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37270->127.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:37774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37394->127.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:37398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37292->127.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:37878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:37572->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:38094->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: 732006560 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39052->127.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:39762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39442->127.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:39110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39218->127.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:39208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39060->127.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:39424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39936->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39098->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: 260213650 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41014->127.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:41452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41222->127.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:40832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41132->127.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:40852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41224->127.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: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:40930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40862->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: 947780700 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42974->127.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:43200->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5558034 641.7 ns/op 442.56 MB/s Benchmark___BumpPubCount_1x3-16 5582182 647.7 ns/op 438.44 MB/s Benchmark___BumpPubCount_1x3-16 5562751 641.3 ns/op 442.82 MB/s Benchmark___BumpPubCount_1x3-16 5572994 644.2 ns/op 440.86 MB/s Benchmark___BumpPubCount_1x3-16 5577507 641.8 ns/op 442.50 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5274288 676.1 ns/op 420.07 MB/s Benchmark___BumpPubCount_2x3-16 5278093 674.7 ns/op 420.94 MB/s Benchmark___BumpPubCount_2x3-16 5279325 673.9 ns/op 421.41 MB/s Benchmark___BumpPubCount_2x3-16 5308656 678.1 ns/op 418.80 MB/s Benchmark___BumpPubCount_2x3-16 5301792 679.0 ns/op 418.25 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5535855 644.7 ns/op 440.53 MB/s Benchmark___BumpPubCount_5x3-16 5211578 650.9 ns/op 436.33 MB/s Benchmark___BumpPubCount_5x3-16 5568525 645.8 ns/op 439.74 MB/s Benchmark___BumpPubCount_5x3-16 5554267 646.8 ns/op 439.06 MB/s Benchmark___BumpPubCount_5x3-16 5490968 650.0 ns/op 436.89 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5505190 647.6 ns/op 438.53 MB/s Benchmark__BumpPubCount_10x3-16 5487885 648.8 ns/op 437.72 MB/s Benchmark__BumpPubCount_10x3-16 5503723 649.0 ns/op 437.57 MB/s Benchmark__BumpPubCount_10x3-16 5506452 646.7 ns/op 439.15 MB/s Benchmark__BumpPubCount_10x3-16 5572398 651.4 ns/op 435.95 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12178621 273.6 ns/op 3801.49 MB/s Benchmark____GWs_Opt_1kx01x0-16 12140034 275.2 ns/op 3779.32 MB/s Benchmark____GWs_Opt_1kx01x0-16 12376507 267.8 ns/op 3883.30 MB/s Benchmark____GWs_Opt_1kx01x0-16 11861907 274.9 ns/op 3783.32 MB/s Benchmark____GWs_Opt_1kx01x0-16 12148029 271.1 ns/op 3836.48 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9715749 331.9 ns/op 6217.88 MB/s Benchmark____GWs_Opt_2kx01x0-16 10620811 332.1 ns/op 6214.70 MB/s Benchmark____GWs_Opt_2kx01x0-16 9776802 346.9 ns/op 5949.93 MB/s Benchmark____GWs_Opt_2kx01x0-16 10190391 339.2 ns/op 6084.08 MB/s Benchmark____GWs_Opt_2kx01x0-16 10484282 356.0 ns/op 5798.45 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5580798 649.9 ns/op 6327.41 MB/s Benchmark____GWs_Opt_4kx01x0-16 5650296 652.3 ns/op 6303.53 MB/s Benchmark____GWs_Opt_4kx01x0-16 5416570 631.9 ns/op 6507.37 MB/s Benchmark____GWs_Opt_4kx01x0-16 5416408 645.4 ns/op 6371.29 MB/s Benchmark____GWs_Opt_4kx01x0-16 5492455 655.8 ns/op 6270.21 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28923922 109.4 ns/op 9505.04 MB/s Benchmark____GWs_Opt_1kx10x0-16 31305052 115.4 ns/op 9011.15 MB/s Benchmark____GWs_Opt_1kx10x0-16 31913444 115.5 ns/op 9002.85 MB/s Benchmark____GWs_Opt_1kx10x0-16 27788721 112.4 ns/op 9250.65 MB/s Benchmark____GWs_Opt_1kx10x0-16 33027828 111.0 ns/op 9368.93 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25050123 155.0 ns/op 13315.79 MB/s Benchmark____GWs_Opt_2kx10x0-16 22459168 163.9 ns/op 12593.70 MB/s Benchmark____GWs_Opt_2kx10x0-16 23421583 148.9 ns/op 13859.16 MB/s Benchmark____GWs_Opt_2kx10x0-16 24323650 146.0 ns/op 14134.54 MB/s Benchmark____GWs_Opt_2kx10x0-16 23724554 143.2 ns/op 14408.72 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11463877 320.0 ns/op 12849.91 MB/s Benchmark____GWs_Opt_4kx10x0-16 11736132 295.9 ns/op 13895.25 MB/s Benchmark____GWs_Opt_4kx10x0-16 13246702 293.7 ns/op 13999.21 MB/s Benchmark____GWs_Opt_4kx10x0-16 11651888 324.4 ns/op 12677.65 MB/s Benchmark____GWs_Opt_4kx10x0-16 8188197 367.1 ns/op 11200.52 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6484416 550.4 ns/op 5677.49 MB/s Benchmark____GWs_Opt_1kx01x1-16 6431401 555.8 ns/op 5622.39 MB/s Benchmark____GWs_Opt_1kx01x1-16 6463293 553.5 ns/op 5645.80 MB/s Benchmark____GWs_Opt_1kx01x1-16 6182575 554.6 ns/op 5634.97 MB/s Benchmark____GWs_Opt_1kx01x1-16 6399146 553.9 ns/op 5641.99 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4721677 786.3 ns/op 7881.67 MB/s Benchmark____GWs_Opt_2kx01x1-16 4552635 840.3 ns/op 7374.56 MB/s Benchmark____GWs_Opt_2kx01x1-16 4593824 770.6 ns/op 8041.68 MB/s Benchmark____GWs_Opt_2kx01x1-16 4568814 774.5 ns/op 8001.60 MB/s Benchmark____GWs_Opt_2kx01x1-16 4629252 778.2 ns/op 7963.33 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2614766 1393 ns/op 8861.24 MB/s Benchmark____GWs_Opt_4kx01x1-16 2573922 1403 ns/op 8796.75 MB/s Benchmark____GWs_Opt_4kx01x1-16 2645983 1390 ns/op 8875.95 MB/s Benchmark____GWs_Opt_4kx01x1-16 2405521 1390 ns/op 8879.26 MB/s Benchmark____GWs_Opt_4kx01x1-16 2629179 1395 ns/op 8843.86 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6384208 559.8 ns/op 5581.90 MB/s Benchmark____GWs_Opt_1kx10x1-16 6131767 560.7 ns/op 5573.17 MB/s Benchmark____GWs_Opt_1kx10x1-16 6173229 560.0 ns/op 5580.45 MB/s Benchmark____GWs_Opt_1kx10x1-16 6634088 559.8 ns/op 5582.40 MB/s Benchmark____GWs_Opt_1kx10x1-16 6546805 563.5 ns/op 5546.14 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4204093 854.5 ns/op 7252.29 MB/s Benchmark____GWs_Opt_2kx10x1-16 4040668 833.6 ns/op 7434.02 MB/s Benchmark____GWs_Opt_2kx10x1-16 4168892 841.5 ns/op 7364.50 MB/s Benchmark____GWs_Opt_2kx10x1-16 4103404 845.4 ns/op 7330.25 MB/s Benchmark____GWs_Opt_2kx10x1-16 4108845 844.6 ns/op 7336.80 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2299148 1500 ns/op 8225.55 MB/s Benchmark____GWs_Opt_4kx10x1-16 2323672 1496 ns/op 8251.67 MB/s Benchmark____GWs_Opt_4kx10x1-16 2319512 1631 ns/op 7566.73 MB/s Benchmark____GWs_Opt_4kx10x1-16 2393954 1518 ns/op 8127.52 MB/s Benchmark____GWs_Opt_4kx10x1-16 2482154 1596 ns/op 7731.01 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11883366 291.5 ns/op 3567.86 MB/s Benchmark____GWs_Int_1kx01x0-16 12056292 286.9 ns/op 3625.58 MB/s Benchmark____GWs_Int_1kx01x0-16 12385714 285.6 ns/op 3640.93 MB/s Benchmark____GWs_Int_1kx01x0-16 12474472 287.6 ns/op 3616.44 MB/s Benchmark____GWs_Int_1kx01x0-16 12761787 295.8 ns/op 3515.43 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9749006 348.6 ns/op 5920.84 MB/s Benchmark____GWs_Int_2kx01x0-16 10049611 356.8 ns/op 5784.87 MB/s Benchmark____GWs_Int_2kx01x0-16 9940968 352.1 ns/op 5862.53 MB/s Benchmark____GWs_Int_2kx01x0-16 10107823 356.2 ns/op 5794.54 MB/s Benchmark____GWs_Int_2kx01x0-16 10055276 357.9 ns/op 5767.60 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5535345 658.0 ns/op 6249.07 MB/s Benchmark____GWs_Int_4kx01x0-16 5564388 646.4 ns/op 6360.94 MB/s Benchmark____GWs_Int_4kx01x0-16 5749104 671.6 ns/op 6122.98 MB/s Benchmark____GWs_Int_4kx01x0-16 5455700 663.7 ns/op 6195.64 MB/s Benchmark____GWs_Int_4kx01x0-16 5711970 673.3 ns/op 6107.12 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31955761 113.3 ns/op 9177.37 MB/s Benchmark____GWs_Int_1kx10x0-16 32467929 111.1 ns/op 9358.41 MB/s Benchmark____GWs_Int_1kx10x0-16 31417059 112.6 ns/op 9238.99 MB/s Benchmark____GWs_Int_1kx10x0-16 31186291 113.3 ns/op 9181.42 MB/s Benchmark____GWs_Int_1kx10x0-16 32069179 121.7 ns/op 8547.16 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 21784460 145.5 ns/op 14190.24 MB/s Benchmark____GWs_Int_2kx10x0-16 21987610 163.3 ns/op 12639.05 MB/s Benchmark____GWs_Int_2kx10x0-16 22864765 140.6 ns/op 14679.88 MB/s Benchmark____GWs_Int_2kx10x0-16 24450662 143.2 ns/op 14412.51 MB/s Benchmark____GWs_Int_2kx10x0-16 24910849 142.6 ns/op 14473.46 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13153432 287.0 ns/op 14326.66 MB/s Benchmark____GWs_Int_4kx10x0-16 10712332 383.5 ns/op 10723.69 MB/s Benchmark____GWs_Int_4kx10x0-16 12083142 285.1 ns/op 14421.61 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:46374->127.0.0.1:34533: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:51344->127.0.0.1:39393: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 11334790 307.7 ns/op 13364.02 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6539146 556.7 ns/op 5613.44 MB/s Benchmark____GWs_Int_1kx01x1-16 5839992 570.3 ns/op 5480.05 MB/s Benchmark____GWs_Int_1kx01x1-16 6206329 567.4 ns/op 5507.18 MB/s Benchmark____GWs_Int_1kx01x1-16 6518001 560.2 ns/op 5578.39 MB/s Benchmark____GWs_Int_1kx01x1-16 6338439 623.3 ns/op 5013.92 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4767254 781.0 ns/op 7934.41 MB/s Benchmark____GWs_Int_2kx01x1-16 4654285 951.5 ns/op 6512.60 MB/s Benchmark____GWs_Int_2kx01x1-16 4648861 780.5 ns/op 7939.68 MB/s Benchmark____GWs_Int_2kx01x1-16 4642477 769.0 ns/op 8058.24 MB/s Benchmark____GWs_Int_2kx01x1-16 4641950 1170 ns/op 5298.70 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2612694 1399 ns/op 8821.35 MB/s Benchmark____GWs_Int_4kx01x1-16 2380610 1398 ns/op 8825.47 MB/s Benchmark____GWs_Int_4kx01x1-16 2625948 1394 ns/op 8851.75 MB/s Benchmark____GWs_Int_4kx01x1-16 2623563 1413 ns/op 8736.37 MB/s Benchmark____GWs_Int_4kx01x1-16 2581404 1397 ns/op 8833.67 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6269554 559.4 ns/op 5586.70 MB/s Benchmark____GWs_Int_1kx10x1-16 6200270 559.0 ns/op 5590.30 MB/s Benchmark____GWs_Int_1kx10x1-16 6190353 556.0 ns/op 5620.86 MB/s Benchmark____GWs_Int_1kx10x1-16 6246805 561.9 ns/op 5561.59 MB/s Benchmark____GWs_Int_1kx10x1-16 6229956 563.8 ns/op 5542.82 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4128177 843.1 ns/op 7350.63 MB/s Benchmark____GWs_Int_2kx10x1-16 4062232 851.1 ns/op 7281.47 MB/s Benchmark____GWs_Int_2kx10x1-16 4058316 909.6 ns/op 6812.55 MB/s Benchmark____GWs_Int_2kx10x1-16 4042792 873.5 ns/op 7094.17 MB/s Benchmark____GWs_Int_2kx10x1-16 4253426 857.9 ns/op 7223.66 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2286260 1530 ns/op 8067.36 MB/s Benchmark____GWs_Int_4kx10x1-16 2329177 1539 ns/op 8016.58 MB/s Benchmark____GWs_Int_4kx10x1-16 2316190 1518 ns/op 8130.61 MB/s Benchmark____GWs_Int_4kx10x1-16 2174956 1523 ns/op 8102.42 MB/s Benchmark____GWs_Int_4kx10x1-16 2344538 1493 ns/op 8267.17 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8092064 444.8 ns/op 229.33 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7905255 449.3 ns/op 227.02 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7792116 441.4 ns/op 231.09 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8059752 448.4 ns/op 227.48 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8363785 442.6 ns/op 230.44 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 612918 5031 ns/op 35.18 MB/s Benchmark__GWs_Reqs_1SubEach-16 804426 5212 ns/op 33.96 MB/s Benchmark__GWs_Reqs_1SubEach-16 738261 5262 ns/op 33.64 MB/s Benchmark__GWs_Reqs_1SubEach-16 778785 5316 ns/op 33.30 MB/s Benchmark__GWs_Reqs_1SubEach-16 719510 5270 ns/op 33.59 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2107.571s ❌ Non-zero exit code: 1