> ROOT_DIR=/tmp/go-bench-away-job-ad4b53ef-62ac-45b2-96b7-4fb98e4943d0-2199312680 > OUTPUT_FILE=/tmp/go-bench-away-job-ad4b53ef-62ac-45b2-96b7-4fb98e4943d0-2199312680/results.txt > SHA_FILE=/tmp/go-bench-away-job-ad4b53ef-62ac-45b2-96b7-4fb98e4943d0-2199312680/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-ad4b53ef-62ac-45b2-96b7-4fb98e4943d0-2199312680/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.26.3/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-ad4b53ef-62ac-45b2-96b7-4fb98e4943d0-2199312680/source.git SHA of main: d998ae7416defc42d7cbfc99c0d9b2ecea20a98f Go runtime: go version go1.26.3 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build4198530191=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-ad4b53ef-62ac-45b2-96b7-4fb98e4943d0-2199312680/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.26.3' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.26.3/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.3' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 49115382 72.20 ns/op 152.35 MB/s Benchmark______Pub0b_Payload-16 47450979 72.11 ns/op 152.55 MB/s Benchmark______Pub0b_Payload-16 47163901 72.17 ns/op 152.43 MB/s Benchmark______Pub0b_Payload-16 47651869 77.59 ns/op 141.77 MB/s Benchmark______Pub0b_Payload-16 45526377 72.63 ns/op 151.46 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46830823 72.73 ns/op 261.23 MB/s Benchmark______Pub8b_Payload-16 46416732 72.80 ns/op 261.00 MB/s Benchmark______Pub8b_Payload-16 46935590 72.77 ns/op 261.11 MB/s Benchmark______Pub8b_Payload-16 46956074 72.67 ns/op 261.47 MB/s Benchmark______Pub8b_Payload-16 49489815 73.23 ns/op 259.46 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44239472 78.12 ns/op 563.25 MB/s Benchmark_____Pub32b_Payload-16 44147796 77.63 ns/op 566.81 MB/s Benchmark_____Pub32b_Payload-16 43950543 77.40 ns/op 568.50 MB/s Benchmark_____Pub32b_Payload-16 43972584 76.91 ns/op 572.12 MB/s Benchmark_____Pub32b_Payload-16 43632397 77.41 ns/op 568.38 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39829801 87.63 ns/op 1609.04 MB/s Benchmark____Pub128B_Payload-16 38537476 88.50 ns/op 1593.25 MB/s Benchmark____Pub128B_Payload-16 38594956 86.81 ns/op 1624.20 MB/s Benchmark____Pub128B_Payload-16 39720589 87.89 ns/op 1604.21 MB/s Benchmark____Pub128B_Payload-16 38091524 88.20 ns/op 1598.56 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36688933 97.09 ns/op 2770.62 MB/s Benchmark____Pub256B_Payload-16 32416256 95.13 ns/op 2827.59 MB/s Benchmark____Pub256B_Payload-16 36132824 96.08 ns/op 2799.71 MB/s Benchmark____Pub256B_Payload-16 35761866 97.41 ns/op 2761.51 MB/s Benchmark____Pub256B_Payload-16 37964900 102.0 ns/op 2637.47 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24446665 137.2 ns/op 7564.14 MB/s Benchmark______Pub1K_Payload-16 24511107 140.2 ns/op 7401.22 MB/s Benchmark______Pub1K_Payload-16 24304988 137.2 ns/op 7564.78 MB/s Benchmark______Pub1K_Payload-16 24248912 144.0 ns/op 7207.47 MB/s Benchmark______Pub1K_Payload-16 24032851 137.6 ns/op 7543.91 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5771828 616.1 ns/op 6671.46 MB/s Benchmark______Pub4K_Payload-16 5636203 625.6 ns/op 6569.23 MB/s Benchmark______Pub4K_Payload-16 5458904 632.9 ns/op 6494.23 MB/s Benchmark______Pub4K_Payload-16 5719446 612.4 ns/op 6711.52 MB/s Benchmark______Pub4K_Payload-16 5548173 616.3 ns/op 6668.69 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2739399 1286 ns/op 6381.71 MB/s Benchmark______Pub8K_Payload-16 2633995 1276 ns/op 6431.70 MB/s Benchmark______Pub8K_Payload-16 2808520 1284 ns/op 6391.17 MB/s Benchmark______Pub8K_Payload-16 2727194 1287 ns/op 6375.36 MB/s Benchmark______Pub8K_Payload-16 2754229 1286 ns/op 6382.68 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 652045 5492 ns/op 5969.10 MB/s Benchmark_____Pub32K_Payload-16 661711 5503 ns/op 5957.69 MB/s Benchmark_____Pub32K_Payload-16 665978 5502 ns/op 5958.86 MB/s Benchmark_____Pub32K_Payload-16 657470 5352 ns/op 6125.26 MB/s Benchmark_____Pub32K_Payload-16 657079 5434 ns/op 6033.07 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32154423 97.59 ns/op 112.71 MB/s Benchmark__AuthPub0b_Payload-16 36200205 94.26 ns/op 116.70 MB/s Benchmark__AuthPub0b_Payload-16 36139680 95.05 ns/op 115.73 MB/s Benchmark__AuthPub0b_Payload-16 36414963 95.11 ns/op 115.66 MB/s Benchmark__AuthPub0b_Payload-16 36153190 96.92 ns/op 113.50 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15442586 231.0 ns/op Benchmark_____________PubSub-16 15605108 229.2 ns/op Benchmark_____________PubSub-16 15466760 229.8 ns/op Benchmark_____________PubSub-16 15332581 229.6 ns/op Benchmark_____________PubSub-16 15162295 230.9 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15389348 229.0 ns/op Benchmark_____PubSubTwoConns-16 15482155 228.6 ns/op Benchmark_____PubSubTwoConns-16 15248196 230.0 ns/op Benchmark_____PubSubTwoConns-16 15508369 228.0 ns/op Benchmark_____PubSubTwoConns-16 15490220 228.7 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51054->127.0.0.1:42753: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:55232->127.0.0.1:40797: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57218->127.0.0.1:39655: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51474->127.0.0.1:33141: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40696->127.0.0.1:33345: 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 14296005 250.0 ns/op Benchmark_____PubTwoQueueSub-16 14145866 250.2 ns/op Benchmark_____PubTwoQueueSub-16 14071108 250.3 ns/op Benchmark_____PubTwoQueueSub-16 14148028 249.3 ns/op Benchmark_____PubTwoQueueSub-16 14312076 249.4 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14161176 250.8 ns/op Benchmark____PubFourQueueSub-16 14163153 250.6 ns/op Benchmark____PubFourQueueSub-16 14141835 251.2 ns/op Benchmark____PubFourQueueSub-16 14068768 249.6 ns/op Benchmark____PubFourQueueSub-16 14084406 248.8 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14130477 250.7 ns/op Benchmark___PubEightQueueSub-16 14193916 250.7 ns/op Benchmark___PubEightQueueSub-16 14111940 250.3 ns/op Benchmark___PubEightQueueSub-16 14041950 251.6 ns/op Benchmark___PubEightQueueSub-16 14206792 251.3 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22864 158319 ns/op Benchmark_PubSub512kTwoConns-16 22987 156410 ns/op Benchmark_PubSub512kTwoConns-16 22749 156878 ns/op Benchmark_PubSub512kTwoConns-16 22930 165963 ns/op Benchmark_PubSub512kTwoConns-16 22772 155189 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15200208 231.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15139711 231.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15057754 231.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15319647 231.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15113566 229.9 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15101490 230.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15125077 231.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15135574 231.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 14953150 231.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15098581 231.6 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11607751 311.6 ns/op Benchmark____RoutedPubSub_0b-16 11095321 311.0 ns/op Benchmark____RoutedPubSub_0b-16 11399377 311.2 ns/op Benchmark____RoutedPubSub_0b-16 11430568 310.7 ns/op Benchmark____RoutedPubSub_0b-16 11816059 312.3 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6603123 532.4 ns/op Benchmark____RoutedPubSub_1K-16 6605814 543.3 ns/op Benchmark____RoutedPubSub_1K-16 6582637 535.2 ns/op Benchmark____RoutedPubSub_1K-16 6836397 536.1 ns/op Benchmark____RoutedPubSub_1K-16 6689346 533.6 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 82725 42215 ns/op Benchmark__RoutedPubSub_100K-16 84350 44706 ns/op Benchmark__RoutedPubSub_100K-16 81070 46524 ns/op Benchmark__RoutedPubSub_100K-16 83174 42426 ns/op Benchmark__RoutedPubSub_100K-16 83739 45682 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9694195 317.9 ns/op Benchmark____Routed2QueueSub-16 9769951 317.1 ns/op Benchmark____Routed2QueueSub-16 9752208 316.5 ns/op Benchmark____Routed2QueueSub-16 9488869 320.7 ns/op Benchmark____Routed2QueueSub-16 9766533 319.9 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9670821 319.4 ns/op Benchmark____Routed4QueueSub-16 9530742 330.6 ns/op Benchmark____Routed4QueueSub-16 11222970 319.9 ns/op Benchmark____Routed4QueueSub-16 9740419 322.4 ns/op Benchmark____Routed4QueueSub-16 9607052 324.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9185761 334.9 ns/op Benchmark____Routed8QueueSub-16 9255548 328.1 ns/op Benchmark____Routed8QueueSub-16 9127773 329.3 ns/op Benchmark____Routed8QueueSub-16 9349030 330.3 ns/op Benchmark____Routed8QueueSub-16 9361867 331.2 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8917962 342.3 ns/op Benchmark___Routed16QueueSub-16 10309158 346.6 ns/op Benchmark___Routed16QueueSub-16 9065001 351.3 ns/op Benchmark___Routed16QueueSub-16 8818708 346.5 ns/op Benchmark___Routed16QueueSub-16 8752190 351.4 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6412850 549.0 ns/op Benchmark____________RouteCompressOff-16 6372192 555.6 ns/op Benchmark____________RouteCompressOff-16 6541456 546.2 ns/op Benchmark____________RouteCompressOff-16 6588318 544.8 ns/op Benchmark____________RouteCompressOff-16 6303744 545.7 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6573094 550.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6526555 542.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6288595 544.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6491514 547.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6538225 554.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6310399 548.5 ns/op Benchmark_________RouteCompressS2Fast-16 6620744 547.3 ns/op Benchmark_________RouteCompressS2Fast-16 6594978 544.3 ns/op Benchmark_________RouteCompressS2Fast-16 6506304 542.1 ns/op Benchmark_________RouteCompressS2Fast-16 6571086 545.5 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6369422 544.2 ns/op Benchmark_______RouteCompressS2Better-16 6563412 551.6 ns/op Benchmark_______RouteCompressS2Better-16 6443112 543.1 ns/op Benchmark_______RouteCompressS2Better-16 6543340 547.6 ns/op Benchmark_______RouteCompressS2Better-16 6398408 543.9 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6391378 554.2 ns/op Benchmark_________RouteCompressS2Best-16 6442460 546.6 ns/op Benchmark_________RouteCompressS2Best-16 6390132 543.4 ns/op Benchmark_________RouteCompressS2Best-16 6577641 540.6 ns/op Benchmark_________RouteCompressS2Best-16 6458685 545.9 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4654489 771.6 ns/op 322.71 MB/s Benchmark______FanOut_8x1x10-16 4633606 772.1 ns/op 322.49 MB/s Benchmark______FanOut_8x1x10-16 4645512 768.9 ns/op 323.84 MB/s Benchmark______FanOut_8x1x10-16 4654850 772.3 ns/op 322.43 MB/s Benchmark______FanOut_8x1x10-16 4691262 769.7 ns/op 323.52 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 543650 6153 ns/op 376.92 MB/s Benchmark_____FanOut_8x1x100-16 549361 6105 ns/op 379.84 MB/s Benchmark_____FanOut_8x1x100-16 541599 6183 ns/op 375.09 MB/s Benchmark_____FanOut_8x1x100-16 519883 6124 ns/op 378.66 MB/s Benchmark_____FanOut_8x1x100-16 531932 6178 ns/op 375.38 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48336 74722 ns/op 308.06 MB/s Benchmark____FanOut_8x10x100-16 47668 75416 ns/op 305.23 MB/s Benchmark____FanOut_8x10x100-16 48067 75425 ns/op 305.19 MB/s Benchmark____FanOut_8x10x100-16 47928 74750 ns/op 307.95 MB/s Benchmark____FanOut_8x10x100-16 48021 75231 ns/op 305.98 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5610 604847 ns/op 396.83 MB/s Benchmark___FanOut_8x10x1000-16 5654 603049 ns/op 398.01 MB/s Benchmark___FanOut_8x10x1000-16 6136 597491 ns/op 401.71 MB/s Benchmark___FanOut_8x10x1000-16 6002 607656 ns/op 394.99 MB/s Benchmark___FanOut_8x10x1000-16 5797 604666 ns/op 396.94 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4983 714793 ns/op 321.80 MB/s Benchmark___FanOut_8x100x100-16 5011 707665 ns/op 325.04 MB/s Benchmark___FanOut_8x100x100-16 5018 714405 ns/op 321.97 MB/s Benchmark___FanOut_8x100x100-16 5006 705845 ns/op 325.88 MB/s Benchmark___FanOut_8x100x100-16 4928 704744 ns/op 326.39 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 566 6106884 ns/op 393.00 MB/s Benchmark__FanOut_8x100x1000-16 574 6151597 ns/op 390.15 MB/s Benchmark__FanOut_8x100x1000-16 572 6245040 ns/op 384.31 MB/s Benchmark__FanOut_8x100x1000-16 579 6359094 ns/op 377.42 MB/s Benchmark__FanOut_8x100x1000-16 582 6136653 ns/op 391.10 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 512 6795707 ns/op 367.88 MB/s Benchmark__FanOut_8x10x10000-16 528 6704934 ns/op 372.86 MB/s Benchmark__FanOut_8x10x10000-16 531 6731132 ns/op 371.41 MB/s Benchmark__FanOut_8x10x10000-16 543 6702052 ns/op 373.02 MB/s Benchmark__FanOut_8x10x10000-16 520 6858699 ns/op 364.50 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 955 3756111 ns/op 306.17 MB/s Benchmark___FanOut_8x500x100-16 956 3790848 ns/op 303.37 MB/s Benchmark___FanOut_8x500x100-16 934 3755652 ns/op 306.21 MB/s Benchmark___FanOut_8x500x100-16 946 3744545 ns/op 307.12 MB/s Benchmark___FanOut_8x500x100-16 955 3757911 ns/op 306.03 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 366832 9526 ns/op 1536.87 MB/s Benchmark___FanOut_128x1x100-16 369300 9416 ns/op 1554.97 MB/s Benchmark___FanOut_128x1x100-16 359138 9389 ns/op 1559.45 MB/s Benchmark___FanOut_128x1x100-16 366054 9512 ns/op 1539.23 MB/s Benchmark___FanOut_128x1x100-16 368211 9428 ns/op 1552.92 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32464 110441 ns/op 1314.20 MB/s Benchmark__FanOut_128x10x100-16 32562 110097 ns/op 1318.30 MB/s Benchmark__FanOut_128x10x100-16 32420 110402 ns/op 1314.66 MB/s Benchmark__FanOut_128x10x100-16 32564 110928 ns/op 1308.43 MB/s Benchmark__FanOut_128x10x100-16 32683 110898 ns/op 1308.78 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3984 865917 ns/op 1686.24 MB/s Benchmark_FanOut_128x10x1000-16 4123 876489 ns/op 1665.90 MB/s Benchmark_FanOut_128x10x1000-16 4021 872684 ns/op 1673.16 MB/s Benchmark_FanOut_128x10x1000-16 4107 866848 ns/op 1684.43 MB/s Benchmark_FanOut_128x10x1000-16 4053 866229 ns/op 1685.63 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3538 1011412 ns/op 1433.78 MB/s Benchmark_FanOut_128x100x100-16 3499 1007222 ns/op 1439.74 MB/s Benchmark_FanOut_128x100x100-16 3612 1013739 ns/op 1430.49 MB/s Benchmark_FanOut_128x100x100-16 3526 1005137 ns/op 1442.73 MB/s Benchmark_FanOut_128x100x100-16 3471 1011570 ns/op 1433.56 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 393 9154859 ns/op 1594.80 MB/s BenchmarkFanOut_128x100x1000-16 384 9331724 ns/op 1564.57 MB/s BenchmarkFanOut_128x100x1000-16 381 9320331 ns/op 1566.48 MB/s BenchmarkFanOut_128x100x1000-16 386 9159759 ns/op 1593.94 MB/s BenchmarkFanOut_128x100x1000-16 386 9213128 ns/op 1584.71 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 376 9568700 ns/op 1536.27 MB/s BenchmarkFanOut_128x10x10000-16 373 9579282 ns/op 1534.58 MB/s BenchmarkFanOut_128x10x10000-16 374 9571830 ns/op 1535.77 MB/s BenchmarkFanOut_128x10x10000-16 375 9580647 ns/op 1534.36 MB/s BenchmarkFanOut_128x10x10000-16 369 9603666 ns/op 1530.68 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 674 5268706 ns/op 1376.08 MB/s BenchmarkFanOut__128x500x100-16 678 5248424 ns/op 1381.39 MB/s BenchmarkFanOut__128x500x100-16 673 5267721 ns/op 1376.33 MB/s BenchmarkFanOut__128x500x100-16 674 5258524 ns/op 1378.74 MB/s BenchmarkFanOut__128x500x100-16 678 5257734 ns/op 1378.95 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1948 1821473 ns/op 2904.53 MB/s Benchmark_FanOut_512x100x100-16 1950 1828561 ns/op 2893.27 MB/s Benchmark_FanOut_512x100x100-16 1917 1824144 ns/op 2900.28 MB/s Benchmark_FanOut_512x100x100-16 1984 1827959 ns/op 2894.22 MB/s Benchmark_FanOut_512x100x100-16 1918 1830095 ns/op 2890.85 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 219 16573444 ns/op 3197.92 MB/s Benchmark__FanOut_512x100x1k-16 216 16616345 ns/op 3189.66 MB/s Benchmark__FanOut_512x100x1k-16 219 16822334 ns/op 3150.60 MB/s Benchmark__FanOut_512x100x1k-16 214 16618592 ns/op 3189.23 MB/s Benchmark__FanOut_512x100x1k-16 214 16611983 ns/op 3190.50 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3104 1162731 ns/op 8971.15 MB/s Benchmark____FanOut_1kx10x1k-16 3121 1157534 ns/op 9011.43 MB/s Benchmark____FanOut_1kx10x1k-16 2979 1133287 ns/op 9204.23 MB/s Benchmark____FanOut_1kx10x1k-16 2986 1125316 ns/op 9269.43 MB/s Benchmark____FanOut_1kx10x1k-16 3102 1159721 ns/op 8994.44 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2742 1256883 ns/op 8291.18 MB/s Benchmark__FanOut_1kx100x100-16 2743 1259821 ns/op 8271.84 MB/s Benchmark__FanOut_1kx100x100-16 2814 1259087 ns/op 8276.66 MB/s Benchmark__FanOut_1kx100x100-16 2822 1257929 ns/op 8284.28 MB/s Benchmark__FanOut_1kx100x100-16 2778 1252614 ns/op 8319.43 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4492606 774.9 ns/op 321.34 MB/s Benchmark_____RFanOut_8x1x10-16 4572038 777.2 ns/op 320.37 MB/s Benchmark_____RFanOut_8x1x10-16 4470318 781.2 ns/op 318.73 MB/s Benchmark_____RFanOut_8x1x10-16 4419388 789.4 ns/op 315.41 MB/s Benchmark_____RFanOut_8x1x10-16 4444737 804.8 ns/op 309.39 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 533750 6089 ns/op 380.86 MB/s Benchmark____RFanOut_8x1x100-16 547428 6316 ns/op 367.16 MB/s Benchmark____RFanOut_8x1x100-16 545311 6379 ns/op 363.51 MB/s Benchmark____RFanOut_8x1x100-16 521358 6342 ns/op 365.68 MB/s Benchmark____RFanOut_8x1x100-16 514810 6091 ns/op 380.75 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47928 74891 ns/op 307.37 MB/s Benchmark___RFanOut_8x10x100-16 47312 74558 ns/op 308.74 MB/s Benchmark___RFanOut_8x10x100-16 48176 74949 ns/op 307.13 MB/s Benchmark___RFanOut_8x10x100-16 47844 74602 ns/op 308.56 MB/s Benchmark___RFanOut_8x10x100-16 47816 74766 ns/op 307.88 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6068 596187 ns/op 402.59 MB/s Benchmark__RFanOut_8x10x1000-16 5871 602115 ns/op 398.63 MB/s Benchmark__RFanOut_8x10x1000-16 5986 599033 ns/op 400.68 MB/s Benchmark__RFanOut_8x10x1000-16 5984 597440 ns/op 401.75 MB/s Benchmark__RFanOut_8x10x1000-16 5619 600347 ns/op 399.80 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4909 708926 ns/op 324.46 MB/s Benchmark__RFanOut_8x100x100-16 4983 706174 ns/op 325.73 MB/s Benchmark__RFanOut_8x100x100-16 5048 706586 ns/op 325.54 MB/s Benchmark__RFanOut_8x100x100-16 5013 707284 ns/op 325.21 MB/s Benchmark__RFanOut_8x100x100-16 5005 709020 ns/op 324.42 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 566 6154615 ns/op 389.95 MB/s Benchmark_RFanOut_8x100x1000-16 582 6100729 ns/op 393.40 MB/s Benchmark_RFanOut_8x100x1000-16 574 6231105 ns/op 385.17 MB/s Benchmark_RFanOut_8x100x1000-16 567 6288150 ns/op 381.67 MB/s Benchmark_RFanOut_8x100x1000-16 588 6179922 ns/op 388.36 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 540 6765790 ns/op 369.51 MB/s Benchmark_RFanOut_8x10x10000-16 543 6804122 ns/op 367.43 MB/s Benchmark_RFanOut_8x10x10000-16 526 6811055 ns/op 367.05 MB/s Benchmark_RFanOut_8x10x10000-16 536 6649900 ns/op 375.95 MB/s Benchmark_RFanOut_8x10x10000-16 540 6710718 ns/op 372.54 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2878 1172136 ns/op 8899.17 MB/s Benchmark_RFanOut_1kx10x1000-16 3172 1154885 ns/op 9032.10 MB/s Benchmark_RFanOut_1kx10x1000-16 2814 1155693 ns/op 9025.78 MB/s Benchmark_RFanOut_1kx10x1000-16 2859 1158918 ns/op 9000.67 MB/s Benchmark_RFanOut_1kx10x1000-16 2839 1165848 ns/op 8947.17 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7029024 506.7 ns/op 4100.73 MB/s Benchmark_____FanIn_1kx100x1-16 6968889 502.1 ns/op 4138.61 MB/s Benchmark_____FanIn_1kx100x1-16 7021363 503.0 ns/op 4131.02 MB/s Benchmark_____FanIn_1kx100x1-16 7071874 503.4 ns/op 4127.79 MB/s Benchmark_____FanIn_1kx100x1-16 6976635 505.4 ns/op 4111.61 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2624018 1357 ns/op 6057.40 MB/s Benchmark_____FanIn_4kx100x1-16 2641603 1347 ns/op 6104.70 MB/s Benchmark_____FanIn_4kx100x1-16 2671785 1359 ns/op 6048.39 MB/s Benchmark_____FanIn_4kx100x1-16 2595938 1379 ns/op 5963.37 MB/s Benchmark_____FanIn_4kx100x1-16 2597900 1328 ns/op 6189.79 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1708172 2128 ns/op 7714.09 MB/s Benchmark_____FanIn_8kx100x1-16 1692847 2115 ns/op 7761.32 MB/s Benchmark_____FanIn_8kx100x1-16 1702749 2108 ns/op 7785.46 MB/s Benchmark_____FanIn_8kx100x1-16 1729423 2096 ns/op 7830.35 MB/s Benchmark_____FanIn_8kx100x1-16 1729615 2134 ns/op 7692.74 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 865887 4129 ns/op 7943.96 MB/s Benchmark____FanIn_16kx100x1-16 873963 4101 ns/op 7998.16 MB/s Benchmark____FanIn_16kx100x1-16 864650 4146 ns/op 7911.56 MB/s Benchmark____FanIn_16kx100x1-16 880365 4186 ns/op 7835.41 MB/s Benchmark____FanIn_16kx100x1-16 872953 4137 ns/op 7927.74 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 168342 19619 ns/op 6682.51 MB/s Benchmark____FanIn_64kx100x1-16 167989 19597 ns/op 6690.10 MB/s Benchmark____FanIn_64kx100x1-16 167883 19810 ns/op 6618.17 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 9750353220 vs 11111233500 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54250->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53398->127.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:53668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53892->127.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:54124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54072->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53988->127.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:53770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53474->127.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:53790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53742->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:54052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:53490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53928->127.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 Benchmark____FanIn_64kx100x1-16 159433 19746 ns/op 6639.46 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 950795770 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37180->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: 689140130 vs 11431048000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40432->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: 110246690 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42180->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:41906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42348->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: 1018307120 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43938->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: 859557130 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45982->127.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:46082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:45974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45766->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5643495 637.7 ns/op 445.38 MB/s Benchmark___BumpPubCount_1x3-16 5675468 632.4 ns/op 449.11 MB/s Benchmark___BumpPubCount_1x3-16 5587280 636.2 ns/op 446.37 MB/s Benchmark___BumpPubCount_1x3-16 5663185 638.5 ns/op 444.81 MB/s Benchmark___BumpPubCount_1x3-16 5608338 638.4 ns/op 444.89 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5302849 672.6 ns/op 422.24 MB/s Benchmark___BumpPubCount_2x3-16 5326394 671.6 ns/op 422.87 MB/s Benchmark___BumpPubCount_2x3-16 5336719 669.5 ns/op 424.23 MB/s Benchmark___BumpPubCount_2x3-16 5296312 668.8 ns/op 424.65 MB/s Benchmark___BumpPubCount_2x3-16 5342070 674.0 ns/op 421.40 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5568416 642.1 ns/op 442.31 MB/s Benchmark___BumpPubCount_5x3-16 5583052 638.0 ns/op 445.14 MB/s Benchmark___BumpPubCount_5x3-16 5371690 639.4 ns/op 444.20 MB/s Benchmark___BumpPubCount_5x3-16 5552948 639.7 ns/op 443.93 MB/s Benchmark___BumpPubCount_5x3-16 5585030 642.5 ns/op 442.05 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5588827 642.4 ns/op 442.06 MB/s Benchmark__BumpPubCount_10x3-16 5573676 642.0 ns/op 442.35 MB/s Benchmark__BumpPubCount_10x3-16 5610650 641.7 ns/op 442.58 MB/s Benchmark__BumpPubCount_10x3-16 5626087 639.3 ns/op 444.24 MB/s Benchmark__BumpPubCount_10x3-16 5596596 640.8 ns/op 443.19 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11921590 281.4 ns/op 3695.35 MB/s Benchmark____GWs_Opt_1kx01x0-16 12333920 269.2 ns/op 3863.91 MB/s Benchmark____GWs_Opt_1kx01x0-16 13118070 270.9 ns/op 3838.55 MB/s Benchmark____GWs_Opt_1kx01x0-16 13135944 276.2 ns/op 3764.71 MB/s Benchmark____GWs_Opt_1kx01x0-16 12495882 270.1 ns/op 3850.90 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10499370 345.5 ns/op 5974.43 MB/s Benchmark____GWs_Opt_2kx01x0-16 10414365 343.7 ns/op 6005.45 MB/s Benchmark____GWs_Opt_2kx01x0-16 10260420 325.6 ns/op 6339.58 MB/s Benchmark____GWs_Opt_2kx01x0-16 9176374 343.6 ns/op 6006.58 MB/s Benchmark____GWs_Opt_2kx01x0-16 10186890 355.3 ns/op 5809.20 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5802826 613.3 ns/op 6704.77 MB/s Benchmark____GWs_Opt_4kx01x0-16 5763705 638.3 ns/op 6442.12 MB/s Benchmark____GWs_Opt_4kx01x0-16 5656561 622.3 ns/op 6607.50 MB/s Benchmark____GWs_Opt_4kx01x0-16 5693410 621.5 ns/op 6615.98 MB/s Benchmark____GWs_Opt_4kx01x0-16 5788639 648.6 ns/op 6340.10 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 27981423 113.1 ns/op 9192.13 MB/s Benchmark____GWs_Opt_1kx10x0-16 32602398 112.2 ns/op 9272.08 MB/s Benchmark____GWs_Opt_1kx10x0-16 31007158 114.2 ns/op 9110.62 MB/s Benchmark____GWs_Opt_1kx10x0-16 26821210 113.9 ns/op 9134.00 MB/s Benchmark____GWs_Opt_1kx10x0-16 31117478 119.4 ns/op 8711.83 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24972262 160.7 ns/op 12842.95 MB/s Benchmark____GWs_Opt_2kx10x0-16 21388220 150.4 ns/op 13723.99 MB/s Benchmark____GWs_Opt_2kx10x0-16 24165392 144.4 ns/op 14294.73 MB/s Benchmark____GWs_Opt_2kx10x0-16 23716286 151.1 ns/op 13661.36 MB/s Benchmark____GWs_Opt_2kx10x0-16 21919245 148.2 ns/op 13931.27 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12833407 371.8 ns/op 11058.71 MB/s Benchmark____GWs_Opt_4kx10x0-16 12365620 296.2 ns/op 13881.42 MB/s Benchmark____GWs_Opt_4kx10x0-16 10575993 313.5 ns/op 13117.19 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:36050->127.0.0.1:38385: i/o timeout bench_test.go:167: Did not receive all bytes: 176 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:52228->127.0.0.1:35075: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:52170->127.0.0.1:35075: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 12808740 307.1 ns/op 13387.75 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6520555 537.1 ns/op 5818.50 MB/s Benchmark____GWs_Opt_1kx01x1-16 6733695 540.3 ns/op 5783.47 MB/s Benchmark____GWs_Opt_1kx01x1-16 6460504 544.4 ns/op 5740.46 MB/s Benchmark____GWs_Opt_1kx01x1-16 6529771 762.3 ns/op 4099.20 MB/s Benchmark____GWs_Opt_1kx01x1-16 6469717 542.5 ns/op 5760.03 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4677070 751.9 ns/op 8242.20 MB/s Benchmark____GWs_Opt_2kx01x1-16 4848291 757.6 ns/op 8180.23 MB/s Benchmark____GWs_Opt_2kx01x1-16 4645543 762.2 ns/op 8130.46 MB/s Benchmark____GWs_Opt_2kx01x1-16 4810129 754.3 ns/op 8215.79 MB/s Benchmark____GWs_Opt_2kx01x1-16 4622355 752.3 ns/op 8236.89 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2640723 1374 ns/op 8979.70 MB/s Benchmark____GWs_Opt_4kx01x1-16 2671117 1362 ns/op 9063.99 MB/s Benchmark____GWs_Opt_4kx01x1-16 2580998 1366 ns/op 9031.96 MB/s Benchmark____GWs_Opt_4kx01x1-16 2296882 1351 ns/op 9133.88 MB/s Benchmark____GWs_Opt_4kx01x1-16 2654382 1354 ns/op 9113.80 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6205615 556.2 ns/op 5618.07 MB/s Benchmark____GWs_Opt_1kx10x1-16 6532512 550.7 ns/op 5674.45 MB/s Benchmark____GWs_Opt_1kx10x1-16 6466550 559.0 ns/op 5589.89 MB/s Benchmark____GWs_Opt_1kx10x1-16 5933433 585.9 ns/op 5333.75 MB/s Benchmark____GWs_Opt_1kx10x1-16 6659113 552.6 ns/op 5655.45 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4732786 842.9 ns/op 7352.18 MB/s Benchmark____GWs_Opt_2kx10x1-16 4209834 918.0 ns/op 6750.91 MB/s Benchmark____GWs_Opt_2kx10x1-16 4048546 840.2 ns/op 7375.86 MB/s Benchmark____GWs_Opt_2kx10x1-16 4093506 844.2 ns/op 7340.60 MB/s Benchmark____GWs_Opt_2kx10x1-16 4292514 857.3 ns/op 7228.82 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2293954 1574 ns/op 7841.05 MB/s Benchmark____GWs_Opt_4kx10x1-16 2345845 1541 ns/op 8010.76 MB/s Benchmark____GWs_Opt_4kx10x1-16 2421975 1539 ns/op 8017.66 MB/s Benchmark____GWs_Opt_4kx10x1-16 2281560 1503 ns/op 8211.25 MB/s Benchmark____GWs_Opt_4kx10x1-16 2378529 1514 ns/op 8151.10 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12552872 293.8 ns/op 3540.29 MB/s Benchmark____GWs_Int_1kx01x0-16 12049748 280.6 ns/op 3706.71 MB/s Benchmark____GWs_Int_1kx01x0-16 12746913 279.6 ns/op 3720.11 MB/s Benchmark____GWs_Int_1kx01x0-16 12094040 285.0 ns/op 3649.47 MB/s Benchmark____GWs_Int_1kx01x0-16 12744789 289.4 ns/op 3593.43 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10024910 331.7 ns/op 6222.97 MB/s Benchmark____GWs_Int_2kx01x0-16 9979005 357.0 ns/op 5781.80 MB/s Benchmark____GWs_Int_2kx01x0-16 9974876 363.7 ns/op 5674.73 MB/s Benchmark____GWs_Int_2kx01x0-16 10837047 350.6 ns/op 5887.44 MB/s Benchmark____GWs_Int_2kx01x0-16 10668157 353.3 ns/op 5842.28 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5342668 644.9 ns/op 6376.58 MB/s Benchmark____GWs_Int_4kx01x0-16 5694649 606.1 ns/op 6784.20 MB/s Benchmark____GWs_Int_4kx01x0-16 5718013 630.1 ns/op 6526.15 MB/s Benchmark____GWs_Int_4kx01x0-16 5785215 745.0 ns/op 5519.79 MB/s Benchmark____GWs_Int_4kx01x0-16 5762863 616.3 ns/op 6672.14 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32069830 123.1 ns/op 8449.71 MB/s Benchmark____GWs_Int_1kx10x0-16 31302727 115.0 ns/op 9046.07 MB/s Benchmark____GWs_Int_1kx10x0-16 31846072 112.6 ns/op 9238.15 MB/s Benchmark____GWs_Int_1kx10x0-16 31277136 116.6 ns/op 8917.94 MB/s Benchmark____GWs_Int_1kx10x0-16 31590067 115.5 ns/op 9005.80 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25888672 147.0 ns/op 14043.42 MB/s Benchmark____GWs_Int_2kx10x0-16 25003090 142.6 ns/op 14478.30 MB/s Benchmark____GWs_Int_2kx10x0-16 21586053 167.6 ns/op 12316.67 MB/s Benchmark____GWs_Int_2kx10x0-16 22025912 142.2 ns/op 14512.06 MB/s Benchmark____GWs_Int_2kx10x0-16 26007009 143.9 ns/op 14346.79 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 7434487 427.4 ns/op 9621.29 MB/s Benchmark____GWs_Int_4kx10x0-16 12506644 296.6 ns/op 13864.83 MB/s Benchmark____GWs_Int_4kx10x0-16 13324317 280.2 ns/op 14674.63 MB/s Benchmark____GWs_Int_4kx10x0-16 9284719 347.9 ns/op 11821.00 MB/s Benchmark____GWs_Int_4kx10x0-16 13182592 297.0 ns/op 13843.71 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6563500 543.8 ns/op 5746.13 MB/s Benchmark____GWs_Int_1kx01x1-16 6561753 549.0 ns/op 5692.55 MB/s Benchmark____GWs_Int_1kx01x1-16 6521058 563.1 ns/op 5550.06 MB/s Benchmark____GWs_Int_1kx01x1-16 6625664 550.6 ns/op 5675.93 MB/s Benchmark____GWs_Int_1kx01x1-16 6565932 549.8 ns/op 5683.82 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4874646 765.1 ns/op 8099.41 MB/s Benchmark____GWs_Int_2kx01x1-16 4675549 830.2 ns/op 7464.22 MB/s Benchmark____GWs_Int_2kx01x1-16 4702269 760.2 ns/op 8151.94 MB/s Benchmark____GWs_Int_2kx01x1-16 4744226 796.6 ns/op 7779.56 MB/s Benchmark____GWs_Int_2kx01x1-16 4655560 764.5 ns/op 8106.44 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2462836 1694 ns/op 7286.05 MB/s Benchmark____GWs_Int_4kx01x1-16 2624097 1777 ns/op 6943.45 MB/s Benchmark____GWs_Int_4kx01x1-16 2271240 1461 ns/op 8445.64 MB/s Benchmark____GWs_Int_4kx01x1-16 2658118 1407 ns/op 8772.49 MB/s Benchmark____GWs_Int_4kx01x1-16 2640464 1366 ns/op 9035.51 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6250604 620.5 ns/op 5036.06 MB/s Benchmark____GWs_Int_1kx10x1-16 6307620 604.1 ns/op 5172.80 MB/s Benchmark____GWs_Int_1kx10x1-16 6421606 556.4 ns/op 5616.59 MB/s Benchmark____GWs_Int_1kx10x1-16 6640442 546.9 ns/op 5713.70 MB/s Benchmark____GWs_Int_1kx10x1-16 6519034 556.2 ns/op 5618.07 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4193154 836.0 ns/op 7412.94 MB/s Benchmark____GWs_Int_2kx10x1-16 4113411 852.3 ns/op 7270.88 MB/s Benchmark____GWs_Int_2kx10x1-16 3825925 849.0 ns/op 7298.96 MB/s Benchmark____GWs_Int_2kx10x1-16 4093274 896.8 ns/op 6910.18 MB/s Benchmark____GWs_Int_2kx10x1-16 4206436 840.4 ns/op 7373.85 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2346580 1654 ns/op 7461.73 MB/s Benchmark____GWs_Int_4kx10x1-16 2152345 1522 ns/op 8106.32 MB/s Benchmark____GWs_Int_4kx10x1-16 2404830 1515 ns/op 8146.76 MB/s Benchmark____GWs_Int_4kx10x1-16 2289658 1655 ns/op 7455.66 MB/s Benchmark____GWs_Int_4kx10x1-16 2355973 1522 ns/op 8106.98 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8156184 432.7 ns/op 235.70 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8322073 433.8 ns/op 235.11 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8436860 436.2 ns/op 233.86 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8470124 431.2 ns/op 236.55 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8427241 483.8 ns/op 210.85 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 622882 5036 ns/op 35.15 MB/s Benchmark__GWs_Reqs_1SubEach-16 759506 5240 ns/op 33.78 MB/s Benchmark__GWs_Reqs_1SubEach-16 741434 5301 ns/op 33.39 MB/s Benchmark__GWs_Reqs_1SubEach-16 755522 5310 ns/op 33.34 MB/s Benchmark__GWs_Reqs_1SubEach-16 740109 5334 ns/op 33.18 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2089.515s ❌ Non-zero exit code: 1