> ROOT_DIR=/tmp/go-bench-away-job-d80d44ca-8469-419c-ba7e-3247ad28e9b7-2837451099 > OUTPUT_FILE=/tmp/go-bench-away-job-d80d44ca-8469-419c-ba7e-3247ad28e9b7-2837451099/results.txt > SHA_FILE=/tmp/go-bench-away-job-d80d44ca-8469-419c-ba7e-3247ad28e9b7-2837451099/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-d80d44ca-8469-419c-ba7e-3247ad28e9b7-2837451099/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.26.3/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-d80d44ca-8469-419c-ba7e-3247ad28e9b7-2837451099/source.git SHA of main: bd058fac3d0c04398698b113e986b35065212fda Go runtime: go version go1.26.3 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build2802113935=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-d80d44ca-8469-419c-ba7e-3247ad28e9b7-2837451099/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.26.3' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.26.3/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.3' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 49941112 72.10 ns/op 152.57 MB/s Benchmark______Pub0b_Payload-16 46998942 72.16 ns/op 152.45 MB/s Benchmark______Pub0b_Payload-16 45577002 71.95 ns/op 152.88 MB/s Benchmark______Pub0b_Payload-16 47747008 71.96 ns/op 152.87 MB/s Benchmark______Pub0b_Payload-16 47301342 72.19 ns/op 152.37 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46656199 72.61 ns/op 261.66 MB/s Benchmark______Pub8b_Payload-16 46887775 72.95 ns/op 260.46 MB/s Benchmark______Pub8b_Payload-16 46158903 72.88 ns/op 260.69 MB/s Benchmark______Pub8b_Payload-16 44819281 72.66 ns/op 261.51 MB/s Benchmark______Pub8b_Payload-16 49662225 72.89 ns/op 260.68 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 41640236 78.18 ns/op 562.79 MB/s Benchmark_____Pub32b_Payload-16 44745921 78.11 ns/op 563.29 MB/s Benchmark_____Pub32b_Payload-16 44429770 76.71 ns/op 573.57 MB/s Benchmark_____Pub32b_Payload-16 47186821 80.93 ns/op 543.69 MB/s Benchmark_____Pub32b_Payload-16 44767260 76.30 ns/op 576.66 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 41687509 90.32 ns/op 1561.09 MB/s Benchmark____Pub128B_Payload-16 39109960 87.24 ns/op 1616.27 MB/s Benchmark____Pub128B_Payload-16 33657696 93.85 ns/op 1502.41 MB/s Benchmark____Pub128B_Payload-16 39671685 86.33 ns/op 1633.27 MB/s Benchmark____Pub128B_Payload-16 39247329 86.87 ns/op 1623.16 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35972817 94.84 ns/op 2836.26 MB/s Benchmark____Pub256B_Payload-16 36709653 94.79 ns/op 2837.95 MB/s Benchmark____Pub256B_Payload-16 32668502 100.0 ns/op 2688.78 MB/s Benchmark____Pub256B_Payload-16 31848592 105.9 ns/op 2539.02 MB/s Benchmark____Pub256B_Payload-16 38022864 95.15 ns/op 2827.18 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25711533 139.4 ns/op 7447.84 MB/s Benchmark______Pub1K_Payload-16 24102966 145.3 ns/op 7142.57 MB/s Benchmark______Pub1K_Payload-16 23808860 136.7 ns/op 7591.59 MB/s Benchmark______Pub1K_Payload-16 23804438 136.5 ns/op 7606.20 MB/s Benchmark______Pub1K_Payload-16 23217266 144.2 ns/op 7198.10 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5463388 622.8 ns/op 6599.16 MB/s Benchmark______Pub4K_Payload-16 5594539 612.1 ns/op 6714.54 MB/s Benchmark______Pub4K_Payload-16 5122855 622.3 ns/op 6604.62 MB/s Benchmark______Pub4K_Payload-16 5761088 617.6 ns/op 6654.72 MB/s Benchmark______Pub4K_Payload-16 5567672 609.3 ns/op 6745.28 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2774911 1272 ns/op 6452.51 MB/s Benchmark______Pub8K_Payload-16 2805354 1270 ns/op 6459.23 MB/s Benchmark______Pub8K_Payload-16 2777428 1277 ns/op 6426.10 MB/s Benchmark______Pub8K_Payload-16 2785430 1284 ns/op 6390.18 MB/s Benchmark______Pub8K_Payload-16 2758401 1273 ns/op 6447.88 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 668917 5655 ns/op 5796.66 MB/s Benchmark_____Pub32K_Payload-16 658111 5412 ns/op 6057.60 MB/s Benchmark_____Pub32K_Payload-16 666692 6599 ns/op 4967.70 MB/s Benchmark_____Pub32K_Payload-16 597128 5440 ns/op 6026.22 MB/s Benchmark_____Pub32K_Payload-16 661454 5447 ns/op 6018.13 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 38913118 92.62 ns/op 118.76 MB/s Benchmark__AuthPub0b_Payload-16 35959046 92.98 ns/op 118.30 MB/s Benchmark__AuthPub0b_Payload-16 35365914 92.84 ns/op 118.49 MB/s Benchmark__AuthPub0b_Payload-16 36763594 92.40 ns/op 119.04 MB/s Benchmark__AuthPub0b_Payload-16 34663910 92.88 ns/op 118.43 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15406491 227.6 ns/op Benchmark_____________PubSub-16 15436056 228.0 ns/op Benchmark_____________PubSub-16 15550305 227.9 ns/op Benchmark_____________PubSub-16 15445309 228.2 ns/op Benchmark_____________PubSub-16 15405102 228.2 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15687316 226.5 ns/op Benchmark_____PubSubTwoConns-16 15695905 228.7 ns/op Benchmark_____PubSubTwoConns-16 15271087 227.9 ns/op Benchmark_____PubSubTwoConns-16 15674444 226.9 ns/op Benchmark_____PubSubTwoConns-16 15640654 228.6 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49364->127.0.0.1:37589: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51312->127.0.0.1:44743: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:48608->127.0.0.1:41417: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58892->127.0.0.1:44407: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57348->127.0.0.1:33347: 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 14450059 246.3 ns/op Benchmark_____PubTwoQueueSub-16 14474846 246.3 ns/op Benchmark_____PubTwoQueueSub-16 14194443 245.8 ns/op Benchmark_____PubTwoQueueSub-16 14430465 247.3 ns/op Benchmark_____PubTwoQueueSub-16 14250192 246.4 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14232369 247.5 ns/op Benchmark____PubFourQueueSub-16 14592538 246.0 ns/op Benchmark____PubFourQueueSub-16 14319948 246.9 ns/op Benchmark____PubFourQueueSub-16 14498984 247.1 ns/op Benchmark____PubFourQueueSub-16 14427343 247.8 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14388649 246.2 ns/op Benchmark___PubEightQueueSub-16 14464923 246.7 ns/op Benchmark___PubEightQueueSub-16 14410033 246.5 ns/op Benchmark___PubEightQueueSub-16 14408739 244.8 ns/op Benchmark___PubEightQueueSub-16 14283650 247.9 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23228 154209 ns/op Benchmark_PubSub512kTwoConns-16 23044 155193 ns/op Benchmark_PubSub512kTwoConns-16 23172 155589 ns/op Benchmark_PubSub512kTwoConns-16 23244 154915 ns/op Benchmark_PubSub512kTwoConns-16 23157 155049 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15063609 229.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15123318 229.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15278494 229.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15112761 230.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15264553 230.5 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15044174 229.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15349417 230.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15261230 230.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15257275 231.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15236331 230.7 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11440134 317.9 ns/op Benchmark____RoutedPubSub_0b-16 10909480 312.7 ns/op Benchmark____RoutedPubSub_0b-16 11068850 316.6 ns/op Benchmark____RoutedPubSub_0b-16 11260842 314.2 ns/op Benchmark____RoutedPubSub_0b-16 10845573 312.7 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6514074 654.7 ns/op Benchmark____RoutedPubSub_1K-16 6518458 504.9 ns/op Benchmark____RoutedPubSub_1K-16 6562464 543.7 ns/op Benchmark____RoutedPubSub_1K-16 6582921 537.2 ns/op Benchmark____RoutedPubSub_1K-16 6589948 534.6 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84032 43792 ns/op Benchmark__RoutedPubSub_100K-16 78490 41459 ns/op Benchmark__RoutedPubSub_100K-16 80400 44085 ns/op Benchmark__RoutedPubSub_100K-16 79432 43238 ns/op Benchmark__RoutedPubSub_100K-16 84069 44750 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9515571 322.5 ns/op Benchmark____Routed2QueueSub-16 9556701 320.8 ns/op Benchmark____Routed2QueueSub-16 9379056 320.4 ns/op Benchmark____Routed2QueueSub-16 9544503 323.5 ns/op Benchmark____Routed2QueueSub-16 9903945 320.1 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9204242 328.3 ns/op Benchmark____Routed4QueueSub-16 9651956 320.4 ns/op Benchmark____Routed4QueueSub-16 9533704 326.4 ns/op Benchmark____Routed4QueueSub-16 9434144 329.8 ns/op Benchmark____Routed4QueueSub-16 9471810 321.6 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9176142 338.7 ns/op Benchmark____Routed8QueueSub-16 9359127 333.2 ns/op Benchmark____Routed8QueueSub-16 9213614 333.0 ns/op Benchmark____Routed8QueueSub-16 9171505 328.5 ns/op Benchmark____Routed8QueueSub-16 10928068 327.8 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8880097 348.5 ns/op Benchmark___Routed16QueueSub-16 8825958 353.4 ns/op Benchmark___Routed16QueueSub-16 8670816 349.9 ns/op Benchmark___Routed16QueueSub-16 8850026 350.8 ns/op Benchmark___Routed16QueueSub-16 8905196 347.7 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6261144 554.6 ns/op Benchmark____________RouteCompressOff-16 6301945 556.7 ns/op Benchmark____________RouteCompressOff-16 6445070 553.7 ns/op Benchmark____________RouteCompressOff-16 6492946 555.5 ns/op Benchmark____________RouteCompressOff-16 6173404 555.1 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6312195 546.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6440550 556.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6402553 556.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6364825 548.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6481263 551.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6461958 549.7 ns/op Benchmark_________RouteCompressS2Fast-16 6298089 548.8 ns/op Benchmark_________RouteCompressS2Fast-16 6425890 553.8 ns/op Benchmark_________RouteCompressS2Fast-16 6375048 547.9 ns/op Benchmark_________RouteCompressS2Fast-16 6471108 551.0 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6267714 553.4 ns/op Benchmark_______RouteCompressS2Better-16 6473356 549.9 ns/op Benchmark_______RouteCompressS2Better-16 6415068 550.8 ns/op Benchmark_______RouteCompressS2Better-16 6523976 551.1 ns/op Benchmark_______RouteCompressS2Better-16 6490754 546.5 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6303195 553.0 ns/op Benchmark_________RouteCompressS2Best-16 6226220 545.0 ns/op Benchmark_________RouteCompressS2Best-16 6504088 552.6 ns/op Benchmark_________RouteCompressS2Best-16 6482720 551.8 ns/op Benchmark_________RouteCompressS2Best-16 6527502 552.5 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4678358 766.8 ns/op 324.72 MB/s Benchmark______FanOut_8x1x10-16 4646428 768.5 ns/op 324.01 MB/s Benchmark______FanOut_8x1x10-16 4701956 770.5 ns/op 323.18 MB/s Benchmark______FanOut_8x1x10-16 4658751 769.3 ns/op 323.66 MB/s Benchmark______FanOut_8x1x10-16 4664850 769.1 ns/op 323.73 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 538663 6198 ns/op 374.15 MB/s Benchmark_____FanOut_8x1x100-16 530221 6141 ns/op 377.61 MB/s Benchmark_____FanOut_8x1x100-16 522147 6184 ns/op 375.02 MB/s Benchmark_____FanOut_8x1x100-16 568899 6185 ns/op 374.92 MB/s Benchmark_____FanOut_8x1x100-16 565981 6116 ns/op 379.19 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47655 76482 ns/op 300.97 MB/s Benchmark____FanOut_8x10x100-16 47424 75823 ns/op 303.59 MB/s Benchmark____FanOut_8x10x100-16 47517 75720 ns/op 304.00 MB/s Benchmark____FanOut_8x10x100-16 47438 75787 ns/op 303.73 MB/s Benchmark____FanOut_8x10x100-16 47377 75910 ns/op 303.24 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5916 606067 ns/op 396.03 MB/s Benchmark___FanOut_8x10x1000-16 5817 608058 ns/op 394.73 MB/s Benchmark___FanOut_8x10x1000-16 5671 606778 ns/op 395.56 MB/s Benchmark___FanOut_8x10x1000-16 5800 610220 ns/op 393.33 MB/s Benchmark___FanOut_8x10x1000-16 5764 606630 ns/op 395.66 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5007 723383 ns/op 317.98 MB/s Benchmark___FanOut_8x100x100-16 4904 720528 ns/op 319.24 MB/s Benchmark___FanOut_8x100x100-16 4897 724898 ns/op 317.31 MB/s Benchmark___FanOut_8x100x100-16 4928 724517 ns/op 317.48 MB/s Benchmark___FanOut_8x100x100-16 4936 720532 ns/op 319.23 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 561 6279297 ns/op 382.21 MB/s Benchmark__FanOut_8x100x1000-16 553 6327257 ns/op 379.31 MB/s Benchmark__FanOut_8x100x1000-16 568 6309908 ns/op 380.36 MB/s Benchmark__FanOut_8x100x1000-16 570 6282608 ns/op 382.01 MB/s Benchmark__FanOut_8x100x1000-16 566 6311159 ns/op 380.28 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 520 6826980 ns/op 366.20 MB/s Benchmark__FanOut_8x10x10000-16 526 6849132 ns/op 365.01 MB/s Benchmark__FanOut_8x10x10000-16 520 6859560 ns/op 364.46 MB/s Benchmark__FanOut_8x10x10000-16 526 6835368 ns/op 365.75 MB/s Benchmark__FanOut_8x10x10000-16 525 6861828 ns/op 364.34 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 934 3826381 ns/op 300.55 MB/s Benchmark___FanOut_8x500x100-16 934 3822581 ns/op 300.85 MB/s Benchmark___FanOut_8x500x100-16 934 3834940 ns/op 299.88 MB/s Benchmark___FanOut_8x500x100-16 926 3860792 ns/op 297.87 MB/s Benchmark___FanOut_8x500x100-16 939 3831315 ns/op 300.16 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 365596 9567 ns/op 1530.44 MB/s Benchmark___FanOut_128x1x100-16 355246 9527 ns/op 1536.72 MB/s Benchmark___FanOut_128x1x100-16 362464 9578 ns/op 1528.67 MB/s Benchmark___FanOut_128x1x100-16 352018 9551 ns/op 1532.94 MB/s Benchmark___FanOut_128x1x100-16 354204 9627 ns/op 1520.90 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32451 111604 ns/op 1300.50 MB/s Benchmark__FanOut_128x10x100-16 32413 111993 ns/op 1295.98 MB/s Benchmark__FanOut_128x10x100-16 32095 112036 ns/op 1295.48 MB/s Benchmark__FanOut_128x10x100-16 32155 111991 ns/op 1296.01 MB/s Benchmark__FanOut_128x10x100-16 32037 112206 ns/op 1293.52 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4017 882947 ns/op 1653.71 MB/s Benchmark_FanOut_128x10x1000-16 3940 882165 ns/op 1655.18 MB/s Benchmark_FanOut_128x10x1000-16 4034 889106 ns/op 1642.26 MB/s Benchmark_FanOut_128x10x1000-16 3822 904197 ns/op 1614.85 MB/s Benchmark_FanOut_128x10x1000-16 3933 892462 ns/op 1636.08 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3510 1025935 ns/op 1413.48 MB/s Benchmark_FanOut_128x100x100-16 3495 1019976 ns/op 1421.74 MB/s Benchmark_FanOut_128x100x100-16 3447 1024973 ns/op 1414.81 MB/s Benchmark_FanOut_128x100x100-16 3444 1024122 ns/op 1415.98 MB/s Benchmark_FanOut_128x100x100-16 3434 1022505 ns/op 1418.22 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 372 9408905 ns/op 1551.74 MB/s BenchmarkFanOut_128x100x1000-16 375 9570556 ns/op 1525.53 MB/s BenchmarkFanOut_128x100x1000-16 375 9492756 ns/op 1538.03 MB/s BenchmarkFanOut_128x100x1000-16 379 9489884 ns/op 1538.50 MB/s BenchmarkFanOut_128x100x1000-16 380 9458213 ns/op 1543.65 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 369 9755790 ns/op 1506.81 MB/s BenchmarkFanOut_128x10x10000-16 367 9789571 ns/op 1501.61 MB/s BenchmarkFanOut_128x10x10000-16 370 9782011 ns/op 1502.77 MB/s BenchmarkFanOut_128x10x10000-16 366 9777645 ns/op 1503.44 MB/s BenchmarkFanOut_128x10x10000-16 366 9813554 ns/op 1497.94 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 670 5337790 ns/op 1358.27 MB/s BenchmarkFanOut__128x500x100-16 656 5357945 ns/op 1353.16 MB/s BenchmarkFanOut__128x500x100-16 657 5315955 ns/op 1363.85 MB/s BenchmarkFanOut__128x500x100-16 650 5335702 ns/op 1358.80 MB/s BenchmarkFanOut__128x500x100-16 661 5386093 ns/op 1346.09 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1940 1858878 ns/op 2846.09 MB/s Benchmark_FanOut_512x100x100-16 1887 1850812 ns/op 2858.49 MB/s Benchmark_FanOut_512x100x100-16 1945 1856406 ns/op 2849.87 MB/s Benchmark_FanOut_512x100x100-16 1918 1864923 ns/op 2836.86 MB/s Benchmark_FanOut_512x100x100-16 1897 1846337 ns/op 2865.42 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16891421 ns/op 3137.72 MB/s Benchmark__FanOut_512x100x1k-16 213 16781851 ns/op 3158.20 MB/s Benchmark__FanOut_512x100x1k-16 211 16919623 ns/op 3132.49 MB/s Benchmark__FanOut_512x100x1k-16 213 16751873 ns/op 3163.86 MB/s Benchmark__FanOut_512x100x1k-16 211 16913851 ns/op 3133.56 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3115 1166321 ns/op 8943.54 MB/s Benchmark____FanOut_1kx10x1k-16 3049 1171104 ns/op 8907.01 MB/s Benchmark____FanOut_1kx10x1k-16 3081 1142513 ns/op 9129.91 MB/s Benchmark____FanOut_1kx10x1k-16 3076 1173872 ns/op 8886.01 MB/s Benchmark____FanOut_1kx10x1k-16 3150 1169422 ns/op 8919.83 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2743 1274123 ns/op 8178.99 MB/s Benchmark__FanOut_1kx100x100-16 2749 1280152 ns/op 8140.47 MB/s Benchmark__FanOut_1kx100x100-16 2773 1265669 ns/op 8233.62 MB/s Benchmark__FanOut_1kx100x100-16 2764 1272555 ns/op 8189.07 MB/s Benchmark__FanOut_1kx100x100-16 2770 1275223 ns/op 8171.93 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4493419 779.7 ns/op 319.37 MB/s Benchmark_____RFanOut_8x1x10-16 4535258 778.6 ns/op 319.80 MB/s Benchmark_____RFanOut_8x1x10-16 4494010 788.9 ns/op 315.61 MB/s Benchmark_____RFanOut_8x1x10-16 4464876 789.8 ns/op 315.27 MB/s Benchmark_____RFanOut_8x1x10-16 4265103 783.7 ns/op 317.71 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 527928 6279 ns/op 369.33 MB/s Benchmark____RFanOut_8x1x100-16 531382 6208 ns/op 373.58 MB/s Benchmark____RFanOut_8x1x100-16 570823 6186 ns/op 374.89 MB/s Benchmark____RFanOut_8x1x100-16 525123 6229 ns/op 372.28 MB/s Benchmark____RFanOut_8x1x100-16 519826 6230 ns/op 372.24 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46581 76270 ns/op 301.81 MB/s Benchmark___RFanOut_8x10x100-16 47516 75479 ns/op 304.97 MB/s Benchmark___RFanOut_8x10x100-16 47250 77200 ns/op 298.17 MB/s Benchmark___RFanOut_8x10x100-16 47337 76506 ns/op 300.88 MB/s Benchmark___RFanOut_8x10x100-16 47498 77508 ns/op 296.99 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5863 621664 ns/op 386.09 MB/s Benchmark__RFanOut_8x10x1000-16 5869 611249 ns/op 392.67 MB/s Benchmark__RFanOut_8x10x1000-16 5658 628657 ns/op 381.80 MB/s Benchmark__RFanOut_8x10x1000-16 5847 609993 ns/op 393.48 MB/s Benchmark__RFanOut_8x10x1000-16 5600 632045 ns/op 379.75 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4846 722735 ns/op 318.26 MB/s Benchmark__RFanOut_8x100x100-16 4863 714871 ns/op 321.76 MB/s Benchmark__RFanOut_8x100x100-16 4956 714367 ns/op 321.99 MB/s Benchmark__RFanOut_8x100x100-16 4922 720902 ns/op 319.07 MB/s Benchmark__RFanOut_8x100x100-16 4879 724962 ns/op 317.28 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 556 6339628 ns/op 378.57 MB/s Benchmark_RFanOut_8x100x1000-16 558 6400965 ns/op 374.95 MB/s Benchmark_RFanOut_8x100x1000-16 572 6484449 ns/op 370.12 MB/s Benchmark_RFanOut_8x100x1000-16 566 6384515 ns/op 375.91 MB/s Benchmark_RFanOut_8x100x1000-16 555 6616149 ns/op 362.75 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 522 6849070 ns/op 365.02 MB/s Benchmark_RFanOut_8x10x10000-16 524 6841103 ns/op 365.44 MB/s Benchmark_RFanOut_8x10x10000-16 529 6885035 ns/op 363.11 MB/s Benchmark_RFanOut_8x10x10000-16 512 6849353 ns/op 365.00 MB/s Benchmark_RFanOut_8x10x10000-16 506 6745468 ns/op 370.62 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2820 1184101 ns/op 8809.25 MB/s Benchmark_RFanOut_1kx10x1000-16 3021 1173295 ns/op 8890.38 MB/s Benchmark_RFanOut_1kx10x1000-16 3126 1173653 ns/op 8887.67 MB/s Benchmark_RFanOut_1kx10x1000-16 3073 1167477 ns/op 8934.68 MB/s Benchmark_RFanOut_1kx10x1000-16 3273 1150964 ns/op 9062.87 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6936612 504.6 ns/op 4118.01 MB/s Benchmark_____FanIn_1kx100x1-16 6984561 507.8 ns/op 4092.17 MB/s Benchmark_____FanIn_1kx100x1-16 6981211 506.3 ns/op 4104.39 MB/s Benchmark_____FanIn_1kx100x1-16 6914228 506.6 ns/op 4101.92 MB/s Benchmark_____FanIn_1kx100x1-16 6942765 509.5 ns/op 4078.25 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2588547 1378 ns/op 5965.48 MB/s Benchmark_____FanIn_4kx100x1-16 2634988 1360 ns/op 6047.04 MB/s Benchmark_____FanIn_4kx100x1-16 2660071 1363 ns/op 6030.12 MB/s Benchmark_____FanIn_4kx100x1-16 2630290 1395 ns/op 5894.16 MB/s Benchmark_____FanIn_4kx100x1-16 2625032 1356 ns/op 6064.37 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1682112 2133 ns/op 7696.19 MB/s Benchmark_____FanIn_8kx100x1-16 1708430 2125 ns/op 7725.99 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 95508288 vs 13992998400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52192->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52266->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark_____FanIn_8kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51868->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52042->127.0.0.1:5222: write: broken pipe Benchmark_____FanIn_8kx100x1-16 1693083 2147 ns/op 7643.40 MB/s Benchmark_____FanIn_8kx100x1-16 1675371 2104 ns/op 7802.46 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 878250 4116 ns/op 7969.73 MB/s Benchmark____FanIn_16kx100x1-16 878554 4154 ns/op 7895.54 MB/s Benchmark____FanIn_16kx100x1-16 863052 4126 ns/op 7950.20 MB/s Benchmark____FanIn_16kx100x1-16 861364 4170 ns/op 7866.34 MB/s Benchmark____FanIn_16kx100x1-16 872486 4163 ns/op 7879.49 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 169294 19980 ns/op 6561.86 MB/s Benchmark____FanIn_64kx100x1-16 181569 19876 ns/op 6596.02 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 2023883322 vs 11045680500 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54828->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 167652 19941 ns/op 6574.45 MB/s Benchmark____FanIn_64kx100x1-16 170113 19763 ns/op 6633.88 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 2053524850 vs 11798100000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35238->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: 1053439240 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:43198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43478->127.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:43756->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: 884988590 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45988->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:45624->127.0.0.1:5222: write: broken pipe bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 379767730 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47182->127.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:47406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47152->127.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:47584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47020->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: 137251230 vs 10264347000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49762->127.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:50268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50256->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:50006->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50410->127.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:49784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50076->127.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:50346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50398->127.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:50116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49906->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5549500 641.0 ns/op 443.06 MB/s Benchmark___BumpPubCount_1x3-16 5535813 644.9 ns/op 440.36 MB/s Benchmark___BumpPubCount_1x3-16 5560297 641.4 ns/op 442.81 MB/s Benchmark___BumpPubCount_1x3-16 5574099 642.1 ns/op 442.33 MB/s Benchmark___BumpPubCount_1x3-16 5507034 639.8 ns/op 443.89 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5294828 677.6 ns/op 419.10 MB/s Benchmark___BumpPubCount_2x3-16 5284689 677.5 ns/op 419.19 MB/s Benchmark___BumpPubCount_2x3-16 5234785 678.2 ns/op 418.76 MB/s Benchmark___BumpPubCount_2x3-16 5310321 674.7 ns/op 420.91 MB/s Benchmark___BumpPubCount_2x3-16 5310994 675.1 ns/op 420.69 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5496434 647.0 ns/op 438.92 MB/s Benchmark___BumpPubCount_5x3-16 5559202 653.8 ns/op 434.41 MB/s Benchmark___BumpPubCount_5x3-16 5068770 649.1 ns/op 437.55 MB/s Benchmark___BumpPubCount_5x3-16 5217016 648.2 ns/op 438.12 MB/s Benchmark___BumpPubCount_5x3-16 5528558 649.1 ns/op 437.55 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5539376 648.0 ns/op 438.25 MB/s Benchmark__BumpPubCount_10x3-16 5513737 647.6 ns/op 438.53 MB/s Benchmark__BumpPubCount_10x3-16 5547872 649.9 ns/op 436.98 MB/s Benchmark__BumpPubCount_10x3-16 5509872 646.9 ns/op 439.01 MB/s Benchmark__BumpPubCount_10x3-16 5538174 644.9 ns/op 440.40 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12297822 269.0 ns/op 3865.81 MB/s Benchmark____GWs_Opt_1kx01x0-16 13367685 270.0 ns/op 3851.36 MB/s Benchmark____GWs_Opt_1kx01x0-16 13292822 273.1 ns/op 3808.54 MB/s Benchmark____GWs_Opt_1kx01x0-16 11998012 277.6 ns/op 3745.85 MB/s Benchmark____GWs_Opt_1kx01x0-16 12829152 282.3 ns/op 3684.40 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 11182285 342.6 ns/op 6024.77 MB/s Benchmark____GWs_Opt_2kx01x0-16 10419301 349.1 ns/op 5912.56 MB/s Benchmark____GWs_Opt_2kx01x0-16 10514350 381.5 ns/op 5409.73 MB/s Benchmark____GWs_Opt_2kx01x0-16 10371693 343.3 ns/op 6012.87 MB/s Benchmark____GWs_Opt_2kx01x0-16 11130369 349.1 ns/op 5912.90 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5723432 625.3 ns/op 6575.78 MB/s Benchmark____GWs_Opt_4kx01x0-16 5686194 617.5 ns/op 6659.30 MB/s Benchmark____GWs_Opt_4kx01x0-16 5768151 620.0 ns/op 6632.10 MB/s Benchmark____GWs_Opt_4kx01x0-16 5875746 605.9 ns/op 6787.11 MB/s Benchmark____GWs_Opt_4kx01x0-16 5661992 622.8 ns/op 6602.45 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 27583076 112.2 ns/op 9268.81 MB/s Benchmark____GWs_Opt_1kx10x0-16 32568040 113.0 ns/op 9205.41 MB/s Benchmark____GWs_Opt_1kx10x0-16 32152141 106.7 ns/op 9746.86 MB/s Benchmark____GWs_Opt_1kx10x0-16 32308146 112.3 ns/op 9260.89 MB/s Benchmark____GWs_Opt_1kx10x0-16 31820480 111.2 ns/op 9356.26 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25103092 172.4 ns/op 11973.15 MB/s Benchmark____GWs_Opt_2kx10x0-16 26049715 143.7 ns/op 14367.37 MB/s Benchmark____GWs_Opt_2kx10x0-16 23893333 145.9 ns/op 14149.99 MB/s Benchmark____GWs_Opt_2kx10x0-16 26336010 152.3 ns/op 13551.79 MB/s Benchmark____GWs_Opt_2kx10x0-16 25241881 144.5 ns/op 14288.37 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12049928 314.8 ns/op 13063.20 MB/s Benchmark____GWs_Opt_4kx10x0-16 12490335 360.5 ns/op 11405.67 MB/s Benchmark____GWs_Opt_4kx10x0-16 11534613 286.2 ns/op 14369.66 MB/s Benchmark____GWs_Opt_4kx10x0-16 12189578 286.8 ns/op 14338.24 MB/s Benchmark____GWs_Opt_4kx10x0-16 13287664 301.5 ns/op 13636.62 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6646101 547.7 ns/op 5705.42 MB/s Benchmark____GWs_Opt_1kx01x1-16 6457714 547.8 ns/op 5705.16 MB/s Benchmark____GWs_Opt_1kx01x1-16 6418778 542.8 ns/op 5757.46 MB/s Benchmark____GWs_Opt_1kx01x1-16 6334074 544.9 ns/op 5735.05 MB/s Benchmark____GWs_Opt_1kx01x1-16 6476931 541.6 ns/op 5770.16 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4865500 771.5 ns/op 8032.11 MB/s Benchmark____GWs_Opt_2kx01x1-16 4680962 785.3 ns/op 7891.62 MB/s Benchmark____GWs_Opt_2kx01x1-16 4692465 868.0 ns/op 7139.40 MB/s Benchmark____GWs_Opt_2kx01x1-16 4648102 755.9 ns/op 8198.40 MB/s Benchmark____GWs_Opt_2kx01x1-16 4638249 759.0 ns/op 8164.75 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2636823 1396 ns/op 8842.46 MB/s Benchmark____GWs_Opt_4kx01x1-16 2638560 1420 ns/op 8690.81 MB/s Benchmark____GWs_Opt_4kx01x1-16 2596830 1526 ns/op 8087.46 MB/s Benchmark____GWs_Opt_4kx01x1-16 2573125 1339 ns/op 9213.61 MB/s Benchmark____GWs_Opt_4kx01x1-16 2630100 1346 ns/op 9170.54 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6614250 564.0 ns/op 5540.53 MB/s Benchmark____GWs_Opt_1kx10x1-16 6200029 569.2 ns/op 5489.70 MB/s Benchmark____GWs_Opt_1kx10x1-16 6062720 558.8 ns/op 5592.61 MB/s Benchmark____GWs_Opt_1kx10x1-16 6145188 560.0 ns/op 5579.95 MB/s Benchmark____GWs_Opt_1kx10x1-16 6331596 550.7 ns/op 5674.12 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4160422 844.7 ns/op 7336.66 MB/s Benchmark____GWs_Opt_2kx10x1-16 4236422 851.2 ns/op 7280.05 MB/s Benchmark____GWs_Opt_2kx10x1-16 4155512 850.8 ns/op 7283.56 MB/s Benchmark____GWs_Opt_2kx10x1-16 4136636 859.8 ns/op 7207.77 MB/s Benchmark____GWs_Opt_2kx10x1-16 4106906 865.9 ns/op 7157.11 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2317478 1535 ns/op 8039.97 MB/s Benchmark____GWs_Opt_4kx10x1-16 2308723 1496 ns/op 8250.05 MB/s Benchmark____GWs_Opt_4kx10x1-16 2330670 1539 ns/op 8017.25 MB/s Benchmark____GWs_Opt_4kx10x1-16 2327235 1508 ns/op 8183.83 MB/s Benchmark____GWs_Opt_4kx10x1-16 2225493 1538 ns/op 8022.18 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12416516 288.9 ns/op 3600.38 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:38854->127.0.0.1:44321: use of closed network connection --- FAIL: Benchmark____GWs_Int_1kx01x0 --- FAIL: Benchmark____GWs_Int_1kx01x0-16 Benchmark____GWs_Int_1kx01x0-16 12330382 298.5 ns/op 3484.42 MB/s Benchmark____GWs_Int_1kx01x0-16 12376311 288.2 ns/op 3609.15 MB/s Benchmark____GWs_Int_1kx01x0-16 12847524 292.2 ns/op 3559.37 MB/s Benchmark____GWs_Int_2kx01x0 bench_test.go:55: Failed read: read tcp 127.0.0.1:58946->127.0.0.1:43349: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5575010 635.7 ns/op 6468.82 MB/s Benchmark____GWs_Int_4kx01x0-16 5817918 632.7 ns/op 6498.99 MB/s Benchmark____GWs_Int_4kx01x0-16 5746591 624.0 ns/op 6589.30 MB/s Benchmark____GWs_Int_4kx01x0-16 5829307 639.5 ns/op 6430.46 MB/s Benchmark____GWs_Int_4kx01x0-16 5758704 630.7 ns/op 6519.65 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 28670023 111.2 ns/op 9355.66 MB/s Benchmark____GWs_Int_1kx10x0-16 31818062 112.5 ns/op 9241.77 MB/s Benchmark____GWs_Int_1kx10x0-16 31935762 109.5 ns/op 9497.24 MB/s Benchmark____GWs_Int_1kx10x0-16 30877484 114.9 ns/op 9053.85 MB/s Benchmark____GWs_Int_1kx10x0-16 30843652 112.7 ns/op 9227.94 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25129336 140.1 ns/op 14730.29 MB/s Benchmark____GWs_Int_2kx10x0-16 24080793 170.8 ns/op 12081.97 MB/s Benchmark____GWs_Int_2kx10x0-16 25450822 139.5 ns/op 14800.84 MB/s Benchmark____GWs_Int_2kx10x0-16 25588716 144.1 ns/op 14318.83 MB/s Benchmark____GWs_Int_2kx10x0-16 26524111 138.7 ns/op 14882.34 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 9750601 328.3 ns/op 12525.08 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:53060->127.0.0.1:44147: 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:51632->127.0.0.1:46851: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12495448 332.5 ns/op 12365.56 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:32818->127.0.0.1:41645: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 13470214 282.7 ns/op 14546.77 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6428214 558.2 ns/op 5597.93 MB/s Benchmark____GWs_Int_1kx01x1-16 6541976 553.3 ns/op 5647.56 MB/s Benchmark____GWs_Int_1kx01x1-16 6189286 553.7 ns/op 5644.07 MB/s Benchmark____GWs_Int_1kx01x1-16 6430768 557.2 ns/op 5608.02 MB/s Benchmark____GWs_Int_1kx01x1-16 6497581 557.0 ns/op 5610.58 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4478833 769.5 ns/op 8053.44 MB/s Benchmark____GWs_Int_2kx01x1-16 4682709 836.2 ns/op 7410.95 MB/s Benchmark____GWs_Int_2kx01x1-16 4725970 1113 ns/op 5565.51 MB/s Benchmark____GWs_Int_2kx01x1-16 4436936 767.7 ns/op 8072.15 MB/s Benchmark____GWs_Int_2kx01x1-16 4631520 754.5 ns/op 8213.22 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2302107 1561 ns/op 7906.77 MB/s Benchmark____GWs_Int_4kx01x1-16 2618622 1560 ns/op 7912.26 MB/s Benchmark____GWs_Int_4kx01x1-16 2548819 1370 ns/op 9009.12 MB/s Benchmark____GWs_Int_4kx01x1-16 2607735 1371 ns/op 9000.65 MB/s Benchmark____GWs_Int_4kx01x1-16 2645000 1363 ns/op 9051.38 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6127908 556.6 ns/op 5614.65 MB/s Benchmark____GWs_Int_1kx10x1-16 6150020 561.0 ns/op 5570.68 MB/s Benchmark____GWs_Int_1kx10x1-16 6163513 582.6 ns/op 5364.04 MB/s Benchmark____GWs_Int_1kx10x1-16 6293108 562.3 ns/op 5557.08 MB/s Benchmark____GWs_Int_1kx10x1-16 6179748 562.8 ns/op 5552.92 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4134657 852.3 ns/op 7271.15 MB/s Benchmark____GWs_Int_2kx10x1-16 4162066 876.0 ns/op 7074.16 MB/s Benchmark____GWs_Int_2kx10x1-16 4152183 859.7 ns/op 7208.75 MB/s Benchmark____GWs_Int_2kx10x1-16 4192615 858.6 ns/op 7217.24 MB/s Benchmark____GWs_Int_2kx10x1-16 4172932 854.9 ns/op 7248.74 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2492818 1692 ns/op 7295.31 MB/s Benchmark____GWs_Int_4kx10x1-16 2375326 1483 ns/op 8324.02 MB/s Benchmark____GWs_Int_4kx10x1-16 2355922 1668 ns/op 7398.16 MB/s Benchmark____GWs_Int_4kx10x1-16 2333512 1539 ns/op 8016.36 MB/s Benchmark____GWs_Int_4kx10x1-16 2236286 1591 ns/op 7758.35 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8249439 435.5 ns/op 234.23 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8012631 436.1 ns/op 233.91 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8633834 442.9 ns/op 230.28 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8257251 433.5 ns/op 235.30 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8152693 439.5 ns/op 232.06 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 621603 5108 ns/op 34.65 MB/s Benchmark__GWs_Reqs_1SubEach-16 765207 5242 ns/op 33.76 MB/s Benchmark__GWs_Reqs_1SubEach-16 735426 5328 ns/op 33.22 MB/s Benchmark__GWs_Reqs_1SubEach-16 595627 5265 ns/op 33.62 MB/s Benchmark__GWs_Reqs_1SubEach-16 698151 5341 ns/op 33.14 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2077.825s ❌ Non-zero exit code: 1