> ROOT_DIR=/tmp/go-bench-away-job-2f21b72a-3af1-406e-8176-ba93a71dc60f-3741381057 > OUTPUT_FILE=/tmp/go-bench-away-job-2f21b72a-3af1-406e-8176-ba93a71dc60f-3741381057/results.txt > SHA_FILE=/tmp/go-bench-away-job-2f21b72a-3af1-406e-8176-ba93a71dc60f-3741381057/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-2f21b72a-3af1-406e-8176-ba93a71dc60f-3741381057/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-2f21b72a-3af1-406e-8176-ba93a71dc60f-3741381057/source.git SHA of main: 4cec8d2ff7517549aec0872b2725761e11600912 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-build3509062649=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-2f21b72a-3af1-406e-8176-ba93a71dc60f-3741381057/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 50110789 71.85 ns/op 153.09 MB/s Benchmark______Pub0b_Payload-16 45819277 71.89 ns/op 153.01 MB/s Benchmark______Pub0b_Payload-16 43602057 71.77 ns/op 153.27 MB/s Benchmark______Pub0b_Payload-16 47581064 71.86 ns/op 153.07 MB/s Benchmark______Pub0b_Payload-16 50036202 71.85 ns/op 153.09 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 44668922 72.66 ns/op 261.50 MB/s Benchmark______Pub8b_Payload-16 46757281 72.66 ns/op 261.51 MB/s Benchmark______Pub8b_Payload-16 43904716 72.90 ns/op 260.63 MB/s Benchmark______Pub8b_Payload-16 46692300 76.39 ns/op 248.72 MB/s Benchmark______Pub8b_Payload-16 47151172 72.65 ns/op 261.52 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44040781 80.13 ns/op 549.11 MB/s Benchmark_____Pub32b_Payload-16 38268878 78.83 ns/op 558.17 MB/s Benchmark_____Pub32b_Payload-16 44174640 76.69 ns/op 573.74 MB/s Benchmark_____Pub32b_Payload-16 44265853 77.01 ns/op 571.32 MB/s Benchmark_____Pub32b_Payload-16 44167118 76.51 ns/op 575.11 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39343094 86.17 ns/op 1636.34 MB/s Benchmark____Pub128B_Payload-16 39246074 86.72 ns/op 1625.90 MB/s Benchmark____Pub128B_Payload-16 41093580 86.54 ns/op 1629.24 MB/s Benchmark____Pub128B_Payload-16 39171442 85.44 ns/op 1650.23 MB/s Benchmark____Pub128B_Payload-16 39898664 85.84 ns/op 1642.64 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 37140163 93.15 ns/op 2887.70 MB/s Benchmark____Pub256B_Payload-16 37007013 100.8 ns/op 2667.73 MB/s Benchmark____Pub256B_Payload-16 33066223 94.71 ns/op 2840.19 MB/s Benchmark____Pub256B_Payload-16 36837058 98.29 ns/op 2736.78 MB/s Benchmark____Pub256B_Payload-16 32483316 99.36 ns/op 2707.40 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25040893 139.1 ns/op 7461.62 MB/s Benchmark______Pub1K_Payload-16 25162538 135.1 ns/op 7684.23 MB/s Benchmark______Pub1K_Payload-16 24339286 142.4 ns/op 7288.03 MB/s Benchmark______Pub1K_Payload-16 25795790 135.3 ns/op 7671.69 MB/s Benchmark______Pub1K_Payload-16 23762979 136.9 ns/op 7581.39 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5573314 617.7 ns/op 6653.28 MB/s Benchmark______Pub4K_Payload-16 5455970 621.2 ns/op 6616.53 MB/s Benchmark______Pub4K_Payload-16 5487211 636.4 ns/op 6458.55 MB/s Benchmark______Pub4K_Payload-16 5401594 621.7 ns/op 6610.61 MB/s Benchmark______Pub4K_Payload-16 5248944 617.4 ns/op 6656.80 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2782274 1281 ns/op 6405.05 MB/s Benchmark______Pub8K_Payload-16 2767874 1279 ns/op 6417.57 MB/s Benchmark______Pub8K_Payload-16 2806099 1278 ns/op 6421.76 MB/s Benchmark______Pub8K_Payload-16 2759654 1280 ns/op 6412.05 MB/s Benchmark______Pub8K_Payload-16 2786552 1269 ns/op 6469.02 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 592640 5363 ns/op 6113.24 MB/s Benchmark_____Pub32K_Payload-16 663486 5518 ns/op 5941.39 MB/s Benchmark_____Pub32K_Payload-16 576159 8010 ns/op 4092.93 MB/s Benchmark_____Pub32K_Payload-16 653456 5486 ns/op 5975.74 MB/s Benchmark_____Pub32K_Payload-16 668644 5548 ns/op 5908.51 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32830935 92.54 ns/op 118.87 MB/s Benchmark__AuthPub0b_Payload-16 33071746 92.11 ns/op 119.42 MB/s Benchmark__AuthPub0b_Payload-16 37074283 92.27 ns/op 119.21 MB/s Benchmark__AuthPub0b_Payload-16 33102202 91.83 ns/op 119.78 MB/s Benchmark__AuthPub0b_Payload-16 37203120 93.29 ns/op 117.91 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15728460 226.0 ns/op Benchmark_____________PubSub-16 15665073 227.1 ns/op Benchmark_____________PubSub-16 15791374 225.9 ns/op Benchmark_____________PubSub-16 15502010 226.1 ns/op Benchmark_____________PubSub-16 15603217 227.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15631562 225.2 ns/op Benchmark_____PubSubTwoConns-16 15542056 225.9 ns/op Benchmark_____PubSubTwoConns-16 15633890 225.8 ns/op Benchmark_____PubSubTwoConns-16 15670675 225.8 ns/op Benchmark_____PubSubTwoConns-16 15469244 225.5 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41542->127.0.0.1:42005: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:48290->127.0.0.1:39893: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42890->127.0.0.1:37581: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:56644->127.0.0.1:38773: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:37172->127.0.0.1:36751: 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 14423624 246.1 ns/op Benchmark_____PubTwoQueueSub-16 14458038 245.9 ns/op Benchmark_____PubTwoQueueSub-16 14446680 246.5 ns/op Benchmark_____PubTwoQueueSub-16 14399142 245.9 ns/op Benchmark_____PubTwoQueueSub-16 14384253 247.5 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14492485 246.3 ns/op Benchmark____PubFourQueueSub-16 14420257 246.8 ns/op Benchmark____PubFourQueueSub-16 14262300 246.2 ns/op Benchmark____PubFourQueueSub-16 14285872 246.0 ns/op Benchmark____PubFourQueueSub-16 14279230 246.7 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14378664 246.6 ns/op Benchmark___PubEightQueueSub-16 14229957 246.3 ns/op Benchmark___PubEightQueueSub-16 14113492 246.3 ns/op Benchmark___PubEightQueueSub-16 14465329 245.2 ns/op Benchmark___PubEightQueueSub-16 14323884 246.8 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23172 154339 ns/op Benchmark_PubSub512kTwoConns-16 22762 157020 ns/op bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 274213084 vs 5243080000 --- FAIL: Benchmark_PubSub512kTwoConns-16 Benchmark_PubSub512kTwoConns-16 20905 170134 ns/op Benchmark_PubSub512kTwoConns-16 22056 169620 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15187674 230.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15327080 228.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15060164 230.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15208230 229.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15101013 231.2 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15144094 230.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15151249 231.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15173290 230.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15019717 230.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15398847 231.2 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10892160 320.4 ns/op Benchmark____RoutedPubSub_0b-16 11275136 320.0 ns/op Benchmark____RoutedPubSub_0b-16 10915443 317.5 ns/op Benchmark____RoutedPubSub_0b-16 10937713 317.4 ns/op Benchmark____RoutedPubSub_0b-16 10801410 323.4 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6629701 542.1 ns/op Benchmark____RoutedPubSub_1K-16 6318804 540.0 ns/op Benchmark____RoutedPubSub_1K-16 6520088 531.7 ns/op Benchmark____RoutedPubSub_1K-16 6352942 539.4 ns/op Benchmark____RoutedPubSub_1K-16 6427299 547.1 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 77217 46301 ns/op Benchmark__RoutedPubSub_100K-16 80325 48118 ns/op Benchmark__RoutedPubSub_100K-16 80072 47219 ns/op Benchmark__RoutedPubSub_100K-16 77617 45835 ns/op Benchmark__RoutedPubSub_100K-16 76954 45917 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9532172 324.9 ns/op Benchmark____Routed2QueueSub-16 9688221 319.9 ns/op Benchmark____Routed2QueueSub-16 9849512 344.8 ns/op Benchmark____Routed2QueueSub-16 9685537 330.2 ns/op Benchmark____Routed2QueueSub-16 9578474 324.0 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9547344 324.1 ns/op Benchmark____Routed4QueueSub-16 9385603 322.5 ns/op Benchmark____Routed4QueueSub-16 9448882 318.2 ns/op Benchmark____Routed4QueueSub-16 9406123 323.6 ns/op Benchmark____Routed4QueueSub-16 11130314 332.3 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9318690 327.9 ns/op Benchmark____Routed8QueueSub-16 9252380 333.8 ns/op Benchmark____Routed8QueueSub-16 9071443 332.4 ns/op Benchmark____Routed8QueueSub-16 9138242 332.4 ns/op Benchmark____Routed8QueueSub-16 9158857 330.3 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8832770 349.2 ns/op Benchmark___Routed16QueueSub-16 8871571 356.0 ns/op Benchmark___Routed16QueueSub-16 10366932 351.6 ns/op Benchmark___Routed16QueueSub-16 8923236 348.0 ns/op Benchmark___Routed16QueueSub-16 8674279 350.3 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6201117 565.1 ns/op Benchmark____________RouteCompressOff-16 6151815 565.5 ns/op Benchmark____________RouteCompressOff-16 6389464 571.2 ns/op Benchmark____________RouteCompressOff-16 6393399 564.5 ns/op Benchmark____________RouteCompressOff-16 6602498 566.1 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6390999 563.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6350625 562.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6277558 559.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6387214 566.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6308104 566.2 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6405547 564.7 ns/op Benchmark_________RouteCompressS2Fast-16 6216602 563.4 ns/op Benchmark_________RouteCompressS2Fast-16 6260583 562.0 ns/op Benchmark_________RouteCompressS2Fast-16 6366271 556.9 ns/op Benchmark_________RouteCompressS2Fast-16 6464892 563.5 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6380707 563.4 ns/op Benchmark_______RouteCompressS2Better-16 6294319 556.9 ns/op Benchmark_______RouteCompressS2Better-16 6218335 572.0 ns/op Benchmark_______RouteCompressS2Better-16 6347562 567.7 ns/op Benchmark_______RouteCompressS2Better-16 6214261 565.0 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6212997 567.3 ns/op Benchmark_________RouteCompressS2Best-16 6409928 567.2 ns/op Benchmark_________RouteCompressS2Best-16 6425466 562.9 ns/op Benchmark_________RouteCompressS2Best-16 6210829 555.9 ns/op Benchmark_________RouteCompressS2Best-16 6548680 556.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4616131 778.2 ns/op 319.97 MB/s Benchmark______FanOut_8x1x10-16 4607796 778.2 ns/op 319.98 MB/s Benchmark______FanOut_8x1x10-16 4598320 780.9 ns/op 318.86 MB/s Benchmark______FanOut_8x1x10-16 4591556 779.6 ns/op 319.41 MB/s Benchmark______FanOut_8x1x10-16 4608692 776.0 ns/op 320.88 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 551740 6233 ns/op 372.05 MB/s Benchmark_____FanOut_8x1x100-16 550776 6284 ns/op 369.03 MB/s Benchmark_____FanOut_8x1x100-16 562125 6313 ns/op 367.32 MB/s Benchmark_____FanOut_8x1x100-16 520842 6192 ns/op 374.50 MB/s Benchmark_____FanOut_8x1x100-16 550906 6194 ns/op 374.42 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 46675 77092 ns/op 298.59 MB/s Benchmark____FanOut_8x10x100-16 46924 77038 ns/op 298.80 MB/s Benchmark____FanOut_8x10x100-16 46844 76761 ns/op 299.88 MB/s Benchmark____FanOut_8x10x100-16 46598 76882 ns/op 299.41 MB/s Benchmark____FanOut_8x10x100-16 46477 76901 ns/op 299.33 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5626 624867 ns/op 384.11 MB/s Benchmark___FanOut_8x10x1000-16 5713 623485 ns/op 384.96 MB/s Benchmark___FanOut_8x10x1000-16 5718 624613 ns/op 384.27 MB/s Benchmark___FanOut_8x10x1000-16 5806 623607 ns/op 384.89 MB/s Benchmark___FanOut_8x10x1000-16 5647 623601 ns/op 384.89 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4843 735223 ns/op 312.86 MB/s Benchmark___FanOut_8x100x100-16 4768 733365 ns/op 313.65 MB/s Benchmark___FanOut_8x100x100-16 4878 731787 ns/op 314.33 MB/s Benchmark___FanOut_8x100x100-16 4794 735778 ns/op 312.62 MB/s Benchmark___FanOut_8x100x100-16 4819 732365 ns/op 314.08 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 548 6565514 ns/op 365.55 MB/s Benchmark__FanOut_8x100x1000-16 559 6527303 ns/op 367.69 MB/s Benchmark__FanOut_8x100x1000-16 536 6487721 ns/op 369.93 MB/s Benchmark__FanOut_8x100x1000-16 553 6472706 ns/op 370.79 MB/s Benchmark__FanOut_8x100x1000-16 549 6535585 ns/op 367.22 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 512 6933444 ns/op 360.57 MB/s Benchmark__FanOut_8x10x10000-16 522 7078656 ns/op 353.18 MB/s Benchmark__FanOut_8x10x10000-16 518 6970826 ns/op 358.64 MB/s Benchmark__FanOut_8x10x10000-16 511 6915629 ns/op 361.50 MB/s Benchmark__FanOut_8x10x10000-16 514 6949945 ns/op 359.72 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 924 3906070 ns/op 294.42 MB/s Benchmark___FanOut_8x500x100-16 924 3862044 ns/op 297.77 MB/s Benchmark___FanOut_8x500x100-16 916 3861130 ns/op 297.85 MB/s Benchmark___FanOut_8x500x100-16 918 3837996 ns/op 299.64 MB/s Benchmark___FanOut_8x500x100-16 924 3852313 ns/op 298.53 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 354966 9642 ns/op 1518.44 MB/s Benchmark___FanOut_128x1x100-16 352562 9636 ns/op 1519.41 MB/s Benchmark___FanOut_128x1x100-16 356326 9606 ns/op 1524.14 MB/s Benchmark___FanOut_128x1x100-16 353512 9612 ns/op 1523.18 MB/s Benchmark___FanOut_128x1x100-16 355582 9653 ns/op 1516.79 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 31935 112178 ns/op 1293.85 MB/s Benchmark__FanOut_128x10x100-16 31704 112408 ns/op 1291.20 MB/s Benchmark__FanOut_128x10x100-16 32031 112474 ns/op 1290.44 MB/s Benchmark__FanOut_128x10x100-16 32100 112783 ns/op 1286.90 MB/s Benchmark__FanOut_128x10x100-16 31981 112556 ns/op 1289.50 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3795 904530 ns/op 1614.25 MB/s Benchmark_FanOut_128x10x1000-16 3998 893489 ns/op 1634.20 MB/s Benchmark_FanOut_128x10x1000-16 3890 902078 ns/op 1618.64 MB/s Benchmark_FanOut_128x10x1000-16 3996 900010 ns/op 1622.36 MB/s Benchmark_FanOut_128x10x1000-16 4029 895960 ns/op 1629.69 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3411 1030030 ns/op 1407.86 MB/s Benchmark_FanOut_128x100x100-16 3427 1032750 ns/op 1404.16 MB/s Benchmark_FanOut_128x100x100-16 3411 1038032 ns/op 1397.01 MB/s Benchmark_FanOut_128x100x100-16 3438 1031913 ns/op 1405.29 MB/s Benchmark_FanOut_128x100x100-16 3436 1031927 ns/op 1405.27 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 375 9566677 ns/op 1526.15 MB/s BenchmarkFanOut_128x100x1000-16 379 9523773 ns/op 1533.02 MB/s BenchmarkFanOut_128x100x1000-16 372 9569820 ns/op 1525.64 MB/s BenchmarkFanOut_128x100x1000-16 376 9461334 ns/op 1543.14 MB/s BenchmarkFanOut_128x100x1000-16 372 9529752 ns/op 1532.06 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 364 9835940 ns/op 1494.53 MB/s BenchmarkFanOut_128x10x10000-16 367 9888669 ns/op 1486.56 MB/s BenchmarkFanOut_128x10x10000-16 366 9871594 ns/op 1489.14 MB/s BenchmarkFanOut_128x10x10000-16 364 9906741 ns/op 1483.85 MB/s BenchmarkFanOut_128x10x10000-16 366 9944894 ns/op 1478.16 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 654 5393927 ns/op 1344.13 MB/s BenchmarkFanOut__128x500x100-16 661 5359856 ns/op 1352.67 MB/s BenchmarkFanOut__128x500x100-16 662 5351720 ns/op 1354.73 MB/s BenchmarkFanOut__128x500x100-16 664 5370644 ns/op 1349.96 MB/s BenchmarkFanOut__128x500x100-16 656 5359020 ns/op 1352.89 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1914 1852615 ns/op 2855.71 MB/s Benchmark_FanOut_512x100x100-16 1894 1853881 ns/op 2853.76 MB/s Benchmark_FanOut_512x100x100-16 1900 1887081 ns/op 2803.55 MB/s Benchmark_FanOut_512x100x100-16 1911 1885340 ns/op 2806.14 MB/s Benchmark_FanOut_512x100x100-16 1936 1861852 ns/op 2841.54 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 17021040 ns/op 3113.82 MB/s Benchmark__FanOut_512x100x1k-16 214 17138255 ns/op 3092.53 MB/s Benchmark__FanOut_512x100x1k-16 211 17028537 ns/op 3112.45 MB/s Benchmark__FanOut_512x100x1k-16 210 17129584 ns/op 3094.09 MB/s Benchmark__FanOut_512x100x1k-16 211 17104091 ns/op 3098.70 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3177 1144407 ns/op 9114.80 MB/s Benchmark____FanOut_1kx10x1k-16 2768 1177726 ns/op 8856.93 MB/s Benchmark____FanOut_1kx10x1k-16 3015 1177077 ns/op 8861.82 MB/s Benchmark____FanOut_1kx10x1k-16 3165 1161843 ns/op 8978.01 MB/s Benchmark____FanOut_1kx10x1k-16 2761 1161307 ns/op 8982.16 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2728 1289084 ns/op 8084.06 MB/s Benchmark__FanOut_1kx100x100-16 2701 1276677 ns/op 8162.63 MB/s Benchmark__FanOut_1kx100x100-16 2761 1279669 ns/op 8143.54 MB/s Benchmark__FanOut_1kx100x100-16 2702 1280243 ns/op 8139.89 MB/s Benchmark__FanOut_1kx100x100-16 2734 1274803 ns/op 8174.62 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4416028 795.7 ns/op 312.94 MB/s Benchmark_____RFanOut_8x1x10-16 4385864 783.3 ns/op 317.89 MB/s Benchmark_____RFanOut_8x1x10-16 4395589 791.0 ns/op 314.79 MB/s Benchmark_____RFanOut_8x1x10-16 4488729 788.7 ns/op 315.70 MB/s Benchmark_____RFanOut_8x1x10-16 4440436 800.1 ns/op 311.23 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 541210 6254 ns/op 370.81 MB/s Benchmark____RFanOut_8x1x100-16 529386 6347 ns/op 365.39 MB/s Benchmark____RFanOut_8x1x100-16 535843 6264 ns/op 370.22 MB/s Benchmark____RFanOut_8x1x100-16 522950 6249 ns/op 371.11 MB/s Benchmark____RFanOut_8x1x100-16 524120 6271 ns/op 369.79 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46334 77062 ns/op 298.71 MB/s Benchmark___RFanOut_8x10x100-16 46610 76488 ns/op 300.95 MB/s Benchmark___RFanOut_8x10x100-16 46915 77556 ns/op 296.81 MB/s Benchmark___RFanOut_8x10x100-16 46322 77491 ns/op 297.06 MB/s Benchmark___RFanOut_8x10x100-16 46843 77891 ns/op 295.53 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5515 631372 ns/op 380.15 MB/s Benchmark__RFanOut_8x10x1000-16 5463 627415 ns/op 382.55 MB/s Benchmark__RFanOut_8x10x1000-16 5677 639214 ns/op 375.49 MB/s Benchmark__RFanOut_8x10x1000-16 5559 627366 ns/op 382.58 MB/s Benchmark__RFanOut_8x10x1000-16 5668 633860 ns/op 378.66 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4918 731618 ns/op 314.40 MB/s Benchmark__RFanOut_8x100x100-16 4802 726243 ns/op 316.72 MB/s Benchmark__RFanOut_8x100x100-16 4893 735112 ns/op 312.90 MB/s Benchmark__RFanOut_8x100x100-16 4690 734151 ns/op 313.31 MB/s Benchmark__RFanOut_8x100x100-16 4868 725912 ns/op 316.87 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 538 6416672 ns/op 374.03 MB/s Benchmark_RFanOut_8x100x1000-16 529 6619488 ns/op 362.57 MB/s Benchmark_RFanOut_8x100x1000-16 546 6677878 ns/op 359.40 MB/s Benchmark_RFanOut_8x100x1000-16 547 6714713 ns/op 357.43 MB/s Benchmark_RFanOut_8x100x1000-16 542 6537829 ns/op 367.10 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 519 6903846 ns/op 362.12 MB/s Benchmark_RFanOut_8x10x10000-16 506 7060884 ns/op 354.07 MB/s Benchmark_RFanOut_8x10x10000-16 523 6962279 ns/op 359.08 MB/s Benchmark_RFanOut_8x10x10000-16 502 7005986 ns/op 356.84 MB/s Benchmark_RFanOut_8x10x10000-16 517 6967065 ns/op 358.83 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3166 1181204 ns/op 8830.85 MB/s Benchmark_RFanOut_1kx10x1000-16 2776 1165777 ns/op 8947.71 MB/s Benchmark_RFanOut_1kx10x1000-16 2848 1183276 ns/op 8815.39 MB/s Benchmark_RFanOut_1kx10x1000-16 3117 1173769 ns/op 8886.79 MB/s Benchmark_RFanOut_1kx10x1000-16 3092 1170091 ns/op 8914.72 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6900387 507.7 ns/op 4092.57 MB/s Benchmark_____FanIn_1kx100x1-16 6964770 508.9 ns/op 4083.54 MB/s Benchmark_____FanIn_1kx100x1-16 6977150 508.2 ns/op 4089.21 MB/s Benchmark_____FanIn_1kx100x1-16 6904482 507.4 ns/op 4095.78 MB/s Benchmark_____FanIn_1kx100x1-16 6866349 505.4 ns/op 4111.61 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2611689 1359 ns/op 6051.91 MB/s Benchmark_____FanIn_4kx100x1-16 2651546 1366 ns/op 6020.10 MB/s Benchmark_____FanIn_4kx100x1-16 2652574 1424 ns/op 5773.17 MB/s Benchmark_____FanIn_4kx100x1-16 2644549 1391 ns/op 5912.17 MB/s Benchmark_____FanIn_4kx100x1-16 2628049 1380 ns/op 5956.19 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1704421 2107 ns/op 7791.49 MB/s Benchmark_____FanIn_8kx100x1-16 1696516 2121 ns/op 7737.55 MB/s Benchmark_____FanIn_8kx100x1-16 1686567 2120 ns/op 7742.42 MB/s Benchmark_____FanIn_8kx100x1-16 1676122 2133 ns/op 7697.02 MB/s Benchmark_____FanIn_8kx100x1-16 1694121 2128 ns/op 7714.08 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 856903 4116 ns/op 7969.07 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 25126332 vs 9089434200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39362->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_16kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39906->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_16kx100x1-16 861169 4151 ns/op 7902.43 MB/s Benchmark____FanIn_16kx100x1-16 863408 4119 ns/op 7963.03 MB/s Benchmark____FanIn_16kx100x1-16 865977 4114 ns/op 7973.54 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 166474 19841 ns/op 6607.63 MB/s Benchmark____FanIn_64kx100x1-16 173372 20182 ns/op 6496.03 MB/s Benchmark____FanIn_64kx100x1-16 163153 20249 ns/op 6474.56 MB/s Benchmark____FanIn_64kx100x1-16 164179 20113 ns/op 6518.26 MB/s Benchmark____FanIn_64kx100x1-16 166440 19957 ns/op 6569.48 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1420753420 vs 11575247000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53524->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: 528554880 vs 11562138000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56964->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56510->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56416->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56446->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:56722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56578->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 451473960 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58178->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58632->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58754->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58708->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58846->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: 176053870 vs 11234413000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32942->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: 891674180 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34830->127.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: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:35108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35056->127.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:35300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34498->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5480905 644.1 ns/op 440.94 MB/s Benchmark___BumpPubCount_1x3-16 5481531 646.6 ns/op 439.24 MB/s Benchmark___BumpPubCount_1x3-16 5514108 648.1 ns/op 438.18 MB/s Benchmark___BumpPubCount_1x3-16 5461461 645.2 ns/op 440.19 MB/s Benchmark___BumpPubCount_1x3-16 5517018 647.7 ns/op 438.46 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5311976 677.0 ns/op 419.52 MB/s Benchmark___BumpPubCount_2x3-16 5249908 675.9 ns/op 420.19 MB/s Benchmark___BumpPubCount_2x3-16 5298676 676.5 ns/op 419.81 MB/s Benchmark___BumpPubCount_2x3-16 5245494 679.2 ns/op 418.12 MB/s Benchmark___BumpPubCount_2x3-16 5256772 681.2 ns/op 416.92 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5524708 656.6 ns/op 432.50 MB/s Benchmark___BumpPubCount_5x3-16 5474974 648.1 ns/op 438.21 MB/s Benchmark___BumpPubCount_5x3-16 5519002 652.8 ns/op 435.06 MB/s Benchmark___BumpPubCount_5x3-16 5522544 650.4 ns/op 436.67 MB/s Benchmark___BumpPubCount_5x3-16 5515336 648.6 ns/op 437.90 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5093941 650.1 ns/op 436.88 MB/s Benchmark__BumpPubCount_10x3-16 5506819 648.8 ns/op 437.74 MB/s Benchmark__BumpPubCount_10x3-16 5532764 649.2 ns/op 437.48 MB/s Benchmark__BumpPubCount_10x3-16 5534335 647.5 ns/op 438.60 MB/s Benchmark__BumpPubCount_10x3-16 5504575 650.3 ns/op 436.73 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12198675 283.7 ns/op 3666.24 MB/s Benchmark____GWs_Opt_1kx01x0-16 11576302 302.2 ns/op 3441.52 MB/s Benchmark____GWs_Opt_1kx01x0-16 13284152 270.7 ns/op 3842.05 MB/s Benchmark____GWs_Opt_1kx01x0-16 12836311 277.4 ns/op 3748.79 MB/s Benchmark____GWs_Opt_1kx01x0-16 13407142 273.5 ns/op 3802.57 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10653349 334.6 ns/op 6167.81 MB/s Benchmark____GWs_Opt_2kx01x0-16 9071780 352.2 ns/op 5859.60 MB/s Benchmark____GWs_Opt_2kx01x0-16 10109521 352.5 ns/op 5854.80 MB/s Benchmark____GWs_Opt_2kx01x0-16 10525288 327.7 ns/op 6298.10 MB/s Benchmark____GWs_Opt_2kx01x0-16 9769099 335.8 ns/op 6146.90 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5908365 630.3 ns/op 6523.67 MB/s Benchmark____GWs_Opt_4kx01x0-16 5838604 629.4 ns/op 6532.73 MB/s Benchmark____GWs_Opt_4kx01x0-16 6073245 624.6 ns/op 6583.66 MB/s Benchmark____GWs_Opt_4kx01x0-16 5508757 625.5 ns/op 6573.89 MB/s Benchmark____GWs_Opt_4kx01x0-16 5564083 639.6 ns/op 6428.94 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28458510 121.3 ns/op 8570.74 MB/s Benchmark____GWs_Opt_1kx10x0-16 32286052 110.3 ns/op 9428.14 MB/s Benchmark____GWs_Opt_1kx10x0-16 32372857 111.4 ns/op 9336.20 MB/s Benchmark____GWs_Opt_1kx10x0-16 31131168 112.1 ns/op 9278.46 MB/s Benchmark____GWs_Opt_1kx10x0-16 28326216 114.4 ns/op 9091.90 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25208044 139.5 ns/op 14798.69 MB/s Benchmark____GWs_Opt_2kx10x0-16 25979248 144.4 ns/op 14293.98 MB/s Benchmark____GWs_Opt_2kx10x0-16 24681529 144.4 ns/op 14290.46 MB/s Benchmark____GWs_Opt_2kx10x0-16 23742007 140.6 ns/op 14678.03 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:60492->127.0.0.1:37461: 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:41474->127.0.0.1:42895: use of closed network connection --- FAIL: Benchmark____GWs_Opt_2kx10x0-16 Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11987586 325.2 ns/op 12644.46 MB/s Benchmark____GWs_Opt_4kx10x0-16 12801798 324.8 ns/op 12661.98 MB/s Benchmark____GWs_Opt_4kx10x0-16 13422824 377.3 ns/op 10898.55 MB/s Benchmark____GWs_Opt_4kx10x0-16 12269340 321.6 ns/op 12785.47 MB/s Benchmark____GWs_Opt_4kx10x0-16 8961291 369.9 ns/op 11116.77 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6485656 554.8 ns/op 5632.70 MB/s Benchmark____GWs_Opt_1kx01x1-16 6352119 546.8 ns/op 5714.68 MB/s Benchmark____GWs_Opt_1kx01x1-16 6564241 554.6 ns/op 5634.99 MB/s Benchmark____GWs_Opt_1kx01x1-16 6378022 553.1 ns/op 5650.06 MB/s Benchmark____GWs_Opt_1kx01x1-16 6654622 546.6 ns/op 5717.13 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4598462 766.0 ns/op 8090.43 MB/s Benchmark____GWs_Opt_2kx01x1-16 4680132 951.2 ns/op 6515.07 MB/s Benchmark____GWs_Opt_2kx01x1-16 4603456 774.0 ns/op 8006.62 MB/s Benchmark____GWs_Opt_2kx01x1-16 4630646 767.2 ns/op 8076.90 MB/s Benchmark____GWs_Opt_2kx01x1-16 4521937 773.8 ns/op 8008.45 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2594338 1378 ns/op 8953.58 MB/s Benchmark____GWs_Opt_4kx01x1-16 2619723 1397 ns/op 8835.17 MB/s Benchmark____GWs_Opt_4kx01x1-16 2530742 1431 ns/op 8623.02 MB/s Benchmark____GWs_Opt_4kx01x1-16 2613231 1410 ns/op 8754.37 MB/s Benchmark____GWs_Opt_4kx01x1-16 2617873 1370 ns/op 9005.36 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6200881 553.6 ns/op 5645.18 MB/s Benchmark____GWs_Opt_1kx10x1-16 6113166 559.2 ns/op 5588.43 MB/s Benchmark____GWs_Opt_1kx10x1-16 6316809 565.9 ns/op 5522.55 MB/s Benchmark____GWs_Opt_1kx10x1-16 6447102 558.6 ns/op 5594.59 MB/s Benchmark____GWs_Opt_1kx10x1-16 6287149 563.2 ns/op 5548.92 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4022773 848.8 ns/op 7300.84 MB/s Benchmark____GWs_Opt_2kx10x1-16 4490500 848.4 ns/op 7304.75 MB/s Benchmark____GWs_Opt_2kx10x1-16 4035853 857.5 ns/op 7227.08 MB/s Benchmark____GWs_Opt_2kx10x1-16 4047291 839.0 ns/op 7385.95 MB/s Benchmark____GWs_Opt_2kx10x1-16 4346355 841.1 ns/op 7367.97 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2348364 1565 ns/op 7883.30 MB/s Benchmark____GWs_Opt_4kx10x1-16 2357020 1538 ns/op 8025.07 MB/s Benchmark____GWs_Opt_4kx10x1-16 2389934 1503 ns/op 8211.44 MB/s Benchmark____GWs_Opt_4kx10x1-16 2364529 1517 ns/op 8133.93 MB/s Benchmark____GWs_Opt_4kx10x1-16 2322884 1525 ns/op 8091.36 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12732289 280.9 ns/op 3702.60 MB/s Benchmark____GWs_Int_1kx01x0-16 11980615 287.0 ns/op 3623.61 MB/s Benchmark____GWs_Int_1kx01x0-16 12305408 284.0 ns/op 3661.75 MB/s Benchmark____GWs_Int_1kx01x0-16 12194533 277.7 ns/op 3745.62 MB/s Benchmark____GWs_Int_1kx01x0-16 12841654 287.8 ns/op 3614.20 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10109007 348.5 ns/op 5923.36 MB/s Benchmark____GWs_Int_2kx01x0-16 10732038 352.2 ns/op 5861.02 MB/s Benchmark____GWs_Int_2kx01x0-16 10794844 348.7 ns/op 5918.91 MB/s Benchmark____GWs_Int_2kx01x0-16 10283797 355.8 ns/op 5801.05 MB/s Benchmark____GWs_Int_2kx01x0-16 9909826 368.5 ns/op 5600.50 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5692783 640.1 ns/op 6423.70 MB/s Benchmark____GWs_Int_4kx01x0-16 5859792 636.8 ns/op 6457.51 MB/s Benchmark____GWs_Int_4kx01x0-16 5853369 634.0 ns/op 6486.30 MB/s Benchmark____GWs_Int_4kx01x0-16 4995920 630.7 ns/op 6520.02 MB/s Benchmark____GWs_Int_4kx01x0-16 5717178 640.4 ns/op 6420.79 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30681814 136.4 ns/op 7622.95 MB/s Benchmark____GWs_Int_1kx10x0-16 31798664 115.3 ns/op 9020.10 MB/s Benchmark____GWs_Int_1kx10x0-16 30251877 116.1 ns/op 8956.24 MB/s Benchmark____GWs_Int_1kx10x0-16 31537491 110.2 ns/op 9440.36 MB/s Benchmark____GWs_Int_1kx10x0-16 30562466 114.6 ns/op 9071.76 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 23989713 142.1 ns/op 14519.93 MB/s Benchmark____GWs_Int_2kx10x0-16 24414614 148.9 ns/op 13862.47 MB/s Benchmark____GWs_Int_2kx10x0-16 25644750 155.2 ns/op 13299.05 MB/s Benchmark____GWs_Int_2kx10x0-16 25490244 139.0 ns/op 14849.86 MB/s Benchmark____GWs_Int_2kx10x0-16 25324549 161.6 ns/op 12771.76 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13077328 312.3 ns/op 13166.41 MB/s Benchmark____GWs_Int_4kx10x0-16 13277576 318.7 ns/op 12901.99 MB/s Benchmark____GWs_Int_4kx10x0-16 13207284 306.5 ns/op 13418.11 MB/s Benchmark____GWs_Int_4kx10x0-16 11027810 276.8 ns/op 14854.60 MB/s Benchmark____GWs_Int_4kx10x0-16 7485378 633.5 ns/op 6491.13 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6614350 559.3 ns/op 5587.03 MB/s Benchmark____GWs_Int_1kx01x1-16 6338028 553.9 ns/op 5642.11 MB/s Benchmark____GWs_Int_1kx01x1-16 6456132 563.7 ns/op 5543.97 MB/s Benchmark____GWs_Int_1kx01x1-16 6500392 553.1 ns/op 5649.95 MB/s Benchmark____GWs_Int_1kx01x1-16 6278174 561.9 ns/op 5561.03 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4285296 1324 ns/op 4681.35 MB/s Benchmark____GWs_Int_2kx01x1-16 4701950 773.7 ns/op 8009.84 MB/s Benchmark____GWs_Int_2kx01x1-16 4722996 890.5 ns/op 6958.77 MB/s Benchmark____GWs_Int_2kx01x1-16 4098097 766.1 ns/op 8089.55 MB/s Benchmark____GWs_Int_2kx01x1-16 4635211 758.2 ns/op 8173.29 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2587614 1358 ns/op 9087.17 MB/s Benchmark____GWs_Int_4kx01x1-16 2592658 1390 ns/op 8881.34 MB/s Benchmark____GWs_Int_4kx01x1-16 2638537 1566 ns/op 7882.78 MB/s Benchmark____GWs_Int_4kx01x1-16 2608604 1383 ns/op 8923.17 MB/s Benchmark____GWs_Int_4kx01x1-16 2619453 1384 ns/op 8917.51 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6169046 557.6 ns/op 5604.67 MB/s Benchmark____GWs_Int_1kx10x1-16 6439024 555.6 ns/op 5624.28 MB/s Benchmark____GWs_Int_1kx10x1-16 6566356 557.5 ns/op 5605.48 MB/s Benchmark____GWs_Int_1kx10x1-16 6278443 566.5 ns/op 5516.36 MB/s Benchmark____GWs_Int_1kx10x1-16 6643453 582.7 ns/op 5363.18 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4188162 844.9 ns/op 7334.37 MB/s Benchmark____GWs_Int_2kx10x1-16 4097276 892.4 ns/op 6943.99 MB/s Benchmark____GWs_Int_2kx10x1-16 4250769 842.1 ns/op 7358.79 MB/s Benchmark____GWs_Int_2kx10x1-16 4071582 905.2 ns/op 6845.86 MB/s Benchmark____GWs_Int_2kx10x1-16 4227632 866.0 ns/op 7156.28 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2301992 1525 ns/op 8092.37 MB/s Benchmark____GWs_Int_4kx10x1-16 2179980 1540 ns/op 8015.92 MB/s Benchmark____GWs_Int_4kx10x1-16 2344704 1525 ns/op 8094.20 MB/s Benchmark____GWs_Int_4kx10x1-16 2132395 1528 ns/op 8077.48 MB/s Benchmark____GWs_Int_4kx10x1-16 2366324 1535 ns/op 8038.78 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8407699 434.3 ns/op 234.88 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8384220 439.4 ns/op 232.13 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8102276 440.0 ns/op 231.82 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8353891 430.3 ns/op 237.03 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7988512 428.6 ns/op 237.98 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 624216 5015 ns/op 35.30 MB/s Benchmark__GWs_Reqs_1SubEach-16 757418 5132 ns/op 34.49 MB/s Benchmark__GWs_Reqs_1SubEach-16 794929 5280 ns/op 33.52 MB/s Benchmark__GWs_Reqs_1SubEach-16 751561 5254 ns/op 33.69 MB/s Benchmark__GWs_Reqs_1SubEach-16 754322 5437 ns/op 32.55 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2086.637s ❌ Non-zero exit code: 1