> ROOT_DIR=/tmp/go-bench-away-job-04e7acbc-fcce-4f1a-8008-2f3b14f8d40f-3321881626 > OUTPUT_FILE=/tmp/go-bench-away-job-04e7acbc-fcce-4f1a-8008-2f3b14f8d40f-3321881626/results.txt > SHA_FILE=/tmp/go-bench-away-job-04e7acbc-fcce-4f1a-8008-2f3b14f8d40f-3321881626/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-04e7acbc-fcce-4f1a-8008-2f3b14f8d40f-3321881626/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=v2.12.12 > 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: v2.12.12 to /tmp/go-bench-away-job-04e7acbc-fcce-4f1a-8008-2f3b14f8d40f-3321881626/source.git SHA of v2.12.12: 02e7283d0b8a6ba8af344c16a5604a64e609c3d3 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-build3716602976=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-04e7acbc-fcce-4f1a-8008-2f3b14f8d40f-3321881626/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 39440634 76.53 ns/op 143.74 MB/s Benchmark______Pub0b_Payload-16 46189840 74.28 ns/op 148.09 MB/s Benchmark______Pub0b_Payload-16 46012581 74.16 ns/op 148.33 MB/s Benchmark______Pub0b_Payload-16 45938822 76.33 ns/op 144.12 MB/s Benchmark______Pub0b_Payload-16 44842026 74.16 ns/op 148.33 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45632665 74.92 ns/op 253.60 MB/s Benchmark______Pub8b_Payload-16 42391615 74.70 ns/op 254.34 MB/s Benchmark______Pub8b_Payload-16 45530916 75.02 ns/op 253.26 MB/s Benchmark______Pub8b_Payload-16 44655414 76.99 ns/op 246.78 MB/s Benchmark______Pub8b_Payload-16 45277891 78.64 ns/op 241.60 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43432821 78.62 ns/op 559.65 MB/s Benchmark_____Pub32b_Payload-16 43402717 79.82 ns/op 551.22 MB/s Benchmark_____Pub32b_Payload-16 45779241 79.22 ns/op 555.41 MB/s Benchmark_____Pub32b_Payload-16 45472488 80.86 ns/op 544.13 MB/s Benchmark_____Pub32b_Payload-16 43354021 78.52 ns/op 560.36 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 34223743 93.42 ns/op 1509.37 MB/s Benchmark____Pub128B_Payload-16 38359914 100.7 ns/op 1400.21 MB/s Benchmark____Pub128B_Payload-16 34622350 87.37 ns/op 1613.78 MB/s Benchmark____Pub128B_Payload-16 40395193 87.23 ns/op 1616.41 MB/s Benchmark____Pub128B_Payload-16 37560554 87.19 ns/op 1617.16 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 32011808 95.70 ns/op 2810.87 MB/s Benchmark____Pub256B_Payload-16 31214916 101.7 ns/op 2646.08 MB/s Benchmark____Pub256B_Payload-16 33155257 95.93 ns/op 2804.07 MB/s Benchmark____Pub256B_Payload-16 38016476 95.46 ns/op 2817.94 MB/s Benchmark____Pub256B_Payload-16 36915856 95.65 ns/op 2812.30 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23562902 145.8 ns/op 7119.19 MB/s Benchmark______Pub1K_Payload-16 24499346 151.1 ns/op 6869.92 MB/s Benchmark______Pub1K_Payload-16 24362325 144.4 ns/op 7188.10 MB/s Benchmark______Pub1K_Payload-16 23060724 144.9 ns/op 7161.38 MB/s Benchmark______Pub1K_Payload-16 25045016 150.7 ns/op 6888.60 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5477708 613.6 ns/op 6698.71 MB/s Benchmark______Pub4K_Payload-16 5545539 614.4 ns/op 6689.78 MB/s Benchmark______Pub4K_Payload-16 5309338 627.8 ns/op 6546.89 MB/s Benchmark______Pub4K_Payload-16 5386276 618.1 ns/op 6649.05 MB/s Benchmark______Pub4K_Payload-16 5483517 623.8 ns/op 6589.12 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2686558 1280 ns/op 6410.53 MB/s Benchmark______Pub8K_Payload-16 2732905 1274 ns/op 6440.46 MB/s Benchmark______Pub8K_Payload-16 2770965 1270 ns/op 6460.60 MB/s Benchmark______Pub8K_Payload-16 2755233 1272 ns/op 6451.11 MB/s Benchmark______Pub8K_Payload-16 2772643 1352 ns/op 6071.10 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 648450 5502 ns/op 5957.88 MB/s Benchmark_____Pub32K_Payload-16 648801 5611 ns/op 5842.42 MB/s Benchmark_____Pub32K_Payload-16 639920 5517 ns/op 5942.30 MB/s Benchmark_____Pub32K_Payload-16 644925 5538 ns/op 5919.61 MB/s Benchmark_____Pub32K_Payload-16 587863 5661 ns/op 5790.82 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32805792 92.65 ns/op 118.73 MB/s Benchmark__AuthPub0b_Payload-16 36970614 93.33 ns/op 117.86 MB/s Benchmark__AuthPub0b_Payload-16 32863638 92.16 ns/op 119.36 MB/s Benchmark__AuthPub0b_Payload-16 35086168 92.13 ns/op 119.40 MB/s Benchmark__AuthPub0b_Payload-16 37046958 92.05 ns/op 119.50 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15665659 225.3 ns/op Benchmark_____________PubSub-16 15662116 226.0 ns/op Benchmark_____________PubSub-16 15485740 227.1 ns/op Benchmark_____________PubSub-16 15582811 226.1 ns/op Benchmark_____________PubSub-16 15698625 226.8 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15623798 224.5 ns/op Benchmark_____PubSubTwoConns-16 15726758 225.3 ns/op Benchmark_____PubSubTwoConns-16 15786218 225.6 ns/op Benchmark_____PubSubTwoConns-16 15776170 224.6 ns/op Benchmark_____PubSubTwoConns-16 15766009 224.3 ns/op Benchmark__PubServiceImports bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:54806->127.0.0.1:33769: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:46838->127.0.0.1:44321: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:34730->127.0.0.1:46587: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:36620->127.0.0.1:35333: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:54900->127.0.0.1:35843: 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 14364223 249.8 ns/op Benchmark_____PubTwoQueueSub-16 14250619 249.5 ns/op Benchmark_____PubTwoQueueSub-16 14266627 249.2 ns/op Benchmark_____PubTwoQueueSub-16 13995936 248.9 ns/op Benchmark_____PubTwoQueueSub-16 14106477 249.1 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14347252 249.3 ns/op Benchmark____PubFourQueueSub-16 14270072 249.3 ns/op Benchmark____PubFourQueueSub-16 14308837 249.5 ns/op Benchmark____PubFourQueueSub-16 14262388 249.2 ns/op Benchmark____PubFourQueueSub-16 14362956 250.2 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14314420 250.1 ns/op Benchmark___PubEightQueueSub-16 14245303 249.7 ns/op Benchmark___PubEightQueueSub-16 14281836 249.3 ns/op Benchmark___PubEightQueueSub-16 14329836 249.0 ns/op Benchmark___PubEightQueueSub-16 14035152 249.6 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23301 155279 ns/op Benchmark_PubSub512kTwoConns-16 23023 153630 ns/op Benchmark_PubSub512kTwoConns-16 23168 154526 ns/op Benchmark_PubSub512kTwoConns-16 23104 163001 ns/op Benchmark_PubSub512kTwoConns-16 23046 157711 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15105570 232.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15236965 233.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15035384 232.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 14794725 232.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15016960 233.3 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14988920 233.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 14942263 232.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15072138 233.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 14903841 232.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15081704 232.7 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11286254 312.9 ns/op Benchmark____RoutedPubSub_0b-16 11225793 309.1 ns/op Benchmark____RoutedPubSub_0b-16 11619134 314.5 ns/op Benchmark____RoutedPubSub_0b-16 11459002 309.1 ns/op Benchmark____RoutedPubSub_0b-16 11335290 307.2 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6730248 536.5 ns/op Benchmark____RoutedPubSub_1K-16 6795574 534.8 ns/op Benchmark____RoutedPubSub_1K-16 6513087 532.5 ns/op Benchmark____RoutedPubSub_1K-16 6627526 534.7 ns/op Benchmark____RoutedPubSub_1K-16 6731673 513.4 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84908 41566 ns/op Benchmark__RoutedPubSub_100K-16 85771 42366 ns/op Benchmark__RoutedPubSub_100K-16 83997 41607 ns/op Benchmark__RoutedPubSub_100K-16 85288 41036 ns/op Benchmark__RoutedPubSub_100K-16 85752 40303 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9755737 317.4 ns/op Benchmark____Routed2QueueSub-16 9995870 313.6 ns/op Benchmark____Routed2QueueSub-16 9777493 318.3 ns/op Benchmark____Routed2QueueSub-16 9531457 316.9 ns/op Benchmark____Routed2QueueSub-16 9785949 315.0 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9630302 319.0 ns/op Benchmark____Routed4QueueSub-16 9363403 324.0 ns/op Benchmark____Routed4QueueSub-16 9793700 322.1 ns/op Benchmark____Routed4QueueSub-16 9420751 323.0 ns/op Benchmark____Routed4QueueSub-16 11452219 312.5 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 11022189 331.5 ns/op Benchmark____Routed8QueueSub-16 11021583 332.6 ns/op Benchmark____Routed8QueueSub-16 9395012 324.2 ns/op Benchmark____Routed8QueueSub-16 10957974 327.8 ns/op Benchmark____Routed8QueueSub-16 9747421 316.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8717048 350.7 ns/op Benchmark___Routed16QueueSub-16 8859350 351.8 ns/op Benchmark___Routed16QueueSub-16 8994615 346.4 ns/op Benchmark___Routed16QueueSub-16 10529478 346.1 ns/op Benchmark___Routed16QueueSub-16 8780644 345.6 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6499641 549.0 ns/op Benchmark____________RouteCompressOff-16 6470356 549.1 ns/op Benchmark____________RouteCompressOff-16 6342544 549.5 ns/op Benchmark____________RouteCompressOff-16 6451845 551.4 ns/op Benchmark____________RouteCompressOff-16 6425937 550.6 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6566943 503.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6238288 550.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6203200 547.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6398422 556.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6531148 548.0 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6411753 496.0 ns/op Benchmark_________RouteCompressS2Fast-16 6324751 560.0 ns/op Benchmark_________RouteCompressS2Fast-16 6510075 533.1 ns/op Benchmark_________RouteCompressS2Fast-16 6497594 550.9 ns/op Benchmark_________RouteCompressS2Fast-16 6372026 490.3 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6409898 549.7 ns/op Benchmark_______RouteCompressS2Better-16 6428520 480.5 ns/op Benchmark_______RouteCompressS2Better-16 6314533 555.8 ns/op Benchmark_______RouteCompressS2Better-16 6654063 545.4 ns/op Benchmark_______RouteCompressS2Better-16 6518431 554.9 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6599434 493.3 ns/op Benchmark_________RouteCompressS2Best-16 6397788 549.8 ns/op Benchmark_________RouteCompressS2Best-16 6535236 486.1 ns/op Benchmark_________RouteCompressS2Best-16 6447804 549.4 ns/op Benchmark_________RouteCompressS2Best-16 6568099 551.2 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4653694 771.8 ns/op 322.64 MB/s Benchmark______FanOut_8x1x10-16 4631971 770.8 ns/op 323.05 MB/s Benchmark______FanOut_8x1x10-16 4636070 770.9 ns/op 322.98 MB/s Benchmark______FanOut_8x1x10-16 4628582 790.6 ns/op 314.97 MB/s Benchmark______FanOut_8x1x10-16 4644981 774.7 ns/op 321.43 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 533151 6166 ns/op 376.11 MB/s Benchmark_____FanOut_8x1x100-16 547369 6208 ns/op 373.56 MB/s Benchmark_____FanOut_8x1x100-16 543432 6159 ns/op 376.55 MB/s Benchmark_____FanOut_8x1x100-16 554466 6257 ns/op 370.63 MB/s Benchmark_____FanOut_8x1x100-16 546729 6107 ns/op 379.71 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47584 74733 ns/op 308.02 MB/s Benchmark____FanOut_8x10x100-16 47890 74736 ns/op 308.00 MB/s Benchmark____FanOut_8x10x100-16 44640 75995 ns/op 302.90 MB/s Benchmark____FanOut_8x10x100-16 47265 75026 ns/op 306.81 MB/s Benchmark____FanOut_8x10x100-16 47505 76080 ns/op 302.56 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5836 598149 ns/op 401.27 MB/s Benchmark___FanOut_8x10x1000-16 5842 644025 ns/op 372.69 MB/s Benchmark___FanOut_8x10x1000-16 5814 631220 ns/op 380.25 MB/s Benchmark___FanOut_8x10x1000-16 5570 610276 ns/op 393.30 MB/s Benchmark___FanOut_8x10x1000-16 5794 641948 ns/op 373.89 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4974 708306 ns/op 324.75 MB/s Benchmark___FanOut_8x100x100-16 4989 718249 ns/op 320.25 MB/s Benchmark___FanOut_8x100x100-16 5036 714103 ns/op 322.11 MB/s Benchmark___FanOut_8x100x100-16 4914 711178 ns/op 323.43 MB/s Benchmark___FanOut_8x100x100-16 4956 710084 ns/op 323.93 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 583 6192023 ns/op 387.60 MB/s Benchmark__FanOut_8x100x1000-16 574 6319044 ns/op 379.81 MB/s Benchmark__FanOut_8x100x1000-16 573 6163671 ns/op 389.38 MB/s Benchmark__FanOut_8x100x1000-16 576 6311526 ns/op 380.26 MB/s Benchmark__FanOut_8x100x1000-16 566 6254681 ns/op 383.72 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 524 6941071 ns/op 360.18 MB/s Benchmark__FanOut_8x10x10000-16 526 6845527 ns/op 365.20 MB/s Benchmark__FanOut_8x10x10000-16 529 6894710 ns/op 362.60 MB/s Benchmark__FanOut_8x10x10000-16 511 7203513 ns/op 347.06 MB/s Benchmark__FanOut_8x10x10000-16 524 7116690 ns/op 351.29 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 918 3861424 ns/op 297.82 MB/s Benchmark___FanOut_8x500x100-16 927 3778497 ns/op 304.36 MB/s Benchmark___FanOut_8x500x100-16 939 3778821 ns/op 304.33 MB/s Benchmark___FanOut_8x500x100-16 934 3747098 ns/op 306.91 MB/s Benchmark___FanOut_8x500x100-16 954 3790024 ns/op 303.43 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 352459 9552 ns/op 1532.77 MB/s Benchmark___FanOut_128x1x100-16 356713 9567 ns/op 1530.44 MB/s Benchmark___FanOut_128x1x100-16 364650 9545 ns/op 1533.86 MB/s Benchmark___FanOut_128x1x100-16 361359 9603 ns/op 1524.65 MB/s Benchmark___FanOut_128x1x100-16 364460 9706 ns/op 1508.40 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32402 111537 ns/op 1301.28 MB/s Benchmark__FanOut_128x10x100-16 32373 110834 ns/op 1309.53 MB/s Benchmark__FanOut_128x10x100-16 32557 111218 ns/op 1305.01 MB/s Benchmark__FanOut_128x10x100-16 32367 111061 ns/op 1306.86 MB/s Benchmark__FanOut_128x10x100-16 32208 111053 ns/op 1306.95 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4086 883476 ns/op 1652.72 MB/s Benchmark_FanOut_128x10x1000-16 3930 884205 ns/op 1651.36 MB/s Benchmark_FanOut_128x10x1000-16 3924 892301 ns/op 1636.38 MB/s Benchmark_FanOut_128x10x1000-16 3894 883058 ns/op 1653.50 MB/s Benchmark_FanOut_128x10x1000-16 3945 923221 ns/op 1581.57 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3505 1023802 ns/op 1416.43 MB/s Benchmark_FanOut_128x100x100-16 3459 1021149 ns/op 1420.11 MB/s Benchmark_FanOut_128x100x100-16 3489 1020242 ns/op 1421.37 MB/s Benchmark_FanOut_128x100x100-16 3468 1019055 ns/op 1423.03 MB/s Benchmark_FanOut_128x100x100-16 3510 1015143 ns/op 1428.51 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 380 9413022 ns/op 1551.06 MB/s BenchmarkFanOut_128x100x1000-16 378 9422905 ns/op 1549.43 MB/s BenchmarkFanOut_128x100x1000-16 378 9519727 ns/op 1533.67 MB/s BenchmarkFanOut_128x100x1000-16 381 9435137 ns/op 1547.42 MB/s BenchmarkFanOut_128x100x1000-16 376 9424481 ns/op 1549.17 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 372 9859522 ns/op 1490.96 MB/s BenchmarkFanOut_128x10x10000-16 366 9768138 ns/op 1504.91 MB/s BenchmarkFanOut_128x10x10000-16 366 9700628 ns/op 1515.38 MB/s BenchmarkFanOut_128x10x10000-16 369 9779629 ns/op 1503.14 MB/s BenchmarkFanOut_128x10x10000-16 367 9737474 ns/op 1509.65 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 662 5293696 ns/op 1369.58 MB/s BenchmarkFanOut__128x500x100-16 674 5350631 ns/op 1355.01 MB/s BenchmarkFanOut__128x500x100-16 670 5324968 ns/op 1361.54 MB/s BenchmarkFanOut__128x500x100-16 664 5337544 ns/op 1358.33 MB/s BenchmarkFanOut__128x500x100-16 666 5358336 ns/op 1353.06 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1909 1869821 ns/op 2829.43 MB/s Benchmark_FanOut_512x100x100-16 1918 1849588 ns/op 2860.38 MB/s Benchmark_FanOut_512x100x100-16 1915 1905541 ns/op 2776.39 MB/s Benchmark_FanOut_512x100x100-16 1953 1868799 ns/op 2830.98 MB/s Benchmark_FanOut_512x100x100-16 1929 1844396 ns/op 2868.43 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 16976073 ns/op 3122.07 MB/s Benchmark__FanOut_512x100x1k-16 211 16902154 ns/op 3135.73 MB/s Benchmark__FanOut_512x100x1k-16 212 16665165 ns/op 3180.32 MB/s Benchmark__FanOut_512x100x1k-16 213 16914866 ns/op 3133.37 MB/s Benchmark__FanOut_512x100x1k-16 214 16949685 ns/op 3126.93 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3114 1155337 ns/op 9028.56 MB/s Benchmark____FanOut_1kx10x1k-16 3288 1156684 ns/op 9018.05 MB/s Benchmark____FanOut_1kx10x1k-16 3070 1175921 ns/op 8870.53 MB/s Benchmark____FanOut_1kx10x1k-16 2890 1159046 ns/op 8999.67 MB/s Benchmark____FanOut_1kx10x1k-16 3038 1135226 ns/op 9188.51 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2749 1255861 ns/op 8297.92 MB/s Benchmark__FanOut_1kx100x100-16 2762 1259420 ns/op 8274.47 MB/s Benchmark__FanOut_1kx100x100-16 2830 1257993 ns/op 8283.86 MB/s Benchmark__FanOut_1kx100x100-16 2737 1267228 ns/op 8223.49 MB/s Benchmark__FanOut_1kx100x100-16 2758 1267446 ns/op 8222.08 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4442668 768.4 ns/op 324.06 MB/s Benchmark_____RFanOut_8x1x10-16 4501003 791.3 ns/op 314.66 MB/s Benchmark_____RFanOut_8x1x10-16 4574508 798.6 ns/op 311.80 MB/s Benchmark_____RFanOut_8x1x10-16 4458997 787.6 ns/op 316.14 MB/s Benchmark_____RFanOut_8x1x10-16 4296514 770.6 ns/op 323.14 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 529810 6365 ns/op 364.32 MB/s Benchmark____RFanOut_8x1x100-16 484063 6349 ns/op 365.28 MB/s Benchmark____RFanOut_8x1x100-16 518724 6404 ns/op 362.12 MB/s Benchmark____RFanOut_8x1x100-16 537042 6421 ns/op 361.16 MB/s Benchmark____RFanOut_8x1x100-16 530648 6352 ns/op 365.10 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48123 75635 ns/op 304.34 MB/s Benchmark___RFanOut_8x10x100-16 47749 74352 ns/op 309.59 MB/s Benchmark___RFanOut_8x10x100-16 48112 74431 ns/op 309.27 MB/s Benchmark___RFanOut_8x10x100-16 47660 74766 ns/op 307.88 MB/s Benchmark___RFanOut_8x10x100-16 47907 75394 ns/op 305.31 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5613 602775 ns/op 398.19 MB/s Benchmark__RFanOut_8x10x1000-16 5878 603568 ns/op 397.67 MB/s Benchmark__RFanOut_8x10x1000-16 5941 601142 ns/op 399.27 MB/s Benchmark__RFanOut_8x10x1000-16 5714 601425 ns/op 399.08 MB/s Benchmark__RFanOut_8x10x1000-16 5920 602515 ns/op 398.36 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5005 717998 ns/op 320.36 MB/s Benchmark__RFanOut_8x100x100-16 4994 713747 ns/op 322.27 MB/s Benchmark__RFanOut_8x100x100-16 4950 721950 ns/op 318.61 MB/s Benchmark__RFanOut_8x100x100-16 5007 706908 ns/op 325.39 MB/s Benchmark__RFanOut_8x100x100-16 4902 706364 ns/op 325.64 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 564 6245932 ns/op 384.25 MB/s Benchmark_RFanOut_8x100x1000-16 567 6200892 ns/op 387.04 MB/s Benchmark_RFanOut_8x100x1000-16 553 6262051 ns/op 383.26 MB/s Benchmark_RFanOut_8x100x1000-16 567 6235338 ns/op 384.91 MB/s Benchmark_RFanOut_8x100x1000-16 567 6289049 ns/op 381.62 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 530 6748037 ns/op 370.48 MB/s Benchmark_RFanOut_8x10x10000-16 523 6794904 ns/op 367.93 MB/s Benchmark_RFanOut_8x10x10000-16 513 6812640 ns/op 366.97 MB/s Benchmark_RFanOut_8x10x10000-16 520 6795802 ns/op 367.88 MB/s Benchmark_RFanOut_8x10x10000-16 510 6807793 ns/op 367.23 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3102 1152569 ns/op 9050.25 MB/s Benchmark_RFanOut_1kx10x1000-16 3078 1146828 ns/op 9095.56 MB/s Benchmark_RFanOut_1kx10x1000-16 2911 1156337 ns/op 9020.76 MB/s Benchmark_RFanOut_1kx10x1000-16 3102 1153049 ns/op 9046.48 MB/s Benchmark_RFanOut_1kx10x1000-16 2923 1154156 ns/op 9037.80 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6982071 502.7 ns/op 4133.93 MB/s Benchmark_____FanIn_1kx100x1-16 7003714 503.4 ns/op 4128.31 MB/s Benchmark_____FanIn_1kx100x1-16 6950805 502.6 ns/op 4134.49 MB/s Benchmark_____FanIn_1kx100x1-16 7013088 503.8 ns/op 4124.46 MB/s Benchmark_____FanIn_1kx100x1-16 6931508 505.3 ns/op 4112.50 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2651661 1359 ns/op 6048.19 MB/s Benchmark_____FanIn_4kx100x1-16 2606110 1354 ns/op 6073.56 MB/s Benchmark_____FanIn_4kx100x1-16 2610050 1355 ns/op 6066.39 MB/s Benchmark_____FanIn_4kx100x1-16 2632407 1369 ns/op 6006.62 MB/s Benchmark_____FanIn_4kx100x1-16 2692024 1370 ns/op 6001.43 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1708940 2099 ns/op 7818.61 MB/s Benchmark_____FanIn_8kx100x1-16 1660125 2099 ns/op 7820.53 MB/s Benchmark_____FanIn_8kx100x1-16 1725634 2107 ns/op 7790.14 MB/s Benchmark_____FanIn_8kx100x1-16 1723446 2118 ns/op 7751.07 MB/s Benchmark_____FanIn_8kx100x1-16 1730822 2096 ns/op 7832.17 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 874285 4132 ns/op 7937.35 MB/s Benchmark____FanIn_16kx100x1-16 828646 4154 ns/op 7896.70 MB/s Benchmark____FanIn_16kx100x1-16 868300 4109 ns/op 7982.28 MB/s Benchmark____FanIn_16kx100x1-16 840139 4164 ns/op 7876.47 MB/s Benchmark____FanIn_16kx100x1-16 861294 4171 ns/op 7864.74 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 623212371 vs 10927685100 bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:33418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:33926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:33096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:33208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:33902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:33524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:33310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:33250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:33344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33534->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 169287 19903 ns/op 6587.27 MB/s Benchmark____FanIn_64kx100x1-16 166177 19946 ns/op 6572.84 MB/s Benchmark____FanIn_64kx100x1-16 164246 19888 ns/op 6592.25 MB/s Benchmark____FanIn_64kx100x1-16 173167 19758 ns/op 6635.42 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 254183510 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34468->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: 791652510 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36388->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36644->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: 207253290 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:38340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:37904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:38402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:38318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:38488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:38440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:38200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:38544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:38512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:37970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:37772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:38314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:38332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:37778->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: 280401510 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:39630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:39886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40286->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:39526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:39850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40096->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1202750750 vs 11404830000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59890->127.0.0.1:5222: write: broken pipe bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60332->127.0.0.1:5222: write: broken pipe bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60478->127.0.0.1:5222: write: broken pipe bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60050->127.0.0.1:5222: write: broken pipe bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60010->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5604778 640.2 ns/op 443.63 MB/s Benchmark___BumpPubCount_1x3-16 5640632 639.9 ns/op 443.79 MB/s Benchmark___BumpPubCount_1x3-16 5632497 639.2 ns/op 444.28 MB/s Benchmark___BumpPubCount_1x3-16 5591457 640.6 ns/op 443.34 MB/s Benchmark___BumpPubCount_1x3-16 5568698 640.2 ns/op 443.59 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5269551 674.1 ns/op 421.32 MB/s Benchmark___BumpPubCount_2x3-16 5313025 671.7 ns/op 422.81 MB/s Benchmark___BumpPubCount_2x3-16 5314539 673.7 ns/op 421.55 MB/s Benchmark___BumpPubCount_2x3-16 5327451 677.1 ns/op 419.44 MB/s Benchmark___BumpPubCount_2x3-16 5253326 673.2 ns/op 421.89 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5600460 641.3 ns/op 442.85 MB/s Benchmark___BumpPubCount_5x3-16 5594377 645.1 ns/op 440.25 MB/s Benchmark___BumpPubCount_5x3-16 5560678 641.7 ns/op 442.56 MB/s Benchmark___BumpPubCount_5x3-16 5544780 642.2 ns/op 442.20 MB/s Benchmark___BumpPubCount_5x3-16 5549805 640.5 ns/op 443.41 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5017374 640.6 ns/op 443.37 MB/s Benchmark__BumpPubCount_10x3-16 5593972 638.6 ns/op 444.73 MB/s Benchmark__BumpPubCount_10x3-16 5620225 642.1 ns/op 442.28 MB/s Benchmark__BumpPubCount_10x3-16 5590725 643.2 ns/op 441.56 MB/s Benchmark__BumpPubCount_10x3-16 5613618 642.1 ns/op 442.27 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12778917 280.7 ns/op 3705.51 MB/s Benchmark____GWs_Opt_1kx01x0-16 13518949 265.3 ns/op 3919.93 MB/s Benchmark____GWs_Opt_1kx01x0-16 13580631 264.1 ns/op 3938.13 MB/s Benchmark____GWs_Opt_1kx01x0-16 13482783 261.6 ns/op 3975.08 MB/s Benchmark____GWs_Opt_1kx01x0-16 12595816 262.5 ns/op 3961.72 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10236068 329.7 ns/op 6260.21 MB/s Benchmark____GWs_Opt_2kx01x0-16 11085441 321.5 ns/op 6419.50 MB/s Benchmark____GWs_Opt_2kx01x0-16 10932391 331.9 ns/op 6218.34 MB/s Benchmark____GWs_Opt_2kx01x0-16 9688812 333.9 ns/op 6180.88 MB/s Benchmark____GWs_Opt_2kx01x0-16 10339332 329.4 ns/op 6265.10 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5855389 607.6 ns/op 6767.54 MB/s Benchmark____GWs_Opt_4kx01x0-16 5974968 626.3 ns/op 6565.55 MB/s Benchmark____GWs_Opt_4kx01x0-16 6017356 617.2 ns/op 6662.00 MB/s Benchmark____GWs_Opt_4kx01x0-16 5748967 621.3 ns/op 6618.57 MB/s Benchmark____GWs_Opt_4kx01x0-16 5765644 631.5 ns/op 6511.07 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 31055790 113.3 ns/op 9181.09 MB/s Benchmark____GWs_Opt_1kx10x0-16 20955718 747.7 ns/op 1390.90 MB/s Benchmark____GWs_Opt_1kx10x0-16 29929176 116.3 ns/op 8941.24 MB/s Benchmark____GWs_Opt_1kx10x0-16 31443618 111.2 ns/op 9353.35 MB/s Benchmark____GWs_Opt_1kx10x0-16 32535226 125.0 ns/op 8322.24 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 22849195 148.7 ns/op 13876.73 MB/s Benchmark____GWs_Opt_2kx10x0-16 21711850 183.4 ns/op 11252.15 MB/s Benchmark____GWs_Opt_2kx10x0-16 22491870 140.3 ns/op 14709.36 MB/s Benchmark____GWs_Opt_2kx10x0-16 24410326 151.7 ns/op 13603.50 MB/s Benchmark____GWs_Opt_2kx10x0-16 25516034 164.3 ns/op 12565.16 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 10750647 285.8 ns/op 14388.00 MB/s Benchmark____GWs_Opt_4kx10x0-16 12991284 291.1 ns/op 14125.07 MB/s Benchmark____GWs_Opt_4kx10x0-16 12796314 305.0 ns/op 13480.73 MB/s Benchmark____GWs_Opt_4kx10x0-16 12557541 283.5 ns/op 14503.94 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:36200->127.0.0.1:43111: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:48214->127.0.0.1:38501: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6524184 666.7 ns/op 4687.36 MB/s Benchmark____GWs_Opt_1kx01x1-16 6555222 546.0 ns/op 5723.01 MB/s Benchmark____GWs_Opt_1kx01x1-16 6536715 538.5 ns/op 5803.12 MB/s Benchmark____GWs_Opt_1kx01x1-16 6708656 542.6 ns/op 5759.14 MB/s Benchmark____GWs_Opt_1kx01x1-16 6571807 547.7 ns/op 5705.51 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4698060 747.9 ns/op 8286.37 MB/s Benchmark____GWs_Opt_2kx01x1-16 4764918 752.7 ns/op 8233.54 MB/s Benchmark____GWs_Opt_2kx01x1-16 4676882 755.5 ns/op 8202.51 MB/s Benchmark____GWs_Opt_2kx01x1-16 4515369 755.1 ns/op 8207.20 MB/s Benchmark____GWs_Opt_2kx01x1-16 4683667 755.3 ns/op 8205.01 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2666920 1368 ns/op 9024.23 MB/s Benchmark____GWs_Opt_4kx01x1-16 2644304 2847 ns/op 4335.28 MB/s Benchmark____GWs_Opt_4kx01x1-16 2648700 1352 ns/op 9127.96 MB/s Benchmark____GWs_Opt_4kx01x1-16 2643955 1355 ns/op 9108.27 MB/s Benchmark____GWs_Opt_4kx01x1-16 2592415 1578 ns/op 7819.69 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 5963084 551.0 ns/op 5671.70 MB/s Benchmark____GWs_Opt_1kx10x1-16 6607404 554.5 ns/op 5635.43 MB/s Benchmark____GWs_Opt_1kx10x1-16 6191486 552.2 ns/op 5659.57 MB/s Benchmark____GWs_Opt_1kx10x1-16 6467578 548.0 ns/op 5702.14 MB/s Benchmark____GWs_Opt_1kx10x1-16 6604872 549.9 ns/op 5682.85 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4371579 848.3 ns/op 7305.20 MB/s Benchmark____GWs_Opt_2kx10x1-16 4142336 844.5 ns/op 7338.33 MB/s Benchmark____GWs_Opt_2kx10x1-16 4701508 843.4 ns/op 7347.82 MB/s Benchmark____GWs_Opt_2kx10x1-16 4656176 832.9 ns/op 7440.67 MB/s Benchmark____GWs_Opt_2kx10x1-16 4126998 852.3 ns/op 7271.00 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2399198 1527 ns/op 8079.58 MB/s Benchmark____GWs_Opt_4kx10x1-16 2540494 1517 ns/op 8134.47 MB/s Benchmark____GWs_Opt_4kx10x1-16 2379397 1446 ns/op 8534.90 MB/s Benchmark____GWs_Opt_4kx10x1-16 2363346 1477 ns/op 8355.43 MB/s Benchmark____GWs_Opt_4kx10x1-16 2325122 1527 ns/op 8079.91 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12821436 277.9 ns/op 3742.97 MB/s Benchmark____GWs_Int_1kx01x0-16 12344318 284.0 ns/op 3661.64 MB/s Benchmark____GWs_Int_1kx01x0-16 12593227 277.5 ns/op 3747.76 MB/s Benchmark____GWs_Int_1kx01x0-16 12318086 284.5 ns/op 3656.04 MB/s Benchmark____GWs_Int_1kx01x0-16 12528232 281.0 ns/op 3700.59 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10200528 336.4 ns/op 6134.89 MB/s Benchmark____GWs_Int_2kx01x0-16 9167043 354.8 ns/op 5817.08 MB/s Benchmark____GWs_Int_2kx01x0-16 9698055 353.5 ns/op 5838.02 MB/s Benchmark____GWs_Int_2kx01x0-16 10281433 354.2 ns/op 5826.78 MB/s Benchmark____GWs_Int_2kx01x0-16 10645032 331.1 ns/op 6232.91 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5817985 618.2 ns/op 6651.49 MB/s Benchmark____GWs_Int_4kx01x0-16 6020616 626.2 ns/op 6566.67 MB/s Benchmark____GWs_Int_4kx01x0-16 5796225 625.2 ns/op 6576.59 MB/s Benchmark____GWs_Int_4kx01x0-16 5913890 620.0 ns/op 6632.27 MB/s Benchmark____GWs_Int_4kx01x0-16 5768096 641.7 ns/op 6407.50 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32096750 139.0 ns/op 7482.49 MB/s Benchmark____GWs_Int_1kx10x0-16 31141270 116.8 ns/op 8902.69 MB/s Benchmark____GWs_Int_1kx10x0-16 31810670 116.8 ns/op 8903.98 MB/s Benchmark____GWs_Int_1kx10x0-16 31760146 109.2 ns/op 9524.81 MB/s Benchmark____GWs_Int_1kx10x0-16 27761013 113.2 ns/op 9184.80 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 22642956 161.3 ns/op 12797.90 MB/s Benchmark____GWs_Int_2kx10x0-16 24761266 141.4 ns/op 14593.51 MB/s Benchmark____GWs_Int_2kx10x0-16 26266358 140.9 ns/op 14648.78 MB/s Benchmark____GWs_Int_2kx10x0-16 25576698 141.6 ns/op 14571.72 MB/s Benchmark____GWs_Int_2kx10x0-16 25035496 141.1 ns/op 14623.17 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12501300 285.2 ns/op 14417.60 MB/s Benchmark____GWs_Int_4kx10x0-16 13114677 302.3 ns/op 13604.22 MB/s Benchmark____GWs_Int_4kx10x0-16 11961342 279.9 ns/op 14692.59 MB/s Benchmark____GWs_Int_4kx10x0-16 13211683 286.0 ns/op 14377.01 MB/s Benchmark____GWs_Int_4kx10x0-16 13099920 279.6 ns/op 14707.78 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6294327 551.0 ns/op 5671.59 MB/s Benchmark____GWs_Int_1kx01x1-16 6598754 547.0 ns/op 5712.85 MB/s Benchmark____GWs_Int_1kx01x1-16 6493650 551.5 ns/op 5665.93 MB/s Benchmark____GWs_Int_1kx01x1-16 6514593 553.1 ns/op 5649.53 MB/s Benchmark____GWs_Int_1kx01x1-16 6633681 559.0 ns/op 5590.17 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4777898 752.5 ns/op 8235.15 MB/s Benchmark____GWs_Int_2kx01x1-16 4840387 763.7 ns/op 8114.09 MB/s Benchmark____GWs_Int_2kx01x1-16 4425505 899.6 ns/op 6888.65 MB/s Benchmark____GWs_Int_2kx01x1-16 4791524 774.3 ns/op 8003.07 MB/s Benchmark____GWs_Int_2kx01x1-16 4760635 803.4 ns/op 7713.49 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2677654 1366 ns/op 9036.53 MB/s Benchmark____GWs_Int_4kx01x1-16 2629261 1372 ns/op 8992.45 MB/s Benchmark____GWs_Int_4kx01x1-16 2639542 1561 ns/op 7907.96 MB/s Benchmark____GWs_Int_4kx01x1-16 2574410 1372 ns/op 8992.92 MB/s Benchmark____GWs_Int_4kx01x1-16 2681593 1387 ns/op 8898.79 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6445515 1085 ns/op 2880.69 MB/s Benchmark____GWs_Int_1kx10x1-16 6603705 657.6 ns/op 4751.84 MB/s Benchmark____GWs_Int_1kx10x1-16 6598503 571.6 ns/op 5466.70 MB/s Benchmark____GWs_Int_1kx10x1-16 6412644 544.4 ns/op 5740.30 MB/s Benchmark____GWs_Int_1kx10x1-16 6563653 587.7 ns/op 5317.27 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4152889 838.4 ns/op 7391.37 MB/s Benchmark____GWs_Int_2kx10x1-16 4187341 840.3 ns/op 7374.67 MB/s Benchmark____GWs_Int_2kx10x1-16 4140159 839.9 ns/op 7378.23 MB/s Benchmark____GWs_Int_2kx10x1-16 4670852 830.4 ns/op 7462.40 MB/s Benchmark____GWs_Int_2kx10x1-16 4525993 837.6 ns/op 7398.10 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2160903 1545 ns/op 7989.73 MB/s Benchmark____GWs_Int_4kx10x1-16 2315120 1532 ns/op 8055.36 MB/s Benchmark____GWs_Int_4kx10x1-16 2325352 1573 ns/op 7845.82 MB/s Benchmark____GWs_Int_4kx10x1-16 2364834 1475 ns/op 8367.01 MB/s Benchmark____GWs_Int_4kx10x1-16 2352408 1472 ns/op 8385.53 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 7927672 435.8 ns/op 234.03 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8256865 432.3 ns/op 235.96 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8342082 429.1 ns/op 237.72 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8428338 428.6 ns/op 238.00 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8522058 426.6 ns/op 239.08 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 602446 5116 ns/op 34.60 MB/s Benchmark__GWs_Reqs_1SubEach-16 789951 5238 ns/op 33.79 MB/s Benchmark__GWs_Reqs_1SubEach-16 719890 5206 ns/op 34.00 MB/s Benchmark__GWs_Reqs_1SubEach-16 703760 5308 ns/op 33.35 MB/s Benchmark__GWs_Reqs_1SubEach-16 792324 5307 ns/op 33.35 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2128.824s ❌ Non-zero exit code: 1