> ROOT_DIR=/tmp/go-bench-away-job-c6f157b7-9ada-481a-bb76-37914b447868-570551767 > OUTPUT_FILE=/tmp/go-bench-away-job-c6f157b7-9ada-481a-bb76-37914b447868-570551767/results.txt > SHA_FILE=/tmp/go-bench-away-job-c6f157b7-9ada-481a-bb76-37914b447868-570551767/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-c6f157b7-9ada-481a-bb76-37914b447868-570551767/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-c6f157b7-9ada-481a-bb76-37914b447868-570551767/source.git SHA of main: ca6311b2e1da1f20d68ccb68f20a352f3c7799d7 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-build768189398=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-c6f157b7-9ada-481a-bb76-37914b447868-570551767/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 43491668 71.70 ns/op 153.42 MB/s Benchmark______Pub0b_Payload-16 47052678 72.76 ns/op 151.19 MB/s Benchmark______Pub0b_Payload-16 47362368 74.55 ns/op 147.55 MB/s Benchmark______Pub0b_Payload-16 43610295 72.21 ns/op 152.33 MB/s Benchmark______Pub0b_Payload-16 47723474 71.80 ns/op 153.21 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 49759797 72.35 ns/op 262.62 MB/s Benchmark______Pub8b_Payload-16 46771375 73.17 ns/op 259.66 MB/s Benchmark______Pub8b_Payload-16 46821511 72.40 ns/op 262.45 MB/s Benchmark______Pub8b_Payload-16 46705448 72.63 ns/op 261.59 MB/s Benchmark______Pub8b_Payload-16 46970301 72.96 ns/op 260.40 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44529711 76.54 ns/op 574.86 MB/s Benchmark_____Pub32b_Payload-16 44370075 76.81 ns/op 572.81 MB/s Benchmark_____Pub32b_Payload-16 43524050 77.18 ns/op 570.11 MB/s Benchmark_____Pub32b_Payload-16 44536366 76.84 ns/op 572.64 MB/s Benchmark_____Pub32b_Payload-16 44843355 76.62 ns/op 574.23 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 40135147 87.83 ns/op 1605.33 MB/s Benchmark____Pub128B_Payload-16 38573977 85.61 ns/op 1646.98 MB/s Benchmark____Pub128B_Payload-16 40117075 85.38 ns/op 1651.48 MB/s Benchmark____Pub128B_Payload-16 39142089 86.30 ns/op 1633.92 MB/s Benchmark____Pub128B_Payload-16 35728034 85.57 ns/op 1647.78 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 33374311 93.40 ns/op 2880.00 MB/s Benchmark____Pub256B_Payload-16 35947868 94.94 ns/op 2833.32 MB/s Benchmark____Pub256B_Payload-16 31250554 97.48 ns/op 2759.43 MB/s Benchmark____Pub256B_Payload-16 38232847 95.28 ns/op 2823.24 MB/s Benchmark____Pub256B_Payload-16 38189408 95.66 ns/op 2812.12 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23681319 143.1 ns/op 7252.97 MB/s Benchmark______Pub1K_Payload-16 24423283 137.5 ns/op 7548.59 MB/s Benchmark______Pub1K_Payload-16 26809695 140.9 ns/op 7369.15 MB/s Benchmark______Pub1K_Payload-16 25619337 143.2 ns/op 7249.22 MB/s Benchmark______Pub1K_Payload-16 22074913 143.2 ns/op 7247.66 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5718471 620.2 ns/op 6627.16 MB/s Benchmark______Pub4K_Payload-16 5708926 615.1 ns/op 6681.40 MB/s Benchmark______Pub4K_Payload-16 5655138 621.0 ns/op 6618.68 MB/s Benchmark______Pub4K_Payload-16 5196615 626.9 ns/op 6555.71 MB/s Benchmark______Pub4K_Payload-16 5650624 611.8 ns/op 6717.86 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2742615 1276 ns/op 6432.47 MB/s Benchmark______Pub8K_Payload-16 2740706 1278 ns/op 6422.84 MB/s Benchmark______Pub8K_Payload-16 2814525 1291 ns/op 6354.62 MB/s Benchmark______Pub8K_Payload-16 2665260 1291 ns/op 6355.69 MB/s Benchmark______Pub8K_Payload-16 2755272 1290 ns/op 6360.64 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 645157 5594 ns/op 5860.26 MB/s Benchmark_____Pub32K_Payload-16 663122 5501 ns/op 5959.75 MB/s Benchmark_____Pub32K_Payload-16 659013 5433 ns/op 6034.52 MB/s Benchmark_____Pub32K_Payload-16 461257 8834 ns/op 3710.95 MB/s Benchmark_____Pub32K_Payload-16 660024 5563 ns/op 5893.12 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 38384276 94.55 ns/op 116.34 MB/s Benchmark__AuthPub0b_Payload-16 34260921 94.04 ns/op 116.98 MB/s Benchmark__AuthPub0b_Payload-16 36403398 94.18 ns/op 116.79 MB/s Benchmark__AuthPub0b_Payload-16 38299551 94.34 ns/op 116.60 MB/s Benchmark__AuthPub0b_Payload-16 36391029 94.18 ns/op 116.79 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15515166 229.1 ns/op Benchmark_____________PubSub-16 15632392 227.9 ns/op Benchmark_____________PubSub-16 15704757 229.6 ns/op Benchmark_____________PubSub-16 15641244 227.6 ns/op Benchmark_____________PubSub-16 15455497 227.6 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15641514 227.2 ns/op Benchmark_____PubSubTwoConns-16 15623359 226.6 ns/op Benchmark_____PubSubTwoConns-16 15635847 225.5 ns/op Benchmark_____PubSubTwoConns-16 15688662 226.9 ns/op Benchmark_____PubSubTwoConns-16 15692725 226.2 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59952->127.0.0.1:46293: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59994->127.0.0.1:37055: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:35618->127.0.0.1:32975: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49570->127.0.0.1:44785: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41818->127.0.0.1:40089: 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 14179270 248.6 ns/op Benchmark_____PubTwoQueueSub-16 14395464 248.0 ns/op Benchmark_____PubTwoQueueSub-16 14351012 247.8 ns/op Benchmark_____PubTwoQueueSub-16 14329624 247.9 ns/op Benchmark_____PubTwoQueueSub-16 14283574 247.5 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14331127 246.8 ns/op Benchmark____PubFourQueueSub-16 14320630 247.7 ns/op Benchmark____PubFourQueueSub-16 14125010 248.4 ns/op Benchmark____PubFourQueueSub-16 14303463 247.4 ns/op Benchmark____PubFourQueueSub-16 14102444 249.3 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14203224 247.6 ns/op Benchmark___PubEightQueueSub-16 14328408 246.5 ns/op Benchmark___PubEightQueueSub-16 14199342 249.0 ns/op Benchmark___PubEightQueueSub-16 14138648 248.7 ns/op Benchmark___PubEightQueueSub-16 14229056 247.2 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22135 153796 ns/op Benchmark_PubSub512kTwoConns-16 22999 155267 ns/op Benchmark_PubSub512kTwoConns-16 23235 155437 ns/op Benchmark_PubSub512kTwoConns-16 23247 154140 ns/op Benchmark_PubSub512kTwoConns-16 23118 155003 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15087890 230.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15261669 229.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15310878 230.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 14985163 230.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 14949794 228.8 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15369717 230.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15289713 229.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15197462 230.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15397066 230.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15102577 230.6 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11352319 315.9 ns/op Benchmark____RoutedPubSub_0b-16 11216614 316.4 ns/op Benchmark____RoutedPubSub_0b-16 10946307 313.4 ns/op Benchmark____RoutedPubSub_0b-16 11029002 312.6 ns/op Benchmark____RoutedPubSub_0b-16 11357077 319.3 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6527134 525.2 ns/op Benchmark____RoutedPubSub_1K-16 6554482 548.4 ns/op Benchmark____RoutedPubSub_1K-16 6447237 546.3 ns/op Benchmark____RoutedPubSub_1K-16 6561292 542.5 ns/op Benchmark____RoutedPubSub_1K-16 6492705 516.6 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 83384 42170 ns/op Benchmark__RoutedPubSub_100K-16 82213 42670 ns/op Benchmark__RoutedPubSub_100K-16 86235 44538 ns/op Benchmark__RoutedPubSub_100K-16 74616 43301 ns/op Benchmark__RoutedPubSub_100K-16 83920 42105 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11244444 316.6 ns/op Benchmark____Routed2QueueSub-16 9533712 324.8 ns/op Benchmark____Routed2QueueSub-16 9582104 320.4 ns/op Benchmark____Routed2QueueSub-16 9508677 317.0 ns/op Benchmark____Routed2QueueSub-16 11239718 320.5 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9199564 330.4 ns/op Benchmark____Routed4QueueSub-16 9305478 332.1 ns/op Benchmark____Routed4QueueSub-16 9447169 326.8 ns/op Benchmark____Routed4QueueSub-16 11187061 323.4 ns/op Benchmark____Routed4QueueSub-16 9426351 324.3 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 10984057 333.4 ns/op Benchmark____Routed8QueueSub-16 9355424 328.7 ns/op Benchmark____Routed8QueueSub-16 9139738 333.3 ns/op Benchmark____Routed8QueueSub-16 8991384 333.8 ns/op Benchmark____Routed8QueueSub-16 9135745 332.6 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8642968 347.6 ns/op Benchmark___Routed16QueueSub-16 8747757 347.4 ns/op Benchmark___Routed16QueueSub-16 8860647 357.8 ns/op Benchmark___Routed16QueueSub-16 8793262 346.4 ns/op Benchmark___Routed16QueueSub-16 8725302 354.1 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6373180 554.8 ns/op Benchmark____________RouteCompressOff-16 6448532 544.7 ns/op Benchmark____________RouteCompressOff-16 6448132 555.6 ns/op Benchmark____________RouteCompressOff-16 6396163 558.7 ns/op Benchmark____________RouteCompressOff-16 6288757 554.7 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6567009 553.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6408853 553.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6335953 553.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6216076 552.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6651600 550.5 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6300258 516.4 ns/op Benchmark_________RouteCompressS2Fast-16 6181573 551.7 ns/op Benchmark_________RouteCompressS2Fast-16 6484748 553.5 ns/op Benchmark_________RouteCompressS2Fast-16 6442624 488.2 ns/op Benchmark_________RouteCompressS2Fast-16 6386607 547.2 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6452502 554.1 ns/op Benchmark_______RouteCompressS2Better-16 6318530 549.3 ns/op Benchmark_______RouteCompressS2Better-16 6446733 555.5 ns/op Benchmark_______RouteCompressS2Better-16 6341734 551.8 ns/op Benchmark_______RouteCompressS2Better-16 6452738 554.6 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6489564 512.0 ns/op Benchmark_________RouteCompressS2Best-16 6355834 553.0 ns/op Benchmark_________RouteCompressS2Best-16 6290286 566.9 ns/op Benchmark_________RouteCompressS2Best-16 6291297 560.8 ns/op Benchmark_________RouteCompressS2Best-16 6433442 559.7 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4634690 775.8 ns/op 320.94 MB/s Benchmark______FanOut_8x1x10-16 4584277 775.1 ns/op 321.23 MB/s Benchmark______FanOut_8x1x10-16 4634419 770.3 ns/op 323.24 MB/s Benchmark______FanOut_8x1x10-16 4611097 781.4 ns/op 318.65 MB/s Benchmark______FanOut_8x1x10-16 4639478 783.6 ns/op 317.77 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 548637 6216 ns/op 373.08 MB/s Benchmark_____FanOut_8x1x100-16 535672 6108 ns/op 379.68 MB/s Benchmark_____FanOut_8x1x100-16 540079 6226 ns/op 372.50 MB/s Benchmark_____FanOut_8x1x100-16 538039 6254 ns/op 370.83 MB/s Benchmark_____FanOut_8x1x100-16 533874 6109 ns/op 379.60 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47313 76461 ns/op 301.05 MB/s Benchmark____FanOut_8x10x100-16 47348 76050 ns/op 302.68 MB/s Benchmark____FanOut_8x10x100-16 47103 75884 ns/op 303.34 MB/s Benchmark____FanOut_8x10x100-16 47598 75443 ns/op 305.12 MB/s Benchmark____FanOut_8x10x100-16 47228 75442 ns/op 305.12 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5696 612707 ns/op 391.74 MB/s Benchmark___FanOut_8x10x1000-16 5695 622951 ns/op 385.29 MB/s Benchmark___FanOut_8x10x1000-16 5774 609966 ns/op 393.50 MB/s Benchmark___FanOut_8x10x1000-16 5702 614182 ns/op 390.79 MB/s Benchmark___FanOut_8x10x1000-16 5860 607845 ns/op 394.87 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4876 721922 ns/op 318.62 MB/s Benchmark___FanOut_8x100x100-16 4898 721409 ns/op 318.85 MB/s Benchmark___FanOut_8x100x100-16 4892 721737 ns/op 318.70 MB/s Benchmark___FanOut_8x100x100-16 4944 722102 ns/op 318.54 MB/s Benchmark___FanOut_8x100x100-16 4912 721714 ns/op 318.71 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 560 6260588 ns/op 383.35 MB/s Benchmark__FanOut_8x100x1000-16 564 6312610 ns/op 380.19 MB/s Benchmark__FanOut_8x100x1000-16 560 6342443 ns/op 378.41 MB/s Benchmark__FanOut_8x100x1000-16 553 6312672 ns/op 380.19 MB/s Benchmark__FanOut_8x100x1000-16 561 6360531 ns/op 377.33 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 524 6941793 ns/op 360.14 MB/s Benchmark__FanOut_8x10x10000-16 528 6878291 ns/op 363.47 MB/s Benchmark__FanOut_8x10x10000-16 519 7012405 ns/op 356.51 MB/s Benchmark__FanOut_8x10x10000-16 512 6933297 ns/op 360.58 MB/s Benchmark__FanOut_8x10x10000-16 524 6854853 ns/op 364.71 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 926 3831268 ns/op 300.17 MB/s Benchmark___FanOut_8x500x100-16 933 3841442 ns/op 299.37 MB/s Benchmark___FanOut_8x500x100-16 922 3816353 ns/op 301.34 MB/s Benchmark___FanOut_8x500x100-16 930 3816858 ns/op 301.30 MB/s Benchmark___FanOut_8x500x100-16 931 3805479 ns/op 302.20 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 352760 9590 ns/op 1526.72 MB/s Benchmark___FanOut_128x1x100-16 362596 9675 ns/op 1513.33 MB/s Benchmark___FanOut_128x1x100-16 351199 9631 ns/op 1520.14 MB/s Benchmark___FanOut_128x1x100-16 356745 9626 ns/op 1520.91 MB/s Benchmark___FanOut_128x1x100-16 360722 9723 ns/op 1505.87 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32151 112201 ns/op 1293.59 MB/s Benchmark__FanOut_128x10x100-16 31987 113083 ns/op 1283.49 MB/s Benchmark__FanOut_128x10x100-16 31736 112947 ns/op 1285.04 MB/s Benchmark__FanOut_128x10x100-16 32160 112581 ns/op 1289.22 MB/s Benchmark__FanOut_128x10x100-16 31684 112595 ns/op 1289.05 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4008 895068 ns/op 1631.32 MB/s Benchmark_FanOut_128x10x1000-16 3998 891529 ns/op 1637.79 MB/s Benchmark_FanOut_128x10x1000-16 3936 893918 ns/op 1633.42 MB/s Benchmark_FanOut_128x10x1000-16 3804 887892 ns/op 1644.50 MB/s Benchmark_FanOut_128x10x1000-16 3813 885686 ns/op 1648.60 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3478 1028282 ns/op 1410.26 MB/s Benchmark_FanOut_128x100x100-16 3424 1026802 ns/op 1412.29 MB/s Benchmark_FanOut_128x100x100-16 3436 1025029 ns/op 1414.73 MB/s Benchmark_FanOut_128x100x100-16 3415 1027286 ns/op 1411.62 MB/s Benchmark_FanOut_128x100x100-16 3433 1030565 ns/op 1407.13 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 375 9457620 ns/op 1543.74 MB/s BenchmarkFanOut_128x100x1000-16 375 9396009 ns/op 1553.87 MB/s BenchmarkFanOut_128x100x1000-16 384 9382539 ns/op 1556.10 MB/s BenchmarkFanOut_128x100x1000-16 380 9491910 ns/op 1538.17 MB/s BenchmarkFanOut_128x100x1000-16 382 9524250 ns/op 1532.94 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 366 9827220 ns/op 1495.86 MB/s BenchmarkFanOut_128x10x10000-16 369 9854898 ns/op 1491.66 MB/s BenchmarkFanOut_128x10x10000-16 366 9882096 ns/op 1487.55 MB/s BenchmarkFanOut_128x10x10000-16 368 9740101 ns/op 1509.24 MB/s BenchmarkFanOut_128x10x10000-16 367 9769084 ns/op 1504.76 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 668 5347748 ns/op 1355.74 MB/s BenchmarkFanOut__128x500x100-16 664 5342415 ns/op 1357.09 MB/s BenchmarkFanOut__128x500x100-16 664 5345001 ns/op 1356.43 MB/s BenchmarkFanOut__128x500x100-16 663 5350965 ns/op 1354.92 MB/s BenchmarkFanOut__128x500x100-16 676 5370459 ns/op 1350.00 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1903 1868552 ns/op 2831.35 MB/s Benchmark_FanOut_512x100x100-16 1917 1857334 ns/op 2848.45 MB/s Benchmark_FanOut_512x100x100-16 1897 1851859 ns/op 2856.87 MB/s Benchmark_FanOut_512x100x100-16 1918 1851651 ns/op 2857.19 MB/s Benchmark_FanOut_512x100x100-16 1912 1862188 ns/op 2841.03 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 216 16597485 ns/op 3193.29 MB/s Benchmark__FanOut_512x100x1k-16 211 16770629 ns/op 3160.32 MB/s Benchmark__FanOut_512x100x1k-16 214 16853610 ns/op 3144.76 MB/s Benchmark__FanOut_512x100x1k-16 213 16658671 ns/op 3181.56 MB/s Benchmark__FanOut_512x100x1k-16 212 16796436 ns/op 3155.46 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3078 1159332 ns/op 8997.46 MB/s Benchmark____FanOut_1kx10x1k-16 3122 1172765 ns/op 8894.40 MB/s Benchmark____FanOut_1kx10x1k-16 3177 1172254 ns/op 8898.28 MB/s Benchmark____FanOut_1kx10x1k-16 3205 1143981 ns/op 9118.19 MB/s Benchmark____FanOut_1kx10x1k-16 3099 1148313 ns/op 9083.80 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2751 1269020 ns/op 8211.88 MB/s Benchmark__FanOut_1kx100x100-16 2794 1266049 ns/op 8231.15 MB/s Benchmark__FanOut_1kx100x100-16 2787 1273519 ns/op 8182.87 MB/s Benchmark__FanOut_1kx100x100-16 2764 1273668 ns/op 8181.91 MB/s Benchmark__FanOut_1kx100x100-16 2782 1268369 ns/op 8216.09 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4316470 779.6 ns/op 319.41 MB/s Benchmark_____RFanOut_8x1x10-16 4484118 794.5 ns/op 313.41 MB/s Benchmark_____RFanOut_8x1x10-16 4385156 784.5 ns/op 317.39 MB/s Benchmark_____RFanOut_8x1x10-16 4542116 794.3 ns/op 313.49 MB/s Benchmark_____RFanOut_8x1x10-16 4419248 786.8 ns/op 316.46 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 543854 6203 ns/op 373.88 MB/s Benchmark____RFanOut_8x1x100-16 515491 6196 ns/op 374.28 MB/s Benchmark____RFanOut_8x1x100-16 490076 6305 ns/op 367.80 MB/s Benchmark____RFanOut_8x1x100-16 544183 6311 ns/op 367.44 MB/s Benchmark____RFanOut_8x1x100-16 538797 6254 ns/op 370.81 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46992 76751 ns/op 299.92 MB/s Benchmark___RFanOut_8x10x100-16 47401 76535 ns/op 300.76 MB/s Benchmark___RFanOut_8x10x100-16 46581 77299 ns/op 297.79 MB/s Benchmark___RFanOut_8x10x100-16 47100 76148 ns/op 302.29 MB/s Benchmark___RFanOut_8x10x100-16 47204 75465 ns/op 305.03 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5654 616153 ns/op 389.54 MB/s Benchmark__RFanOut_8x10x1000-16 5659 625221 ns/op 383.89 MB/s Benchmark__RFanOut_8x10x1000-16 5748 630191 ns/op 380.87 MB/s Benchmark__RFanOut_8x10x1000-16 5710 635354 ns/op 377.77 MB/s Benchmark__RFanOut_8x10x1000-16 5625 614909 ns/op 390.33 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4930 715435 ns/op 321.51 MB/s Benchmark__RFanOut_8x100x100-16 4818 726184 ns/op 316.75 MB/s Benchmark__RFanOut_8x100x100-16 4962 723036 ns/op 318.13 MB/s Benchmark__RFanOut_8x100x100-16 4988 716539 ns/op 321.01 MB/s Benchmark__RFanOut_8x100x100-16 4938 723482 ns/op 317.93 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 552 6461104 ns/op 371.46 MB/s Benchmark_RFanOut_8x100x1000-16 555 6306540 ns/op 380.56 MB/s Benchmark_RFanOut_8x100x1000-16 561 6407250 ns/op 374.58 MB/s Benchmark_RFanOut_8x100x1000-16 543 6682750 ns/op 359.14 MB/s Benchmark_RFanOut_8x100x1000-16 556 6340061 ns/op 378.55 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 516 6879700 ns/op 363.39 MB/s Benchmark_RFanOut_8x10x10000-16 524 6915316 ns/op 361.52 MB/s Benchmark_RFanOut_8x10x10000-16 506 6809555 ns/op 367.13 MB/s Benchmark_RFanOut_8x10x10000-16 528 6901516 ns/op 362.24 MB/s Benchmark_RFanOut_8x10x10000-16 528 6922156 ns/op 361.16 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2804 1144374 ns/op 9115.06 MB/s Benchmark_RFanOut_1kx10x1000-16 2781 1159389 ns/op 8997.01 MB/s Benchmark_RFanOut_1kx10x1000-16 3021 1138967 ns/op 9158.33 MB/s Benchmark_RFanOut_1kx10x1000-16 3082 1177156 ns/op 8861.22 MB/s Benchmark_RFanOut_1kx10x1000-16 2967 1162896 ns/op 8969.88 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7011580 505.7 ns/op 4109.38 MB/s Benchmark_____FanIn_1kx100x1-16 6923869 507.3 ns/op 4096.59 MB/s Benchmark_____FanIn_1kx100x1-16 6936102 504.8 ns/op 4116.59 MB/s Benchmark_____FanIn_1kx100x1-16 7003364 505.7 ns/op 4109.16 MB/s Benchmark_____FanIn_1kx100x1-16 6890242 505.9 ns/op 4107.43 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2667328 1396 ns/op 5890.79 MB/s Benchmark_____FanIn_4kx100x1-16 2558965 1368 ns/op 6010.31 MB/s Benchmark_____FanIn_4kx100x1-16 2626244 1351 ns/op 6083.78 MB/s Benchmark_____FanIn_4kx100x1-16 2605168 1382 ns/op 5949.51 MB/s Benchmark_____FanIn_4kx100x1-16 2609266 1369 ns/op 6005.97 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1693608 2134 ns/op 7692.50 MB/s Benchmark_____FanIn_8kx100x1-16 1679354 2124 ns/op 7727.44 MB/s Benchmark_____FanIn_8kx100x1-16 1684250 2122 ns/op 7735.76 MB/s Benchmark_____FanIn_8kx100x1-16 1709079 2134 ns/op 7689.89 MB/s Benchmark_____FanIn_8kx100x1-16 1711608 2122 ns/op 7736.74 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 868970 4177 ns/op 7852.82 MB/s Benchmark____FanIn_16kx100x1-16 874854 4138 ns/op 7925.91 MB/s Benchmark____FanIn_16kx100x1-16 864685 4156 ns/op 7892.90 MB/s Benchmark____FanIn_16kx100x1-16 862687 4116 ns/op 7968.22 MB/s Benchmark____FanIn_16kx100x1-16 864856 4146 ns/op 7911.40 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 124812912 vs 655530000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36514->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 160738 20099 ns/op 6522.82 MB/s Benchmark____FanIn_64kx100x1-16 168148 19814 ns/op 6616.82 MB/s Benchmark____FanIn_64kx100x1-16 165489 19924 ns/op 6580.10 MB/s Benchmark____FanIn_64kx100x1-16 163125 20155 ns/op 6504.94 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 288791270 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37002->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: 302162450 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38712->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: 991433670 vs 11352394000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40848->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: 1876028990 vs 11457266000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44380->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43626->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: 142757010 vs 11470375000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46332->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5540472 642.7 ns/op 441.87 MB/s Benchmark___BumpPubCount_1x3-16 5553324 647.8 ns/op 438.38 MB/s Benchmark___BumpPubCount_1x3-16 5614686 640.1 ns/op 443.66 MB/s Benchmark___BumpPubCount_1x3-16 5653852 644.6 ns/op 440.59 MB/s Benchmark___BumpPubCount_1x3-16 5576979 647.4 ns/op 438.68 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5366257 673.3 ns/op 421.80 MB/s Benchmark___BumpPubCount_2x3-16 5340008 671.2 ns/op 423.11 MB/s Benchmark___BumpPubCount_2x3-16 5368958 671.3 ns/op 423.09 MB/s Benchmark___BumpPubCount_2x3-16 5335075 670.4 ns/op 423.62 MB/s Benchmark___BumpPubCount_2x3-16 5289297 670.4 ns/op 423.62 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5574658 644.8 ns/op 440.47 MB/s Benchmark___BumpPubCount_5x3-16 5543217 645.6 ns/op 439.89 MB/s Benchmark___BumpPubCount_5x3-16 5216505 646.4 ns/op 439.35 MB/s Benchmark___BumpPubCount_5x3-16 5174132 646.4 ns/op 439.36 MB/s Benchmark___BumpPubCount_5x3-16 5568464 661.4 ns/op 429.40 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5537470 650.9 ns/op 436.30 MB/s Benchmark__BumpPubCount_10x3-16 5550241 647.1 ns/op 438.90 MB/s Benchmark__BumpPubCount_10x3-16 5553272 649.8 ns/op 437.04 MB/s Benchmark__BumpPubCount_10x3-16 5556646 647.6 ns/op 438.55 MB/s Benchmark__BumpPubCount_10x3-16 5546242 649.2 ns/op 437.47 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12556310 277.9 ns/op 3741.75 MB/s Benchmark____GWs_Opt_1kx01x0-16 13081135 271.7 ns/op 3827.78 MB/s Benchmark____GWs_Opt_1kx01x0-16 12398349 279.0 ns/op 3728.17 MB/s Benchmark____GWs_Opt_1kx01x0-16 12617355 282.8 ns/op 3677.06 MB/s Benchmark____GWs_Opt_1kx01x0-16 12448992 280.0 ns/op 3714.15 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10053777 341.9 ns/op 6037.05 MB/s Benchmark____GWs_Opt_2kx01x0-16 10658329 333.2 ns/op 6195.10 MB/s Benchmark____GWs_Opt_2kx01x0-16 10413289 342.5 ns/op 6027.12 MB/s Benchmark____GWs_Opt_2kx01x0-16 10370190 334.0 ns/op 6179.31 MB/s Benchmark____GWs_Opt_2kx01x0-16 10278763 332.4 ns/op 6209.28 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5292020 640.0 ns/op 6425.43 MB/s Benchmark____GWs_Opt_4kx01x0-16 5818682 600.8 ns/op 6844.41 MB/s Benchmark____GWs_Opt_4kx01x0-16 5777067 627.1 ns/op 6556.84 MB/s Benchmark____GWs_Opt_4kx01x0-16 5845010 612.5 ns/op 6713.47 MB/s Benchmark____GWs_Opt_4kx01x0-16 5912224 611.9 ns/op 6719.95 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29034990 107.2 ns/op 9702.81 MB/s Benchmark____GWs_Opt_1kx10x0-16 28651053 107.5 ns/op 9671.29 MB/s Benchmark____GWs_Opt_1kx10x0-16 30739142 110.7 ns/op 9397.77 MB/s Benchmark____GWs_Opt_1kx10x0-16 30605784 108.1 ns/op 9619.37 MB/s Benchmark____GWs_Opt_1kx10x0-16 27665984 113.2 ns/op 9189.09 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25213390 159.6 ns/op 12935.60 MB/s Benchmark____GWs_Opt_2kx10x0-16 21628902 143.1 ns/op 14425.12 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:60916->127.0.0.1:46699: 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:55168->127.0.0.1:38655: use of closed network connection --- FAIL: Benchmark____GWs_Opt_2kx10x0-16 Benchmark____GWs_Opt_2kx10x0-16 24122308 148.7 ns/op 13877.36 MB/s Benchmark____GWs_Opt_2kx10x0-16 23559426 154.7 ns/op 13343.26 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11036366 337.1 ns/op 12198.92 MB/s Benchmark____GWs_Opt_4kx10x0-16 12106444 289.5 ns/op 14202.82 MB/s Benchmark____GWs_Opt_4kx10x0-16 11128683 290.2 ns/op 14168.08 MB/s Benchmark____GWs_Opt_4kx10x0-16 11495796 297.6 ns/op 13816.94 MB/s Benchmark____GWs_Opt_4kx10x0-16 12656940 327.2 ns/op 12565.97 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6544232 547.6 ns/op 5707.03 MB/s Benchmark____GWs_Opt_1kx01x1-16 6243177 551.6 ns/op 5664.86 MB/s Benchmark____GWs_Opt_1kx01x1-16 6442147 564.9 ns/op 5531.74 MB/s Benchmark____GWs_Opt_1kx01x1-16 6545887 569.4 ns/op 5488.09 MB/s Benchmark____GWs_Opt_1kx01x1-16 6444409 555.0 ns/op 5630.71 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4553884 765.0 ns/op 8100.44 MB/s Benchmark____GWs_Opt_2kx01x1-16 4507934 787.6 ns/op 7867.97 MB/s Benchmark____GWs_Opt_2kx01x1-16 4626843 770.8 ns/op 8039.56 MB/s Benchmark____GWs_Opt_2kx01x1-16 4598857 765.5 ns/op 8094.91 MB/s Benchmark____GWs_Opt_2kx01x1-16 4680889 770.0 ns/op 8048.07 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2634580 1378 ns/op 8955.10 MB/s Benchmark____GWs_Opt_4kx01x1-16 2572178 1389 ns/op 8885.00 MB/s Benchmark____GWs_Opt_4kx01x1-16 2555220 1459 ns/op 8460.96 MB/s Benchmark____GWs_Opt_4kx01x1-16 2608192 1815 ns/op 6801.26 MB/s Benchmark____GWs_Opt_4kx01x1-16 2630288 1356 ns/op 9103.99 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6139218 560.3 ns/op 5577.60 MB/s Benchmark____GWs_Opt_1kx10x1-16 6070056 561.9 ns/op 5561.08 MB/s Benchmark____GWs_Opt_1kx10x1-16 6091273 574.4 ns/op 5440.61 MB/s Benchmark____GWs_Opt_1kx10x1-16 6073518 557.4 ns/op 5606.40 MB/s Benchmark____GWs_Opt_1kx10x1-16 5809401 562.2 ns/op 5558.59 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 3993259 851.6 ns/op 7276.77 MB/s Benchmark____GWs_Opt_2kx10x1-16 4160246 843.8 ns/op 7344.48 MB/s Benchmark____GWs_Opt_2kx10x1-16 4095706 876.3 ns/op 7072.17 MB/s Benchmark____GWs_Opt_2kx10x1-16 4168848 852.5 ns/op 7269.54 MB/s Benchmark____GWs_Opt_2kx10x1-16 4192761 853.2 ns/op 7262.93 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2279150 1519 ns/op 8122.88 MB/s Benchmark____GWs_Opt_4kx10x1-16 2316997 1502 ns/op 8218.02 MB/s Benchmark____GWs_Opt_4kx10x1-16 2363275 1552 ns/op 7950.55 MB/s Benchmark____GWs_Opt_4kx10x1-16 2356526 1526 ns/op 8086.88 MB/s Benchmark____GWs_Opt_4kx10x1-16 2367277 1540 ns/op 8011.80 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12404422 284.2 ns/op 3659.98 MB/s Benchmark____GWs_Int_1kx01x0-16 12681234 283.5 ns/op 3668.25 MB/s Benchmark____GWs_Int_1kx01x0-16 12580306 288.2 ns/op 3608.13 MB/s Benchmark____GWs_Int_1kx01x0-16 12545044 283.1 ns/op 3673.10 MB/s Benchmark____GWs_Int_1kx01x0-16 12355714 292.3 ns/op 3558.13 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9496288 361.4 ns/op 5711.49 MB/s Benchmark____GWs_Int_2kx01x0-16 9015507 360.8 ns/op 5721.35 MB/s Benchmark____GWs_Int_2kx01x0-16 10155261 363.3 ns/op 5680.51 MB/s Benchmark____GWs_Int_2kx01x0-16 10410439 364.8 ns/op 5657.28 MB/s Benchmark____GWs_Int_2kx01x0-16 10048022 351.7 ns/op 5868.07 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5755874 634.1 ns/op 6484.32 MB/s Benchmark____GWs_Int_4kx01x0-16 5685154 633.6 ns/op 6490.07 MB/s Benchmark____GWs_Int_4kx01x0-16 5817969 628.1 ns/op 6547.04 MB/s Benchmark____GWs_Int_4kx01x0-16 5797849 677.3 ns/op 6071.15 MB/s Benchmark____GWs_Int_4kx01x0-16 5109217 634.7 ns/op 6478.43 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31624929 107.1 ns/op 9710.24 MB/s Benchmark____GWs_Int_1kx10x0-16 30174958 109.6 ns/op 9492.24 MB/s Benchmark____GWs_Int_1kx10x0-16 32452879 113.4 ns/op 9173.32 MB/s Benchmark____GWs_Int_1kx10x0-16 28891488 111.4 ns/op 9332.42 MB/s Benchmark____GWs_Int_1kx10x0-16 28367467 114.7 ns/op 9065.79 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25804171 156.5 ns/op 13184.40 MB/s Benchmark____GWs_Int_2kx10x0-16 26124954 142.4 ns/op 14493.18 MB/s Benchmark____GWs_Int_2kx10x0-16 24849048 142.9 ns/op 14443.68 MB/s Benchmark____GWs_Int_2kx10x0-16 24616978 150.0 ns/op 13761.72 MB/s Benchmark____GWs_Int_2kx10x0-16 25420494 156.4 ns/op 13194.62 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13271941 281.9 ns/op 14587.34 MB/s Benchmark____GWs_Int_4kx10x0-16 12678832 309.2 ns/op 13299.52 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:54680->127.0.0.1:40243: 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:44750->127.0.0.1:42553: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 11686513 281.7 ns/op 14598.61 MB/s Benchmark____GWs_Int_4kx10x0-16 13192458 343.9 ns/op 11957.90 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6397834 561.5 ns/op 5565.39 MB/s Benchmark____GWs_Int_1kx01x1-16 6275628 559.0 ns/op 5590.51 MB/s Benchmark____GWs_Int_1kx01x1-16 6358358 563.2 ns/op 5549.05 MB/s Benchmark____GWs_Int_1kx01x1-16 6509274 559.7 ns/op 5583.46 MB/s Benchmark____GWs_Int_1kx01x1-16 6160656 562.5 ns/op 5555.22 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4609038 771.8 ns/op 8029.09 MB/s Benchmark____GWs_Int_2kx01x1-16 4712143 1041 ns/op 5953.95 MB/s Benchmark____GWs_Int_2kx01x1-16 4600550 776.4 ns/op 7982.10 MB/s Benchmark____GWs_Int_2kx01x1-16 4659518 773.7 ns/op 8009.33 MB/s Benchmark____GWs_Int_2kx01x1-16 4449147 773.5 ns/op 8011.53 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2591521 1400 ns/op 8815.19 MB/s Benchmark____GWs_Int_4kx01x1-16 2578353 1394 ns/op 8850.21 MB/s Benchmark____GWs_Int_4kx01x1-16 2609691 1361 ns/op 9070.57 MB/s Benchmark____GWs_Int_4kx01x1-16 2600055 1382 ns/op 8929.70 MB/s Benchmark____GWs_Int_4kx01x1-16 2679273 1533 ns/op 8052.36 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6016452 561.0 ns/op 5570.14 MB/s Benchmark____GWs_Int_1kx10x1-16 5958051 562.4 ns/op 5556.76 MB/s Benchmark____GWs_Int_1kx10x1-16 6137808 560.9 ns/op 5571.19 MB/s Benchmark____GWs_Int_1kx10x1-16 6305061 566.2 ns/op 5518.85 MB/s Benchmark____GWs_Int_1kx10x1-16 6700758 566.3 ns/op 5518.17 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4085282 853.3 ns/op 7262.14 MB/s Benchmark____GWs_Int_2kx10x1-16 4179789 851.9 ns/op 7274.72 MB/s Benchmark____GWs_Int_2kx10x1-16 4100072 884.4 ns/op 7006.86 MB/s Benchmark____GWs_Int_2kx10x1-16 4184937 859.6 ns/op 7209.09 MB/s Benchmark____GWs_Int_2kx10x1-16 4236088 882.1 ns/op 7024.90 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2395542 1492 ns/op 8273.90 MB/s Benchmark____GWs_Int_4kx10x1-16 2226855 1533 ns/op 8052.70 MB/s Benchmark____GWs_Int_4kx10x1-16 2303024 1522 ns/op 8107.07 MB/s Benchmark____GWs_Int_4kx10x1-16 2369038 1550 ns/op 7961.64 MB/s Benchmark____GWs_Int_4kx10x1-16 2252972 1535 ns/op 8040.64 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8084428 439.7 ns/op 231.98 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8025320 434.2 ns/op 234.93 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8398449 440.1 ns/op 231.78 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8257374 433.6 ns/op 235.26 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8171457 443.6 ns/op 229.94 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 719642 5089 ns/op 34.78 MB/s Benchmark__GWs_Reqs_1SubEach-16 716529 5262 ns/op 33.64 MB/s Benchmark__GWs_Reqs_1SubEach-16 730159 5352 ns/op 33.07 MB/s Benchmark__GWs_Reqs_1SubEach-16 758121 5425 ns/op 32.62 MB/s Benchmark__GWs_Reqs_1SubEach-16 715233 5214 ns/op 33.95 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2140.777s ❌ Non-zero exit code: 1