> ROOT_DIR=/tmp/go-bench-away-job-bf392387-2645-4cb5-a63b-8d519f1f319c-946268904 > OUTPUT_FILE=/tmp/go-bench-away-job-bf392387-2645-4cb5-a63b-8d519f1f319c-946268904/results.txt > SHA_FILE=/tmp/go-bench-away-job-bf392387-2645-4cb5-a63b-8d519f1f319c-946268904/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-bf392387-2645-4cb5-a63b-8d519f1f319c-946268904/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.25.4/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-bf392387-2645-4cb5-a63b-8d519f1f319c-946268904/source.git SHA of main: 51fbade1ed5aa9cd026e6be57ad9b0c6272f6709 Go runtime: go version go1.26.0 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-build3475988013=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-bf392387-2645-4cb5-a63b-8d519f1f319c-946268904/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.25.4' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.25.4/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.0' 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 53519473 67.33 ns/op 163.38 MB/s Benchmark______Pub0b_Payload-16 50583493 67.34 ns/op 163.34 MB/s Benchmark______Pub0b_Payload-16 50814112 67.37 ns/op 163.27 MB/s Benchmark______Pub0b_Payload-16 50091811 67.70 ns/op 162.49 MB/s Benchmark______Pub0b_Payload-16 45440023 67.25 ns/op 163.56 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 53173017 68.04 ns/op 279.24 MB/s Benchmark______Pub8b_Payload-16 52961740 68.18 ns/op 278.67 MB/s Benchmark______Pub8b_Payload-16 48768284 68.00 ns/op 279.43 MB/s Benchmark______Pub8b_Payload-16 49907319 67.83 ns/op 280.12 MB/s Benchmark______Pub8b_Payload-16 51284757 68.17 ns/op 278.73 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 45689445 72.38 ns/op 607.91 MB/s Benchmark_____Pub32b_Payload-16 46899202 72.45 ns/op 607.34 MB/s Benchmark_____Pub32b_Payload-16 49781102 72.18 ns/op 609.57 MB/s Benchmark_____Pub32b_Payload-16 47258421 72.64 ns/op 605.72 MB/s Benchmark_____Pub32b_Payload-16 49634334 71.99 ns/op 611.23 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 36823590 82.13 ns/op 1716.77 MB/s Benchmark____Pub128B_Payload-16 41362830 81.94 ns/op 1720.70 MB/s Benchmark____Pub128B_Payload-16 36295569 92.78 ns/op 1519.76 MB/s Benchmark____Pub128B_Payload-16 44038154 83.59 ns/op 1686.79 MB/s Benchmark____Pub128B_Payload-16 41138662 82.61 ns/op 1706.78 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 39894892 91.23 ns/op 2948.57 MB/s Benchmark____Pub256B_Payload-16 34041003 90.17 ns/op 2983.20 MB/s Benchmark____Pub256B_Payload-16 38488226 91.26 ns/op 2947.70 MB/s Benchmark____Pub256B_Payload-16 39857618 90.50 ns/op 2972.34 MB/s Benchmark____Pub256B_Payload-16 38158897 91.82 ns/op 2929.71 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 26963311 136.7 ns/op 7590.81 MB/s Benchmark______Pub1K_Payload-16 25373440 130.4 ns/op 7961.33 MB/s Benchmark______Pub1K_Payload-16 27004432 132.3 ns/op 7843.26 MB/s Benchmark______Pub1K_Payload-16 24175837 138.5 ns/op 7494.36 MB/s Benchmark______Pub1K_Payload-16 23838104 135.7 ns/op 7651.79 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5688099 621.6 ns/op 6612.32 MB/s Benchmark______Pub4K_Payload-16 5462822 616.8 ns/op 6663.31 MB/s Benchmark______Pub4K_Payload-16 5284737 615.3 ns/op 6679.65 MB/s Benchmark______Pub4K_Payload-16 5803669 635.4 ns/op 6468.46 MB/s Benchmark______Pub4K_Payload-16 5319135 619.9 ns/op 6630.11 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2823615 1291 ns/op 6358.70 MB/s Benchmark______Pub8K_Payload-16 2663767 1283 ns/op 6395.41 MB/s Benchmark______Pub8K_Payload-16 2745310 1284 ns/op 6390.41 MB/s Benchmark______Pub8K_Payload-16 2753938 1284 ns/op 6392.79 MB/s Benchmark______Pub8K_Payload-16 2793781 1276 ns/op 6432.00 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 586772 5368 ns/op 6107.42 MB/s Benchmark_____Pub32K_Payload-16 569497 5333 ns/op 6147.16 MB/s Benchmark_____Pub32K_Payload-16 680287 5352 ns/op 6125.11 MB/s Benchmark_____Pub32K_Payload-16 671953 16539 ns/op 1982.17 MB/s Benchmark_____Pub32K_Payload-16 678153 5348 ns/op 6130.33 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 41203724 87.90 ns/op 125.14 MB/s Benchmark__AuthPub0b_Payload-16 34639172 87.51 ns/op 125.69 MB/s Benchmark__AuthPub0b_Payload-16 35104518 87.92 ns/op 125.11 MB/s Benchmark__AuthPub0b_Payload-16 39023068 87.95 ns/op 125.08 MB/s Benchmark__AuthPub0b_Payload-16 38851420 88.03 ns/op 124.95 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 16810004 208.4 ns/op Benchmark_____________PubSub-16 16652373 210.2 ns/op Benchmark_____________PubSub-16 16790322 209.8 ns/op Benchmark_____________PubSub-16 16741712 210.8 ns/op Benchmark_____________PubSub-16 16924118 211.1 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 17038371 208.4 ns/op Benchmark_____PubSubTwoConns-16 17101705 208.6 ns/op Benchmark_____PubSubTwoConns-16 16874137 209.4 ns/op Benchmark_____PubSubTwoConns-16 17004421 210.2 ns/op Benchmark_____PubSubTwoConns-16 16952900 208.9 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49354->127.0.0.1:33691: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:56254->127.0.0.1:35631: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33288->127.0.0.1:38889: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41758->127.0.0.1:36593: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49276->127.0.0.1:45389: 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 15388635 226.7 ns/op Benchmark_____PubTwoQueueSub-16 15608434 227.2 ns/op Benchmark_____PubTwoQueueSub-16 15665880 227.2 ns/op Benchmark_____PubTwoQueueSub-16 15708538 227.8 ns/op Benchmark_____PubTwoQueueSub-16 15966819 226.4 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15709515 226.1 ns/op Benchmark____PubFourQueueSub-16 15592938 226.3 ns/op Benchmark____PubFourQueueSub-16 15735382 226.5 ns/op Benchmark____PubFourQueueSub-16 15523870 226.6 ns/op Benchmark____PubFourQueueSub-16 15705522 226.5 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15461262 226.5 ns/op Benchmark___PubEightQueueSub-16 15644667 226.4 ns/op Benchmark___PubEightQueueSub-16 15839152 227.2 ns/op Benchmark___PubEightQueueSub-16 15641403 226.3 ns/op Benchmark___PubEightQueueSub-16 15758335 226.1 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23149 155945 ns/op Benchmark_PubSub512kTwoConns-16 23149 165149 ns/op Benchmark_PubSub512kTwoConns-16 23024 160806 ns/op Benchmark_PubSub512kTwoConns-16 22893 156378 ns/op Benchmark_PubSub512kTwoConns-16 23023 155268 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16390387 213.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 16189909 212.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 16368406 211.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 16195845 212.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 16214721 212.4 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16476372 213.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 16324263 212.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 16422886 212.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 16395734 211.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 16692698 212.8 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11714802 290.9 ns/op Benchmark____RoutedPubSub_0b-16 12007465 289.6 ns/op Benchmark____RoutedPubSub_0b-16 12085262 298.0 ns/op Benchmark____RoutedPubSub_0b-16 11691608 294.9 ns/op Benchmark____RoutedPubSub_0b-16 12216584 296.9 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6838444 514.6 ns/op Benchmark____RoutedPubSub_1K-16 6988724 515.6 ns/op Benchmark____RoutedPubSub_1K-16 6835572 523.5 ns/op Benchmark____RoutedPubSub_1K-16 7007302 515.5 ns/op Benchmark____RoutedPubSub_1K-16 6939584 519.8 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84146 43116 ns/op Benchmark__RoutedPubSub_100K-16 82584 43020 ns/op Benchmark__RoutedPubSub_100K-16 83444 42311 ns/op Benchmark__RoutedPubSub_100K-16 84100 43572 ns/op Benchmark__RoutedPubSub_100K-16 79874 43586 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11843190 304.7 ns/op Benchmark____Routed2QueueSub-16 9997917 306.2 ns/op Benchmark____Routed2QueueSub-16 10156174 308.3 ns/op Benchmark____Routed2QueueSub-16 10065487 305.5 ns/op Benchmark____Routed2QueueSub-16 9999156 302.0 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9783468 311.4 ns/op Benchmark____Routed4QueueSub-16 9866926 309.7 ns/op Benchmark____Routed4QueueSub-16 11741932 303.8 ns/op Benchmark____Routed4QueueSub-16 9898004 313.6 ns/op Benchmark____Routed4QueueSub-16 11741817 310.6 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9614492 312.3 ns/op Benchmark____Routed8QueueSub-16 9900120 321.2 ns/op Benchmark____Routed8QueueSub-16 9502840 321.0 ns/op Benchmark____Routed8QueueSub-16 9415563 324.0 ns/op Benchmark____Routed8QueueSub-16 9490734 322.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 9064711 340.8 ns/op Benchmark___Routed16QueueSub-16 9295260 335.6 ns/op Benchmark___Routed16QueueSub-16 9412357 339.4 ns/op Benchmark___Routed16QueueSub-16 9090639 344.2 ns/op Benchmark___Routed16QueueSub-16 9181458 342.9 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6641962 523.0 ns/op Benchmark____________RouteCompressOff-16 6666103 530.4 ns/op Benchmark____________RouteCompressOff-16 6673736 526.9 ns/op Benchmark____________RouteCompressOff-16 6598864 532.2 ns/op Benchmark____________RouteCompressOff-16 6672976 532.9 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6942741 529.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6478107 534.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6540957 538.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6706302 531.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6692294 458.1 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6493851 527.6 ns/op Benchmark_________RouteCompressS2Fast-16 6586045 529.2 ns/op Benchmark_________RouteCompressS2Fast-16 6619126 466.1 ns/op Benchmark_________RouteCompressS2Fast-16 6782778 528.7 ns/op Benchmark_________RouteCompressS2Fast-16 6614276 533.3 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6868119 529.1 ns/op Benchmark_______RouteCompressS2Better-16 6834876 526.7 ns/op Benchmark_______RouteCompressS2Better-16 6645738 469.6 ns/op Benchmark_______RouteCompressS2Better-16 6554924 528.0 ns/op Benchmark_______RouteCompressS2Better-16 7427757 530.6 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6816603 532.0 ns/op Benchmark_________RouteCompressS2Best-16 6530978 529.4 ns/op Benchmark_________RouteCompressS2Best-16 6589650 529.2 ns/op Benchmark_________RouteCompressS2Best-16 6724618 528.7 ns/op Benchmark_________RouteCompressS2Best-16 6779938 528.1 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5186079 686.2 ns/op 362.87 MB/s Benchmark______FanOut_8x1x10-16 5213227 691.5 ns/op 360.08 MB/s Benchmark______FanOut_8x1x10-16 5202918 682.8 ns/op 364.65 MB/s Benchmark______FanOut_8x1x10-16 5269274 681.1 ns/op 365.61 MB/s Benchmark______FanOut_8x1x10-16 5281141 687.6 ns/op 362.14 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 614328 5287 ns/op 438.64 MB/s Benchmark_____FanOut_8x1x100-16 640214 5349 ns/op 433.56 MB/s Benchmark_____FanOut_8x1x100-16 618856 5351 ns/op 433.34 MB/s Benchmark_____FanOut_8x1x100-16 615495 5302 ns/op 437.39 MB/s Benchmark_____FanOut_8x1x100-16 606186 5508 ns/op 420.99 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 52862 67637 ns/op 340.33 MB/s Benchmark____FanOut_8x10x100-16 52957 67670 ns/op 340.16 MB/s Benchmark____FanOut_8x10x100-16 53294 68038 ns/op 338.33 MB/s Benchmark____FanOut_8x10x100-16 52974 67763 ns/op 339.70 MB/s Benchmark____FanOut_8x10x100-16 52803 67874 ns/op 339.15 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6490 531395 ns/op 451.68 MB/s Benchmark___FanOut_8x10x1000-16 6651 538040 ns/op 446.10 MB/s Benchmark___FanOut_8x10x1000-16 6507 533083 ns/op 450.25 MB/s Benchmark___FanOut_8x10x1000-16 6248 531328 ns/op 451.73 MB/s Benchmark___FanOut_8x10x1000-16 6546 536958 ns/op 447.00 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5596 630903 ns/op 364.59 MB/s Benchmark___FanOut_8x100x100-16 5524 633378 ns/op 363.16 MB/s Benchmark___FanOut_8x100x100-16 5541 630380 ns/op 364.89 MB/s Benchmark___FanOut_8x100x100-16 5550 633702 ns/op 362.98 MB/s Benchmark___FanOut_8x100x100-16 5576 642964 ns/op 357.75 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 625 5621638 ns/op 426.93 MB/s Benchmark__FanOut_8x100x1000-16 630 5531425 ns/op 433.89 MB/s Benchmark__FanOut_8x100x1000-16 645 5469909 ns/op 438.77 MB/s Benchmark__FanOut_8x100x1000-16 660 5561448 ns/op 431.55 MB/s Benchmark__FanOut_8x100x1000-16 661 5491851 ns/op 437.01 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 614 5867174 ns/op 426.10 MB/s Benchmark__FanOut_8x10x10000-16 607 5822169 ns/op 429.40 MB/s Benchmark__FanOut_8x10x10000-16 606 5876185 ns/op 425.45 MB/s Benchmark__FanOut_8x10x10000-16 612 5928404 ns/op 421.70 MB/s Benchmark__FanOut_8x10x10000-16 600 5956487 ns/op 419.71 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1046 3420525 ns/op 336.21 MB/s Benchmark___FanOut_8x500x100-16 1052 3400204 ns/op 338.22 MB/s Benchmark___FanOut_8x500x100-16 1051 3405422 ns/op 337.70 MB/s Benchmark___FanOut_8x500x100-16 1044 3409499 ns/op 337.30 MB/s Benchmark___FanOut_8x500x100-16 1038 3410008 ns/op 337.25 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 394088 8819 ns/op 1660.14 MB/s Benchmark___FanOut_128x1x100-16 373795 8805 ns/op 1662.85 MB/s Benchmark___FanOut_128x1x100-16 383408 8877 ns/op 1649.23 MB/s Benchmark___FanOut_128x1x100-16 387441 8839 ns/op 1656.34 MB/s Benchmark___FanOut_128x1x100-16 383193 8767 ns/op 1669.99 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 35269 101533 ns/op 1429.50 MB/s Benchmark__FanOut_128x10x100-16 35217 102088 ns/op 1421.73 MB/s Benchmark__FanOut_128x10x100-16 35058 102518 ns/op 1415.76 MB/s Benchmark__FanOut_128x10x100-16 35293 102311 ns/op 1418.63 MB/s Benchmark__FanOut_128x10x100-16 35185 101777 ns/op 1426.07 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4375 787499 ns/op 1854.15 MB/s Benchmark_FanOut_128x10x1000-16 4422 792214 ns/op 1843.11 MB/s Benchmark_FanOut_128x10x1000-16 4536 790691 ns/op 1846.66 MB/s Benchmark_FanOut_128x10x1000-16 4297 797767 ns/op 1830.28 MB/s Benchmark_FanOut_128x10x1000-16 4324 789579 ns/op 1849.27 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3931 937339 ns/op 1547.08 MB/s Benchmark_FanOut_128x100x100-16 3762 934458 ns/op 1551.85 MB/s Benchmark_FanOut_128x100x100-16 3814 934501 ns/op 1551.78 MB/s Benchmark_FanOut_128x100x100-16 3762 941063 ns/op 1540.96 MB/s Benchmark_FanOut_128x100x100-16 3782 932463 ns/op 1555.17 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 428 8386000 ns/op 1741.01 MB/s BenchmarkFanOut_128x100x1000-16 416 8446778 ns/op 1728.49 MB/s BenchmarkFanOut_128x100x1000-16 426 8455371 ns/op 1726.73 MB/s BenchmarkFanOut_128x100x1000-16 414 8516859 ns/op 1714.26 MB/s BenchmarkFanOut_128x100x1000-16 412 8450823 ns/op 1727.66 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 406 8775384 ns/op 1675.16 MB/s BenchmarkFanOut_128x10x10000-16 403 8749095 ns/op 1680.19 MB/s BenchmarkFanOut_128x10x10000-16 406 8764735 ns/op 1677.19 MB/s BenchmarkFanOut_128x10x10000-16 402 8807477 ns/op 1669.05 MB/s BenchmarkFanOut_128x10x10000-16 406 8755808 ns/op 1678.90 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 708 4985037 ns/op 1454.38 MB/s BenchmarkFanOut__128x500x100-16 718 4943933 ns/op 1466.47 MB/s BenchmarkFanOut__128x500x100-16 722 4965554 ns/op 1460.09 MB/s BenchmarkFanOut__128x500x100-16 709 5005446 ns/op 1448.45 MB/s BenchmarkFanOut__128x500x100-16 706 4950342 ns/op 1464.57 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1987 1758565 ns/op 3008.43 MB/s Benchmark_FanOut_512x100x100-16 1966 1754203 ns/op 3015.91 MB/s Benchmark_FanOut_512x100x100-16 2002 1754574 ns/op 3015.28 MB/s Benchmark_FanOut_512x100x100-16 1978 1783972 ns/op 2965.59 MB/s Benchmark_FanOut_512x100x100-16 2004 1778421 ns/op 2974.84 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 226 16114846 ns/op 3288.93 MB/s Benchmark__FanOut_512x100x1k-16 225 15946477 ns/op 3323.65 MB/s Benchmark__FanOut_512x100x1k-16 224 15865251 ns/op 3340.67 MB/s Benchmark__FanOut_512x100x1k-16 220 16063986 ns/op 3299.34 MB/s Benchmark__FanOut_512x100x1k-16 224 15993220 ns/op 3313.94 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3380 1097154 ns/op 9507.36 MB/s Benchmark____FanOut_1kx10x1k-16 2986 1112111 ns/op 9379.50 MB/s Benchmark____FanOut_1kx10x1k-16 3176 1088739 ns/op 9580.85 MB/s Benchmark____FanOut_1kx10x1k-16 3070 1093870 ns/op 9535.90 MB/s Benchmark____FanOut_1kx10x1k-16 3298 1110445 ns/op 9393.56 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2932 1189483 ns/op 8760.98 MB/s Benchmark__FanOut_1kx100x100-16 2943 1202137 ns/op 8668.76 MB/s Benchmark__FanOut_1kx100x100-16 2924 1185871 ns/op 8787.66 MB/s Benchmark__FanOut_1kx100x100-16 2967 1193897 ns/op 8728.59 MB/s Benchmark__FanOut_1kx100x100-16 3004 1199507 ns/op 8687.77 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4813080 700.7 ns/op 355.38 MB/s Benchmark_____RFanOut_8x1x10-16 5026508 720.6 ns/op 345.56 MB/s Benchmark_____RFanOut_8x1x10-16 4788547 700.5 ns/op 355.48 MB/s Benchmark_____RFanOut_8x1x10-16 4941616 687.5 ns/op 362.19 MB/s Benchmark_____RFanOut_8x1x10-16 4988077 725.7 ns/op 343.13 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 688581 5293 ns/op 438.11 MB/s Benchmark____RFanOut_8x1x100-16 607304 5351 ns/op 433.40 MB/s Benchmark____RFanOut_8x1x100-16 630274 5252 ns/op 441.52 MB/s Benchmark____RFanOut_8x1x100-16 590439 5285 ns/op 438.78 MB/s Benchmark____RFanOut_8x1x100-16 629376 5305 ns/op 437.13 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 52760 68672 ns/op 335.20 MB/s Benchmark___RFanOut_8x10x100-16 52936 67914 ns/op 338.94 MB/s Benchmark___RFanOut_8x10x100-16 51393 67761 ns/op 339.71 MB/s Benchmark___RFanOut_8x10x100-16 52641 67691 ns/op 340.06 MB/s Benchmark___RFanOut_8x10x100-16 53006 68137 ns/op 337.84 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6837 541642 ns/op 443.13 MB/s Benchmark__RFanOut_8x10x1000-16 6633 538261 ns/op 445.92 MB/s Benchmark__RFanOut_8x10x1000-16 6596 543698 ns/op 441.46 MB/s Benchmark__RFanOut_8x10x1000-16 6613 537386 ns/op 446.64 MB/s Benchmark__RFanOut_8x10x1000-16 6218 533105 ns/op 450.23 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5558 641173 ns/op 358.75 MB/s Benchmark__RFanOut_8x100x100-16 5586 632839 ns/op 363.47 MB/s Benchmark__RFanOut_8x100x100-16 5571 652084 ns/op 352.74 MB/s Benchmark__RFanOut_8x100x100-16 5583 634981 ns/op 362.25 MB/s Benchmark__RFanOut_8x100x100-16 5523 631979 ns/op 363.97 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 668 5510818 ns/op 435.51 MB/s Benchmark_RFanOut_8x100x1000-16 657 5483819 ns/op 437.65 MB/s Benchmark_RFanOut_8x100x1000-16 644 5588074 ns/op 429.49 MB/s Benchmark_RFanOut_8x100x1000-16 644 5537704 ns/op 433.40 MB/s Benchmark_RFanOut_8x100x1000-16 642 5590903 ns/op 429.27 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 612 5928782 ns/op 421.67 MB/s Benchmark_RFanOut_8x10x10000-16 603 5940750 ns/op 420.83 MB/s Benchmark_RFanOut_8x10x10000-16 600 5923632 ns/op 422.04 MB/s Benchmark_RFanOut_8x10x10000-16 600 5938319 ns/op 421.00 MB/s Benchmark_RFanOut_8x10x10000-16 583 5883804 ns/op 424.90 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3087 1106978 ns/op 9422.99 MB/s Benchmark_RFanOut_1kx10x1000-16 3123 1109164 ns/op 9404.41 MB/s Benchmark_RFanOut_1kx10x1000-16 3230 1120984 ns/op 9305.25 MB/s Benchmark_RFanOut_1kx10x1000-16 3384 1109062 ns/op 9405.28 MB/s Benchmark_RFanOut_1kx10x1000-16 3000 1109676 ns/op 9400.08 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7211907 488.9 ns/op 4250.53 MB/s Benchmark_____FanIn_1kx100x1-16 7238406 488.0 ns/op 4258.52 MB/s Benchmark_____FanIn_1kx100x1-16 7240260 486.6 ns/op 4270.59 MB/s Benchmark_____FanIn_1kx100x1-16 7296890 487.4 ns/op 4263.46 MB/s Benchmark_____FanIn_1kx100x1-16 7257582 486.1 ns/op 4274.94 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2677570 1341 ns/op 6133.39 MB/s Benchmark_____FanIn_4kx100x1-16 2619781 1359 ns/op 6048.18 MB/s Benchmark_____FanIn_4kx100x1-16 2617687 1345 ns/op 6112.49 MB/s Benchmark_____FanIn_4kx100x1-16 2643618 1361 ns/op 6042.56 MB/s Benchmark_____FanIn_4kx100x1-16 2672098 1331 ns/op 6176.54 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1709151 2082 ns/op 7885.07 MB/s Benchmark_____FanIn_8kx100x1-16 1696894 2102 ns/op 7807.53 MB/s Benchmark_____FanIn_8kx100x1-16 1736198 2088 ns/op 7860.66 MB/s Benchmark_____FanIn_8kx100x1-16 1713200 2118 ns/op 7748.91 MB/s Benchmark_____FanIn_8kx100x1-16 1719124 2095 ns/op 7835.53 MB/s Benchmark____FanIn_16kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 334039167 vs 14091739200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: 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:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38008->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37682->127.0.0.1:5222: write: broken pipe bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:37950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:37874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38158->127.0.0.1:5222: write: broken pipe bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38436->127.0.0.1:5222: write: broken pipe bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:37968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38352->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:37866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37986->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_16kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37868->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37596->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_16kx100x1-16 867188 4131 ns/op 7939.35 MB/s Benchmark____FanIn_16kx100x1-16 882168 4158 ns/op 7888.07 MB/s Benchmark____FanIn_16kx100x1-16 875976 4140 ns/op 7923.07 MB/s Benchmark____FanIn_16kx100x1-16 829417 4103 ns/op 7994.77 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 162804 20034 ns/op 6544.22 MB/s Benchmark____FanIn_64kx100x1-16 163696 19929 ns/op 6578.48 MB/s Benchmark____FanIn_64kx100x1-16 165480 19931 ns/op 6577.77 MB/s Benchmark____FanIn_64kx100x1-16 166104 19787 ns/op 6625.63 MB/s Benchmark____FanIn_64kx100x1-16 165793 19973 ns/op 6564.16 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 526457440 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:40140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:40458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:40502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:40156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:40674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:39804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:40214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40270->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: 1094077140 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41744->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42428->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: 381865170 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43832->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43676->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: 813937810 vs 11601465000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46984->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46470->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: 724272250 vs 11614574000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49120->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48964->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49132->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5995646 592.7 ns/op 479.17 MB/s Benchmark___BumpPubCount_1x3-16 6080224 589.6 ns/op 481.69 MB/s Benchmark___BumpPubCount_1x3-16 6069656 592.4 ns/op 479.38 MB/s Benchmark___BumpPubCount_1x3-16 6048578 591.4 ns/op 480.24 MB/s Benchmark___BumpPubCount_1x3-16 6058580 589.7 ns/op 481.63 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5686153 623.7 ns/op 455.35 MB/s Benchmark___BumpPubCount_2x3-16 5705850 624.3 ns/op 454.93 MB/s Benchmark___BumpPubCount_2x3-16 5621871 630.3 ns/op 450.60 MB/s Benchmark___BumpPubCount_2x3-16 5679352 632.7 ns/op 448.86 MB/s Benchmark___BumpPubCount_2x3-16 5634548 632.0 ns/op 449.37 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5651371 611.7 ns/op 464.30 MB/s Benchmark___BumpPubCount_5x3-16 5634704 611.1 ns/op 464.76 MB/s Benchmark___BumpPubCount_5x3-16 5861360 615.4 ns/op 461.51 MB/s Benchmark___BumpPubCount_5x3-16 5578137 613.8 ns/op 462.69 MB/s Benchmark___BumpPubCount_5x3-16 5029332 614.3 ns/op 462.30 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5903424 608.8 ns/op 466.49 MB/s Benchmark__BumpPubCount_10x3-16 5896428 604.8 ns/op 469.61 MB/s Benchmark__BumpPubCount_10x3-16 5923276 607.2 ns/op 467.68 MB/s Benchmark__BumpPubCount_10x3-16 5890904 606.1 ns/op 468.60 MB/s Benchmark__BumpPubCount_10x3-16 5896795 609.1 ns/op 466.30 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12136802 275.0 ns/op 3781.66 MB/s Benchmark____GWs_Opt_1kx01x0-16 12635424 281.4 ns/op 3695.16 MB/s Benchmark____GWs_Opt_1kx01x0-16 11713321 279.8 ns/op 3716.84 MB/s Benchmark____GWs_Opt_1kx01x0-16 12198486 276.1 ns/op 3767.29 MB/s Benchmark____GWs_Opt_1kx01x0-16 12332374 276.8 ns/op 3756.62 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10273288 322.0 ns/op 6409.03 MB/s Benchmark____GWs_Opt_2kx01x0-16 10294045 343.7 ns/op 6005.68 MB/s Benchmark____GWs_Opt_2kx01x0-16 9998875 353.4 ns/op 5840.18 MB/s Benchmark____GWs_Opt_2kx01x0-16 9578517 338.6 ns/op 6095.66 MB/s Benchmark____GWs_Opt_2kx01x0-16 10586944 326.1 ns/op 6328.87 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5767852 628.2 ns/op 6545.67 MB/s Benchmark____GWs_Opt_4kx01x0-16 5662924 712.2 ns/op 5773.30 MB/s Benchmark____GWs_Opt_4kx01x0-16 5823813 629.0 ns/op 6537.33 MB/s Benchmark____GWs_Opt_4kx01x0-16 5661502 624.9 ns/op 6579.92 MB/s Benchmark____GWs_Opt_4kx01x0-16 6025050 607.1 ns/op 6773.51 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28929308 109.0 ns/op 9538.67 MB/s Benchmark____GWs_Opt_1kx10x0-16 31310392 112.3 ns/op 9263.86 MB/s Benchmark____GWs_Opt_1kx10x0-16 32404970 113.4 ns/op 9172.38 MB/s Benchmark____GWs_Opt_1kx10x0-16 29278270 115.5 ns/op 9006.32 MB/s Benchmark____GWs_Opt_1kx10x0-16 30483295 113.9 ns/op 9133.02 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25152195 143.0 ns/op 14436.48 MB/s Benchmark____GWs_Opt_2kx10x0-16 26558404 143.3 ns/op 14402.77 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:39108->127.0.0.1:45413: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:54202->127.0.0.1:40279: use of closed network connection --- FAIL: Benchmark____GWs_Opt_2kx10x0-16 Benchmark____GWs_Opt_2kx10x0-16 24964611 150.9 ns/op 13673.94 MB/s Benchmark____GWs_Opt_2kx10x0-16 26197154 142.5 ns/op 14487.29 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12439527 321.8 ns/op 12777.56 MB/s Benchmark____GWs_Opt_4kx10x0-16 11323227 282.1 ns/op 14573.88 MB/s Benchmark____GWs_Opt_4kx10x0-16 13112968 279.7 ns/op 14704.06 MB/s Benchmark____GWs_Opt_4kx10x0-16 12862161 316.5 ns/op 12990.26 MB/s Benchmark____GWs_Opt_4kx10x0-16 13334217 284.8 ns/op 14436.60 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6602169 534.1 ns/op 5850.96 MB/s Benchmark____GWs_Opt_1kx01x1-16 6573219 541.3 ns/op 5773.28 MB/s Benchmark____GWs_Opt_1kx01x1-16 6806493 538.0 ns/op 5808.83 MB/s Benchmark____GWs_Opt_1kx01x1-16 6543085 544.0 ns/op 5744.34 MB/s Benchmark____GWs_Opt_1kx01x1-16 6615295 535.1 ns/op 5840.12 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4893424 745.6 ns/op 8311.46 MB/s Benchmark____GWs_Opt_2kx01x1-16 4737464 745.1 ns/op 8316.72 MB/s Benchmark____GWs_Opt_2kx01x1-16 4770094 739.1 ns/op 8385.08 MB/s Benchmark____GWs_Opt_2kx01x1-16 4803475 753.9 ns/op 8220.06 MB/s Benchmark____GWs_Opt_2kx01x1-16 4884902 752.6 ns/op 8233.93 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2690630 1345 ns/op 9175.11 MB/s Benchmark____GWs_Opt_4kx01x1-16 2719082 1345 ns/op 9174.23 MB/s Benchmark____GWs_Opt_4kx01x1-16 2644712 1353 ns/op 9120.71 MB/s Benchmark____GWs_Opt_4kx01x1-16 2641388 1494 ns/op 8262.65 MB/s Benchmark____GWs_Opt_4kx01x1-16 2664126 1346 ns/op 9167.37 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6479318 526.1 ns/op 5939.47 MB/s Benchmark____GWs_Opt_1kx10x1-16 6726847 525.1 ns/op 5950.98 MB/s Benchmark____GWs_Opt_1kx10x1-16 6326716 541.3 ns/op 5773.42 MB/s Benchmark____GWs_Opt_1kx10x1-16 6761730 536.4 ns/op 5826.38 MB/s Benchmark____GWs_Opt_1kx10x1-16 6770197 528.6 ns/op 5912.23 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4225136 833.2 ns/op 7437.29 MB/s Benchmark____GWs_Opt_2kx10x1-16 4175767 834.8 ns/op 7423.27 MB/s Benchmark____GWs_Opt_2kx10x1-16 4089915 833.0 ns/op 7439.02 MB/s Benchmark____GWs_Opt_2kx10x1-16 4323680 829.5 ns/op 7470.35 MB/s Benchmark____GWs_Opt_2kx10x1-16 4278327 809.7 ns/op 7653.45 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2393713 1533 ns/op 8050.36 MB/s Benchmark____GWs_Opt_4kx10x1-16 2354269 1485 ns/op 8311.98 MB/s Benchmark____GWs_Opt_4kx10x1-16 2384113 1429 ns/op 8634.68 MB/s Benchmark____GWs_Opt_4kx10x1-16 2488335 1672 ns/op 7381.30 MB/s Benchmark____GWs_Opt_4kx10x1-16 2286250 1451 ns/op 8507.00 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11076255 297.5 ns/op 3495.78 MB/s Benchmark____GWs_Int_1kx01x0-16 11898896 290.0 ns/op 3585.95 MB/s Benchmark____GWs_Int_1kx01x0-16 12343750 292.0 ns/op 3561.20 MB/s Benchmark____GWs_Int_1kx01x0-16 12311667 292.5 ns/op 3555.04 MB/s Benchmark____GWs_Int_1kx01x0-16 12311617 284.4 ns/op 3656.62 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10623243 353.4 ns/op 5840.17 MB/s Benchmark____GWs_Int_2kx01x0-16 10643331 359.4 ns/op 5742.92 MB/s Benchmark____GWs_Int_2kx01x0-16 10676377 364.7 ns/op 5659.05 MB/s Benchmark____GWs_Int_2kx01x0-16 10392267 351.0 ns/op 5880.63 MB/s Benchmark____GWs_Int_2kx01x0-16 10569453 362.9 ns/op 5686.81 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5374310 627.1 ns/op 6556.86 MB/s Benchmark____GWs_Int_4kx01x0-16 5604277 674.8 ns/op 6094.07 MB/s Benchmark____GWs_Int_4kx01x0-16 5814580 622.8 ns/op 6602.33 MB/s Benchmark____GWs_Int_4kx01x0-16 5783797 622.7 ns/op 6603.99 MB/s Benchmark____GWs_Int_4kx01x0-16 5844309 615.3 ns/op 6682.75 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31850403 118.6 ns/op 8766.99 MB/s Benchmark____GWs_Int_1kx10x0-16 31459630 106.2 ns/op 9789.97 MB/s Benchmark____GWs_Int_1kx10x0-16 33630747 115.3 ns/op 9021.29 MB/s Benchmark____GWs_Int_1kx10x0-16 27521404 110.6 ns/op 9399.42 MB/s Benchmark____GWs_Int_1kx10x0-16 32802064 107.9 ns/op 9638.59 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25406086 138.3 ns/op 14923.56 MB/s Benchmark____GWs_Int_2kx10x0-16 24833592 145.7 ns/op 14162.44 MB/s Benchmark____GWs_Int_2kx10x0-16 26140268 154.4 ns/op 13368.08 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:54472->127.0.0.1:39545: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:49802->127.0.0.1:43115: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 21826696 141.6 ns/op 14574.33 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12996728 289.4 ns/op 14211.04 MB/s Benchmark____GWs_Int_4kx10x0-16 11734737 315.4 ns/op 13038.88 MB/s Benchmark____GWs_Int_4kx10x0-16 13398612 280.6 ns/op 14653.24 MB/s Benchmark____GWs_Int_4kx10x0-16 13098519 293.1 ns/op 14029.63 MB/s Benchmark____GWs_Int_4kx10x0-16 11811044 300.3 ns/op 13694.35 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6558488 553.7 ns/op 5643.65 MB/s Benchmark____GWs_Int_1kx01x1-16 6327590 551.5 ns/op 5666.32 MB/s Benchmark____GWs_Int_1kx01x1-16 6525572 544.8 ns/op 5735.83 MB/s Benchmark____GWs_Int_1kx01x1-16 6801140 546.3 ns/op 5720.34 MB/s Benchmark____GWs_Int_1kx01x1-16 6681582 541.7 ns/op 5769.28 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4809690 756.6 ns/op 8190.18 MB/s Benchmark____GWs_Int_2kx01x1-16 4751998 748.8 ns/op 8275.59 MB/s Benchmark____GWs_Int_2kx01x1-16 4729302 734.6 ns/op 8436.34 MB/s Benchmark____GWs_Int_2kx01x1-16 4724790 739.0 ns/op 8385.85 MB/s Benchmark____GWs_Int_2kx01x1-16 4633470 762.1 ns/op 8131.11 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2654631 1431 ns/op 8625.30 MB/s Benchmark____GWs_Int_4kx01x1-16 2651920 1382 ns/op 8930.56 MB/s Benchmark____GWs_Int_4kx01x1-16 2622765 1367 ns/op 9025.54 MB/s Benchmark____GWs_Int_4kx01x1-16 2585306 1399 ns/op 8818.26 MB/s Benchmark____GWs_Int_4kx01x1-16 2648462 1362 ns/op 9058.60 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6735734 532.8 ns/op 5864.88 MB/s Benchmark____GWs_Int_1kx10x1-16 6750045 548.4 ns/op 5698.74 MB/s Benchmark____GWs_Int_1kx10x1-16 6850812 558.0 ns/op 5600.05 MB/s Benchmark____GWs_Int_1kx10x1-16 6791638 537.5 ns/op 5813.47 MB/s Benchmark____GWs_Int_1kx10x1-16 6643324 540.7 ns/op 5779.83 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4166001 832.7 ns/op 7441.91 MB/s Benchmark____GWs_Int_2kx10x1-16 4433293 842.6 ns/op 7354.75 MB/s Benchmark____GWs_Int_2kx10x1-16 4145647 834.5 ns/op 7426.32 MB/s Benchmark____GWs_Int_2kx10x1-16 4223868 839.3 ns/op 7383.29 MB/s Benchmark____GWs_Int_2kx10x1-16 4162735 822.8 ns/op 7531.56 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2458843 1525 ns/op 8092.80 MB/s Benchmark____GWs_Int_4kx10x1-16 2148748 1494 ns/op 8259.63 MB/s Benchmark____GWs_Int_4kx10x1-16 2292747 1561 ns/op 7905.32 MB/s Benchmark____GWs_Int_4kx10x1-16 2266754 1690 ns/op 7301.07 MB/s Benchmark____GWs_Int_4kx10x1-16 2450542 1481 ns/op 8330.45 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8277277 427.3 ns/op 238.69 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8305302 430.1 ns/op 237.15 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8645527 428.7 ns/op 237.91 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8572898 424.6 ns/op 240.25 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8450143 425.2 ns/op 239.90 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 652071 4667 ns/op 37.93 MB/s Benchmark__GWs_Reqs_1SubEach-16 825337 4966 ns/op 35.64 MB/s Benchmark__GWs_Reqs_1SubEach-16 803979 4925 ns/op 35.94 MB/s Benchmark__GWs_Reqs_1SubEach-16 830736 5003 ns/op 35.38 MB/s Benchmark__GWs_Reqs_1SubEach-16 774748 5031 ns/op 35.18 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2134.394s ❌ Non-zero exit code: 1