> ROOT_DIR=/tmp/go-bench-away-job-6c3cee6f-a6a1-42e2-bc06-3593ae8270dd-544003860 > OUTPUT_FILE=/tmp/go-bench-away-job-6c3cee6f-a6a1-42e2-bc06-3593ae8270dd-544003860/results.txt > SHA_FILE=/tmp/go-bench-away-job-6c3cee6f-a6a1-42e2-bc06-3593ae8270dd-544003860/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-6c3cee6f-a6a1-42e2-bc06-3593ae8270dd-544003860/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-6c3cee6f-a6a1-42e2-bc06-3593ae8270dd-544003860/source.git SHA of main: 146b0be65b3591e925cce61ce9d2cae32cdeb227 Go runtime: go version go1.26.3 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build457672046=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-6c3cee6f-a6a1-42e2-bc06-3593ae8270dd-544003860/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 49484176 72.73 ns/op 151.25 MB/s Benchmark______Pub0b_Payload-16 45660961 73.05 ns/op 150.58 MB/s Benchmark______Pub0b_Payload-16 47109309 76.95 ns/op 142.95 MB/s Benchmark______Pub0b_Payload-16 46593108 72.80 ns/op 151.10 MB/s Benchmark______Pub0b_Payload-16 45110239 73.21 ns/op 150.25 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46234464 73.38 ns/op 258.93 MB/s Benchmark______Pub8b_Payload-16 46441953 73.51 ns/op 258.46 MB/s Benchmark______Pub8b_Payload-16 46162645 73.33 ns/op 259.09 MB/s Benchmark______Pub8b_Payload-16 46307250 73.20 ns/op 259.56 MB/s Benchmark______Pub8b_Payload-16 49013042 73.50 ns/op 258.49 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44262320 77.28 ns/op 569.38 MB/s Benchmark_____Pub32b_Payload-16 43972674 77.44 ns/op 568.19 MB/s Benchmark_____Pub32b_Payload-16 44186860 76.96 ns/op 571.74 MB/s Benchmark_____Pub32b_Payload-16 43247145 77.39 ns/op 568.54 MB/s Benchmark_____Pub32b_Payload-16 42955576 77.55 ns/op 567.41 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38759742 86.15 ns/op 1636.62 MB/s Benchmark____Pub128B_Payload-16 39285433 87.89 ns/op 1604.30 MB/s Benchmark____Pub128B_Payload-16 41867095 86.52 ns/op 1629.59 MB/s Benchmark____Pub128B_Payload-16 39840181 86.26 ns/op 1634.61 MB/s Benchmark____Pub128B_Payload-16 35031021 86.27 ns/op 1634.37 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35157840 94.52 ns/op 2845.88 MB/s Benchmark____Pub256B_Payload-16 36078669 96.47 ns/op 2788.37 MB/s Benchmark____Pub256B_Payload-16 36130801 94.72 ns/op 2839.92 MB/s Benchmark____Pub256B_Payload-16 35360338 98.73 ns/op 2724.63 MB/s Benchmark____Pub256B_Payload-16 36659965 99.75 ns/op 2696.72 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24172417 135.4 ns/op 7665.49 MB/s Benchmark______Pub1K_Payload-16 24009505 143.9 ns/op 7215.59 MB/s Benchmark______Pub1K_Payload-16 24500344 143.9 ns/op 7215.31 MB/s Benchmark______Pub1K_Payload-16 25731529 146.0 ns/op 7108.46 MB/s Benchmark______Pub1K_Payload-16 23867006 136.3 ns/op 7613.95 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5572300 616.0 ns/op 6672.45 MB/s Benchmark______Pub4K_Payload-16 5584821 617.3 ns/op 6658.06 MB/s Benchmark______Pub4K_Payload-16 5331790 610.9 ns/op 6728.01 MB/s Benchmark______Pub4K_Payload-16 5513139 641.7 ns/op 6404.50 MB/s Benchmark______Pub4K_Payload-16 5766483 628.3 ns/op 6541.19 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2667673 1278 ns/op 6421.51 MB/s Benchmark______Pub8K_Payload-16 2619289 1274 ns/op 6438.76 MB/s Benchmark______Pub8K_Payload-16 2729515 1272 ns/op 6453.38 MB/s Benchmark______Pub8K_Payload-16 2758281 1283 ns/op 6393.86 MB/s Benchmark______Pub8K_Payload-16 2807083 1285 ns/op 6385.36 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 608487 5432 ns/op 6035.28 MB/s Benchmark_____Pub32K_Payload-16 673102 5511 ns/op 5948.41 MB/s Benchmark_____Pub32K_Payload-16 644497 5472 ns/op 5991.59 MB/s Benchmark_____Pub32K_Payload-16 468354 8599 ns/op 3812.38 MB/s Benchmark_____Pub32K_Payload-16 433174 14637 ns/op 2239.70 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31807292 94.96 ns/op 115.84 MB/s Benchmark__AuthPub0b_Payload-16 36109864 95.05 ns/op 115.73 MB/s Benchmark__AuthPub0b_Payload-16 35041011 94.83 ns/op 116.00 MB/s Benchmark__AuthPub0b_Payload-16 32884312 100.9 ns/op 109.02 MB/s Benchmark__AuthPub0b_Payload-16 34942808 95.69 ns/op 114.95 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15571856 228.1 ns/op Benchmark_____________PubSub-16 15606052 228.5 ns/op Benchmark_____________PubSub-16 15519453 228.2 ns/op Benchmark_____________PubSub-16 15551911 229.5 ns/op Benchmark_____________PubSub-16 15444409 227.8 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15589452 226.2 ns/op Benchmark_____PubSubTwoConns-16 15562484 226.1 ns/op Benchmark_____PubSubTwoConns-16 15411711 226.4 ns/op Benchmark_____PubSubTwoConns-16 15529203 227.7 ns/op Benchmark_____PubSubTwoConns-16 15500612 227.4 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34268->127.0.0.1:42299: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:53410->127.0.0.1:35959: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42958->127.0.0.1:41869: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:52110->127.0.0.1:34973: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59198->127.0.0.1:34703: 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 14320087 245.2 ns/op Benchmark_____PubTwoQueueSub-16 14466913 244.6 ns/op Benchmark_____PubTwoQueueSub-16 14439573 244.7 ns/op Benchmark_____PubTwoQueueSub-16 14698405 244.3 ns/op Benchmark_____PubTwoQueueSub-16 14453886 244.8 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14318419 243.3 ns/op Benchmark____PubFourQueueSub-16 14630488 244.3 ns/op Benchmark____PubFourQueueSub-16 14756911 244.2 ns/op Benchmark____PubFourQueueSub-16 14306484 243.9 ns/op Benchmark____PubFourQueueSub-16 14388211 243.9 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14614572 245.6 ns/op Benchmark___PubEightQueueSub-16 14677911 244.2 ns/op Benchmark___PubEightQueueSub-16 14496838 244.7 ns/op Benchmark___PubEightQueueSub-16 14609000 244.5 ns/op Benchmark___PubEightQueueSub-16 14221630 243.7 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22953 155053 ns/op Benchmark_PubSub512kTwoConns-16 23104 155815 ns/op Benchmark_PubSub512kTwoConns-16 23310 154531 ns/op Benchmark_PubSub512kTwoConns-16 23018 154721 ns/op Benchmark_PubSub512kTwoConns-16 23091 157265 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14942755 230.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15168594 230.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15313525 230.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15040302 229.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 14963018 231.4 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15240452 230.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15203097 230.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15037212 231.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15256854 230.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15248709 231.7 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11149356 310.2 ns/op Benchmark____RoutedPubSub_0b-16 11538768 316.7 ns/op Benchmark____RoutedPubSub_0b-16 11488212 313.7 ns/op Benchmark____RoutedPubSub_0b-16 11537235 316.1 ns/op Benchmark____RoutedPubSub_0b-16 11051547 319.5 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6504448 535.8 ns/op Benchmark____RoutedPubSub_1K-16 6871976 533.0 ns/op Benchmark____RoutedPubSub_1K-16 6601032 533.4 ns/op Benchmark____RoutedPubSub_1K-16 6505110 532.6 ns/op Benchmark____RoutedPubSub_1K-16 6686620 541.2 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 81046 45063 ns/op Benchmark__RoutedPubSub_100K-16 84381 44301 ns/op Benchmark__RoutedPubSub_100K-16 73628 48058 ns/op Benchmark__RoutedPubSub_100K-16 75838 47546 ns/op Benchmark__RoutedPubSub_100K-16 76917 48693 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9951872 317.4 ns/op Benchmark____Routed2QueueSub-16 9847302 312.6 ns/op Benchmark____Routed2QueueSub-16 9582044 314.9 ns/op Benchmark____Routed2QueueSub-16 11455831 315.4 ns/op Benchmark____Routed2QueueSub-16 9933607 313.3 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9863190 322.9 ns/op Benchmark____Routed4QueueSub-16 9521980 329.6 ns/op Benchmark____Routed4QueueSub-16 9668036 328.8 ns/op Benchmark____Routed4QueueSub-16 9505977 326.0 ns/op Benchmark____Routed4QueueSub-16 9725362 320.6 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9351595 330.2 ns/op Benchmark____Routed8QueueSub-16 9432835 325.8 ns/op Benchmark____Routed8QueueSub-16 9445863 330.5 ns/op Benchmark____Routed8QueueSub-16 9378056 338.3 ns/op Benchmark____Routed8QueueSub-16 9082078 335.4 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 9172184 347.7 ns/op Benchmark___Routed16QueueSub-16 8574152 351.3 ns/op Benchmark___Routed16QueueSub-16 8681040 357.1 ns/op Benchmark___Routed16QueueSub-16 8904392 346.6 ns/op Benchmark___Routed16QueueSub-16 8803312 353.2 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6454676 559.7 ns/op Benchmark____________RouteCompressOff-16 6401305 543.8 ns/op Benchmark____________RouteCompressOff-16 6542311 551.3 ns/op Benchmark____________RouteCompressOff-16 6315368 559.8 ns/op Benchmark____________RouteCompressOff-16 6430914 550.7 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6411285 555.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6451882 552.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6537826 554.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6221684 556.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6538179 551.9 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6341680 552.5 ns/op Benchmark_________RouteCompressS2Fast-16 6267255 547.6 ns/op Benchmark_________RouteCompressS2Fast-16 6333369 555.0 ns/op Benchmark_________RouteCompressS2Fast-16 6335312 554.4 ns/op Benchmark_________RouteCompressS2Fast-16 6566805 552.2 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6445028 492.0 ns/op Benchmark_______RouteCompressS2Better-16 6470322 550.7 ns/op Benchmark_______RouteCompressS2Better-16 6536794 552.9 ns/op Benchmark_______RouteCompressS2Better-16 6329556 550.0 ns/op Benchmark_______RouteCompressS2Better-16 6389229 549.7 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6578294 550.4 ns/op Benchmark_________RouteCompressS2Best-16 6391256 555.2 ns/op Benchmark_________RouteCompressS2Best-16 6390939 551.2 ns/op Benchmark_________RouteCompressS2Best-16 6453100 553.9 ns/op Benchmark_________RouteCompressS2Best-16 6385129 548.2 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4629297 771.4 ns/op 322.80 MB/s Benchmark______FanOut_8x1x10-16 4661857 768.1 ns/op 324.16 MB/s Benchmark______FanOut_8x1x10-16 4634883 766.4 ns/op 324.90 MB/s Benchmark______FanOut_8x1x10-16 4648519 767.8 ns/op 324.31 MB/s Benchmark______FanOut_8x1x10-16 4623032 768.2 ns/op 324.14 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 531174 6085 ns/op 381.09 MB/s Benchmark_____FanOut_8x1x100-16 561800 6051 ns/op 383.21 MB/s Benchmark_____FanOut_8x1x100-16 534445 6142 ns/op 377.59 MB/s Benchmark_____FanOut_8x1x100-16 551995 6078 ns/op 381.57 MB/s Benchmark_____FanOut_8x1x100-16 552974 6055 ns/op 383.00 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48271 74530 ns/op 308.86 MB/s Benchmark____FanOut_8x10x100-16 48345 75208 ns/op 306.07 MB/s Benchmark____FanOut_8x10x100-16 47744 74305 ns/op 309.79 MB/s Benchmark____FanOut_8x10x100-16 47840 74933 ns/op 307.20 MB/s Benchmark____FanOut_8x10x100-16 48571 75203 ns/op 306.09 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5941 594477 ns/op 403.75 MB/s Benchmark___FanOut_8x10x1000-16 6031 595202 ns/op 403.26 MB/s Benchmark___FanOut_8x10x1000-16 5767 599373 ns/op 400.45 MB/s Benchmark___FanOut_8x10x1000-16 5983 594218 ns/op 403.92 MB/s Benchmark___FanOut_8x10x1000-16 5817 604492 ns/op 397.06 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5031 711702 ns/op 323.20 MB/s Benchmark___FanOut_8x100x100-16 4948 707101 ns/op 325.30 MB/s Benchmark___FanOut_8x100x100-16 4999 712746 ns/op 322.72 MB/s Benchmark___FanOut_8x100x100-16 4930 706826 ns/op 325.43 MB/s Benchmark___FanOut_8x100x100-16 5053 705643 ns/op 325.97 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 573 6125955 ns/op 391.78 MB/s Benchmark__FanOut_8x100x1000-16 585 6099288 ns/op 393.49 MB/s Benchmark__FanOut_8x100x1000-16 570 6231892 ns/op 385.12 MB/s Benchmark__FanOut_8x100x1000-16 548 6133960 ns/op 391.27 MB/s Benchmark__FanOut_8x100x1000-16 578 6116324 ns/op 392.40 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 522 6704705 ns/op 372.88 MB/s Benchmark__FanOut_8x10x10000-16 519 6828660 ns/op 366.11 MB/s Benchmark__FanOut_8x10x10000-16 538 6837327 ns/op 365.64 MB/s Benchmark__FanOut_8x10x10000-16 519 6842495 ns/op 365.37 MB/s Benchmark__FanOut_8x10x10000-16 526 6683850 ns/op 374.04 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 951 3780936 ns/op 304.16 MB/s Benchmark___FanOut_8x500x100-16 948 3755993 ns/op 306.18 MB/s Benchmark___FanOut_8x500x100-16 945 3765101 ns/op 305.44 MB/s Benchmark___FanOut_8x500x100-16 948 3751967 ns/op 306.51 MB/s Benchmark___FanOut_8x500x100-16 931 3761228 ns/op 305.76 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 362925 9508 ns/op 1539.92 MB/s Benchmark___FanOut_128x1x100-16 361754 9471 ns/op 1545.96 MB/s Benchmark___FanOut_128x1x100-16 371190 9500 ns/op 1541.21 MB/s Benchmark___FanOut_128x1x100-16 362648 9454 ns/op 1548.66 MB/s Benchmark___FanOut_128x1x100-16 345856 9479 ns/op 1544.53 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32487 109429 ns/op 1326.35 MB/s Benchmark__FanOut_128x10x100-16 32492 111006 ns/op 1307.51 MB/s Benchmark__FanOut_128x10x100-16 32486 111049 ns/op 1307.00 MB/s Benchmark__FanOut_128x10x100-16 32250 111675 ns/op 1299.67 MB/s Benchmark__FanOut_128x10x100-16 32407 112158 ns/op 1294.08 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3919 874857 ns/op 1669.01 MB/s Benchmark_FanOut_128x10x1000-16 4040 878277 ns/op 1662.51 MB/s Benchmark_FanOut_128x10x1000-16 4076 889607 ns/op 1641.33 MB/s Benchmark_FanOut_128x10x1000-16 4062 874678 ns/op 1669.35 MB/s Benchmark_FanOut_128x10x1000-16 3984 867777 ns/op 1682.62 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3595 1007921 ns/op 1438.74 MB/s Benchmark_FanOut_128x100x100-16 3489 1007483 ns/op 1439.37 MB/s Benchmark_FanOut_128x100x100-16 3501 1007244 ns/op 1439.71 MB/s Benchmark_FanOut_128x100x100-16 3522 1007033 ns/op 1440.01 MB/s Benchmark_FanOut_128x100x100-16 3459 1009186 ns/op 1436.94 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 390 9279095 ns/op 1573.44 MB/s BenchmarkFanOut_128x100x1000-16 386 9251566 ns/op 1578.13 MB/s BenchmarkFanOut_128x100x1000-16 385 9385229 ns/op 1555.65 MB/s BenchmarkFanOut_128x100x1000-16 382 9237423 ns/op 1580.54 MB/s BenchmarkFanOut_128x100x1000-16 385 9273977 ns/op 1574.31 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 370 9601245 ns/op 1531.07 MB/s BenchmarkFanOut_128x10x10000-16 370 9699643 ns/op 1515.53 MB/s BenchmarkFanOut_128x10x10000-16 374 9704214 ns/op 1514.82 MB/s BenchmarkFanOut_128x10x10000-16 368 9685384 ns/op 1517.77 MB/s BenchmarkFanOut_128x10x10000-16 363 9624173 ns/op 1527.42 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 680 5293059 ns/op 1369.74 MB/s BenchmarkFanOut__128x500x100-16 669 5260909 ns/op 1378.12 MB/s BenchmarkFanOut__128x500x100-16 672 5269640 ns/op 1375.83 MB/s BenchmarkFanOut__128x500x100-16 682 5265002 ns/op 1377.04 MB/s BenchmarkFanOut__128x500x100-16 672 5230831 ns/op 1386.04 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1929 1849141 ns/op 2861.07 MB/s Benchmark_FanOut_512x100x100-16 1941 1835560 ns/op 2882.24 MB/s Benchmark_FanOut_512x100x100-16 1909 1842942 ns/op 2870.70 MB/s Benchmark_FanOut_512x100x100-16 1936 1837780 ns/op 2878.76 MB/s Benchmark_FanOut_512x100x100-16 1933 1836647 ns/op 2880.54 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 211 16881104 ns/op 3139.64 MB/s Benchmark__FanOut_512x100x1k-16 217 16687066 ns/op 3176.14 MB/s Benchmark__FanOut_512x100x1k-16 213 16686751 ns/op 3176.20 MB/s Benchmark__FanOut_512x100x1k-16 216 16824019 ns/op 3150.29 MB/s Benchmark__FanOut_512x100x1k-16 217 16800224 ns/op 3154.75 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3339 1152382 ns/op 9051.72 MB/s Benchmark____FanOut_1kx10x1k-16 3054 1166124 ns/op 8945.05 MB/s Benchmark____FanOut_1kx10x1k-16 3183 1151301 ns/op 9060.22 MB/s Benchmark____FanOut_1kx10x1k-16 2851 1125356 ns/op 9269.10 MB/s Benchmark____FanOut_1kx10x1k-16 3249 1132850 ns/op 9207.79 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2818 1253466 ns/op 8313.78 MB/s Benchmark__FanOut_1kx100x100-16 2863 1257423 ns/op 8287.62 MB/s Benchmark__FanOut_1kx100x100-16 2776 1259975 ns/op 8270.83 MB/s Benchmark__FanOut_1kx100x100-16 2787 1270305 ns/op 8203.57 MB/s Benchmark__FanOut_1kx100x100-16 2763 1261223 ns/op 8262.64 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4437568 799.0 ns/op 311.64 MB/s Benchmark_____RFanOut_8x1x10-16 4451156 782.7 ns/op 318.13 MB/s Benchmark_____RFanOut_8x1x10-16 4365674 785.9 ns/op 316.84 MB/s Benchmark_____RFanOut_8x1x10-16 4379305 775.1 ns/op 321.25 MB/s Benchmark_____RFanOut_8x1x10-16 4225216 798.2 ns/op 311.96 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 522103 6474 ns/op 358.18 MB/s Benchmark____RFanOut_8x1x100-16 543885 6694 ns/op 346.43 MB/s Benchmark____RFanOut_8x1x100-16 523718 6352 ns/op 365.06 MB/s Benchmark____RFanOut_8x1x100-16 505810 6374 ns/op 363.81 MB/s Benchmark____RFanOut_8x1x100-16 518097 6302 ns/op 367.99 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47360 75139 ns/op 306.35 MB/s Benchmark___RFanOut_8x10x100-16 48211 75711 ns/op 304.04 MB/s Benchmark___RFanOut_8x10x100-16 48056 74463 ns/op 309.13 MB/s Benchmark___RFanOut_8x10x100-16 47786 74878 ns/op 307.42 MB/s Benchmark___RFanOut_8x10x100-16 47584 74849 ns/op 307.54 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5704 600399 ns/op 399.77 MB/s Benchmark__RFanOut_8x10x1000-16 5960 602548 ns/op 398.34 MB/s Benchmark__RFanOut_8x10x1000-16 5931 599936 ns/op 400.07 MB/s Benchmark__RFanOut_8x10x1000-16 5791 602838 ns/op 398.15 MB/s Benchmark__RFanOut_8x10x1000-16 5641 600658 ns/op 399.59 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5032 713747 ns/op 322.27 MB/s Benchmark__RFanOut_8x100x100-16 4972 707308 ns/op 325.20 MB/s Benchmark__RFanOut_8x100x100-16 4936 708967 ns/op 324.44 MB/s Benchmark__RFanOut_8x100x100-16 4918 711048 ns/op 323.49 MB/s Benchmark__RFanOut_8x100x100-16 5006 707169 ns/op 325.27 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 571 6235182 ns/op 384.92 MB/s Benchmark_RFanOut_8x100x1000-16 577 6257613 ns/op 383.54 MB/s Benchmark_RFanOut_8x100x1000-16 577 6237530 ns/op 384.77 MB/s Benchmark_RFanOut_8x100x1000-16 566 6158387 ns/op 389.72 MB/s Benchmark_RFanOut_8x100x1000-16 577 6145106 ns/op 390.56 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 531 6739657 ns/op 370.94 MB/s Benchmark_RFanOut_8x10x10000-16 535 6696334 ns/op 373.34 MB/s Benchmark_RFanOut_8x10x10000-16 534 6790325 ns/op 368.17 MB/s Benchmark_RFanOut_8x10x10000-16 529 6793781 ns/op 367.99 MB/s Benchmark_RFanOut_8x10x10000-16 532 6684177 ns/op 374.02 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3268 1163679 ns/op 8963.85 MB/s Benchmark_RFanOut_1kx10x1000-16 3249 1157255 ns/op 9013.60 MB/s Benchmark_RFanOut_1kx10x1000-16 2805 1167987 ns/op 8930.78 MB/s Benchmark_RFanOut_1kx10x1000-16 3106 1143873 ns/op 9119.05 MB/s Benchmark_RFanOut_1kx10x1000-16 3162 1147132 ns/op 9093.15 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6960286 504.1 ns/op 4122.05 MB/s Benchmark_____FanIn_1kx100x1-16 6952515 502.3 ns/op 4137.00 MB/s Benchmark_____FanIn_1kx100x1-16 6990273 505.6 ns/op 4109.66 MB/s Benchmark_____FanIn_1kx100x1-16 6948429 508.1 ns/op 4089.70 MB/s Benchmark_____FanIn_1kx100x1-16 6924855 505.9 ns/op 4107.36 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2659333 1365 ns/op 6025.04 MB/s Benchmark_____FanIn_4kx100x1-16 2631645 1359 ns/op 6052.10 MB/s Benchmark_____FanIn_4kx100x1-16 2631439 1363 ns/op 6031.17 MB/s Benchmark_____FanIn_4kx100x1-16 2591372 1356 ns/op 6063.99 MB/s Benchmark_____FanIn_4kx100x1-16 2643010 1352 ns/op 6081.00 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1696818 2118 ns/op 7749.20 MB/s Benchmark_____FanIn_8kx100x1-16 1711675 2117 ns/op 7752.13 MB/s Benchmark_____FanIn_8kx100x1-16 1663528 2109 ns/op 7784.64 MB/s Benchmark_____FanIn_8kx100x1-16 1707112 2104 ns/op 7800.53 MB/s Benchmark_____FanIn_8kx100x1-16 1702440 2080 ns/op 7890.98 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 880838 4131 ns/op 7940.80 MB/s Benchmark____FanIn_16kx100x1-16 870786 4123 ns/op 7955.10 MB/s Benchmark____FanIn_16kx100x1-16 863846 4187 ns/op 7834.57 MB/s Benchmark____FanIn_16kx100x1-16 873001 4137 ns/op 7928.34 MB/s Benchmark____FanIn_16kx100x1-16 865036 4159 ns/op 7887.02 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 166478 19736 ns/op 6642.89 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 4377301575 vs 11694655200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60986->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:60942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33416->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 177849 20023 ns/op 6547.51 MB/s Benchmark____FanIn_64kx100x1-16 168402 19989 ns/op 6558.65 MB/s Benchmark____FanIn_64kx100x1-16 171130 19800 ns/op 6621.54 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 724927700 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36226->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:36412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36556->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: 79047270 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38208->127.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:38040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38148->127.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:37690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37838->127.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:38346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38290->127.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:37736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37650->127.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:37806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37938->127.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:37960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:38194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:38250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:38178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37768->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:38278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:37622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37836->127.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:37752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38358->127.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:38336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38300->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: 186016710 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39456->127.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:39640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39982->127.0.0.1:5222: write: connection reset by peer 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:39806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39906->127.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:40070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40016->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: 454357940 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:41730->127.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:41466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41740->127.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:41702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41530->127.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:42006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41326->127.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:41498->127.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:41890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:41866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42088->127.0.0.1:5222: write: connection reset by peer bench_test.go: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: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:41514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41342->127.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:41544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:41310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41736->127.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:41824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42118->127.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 --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 200829880 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43136->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:43684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43744->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43512->127.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:43786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43670->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5554496 640.3 ns/op 443.53 MB/s Benchmark___BumpPubCount_1x3-16 5581216 637.9 ns/op 445.21 MB/s Benchmark___BumpPubCount_1x3-16 5580909 640.4 ns/op 443.48 MB/s Benchmark___BumpPubCount_1x3-16 5607261 638.9 ns/op 444.48 MB/s Benchmark___BumpPubCount_1x3-16 5630887 643.6 ns/op 441.25 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5280692 676.3 ns/op 419.95 MB/s Benchmark___BumpPubCount_2x3-16 5308176 669.4 ns/op 424.24 MB/s Benchmark___BumpPubCount_2x3-16 5302747 669.9 ns/op 423.94 MB/s Benchmark___BumpPubCount_2x3-16 5193825 670.3 ns/op 423.70 MB/s Benchmark___BumpPubCount_2x3-16 5309480 670.8 ns/op 423.36 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5493861 645.9 ns/op 439.67 MB/s Benchmark___BumpPubCount_5x3-16 5565490 645.2 ns/op 440.17 MB/s Benchmark___BumpPubCount_5x3-16 5582749 645.1 ns/op 440.24 MB/s Benchmark___BumpPubCount_5x3-16 5571715 643.5 ns/op 441.35 MB/s Benchmark___BumpPubCount_5x3-16 5533408 647.7 ns/op 438.46 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5585145 640.6 ns/op 443.33 MB/s Benchmark__BumpPubCount_10x3-16 5617136 640.5 ns/op 443.42 MB/s Benchmark__BumpPubCount_10x3-16 5602063 639.9 ns/op 443.79 MB/s Benchmark__BumpPubCount_10x3-16 5592722 643.2 ns/op 441.54 MB/s Benchmark__BumpPubCount_10x3-16 5586532 641.5 ns/op 442.74 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12328809 281.1 ns/op 3699.88 MB/s Benchmark____GWs_Opt_1kx01x0-16 12699271 270.1 ns/op 3850.72 MB/s Benchmark____GWs_Opt_1kx01x0-16 12513021 268.3 ns/op 3876.92 MB/s Benchmark____GWs_Opt_1kx01x0-16 13215204 271.2 ns/op 3834.80 MB/s Benchmark____GWs_Opt_1kx01x0-16 11873180 272.8 ns/op 3812.56 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 11044390 334.3 ns/op 6173.53 MB/s Benchmark____GWs_Opt_2kx01x0-16 11001520 340.1 ns/op 6069.68 MB/s Benchmark____GWs_Opt_2kx01x0-16 10633545 344.4 ns/op 5992.77 MB/s Benchmark____GWs_Opt_2kx01x0-16 10521313 333.3 ns/op 6191.74 MB/s Benchmark____GWs_Opt_2kx01x0-16 9475318 345.4 ns/op 5975.89 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5808619 621.5 ns/op 6616.09 MB/s Benchmark____GWs_Opt_4kx01x0-16 5746435 614.3 ns/op 6694.16 MB/s Benchmark____GWs_Opt_4kx01x0-16 5892151 621.3 ns/op 6618.56 MB/s Benchmark____GWs_Opt_4kx01x0-16 5815906 609.0 ns/op 6752.17 MB/s Benchmark____GWs_Opt_4kx01x0-16 5866262 632.8 ns/op 6498.38 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29058532 109.3 ns/op 9517.03 MB/s Benchmark____GWs_Opt_1kx10x0-16 31391722 110.2 ns/op 9441.20 MB/s Benchmark____GWs_Opt_1kx10x0-16 32193411 114.0 ns/op 9125.23 MB/s Benchmark____GWs_Opt_1kx10x0-16 32685486 113.2 ns/op 9191.22 MB/s Benchmark____GWs_Opt_1kx10x0-16 32076901 116.6 ns/op 8917.81 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23898163 141.4 ns/op 14596.93 MB/s Benchmark____GWs_Opt_2kx10x0-16 23755618 152.0 ns/op 13582.62 MB/s Benchmark____GWs_Opt_2kx10x0-16 25867984 139.4 ns/op 14805.11 MB/s Benchmark____GWs_Opt_2kx10x0-16 24974012 151.9 ns/op 13583.78 MB/s Benchmark____GWs_Opt_2kx10x0-16 21496453 141.8 ns/op 14551.46 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12450956 292.0 ns/op 14082.96 MB/s Benchmark____GWs_Opt_4kx10x0-16 12570924 286.5 ns/op 14352.19 MB/s Benchmark____GWs_Opt_4kx10x0-16 12234508 288.7 ns/op 14243.31 MB/s Benchmark____GWs_Opt_4kx10x0-16 12892704 285.9 ns/op 14382.05 MB/s Benchmark____GWs_Opt_4kx10x0-16 12895155 350.4 ns/op 11734.59 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6612954 551.7 ns/op 5664.46 MB/s Benchmark____GWs_Opt_1kx01x1-16 6249871 549.9 ns/op 5683.11 MB/s Benchmark____GWs_Opt_1kx01x1-16 6526116 552.3 ns/op 5658.23 MB/s Benchmark____GWs_Opt_1kx01x1-16 6454124 543.2 ns/op 5752.53 MB/s Benchmark____GWs_Opt_1kx01x1-16 6580531 553.0 ns/op 5650.86 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4574197 753.2 ns/op 8228.09 MB/s Benchmark____GWs_Opt_2kx01x1-16 4553456 850.7 ns/op 7284.43 MB/s Benchmark____GWs_Opt_2kx01x1-16 4711130 826.0 ns/op 7502.09 MB/s Benchmark____GWs_Opt_2kx01x1-16 4717110 766.7 ns/op 8082.65 MB/s Benchmark____GWs_Opt_2kx01x1-16 4519531 763.1 ns/op 8120.92 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2632124 1378 ns/op 8958.88 MB/s Benchmark____GWs_Opt_4kx01x1-16 2565133 1364 ns/op 9050.83 MB/s Benchmark____GWs_Opt_4kx01x1-16 2669224 1385 ns/op 8911.83 MB/s Benchmark____GWs_Opt_4kx01x1-16 2583188 1373 ns/op 8987.40 MB/s Benchmark____GWs_Opt_4kx01x1-16 2662976 1382 ns/op 8932.96 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6105830 555.3 ns/op 5627.21 MB/s Benchmark____GWs_Opt_1kx10x1-16 6116236 562.9 ns/op 5551.66 MB/s Benchmark____GWs_Opt_1kx10x1-16 6029217 560.3 ns/op 5577.18 MB/s Benchmark____GWs_Opt_1kx10x1-16 6106662 548.7 ns/op 5695.10 MB/s Benchmark____GWs_Opt_1kx10x1-16 6220886 552.1 ns/op 5660.07 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4155716 864.1 ns/op 7171.96 MB/s Benchmark____GWs_Opt_2kx10x1-16 4115944 846.2 ns/op 7323.65 MB/s Benchmark____GWs_Opt_2kx10x1-16 4115700 847.4 ns/op 7312.96 MB/s Benchmark____GWs_Opt_2kx10x1-16 3978376 853.4 ns/op 7261.48 MB/s Benchmark____GWs_Opt_2kx10x1-16 4105563 826.8 ns/op 7495.49 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2402996 1478 ns/op 8350.85 MB/s Benchmark____GWs_Opt_4kx10x1-16 2119862 1696 ns/op 7274.65 MB/s Benchmark____GWs_Opt_4kx10x1-16 2272950 1576 ns/op 7829.72 MB/s Benchmark____GWs_Opt_4kx10x1-16 2350198 1536 ns/op 8035.48 MB/s Benchmark____GWs_Opt_4kx10x1-16 2139970 1599 ns/op 7715.92 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12347816 280.4 ns/op 3708.40 MB/s Benchmark____GWs_Int_1kx01x0-16 12109527 286.1 ns/op 3635.24 MB/s Benchmark____GWs_Int_1kx01x0-16 12334372 296.9 ns/op 3503.15 MB/s Benchmark____GWs_Int_1kx01x0-16 12026047 293.5 ns/op 3543.23 MB/s Benchmark____GWs_Int_1kx01x0-16 11336253 286.4 ns/op 3630.87 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9269714 366.4 ns/op 5633.35 MB/s Benchmark____GWs_Int_2kx01x0-16 10339994 367.7 ns/op 5612.61 MB/s Benchmark____GWs_Int_2kx01x0-16 10180064 361.7 ns/op 5706.20 MB/s Benchmark____GWs_Int_2kx01x0-16 10091071 357.1 ns/op 5779.48 MB/s Benchmark____GWs_Int_2kx01x0-16 10033160 353.8 ns/op 5833.84 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5771809 626.3 ns/op 6566.04 MB/s Benchmark____GWs_Int_4kx01x0-16 5751193 636.1 ns/op 6464.00 MB/s Benchmark____GWs_Int_4kx01x0-16 5743273 726.5 ns/op 5660.18 MB/s Benchmark____GWs_Int_4kx01x0-16 5681524 644.3 ns/op 6382.37 MB/s Benchmark____GWs_Int_4kx01x0-16 5783229 644.0 ns/op 6385.52 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31313607 122.9 ns/op 8460.57 MB/s Benchmark____GWs_Int_1kx10x0-16 32366288 111.6 ns/op 9315.73 MB/s Benchmark____GWs_Int_1kx10x0-16 31025864 113.4 ns/op 9173.13 MB/s Benchmark____GWs_Int_1kx10x0-16 31762144 111.3 ns/op 9348.11 MB/s Benchmark____GWs_Int_1kx10x0-16 29629893 111.8 ns/op 9300.66 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25575004 137.4 ns/op 15020.40 MB/s Benchmark____GWs_Int_2kx10x0-16 25329129 159.3 ns/op 12959.94 MB/s Benchmark____GWs_Int_2kx10x0-16 25684852 139.1 ns/op 14842.84 MB/s Benchmark____GWs_Int_2kx10x0-16 24389134 154.4 ns/op 13364.02 MB/s Benchmark____GWs_Int_2kx10x0-16 26090750 152.0 ns/op 13581.50 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 10491764 305.0 ns/op 13480.78 MB/s Benchmark____GWs_Int_4kx10x0-16 13024119 280.2 ns/op 14676.20 MB/s Benchmark____GWs_Int_4kx10x0-16 10401168 325.8 ns/op 12622.78 MB/s Benchmark____GWs_Int_4kx10x0-16 13230158 276.7 ns/op 14863.09 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:35068->127.0.0.1:33945: 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:43072->127.0.0.1:46597: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6438532 555.5 ns/op 5625.59 MB/s Benchmark____GWs_Int_1kx01x1-16 6546584 555.2 ns/op 5629.05 MB/s Benchmark____GWs_Int_1kx01x1-16 6462777 563.4 ns/op 5546.98 MB/s Benchmark____GWs_Int_1kx01x1-16 6383748 553.5 ns/op 5645.39 MB/s Benchmark____GWs_Int_1kx01x1-16 6694300 550.7 ns/op 5674.50 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4223182 779.4 ns/op 7951.04 MB/s Benchmark____GWs_Int_2kx01x1-16 4582138 750.0 ns/op 8262.72 MB/s Benchmark____GWs_Int_2kx01x1-16 4728435 769.4 ns/op 8054.66 MB/s Benchmark____GWs_Int_2kx01x1-16 4706332 768.4 ns/op 8064.41 MB/s Benchmark____GWs_Int_2kx01x1-16 4720486 761.0 ns/op 8143.23 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2592890 1480 ns/op 8338.10 MB/s Benchmark____GWs_Int_4kx01x1-16 2670465 1365 ns/op 9044.15 MB/s Benchmark____GWs_Int_4kx01x1-16 2258214 1375 ns/op 8973.77 MB/s Benchmark____GWs_Int_4kx01x1-16 2466735 1379 ns/op 8948.75 MB/s Benchmark____GWs_Int_4kx01x1-16 2619704 1386 ns/op 8902.80 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6216687 560.9 ns/op 5571.30 MB/s Benchmark____GWs_Int_1kx10x1-16 6232998 565.8 ns/op 5522.98 MB/s Benchmark____GWs_Int_1kx10x1-16 6235971 964.6 ns/op 3239.72 MB/s Benchmark____GWs_Int_1kx10x1-16 6562268 561.6 ns/op 5564.43 MB/s Benchmark____GWs_Int_1kx10x1-16 6432962 560.8 ns/op 5572.01 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4044663 908.1 ns/op 6824.50 MB/s Benchmark____GWs_Int_2kx10x1-16 4104453 853.4 ns/op 7261.34 MB/s Benchmark____GWs_Int_2kx10x1-16 4215342 859.6 ns/op 7209.36 MB/s Benchmark____GWs_Int_2kx10x1-16 4161955 849.2 ns/op 7297.37 MB/s Benchmark____GWs_Int_2kx10x1-16 4099656 893.1 ns/op 6938.62 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2407702 1501 ns/op 8223.63 MB/s Benchmark____GWs_Int_4kx10x1-16 2295039 1558 ns/op 7921.12 MB/s Benchmark____GWs_Int_4kx10x1-16 2332494 1586 ns/op 7782.59 MB/s Benchmark____GWs_Int_4kx10x1-16 2359195 1514 ns/op 8153.18 MB/s Benchmark____GWs_Int_4kx10x1-16 2298600 1528 ns/op 8074.29 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8310723 432.2 ns/op 235.99 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8122118 458.6 ns/op 222.41 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8323093 441.4 ns/op 231.09 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8603127 431.0 ns/op 236.68 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8252107 425.9 ns/op 239.52 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 607359 5062 ns/op 34.97 MB/s Benchmark__GWs_Reqs_1SubEach-16 753613 5211 ns/op 33.97 MB/s Benchmark__GWs_Reqs_1SubEach-16 738433 5301 ns/op 33.39 MB/s Benchmark__GWs_Reqs_1SubEach-16 745298 5331 ns/op 33.20 MB/s Benchmark__GWs_Reqs_1SubEach-16 735903 5376 ns/op 32.92 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2093.838s ❌ Non-zero exit code: 1