> ROOT_DIR=/tmp/go-bench-away-job-d6cccc27-7cd6-4b62-9d83-0b5fd1608e36-2949053603 > OUTPUT_FILE=/tmp/go-bench-away-job-d6cccc27-7cd6-4b62-9d83-0b5fd1608e36-2949053603/results.txt > SHA_FILE=/tmp/go-bench-away-job-d6cccc27-7cd6-4b62-9d83-0b5fd1608e36-2949053603/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-d6cccc27-7cd6-4b62-9d83-0b5fd1608e36-2949053603/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.25.4/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-d6cccc27-7cd6-4b62-9d83-0b5fd1608e36-2949053603/source.git SHA of main: 06ca952879d09d192145d1f0fcf89a642d9545bf 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-build3463198298=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-d6cccc27-7cd6-4b62-9d83-0b5fd1608e36-2949053603/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 48956428 73.63 ns/op 149.39 MB/s Benchmark______Pub0b_Payload-16 46163773 73.64 ns/op 149.38 MB/s Benchmark______Pub0b_Payload-16 46474080 73.59 ns/op 149.47 MB/s Benchmark______Pub0b_Payload-16 46273719 73.67 ns/op 149.32 MB/s Benchmark______Pub0b_Payload-16 46104360 73.32 ns/op 150.02 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 47456470 74.06 ns/op 256.54 MB/s Benchmark______Pub8b_Payload-16 45891096 74.04 ns/op 256.62 MB/s Benchmark______Pub8b_Payload-16 45769374 74.29 ns/op 255.77 MB/s Benchmark______Pub8b_Payload-16 45627285 74.09 ns/op 256.46 MB/s Benchmark______Pub8b_Payload-16 45576966 74.11 ns/op 256.36 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43631413 79.46 ns/op 553.77 MB/s Benchmark_____Pub32b_Payload-16 43446907 78.41 ns/op 561.13 MB/s Benchmark_____Pub32b_Payload-16 43656943 78.84 ns/op 558.07 MB/s Benchmark_____Pub32b_Payload-16 43094959 79.79 ns/op 551.46 MB/s Benchmark_____Pub32b_Payload-16 43627011 78.20 ns/op 562.64 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 37627196 91.78 ns/op 1536.21 MB/s Benchmark____Pub128B_Payload-16 38665260 89.57 ns/op 1574.17 MB/s Benchmark____Pub128B_Payload-16 37867656 88.14 ns/op 1599.76 MB/s Benchmark____Pub128B_Payload-16 38446532 88.40 ns/op 1595.01 MB/s Benchmark____Pub128B_Payload-16 39149698 88.62 ns/op 1591.06 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36369036 96.83 ns/op 2778.13 MB/s Benchmark____Pub256B_Payload-16 34434601 99.59 ns/op 2701.07 MB/s Benchmark____Pub256B_Payload-16 37359834 97.55 ns/op 2757.67 MB/s Benchmark____Pub256B_Payload-16 35587036 97.36 ns/op 2762.99 MB/s Benchmark____Pub256B_Payload-16 31166383 98.66 ns/op 2726.52 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24179767 156.0 ns/op 6654.40 MB/s Benchmark______Pub1K_Payload-16 23790675 143.1 ns/op 7255.37 MB/s Benchmark______Pub1K_Payload-16 23597809 141.8 ns/op 7321.58 MB/s Benchmark______Pub1K_Payload-16 22905559 143.4 ns/op 7239.70 MB/s Benchmark______Pub1K_Payload-16 24176918 145.1 ns/op 7154.16 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5397889 630.5 ns/op 6518.37 MB/s Benchmark______Pub4K_Payload-16 5440267 619.6 ns/op 6632.85 MB/s Benchmark______Pub4K_Payload-16 5310279 621.0 ns/op 6618.22 MB/s Benchmark______Pub4K_Payload-16 5719410 633.3 ns/op 6490.18 MB/s Benchmark______Pub4K_Payload-16 5808291 626.6 ns/op 6559.15 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2723259 1281 ns/op 6404.88 MB/s Benchmark______Pub8K_Payload-16 2780306 1272 ns/op 6451.73 MB/s Benchmark______Pub8K_Payload-16 2741295 1283 ns/op 6394.23 MB/s Benchmark______Pub8K_Payload-16 2824153 1274 ns/op 6439.08 MB/s Benchmark______Pub8K_Payload-16 2721940 1282 ns/op 6401.70 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 721438 5418 ns/op 6050.35 MB/s Benchmark_____Pub32K_Payload-16 559648 5481 ns/op 5980.74 MB/s Benchmark_____Pub32K_Payload-16 670791 5530 ns/op 5928.73 MB/s Benchmark_____Pub32K_Payload-16 482702 6691 ns/op 4899.36 MB/s Benchmark_____Pub32K_Payload-16 652748 7251 ns/op 4521.13 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31519650 99.85 ns/op 110.16 MB/s Benchmark__AuthPub0b_Payload-16 36939730 97.62 ns/op 112.68 MB/s Benchmark__AuthPub0b_Payload-16 31667703 97.18 ns/op 113.20 MB/s Benchmark__AuthPub0b_Payload-16 31309759 97.18 ns/op 113.19 MB/s Benchmark__AuthPub0b_Payload-16 35070417 97.36 ns/op 112.98 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15507354 228.8 ns/op Benchmark_____________PubSub-16 15469896 228.5 ns/op Benchmark_____________PubSub-16 15772471 228.4 ns/op Benchmark_____________PubSub-16 15607623 229.6 ns/op Benchmark_____________PubSub-16 15554462 228.3 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15769174 227.0 ns/op Benchmark_____PubSubTwoConns-16 15484717 227.1 ns/op Benchmark_____PubSubTwoConns-16 15496048 227.6 ns/op Benchmark_____PubSubTwoConns-16 15518691 227.4 ns/op Benchmark_____PubSubTwoConns-16 15495158 227.4 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:44458->127.0.0.1:40945: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:39876->127.0.0.1:45939: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:56642->127.0.0.1:39509: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:32774->127.0.0.1:44421: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:54398->127.0.0.1:45401: 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 14284816 249.6 ns/op Benchmark_____PubTwoQueueSub-16 14281684 248.8 ns/op Benchmark_____PubTwoQueueSub-16 14130404 248.7 ns/op Benchmark_____PubTwoQueueSub-16 14337865 248.8 ns/op Benchmark_____PubTwoQueueSub-16 14275045 248.3 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14190235 248.9 ns/op Benchmark____PubFourQueueSub-16 14224226 249.0 ns/op Benchmark____PubFourQueueSub-16 14308000 248.9 ns/op Benchmark____PubFourQueueSub-16 14370122 248.2 ns/op Benchmark____PubFourQueueSub-16 14246786 249.3 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14154800 247.3 ns/op Benchmark___PubEightQueueSub-16 13949320 249.0 ns/op Benchmark___PubEightQueueSub-16 14128425 248.0 ns/op Benchmark___PubEightQueueSub-16 14101791 249.2 ns/op Benchmark___PubEightQueueSub-16 14128464 249.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23192 156589 ns/op Benchmark_PubSub512kTwoConns-16 23336 156688 ns/op Benchmark_PubSub512kTwoConns-16 21433 155605 ns/op Benchmark_PubSub512kTwoConns-16 22896 156458 ns/op Benchmark_PubSub512kTwoConns-16 22968 156561 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15186040 231.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15221236 230.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 14967357 231.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 15006325 231.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15143726 231.4 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15059384 230.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15331719 231.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15062790 230.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15109744 230.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15067887 231.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10927755 314.2 ns/op Benchmark____RoutedPubSub_0b-16 11447494 312.2 ns/op Benchmark____RoutedPubSub_0b-16 11254490 312.4 ns/op Benchmark____RoutedPubSub_0b-16 11504862 316.3 ns/op Benchmark____RoutedPubSub_0b-16 11248224 316.0 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6811113 538.0 ns/op Benchmark____RoutedPubSub_1K-16 6559670 539.5 ns/op Benchmark____RoutedPubSub_1K-16 6555793 542.4 ns/op Benchmark____RoutedPubSub_1K-16 6567912 547.5 ns/op Benchmark____RoutedPubSub_1K-16 6508603 531.0 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 82008 40136 ns/op Benchmark__RoutedPubSub_100K-16 80540 43437 ns/op Benchmark__RoutedPubSub_100K-16 82630 43163 ns/op Benchmark__RoutedPubSub_100K-16 78895 45503 ns/op Benchmark__RoutedPubSub_100K-16 84720 45403 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9676419 324.3 ns/op Benchmark____Routed2QueueSub-16 9797900 317.0 ns/op Benchmark____Routed2QueueSub-16 9629148 319.5 ns/op Benchmark____Routed2QueueSub-16 9675235 317.4 ns/op Benchmark____Routed2QueueSub-16 9704977 320.1 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9551834 326.4 ns/op Benchmark____Routed4QueueSub-16 9500922 324.6 ns/op Benchmark____Routed4QueueSub-16 11422014 315.3 ns/op Benchmark____Routed4QueueSub-16 9048945 336.2 ns/op Benchmark____Routed4QueueSub-16 9505381 318.7 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 10819978 331.2 ns/op Benchmark____Routed8QueueSub-16 9114826 335.3 ns/op Benchmark____Routed8QueueSub-16 11036587 334.9 ns/op Benchmark____Routed8QueueSub-16 9032613 334.1 ns/op Benchmark____Routed8QueueSub-16 9012219 333.5 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8850627 351.8 ns/op Benchmark___Routed16QueueSub-16 8728598 345.4 ns/op Benchmark___Routed16QueueSub-16 10287238 348.5 ns/op Benchmark___Routed16QueueSub-16 10235650 357.2 ns/op Benchmark___Routed16QueueSub-16 10212772 346.3 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6369271 546.8 ns/op Benchmark____________RouteCompressOff-16 6412077 508.8 ns/op Benchmark____________RouteCompressOff-16 6477417 547.9 ns/op Benchmark____________RouteCompressOff-16 6371874 495.3 ns/op Benchmark____________RouteCompressOff-16 6512617 509.1 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6458011 499.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6348128 557.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6441974 556.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6361978 551.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6495489 549.0 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6381243 552.4 ns/op Benchmark_________RouteCompressS2Fast-16 6409564 486.6 ns/op Benchmark_________RouteCompressS2Fast-16 6456506 542.8 ns/op Benchmark_________RouteCompressS2Fast-16 6404923 550.9 ns/op Benchmark_________RouteCompressS2Fast-16 6270914 545.5 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6389030 542.9 ns/op Benchmark_______RouteCompressS2Better-16 6552064 554.2 ns/op Benchmark_______RouteCompressS2Better-16 6433269 542.1 ns/op Benchmark_______RouteCompressS2Better-16 6499081 546.7 ns/op Benchmark_______RouteCompressS2Better-16 6358627 547.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6572221 479.7 ns/op Benchmark_________RouteCompressS2Best-16 6452673 549.1 ns/op Benchmark_________RouteCompressS2Best-16 6475447 547.1 ns/op Benchmark_________RouteCompressS2Best-16 6381475 474.9 ns/op Benchmark_________RouteCompressS2Best-16 6491581 549.9 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4663849 770.7 ns/op 323.07 MB/s Benchmark______FanOut_8x1x10-16 4658925 766.5 ns/op 324.83 MB/s Benchmark______FanOut_8x1x10-16 4651286 765.6 ns/op 325.22 MB/s Benchmark______FanOut_8x1x10-16 4617964 773.6 ns/op 321.85 MB/s Benchmark______FanOut_8x1x10-16 4676248 771.7 ns/op 322.68 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 543438 6151 ns/op 377.03 MB/s Benchmark_____FanOut_8x1x100-16 535028 6164 ns/op 376.24 MB/s Benchmark_____FanOut_8x1x100-16 548788 6166 ns/op 376.07 MB/s Benchmark_____FanOut_8x1x100-16 524095 6129 ns/op 378.34 MB/s Benchmark_____FanOut_8x1x100-16 559653 6152 ns/op 376.96 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48231 74793 ns/op 307.77 MB/s Benchmark____FanOut_8x10x100-16 48243 75574 ns/op 304.59 MB/s Benchmark____FanOut_8x10x100-16 48139 74488 ns/op 309.03 MB/s Benchmark____FanOut_8x10x100-16 48109 74579 ns/op 308.65 MB/s Benchmark____FanOut_8x10x100-16 47968 74372 ns/op 309.51 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5960 600759 ns/op 399.53 MB/s Benchmark___FanOut_8x10x1000-16 5929 602872 ns/op 398.13 MB/s Benchmark___FanOut_8x10x1000-16 5802 597244 ns/op 401.88 MB/s Benchmark___FanOut_8x10x1000-16 5884 601952 ns/op 398.73 MB/s Benchmark___FanOut_8x10x1000-16 5796 597725 ns/op 401.55 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4938 712046 ns/op 323.04 MB/s Benchmark___FanOut_8x100x100-16 5043 704920 ns/op 326.31 MB/s Benchmark___FanOut_8x100x100-16 5034 709627 ns/op 324.14 MB/s Benchmark___FanOut_8x100x100-16 5016 707972 ns/op 324.90 MB/s Benchmark___FanOut_8x100x100-16 5028 707020 ns/op 325.34 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 574 6152849 ns/op 390.07 MB/s Benchmark__FanOut_8x100x1000-16 579 6143833 ns/op 390.64 MB/s Benchmark__FanOut_8x100x1000-16 560 6137500 ns/op 391.04 MB/s Benchmark__FanOut_8x100x1000-16 576 6169491 ns/op 389.01 MB/s Benchmark__FanOut_8x100x1000-16 576 6148646 ns/op 390.33 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 520 6776343 ns/op 368.93 MB/s Benchmark__FanOut_8x10x10000-16 526 6688378 ns/op 373.79 MB/s Benchmark__FanOut_8x10x10000-16 528 6751739 ns/op 370.28 MB/s Benchmark__FanOut_8x10x10000-16 537 6792679 ns/op 368.05 MB/s Benchmark__FanOut_8x10x10000-16 528 6791555 ns/op 368.11 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 938 3742336 ns/op 307.30 MB/s Benchmark___FanOut_8x500x100-16 948 3745868 ns/op 307.01 MB/s Benchmark___FanOut_8x500x100-16 957 3742774 ns/op 307.26 MB/s Benchmark___FanOut_8x500x100-16 952 3750368 ns/op 306.64 MB/s Benchmark___FanOut_8x500x100-16 960 3741133 ns/op 307.40 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 354429 9519 ns/op 1538.13 MB/s Benchmark___FanOut_128x1x100-16 353481 9461 ns/op 1547.51 MB/s Benchmark___FanOut_128x1x100-16 364104 9559 ns/op 1531.67 MB/s Benchmark___FanOut_128x1x100-16 363230 9573 ns/op 1529.33 MB/s Benchmark___FanOut_128x1x100-16 366072 9505 ns/op 1540.32 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32488 110513 ns/op 1313.34 MB/s Benchmark__FanOut_128x10x100-16 32544 110114 ns/op 1318.10 MB/s Benchmark__FanOut_128x10x100-16 32362 110142 ns/op 1317.76 MB/s Benchmark__FanOut_128x10x100-16 32578 110309 ns/op 1315.76 MB/s Benchmark__FanOut_128x10x100-16 32652 110454 ns/op 1314.04 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3862 879210 ns/op 1660.74 MB/s Benchmark_FanOut_128x10x1000-16 3996 877127 ns/op 1664.69 MB/s Benchmark_FanOut_128x10x1000-16 4056 878768 ns/op 1661.58 MB/s Benchmark_FanOut_128x10x1000-16 4032 876620 ns/op 1665.65 MB/s Benchmark_FanOut_128x10x1000-16 3883 877018 ns/op 1664.89 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3471 1013122 ns/op 1431.36 MB/s Benchmark_FanOut_128x100x100-16 3540 1007558 ns/op 1439.26 MB/s Benchmark_FanOut_128x100x100-16 3472 1010846 ns/op 1434.58 MB/s Benchmark_FanOut_128x100x100-16 3452 1005579 ns/op 1442.10 MB/s Benchmark_FanOut_128x100x100-16 3482 1010003 ns/op 1435.78 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 382 9385882 ns/op 1555.54 MB/s BenchmarkFanOut_128x100x1000-16 390 9296062 ns/op 1570.57 MB/s BenchmarkFanOut_128x100x1000-16 390 9282181 ns/op 1572.92 MB/s BenchmarkFanOut_128x100x1000-16 390 9288881 ns/op 1571.79 MB/s BenchmarkFanOut_128x100x1000-16 384 9287580 ns/op 1572.01 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 370 9632274 ns/op 1526.13 MB/s BenchmarkFanOut_128x10x10000-16 375 9612667 ns/op 1529.25 MB/s BenchmarkFanOut_128x10x10000-16 375 9640017 ns/op 1524.91 MB/s BenchmarkFanOut_128x10x10000-16 374 9606673 ns/op 1530.20 MB/s BenchmarkFanOut_128x10x10000-16 372 9664724 ns/op 1521.01 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 680 5266770 ns/op 1376.58 MB/s BenchmarkFanOut__128x500x100-16 675 5269481 ns/op 1375.87 MB/s BenchmarkFanOut__128x500x100-16 678 5256897 ns/op 1379.17 MB/s BenchmarkFanOut__128x500x100-16 670 5245714 ns/op 1382.11 MB/s BenchmarkFanOut__128x500x100-16 667 5252543 ns/op 1380.31 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1944 1821196 ns/op 2904.97 MB/s Benchmark_FanOut_512x100x100-16 1906 1828689 ns/op 2893.07 MB/s Benchmark_FanOut_512x100x100-16 1986 1828721 ns/op 2893.02 MB/s Benchmark_FanOut_512x100x100-16 1954 1825858 ns/op 2897.56 MB/s Benchmark_FanOut_512x100x100-16 1934 1842143 ns/op 2871.94 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16699690 ns/op 3173.74 MB/s Benchmark__FanOut_512x100x1k-16 217 16615933 ns/op 3189.74 MB/s Benchmark__FanOut_512x100x1k-16 218 16606333 ns/op 3191.59 MB/s Benchmark__FanOut_512x100x1k-16 217 16531586 ns/op 3206.02 MB/s Benchmark__FanOut_512x100x1k-16 216 16545721 ns/op 3203.28 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3267 1161414 ns/op 8981.33 MB/s Benchmark____FanOut_1kx10x1k-16 2935 1160851 ns/op 8985.68 MB/s Benchmark____FanOut_1kx10x1k-16 3034 1135659 ns/op 9185.01 MB/s Benchmark____FanOut_1kx10x1k-16 3055 1162310 ns/op 8974.41 MB/s Benchmark____FanOut_1kx10x1k-16 3259 1120566 ns/op 9308.72 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2776 1260867 ns/op 8264.98 MB/s Benchmark__FanOut_1kx100x100-16 2809 1254377 ns/op 8307.74 MB/s Benchmark__FanOut_1kx100x100-16 2817 1259547 ns/op 8273.64 MB/s Benchmark__FanOut_1kx100x100-16 2865 1257656 ns/op 8286.08 MB/s Benchmark__FanOut_1kx100x100-16 2793 1260702 ns/op 8266.06 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4326778 819.4 ns/op 303.87 MB/s Benchmark_____RFanOut_8x1x10-16 4339047 807.3 ns/op 308.45 MB/s Benchmark_____RFanOut_8x1x10-16 4069239 809.2 ns/op 307.71 MB/s Benchmark_____RFanOut_8x1x10-16 4148517 809.1 ns/op 307.74 MB/s Benchmark_____RFanOut_8x1x10-16 4102447 825.5 ns/op 301.62 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 518215 6591 ns/op 351.85 MB/s Benchmark____RFanOut_8x1x100-16 499352 6695 ns/op 346.37 MB/s Benchmark____RFanOut_8x1x100-16 484791 7020 ns/op 330.36 MB/s Benchmark____RFanOut_8x1x100-16 518635 6599 ns/op 351.42 MB/s Benchmark____RFanOut_8x1x100-16 484293 6559 ns/op 353.55 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 43864 80460 ns/op 286.09 MB/s Benchmark___RFanOut_8x10x100-16 44100 80426 ns/op 286.21 MB/s Benchmark___RFanOut_8x10x100-16 44220 80951 ns/op 284.36 MB/s Benchmark___RFanOut_8x10x100-16 44319 81761 ns/op 281.54 MB/s Benchmark___RFanOut_8x10x100-16 44372 80886 ns/op 284.58 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5359 677274 ns/op 354.39 MB/s Benchmark__RFanOut_8x10x1000-16 5083 663014 ns/op 362.01 MB/s Benchmark__RFanOut_8x10x1000-16 5305 662646 ns/op 362.21 MB/s Benchmark__RFanOut_8x10x1000-16 5094 675270 ns/op 355.44 MB/s Benchmark__RFanOut_8x10x1000-16 5102 663608 ns/op 361.69 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4725 762221 ns/op 301.77 MB/s Benchmark__RFanOut_8x100x100-16 4719 759113 ns/op 303.01 MB/s Benchmark__RFanOut_8x100x100-16 4586 763539 ns/op 301.25 MB/s Benchmark__RFanOut_8x100x100-16 4689 759794 ns/op 302.74 MB/s Benchmark__RFanOut_8x100x100-16 4730 770471 ns/op 298.54 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 514 6943694 ns/op 345.64 MB/s Benchmark_RFanOut_8x100x1000-16 517 6968315 ns/op 344.42 MB/s Benchmark_RFanOut_8x100x1000-16 512 6866485 ns/op 349.53 MB/s Benchmark_RFanOut_8x100x1000-16 518 7035728 ns/op 341.12 MB/s Benchmark_RFanOut_8x100x1000-16 511 6909263 ns/op 347.36 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 480 7448887 ns/op 335.62 MB/s Benchmark_RFanOut_8x10x10000-16 476 7507023 ns/op 333.02 MB/s Benchmark_RFanOut_8x10x10000-16 477 7594167 ns/op 329.20 MB/s Benchmark_RFanOut_8x10x10000-16 494 7333512 ns/op 340.90 MB/s Benchmark_RFanOut_8x10x10000-16 484 7328575 ns/op 341.13 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2792 1182891 ns/op 8818.26 MB/s Benchmark_RFanOut_1kx10x1000-16 2860 1175832 ns/op 8871.20 MB/s Benchmark_RFanOut_1kx10x1000-16 3105 1159688 ns/op 8994.70 MB/s Benchmark_RFanOut_1kx10x1000-16 2920 1175714 ns/op 8872.09 MB/s Benchmark_RFanOut_1kx10x1000-16 3004 1187642 ns/op 8782.98 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6921220 499.4 ns/op 4161.38 MB/s Benchmark_____FanIn_1kx100x1-16 6876488 506.5 ns/op 4102.85 MB/s Benchmark_____FanIn_1kx100x1-16 6948744 505.8 ns/op 4108.22 MB/s Benchmark_____FanIn_1kx100x1-16 6942652 508.7 ns/op 4084.65 MB/s Benchmark_____FanIn_1kx100x1-16 6925539 505.3 ns/op 4112.11 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2667330 1375 ns/op 5979.88 MB/s Benchmark_____FanIn_4kx100x1-16 2608147 1375 ns/op 5980.06 MB/s Benchmark_____FanIn_4kx100x1-16 2626911 1379 ns/op 5963.28 MB/s Benchmark_____FanIn_4kx100x1-16 2591204 1361 ns/op 6041.51 MB/s Benchmark_____FanIn_4kx100x1-16 2582269 1360 ns/op 6044.51 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1726512 2110 ns/op 7777.81 MB/s Benchmark_____FanIn_8kx100x1-16 1714584 2108 ns/op 7787.66 MB/s Benchmark_____FanIn_8kx100x1-16 1696612 2128 ns/op 7713.69 MB/s Benchmark_____FanIn_8kx100x1-16 1683024 2095 ns/op 7836.50 MB/s Benchmark_____FanIn_8kx100x1-16 1683588 2128 ns/op 7711.93 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 848557 4160 ns/op 7884.89 MB/s Benchmark____FanIn_16kx100x1-16 855938 4131 ns/op 7940.13 MB/s Benchmark____FanIn_16kx100x1-16 857853 4151 ns/op 7902.17 MB/s Benchmark____FanIn_16kx100x1-16 862725 4123 ns/op 7955.81 MB/s Benchmark____FanIn_16kx100x1-16 866353 4089 ns/op 8021.46 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 166147 19989 ns/op 6558.80 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7562390739 vs 10967016900 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45628->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45350->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 157274 19819 ns/op 6615.07 MB/s Benchmark____FanIn_64kx100x1-16 169723 19869 ns/op 6598.46 MB/s Benchmark____FanIn_64kx100x1-16 173720 19959 ns/op 6568.56 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 622939680 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:51596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:51070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51126->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:51406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:51298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:51034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:51064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:51356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:51526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:51580->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 565653350 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53604->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1021584370 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55308->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: 1536768070 vs 11509702000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57588->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57496->127.0.0.1:5222: write: broken pipe bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 2112253170 vs 11431048000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60496->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60822->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60708->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60538->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5535205 646.0 ns/op 439.64 MB/s Benchmark___BumpPubCount_1x3-16 5595316 643.8 ns/op 441.13 MB/s Benchmark___BumpPubCount_1x3-16 5539137 644.9 ns/op 440.41 MB/s Benchmark___BumpPubCount_1x3-16 5627785 644.1 ns/op 440.93 MB/s Benchmark___BumpPubCount_1x3-16 5535499 646.3 ns/op 439.46 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5298406 678.2 ns/op 418.74 MB/s Benchmark___BumpPubCount_2x3-16 5242413 678.9 ns/op 418.35 MB/s Benchmark___BumpPubCount_2x3-16 5284173 682.8 ns/op 415.96 MB/s Benchmark___BumpPubCount_2x3-16 5268519 685.0 ns/op 414.60 MB/s Benchmark___BumpPubCount_2x3-16 5287110 675.0 ns/op 420.76 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5426332 651.5 ns/op 435.89 MB/s Benchmark___BumpPubCount_5x3-16 5338413 650.9 ns/op 436.31 MB/s Benchmark___BumpPubCount_5x3-16 5265622 651.1 ns/op 436.16 MB/s Benchmark___BumpPubCount_5x3-16 5356990 654.7 ns/op 433.80 MB/s Benchmark___BumpPubCount_5x3-16 5152734 649.9 ns/op 436.98 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5478859 655.6 ns/op 433.20 MB/s Benchmark__BumpPubCount_10x3-16 5481822 653.0 ns/op 434.92 MB/s Benchmark__BumpPubCount_10x3-16 5467665 652.4 ns/op 435.29 MB/s Benchmark__BumpPubCount_10x3-16 5485776 652.9 ns/op 434.99 MB/s Benchmark__BumpPubCount_10x3-16 5499709 654.7 ns/op 433.78 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12479936 288.4 ns/op 3606.63 MB/s Benchmark____GWs_Opt_1kx01x0-16 11325240 275.6 ns/op 3773.51 MB/s Benchmark____GWs_Opt_1kx01x0-16 12220526 280.0 ns/op 3713.91 MB/s Benchmark____GWs_Opt_1kx01x0-16 12886862 280.7 ns/op 3705.60 MB/s Benchmark____GWs_Opt_1kx01x0-16 11587222 282.1 ns/op 3686.13 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9938342 351.7 ns/op 5868.85 MB/s Benchmark____GWs_Opt_2kx01x0-16 10854956 345.2 ns/op 5978.96 MB/s Benchmark____GWs_Opt_2kx01x0-16 9991054 354.4 ns/op 5823.50 MB/s Benchmark____GWs_Opt_2kx01x0-16 9463197 358.2 ns/op 5762.61 MB/s Benchmark____GWs_Opt_2kx01x0-16 10822534 356.3 ns/op 5793.10 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 4724640 669.1 ns/op 6145.25 MB/s Benchmark____GWs_Opt_4kx01x0-16 5175190 661.5 ns/op 6216.21 MB/s Benchmark____GWs_Opt_4kx01x0-16 5256468 797.6 ns/op 5155.75 MB/s Benchmark____GWs_Opt_4kx01x0-16 5220052 658.8 ns/op 6241.33 MB/s Benchmark____GWs_Opt_4kx01x0-16 5259433 660.0 ns/op 6230.14 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29373445 120.4 ns/op 8637.25 MB/s Benchmark____GWs_Opt_1kx10x0-16 27957164 112.9 ns/op 9209.31 MB/s Benchmark____GWs_Opt_1kx10x0-16 32523008 113.2 ns/op 9186.43 MB/s Benchmark____GWs_Opt_1kx10x0-16 31557906 114.1 ns/op 9113.84 MB/s Benchmark____GWs_Opt_1kx10x0-16 31943888 114.2 ns/op 9110.44 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24772759 156.3 ns/op 13202.90 MB/s Benchmark____GWs_Opt_2kx10x0-16 21514148 156.8 ns/op 13164.01 MB/s Benchmark____GWs_Opt_2kx10x0-16 25413673 149.5 ns/op 13805.30 MB/s Benchmark____GWs_Opt_2kx10x0-16 23980831 152.2 ns/op 13562.13 MB/s Benchmark____GWs_Opt_2kx10x0-16 25046119 157.2 ns/op 13128.76 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12994718 284.5 ns/op 14451.76 MB/s Benchmark____GWs_Opt_4kx10x0-16 12705535 334.2 ns/op 12303.97 MB/s Benchmark____GWs_Opt_4kx10x0-16 12725953 290.5 ns/op 14154.35 MB/s Benchmark____GWs_Opt_4kx10x0-16 12595758 292.6 ns/op 14051.93 MB/s Benchmark____GWs_Opt_4kx10x0-16 12607062 340.8 ns/op 12065.00 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6346204 553.9 ns/op 5641.52 MB/s Benchmark____GWs_Opt_1kx01x1-16 6507384 554.8 ns/op 5632.94 MB/s Benchmark____GWs_Opt_1kx01x1-16 6149996 554.8 ns/op 5632.98 MB/s Benchmark____GWs_Opt_1kx01x1-16 6391489 554.8 ns/op 5633.05 MB/s Benchmark____GWs_Opt_1kx01x1-16 6296230 557.5 ns/op 5605.50 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4584997 775.1 ns/op 7995.44 MB/s Benchmark____GWs_Opt_2kx01x1-16 4602853 761.2 ns/op 8141.54 MB/s Benchmark____GWs_Opt_2kx01x1-16 4801377 793.2 ns/op 7812.49 MB/s Benchmark____GWs_Opt_2kx01x1-16 4659847 766.9 ns/op 8080.52 MB/s Benchmark____GWs_Opt_2kx01x1-16 4739185 954.4 ns/op 6492.75 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2653098 1411 ns/op 8746.89 MB/s Benchmark____GWs_Opt_4kx01x1-16 2636090 1640 ns/op 7524.18 MB/s Benchmark____GWs_Opt_4kx01x1-16 2559441 1383 ns/op 8920.71 MB/s Benchmark____GWs_Opt_4kx01x1-16 2494927 1388 ns/op 8892.84 MB/s Benchmark____GWs_Opt_4kx01x1-16 1000000 3895 ns/op 3168.34 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6074848 558.2 ns/op 5598.47 MB/s Benchmark____GWs_Opt_1kx10x1-16 6608115 549.7 ns/op 5684.64 MB/s Benchmark____GWs_Opt_1kx10x1-16 6674426 553.3 ns/op 5648.15 MB/s Benchmark____GWs_Opt_1kx10x1-16 6375387 553.6 ns/op 5645.27 MB/s Benchmark____GWs_Opt_1kx10x1-16 6126289 558.9 ns/op 5591.52 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4372984 866.2 ns/op 7154.00 MB/s Benchmark____GWs_Opt_2kx10x1-16 4071235 847.0 ns/op 7316.14 MB/s Benchmark____GWs_Opt_2kx10x1-16 4018724 850.9 ns/op 7282.77 MB/s Benchmark____GWs_Opt_2kx10x1-16 3937538 838.7 ns/op 7388.57 MB/s Benchmark____GWs_Opt_2kx10x1-16 4100858 836.9 ns/op 7405.05 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2334225 1427 ns/op 8648.24 MB/s Benchmark____GWs_Opt_4kx10x1-16 2332044 1514 ns/op 8151.61 MB/s Benchmark____GWs_Opt_4kx10x1-16 2365146 1527 ns/op 8081.20 MB/s Benchmark____GWs_Opt_4kx10x1-16 2222542 1552 ns/op 7954.06 MB/s Benchmark____GWs_Opt_4kx10x1-16 2352475 1541 ns/op 8008.13 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12388088 282.2 ns/op 3685.20 MB/s Benchmark____GWs_Int_1kx01x0-16 11978917 289.7 ns/op 3590.29 MB/s Benchmark____GWs_Int_1kx01x0-16 12356191 289.6 ns/op 3591.32 MB/s Benchmark____GWs_Int_1kx01x0-16 11486168 283.8 ns/op 3664.97 MB/s Benchmark____GWs_Int_1kx01x0-16 12565328 294.6 ns/op 3529.67 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9489855 363.7 ns/op 5675.38 MB/s Benchmark____GWs_Int_2kx01x0-16 10053996 365.4 ns/op 5648.16 MB/s Benchmark____GWs_Int_2kx01x0-16 10378437 360.3 ns/op 5728.76 MB/s Benchmark____GWs_Int_2kx01x0-16 10199473 373.8 ns/op 5522.25 MB/s Benchmark____GWs_Int_2kx01x0-16 9702259 366.1 ns/op 5638.15 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5541747 666.8 ns/op 6166.71 MB/s Benchmark____GWs_Int_4kx01x0-16 5434150 689.2 ns/op 5966.38 MB/s Benchmark____GWs_Int_4kx01x0-16 5594260 678.4 ns/op 6061.16 MB/s Benchmark____GWs_Int_4kx01x0-16 5530514 662.8 ns/op 6203.77 MB/s Benchmark____GWs_Int_4kx01x0-16 5426500 676.5 ns/op 6078.59 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30531150 113.2 ns/op 9184.12 MB/s Benchmark____GWs_Int_1kx10x0-16 31772012 113.2 ns/op 9185.89 MB/s Benchmark____GWs_Int_1kx10x0-16 30773976 112.9 ns/op 9213.01 MB/s Benchmark____GWs_Int_1kx10x0-16 31529302 118.5 ns/op 8774.33 MB/s Benchmark____GWs_Int_1kx10x0-16 31841047 112.4 ns/op 9249.63 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24142651 181.4 ns/op 11376.14 MB/s Benchmark____GWs_Int_2kx10x0-16 25658853 147.9 ns/op 13952.77 MB/s Benchmark____GWs_Int_2kx10x0-16 25855050 150.4 ns/op 13722.33 MB/s Benchmark____GWs_Int_2kx10x0-16 25120756 153.4 ns/op 13459.04 MB/s Benchmark____GWs_Int_2kx10x0-16 25595157 144.1 ns/op 14319.10 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 10564665 300.2 ns/op 13696.51 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:35372->127.0.0.1:39565: 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:50984->127.0.0.1:33871: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12035458 307.2 ns/op 13386.01 MB/s Benchmark____GWs_Int_4kx10x0-16 12526291 285.2 ns/op 14417.66 MB/s Benchmark____GWs_Int_4kx10x0-16 13037079 307.8 ns/op 13359.56 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6446826 561.1 ns/op 5569.58 MB/s Benchmark____GWs_Int_1kx01x1-16 6450420 562.2 ns/op 5558.38 MB/s Benchmark____GWs_Int_1kx01x1-16 6541347 571.3 ns/op 5470.07 MB/s Benchmark____GWs_Int_1kx01x1-16 6293187 561.7 ns/op 5563.62 MB/s Benchmark____GWs_Int_1kx01x1-16 6388789 559.0 ns/op 5589.91 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4709805 842.9 ns/op 7351.79 MB/s Benchmark____GWs_Int_2kx01x1-16 4610773 775.1 ns/op 7995.33 MB/s Benchmark____GWs_Int_2kx01x1-16 4652432 777.1 ns/op 7974.44 MB/s Benchmark____GWs_Int_2kx01x1-16 4670200 767.0 ns/op 8079.39 MB/s Benchmark____GWs_Int_2kx01x1-16 4622793 769.9 ns/op 8049.26 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2594408 1467 ns/op 8412.25 MB/s Benchmark____GWs_Int_4kx01x1-16 2312011 1381 ns/op 8939.43 MB/s Benchmark____GWs_Int_4kx01x1-16 2589289 1402 ns/op 8802.81 MB/s Benchmark____GWs_Int_4kx01x1-16 2214430 1385 ns/op 8911.92 MB/s Benchmark____GWs_Int_4kx01x1-16 2602263 1403 ns/op 8799.27 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6179973 557.7 ns/op 5603.36 MB/s Benchmark____GWs_Int_1kx10x1-16 6500101 560.6 ns/op 5574.51 MB/s Benchmark____GWs_Int_1kx10x1-16 6494950 553.9 ns/op 5642.21 MB/s Benchmark____GWs_Int_1kx10x1-16 6108202 555.2 ns/op 5628.49 MB/s Benchmark____GWs_Int_1kx10x1-16 5704873 557.3 ns/op 5607.37 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4272264 838.1 ns/op 7393.89 MB/s Benchmark____GWs_Int_2kx10x1-16 3876840 857.8 ns/op 7224.52 MB/s Benchmark____GWs_Int_2kx10x1-16 3998364 834.8 ns/op 7423.29 MB/s Benchmark____GWs_Int_2kx10x1-16 4123510 843.6 ns/op 7346.21 MB/s Benchmark____GWs_Int_2kx10x1-16 4228767 837.9 ns/op 7396.07 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2324498 1534 ns/op 8047.15 MB/s Benchmark____GWs_Int_4kx10x1-16 2350855 1542 ns/op 8004.50 MB/s Benchmark____GWs_Int_4kx10x1-16 2094104 1511 ns/op 8166.82 MB/s Benchmark____GWs_Int_4kx10x1-16 2151975 1555 ns/op 7933.85 MB/s Benchmark____GWs_Int_4kx10x1-16 2442420 1528 ns/op 8076.94 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 7772665 450.1 ns/op 226.63 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8320862 453.7 ns/op 224.80 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7766809 438.2 ns/op 232.77 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7879960 446.3 ns/op 228.53 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7978294 470.6 ns/op 216.75 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 739326 4925 ns/op 35.94 MB/s Benchmark__GWs_Reqs_1SubEach-16 783021 5097 ns/op 34.73 MB/s Benchmark__GWs_Reqs_1SubEach-16 754705 5130 ns/op 34.50 MB/s Benchmark__GWs_Reqs_1SubEach-16 732774 5166 ns/op 34.27 MB/s Benchmark__GWs_Reqs_1SubEach-16 758167 5128 ns/op 34.51 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2114.050s ❌ Non-zero exit code: 1