> ROOT_DIR=/tmp/go-bench-away-job-010a4605-cff6-4375-9b1f-a4154673e1e5-3671501657 > OUTPUT_FILE=/tmp/go-bench-away-job-010a4605-cff6-4375-9b1f-a4154673e1e5-3671501657/results.txt > SHA_FILE=/tmp/go-bench-away-job-010a4605-cff6-4375-9b1f-a4154673e1e5-3671501657/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-010a4605-cff6-4375-9b1f-a4154673e1e5-3671501657/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-010a4605-cff6-4375-9b1f-a4154673e1e5-3671501657/source.git SHA of main: 050df88d3fb7e968ef8acf02b3ea092d439881c3 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-build2317313311=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-010a4605-cff6-4375-9b1f-a4154673e1e5-3671501657/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 49095891 73.50 ns/op 149.67 MB/s Benchmark______Pub0b_Payload-16 46718480 73.37 ns/op 149.92 MB/s Benchmark______Pub0b_Payload-16 46221729 74.31 ns/op 148.02 MB/s Benchmark______Pub0b_Payload-16 46493866 73.35 ns/op 149.97 MB/s Benchmark______Pub0b_Payload-16 41296726 73.57 ns/op 149.53 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46174322 74.05 ns/op 256.57 MB/s Benchmark______Pub8b_Payload-16 42648832 74.20 ns/op 256.07 MB/s Benchmark______Pub8b_Payload-16 43603423 76.16 ns/op 249.47 MB/s Benchmark______Pub8b_Payload-16 45809088 74.34 ns/op 255.58 MB/s Benchmark______Pub8b_Payload-16 43424683 74.03 ns/op 256.64 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43606498 78.06 ns/op 563.64 MB/s Benchmark_____Pub32b_Payload-16 43436064 82.33 ns/op 534.45 MB/s Benchmark_____Pub32b_Payload-16 43645622 78.23 ns/op 562.42 MB/s Benchmark_____Pub32b_Payload-16 43350777 78.29 ns/op 561.99 MB/s Benchmark_____Pub32b_Payload-16 46093370 78.15 ns/op 563.00 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39090204 87.18 ns/op 1617.31 MB/s Benchmark____Pub128B_Payload-16 41045173 94.39 ns/op 1493.82 MB/s Benchmark____Pub128B_Payload-16 38487439 93.55 ns/op 1507.22 MB/s Benchmark____Pub128B_Payload-16 37491321 89.02 ns/op 1583.94 MB/s Benchmark____Pub128B_Payload-16 39115329 93.20 ns/op 1512.84 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 34233211 95.72 ns/op 2810.30 MB/s Benchmark____Pub256B_Payload-16 31906858 104.3 ns/op 2579.93 MB/s Benchmark____Pub256B_Payload-16 35899801 98.36 ns/op 2734.76 MB/s Benchmark____Pub256B_Payload-16 37802004 96.34 ns/op 2792.26 MB/s Benchmark____Pub256B_Payload-16 35250392 94.64 ns/op 2842.42 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24869732 147.2 ns/op 7051.89 MB/s Benchmark______Pub1K_Payload-16 24719175 139.6 ns/op 7432.94 MB/s Benchmark______Pub1K_Payload-16 23570950 144.6 ns/op 7177.34 MB/s Benchmark______Pub1K_Payload-16 26122822 138.2 ns/op 7510.22 MB/s Benchmark______Pub1K_Payload-16 20470452 155.5 ns/op 6677.02 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5749069 622.6 ns/op 6601.56 MB/s Benchmark______Pub4K_Payload-16 5675571 617.7 ns/op 6653.66 MB/s Benchmark______Pub4K_Payload-16 5503752 635.0 ns/op 6472.87 MB/s Benchmark______Pub4K_Payload-16 5632369 618.1 ns/op 6648.93 MB/s Benchmark______Pub4K_Payload-16 5157352 629.3 ns/op 6531.51 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2777971 1268 ns/op 6470.22 MB/s Benchmark______Pub8K_Payload-16 2759007 1275 ns/op 6437.17 MB/s Benchmark______Pub8K_Payload-16 2714540 1278 ns/op 6419.80 MB/s Benchmark______Pub8K_Payload-16 2756397 1282 ns/op 6400.46 MB/s Benchmark______Pub8K_Payload-16 2791291 1276 ns/op 6431.92 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 656265 5522 ns/op 5937.23 MB/s Benchmark_____Pub32K_Payload-16 650083 5543 ns/op 5914.44 MB/s Benchmark_____Pub32K_Payload-16 644470 5506 ns/op 5954.18 MB/s Benchmark_____Pub32K_Payload-16 602840 5504 ns/op 5955.73 MB/s Benchmark_____Pub32K_Payload-16 660338 5565 ns/op 5891.09 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31731746 96.41 ns/op 114.10 MB/s Benchmark__AuthPub0b_Payload-16 34007197 96.95 ns/op 113.46 MB/s Benchmark__AuthPub0b_Payload-16 35336276 95.86 ns/op 114.76 MB/s Benchmark__AuthPub0b_Payload-16 33494150 95.96 ns/op 114.63 MB/s Benchmark__AuthPub0b_Payload-16 34316049 96.55 ns/op 113.93 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15444678 229.6 ns/op Benchmark_____________PubSub-16 15366848 230.9 ns/op Benchmark_____________PubSub-16 15508369 229.5 ns/op Benchmark_____________PubSub-16 15522320 230.0 ns/op Benchmark_____________PubSub-16 15552679 227.8 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15392202 227.3 ns/op Benchmark_____PubSubTwoConns-16 15654741 227.8 ns/op Benchmark_____PubSubTwoConns-16 15552326 229.0 ns/op Benchmark_____PubSubTwoConns-16 15428311 227.8 ns/op Benchmark_____PubSubTwoConns-16 15597166 226.8 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34228->127.0.0.1:42795: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:48152->127.0.0.1:46393: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40824->127.0.0.1:35749: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34830->127.0.0.1:38185: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33652->127.0.0.1:46223: 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 14547020 245.9 ns/op Benchmark_____PubTwoQueueSub-16 14484760 245.9 ns/op Benchmark_____PubTwoQueueSub-16 14466361 246.6 ns/op Benchmark_____PubTwoQueueSub-16 14499675 246.0 ns/op Benchmark_____PubTwoQueueSub-16 14403044 245.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14283742 245.7 ns/op Benchmark____PubFourQueueSub-16 14526364 245.4 ns/op Benchmark____PubFourQueueSub-16 14437112 246.5 ns/op Benchmark____PubFourQueueSub-16 14415042 246.2 ns/op Benchmark____PubFourQueueSub-16 14452984 246.5 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14459655 246.2 ns/op Benchmark___PubEightQueueSub-16 14272780 246.6 ns/op Benchmark___PubEightQueueSub-16 14387520 246.1 ns/op Benchmark___PubEightQueueSub-16 14428681 246.6 ns/op Benchmark___PubEightQueueSub-16 14602502 245.3 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23275 155099 ns/op Benchmark_PubSub512kTwoConns-16 23080 156263 ns/op Benchmark_PubSub512kTwoConns-16 23102 154739 ns/op Benchmark_PubSub512kTwoConns-16 23162 154597 ns/op Benchmark_PubSub512kTwoConns-16 23163 155660 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15076341 230.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 15088269 231.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15141961 230.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15268130 230.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15362162 230.7 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15110090 230.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15094975 231.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15303568 230.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15101662 229.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15057914 233.1 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10987680 320.2 ns/op Benchmark____RoutedPubSub_0b-16 11416894 312.7 ns/op Benchmark____RoutedPubSub_0b-16 10935427 316.8 ns/op Benchmark____RoutedPubSub_0b-16 11294242 316.2 ns/op Benchmark____RoutedPubSub_0b-16 11005413 317.8 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6694015 536.0 ns/op Benchmark____RoutedPubSub_1K-16 6831756 537.8 ns/op Benchmark____RoutedPubSub_1K-16 6474361 536.3 ns/op Benchmark____RoutedPubSub_1K-16 6569962 534.8 ns/op Benchmark____RoutedPubSub_1K-16 6622398 541.4 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 83113 40892 ns/op Benchmark__RoutedPubSub_100K-16 83362 42522 ns/op Benchmark__RoutedPubSub_100K-16 85089 44362 ns/op Benchmark__RoutedPubSub_100K-16 83889 44113 ns/op Benchmark__RoutedPubSub_100K-16 71979 43248 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9687807 317.0 ns/op Benchmark____Routed2QueueSub-16 9660763 331.1 ns/op Benchmark____Routed2QueueSub-16 9802525 320.2 ns/op Benchmark____Routed2QueueSub-16 9758176 315.2 ns/op Benchmark____Routed2QueueSub-16 9738343 321.6 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9678092 324.1 ns/op Benchmark____Routed4QueueSub-16 9420278 327.6 ns/op Benchmark____Routed4QueueSub-16 9528843 321.8 ns/op Benchmark____Routed4QueueSub-16 9370874 321.2 ns/op Benchmark____Routed4QueueSub-16 9526531 322.2 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9200122 327.1 ns/op Benchmark____Routed8QueueSub-16 11115967 322.8 ns/op Benchmark____Routed8QueueSub-16 9206756 331.1 ns/op Benchmark____Routed8QueueSub-16 10966450 326.6 ns/op Benchmark____Routed8QueueSub-16 9287185 329.3 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8833977 345.3 ns/op Benchmark___Routed16QueueSub-16 8896258 341.7 ns/op Benchmark___Routed16QueueSub-16 8874121 347.4 ns/op Benchmark___Routed16QueueSub-16 8964172 349.6 ns/op Benchmark___Routed16QueueSub-16 8959789 345.2 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6422884 546.9 ns/op Benchmark____________RouteCompressOff-16 6269271 547.5 ns/op Benchmark____________RouteCompressOff-16 6510424 559.9 ns/op Benchmark____________RouteCompressOff-16 6371119 554.1 ns/op Benchmark____________RouteCompressOff-16 6421101 556.9 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6548754 548.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6398049 549.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6407353 552.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6437557 553.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6424244 550.9 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6458607 559.4 ns/op Benchmark_________RouteCompressS2Fast-16 6391633 553.6 ns/op Benchmark_________RouteCompressS2Fast-16 6319545 554.7 ns/op Benchmark_________RouteCompressS2Fast-16 6362128 555.7 ns/op Benchmark_________RouteCompressS2Fast-16 6256989 556.4 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6410990 551.4 ns/op Benchmark_______RouteCompressS2Better-16 6315963 546.8 ns/op Benchmark_______RouteCompressS2Better-16 6441240 546.4 ns/op Benchmark_______RouteCompressS2Better-16 6368935 548.2 ns/op Benchmark_______RouteCompressS2Better-16 6294830 552.6 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6387735 547.0 ns/op Benchmark_________RouteCompressS2Best-16 6402590 544.5 ns/op Benchmark_________RouteCompressS2Best-16 6525189 548.4 ns/op Benchmark_________RouteCompressS2Best-16 6539805 550.1 ns/op Benchmark_________RouteCompressS2Best-16 6420103 549.4 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4609904 769.8 ns/op 323.45 MB/s Benchmark______FanOut_8x1x10-16 4664029 769.9 ns/op 323.44 MB/s Benchmark______FanOut_8x1x10-16 4647476 773.8 ns/op 321.80 MB/s Benchmark______FanOut_8x1x10-16 4645874 774.7 ns/op 321.42 MB/s Benchmark______FanOut_8x1x10-16 4662284 772.0 ns/op 322.52 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 531254 6176 ns/op 375.48 MB/s Benchmark_____FanOut_8x1x100-16 530114 6136 ns/op 377.94 MB/s Benchmark_____FanOut_8x1x100-16 560953 6261 ns/op 370.39 MB/s Benchmark_____FanOut_8x1x100-16 537262 6206 ns/op 373.66 MB/s Benchmark_____FanOut_8x1x100-16 540079 6229 ns/op 372.27 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47218 75636 ns/op 304.34 MB/s Benchmark____FanOut_8x10x100-16 47403 75339 ns/op 305.54 MB/s Benchmark____FanOut_8x10x100-16 47562 75746 ns/op 303.90 MB/s Benchmark____FanOut_8x10x100-16 47631 75797 ns/op 303.69 MB/s Benchmark____FanOut_8x10x100-16 47402 75811 ns/op 303.64 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5562 605032 ns/op 396.70 MB/s Benchmark___FanOut_8x10x1000-16 5797 618553 ns/op 388.03 MB/s Benchmark___FanOut_8x10x1000-16 5320 615522 ns/op 389.94 MB/s Benchmark___FanOut_8x10x1000-16 5700 616042 ns/op 389.61 MB/s Benchmark___FanOut_8x10x1000-16 5896 610896 ns/op 392.90 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4918 721819 ns/op 318.67 MB/s Benchmark___FanOut_8x100x100-16 4894 720431 ns/op 319.28 MB/s Benchmark___FanOut_8x100x100-16 4918 719736 ns/op 319.59 MB/s Benchmark___FanOut_8x100x100-16 4881 736104 ns/op 312.48 MB/s Benchmark___FanOut_8x100x100-16 4905 727563 ns/op 316.15 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 546 6331014 ns/op 379.09 MB/s Benchmark__FanOut_8x100x1000-16 552 6279933 ns/op 382.17 MB/s Benchmark__FanOut_8x100x1000-16 565 6428772 ns/op 373.32 MB/s Benchmark__FanOut_8x100x1000-16 560 6301366 ns/op 380.87 MB/s Benchmark__FanOut_8x100x1000-16 560 6347634 ns/op 378.10 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 513 6850413 ns/op 364.94 MB/s Benchmark__FanOut_8x10x10000-16 519 6829760 ns/op 366.05 MB/s Benchmark__FanOut_8x10x10000-16 526 6866347 ns/op 364.10 MB/s Benchmark__FanOut_8x10x10000-16 511 6941939 ns/op 360.13 MB/s Benchmark__FanOut_8x10x10000-16 522 6949362 ns/op 359.75 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 931 3831511 ns/op 300.15 MB/s Benchmark___FanOut_8x500x100-16 933 3816729 ns/op 301.31 MB/s Benchmark___FanOut_8x500x100-16 930 3810849 ns/op 301.78 MB/s Benchmark___FanOut_8x500x100-16 932 3812491 ns/op 301.65 MB/s Benchmark___FanOut_8x500x100-16 933 3819937 ns/op 301.06 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 356371 9596 ns/op 1525.71 MB/s Benchmark___FanOut_128x1x100-16 357274 9601 ns/op 1524.87 MB/s Benchmark___FanOut_128x1x100-16 357818 9557 ns/op 1531.91 MB/s Benchmark___FanOut_128x1x100-16 361758 9563 ns/op 1530.97 MB/s Benchmark___FanOut_128x1x100-16 362194 9581 ns/op 1528.17 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32088 112424 ns/op 1291.01 MB/s Benchmark__FanOut_128x10x100-16 32198 112688 ns/op 1287.99 MB/s Benchmark__FanOut_128x10x100-16 31924 112615 ns/op 1288.82 MB/s Benchmark__FanOut_128x10x100-16 32330 111503 ns/op 1301.68 MB/s Benchmark__FanOut_128x10x100-16 32132 111329 ns/op 1303.71 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3993 892393 ns/op 1636.21 MB/s Benchmark_FanOut_128x10x1000-16 3670 894252 ns/op 1632.81 MB/s Benchmark_FanOut_128x10x1000-16 3980 894419 ns/op 1632.50 MB/s Benchmark_FanOut_128x10x1000-16 4033 886296 ns/op 1647.46 MB/s Benchmark_FanOut_128x10x1000-16 3751 882434 ns/op 1654.68 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3463 1019241 ns/op 1422.77 MB/s Benchmark_FanOut_128x100x100-16 3452 1031329 ns/op 1406.09 MB/s Benchmark_FanOut_128x100x100-16 3453 1023936 ns/op 1416.24 MB/s Benchmark_FanOut_128x100x100-16 3376 1021765 ns/op 1419.25 MB/s Benchmark_FanOut_128x100x100-16 3528 1024096 ns/op 1416.02 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 373 9509720 ns/op 1535.29 MB/s BenchmarkFanOut_128x100x1000-16 382 9507123 ns/op 1535.71 MB/s BenchmarkFanOut_128x100x1000-16 373 9348820 ns/op 1561.71 MB/s BenchmarkFanOut_128x100x1000-16 373 9422682 ns/op 1549.47 MB/s BenchmarkFanOut_128x100x1000-16 374 9640785 ns/op 1514.41 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 363 9858211 ns/op 1491.16 MB/s BenchmarkFanOut_128x10x10000-16 364 9879423 ns/op 1487.96 MB/s BenchmarkFanOut_128x10x10000-16 366 9881179 ns/op 1487.69 MB/s BenchmarkFanOut_128x10x10000-16 364 9833054 ns/op 1494.97 MB/s BenchmarkFanOut_128x10x10000-16 367 9788301 ns/op 1501.81 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 662 5363884 ns/op 1351.66 MB/s BenchmarkFanOut__128x500x100-16 672 5378628 ns/op 1347.95 MB/s BenchmarkFanOut__128x500x100-16 664 5342385 ns/op 1357.10 MB/s BenchmarkFanOut__128x500x100-16 663 5332816 ns/op 1359.53 MB/s BenchmarkFanOut__128x500x100-16 661 5359019 ns/op 1352.89 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1917 1869169 ns/op 2830.42 MB/s Benchmark_FanOut_512x100x100-16 1893 1853974 ns/op 2853.61 MB/s Benchmark_FanOut_512x100x100-16 1872 1870013 ns/op 2829.14 MB/s Benchmark_FanOut_512x100x100-16 1924 1876324 ns/op 2819.62 MB/s Benchmark_FanOut_512x100x100-16 1910 1866477 ns/op 2834.50 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16966850 ns/op 3123.77 MB/s Benchmark__FanOut_512x100x1k-16 212 16702277 ns/op 3173.25 MB/s Benchmark__FanOut_512x100x1k-16 212 16925435 ns/op 3131.41 MB/s Benchmark__FanOut_512x100x1k-16 212 16853729 ns/op 3144.74 MB/s Benchmark__FanOut_512x100x1k-16 211 16715297 ns/op 3170.78 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3261 1171107 ns/op 8906.99 MB/s Benchmark____FanOut_1kx10x1k-16 3081 1152356 ns/op 9051.92 MB/s Benchmark____FanOut_1kx10x1k-16 3112 1151373 ns/op 9059.65 MB/s Benchmark____FanOut_1kx10x1k-16 3199 1154859 ns/op 9032.30 MB/s Benchmark____FanOut_1kx10x1k-16 2841 1136322 ns/op 9179.65 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2732 1262736 ns/op 8252.74 MB/s Benchmark__FanOut_1kx100x100-16 2778 1270180 ns/op 8204.38 MB/s Benchmark__FanOut_1kx100x100-16 2784 1271334 ns/op 8196.93 MB/s Benchmark__FanOut_1kx100x100-16 2712 1274380 ns/op 8177.34 MB/s Benchmark__FanOut_1kx100x100-16 2706 1277175 ns/op 8159.45 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4460899 787.1 ns/op 316.37 MB/s Benchmark_____RFanOut_8x1x10-16 4524514 786.2 ns/op 316.73 MB/s Benchmark_____RFanOut_8x1x10-16 4541092 786.5 ns/op 316.60 MB/s Benchmark_____RFanOut_8x1x10-16 4490884 782.8 ns/op 318.08 MB/s Benchmark_____RFanOut_8x1x10-16 4535322 777.7 ns/op 320.16 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 553964 6255 ns/op 370.77 MB/s Benchmark____RFanOut_8x1x100-16 521409 6267 ns/op 370.05 MB/s Benchmark____RFanOut_8x1x100-16 526669 6312 ns/op 367.38 MB/s Benchmark____RFanOut_8x1x100-16 535015 6291 ns/op 368.63 MB/s Benchmark____RFanOut_8x1x100-16 547116 6179 ns/op 375.33 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47367 76761 ns/op 299.88 MB/s Benchmark___RFanOut_8x10x100-16 47182 75509 ns/op 304.85 MB/s Benchmark___RFanOut_8x10x100-16 47814 75652 ns/op 304.28 MB/s Benchmark___RFanOut_8x10x100-16 47383 76197 ns/op 302.10 MB/s Benchmark___RFanOut_8x10x100-16 47461 75797 ns/op 303.69 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5474 618403 ns/op 388.13 MB/s Benchmark__RFanOut_8x10x1000-16 5528 618283 ns/op 388.20 MB/s Benchmark__RFanOut_8x10x1000-16 5718 629436 ns/op 381.32 MB/s Benchmark__RFanOut_8x10x1000-16 5738 609429 ns/op 393.84 MB/s Benchmark__RFanOut_8x10x1000-16 5662 610473 ns/op 393.17 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4963 711991 ns/op 323.06 MB/s Benchmark__RFanOut_8x100x100-16 4969 723486 ns/op 317.93 MB/s Benchmark__RFanOut_8x100x100-16 4899 718527 ns/op 320.13 MB/s Benchmark__RFanOut_8x100x100-16 4906 722609 ns/op 318.32 MB/s Benchmark__RFanOut_8x100x100-16 4867 722112 ns/op 318.54 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 558 6351220 ns/op 377.88 MB/s Benchmark_RFanOut_8x100x1000-16 538 6353284 ns/op 377.76 MB/s Benchmark_RFanOut_8x100x1000-16 561 6565779 ns/op 365.53 MB/s Benchmark_RFanOut_8x100x1000-16 566 6281385 ns/op 382.08 MB/s Benchmark_RFanOut_8x100x1000-16 559 6492885 ns/op 369.64 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 514 6855122 ns/op 364.69 MB/s Benchmark_RFanOut_8x10x10000-16 513 6893724 ns/op 362.65 MB/s Benchmark_RFanOut_8x10x10000-16 513 6837330 ns/op 365.64 MB/s Benchmark_RFanOut_8x10x10000-16 513 6980320 ns/op 358.15 MB/s Benchmark_RFanOut_8x10x10000-16 534 6957681 ns/op 359.32 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3085 1173031 ns/op 8892.38 MB/s Benchmark_RFanOut_1kx10x1000-16 2964 1194312 ns/op 8733.93 MB/s Benchmark_RFanOut_1kx10x1000-16 2900 1155578 ns/op 9026.68 MB/s Benchmark_RFanOut_1kx10x1000-16 3074 1149484 ns/op 9074.54 MB/s Benchmark_RFanOut_1kx10x1000-16 3122 1192082 ns/op 8750.27 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6932640 507.3 ns/op 4095.91 MB/s Benchmark_____FanIn_1kx100x1-16 6995025 506.7 ns/op 4101.17 MB/s Benchmark_____FanIn_1kx100x1-16 6917235 507.3 ns/op 4095.94 MB/s Benchmark_____FanIn_1kx100x1-16 6877905 507.1 ns/op 4098.08 MB/s Benchmark_____FanIn_1kx100x1-16 6919422 508.3 ns/op 4088.36 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2616537 1396 ns/op 5888.78 MB/s Benchmark_____FanIn_4kx100x1-16 2659599 1341 ns/op 6131.99 MB/s Benchmark_____FanIn_4kx100x1-16 2616962 1357 ns/op 6059.43 MB/s Benchmark_____FanIn_4kx100x1-16 2594250 1354 ns/op 6070.60 MB/s Benchmark_____FanIn_4kx100x1-16 2583033 1363 ns/op 6033.07 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1713602 2098 ns/op 7824.14 MB/s Benchmark_____FanIn_8kx100x1-16 1693315 2107 ns/op 7791.74 MB/s Benchmark_____FanIn_8kx100x1-16 1706246 2118 ns/op 7751.11 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 828285696 vs 13705718400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44112->127.0.0.1:5222: write: connection reset by peer bench_test.go: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:44458->127.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:44420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44722->127.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: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:44438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44088->127.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:44092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44644->127.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:44252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43928->127.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:44384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44116->127.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: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:43860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44020->127.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:44360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44522->127.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:44706->127.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:44660->127.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:44450->127.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: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:43840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44568->127.0.0.1:5222: write: broken pipe --- FAIL: Benchmark_____FanIn_8kx100x1-16 Benchmark_____FanIn_8kx100x1-16 1698878 2142 ns/op 7661.57 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 859842 4121 ns/op 7958.92 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 28242522 vs 14291831400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33414->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_16kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33586->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_16kx100x1-16 866559 4141 ns/op 7920.06 MB/s Benchmark____FanIn_16kx100x1-16 858374 4134 ns/op 7934.08 MB/s Benchmark____FanIn_16kx100x1-16 849223 4159 ns/op 7886.47 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 170185 20068 ns/op 6533.04 MB/s Benchmark____FanIn_64kx100x1-16 166999 19798 ns/op 6622.07 MB/s Benchmark____FanIn_64kx100x1-16 168363 19818 ns/op 6615.24 MB/s Benchmark____FanIn_64kx100x1-16 170030 20107 ns/op 6520.23 MB/s Benchmark____FanIn_64kx100x1-16 175338 19924 ns/op 6580.23 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 134891610 vs 11535920000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36048->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: 361152950 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38232->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37794->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38206->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38288->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38468->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38176->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38092->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37848->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38450->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: 612059210 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40120->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:40256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39540->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: 380029910 vs 11365503000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42830->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: 179068940 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44968->127.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: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:44224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44746->127.0.0.1:5222: write: 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:44606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44170->127.0.0.1:5222: write: connection reset by peer bench_test.go: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:44280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44940->127.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:44706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44712->127.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:44186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44842->127.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:44892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44570->127.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:44886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44318->127.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:44978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44672->127.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 --- FAIL: Benchmark___FanIn_128kx100x1-16 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 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44158->127.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:44428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44518->127.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: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: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:44622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44910->127.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:44798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44522->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5622495 638.1 ns/op 445.10 MB/s Benchmark___BumpPubCount_1x3-16 5581604 638.8 ns/op 444.57 MB/s Benchmark___BumpPubCount_1x3-16 5574674 637.4 ns/op 445.58 MB/s Benchmark___BumpPubCount_1x3-16 5634795 632.1 ns/op 449.27 MB/s Benchmark___BumpPubCount_1x3-16 5565356 641.5 ns/op 442.69 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5338448 670.7 ns/op 423.41 MB/s Benchmark___BumpPubCount_2x3-16 5317099 668.1 ns/op 425.06 MB/s Benchmark___BumpPubCount_2x3-16 5338185 673.1 ns/op 421.90 MB/s Benchmark___BumpPubCount_2x3-16 5310144 673.5 ns/op 421.68 MB/s Benchmark___BumpPubCount_2x3-16 5351464 673.8 ns/op 421.47 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5408552 650.8 ns/op 436.37 MB/s Benchmark___BumpPubCount_5x3-16 5510499 648.4 ns/op 438.01 MB/s Benchmark___BumpPubCount_5x3-16 5472790 646.8 ns/op 439.08 MB/s Benchmark___BumpPubCount_5x3-16 5170574 644.0 ns/op 441.02 MB/s Benchmark___BumpPubCount_5x3-16 5364748 652.2 ns/op 435.47 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5552390 645.4 ns/op 440.05 MB/s Benchmark__BumpPubCount_10x3-16 5484552 646.9 ns/op 439.00 MB/s Benchmark__BumpPubCount_10x3-16 5569089 646.0 ns/op 439.61 MB/s Benchmark__BumpPubCount_10x3-16 5555533 646.1 ns/op 439.59 MB/s Benchmark__BumpPubCount_10x3-16 5568571 647.7 ns/op 438.48 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12019794 277.9 ns/op 3741.69 MB/s Benchmark____GWs_Opt_1kx01x0-16 12549566 273.7 ns/op 3799.51 MB/s Benchmark____GWs_Opt_1kx01x0-16 12441831 271.5 ns/op 3831.21 MB/s Benchmark____GWs_Opt_1kx01x0-16 12434239 281.7 ns/op 3692.27 MB/s Benchmark____GWs_Opt_1kx01x0-16 12512325 279.6 ns/op 3719.56 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10285112 330.3 ns/op 6249.67 MB/s Benchmark____GWs_Opt_2kx01x0-16 10400956 341.4 ns/op 6046.11 MB/s Benchmark____GWs_Opt_2kx01x0-16 9770793 334.2 ns/op 6176.82 MB/s Benchmark____GWs_Opt_2kx01x0-16 10216471 351.4 ns/op 5872.85 MB/s Benchmark____GWs_Opt_2kx01x0-16 10605409 330.9 ns/op 6237.64 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5774007 658.0 ns/op 6249.30 MB/s Benchmark____GWs_Opt_4kx01x0-16 5731660 658.1 ns/op 6248.72 MB/s Benchmark____GWs_Opt_4kx01x0-16 5788633 625.6 ns/op 6572.49 MB/s Benchmark____GWs_Opt_4kx01x0-16 5902020 627.0 ns/op 6558.36 MB/s Benchmark____GWs_Opt_4kx01x0-16 5781861 625.3 ns/op 6576.56 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28189876 117.0 ns/op 8889.62 MB/s Benchmark____GWs_Opt_1kx10x0-16 29877914 116.3 ns/op 8945.13 MB/s Benchmark____GWs_Opt_1kx10x0-16 27815133 112.7 ns/op 9224.57 MB/s Benchmark____GWs_Opt_1kx10x0-16 31372315 111.4 ns/op 9334.53 MB/s Benchmark____GWs_Opt_1kx10x0-16 31708712 112.5 ns/op 9243.89 MB/s Benchmark____GWs_Opt_2kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:41062->127.0.0.1:37405: 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:32922->127.0.0.1:37629: use of closed network connection --- FAIL: Benchmark____GWs_Opt_2kx10x0-16 Benchmark____GWs_Opt_2kx10x0-16 24328794 144.1 ns/op 14320.68 MB/s Benchmark____GWs_Opt_2kx10x0-16 25010720 152.7 ns/op 13512.52 MB/s Benchmark____GWs_Opt_2kx10x0-16 24063366 138.5 ns/op 14905.61 MB/s Benchmark____GWs_Opt_2kx10x0-16 23649145 149.1 ns/op 13847.07 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12895890 322.6 ns/op 12745.29 MB/s Benchmark____GWs_Opt_4kx10x0-16 12822864 306.2 ns/op 13431.16 MB/s Benchmark____GWs_Opt_4kx10x0-16 13125141 334.9 ns/op 12277.82 MB/s Benchmark____GWs_Opt_4kx10x0-16 12167760 284.7 ns/op 14443.07 MB/s Benchmark____GWs_Opt_4kx10x0-16 12296427 284.4 ns/op 14457.27 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6472820 552.8 ns/op 5653.42 MB/s Benchmark____GWs_Opt_1kx01x1-16 6678201 551.9 ns/op 5661.90 MB/s Benchmark____GWs_Opt_1kx01x1-16 6511125 547.1 ns/op 5711.98 MB/s Benchmark____GWs_Opt_1kx01x1-16 6375258 555.9 ns/op 5621.75 MB/s Benchmark____GWs_Opt_1kx01x1-16 6438728 546.1 ns/op 5722.54 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4561508 1148 ns/op 5398.84 MB/s Benchmark____GWs_Opt_2kx01x1-16 4751971 765.3 ns/op 8097.02 MB/s Benchmark____GWs_Opt_2kx01x1-16 4693144 773.9 ns/op 8007.96 MB/s Benchmark____GWs_Opt_2kx01x1-16 4668058 767.4 ns/op 8075.83 MB/s Benchmark____GWs_Opt_2kx01x1-16 4530768 844.9 ns/op 7334.88 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2521274 1368 ns/op 9021.11 MB/s Benchmark____GWs_Opt_4kx01x1-16 2650333 1360 ns/op 9071.32 MB/s Benchmark____GWs_Opt_4kx01x1-16 2669624 1457 ns/op 8467.58 MB/s Benchmark____GWs_Opt_4kx01x1-16 2628876 1377 ns/op 8962.54 MB/s Benchmark____GWs_Opt_4kx01x1-16 2464531 1375 ns/op 8973.96 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6181552 567.4 ns/op 5507.26 MB/s Benchmark____GWs_Opt_1kx10x1-16 6143445 580.5 ns/op 5383.66 MB/s Benchmark____GWs_Opt_1kx10x1-16 6530406 566.2 ns/op 5518.81 MB/s Benchmark____GWs_Opt_1kx10x1-16 6569179 561.6 ns/op 5564.71 MB/s Benchmark____GWs_Opt_1kx10x1-16 5753944 558.2 ns/op 5598.70 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4173973 853.6 ns/op 7260.12 MB/s Benchmark____GWs_Opt_2kx10x1-16 4199502 841.4 ns/op 7365.03 MB/s Benchmark____GWs_Opt_2kx10x1-16 4180369 846.8 ns/op 7318.56 MB/s Benchmark____GWs_Opt_2kx10x1-16 3992779 849.1 ns/op 7297.89 MB/s Benchmark____GWs_Opt_2kx10x1-16 4050591 857.1 ns/op 7230.17 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2365454 1520 ns/op 8119.48 MB/s Benchmark____GWs_Opt_4kx10x1-16 2345170 1499 ns/op 8232.79 MB/s Benchmark____GWs_Opt_4kx10x1-16 2283356 1433 ns/op 8610.49 MB/s Benchmark____GWs_Opt_4kx10x1-16 2384437 1530 ns/op 8068.35 MB/s Benchmark____GWs_Opt_4kx10x1-16 2339121 1464 ns/op 8430.17 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11818112 292.2 ns/op 3559.05 MB/s Benchmark____GWs_Int_1kx01x0-16 12082090 293.3 ns/op 3546.29 MB/s Benchmark____GWs_Int_1kx01x0-16 12531753 299.7 ns/op 3470.48 MB/s Benchmark____GWs_Int_1kx01x0-16 12097464 288.9 ns/op 3599.68 MB/s Benchmark____GWs_Int_1kx01x0-16 12165008 287.3 ns/op 3619.86 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9991141 422.1 ns/op 4889.45 MB/s Benchmark____GWs_Int_2kx01x0-16 9218132 361.5 ns/op 5709.00 MB/s Benchmark____GWs_Int_2kx01x0-16 10158297 361.2 ns/op 5714.78 MB/s Benchmark____GWs_Int_2kx01x0-16 10117629 380.5 ns/op 5425.14 MB/s Benchmark____GWs_Int_2kx01x0-16 10004410 355.8 ns/op 5800.94 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5699722 641.4 ns/op 6411.21 MB/s Benchmark____GWs_Int_4kx01x0-16 5672437 634.4 ns/op 6481.58 MB/s Benchmark____GWs_Int_4kx01x0-16 5566054 629.9 ns/op 6528.23 MB/s Benchmark____GWs_Int_4kx01x0-16 5621500 630.7 ns/op 6519.49 MB/s Benchmark____GWs_Int_4kx01x0-16 5655020 639.9 ns/op 6425.74 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32752107 124.4 ns/op 8362.62 MB/s Benchmark____GWs_Int_1kx10x0-16 31699464 113.5 ns/op 9162.58 MB/s Benchmark____GWs_Int_1kx10x0-16 32011384 111.6 ns/op 9321.06 MB/s Benchmark____GWs_Int_1kx10x0-16 31434260 112.6 ns/op 9240.01 MB/s Benchmark____GWs_Int_1kx10x0-16 32132710 110.5 ns/op 9408.39 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 20490985 159.4 ns/op 12949.72 MB/s Benchmark____GWs_Int_2kx10x0-16 22493499 147.0 ns/op 14037.52 MB/s Benchmark____GWs_Int_2kx10x0-16 25805943 141.1 ns/op 14628.07 MB/s Benchmark____GWs_Int_2kx10x0-16 25910258 140.8 ns/op 14654.25 MB/s Benchmark____GWs_Int_2kx10x0-16 25966795 149.1 ns/op 13846.98 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13345816 332.0 ns/op 12385.28 MB/s Benchmark____GWs_Int_4kx10x0-16 13055409 280.7 ns/op 14649.11 MB/s Benchmark____GWs_Int_4kx10x0-16 11125009 298.5 ns/op 13776.61 MB/s Benchmark____GWs_Int_4kx10x0-16 13084951 341.5 ns/op 12042.43 MB/s Benchmark____GWs_Int_4kx10x0-16 11023879 317.9 ns/op 12934.55 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6112455 550.3 ns/op 5678.52 MB/s Benchmark____GWs_Int_1kx01x1-16 6373436 556.5 ns/op 5615.36 MB/s Benchmark____GWs_Int_1kx01x1-16 6372865 561.8 ns/op 5562.26 MB/s Benchmark____GWs_Int_1kx01x1-16 6126655 565.2 ns/op 5529.42 MB/s Benchmark____GWs_Int_1kx01x1-16 6492853 561.8 ns/op 5562.28 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4668794 756.4 ns/op 8192.34 MB/s Benchmark____GWs_Int_2kx01x1-16 4714878 757.3 ns/op 8182.56 MB/s Benchmark____GWs_Int_2kx01x1-16 4590964 763.9 ns/op 8111.88 MB/s Benchmark____GWs_Int_2kx01x1-16 4820684 768.4 ns/op 8064.38 MB/s Benchmark____GWs_Int_2kx01x1-16 4792074 1163 ns/op 5326.56 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2682050 1362 ns/op 9061.57 MB/s Benchmark____GWs_Int_4kx01x1-16 2394937 1387 ns/op 8897.85 MB/s Benchmark____GWs_Int_4kx01x1-16 2694064 1554 ns/op 7942.19 MB/s Benchmark____GWs_Int_4kx01x1-16 2270970 1365 ns/op 9039.31 MB/s Benchmark____GWs_Int_4kx01x1-16 2670237 1365 ns/op 9041.45 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6606037 560.2 ns/op 5578.56 MB/s Benchmark____GWs_Int_1kx10x1-16 6087662 559.0 ns/op 5589.96 MB/s Benchmark____GWs_Int_1kx10x1-16 6394672 558.8 ns/op 5592.09 MB/s Benchmark____GWs_Int_1kx10x1-16 6108921 559.3 ns/op 5587.32 MB/s Benchmark____GWs_Int_1kx10x1-16 6575316 563.5 ns/op 5545.23 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4222993 846.3 ns/op 7322.04 MB/s Benchmark____GWs_Int_2kx10x1-16 4024045 844.6 ns/op 7336.97 MB/s Benchmark____GWs_Int_2kx10x1-16 4263398 902.6 ns/op 6865.69 MB/s Benchmark____GWs_Int_2kx10x1-16 4149387 844.5 ns/op 7338.25 MB/s Benchmark____GWs_Int_2kx10x1-16 4207707 968.3 ns/op 6399.70 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2165281 1478 ns/op 8352.13 MB/s Benchmark____GWs_Int_4kx10x1-16 2433912 1476 ns/op 8361.13 MB/s Benchmark____GWs_Int_4kx10x1-16 2443399 1521 ns/op 8111.55 MB/s Benchmark____GWs_Int_4kx10x1-16 2407680 1521 ns/op 8113.80 MB/s Benchmark____GWs_Int_4kx10x1-16 2351500 1429 ns/op 8635.68 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8218995 438.0 ns/op 232.88 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8418868 470.4 ns/op 216.85 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8193436 440.2 ns/op 231.70 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8008114 430.7 ns/op 236.82 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8234059 438.5 ns/op 232.60 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 621746 5054 ns/op 35.02 MB/s Benchmark__GWs_Reqs_1SubEach-16 826386 5260 ns/op 33.65 MB/s Benchmark__GWs_Reqs_1SubEach-16 736954 5319 ns/op 33.28 MB/s Benchmark__GWs_Reqs_1SubEach-16 708898 5390 ns/op 32.84 MB/s Benchmark__GWs_Reqs_1SubEach-16 702423 5314 ns/op 33.31 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2090.443s ❌ Non-zero exit code: 1