> ROOT_DIR=/tmp/go-bench-away-job-4cfd17df-bd40-4963-91d7-2582b62b0051-1870914265 > OUTPUT_FILE=/tmp/go-bench-away-job-4cfd17df-bd40-4963-91d7-2582b62b0051-1870914265/results.txt > SHA_FILE=/tmp/go-bench-away-job-4cfd17df-bd40-4963-91d7-2582b62b0051-1870914265/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-4cfd17df-bd40-4963-91d7-2582b62b0051-1870914265/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=v2.12.5 > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.25.4/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: v2.12.5 to /tmp/go-bench-away-job-4cfd17df-bd40-4963-91d7-2582b62b0051-1870914265/source.git SHA of v2.12.5: fe6536e9fe2bc251b69149fb333a47c4f1af8824 Go runtime: go version go1.26.0 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build1600610281=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-4cfd17df-bd40-4963-91d7-2582b62b0051-1870914265/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.25.4' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.25.4/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.0' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 54423560 67.48 ns/op 163.01 MB/s Benchmark______Pub0b_Payload-16 52158718 65.64 ns/op 167.57 MB/s Benchmark______Pub0b_Payload-16 51877318 65.59 ns/op 167.70 MB/s Benchmark______Pub0b_Payload-16 51959820 65.72 ns/op 167.38 MB/s Benchmark______Pub0b_Payload-16 51745659 65.74 ns/op 167.33 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 51106332 66.38 ns/op 286.22 MB/s Benchmark______Pub8b_Payload-16 47776502 66.30 ns/op 286.56 MB/s Benchmark______Pub8b_Payload-16 50712847 66.45 ns/op 285.93 MB/s Benchmark______Pub8b_Payload-16 50826673 66.36 ns/op 286.30 MB/s Benchmark______Pub8b_Payload-16 51114598 66.16 ns/op 287.18 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 47594520 71.30 ns/op 617.07 MB/s Benchmark_____Pub32b_Payload-16 44952600 71.78 ns/op 612.95 MB/s Benchmark_____Pub32b_Payload-16 45327862 71.53 ns/op 615.10 MB/s Benchmark_____Pub32b_Payload-16 49971387 72.02 ns/op 610.91 MB/s Benchmark_____Pub32b_Payload-16 47552700 71.58 ns/op 614.70 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 44746436 81.27 ns/op 1734.98 MB/s Benchmark____Pub128B_Payload-16 41986222 83.65 ns/op 1685.52 MB/s Benchmark____Pub128B_Payload-16 42585903 81.25 ns/op 1735.38 MB/s Benchmark____Pub128B_Payload-16 43525987 80.90 ns/op 1742.93 MB/s Benchmark____Pub128B_Payload-16 44515564 80.95 ns/op 1741.88 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 38414594 90.73 ns/op 2964.78 MB/s Benchmark____Pub256B_Payload-16 34758333 87.91 ns/op 3059.94 MB/s Benchmark____Pub256B_Payload-16 38357467 87.14 ns/op 3087.04 MB/s Benchmark____Pub256B_Payload-16 38544344 91.71 ns/op 2933.27 MB/s Benchmark____Pub256B_Payload-16 33377203 91.76 ns/op 2931.71 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24490765 143.7 ns/op 7223.16 MB/s Benchmark______Pub1K_Payload-16 24226807 132.5 ns/op 7833.04 MB/s Benchmark______Pub1K_Payload-16 25559360 143.9 ns/op 7213.82 MB/s Benchmark______Pub1K_Payload-16 25123210 139.1 ns/op 7461.72 MB/s Benchmark______Pub1K_Payload-16 21817327 143.8 ns/op 7216.53 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5478957 615.4 ns/op 6678.21 MB/s Benchmark______Pub4K_Payload-16 5768772 627.2 ns/op 6552.50 MB/s Benchmark______Pub4K_Payload-16 5443287 627.9 ns/op 6545.30 MB/s Benchmark______Pub4K_Payload-16 5474437 632.1 ns/op 6502.21 MB/s Benchmark______Pub4K_Payload-16 5675484 621.7 ns/op 6610.90 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2769364 1290 ns/op 6360.96 MB/s Benchmark______Pub8K_Payload-16 2777246 1281 ns/op 6404.09 MB/s Benchmark______Pub8K_Payload-16 2648988 1268 ns/op 6470.44 MB/s Benchmark______Pub8K_Payload-16 2781972 1271 ns/op 6456.75 MB/s Benchmark______Pub8K_Payload-16 2801900 1301 ns/op 6306.42 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 512984 6093 ns/op 5380.66 MB/s Benchmark_____Pub32K_Payload-16 663310 5306 ns/op 6178.68 MB/s Benchmark_____Pub32K_Payload-16 652869 5422 ns/op 6046.49 MB/s Benchmark_____Pub32K_Payload-16 654877 6117 ns/op 5359.17 MB/s Benchmark_____Pub32K_Payload-16 663430 5306 ns/op 6178.22 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 34090716 88.76 ns/op 123.92 MB/s Benchmark__AuthPub0b_Payload-16 38539615 89.07 ns/op 123.50 MB/s Benchmark__AuthPub0b_Payload-16 36877915 89.22 ns/op 123.29 MB/s Benchmark__AuthPub0b_Payload-16 38886907 88.37 ns/op 124.47 MB/s Benchmark__AuthPub0b_Payload-16 34315072 88.55 ns/op 124.23 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 16988676 209.0 ns/op Benchmark_____________PubSub-16 16905430 208.7 ns/op Benchmark_____________PubSub-16 16618977 208.6 ns/op Benchmark_____________PubSub-16 16953091 207.8 ns/op Benchmark_____________PubSub-16 16697774 210.0 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 17064778 208.1 ns/op Benchmark_____PubSubTwoConns-16 16803771 207.9 ns/op Benchmark_____PubSubTwoConns-16 17052592 208.0 ns/op Benchmark_____PubSubTwoConns-16 16846531 207.9 ns/op Benchmark_____PubSubTwoConns-16 17119906 207.8 ns/op Benchmark__PubServiceImports bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:47114->127.0.0.1:41505: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:40208->127.0.0.1:46641: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:38450->127.0.0.1:44025: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:45666->127.0.0.1:41965: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:38206->127.0.0.1:38629: 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 15656200 227.2 ns/op Benchmark_____PubTwoQueueSub-16 15542258 227.5 ns/op Benchmark_____PubTwoQueueSub-16 15513972 228.2 ns/op Benchmark_____PubTwoQueueSub-16 15618934 227.4 ns/op Benchmark_____PubTwoQueueSub-16 15519582 227.6 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15707008 227.9 ns/op Benchmark____PubFourQueueSub-16 15723525 227.3 ns/op Benchmark____PubFourQueueSub-16 15715300 228.0 ns/op Benchmark____PubFourQueueSub-16 15827863 228.4 ns/op Benchmark____PubFourQueueSub-16 15613676 227.3 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15676574 226.2 ns/op Benchmark___PubEightQueueSub-16 15611882 226.1 ns/op Benchmark___PubEightQueueSub-16 15543861 226.4 ns/op Benchmark___PubEightQueueSub-16 15593539 227.3 ns/op Benchmark___PubEightQueueSub-16 15675271 227.5 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23197 154846 ns/op Benchmark_PubSub512kTwoConns-16 23112 155693 ns/op Benchmark_PubSub512kTwoConns-16 23161 154823 ns/op Benchmark_PubSub512kTwoConns-16 23089 155303 ns/op Benchmark_PubSub512kTwoConns-16 23215 155652 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16606017 210.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 16741070 211.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 16347855 211.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 16562319 211.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 16679012 210.6 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16617602 211.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 16307145 210.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 16596283 210.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 16503088 211.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 16548169 212.0 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11603211 299.6 ns/op Benchmark____RoutedPubSub_0b-16 12156711 296.1 ns/op Benchmark____RoutedPubSub_0b-16 11855145 299.0 ns/op Benchmark____RoutedPubSub_0b-16 11917298 298.8 ns/op Benchmark____RoutedPubSub_0b-16 12003097 296.5 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6879639 516.5 ns/op Benchmark____RoutedPubSub_1K-16 6797346 528.3 ns/op Benchmark____RoutedPubSub_1K-16 6903496 493.3 ns/op Benchmark____RoutedPubSub_1K-16 6987397 518.4 ns/op Benchmark____RoutedPubSub_1K-16 6741756 519.4 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85203 43009 ns/op Benchmark__RoutedPubSub_100K-16 85172 42923 ns/op Benchmark__RoutedPubSub_100K-16 78015 45127 ns/op Benchmark__RoutedPubSub_100K-16 78458 46199 ns/op Benchmark__RoutedPubSub_100K-16 86721 42210 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 10284261 307.7 ns/op Benchmark____Routed2QueueSub-16 12238764 292.0 ns/op Benchmark____Routed2QueueSub-16 10189884 302.8 ns/op Benchmark____Routed2QueueSub-16 10090681 300.5 ns/op Benchmark____Routed2QueueSub-16 10264152 301.5 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9942297 305.0 ns/op Benchmark____Routed4QueueSub-16 10076828 299.1 ns/op Benchmark____Routed4QueueSub-16 9933643 306.8 ns/op Benchmark____Routed4QueueSub-16 11985250 301.3 ns/op Benchmark____Routed4QueueSub-16 10264263 300.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 11846034 303.1 ns/op Benchmark____Routed8QueueSub-16 9753168 308.3 ns/op Benchmark____Routed8QueueSub-16 11783262 310.5 ns/op Benchmark____Routed8QueueSub-16 11930617 309.9 ns/op Benchmark____Routed8QueueSub-16 11590801 302.9 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 11155988 324.2 ns/op Benchmark___Routed16QueueSub-16 9242786 328.5 ns/op Benchmark___Routed16QueueSub-16 9367560 327.1 ns/op Benchmark___Routed16QueueSub-16 9419344 326.8 ns/op Benchmark___Routed16QueueSub-16 11003816 326.8 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6714606 473.6 ns/op Benchmark____________RouteCompressOff-16 6700527 528.8 ns/op Benchmark____________RouteCompressOff-16 6490464 465.3 ns/op Benchmark____________RouteCompressOff-16 6734930 526.1 ns/op Benchmark____________RouteCompressOff-16 6708304 476.9 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6813793 529.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6654344 534.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6668115 455.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6537016 539.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6557736 525.6 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6630104 476.0 ns/op Benchmark_________RouteCompressS2Fast-16 6725022 531.0 ns/op Benchmark_________RouteCompressS2Fast-16 6704516 530.0 ns/op Benchmark_________RouteCompressS2Fast-16 6624877 524.4 ns/op Benchmark_________RouteCompressS2Fast-16 6699447 528.5 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 8061817 526.5 ns/op Benchmark_______RouteCompressS2Better-16 6790569 527.9 ns/op Benchmark_______RouteCompressS2Better-16 6667758 530.8 ns/op Benchmark_______RouteCompressS2Better-16 6682773 485.1 ns/op Benchmark_______RouteCompressS2Better-16 6569907 463.4 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 8147084 529.5 ns/op Benchmark_________RouteCompressS2Best-16 8123900 443.1 ns/op Benchmark_________RouteCompressS2Best-16 6837518 528.4 ns/op Benchmark_________RouteCompressS2Best-16 6540913 530.5 ns/op Benchmark_________RouteCompressS2Best-16 6711896 529.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5203431 683.8 ns/op 364.15 MB/s Benchmark______FanOut_8x1x10-16 5167040 686.1 ns/op 362.94 MB/s Benchmark______FanOut_8x1x10-16 5226799 688.6 ns/op 361.61 MB/s Benchmark______FanOut_8x1x10-16 5217706 685.8 ns/op 363.10 MB/s Benchmark______FanOut_8x1x10-16 5245461 685.4 ns/op 363.30 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 610393 5329 ns/op 435.15 MB/s Benchmark_____FanOut_8x1x100-16 631939 5299 ns/op 437.61 MB/s Benchmark_____FanOut_8x1x100-16 640467 5350 ns/op 433.44 MB/s Benchmark_____FanOut_8x1x100-16 625194 5323 ns/op 435.65 MB/s Benchmark_____FanOut_8x1x100-16 623862 5355 ns/op 433.06 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 52706 68005 ns/op 338.49 MB/s Benchmark____FanOut_8x10x100-16 53163 67590 ns/op 340.57 MB/s Benchmark____FanOut_8x10x100-16 52947 67811 ns/op 339.46 MB/s Benchmark____FanOut_8x10x100-16 53072 67736 ns/op 339.83 MB/s Benchmark____FanOut_8x10x100-16 52305 67725 ns/op 339.89 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6692 532118 ns/op 451.06 MB/s Benchmark___FanOut_8x10x1000-16 6782 535048 ns/op 448.59 MB/s Benchmark___FanOut_8x10x1000-16 6412 531016 ns/op 452.00 MB/s Benchmark___FanOut_8x10x1000-16 6670 532053 ns/op 451.12 MB/s Benchmark___FanOut_8x10x1000-16 6858 538200 ns/op 445.97 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5506 634051 ns/op 362.78 MB/s Benchmark___FanOut_8x100x100-16 5474 632827 ns/op 363.48 MB/s Benchmark___FanOut_8x100x100-16 5547 631041 ns/op 364.51 MB/s Benchmark___FanOut_8x100x100-16 5568 633963 ns/op 362.83 MB/s Benchmark___FanOut_8x100x100-16 5571 636542 ns/op 361.36 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 657 5493166 ns/op 436.91 MB/s Benchmark__FanOut_8x100x1000-16 627 5482264 ns/op 437.78 MB/s Benchmark__FanOut_8x100x1000-16 630 5423053 ns/op 442.56 MB/s Benchmark__FanOut_8x100x1000-16 668 5570060 ns/op 430.88 MB/s Benchmark__FanOut_8x100x1000-16 649 5651254 ns/op 424.69 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 613 5929394 ns/op 421.63 MB/s Benchmark__FanOut_8x10x10000-16 620 5852236 ns/op 427.19 MB/s Benchmark__FanOut_8x10x10000-16 606 5826148 ns/op 429.10 MB/s Benchmark__FanOut_8x10x10000-16 612 5808950 ns/op 430.37 MB/s Benchmark__FanOut_8x10x10000-16 583 5894110 ns/op 424.16 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1047 3374122 ns/op 340.84 MB/s Benchmark___FanOut_8x500x100-16 1033 3381630 ns/op 340.08 MB/s Benchmark___FanOut_8x500x100-16 1050 3387398 ns/op 339.50 MB/s Benchmark___FanOut_8x500x100-16 1045 3382461 ns/op 339.99 MB/s Benchmark___FanOut_8x500x100-16 1045 3393597 ns/op 338.88 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 387835 8795 ns/op 1664.66 MB/s Benchmark___FanOut_128x1x100-16 397834 8827 ns/op 1658.69 MB/s Benchmark___FanOut_128x1x100-16 392733 8821 ns/op 1659.74 MB/s Benchmark___FanOut_128x1x100-16 391748 8867 ns/op 1651.18 MB/s Benchmark___FanOut_128x1x100-16 391682 8795 ns/op 1664.70 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 34904 102948 ns/op 1409.85 MB/s Benchmark__FanOut_128x10x100-16 34944 101925 ns/op 1424.00 MB/s Benchmark__FanOut_128x10x100-16 35264 102373 ns/op 1417.76 MB/s Benchmark__FanOut_128x10x100-16 35022 102515 ns/op 1415.80 MB/s Benchmark__FanOut_128x10x100-16 35036 102934 ns/op 1410.03 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4413 786972 ns/op 1855.39 MB/s Benchmark_FanOut_128x10x1000-16 4518 795344 ns/op 1835.86 MB/s Benchmark_FanOut_128x10x1000-16 4392 796242 ns/op 1833.79 MB/s Benchmark_FanOut_128x10x1000-16 4491 792546 ns/op 1842.34 MB/s Benchmark_FanOut_128x10x1000-16 4329 799340 ns/op 1826.68 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3712 938541 ns/op 1545.10 MB/s Benchmark_FanOut_128x100x100-16 3723 938032 ns/op 1545.94 MB/s Benchmark_FanOut_128x100x100-16 3759 939667 ns/op 1543.25 MB/s Benchmark_FanOut_128x100x100-16 3735 941517 ns/op 1540.22 MB/s Benchmark_FanOut_128x100x100-16 3822 942947 ns/op 1537.88 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 414 8462434 ns/op 1725.29 MB/s BenchmarkFanOut_128x100x1000-16 422 8456537 ns/op 1726.49 MB/s BenchmarkFanOut_128x100x1000-16 421 8463981 ns/op 1724.97 MB/s BenchmarkFanOut_128x100x1000-16 421 8393569 ns/op 1739.44 MB/s BenchmarkFanOut_128x100x1000-16 418 8525757 ns/op 1712.47 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 405 8748957 ns/op 1680.22 MB/s BenchmarkFanOut_128x10x10000-16 410 8784988 ns/op 1673.33 MB/s BenchmarkFanOut_128x10x10000-16 409 8829247 ns/op 1664.94 MB/s BenchmarkFanOut_128x10x10000-16 412 8776127 ns/op 1675.01 MB/s BenchmarkFanOut_128x10x10000-16 404 8870205 ns/op 1657.25 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 706 4969774 ns/op 1458.85 MB/s BenchmarkFanOut__128x500x100-16 714 4927178 ns/op 1471.46 MB/s BenchmarkFanOut__128x500x100-16 723 4990572 ns/op 1452.77 MB/s BenchmarkFanOut__128x500x100-16 712 4957147 ns/op 1462.56 MB/s BenchmarkFanOut__128x500x100-16 710 4938900 ns/op 1467.97 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1980 1752750 ns/op 3018.41 MB/s Benchmark_FanOut_512x100x100-16 2013 1750021 ns/op 3023.12 MB/s Benchmark_FanOut_512x100x100-16 2014 1772700 ns/op 2984.45 MB/s Benchmark_FanOut_512x100x100-16 1986 1762388 ns/op 3001.91 MB/s Benchmark_FanOut_512x100x100-16 2007 1760282 ns/op 3005.50 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 224 16043178 ns/op 3303.62 MB/s Benchmark__FanOut_512x100x1k-16 223 16121992 ns/op 3287.47 MB/s Benchmark__FanOut_512x100x1k-16 222 16174917 ns/op 3276.71 MB/s Benchmark__FanOut_512x100x1k-16 222 16094842 ns/op 3293.01 MB/s Benchmark__FanOut_512x100x1k-16 223 16011718 ns/op 3310.11 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3252 1118468 ns/op 9326.18 MB/s Benchmark____FanOut_1kx10x1k-16 2968 1094121 ns/op 9533.72 MB/s Benchmark____FanOut_1kx10x1k-16 3302 1112162 ns/op 9379.06 MB/s Benchmark____FanOut_1kx10x1k-16 3429 1114254 ns/op 9361.46 MB/s Benchmark____FanOut_1kx10x1k-16 2920 1093455 ns/op 9539.52 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2992 1190016 ns/op 8757.05 MB/s Benchmark__FanOut_1kx100x100-16 2911 1195425 ns/op 8717.43 MB/s Benchmark__FanOut_1kx100x100-16 2932 1196351 ns/op 8710.68 MB/s Benchmark__FanOut_1kx100x100-16 2928 1189307 ns/op 8762.28 MB/s Benchmark__FanOut_1kx100x100-16 3014 1190821 ns/op 8751.13 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 5028614 791.3 ns/op 314.66 MB/s Benchmark_____RFanOut_8x1x10-16 4901204 702.9 ns/op 354.27 MB/s Benchmark_____RFanOut_8x1x10-16 5040687 691.3 ns/op 360.22 MB/s Benchmark_____RFanOut_8x1x10-16 5051864 701.7 ns/op 354.85 MB/s Benchmark_____RFanOut_8x1x10-16 5004723 692.4 ns/op 359.63 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 587799 5405 ns/op 429.01 MB/s Benchmark____RFanOut_8x1x100-16 603657 5314 ns/op 436.43 MB/s Benchmark____RFanOut_8x1x100-16 591727 5358 ns/op 432.84 MB/s Benchmark____RFanOut_8x1x100-16 616543 5331 ns/op 435.01 MB/s Benchmark____RFanOut_8x1x100-16 604836 5337 ns/op 434.55 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 52713 67666 ns/op 340.19 MB/s Benchmark___RFanOut_8x10x100-16 52894 67623 ns/op 340.40 MB/s Benchmark___RFanOut_8x10x100-16 52694 69254 ns/op 332.39 MB/s Benchmark___RFanOut_8x10x100-16 52726 67751 ns/op 339.76 MB/s Benchmark___RFanOut_8x10x100-16 53084 67946 ns/op 338.79 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6774 533697 ns/op 449.73 MB/s Benchmark__RFanOut_8x10x1000-16 6560 535325 ns/op 448.36 MB/s Benchmark__RFanOut_8x10x1000-16 6778 539080 ns/op 445.24 MB/s Benchmark__RFanOut_8x10x1000-16 6859 537257 ns/op 446.75 MB/s Benchmark__RFanOut_8x10x1000-16 6800 534891 ns/op 448.72 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5545 633587 ns/op 363.04 MB/s Benchmark__RFanOut_8x100x100-16 5546 630711 ns/op 364.70 MB/s Benchmark__RFanOut_8x100x100-16 5584 632615 ns/op 363.60 MB/s Benchmark__RFanOut_8x100x100-16 5586 631737 ns/op 364.11 MB/s Benchmark__RFanOut_8x100x100-16 5499 632998 ns/op 363.38 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 650 5525875 ns/op 434.32 MB/s Benchmark_RFanOut_8x100x1000-16 636 5641040 ns/op 425.46 MB/s Benchmark_RFanOut_8x100x1000-16 664 5510313 ns/op 435.55 MB/s Benchmark_RFanOut_8x100x1000-16 636 5529828 ns/op 434.01 MB/s Benchmark_RFanOut_8x100x1000-16 634 5561712 ns/op 431.53 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 606 5831437 ns/op 428.71 MB/s Benchmark_RFanOut_8x10x10000-16 602 5857047 ns/op 426.84 MB/s Benchmark_RFanOut_8x10x10000-16 597 5888318 ns/op 424.57 MB/s Benchmark_RFanOut_8x10x10000-16 590 5913257 ns/op 422.78 MB/s Benchmark_RFanOut_8x10x10000-16 596 6048610 ns/op 413.32 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3306 1098249 ns/op 9497.88 MB/s Benchmark_RFanOut_1kx10x1000-16 3412 1081363 ns/op 9646.19 MB/s Benchmark_RFanOut_1kx10x1000-16 3056 1100811 ns/op 9475.78 MB/s Benchmark_RFanOut_1kx10x1000-16 3211 1099564 ns/op 9486.52 MB/s Benchmark_RFanOut_1kx10x1000-16 3038 1103867 ns/op 9449.55 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7208817 491.0 ns/op 4232.30 MB/s Benchmark_____FanIn_1kx100x1-16 7193479 487.5 ns/op 4262.24 MB/s Benchmark_____FanIn_1kx100x1-16 7151091 488.0 ns/op 4257.85 MB/s Benchmark_____FanIn_1kx100x1-16 7243489 487.1 ns/op 4265.84 MB/s Benchmark_____FanIn_1kx100x1-16 7217379 486.1 ns/op 4275.13 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2716584 1349 ns/op 6094.02 MB/s Benchmark_____FanIn_4kx100x1-16 2682774 1337 ns/op 6148.93 MB/s Benchmark_____FanIn_4kx100x1-16 2612715 1341 ns/op 6132.04 MB/s Benchmark_____FanIn_4kx100x1-16 2708600 1328 ns/op 6189.56 MB/s Benchmark_____FanIn_4kx100x1-16 2610147 1332 ns/op 6171.24 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1735282 2075 ns/op 7909.28 MB/s Benchmark_____FanIn_8kx100x1-16 1769059 2058 ns/op 7976.65 MB/s Benchmark_____FanIn_8kx100x1-16 1711588 2098 ns/op 7824.88 MB/s Benchmark_____FanIn_8kx100x1-16 1721964 2082 ns/op 7882.79 MB/s Benchmark_____FanIn_8kx100x1-16 1719249 2066 ns/op 7944.72 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 853413 4122 ns/op 7958.06 MB/s Benchmark____FanIn_16kx100x1-16 870835 4136 ns/op 7930.69 MB/s Benchmark____FanIn_16kx100x1-16 868003 4140 ns/op 7922.62 MB/s Benchmark____FanIn_16kx100x1-16 879054 4125 ns/op 7951.37 MB/s Benchmark____FanIn_16kx100x1-16 861087 4128 ns/op 7946.42 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1869768219 vs 11117788800 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51568->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51482->127.0.0.1:5222: write: broken pipe Benchmark____FanIn_64kx100x1-16 170674 19904 ns/op 6586.77 MB/s Benchmark____FanIn_64kx100x1-16 170361 19771 ns/op 6631.16 MB/s Benchmark____FanIn_64kx100x1-16 174949 19924 ns/op 6580.10 MB/s Benchmark____FanIn_64kx100x1-16 164824 19803 ns/op 6620.52 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 649157680 vs 12099607000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:46048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:45978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:46784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:46178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:46482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:46720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:46532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46690->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: 263621990 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:48566->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: 524884360 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49710->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: 663184310 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:52044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:52018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:52002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51920->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: 1032595930 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53064->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5984313 594.5 ns/op 477.72 MB/s Benchmark___BumpPubCount_1x3-16 6019306 597.4 ns/op 475.36 MB/s Benchmark___BumpPubCount_1x3-16 5997663 595.5 ns/op 476.90 MB/s Benchmark___BumpPubCount_1x3-16 5921364 595.5 ns/op 476.94 MB/s Benchmark___BumpPubCount_1x3-16 6051753 596.7 ns/op 475.92 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5658236 632.4 ns/op 449.09 MB/s Benchmark___BumpPubCount_2x3-16 5639890 629.0 ns/op 451.54 MB/s Benchmark___BumpPubCount_2x3-16 5668906 629.3 ns/op 451.26 MB/s Benchmark___BumpPubCount_2x3-16 5660160 634.0 ns/op 447.94 MB/s Benchmark___BumpPubCount_2x3-16 5651434 633.0 ns/op 448.66 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5846419 609.9 ns/op 465.69 MB/s Benchmark___BumpPubCount_5x3-16 5381344 613.5 ns/op 462.92 MB/s Benchmark___BumpPubCount_5x3-16 5871375 618.7 ns/op 459.05 MB/s Benchmark___BumpPubCount_5x3-16 5847663 611.6 ns/op 464.39 MB/s Benchmark___BumpPubCount_5x3-16 5834055 613.1 ns/op 463.18 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5883867 609.5 ns/op 465.92 MB/s Benchmark__BumpPubCount_10x3-16 5882875 607.5 ns/op 467.48 MB/s Benchmark__BumpPubCount_10x3-16 5871984 608.9 ns/op 466.39 MB/s Benchmark__BumpPubCount_10x3-16 5887946 610.4 ns/op 465.23 MB/s Benchmark__BumpPubCount_10x3-16 5882868 609.0 ns/op 466.37 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12506470 267.5 ns/op 3887.13 MB/s Benchmark____GWs_Opt_1kx01x0-16 11975001 282.9 ns/op 3675.87 MB/s Benchmark____GWs_Opt_1kx01x0-16 12515312 266.8 ns/op 3898.00 MB/s Benchmark____GWs_Opt_1kx01x0-16 12743395 265.2 ns/op 3921.56 MB/s Benchmark____GWs_Opt_1kx01x0-16 12822133 269.9 ns/op 3853.00 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10810630 349.1 ns/op 5911.61 MB/s Benchmark____GWs_Opt_2kx01x0-16 10865292 333.5 ns/op 6189.49 MB/s Benchmark____GWs_Opt_2kx01x0-16 9591477 353.2 ns/op 5844.49 MB/s Benchmark____GWs_Opt_2kx01x0-16 10589428 348.1 ns/op 5928.68 MB/s Benchmark____GWs_Opt_2kx01x0-16 10034678 335.6 ns/op 6149.41 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 6048753 618.0 ns/op 6653.28 MB/s Benchmark____GWs_Opt_4kx01x0-16 5740353 605.7 ns/op 6788.55 MB/s Benchmark____GWs_Opt_4kx01x0-16 5794734 630.8 ns/op 6518.69 MB/s Benchmark____GWs_Opt_4kx01x0-16 5634009 615.0 ns/op 6686.41 MB/s Benchmark____GWs_Opt_4kx01x0-16 5967370 596.0 ns/op 6899.86 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29201692 110.3 ns/op 9427.58 MB/s Benchmark____GWs_Opt_1kx10x0-16 33254673 110.5 ns/op 9413.26 MB/s Benchmark____GWs_Opt_1kx10x0-16 31442650 111.4 ns/op 9339.83 MB/s Benchmark____GWs_Opt_1kx10x0-16 32110716 114.3 ns/op 9102.46 MB/s Benchmark____GWs_Opt_1kx10x0-16 30889701 109.6 ns/op 9490.06 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24664833 143.3 ns/op 14400.74 MB/s Benchmark____GWs_Opt_2kx10x0-16 23103999 158.4 ns/op 13028.18 MB/s Benchmark____GWs_Opt_2kx10x0-16 25904948 147.4 ns/op 13999.31 MB/s Benchmark____GWs_Opt_2kx10x0-16 25608685 161.2 ns/op 12806.69 MB/s Benchmark____GWs_Opt_2kx10x0-16 25292368 139.2 ns/op 14832.05 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11498778 326.9 ns/op 12577.12 MB/s Benchmark____GWs_Opt_4kx10x0-16 13118070 304.4 ns/op 13509.94 MB/s Benchmark____GWs_Opt_4kx10x0-16 12358983 330.1 ns/op 12455.42 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:47748->127.0.0.1:41957: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:51024->127.0.0.1:40801: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 9657019 396.5 ns/op 10371.89 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6826155 537.4 ns/op 5814.88 MB/s Benchmark____GWs_Opt_1kx01x1-16 6589790 542.5 ns/op 5760.89 MB/s Benchmark____GWs_Opt_1kx01x1-16 6532230 537.2 ns/op 5817.34 MB/s Benchmark____GWs_Opt_1kx01x1-16 6533029 534.3 ns/op 5848.29 MB/s Benchmark____GWs_Opt_1kx01x1-16 6728348 540.4 ns/op 5783.08 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4746745 745.0 ns/op 8318.44 MB/s Benchmark____GWs_Opt_2kx01x1-16 4828002 745.0 ns/op 8318.47 MB/s Benchmark____GWs_Opt_2kx01x1-16 4650649 788.3 ns/op 7861.17 MB/s Benchmark____GWs_Opt_2kx01x1-16 4779771 743.0 ns/op 8340.11 MB/s Benchmark____GWs_Opt_2kx01x1-16 4783786 742.7 ns/op 8344.39 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2566309 1356 ns/op 9100.46 MB/s Benchmark____GWs_Opt_4kx01x1-16 2640945 1911 ns/op 6457.35 MB/s Benchmark____GWs_Opt_4kx01x1-16 2666988 1364 ns/op 9048.63 MB/s Benchmark____GWs_Opt_4kx01x1-16 2631111 1352 ns/op 9127.41 MB/s Benchmark____GWs_Opt_4kx01x1-16 2629765 1363 ns/op 9056.31 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6762296 542.9 ns/op 5755.61 MB/s Benchmark____GWs_Opt_1kx10x1-16 6848878 532.5 ns/op 5869.06 MB/s Benchmark____GWs_Opt_1kx10x1-16 6638954 562.8 ns/op 5552.14 MB/s Benchmark____GWs_Opt_1kx10x1-16 6284952 543.0 ns/op 5755.49 MB/s Benchmark____GWs_Opt_1kx10x1-16 6463110 541.8 ns/op 5768.17 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4296379 835.6 ns/op 7415.92 MB/s Benchmark____GWs_Opt_2kx10x1-16 4280402 834.4 ns/op 7426.90 MB/s Benchmark____GWs_Opt_2kx10x1-16 4117371 830.4 ns/op 7462.51 MB/s Benchmark____GWs_Opt_2kx10x1-16 4197494 831.0 ns/op 7457.31 MB/s Benchmark____GWs_Opt_2kx10x1-16 4255864 826.6 ns/op 7497.02 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2290010 1500 ns/op 8227.15 MB/s Benchmark____GWs_Opt_4kx10x1-16 2405790 1567 ns/op 7876.29 MB/s Benchmark____GWs_Opt_4kx10x1-16 2367036 1500 ns/op 8226.46 MB/s Benchmark____GWs_Opt_4kx10x1-16 2182022 1550 ns/op 7961.31 MB/s Benchmark____GWs_Opt_4kx10x1-16 2390377 1525 ns/op 8091.13 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12392174 280.5 ns/op 3707.56 MB/s Benchmark____GWs_Int_1kx01x0-16 12392582 284.0 ns/op 3661.61 MB/s Benchmark____GWs_Int_1kx01x0-16 12243648 292.0 ns/op 3562.10 MB/s Benchmark____GWs_Int_1kx01x0-16 12866462 300.5 ns/op 3461.46 MB/s Benchmark____GWs_Int_1kx01x0-16 11952208 289.9 ns/op 3587.48 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10035740 340.6 ns/op 6060.03 MB/s Benchmark____GWs_Int_2kx01x0-16 8895044 374.9 ns/op 5504.83 MB/s Benchmark____GWs_Int_2kx01x0-16 9855207 353.4 ns/op 5840.71 MB/s Benchmark____GWs_Int_2kx01x0-16 10552074 358.2 ns/op 5762.20 MB/s Benchmark____GWs_Int_2kx01x0-16 10136718 359.2 ns/op 5746.78 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5969409 610.0 ns/op 6740.82 MB/s Benchmark____GWs_Int_4kx01x0-16 5707633 639.7 ns/op 6427.92 MB/s Benchmark____GWs_Int_4kx01x0-16 6114709 629.4 ns/op 6533.71 MB/s Benchmark____GWs_Int_4kx01x0-16 5730640 628.0 ns/op 6548.22 MB/s Benchmark____GWs_Int_4kx01x0-16 5748750 629.3 ns/op 6534.40 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32228920 110.3 ns/op 9431.76 MB/s Benchmark____GWs_Int_1kx10x0-16 31209531 109.6 ns/op 9490.68 MB/s Benchmark____GWs_Int_1kx10x0-16 31401556 109.7 ns/op 9480.93 MB/s Benchmark____GWs_Int_1kx10x0-16 32616615 112.7 ns/op 9229.92 MB/s Benchmark____GWs_Int_1kx10x0-16 32165018 111.3 ns/op 9344.84 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25629968 144.0 ns/op 14332.82 MB/s Benchmark____GWs_Int_2kx10x0-16 24777702 160.6 ns/op 12853.24 MB/s Benchmark____GWs_Int_2kx10x0-16 21571659 153.3 ns/op 13465.19 MB/s Benchmark____GWs_Int_2kx10x0-16 24057288 141.1 ns/op 14633.01 MB/s Benchmark____GWs_Int_2kx10x0-16 24965308 145.3 ns/op 14202.97 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12647086 319.4 ns/op 12875.06 MB/s Benchmark____GWs_Int_4kx10x0-16 12845589 316.8 ns/op 12981.53 MB/s Benchmark____GWs_Int_4kx10x0-16 13143368 307.4 ns/op 13378.68 MB/s Benchmark____GWs_Int_4kx10x0-16 12141544 283.3 ns/op 14513.24 MB/s Benchmark____GWs_Int_4kx10x0-16 12930553 320.3 ns/op 12836.56 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6663670 550.2 ns/op 5680.08 MB/s Benchmark____GWs_Int_1kx01x1-16 5971305 541.5 ns/op 5771.17 MB/s Benchmark____GWs_Int_1kx01x1-16 6648498 546.3 ns/op 5720.13 MB/s Benchmark____GWs_Int_1kx01x1-16 6465178 551.4 ns/op 5667.53 MB/s Benchmark____GWs_Int_1kx01x1-16 6664957 546.7 ns/op 5716.23 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4860897 755.8 ns/op 8199.14 MB/s Benchmark____GWs_Int_2kx01x1-16 4864399 742.0 ns/op 8351.83 MB/s Benchmark____GWs_Int_2kx01x1-16 4825395 809.3 ns/op 7656.83 MB/s Benchmark____GWs_Int_2kx01x1-16 4929244 754.4 ns/op 8214.49 MB/s Benchmark____GWs_Int_2kx01x1-16 4758982 757.7 ns/op 8179.12 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2677821 1356 ns/op 9099.83 MB/s Benchmark____GWs_Int_4kx01x1-16 2650905 1365 ns/op 9039.24 MB/s Benchmark____GWs_Int_4kx01x1-16 2599192 1356 ns/op 9100.68 MB/s Benchmark____GWs_Int_4kx01x1-16 2296521 1367 ns/op 9026.66 MB/s Benchmark____GWs_Int_4kx01x1-16 2622900 1360 ns/op 9077.28 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6805436 761.7 ns/op 4102.86 MB/s Benchmark____GWs_Int_1kx10x1-16 6178768 542.2 ns/op 5763.78 MB/s Benchmark____GWs_Int_1kx10x1-16 6406549 542.2 ns/op 5763.15 MB/s Benchmark____GWs_Int_1kx10x1-16 6216758 556.4 ns/op 5616.26 MB/s Benchmark____GWs_Int_1kx10x1-16 6234884 548.4 ns/op 5698.14 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4420426 839.8 ns/op 7378.97 MB/s Benchmark____GWs_Int_2kx10x1-16 4507015 835.0 ns/op 7421.87 MB/s Benchmark____GWs_Int_2kx10x1-16 4264251 837.5 ns/op 7398.99 MB/s Benchmark____GWs_Int_2kx10x1-16 4342533 824.4 ns/op 7516.85 MB/s Benchmark____GWs_Int_2kx10x1-16 4166166 841.9 ns/op 7360.78 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2589831 1485 ns/op 8309.48 MB/s Benchmark____GWs_Int_4kx10x1-16 2381344 1634 ns/op 7551.08 MB/s Benchmark____GWs_Int_4kx10x1-16 2373576 1509 ns/op 8180.47 MB/s Benchmark____GWs_Int_4kx10x1-16 2389020 1677 ns/op 7356.81 MB/s Benchmark____GWs_Int_4kx10x1-16 2440209 1509 ns/op 8176.54 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8147118 424.8 ns/op 240.10 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8704426 419.2 ns/op 243.35 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8289961 423.2 ns/op 241.01 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8339684 428.0 ns/op 238.33 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8558142 428.3 ns/op 238.13 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 653342 4707 ns/op 37.60 MB/s Benchmark__GWs_Reqs_1SubEach-16 871977 4845 ns/op 36.53 MB/s Benchmark__GWs_Reqs_1SubEach-16 792015 4887 ns/op 36.22 MB/s Benchmark__GWs_Reqs_1SubEach-16 802046 4993 ns/op 35.45 MB/s Benchmark__GWs_Reqs_1SubEach-16 843651 5007 ns/op 35.35 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2138.664s ❌ Non-zero exit code: 1