> ROOT_DIR=/tmp/go-bench-away-job-be6941bd-9334-46ab-99e9-820afe9babb5-1722202577 > OUTPUT_FILE=/tmp/go-bench-away-job-be6941bd-9334-46ab-99e9-820afe9babb5-1722202577/results.txt > SHA_FILE=/tmp/go-bench-away-job-be6941bd-9334-46ab-99e9-820afe9babb5-1722202577/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-be6941bd-9334-46ab-99e9-820afe9babb5-1722202577/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-be6941bd-9334-46ab-99e9-820afe9babb5-1722202577/source.git SHA of main: db0a2c8ce3241df7dbc6cd730b989cfa05677068 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-build1193753657=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-be6941bd-9334-46ab-99e9-820afe9babb5-1722202577/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 48830662 73.57 ns/op 149.52 MB/s Benchmark______Pub0b_Payload-16 46437003 73.76 ns/op 149.14 MB/s Benchmark______Pub0b_Payload-16 46103646 73.48 ns/op 149.70 MB/s Benchmark______Pub0b_Payload-16 46366069 73.56 ns/op 149.53 MB/s Benchmark______Pub0b_Payload-16 43227300 73.40 ns/op 149.87 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45795216 73.96 ns/op 256.91 MB/s Benchmark______Pub8b_Payload-16 45613362 74.53 ns/op 254.94 MB/s Benchmark______Pub8b_Payload-16 45710952 74.16 ns/op 256.19 MB/s Benchmark______Pub8b_Payload-16 48574896 74.13 ns/op 256.29 MB/s Benchmark______Pub8b_Payload-16 45852166 74.55 ns/op 254.86 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43946046 79.44 ns/op 553.89 MB/s Benchmark_____Pub32b_Payload-16 43140121 78.65 ns/op 559.46 MB/s Benchmark_____Pub32b_Payload-16 45590259 78.55 ns/op 560.19 MB/s Benchmark_____Pub32b_Payload-16 43654360 79.95 ns/op 550.33 MB/s Benchmark_____Pub32b_Payload-16 39577712 78.41 ns/op 561.19 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38948478 88.57 ns/op 1591.91 MB/s Benchmark____Pub128B_Payload-16 38340956 91.91 ns/op 1534.13 MB/s Benchmark____Pub128B_Payload-16 39749508 87.80 ns/op 1605.85 MB/s Benchmark____Pub128B_Payload-16 37567524 88.15 ns/op 1599.59 MB/s Benchmark____Pub128B_Payload-16 34280247 96.28 ns/op 1464.47 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35009068 95.95 ns/op 2803.45 MB/s Benchmark____Pub256B_Payload-16 35662524 97.64 ns/op 2755.06 MB/s Benchmark____Pub256B_Payload-16 31132896 96.81 ns/op 2778.63 MB/s Benchmark____Pub256B_Payload-16 34880558 96.35 ns/op 2791.95 MB/s Benchmark____Pub256B_Payload-16 35504061 96.10 ns/op 2799.24 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 22847156 137.7 ns/op 7539.89 MB/s Benchmark______Pub1K_Payload-16 25292439 145.8 ns/op 7117.88 MB/s Benchmark______Pub1K_Payload-16 23339802 142.5 ns/op 7285.80 MB/s Benchmark______Pub1K_Payload-16 25141143 156.5 ns/op 6633.05 MB/s Benchmark______Pub1K_Payload-16 23483778 154.7 ns/op 6709.52 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5322054 619.5 ns/op 6634.08 MB/s Benchmark______Pub4K_Payload-16 5470460 610.4 ns/op 6733.71 MB/s Benchmark______Pub4K_Payload-16 5440574 620.2 ns/op 6626.87 MB/s Benchmark______Pub4K_Payload-16 5699439 627.7 ns/op 6548.14 MB/s Benchmark______Pub4K_Payload-16 5335606 611.9 ns/op 6716.26 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2666889 1274 ns/op 6440.67 MB/s Benchmark______Pub8K_Payload-16 2763176 1275 ns/op 6436.39 MB/s Benchmark______Pub8K_Payload-16 2759206 1276 ns/op 6428.88 MB/s Benchmark______Pub8K_Payload-16 2764393 1277 ns/op 6428.29 MB/s Benchmark______Pub8K_Payload-16 2745549 1272 ns/op 6451.32 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 488660 6567 ns/op 4992.28 MB/s Benchmark_____Pub32K_Payload-16 664768 5460 ns/op 6004.73 MB/s Benchmark_____Pub32K_Payload-16 598460 5438 ns/op 6028.72 MB/s Benchmark_____Pub32K_Payload-16 658129 5563 ns/op 5893.33 MB/s Benchmark_____Pub32K_Payload-16 659788 5480 ns/op 5981.87 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31531857 96.08 ns/op 114.49 MB/s Benchmark__AuthPub0b_Payload-16 35102362 96.09 ns/op 114.47 MB/s Benchmark__AuthPub0b_Payload-16 35408952 98.36 ns/op 111.83 MB/s Benchmark__AuthPub0b_Payload-16 35547603 95.87 ns/op 114.74 MB/s Benchmark__AuthPub0b_Payload-16 34706925 96.40 ns/op 114.11 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15527349 227.3 ns/op Benchmark_____________PubSub-16 15252271 229.6 ns/op Benchmark_____________PubSub-16 15624783 227.1 ns/op Benchmark_____________PubSub-16 15662530 227.6 ns/op Benchmark_____________PubSub-16 15613537 228.8 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15707971 225.1 ns/op Benchmark_____PubSubTwoConns-16 15656706 226.6 ns/op Benchmark_____PubSubTwoConns-16 15752532 225.3 ns/op Benchmark_____PubSubTwoConns-16 15574179 227.4 ns/op Benchmark_____PubSubTwoConns-16 15768247 225.9 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34172->127.0.0.1:39441: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43388->127.0.0.1:37159: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:60380->127.0.0.1:34233: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57960->127.0.0.1:40115: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:44066->127.0.0.1:45217: 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 14479330 244.6 ns/op Benchmark_____PubTwoQueueSub-16 14596407 245.1 ns/op Benchmark_____PubTwoQueueSub-16 14297611 245.5 ns/op Benchmark_____PubTwoQueueSub-16 14397390 245.6 ns/op Benchmark_____PubTwoQueueSub-16 14585066 245.5 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14421746 245.5 ns/op Benchmark____PubFourQueueSub-16 14366360 245.3 ns/op Benchmark____PubFourQueueSub-16 14375488 245.0 ns/op Benchmark____PubFourQueueSub-16 14312838 245.2 ns/op Benchmark____PubFourQueueSub-16 14305690 245.6 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14389046 246.1 ns/op Benchmark___PubEightQueueSub-16 14589363 246.0 ns/op Benchmark___PubEightQueueSub-16 14495535 246.1 ns/op Benchmark___PubEightQueueSub-16 14462443 245.9 ns/op Benchmark___PubEightQueueSub-16 14387240 246.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22954 156440 ns/op Benchmark_PubSub512kTwoConns-16 22995 156094 ns/op Benchmark_PubSub512kTwoConns-16 23058 156044 ns/op Benchmark_PubSub512kTwoConns-16 23049 155107 ns/op Benchmark_PubSub512kTwoConns-16 23180 156579 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14948145 228.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15111704 229.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15297798 229.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15242366 229.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 15221335 229.2 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15183596 230.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15402226 229.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15243814 230.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15306202 229.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15205641 231.2 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11270920 316.4 ns/op Benchmark____RoutedPubSub_0b-16 11412198 322.8 ns/op Benchmark____RoutedPubSub_0b-16 10955050 318.9 ns/op Benchmark____RoutedPubSub_0b-16 10955979 318.1 ns/op Benchmark____RoutedPubSub_0b-16 10965806 318.5 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6521560 537.1 ns/op Benchmark____RoutedPubSub_1K-16 6616075 536.8 ns/op Benchmark____RoutedPubSub_1K-16 6629365 539.7 ns/op Benchmark____RoutedPubSub_1K-16 6491316 535.6 ns/op Benchmark____RoutedPubSub_1K-16 6725733 544.4 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85197 41416 ns/op Benchmark__RoutedPubSub_100K-16 87055 42428 ns/op Benchmark__RoutedPubSub_100K-16 80554 43885 ns/op Benchmark__RoutedPubSub_100K-16 80114 45856 ns/op Benchmark__RoutedPubSub_100K-16 79935 43452 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9956534 311.3 ns/op Benchmark____Routed2QueueSub-16 9620613 332.9 ns/op Benchmark____Routed2QueueSub-16 9763095 324.4 ns/op Benchmark____Routed2QueueSub-16 9813290 332.3 ns/op Benchmark____Routed2QueueSub-16 9712563 323.6 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9362022 329.8 ns/op Benchmark____Routed4QueueSub-16 9455450 330.3 ns/op Benchmark____Routed4QueueSub-16 11167380 317.7 ns/op Benchmark____Routed4QueueSub-16 9491282 323.8 ns/op Benchmark____Routed4QueueSub-16 9519376 326.3 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9233872 336.8 ns/op Benchmark____Routed8QueueSub-16 9334518 332.4 ns/op Benchmark____Routed8QueueSub-16 9259514 329.3 ns/op Benchmark____Routed8QueueSub-16 9304010 330.0 ns/op Benchmark____Routed8QueueSub-16 9034795 337.4 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8767185 349.0 ns/op Benchmark___Routed16QueueSub-16 8825661 346.1 ns/op Benchmark___Routed16QueueSub-16 8749573 348.4 ns/op Benchmark___Routed16QueueSub-16 10511568 346.2 ns/op Benchmark___Routed16QueueSub-16 8757771 348.5 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6215971 559.4 ns/op Benchmark____________RouteCompressOff-16 6439274 555.9 ns/op Benchmark____________RouteCompressOff-16 6156028 556.9 ns/op Benchmark____________RouteCompressOff-16 6565814 557.6 ns/op Benchmark____________RouteCompressOff-16 6245995 562.1 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6339744 564.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6438786 548.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6246270 558.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6183522 553.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6506617 558.8 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6291693 562.3 ns/op Benchmark_________RouteCompressS2Fast-16 6275948 553.5 ns/op Benchmark_________RouteCompressS2Fast-16 6382248 558.7 ns/op Benchmark_________RouteCompressS2Fast-16 6325788 554.0 ns/op Benchmark_________RouteCompressS2Fast-16 6332624 560.7 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6391539 560.1 ns/op Benchmark_______RouteCompressS2Better-16 6228122 552.5 ns/op Benchmark_______RouteCompressS2Better-16 7158406 550.1 ns/op Benchmark_______RouteCompressS2Better-16 6287419 554.6 ns/op Benchmark_______RouteCompressS2Better-16 6533109 557.5 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6399517 550.0 ns/op Benchmark_________RouteCompressS2Best-16 6399534 555.2 ns/op Benchmark_________RouteCompressS2Best-16 6295670 556.1 ns/op Benchmark_________RouteCompressS2Best-16 6310928 555.0 ns/op Benchmark_________RouteCompressS2Best-16 6341538 561.6 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4645032 770.3 ns/op 323.25 MB/s Benchmark______FanOut_8x1x10-16 4626360 776.4 ns/op 320.73 MB/s Benchmark______FanOut_8x1x10-16 4630604 769.0 ns/op 323.81 MB/s Benchmark______FanOut_8x1x10-16 4625630 769.9 ns/op 323.43 MB/s Benchmark______FanOut_8x1x10-16 4649860 774.4 ns/op 321.56 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 554168 6093 ns/op 380.63 MB/s Benchmark_____FanOut_8x1x100-16 546265 6082 ns/op 381.31 MB/s Benchmark_____FanOut_8x1x100-16 592460 6118 ns/op 379.07 MB/s Benchmark_____FanOut_8x1x100-16 544177 6086 ns/op 381.06 MB/s Benchmark_____FanOut_8x1x100-16 552494 6087 ns/op 381.00 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48394 74484 ns/op 309.05 MB/s Benchmark____FanOut_8x10x100-16 48190 74720 ns/op 308.07 MB/s Benchmark____FanOut_8x10x100-16 48204 74276 ns/op 309.91 MB/s Benchmark____FanOut_8x10x100-16 48068 74361 ns/op 309.56 MB/s Benchmark____FanOut_8x10x100-16 48265 75330 ns/op 305.57 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5930 594032 ns/op 404.05 MB/s Benchmark___FanOut_8x10x1000-16 5953 595717 ns/op 402.91 MB/s Benchmark___FanOut_8x10x1000-16 6069 595871 ns/op 402.80 MB/s Benchmark___FanOut_8x10x1000-16 5708 594656 ns/op 403.63 MB/s Benchmark___FanOut_8x10x1000-16 6130 600329 ns/op 399.81 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4976 705466 ns/op 326.05 MB/s Benchmark___FanOut_8x100x100-16 5028 704947 ns/op 326.29 MB/s Benchmark___FanOut_8x100x100-16 5040 705606 ns/op 325.99 MB/s Benchmark___FanOut_8x100x100-16 4990 704936 ns/op 326.30 MB/s Benchmark___FanOut_8x100x100-16 5023 705996 ns/op 325.81 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 561 6113756 ns/op 392.56 MB/s Benchmark__FanOut_8x100x1000-16 583 6127778 ns/op 391.66 MB/s Benchmark__FanOut_8x100x1000-16 579 6127242 ns/op 391.70 MB/s Benchmark__FanOut_8x100x1000-16 579 6101453 ns/op 393.35 MB/s Benchmark__FanOut_8x100x1000-16 582 6076543 ns/op 394.96 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 535 6761618 ns/op 369.74 MB/s Benchmark__FanOut_8x10x10000-16 526 6876779 ns/op 363.55 MB/s Benchmark__FanOut_8x10x10000-16 528 6694939 ns/op 373.42 MB/s Benchmark__FanOut_8x10x10000-16 523 6635341 ns/op 376.77 MB/s Benchmark__FanOut_8x10x10000-16 534 6723577 ns/op 371.83 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 957 3780300 ns/op 304.21 MB/s Benchmark___FanOut_8x500x100-16 950 3744109 ns/op 307.15 MB/s Benchmark___FanOut_8x500x100-16 945 3755050 ns/op 306.26 MB/s Benchmark___FanOut_8x500x100-16 946 3754616 ns/op 306.29 MB/s Benchmark___FanOut_8x500x100-16 943 3736444 ns/op 307.78 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 363136 9492 ns/op 1542.49 MB/s Benchmark___FanOut_128x1x100-16 363262 9475 ns/op 1545.27 MB/s Benchmark___FanOut_128x1x100-16 365887 9501 ns/op 1541.01 MB/s Benchmark___FanOut_128x1x100-16 370689 9443 ns/op 1550.48 MB/s Benchmark___FanOut_128x1x100-16 354778 9484 ns/op 1543.82 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32407 111025 ns/op 1307.29 MB/s Benchmark__FanOut_128x10x100-16 32664 110692 ns/op 1311.22 MB/s Benchmark__FanOut_128x10x100-16 32737 109975 ns/op 1319.76 MB/s Benchmark__FanOut_128x10x100-16 32463 109975 ns/op 1319.76 MB/s Benchmark__FanOut_128x10x100-16 32614 110156 ns/op 1317.59 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4117 867651 ns/op 1682.87 MB/s Benchmark_FanOut_128x10x1000-16 4066 870963 ns/op 1676.47 MB/s Benchmark_FanOut_128x10x1000-16 4011 873552 ns/op 1671.50 MB/s Benchmark_FanOut_128x10x1000-16 4041 867626 ns/op 1682.92 MB/s Benchmark_FanOut_128x10x1000-16 3938 875130 ns/op 1668.48 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3416 1006997 ns/op 1440.06 MB/s Benchmark_FanOut_128x100x100-16 3620 1012260 ns/op 1432.58 MB/s Benchmark_FanOut_128x100x100-16 3534 1007894 ns/op 1438.78 MB/s Benchmark_FanOut_128x100x100-16 3559 1017457 ns/op 1425.26 MB/s Benchmark_FanOut_128x100x100-16 3476 1011518 ns/op 1433.63 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 386 9240905 ns/op 1579.95 MB/s BenchmarkFanOut_128x100x1000-16 388 9268034 ns/op 1575.32 MB/s BenchmarkFanOut_128x100x1000-16 392 9466236 ns/op 1542.34 MB/s BenchmarkFanOut_128x100x1000-16 384 9209072 ns/op 1585.41 MB/s BenchmarkFanOut_128x100x1000-16 380 9253476 ns/op 1577.80 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 375 9655011 ns/op 1522.54 MB/s BenchmarkFanOut_128x10x10000-16 374 9569310 ns/op 1536.18 MB/s BenchmarkFanOut_128x10x10000-16 372 9641579 ns/op 1524.66 MB/s BenchmarkFanOut_128x10x10000-16 372 9582597 ns/op 1534.05 MB/s BenchmarkFanOut_128x10x10000-16 372 9612299 ns/op 1529.31 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 673 5242451 ns/op 1382.97 MB/s BenchmarkFanOut__128x500x100-16 680 5242445 ns/op 1382.97 MB/s BenchmarkFanOut__128x500x100-16 676 5246450 ns/op 1381.91 MB/s BenchmarkFanOut__128x500x100-16 668 5313589 ns/op 1364.45 MB/s BenchmarkFanOut__128x500x100-16 681 5273905 ns/op 1374.72 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1941 1841840 ns/op 2872.41 MB/s Benchmark_FanOut_512x100x100-16 1951 1837545 ns/op 2879.13 MB/s Benchmark_FanOut_512x100x100-16 1939 1833176 ns/op 2885.99 MB/s Benchmark_FanOut_512x100x100-16 1962 1827306 ns/op 2895.26 MB/s Benchmark_FanOut_512x100x100-16 1936 1841258 ns/op 2873.32 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 217 16760187 ns/op 3162.29 MB/s Benchmark__FanOut_512x100x1k-16 213 16676076 ns/op 3178.24 MB/s Benchmark__FanOut_512x100x1k-16 216 16761290 ns/op 3162.08 MB/s Benchmark__FanOut_512x100x1k-16 217 16633549 ns/op 3186.36 MB/s Benchmark__FanOut_512x100x1k-16 216 16591523 ns/op 3194.43 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3001 1130361 ns/op 9228.06 MB/s Benchmark____FanOut_1kx10x1k-16 3129 1152721 ns/op 9049.06 MB/s Benchmark____FanOut_1kx10x1k-16 3110 1125047 ns/op 9271.64 MB/s Benchmark____FanOut_1kx10x1k-16 2948 1146288 ns/op 9099.84 MB/s Benchmark____FanOut_1kx10x1k-16 3271 1151018 ns/op 9062.44 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2844 1249688 ns/op 8338.91 MB/s Benchmark__FanOut_1kx100x100-16 2814 1261284 ns/op 8262.24 MB/s Benchmark__FanOut_1kx100x100-16 2722 1245929 ns/op 8364.07 MB/s Benchmark__FanOut_1kx100x100-16 2808 1248832 ns/op 8344.63 MB/s Benchmark__FanOut_1kx100x100-16 2793 1253110 ns/op 8316.14 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4291978 775.5 ns/op 321.07 MB/s Benchmark_____RFanOut_8x1x10-16 4531770 768.8 ns/op 323.89 MB/s Benchmark_____RFanOut_8x1x10-16 4360468 775.0 ns/op 321.29 MB/s Benchmark_____RFanOut_8x1x10-16 4575866 782.7 ns/op 318.14 MB/s Benchmark_____RFanOut_8x1x10-16 4542650 785.3 ns/op 317.07 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 532741 6156 ns/op 376.70 MB/s Benchmark____RFanOut_8x1x100-16 569830 6146 ns/op 377.34 MB/s Benchmark____RFanOut_8x1x100-16 540268 6108 ns/op 379.66 MB/s Benchmark____RFanOut_8x1x100-16 516286 6264 ns/op 370.24 MB/s Benchmark____RFanOut_8x1x100-16 520195 6052 ns/op 383.18 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48412 73887 ns/op 311.54 MB/s Benchmark___RFanOut_8x10x100-16 48309 73843 ns/op 311.73 MB/s Benchmark___RFanOut_8x10x100-16 48399 73640 ns/op 312.59 MB/s Benchmark___RFanOut_8x10x100-16 48729 73488 ns/op 313.24 MB/s Benchmark___RFanOut_8x10x100-16 48657 73630 ns/op 312.63 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5947 586679 ns/op 409.11 MB/s Benchmark__RFanOut_8x10x1000-16 5887 587602 ns/op 408.47 MB/s Benchmark__RFanOut_8x10x1000-16 5994 587340 ns/op 408.65 MB/s Benchmark__RFanOut_8x10x1000-16 5866 585890 ns/op 409.67 MB/s Benchmark__RFanOut_8x10x1000-16 5962 594733 ns/op 403.57 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5143 696927 ns/op 330.05 MB/s Benchmark__RFanOut_8x100x100-16 5048 697974 ns/op 329.55 MB/s Benchmark__RFanOut_8x100x100-16 5138 696149 ns/op 330.42 MB/s Benchmark__RFanOut_8x100x100-16 5077 696257 ns/op 330.37 MB/s Benchmark__RFanOut_8x100x100-16 5184 695418 ns/op 330.76 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 591 6043617 ns/op 397.12 MB/s Benchmark_RFanOut_8x100x1000-16 580 5995912 ns/op 400.28 MB/s Benchmark_RFanOut_8x100x1000-16 588 5986834 ns/op 400.88 MB/s Benchmark_RFanOut_8x100x1000-16 584 6023114 ns/op 398.47 MB/s Benchmark_RFanOut_8x100x1000-16 594 6014214 ns/op 399.06 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 550 6529403 ns/op 382.89 MB/s Benchmark_RFanOut_8x10x10000-16 541 6687990 ns/op 373.81 MB/s Benchmark_RFanOut_8x10x10000-16 537 6580577 ns/op 379.91 MB/s Benchmark_RFanOut_8x10x10000-16 536 6560955 ns/op 381.04 MB/s Benchmark_RFanOut_8x10x10000-16 543 6578989 ns/op 380.00 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3219 1134829 ns/op 9191.72 MB/s Benchmark_RFanOut_1kx10x1000-16 2690 1165001 ns/op 8953.67 MB/s Benchmark_RFanOut_1kx10x1000-16 3132 1141245 ns/op 9140.05 MB/s Benchmark_RFanOut_1kx10x1000-16 2792 1163423 ns/op 8965.82 MB/s Benchmark_RFanOut_1kx10x1000-16 3052 1120803 ns/op 9306.75 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6970878 504.2 ns/op 4121.23 MB/s Benchmark_____FanIn_1kx100x1-16 6944526 504.4 ns/op 4119.57 MB/s Benchmark_____FanIn_1kx100x1-16 6981949 504.5 ns/op 4118.66 MB/s Benchmark_____FanIn_1kx100x1-16 6934264 506.7 ns/op 4101.19 MB/s Benchmark_____FanIn_1kx100x1-16 6990139 506.7 ns/op 4101.44 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2615629 1369 ns/op 6006.09 MB/s Benchmark_____FanIn_4kx100x1-16 2667907 1350 ns/op 6091.00 MB/s Benchmark_____FanIn_4kx100x1-16 2600871 1389 ns/op 5918.45 MB/s Benchmark_____FanIn_4kx100x1-16 2648823 1362 ns/op 6036.71 MB/s Benchmark_____FanIn_4kx100x1-16 2633670 1357 ns/op 6057.05 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1697188 2112 ns/op 7772.31 MB/s Benchmark_____FanIn_8kx100x1-16 1543170 2123 ns/op 7732.26 MB/s Benchmark_____FanIn_8kx100x1-16 1700660 2151 ns/op 7630.75 MB/s Benchmark_____FanIn_8kx100x1-16 1707284 2135 ns/op 7686.85 MB/s Benchmark_____FanIn_8kx100x1-16 1692910 2105 ns/op 7797.80 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 861522 4126 ns/op 7948.82 MB/s Benchmark____FanIn_16kx100x1-16 859603 4172 ns/op 7861.77 MB/s Benchmark____FanIn_16kx100x1-16 866856 4225 ns/op 7763.73 MB/s Benchmark____FanIn_16kx100x1-16 864793 4138 ns/op 7926.20 MB/s Benchmark____FanIn_16kx100x1-16 865417 4143 ns/op 7917.78 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 314654400 vs 11530772700 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55614->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:56132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56162->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 164878 19852 ns/op 6604.11 MB/s Benchmark____FanIn_64kx100x1-16 166513 19659 ns/op 6668.78 MB/s Benchmark____FanIn_64kx100x1-16 172124 19879 ns/op 6595.17 MB/s Benchmark____FanIn_64kx100x1-16 169350 20008 ns/op 6552.45 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 178544580 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43926->127.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:44538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44060->127.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:44742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44098->127.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:44596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44198->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: 869388880 vs 11404830000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47286->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46764->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47380->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:47030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47356->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: 445837090 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48618->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:49302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48698->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: 642472090 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50792->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: 639588110 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52828->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52640->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52590->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5554730 640.8 ns/op 443.18 MB/s Benchmark___BumpPubCount_1x3-16 5630730 637.9 ns/op 445.20 MB/s Benchmark___BumpPubCount_1x3-16 5552529 642.3 ns/op 442.18 MB/s Benchmark___BumpPubCount_1x3-16 5634813 640.5 ns/op 443.37 MB/s Benchmark___BumpPubCount_1x3-16 5552125 640.9 ns/op 443.09 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5302362 679.8 ns/op 417.74 MB/s Benchmark___BumpPubCount_2x3-16 5227932 676.8 ns/op 419.63 MB/s Benchmark___BumpPubCount_2x3-16 5291239 677.1 ns/op 419.44 MB/s Benchmark___BumpPubCount_2x3-16 5350274 673.1 ns/op 421.92 MB/s Benchmark___BumpPubCount_2x3-16 5279839 673.9 ns/op 421.46 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5548407 647.8 ns/op 438.39 MB/s Benchmark___BumpPubCount_5x3-16 5382717 646.5 ns/op 439.28 MB/s Benchmark___BumpPubCount_5x3-16 5391758 647.9 ns/op 438.34 MB/s Benchmark___BumpPubCount_5x3-16 5558410 648.4 ns/op 438.03 MB/s Benchmark___BumpPubCount_5x3-16 5554644 643.8 ns/op 441.12 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5534127 648.9 ns/op 437.64 MB/s Benchmark__BumpPubCount_10x3-16 5541249 647.8 ns/op 438.44 MB/s Benchmark__BumpPubCount_10x3-16 5521292 647.6 ns/op 438.54 MB/s Benchmark__BumpPubCount_10x3-16 5539048 647.3 ns/op 438.75 MB/s Benchmark__BumpPubCount_10x3-16 5535816 648.2 ns/op 438.12 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12047967 274.6 ns/op 3787.11 MB/s Benchmark____GWs_Opt_1kx01x0-16 12279741 276.0 ns/op 3768.71 MB/s Benchmark____GWs_Opt_1kx01x0-16 11652526 277.4 ns/op 3749.06 MB/s Benchmark____GWs_Opt_1kx01x0-16 12590870 277.3 ns/op 3749.98 MB/s Benchmark____GWs_Opt_1kx01x0-16 12420807 270.5 ns/op 3845.16 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10602061 350.6 ns/op 5887.20 MB/s Benchmark____GWs_Opt_2kx01x0-16 10152236 329.7 ns/op 6259.73 MB/s Benchmark____GWs_Opt_2kx01x0-16 9845340 343.3 ns/op 6011.90 MB/s Benchmark____GWs_Opt_2kx01x0-16 10442644 343.5 ns/op 6008.34 MB/s Benchmark____GWs_Opt_2kx01x0-16 9733950 339.3 ns/op 6082.33 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5730966 621.9 ns/op 6611.63 MB/s Benchmark____GWs_Opt_4kx01x0-16 5582461 620.4 ns/op 6628.24 MB/s Benchmark____GWs_Opt_4kx01x0-16 5622530 624.0 ns/op 6589.99 MB/s Benchmark____GWs_Opt_4kx01x0-16 5805508 611.2 ns/op 6727.31 MB/s Benchmark____GWs_Opt_4kx01x0-16 5579817 713.5 ns/op 5763.21 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28815700 113.5 ns/op 9161.32 MB/s Benchmark____GWs_Opt_1kx10x0-16 29657718 110.8 ns/op 9383.06 MB/s Benchmark____GWs_Opt_1kx10x0-16 28128304 125.5 ns/op 8285.85 MB/s Benchmark____GWs_Opt_1kx10x0-16 28780436 114.6 ns/op 9073.18 MB/s Benchmark____GWs_Opt_1kx10x0-16 28157517 111.7 ns/op 9312.63 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 18417351 167.8 ns/op 12303.18 MB/s Benchmark____GWs_Opt_2kx10x0-16 23887215 139.3 ns/op 14816.08 MB/s Benchmark____GWs_Opt_2kx10x0-16 22103937 141.5 ns/op 14590.48 MB/s Benchmark____GWs_Opt_2kx10x0-16 24404793 158.4 ns/op 13033.31 MB/s Benchmark____GWs_Opt_2kx10x0-16 24848989 605.1 ns/op 3411.15 MB/s Benchmark____GWs_Opt_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:39134->127.0.0.1:37413: 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:60306->127.0.0.1:42441: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 12888304 314.2 ns/op 13086.92 MB/s Benchmark____GWs_Opt_4kx10x0-16 11565195 283.3 ns/op 14513.78 MB/s Benchmark____GWs_Opt_4kx10x0-16 12446721 305.8 ns/op 13448.81 MB/s Benchmark____GWs_Opt_4kx10x0-16 12941367 310.5 ns/op 13243.70 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6447626 549.7 ns/op 5685.00 MB/s Benchmark____GWs_Opt_1kx01x1-16 6450168 545.8 ns/op 5725.36 MB/s Benchmark____GWs_Opt_1kx01x1-16 6632138 553.0 ns/op 5651.30 MB/s Benchmark____GWs_Opt_1kx01x1-16 6442166 549.1 ns/op 5690.86 MB/s Benchmark____GWs_Opt_1kx01x1-16 6432976 550.7 ns/op 5674.90 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4607882 1171 ns/op 5293.43 MB/s Benchmark____GWs_Opt_2kx01x1-16 4618186 770.1 ns/op 8046.75 MB/s Benchmark____GWs_Opt_2kx01x1-16 4650799 767.6 ns/op 8073.55 MB/s Benchmark____GWs_Opt_2kx01x1-16 4614638 763.6 ns/op 8115.42 MB/s Benchmark____GWs_Opt_2kx01x1-16 4662054 783.7 ns/op 7907.01 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2625482 1386 ns/op 8906.71 MB/s Benchmark____GWs_Opt_4kx01x1-16 2678377 1399 ns/op 8818.79 MB/s Benchmark____GWs_Opt_4kx01x1-16 2449503 3408 ns/op 3621.48 MB/s Benchmark____GWs_Opt_4kx01x1-16 2565968 1378 ns/op 8952.67 MB/s Benchmark____GWs_Opt_4kx01x1-16 2547392 1447 ns/op 8529.74 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6600094 560.5 ns/op 5575.13 MB/s Benchmark____GWs_Opt_1kx10x1-16 6518950 554.6 ns/op 5635.17 MB/s Benchmark____GWs_Opt_1kx10x1-16 6193480 542.6 ns/op 5759.78 MB/s Benchmark____GWs_Opt_1kx10x1-16 6571964 559.1 ns/op 5589.29 MB/s Benchmark____GWs_Opt_1kx10x1-16 6360513 559.2 ns/op 5588.67 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4019716 842.3 ns/op 7356.87 MB/s Benchmark____GWs_Opt_2kx10x1-16 4136666 854.5 ns/op 7252.56 MB/s Benchmark____GWs_Opt_2kx10x1-16 4096928 852.0 ns/op 7273.81 MB/s Benchmark____GWs_Opt_2kx10x1-16 4104708 840.1 ns/op 7376.73 MB/s Benchmark____GWs_Opt_2kx10x1-16 4015947 848.2 ns/op 7306.30 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2262462 1551 ns/op 7958.09 MB/s Benchmark____GWs_Opt_4kx10x1-16 2280506 1546 ns/op 7981.00 MB/s Benchmark____GWs_Opt_4kx10x1-16 2419429 1531 ns/op 8060.22 MB/s Benchmark____GWs_Opt_4kx10x1-16 2353201 1555 ns/op 7935.22 MB/s Benchmark____GWs_Opt_4kx10x1-16 2200666 1542 ns/op 8002.72 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11156722 286.6 ns/op 3628.37 MB/s Benchmark____GWs_Int_1kx01x0-16 12579788 296.7 ns/op 3505.57 MB/s Benchmark____GWs_Int_1kx01x0-16 12780762 290.9 ns/op 3574.57 MB/s Benchmark____GWs_Int_1kx01x0-16 12459736 282.2 ns/op 3685.41 MB/s Benchmark____GWs_Int_1kx01x0-16 12464000 283.3 ns/op 3671.19 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10243982 360.4 ns/op 5727.01 MB/s Benchmark____GWs_Int_2kx01x0-16 10252203 370.7 ns/op 5567.29 MB/s Benchmark____GWs_Int_2kx01x0-16 10063525 368.4 ns/op 5602.03 MB/s Benchmark____GWs_Int_2kx01x0-16 10268724 361.7 ns/op 5705.74 MB/s Benchmark____GWs_Int_2kx01x0-16 10015244 359.1 ns/op 5747.79 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5642714 632.7 ns/op 6499.58 MB/s Benchmark____GWs_Int_4kx01x0-16 5764039 645.3 ns/op 6372.46 MB/s Benchmark____GWs_Int_4kx01x0-16 5101639 637.8 ns/op 6446.70 MB/s Benchmark____GWs_Int_4kx01x0-16 5961940 629.0 ns/op 6537.14 MB/s Benchmark____GWs_Int_4kx01x0-16 5595126 639.6 ns/op 6429.14 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31948713 129.8 ns/op 8010.41 MB/s Benchmark____GWs_Int_1kx10x0-16 31009788 111.1 ns/op 9361.75 MB/s Benchmark____GWs_Int_1kx10x0-16 27485002 112.7 ns/op 9227.10 MB/s Benchmark____GWs_Int_1kx10x0-16 30452926 110.6 ns/op 9405.06 MB/s Benchmark____GWs_Int_1kx10x0-16 31696737 109.6 ns/op 9486.45 MB/s Benchmark____GWs_Int_2kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:42034->127.0.0.1:43959: 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:48986->127.0.0.1:44589: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 26272899 644.5 ns/op 3202.71 MB/s Benchmark____GWs_Int_2kx10x0-16 26070943 146.1 ns/op 14123.18 MB/s Benchmark____GWs_Int_2kx10x0-16 25127624 143.3 ns/op 14403.18 MB/s Benchmark____GWs_Int_2kx10x0-16 25186718 140.5 ns/op 14687.53 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11265288 326.8 ns/op 12583.71 MB/s Benchmark____GWs_Int_4kx10x0-16 11253247 303.8 ns/op 13535.69 MB/s Benchmark____GWs_Int_4kx10x0-16 13176553 279.2 ns/op 14726.27 MB/s Benchmark____GWs_Int_4kx10x0-16 13370304 287.9 ns/op 14281.25 MB/s Benchmark____GWs_Int_4kx10x0-16 13276040 290.0 ns/op 14177.62 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6228450 557.0 ns/op 5610.12 MB/s Benchmark____GWs_Int_1kx01x1-16 6643465 564.4 ns/op 5536.76 MB/s Benchmark____GWs_Int_1kx01x1-16 6204673 551.1 ns/op 5670.56 MB/s Benchmark____GWs_Int_1kx01x1-16 6344233 556.4 ns/op 5616.51 MB/s Benchmark____GWs_Int_1kx01x1-16 6265263 557.4 ns/op 5606.55 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4640656 766.2 ns/op 8087.67 MB/s Benchmark____GWs_Int_2kx01x1-16 4630987 803.4 ns/op 7713.35 MB/s Benchmark____GWs_Int_2kx01x1-16 4657880 769.7 ns/op 8050.91 MB/s Benchmark____GWs_Int_2kx01x1-16 4737650 777.2 ns/op 7973.87 MB/s Benchmark____GWs_Int_2kx01x1-16 4714440 760.6 ns/op 8147.60 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2559230 1386 ns/op 8905.98 MB/s Benchmark____GWs_Int_4kx01x1-16 2668550 1367 ns/op 9025.28 MB/s Benchmark____GWs_Int_4kx01x1-16 2632015 1407 ns/op 8773.87 MB/s Benchmark____GWs_Int_4kx01x1-16 2570823 1395 ns/op 8845.03 MB/s Benchmark____GWs_Int_4kx01x1-16 2333514 1398 ns/op 8828.09 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6590175 558.4 ns/op 5596.57 MB/s Benchmark____GWs_Int_1kx10x1-16 6307737 562.8 ns/op 5553.07 MB/s Benchmark____GWs_Int_1kx10x1-16 6561168 560.6 ns/op 5574.18 MB/s Benchmark____GWs_Int_1kx10x1-16 6476966 558.7 ns/op 5593.79 MB/s Benchmark____GWs_Int_1kx10x1-16 6349556 565.2 ns/op 5528.84 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 3846146 842.1 ns/op 7358.60 MB/s Benchmark____GWs_Int_2kx10x1-16 4126870 850.1 ns/op 7289.71 MB/s Benchmark____GWs_Int_2kx10x1-16 4278295 838.3 ns/op 7392.11 MB/s Benchmark____GWs_Int_2kx10x1-16 4207015 848.3 ns/op 7305.40 MB/s Benchmark____GWs_Int_2kx10x1-16 4032861 906.8 ns/op 6833.57 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2356705 1587 ns/op 7776.85 MB/s Benchmark____GWs_Int_4kx10x1-16 2513894 1504 ns/op 8203.20 MB/s Benchmark____GWs_Int_4kx10x1-16 2259696 1543 ns/op 7998.28 MB/s Benchmark____GWs_Int_4kx10x1-16 2149924 1532 ns/op 8053.65 MB/s Benchmark____GWs_Int_4kx10x1-16 2371893 1444 ns/op 8546.48 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8055540 442.3 ns/op 230.64 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8100000 438.7 ns/op 232.48 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8017161 444.6 ns/op 229.44 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7871354 443.8 ns/op 229.83 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7988059 439.1 ns/op 232.28 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 627339 5041 ns/op 35.11 MB/s Benchmark__GWs_Reqs_1SubEach-16 787527 5240 ns/op 33.78 MB/s Benchmark__GWs_Reqs_1SubEach-16 741199 5259 ns/op 33.66 MB/s Benchmark__GWs_Reqs_1SubEach-16 726800 5282 ns/op 33.51 MB/s Benchmark__GWs_Reqs_1SubEach-16 710286 5304 ns/op 33.37 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2136.411s ❌ Non-zero exit code: 1