> ROOT_DIR=/tmp/go-bench-away-job-ee9355e1-311a-43a3-904d-b0dc2a1bc7b7-4046085309 > OUTPUT_FILE=/tmp/go-bench-away-job-ee9355e1-311a-43a3-904d-b0dc2a1bc7b7-4046085309/results.txt > SHA_FILE=/tmp/go-bench-away-job-ee9355e1-311a-43a3-904d-b0dc2a1bc7b7-4046085309/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-ee9355e1-311a-43a3-904d-b0dc2a1bc7b7-4046085309/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-ee9355e1-311a-43a3-904d-b0dc2a1bc7b7-4046085309/source.git SHA of main: 417a07dae4cfc2a5519f135776cc63c50e651c10 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-build235841501=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-ee9355e1-311a-43a3-904d-b0dc2a1bc7b7-4046085309/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 48453712 73.65 ns/op 149.36 MB/s Benchmark______Pub0b_Payload-16 46328802 74.30 ns/op 148.04 MB/s Benchmark______Pub0b_Payload-16 46107356 74.08 ns/op 148.48 MB/s Benchmark______Pub0b_Payload-16 46302297 73.84 ns/op 148.96 MB/s Benchmark______Pub0b_Payload-16 46439508 73.88 ns/op 148.88 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45788601 74.62 ns/op 254.62 MB/s Benchmark______Pub8b_Payload-16 45494480 74.65 ns/op 254.53 MB/s Benchmark______Pub8b_Payload-16 45818622 74.50 ns/op 255.04 MB/s Benchmark______Pub8b_Payload-16 42730053 74.70 ns/op 254.34 MB/s Benchmark______Pub8b_Payload-16 48270282 74.11 ns/op 256.36 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43403374 78.97 ns/op 557.18 MB/s Benchmark_____Pub32b_Payload-16 43187377 81.99 ns/op 536.62 MB/s Benchmark_____Pub32b_Payload-16 43289354 82.85 ns/op 531.05 MB/s Benchmark_____Pub32b_Payload-16 45144517 78.67 ns/op 559.33 MB/s Benchmark_____Pub32b_Payload-16 42322021 78.92 ns/op 557.51 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38769693 90.21 ns/op 1563.07 MB/s Benchmark____Pub128B_Payload-16 34080625 89.28 ns/op 1579.38 MB/s Benchmark____Pub128B_Payload-16 37216914 89.68 ns/op 1572.33 MB/s Benchmark____Pub128B_Payload-16 34090171 88.48 ns/op 1593.66 MB/s Benchmark____Pub128B_Payload-16 34075140 89.18 ns/op 1581.15 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35538561 95.96 ns/op 2803.19 MB/s Benchmark____Pub256B_Payload-16 31393126 98.25 ns/op 2737.90 MB/s Benchmark____Pub256B_Payload-16 35145112 96.92 ns/op 2775.49 MB/s Benchmark____Pub256B_Payload-16 31268874 96.10 ns/op 2799.19 MB/s Benchmark____Pub256B_Payload-16 31072692 98.55 ns/op 2729.66 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24563767 147.8 ns/op 7023.56 MB/s Benchmark______Pub1K_Payload-16 22994632 147.1 ns/op 7054.13 MB/s Benchmark______Pub1K_Payload-16 23973606 136.5 ns/op 7605.54 MB/s Benchmark______Pub1K_Payload-16 24120214 151.9 ns/op 6832.32 MB/s Benchmark______Pub1K_Payload-16 25043911 146.1 ns/op 7105.77 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5804154 623.2 ns/op 6595.36 MB/s Benchmark______Pub4K_Payload-16 5451751 622.0 ns/op 6608.16 MB/s Benchmark______Pub4K_Payload-16 5700574 624.8 ns/op 6577.99 MB/s Benchmark______Pub4K_Payload-16 5542004 627.0 ns/op 6554.74 MB/s Benchmark______Pub4K_Payload-16 5606672 615.2 ns/op 6680.88 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2626323 1287 ns/op 6374.66 MB/s Benchmark______Pub8K_Payload-16 2713248 1266 ns/op 6483.08 MB/s Benchmark______Pub8K_Payload-16 2640242 1282 ns/op 6400.34 MB/s Benchmark______Pub8K_Payload-16 2706579 1280 ns/op 6411.43 MB/s Benchmark______Pub8K_Payload-16 2791396 1292 ns/op 6352.27 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 551962 11801 ns/op 2778.00 MB/s Benchmark_____Pub32K_Payload-16 565435 5459 ns/op 6005.74 MB/s Benchmark_____Pub32K_Payload-16 669379 5313 ns/op 6170.54 MB/s Benchmark_____Pub32K_Payload-16 663518 5494 ns/op 5967.02 MB/s Benchmark_____Pub32K_Payload-16 653937 5547 ns/op 5910.02 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31640856 95.58 ns/op 115.08 MB/s Benchmark__AuthPub0b_Payload-16 32404201 95.72 ns/op 114.91 MB/s Benchmark__AuthPub0b_Payload-16 31998483 102.2 ns/op 107.62 MB/s Benchmark__AuthPub0b_Payload-16 35649452 95.62 ns/op 115.04 MB/s Benchmark__AuthPub0b_Payload-16 32283050 101.7 ns/op 108.12 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15585351 226.7 ns/op Benchmark_____________PubSub-16 15617985 225.9 ns/op Benchmark_____________PubSub-16 15503960 226.5 ns/op Benchmark_____________PubSub-16 15680374 226.8 ns/op Benchmark_____________PubSub-16 15485980 228.1 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15707092 225.8 ns/op Benchmark_____PubSubTwoConns-16 15752994 225.3 ns/op Benchmark_____PubSubTwoConns-16 15807032 226.2 ns/op Benchmark_____PubSubTwoConns-16 15671942 226.5 ns/op Benchmark_____PubSubTwoConns-16 15328189 225.6 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58370->127.0.0.1:33369: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49362->127.0.0.1:39761: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:48646->127.0.0.1:43555: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41456->127.0.0.1:35893: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50068->127.0.0.1:37293: 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 14428129 247.9 ns/op Benchmark_____PubTwoQueueSub-16 14462848 247.6 ns/op Benchmark_____PubTwoQueueSub-16 14291733 248.2 ns/op Benchmark_____PubTwoQueueSub-16 14281192 248.4 ns/op Benchmark_____PubTwoQueueSub-16 14258863 246.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14299183 248.2 ns/op Benchmark____PubFourQueueSub-16 14450191 249.0 ns/op Benchmark____PubFourQueueSub-16 14337793 248.3 ns/op Benchmark____PubFourQueueSub-16 14250643 247.5 ns/op Benchmark____PubFourQueueSub-16 14340194 248.7 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14081594 246.9 ns/op Benchmark___PubEightQueueSub-16 14324912 248.8 ns/op Benchmark___PubEightQueueSub-16 14203372 248.8 ns/op Benchmark___PubEightQueueSub-16 14348161 247.6 ns/op Benchmark___PubEightQueueSub-16 14305090 246.8 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22816 159237 ns/op Benchmark_PubSub512kTwoConns-16 22885 156855 ns/op Benchmark_PubSub512kTwoConns-16 23058 157026 ns/op Benchmark_PubSub512kTwoConns-16 22438 162855 ns/op Benchmark_PubSub512kTwoConns-16 22923 160654 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15014673 229.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 15110520 230.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15136665 230.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15409083 229.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 15106288 230.6 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15239305 229.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15272894 230.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15076526 229.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15285756 231.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15339649 231.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11339672 312.5 ns/op Benchmark____RoutedPubSub_0b-16 11631014 312.7 ns/op Benchmark____RoutedPubSub_0b-16 11570632 310.0 ns/op Benchmark____RoutedPubSub_0b-16 11199440 311.7 ns/op Benchmark____RoutedPubSub_0b-16 11333865 316.6 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6466232 546.8 ns/op Benchmark____RoutedPubSub_1K-16 6664664 540.7 ns/op Benchmark____RoutedPubSub_1K-16 6642829 544.9 ns/op Benchmark____RoutedPubSub_1K-16 6699894 540.8 ns/op Benchmark____RoutedPubSub_1K-16 6669260 539.5 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84930 44061 ns/op Benchmark__RoutedPubSub_100K-16 75723 47372 ns/op Benchmark__RoutedPubSub_100K-16 78121 46754 ns/op Benchmark__RoutedPubSub_100K-16 71434 49017 ns/op Benchmark__RoutedPubSub_100K-16 78027 48445 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11409620 319.0 ns/op Benchmark____Routed2QueueSub-16 9484729 325.4 ns/op Benchmark____Routed2QueueSub-16 9838515 321.3 ns/op Benchmark____Routed2QueueSub-16 9617661 324.7 ns/op Benchmark____Routed2QueueSub-16 9501678 328.9 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9700770 323.1 ns/op Benchmark____Routed4QueueSub-16 9306075 324.9 ns/op Benchmark____Routed4QueueSub-16 9494083 322.7 ns/op Benchmark____Routed4QueueSub-16 9668162 324.3 ns/op Benchmark____Routed4QueueSub-16 9606578 317.9 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9004687 334.6 ns/op Benchmark____Routed8QueueSub-16 9320599 336.5 ns/op Benchmark____Routed8QueueSub-16 10858300 333.7 ns/op Benchmark____Routed8QueueSub-16 9341352 328.0 ns/op Benchmark____Routed8QueueSub-16 9313252 332.4 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8790189 350.8 ns/op Benchmark___Routed16QueueSub-16 8650058 358.2 ns/op Benchmark___Routed16QueueSub-16 8789799 357.1 ns/op Benchmark___Routed16QueueSub-16 10361952 346.4 ns/op Benchmark___Routed16QueueSub-16 8751808 346.2 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6387482 553.9 ns/op Benchmark____________RouteCompressOff-16 6390903 554.4 ns/op Benchmark____________RouteCompressOff-16 6234778 554.0 ns/op Benchmark____________RouteCompressOff-16 6497982 555.5 ns/op Benchmark____________RouteCompressOff-16 6589532 551.3 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6571346 556.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6459888 556.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6361506 552.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6524571 555.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6474706 549.1 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6392449 552.6 ns/op Benchmark_________RouteCompressS2Fast-16 6513436 546.5 ns/op Benchmark_________RouteCompressS2Fast-16 6467883 549.7 ns/op Benchmark_________RouteCompressS2Fast-16 6351151 548.3 ns/op Benchmark_________RouteCompressS2Fast-16 6537314 554.3 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6456096 550.7 ns/op Benchmark_______RouteCompressS2Better-16 6491080 549.4 ns/op Benchmark_______RouteCompressS2Better-16 6508958 556.0 ns/op Benchmark_______RouteCompressS2Better-16 6327195 548.1 ns/op Benchmark_______RouteCompressS2Better-16 6377962 557.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6627379 547.7 ns/op Benchmark_________RouteCompressS2Best-16 6131817 547.8 ns/op Benchmark_________RouteCompressS2Best-16 6562814 547.4 ns/op Benchmark_________RouteCompressS2Best-16 6407581 552.5 ns/op Benchmark_________RouteCompressS2Best-16 6641569 548.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4692950 766.2 ns/op 324.98 MB/s Benchmark______FanOut_8x1x10-16 4691014 767.3 ns/op 324.51 MB/s Benchmark______FanOut_8x1x10-16 4686475 765.5 ns/op 325.26 MB/s Benchmark______FanOut_8x1x10-16 4681813 766.7 ns/op 324.78 MB/s Benchmark______FanOut_8x1x10-16 4694367 765.4 ns/op 325.33 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 551719 6145 ns/op 377.39 MB/s Benchmark_____FanOut_8x1x100-16 529336 6162 ns/op 376.34 MB/s Benchmark_____FanOut_8x1x100-16 549228 6159 ns/op 376.55 MB/s Benchmark_____FanOut_8x1x100-16 534018 6176 ns/op 375.46 MB/s Benchmark_____FanOut_8x1x100-16 533911 6184 ns/op 375.02 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48420 74705 ns/op 308.13 MB/s Benchmark____FanOut_8x10x100-16 47792 74891 ns/op 307.37 MB/s Benchmark____FanOut_8x10x100-16 47648 74594 ns/op 308.59 MB/s Benchmark____FanOut_8x10x100-16 48150 74506 ns/op 308.96 MB/s Benchmark____FanOut_8x10x100-16 48174 75168 ns/op 306.23 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5905 602687 ns/op 398.25 MB/s Benchmark___FanOut_8x10x1000-16 5660 599664 ns/op 400.26 MB/s Benchmark___FanOut_8x10x1000-16 5899 601073 ns/op 399.32 MB/s Benchmark___FanOut_8x10x1000-16 5907 597076 ns/op 401.99 MB/s Benchmark___FanOut_8x10x1000-16 6048 599829 ns/op 400.15 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4927 705892 ns/op 325.86 MB/s Benchmark___FanOut_8x100x100-16 4981 705524 ns/op 326.03 MB/s Benchmark___FanOut_8x100x100-16 4996 699123 ns/op 329.01 MB/s Benchmark___FanOut_8x100x100-16 4983 701773 ns/op 327.77 MB/s Benchmark___FanOut_8x100x100-16 5070 707355 ns/op 325.18 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 588 6144326 ns/op 390.61 MB/s Benchmark__FanOut_8x100x1000-16 577 6157392 ns/op 389.78 MB/s Benchmark__FanOut_8x100x1000-16 576 6200582 ns/op 387.06 MB/s Benchmark__FanOut_8x100x1000-16 584 6149551 ns/op 390.28 MB/s Benchmark__FanOut_8x100x1000-16 582 6134311 ns/op 391.25 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 534 6754764 ns/op 370.11 MB/s Benchmark__FanOut_8x10x10000-16 538 6772336 ns/op 369.15 MB/s Benchmark__FanOut_8x10x10000-16 530 6773170 ns/op 369.11 MB/s Benchmark__FanOut_8x10x10000-16 522 6855569 ns/op 364.67 MB/s Benchmark__FanOut_8x10x10000-16 532 6733155 ns/op 371.30 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 956 3733913 ns/op 307.99 MB/s Benchmark___FanOut_8x500x100-16 951 3730997 ns/op 308.23 MB/s Benchmark___FanOut_8x500x100-16 945 3756689 ns/op 306.13 MB/s Benchmark___FanOut_8x500x100-16 954 3754938 ns/op 306.27 MB/s Benchmark___FanOut_8x500x100-16 952 3750844 ns/op 306.60 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 348301 9542 ns/op 1534.42 MB/s Benchmark___FanOut_128x1x100-16 356847 9595 ns/op 1525.87 MB/s Benchmark___FanOut_128x1x100-16 349213 9529 ns/op 1536.44 MB/s Benchmark___FanOut_128x1x100-16 359072 9516 ns/op 1538.56 MB/s Benchmark___FanOut_128x1x100-16 372622 9561 ns/op 1531.28 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32961 109775 ns/op 1322.17 MB/s Benchmark__FanOut_128x10x100-16 32617 109911 ns/op 1320.53 MB/s Benchmark__FanOut_128x10x100-16 32605 109780 ns/op 1322.11 MB/s Benchmark__FanOut_128x10x100-16 32553 109300 ns/op 1327.92 MB/s Benchmark__FanOut_128x10x100-16 32726 110180 ns/op 1317.30 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4110 875779 ns/op 1667.25 MB/s Benchmark_FanOut_128x10x1000-16 4082 875442 ns/op 1667.89 MB/s Benchmark_FanOut_128x10x1000-16 4000 879267 ns/op 1660.63 MB/s Benchmark_FanOut_128x10x1000-16 3993 881145 ns/op 1657.09 MB/s Benchmark_FanOut_128x10x1000-16 4155 878719 ns/op 1661.67 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3441 1004959 ns/op 1442.99 MB/s Benchmark_FanOut_128x100x100-16 3487 1012261 ns/op 1432.58 MB/s Benchmark_FanOut_128x100x100-16 3489 1009601 ns/op 1436.35 MB/s Benchmark_FanOut_128x100x100-16 3514 1010429 ns/op 1435.17 MB/s Benchmark_FanOut_128x100x100-16 3549 1013670 ns/op 1430.59 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 391 9328206 ns/op 1565.16 MB/s BenchmarkFanOut_128x100x1000-16 381 9149906 ns/op 1595.66 MB/s BenchmarkFanOut_128x100x1000-16 387 9336083 ns/op 1563.84 MB/s BenchmarkFanOut_128x100x1000-16 381 9396742 ns/op 1553.75 MB/s BenchmarkFanOut_128x100x1000-16 386 9317672 ns/op 1566.93 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 370 9611082 ns/op 1529.50 MB/s BenchmarkFanOut_128x10x10000-16 372 9687934 ns/op 1517.37 MB/s BenchmarkFanOut_128x10x10000-16 364 9669038 ns/op 1520.33 MB/s BenchmarkFanOut_128x10x10000-16 374 9663019 ns/op 1521.28 MB/s BenchmarkFanOut_128x10x10000-16 374 9661872 ns/op 1521.46 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 673 5265502 ns/op 1376.91 MB/s BenchmarkFanOut__128x500x100-16 675 5272773 ns/op 1375.01 MB/s BenchmarkFanOut__128x500x100-16 679 5267592 ns/op 1376.37 MB/s BenchmarkFanOut__128x500x100-16 669 5314547 ns/op 1364.21 MB/s BenchmarkFanOut__128x500x100-16 672 5291563 ns/op 1370.13 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1956 1839294 ns/op 2876.39 MB/s Benchmark_FanOut_512x100x100-16 1929 1841621 ns/op 2872.75 MB/s Benchmark_FanOut_512x100x100-16 1920 1850535 ns/op 2858.92 MB/s Benchmark_FanOut_512x100x100-16 1953 1844410 ns/op 2868.41 MB/s Benchmark_FanOut_512x100x100-16 1953 1847702 ns/op 2863.30 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 216 16631878 ns/op 3186.68 MB/s Benchmark__FanOut_512x100x1k-16 213 16568772 ns/op 3198.82 MB/s Benchmark__FanOut_512x100x1k-16 217 16658417 ns/op 3181.61 MB/s Benchmark__FanOut_512x100x1k-16 214 16726422 ns/op 3168.67 MB/s Benchmark__FanOut_512x100x1k-16 218 16569046 ns/op 3198.77 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2743 1140804 ns/op 9143.58 MB/s Benchmark____FanOut_1kx10x1k-16 3031 1177218 ns/op 8860.76 MB/s Benchmark____FanOut_1kx10x1k-16 3312 1134872 ns/op 9191.38 MB/s Benchmark____FanOut_1kx10x1k-16 2952 1141518 ns/op 9137.87 MB/s Benchmark____FanOut_1kx10x1k-16 2980 1140877 ns/op 9143.00 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2830 1256596 ns/op 8293.07 MB/s Benchmark__FanOut_1kx100x100-16 2791 1258900 ns/op 8277.89 MB/s Benchmark__FanOut_1kx100x100-16 2815 1246535 ns/op 8360.00 MB/s Benchmark__FanOut_1kx100x100-16 2798 1248056 ns/op 8349.81 MB/s Benchmark__FanOut_1kx100x100-16 2786 1249787 ns/op 8338.25 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4324224 801.8 ns/op 310.53 MB/s Benchmark_____RFanOut_8x1x10-16 4289458 818.6 ns/op 304.18 MB/s Benchmark_____RFanOut_8x1x10-16 4377235 874.6 ns/op 284.69 MB/s Benchmark_____RFanOut_8x1x10-16 4215997 824.4 ns/op 302.02 MB/s Benchmark_____RFanOut_8x1x10-16 4268019 810.8 ns/op 307.09 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 517039 6746 ns/op 343.75 MB/s Benchmark____RFanOut_8x1x100-16 492445 6611 ns/op 350.80 MB/s Benchmark____RFanOut_8x1x100-16 499608 6652 ns/op 348.64 MB/s Benchmark____RFanOut_8x1x100-16 494391 6734 ns/op 344.36 MB/s Benchmark____RFanOut_8x1x100-16 501759 6620 ns/op 350.30 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 44596 80949 ns/op 284.36 MB/s Benchmark___RFanOut_8x10x100-16 44979 80630 ns/op 285.49 MB/s Benchmark___RFanOut_8x10x100-16 44004 80724 ns/op 285.16 MB/s Benchmark___RFanOut_8x10x100-16 43780 80747 ns/op 285.08 MB/s Benchmark___RFanOut_8x10x100-16 43092 80195 ns/op 287.04 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5224 679913 ns/op 353.01 MB/s Benchmark__RFanOut_8x10x1000-16 5452 687751 ns/op 348.99 MB/s Benchmark__RFanOut_8x10x1000-16 4896 698090 ns/op 343.82 MB/s Benchmark__RFanOut_8x10x1000-16 5173 668131 ns/op 359.24 MB/s Benchmark__RFanOut_8x10x1000-16 5162 683843 ns/op 350.99 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4633 773073 ns/op 297.54 MB/s Benchmark__RFanOut_8x100x100-16 4568 763071 ns/op 301.44 MB/s Benchmark__RFanOut_8x100x100-16 4698 762411 ns/op 301.70 MB/s Benchmark__RFanOut_8x100x100-16 4567 761664 ns/op 302.00 MB/s Benchmark__RFanOut_8x100x100-16 4611 763213 ns/op 301.38 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 513 7125016 ns/op 336.84 MB/s Benchmark_RFanOut_8x100x1000-16 512 6931918 ns/op 346.23 MB/s Benchmark_RFanOut_8x100x1000-16 513 6897345 ns/op 347.96 MB/s Benchmark_RFanOut_8x100x1000-16 501 7058274 ns/op 340.03 MB/s Benchmark_RFanOut_8x100x1000-16 514 6895709 ns/op 348.05 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 483 7316995 ns/op 341.67 MB/s Benchmark_RFanOut_8x10x10000-16 484 7301840 ns/op 342.38 MB/s Benchmark_RFanOut_8x10x10000-16 480 7367368 ns/op 339.34 MB/s Benchmark_RFanOut_8x10x10000-16 475 7458853 ns/op 335.17 MB/s Benchmark_RFanOut_8x10x10000-16 483 7344321 ns/op 340.40 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3087 1181180 ns/op 8831.03 MB/s Benchmark_RFanOut_1kx10x1000-16 3006 1167252 ns/op 8936.41 MB/s Benchmark_RFanOut_1kx10x1000-16 3056 1181146 ns/op 8831.29 MB/s Benchmark_RFanOut_1kx10x1000-16 3027 1182126 ns/op 8823.97 MB/s Benchmark_RFanOut_1kx10x1000-16 2942 1187829 ns/op 8781.60 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6928612 509.3 ns/op 4079.80 MB/s Benchmark_____FanIn_1kx100x1-16 6949896 509.0 ns/op 4082.14 MB/s Benchmark_____FanIn_1kx100x1-16 6888996 509.5 ns/op 4078.47 MB/s Benchmark_____FanIn_1kx100x1-16 6919544 509.6 ns/op 4077.62 MB/s Benchmark_____FanIn_1kx100x1-16 6946999 510.0 ns/op 4074.52 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2600866 1367 ns/op 6013.47 MB/s Benchmark_____FanIn_4kx100x1-16 2662900 1363 ns/op 6033.96 MB/s Benchmark_____FanIn_4kx100x1-16 2596322 1386 ns/op 5932.20 MB/s Benchmark_____FanIn_4kx100x1-16 2601403 1363 ns/op 6033.59 MB/s Benchmark_____FanIn_4kx100x1-16 2603007 1366 ns/op 6019.95 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1696177 2125 ns/op 7724.37 MB/s Benchmark_____FanIn_8kx100x1-16 1677049 2080 ns/op 7891.51 MB/s Benchmark_____FanIn_8kx100x1-16 1690693 2174 ns/op 7549.12 MB/s Benchmark_____FanIn_8kx100x1-16 1693394 2103 ns/op 7804.15 MB/s Benchmark_____FanIn_8kx100x1-16 1693533 2108 ns/op 7784.85 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 866278 4141 ns/op 7920.34 MB/s Benchmark____FanIn_16kx100x1-16 863746 4173 ns/op 7860.68 MB/s Benchmark____FanIn_16kx100x1-16 863889 4149 ns/op 7905.09 MB/s Benchmark____FanIn_16kx100x1-16 871573 4106 ns/op 7988.01 MB/s Benchmark____FanIn_16kx100x1-16 863239 4134 ns/op 7933.91 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 172149 19900 ns/op 6588.28 MB/s Benchmark____FanIn_64kx100x1-16 166422 19982 ns/op 6561.02 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 6925543344 vs 11786429400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40082->127.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:40408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39902->127.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:40698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40656->127.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 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40550->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:40042->127.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:40178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40380->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39930->127.0.0.1:5222: write: broken pipe 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:40798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40500->127.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:40450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40440->127.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:40756->127.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:40714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40344->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40384->127.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:40150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40162->127.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:40006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40238->127.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: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:40722->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40212->127.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:40646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40488->127.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:40570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39964->127.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 --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:40636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40634->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: 3356248047 vs 11032569900 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43452->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 168199 20124 ns/op 6514.74 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 765696690 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47558->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: 258509480 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49370->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:50010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49782->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1136681390 vs 1310900000 --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 117587730 vs 11588356000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54490->127.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:53848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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: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: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:54372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54274->127.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:53834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54040->127.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:54484->127.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:53838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54458->127.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:53864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54554->127.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:54222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54432->127.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:54328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54442->127.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:54118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54424->127.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:54596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54160->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: 539435350 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56184->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56196->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55898->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5591962 637.2 ns/op 445.70 MB/s Benchmark___BumpPubCount_1x3-16 5607120 639.2 ns/op 444.28 MB/s Benchmark___BumpPubCount_1x3-16 5614134 642.9 ns/op 441.77 MB/s Benchmark___BumpPubCount_1x3-16 5629413 641.6 ns/op 442.63 MB/s Benchmark___BumpPubCount_1x3-16 5630091 642.0 ns/op 442.34 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5270977 684.4 ns/op 414.94 MB/s Benchmark___BumpPubCount_2x3-16 5253422 685.3 ns/op 414.42 MB/s Benchmark___BumpPubCount_2x3-16 5243382 676.4 ns/op 419.87 MB/s Benchmark___BumpPubCount_2x3-16 5274144 674.5 ns/op 421.07 MB/s Benchmark___BumpPubCount_2x3-16 5195678 684.7 ns/op 414.76 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5494592 652.6 ns/op 435.16 MB/s Benchmark___BumpPubCount_5x3-16 5103882 651.0 ns/op 436.24 MB/s Benchmark___BumpPubCount_5x3-16 5292540 650.6 ns/op 436.51 MB/s Benchmark___BumpPubCount_5x3-16 5499073 651.5 ns/op 435.91 MB/s Benchmark___BumpPubCount_5x3-16 5506785 655.5 ns/op 433.28 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5065418 650.8 ns/op 436.39 MB/s Benchmark__BumpPubCount_10x3-16 5510572 647.8 ns/op 438.43 MB/s Benchmark__BumpPubCount_10x3-16 5531108 651.2 ns/op 436.14 MB/s Benchmark__BumpPubCount_10x3-16 5490045 649.4 ns/op 437.34 MB/s Benchmark__BumpPubCount_10x3-16 5450509 651.8 ns/op 435.73 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11319355 278.4 ns/op 3736.08 MB/s Benchmark____GWs_Opt_1kx01x0-16 12840272 274.2 ns/op 3792.54 MB/s Benchmark____GWs_Opt_1kx01x0-16 12430940 278.5 ns/op 3733.97 MB/s Benchmark____GWs_Opt_1kx01x0-16 12293575 272.0 ns/op 3823.58 MB/s Benchmark____GWs_Opt_1kx01x0-16 12394316 278.9 ns/op 3729.06 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10344631 330.5 ns/op 6244.47 MB/s Benchmark____GWs_Opt_2kx01x0-16 10160078 320.0 ns/op 6449.59 MB/s Benchmark____GWs_Opt_2kx01x0-16 9954330 346.3 ns/op 5960.67 MB/s Benchmark____GWs_Opt_2kx01x0-16 9480019 344.7 ns/op 5988.46 MB/s Benchmark____GWs_Opt_2kx01x0-16 10900012 342.0 ns/op 6034.88 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5400708 641.3 ns/op 6412.08 MB/s Benchmark____GWs_Opt_4kx01x0-16 5551530 647.0 ns/op 6355.34 MB/s Benchmark____GWs_Opt_4kx01x0-16 5549544 648.9 ns/op 6336.43 MB/s Benchmark____GWs_Opt_4kx01x0-16 5540181 653.1 ns/op 6296.07 MB/s Benchmark____GWs_Opt_4kx01x0-16 5582704 630.9 ns/op 6517.32 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28542750 109.1 ns/op 9529.34 MB/s Benchmark____GWs_Opt_1kx10x0-16 32204319 112.0 ns/op 9283.64 MB/s Benchmark____GWs_Opt_1kx10x0-16 28147042 117.1 ns/op 8884.74 MB/s Benchmark____GWs_Opt_1kx10x0-16 28519934 116.2 ns/op 8950.04 MB/s Benchmark____GWs_Opt_1kx10x0-16 31123792 113.8 ns/op 9138.97 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23096488 161.1 ns/op 12815.63 MB/s Benchmark____GWs_Opt_2kx10x0-16 23971011 138.5 ns/op 14898.13 MB/s Benchmark____GWs_Opt_2kx10x0-16 23359308 143.5 ns/op 14383.92 MB/s Benchmark____GWs_Opt_2kx10x0-16 23226858 143.8 ns/op 14355.46 MB/s Benchmark____GWs_Opt_2kx10x0-16 23751140 142.6 ns/op 14472.39 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11876701 299.0 ns/op 13750.40 MB/s Benchmark____GWs_Opt_4kx10x0-16 12506755 301.1 ns/op 13657.03 MB/s Benchmark____GWs_Opt_4kx10x0-16 12462312 335.7 ns/op 12250.49 MB/s Benchmark____GWs_Opt_4kx10x0-16 12611320 296.7 ns/op 13860.19 MB/s Benchmark____GWs_Opt_4kx10x0-16 11969958 345.5 ns/op 11900.21 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6575239 555.0 ns/op 5630.71 MB/s Benchmark____GWs_Opt_1kx01x1-16 6403749 550.1 ns/op 5681.25 MB/s Benchmark____GWs_Opt_1kx01x1-16 6455577 554.3 ns/op 5637.45 MB/s Benchmark____GWs_Opt_1kx01x1-16 6543908 559.5 ns/op 5585.52 MB/s Benchmark____GWs_Opt_1kx01x1-16 6476348 554.8 ns/op 5632.26 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4559701 758.8 ns/op 8166.62 MB/s Benchmark____GWs_Opt_2kx01x1-16 4581488 766.6 ns/op 8084.00 MB/s Benchmark____GWs_Opt_2kx01x1-16 4784472 882.8 ns/op 7020.08 MB/s Benchmark____GWs_Opt_2kx01x1-16 4558879 776.7 ns/op 7978.92 MB/s Benchmark____GWs_Opt_2kx01x1-16 4685649 766.6 ns/op 8083.22 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2607028 1375 ns/op 8972.19 MB/s Benchmark____GWs_Opt_4kx01x1-16 2513197 1382 ns/op 8932.53 MB/s Benchmark____GWs_Opt_4kx01x1-16 2594172 1382 ns/op 8928.34 MB/s Benchmark____GWs_Opt_4kx01x1-16 2618979 1406 ns/op 8775.07 MB/s Benchmark____GWs_Opt_4kx01x1-16 2615590 1379 ns/op 8951.50 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6105541 559.0 ns/op 5590.74 MB/s Benchmark____GWs_Opt_1kx10x1-16 6189219 557.9 ns/op 5601.75 MB/s Benchmark____GWs_Opt_1kx10x1-16 6490232 552.3 ns/op 5658.12 MB/s Benchmark____GWs_Opt_1kx10x1-16 6515793 546.5 ns/op 5717.87 MB/s Benchmark____GWs_Opt_1kx10x1-16 6150405 564.7 ns/op 5533.59 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4315645 843.5 ns/op 7346.64 MB/s Benchmark____GWs_Opt_2kx10x1-16 4403689 848.9 ns/op 7299.68 MB/s Benchmark____GWs_Opt_2kx10x1-16 4399021 848.6 ns/op 7302.85 MB/s Benchmark____GWs_Opt_2kx10x1-16 4120401 849.6 ns/op 7294.22 MB/s Benchmark____GWs_Opt_2kx10x1-16 4191908 847.8 ns/op 7309.67 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2371004 1575 ns/op 7836.08 MB/s Benchmark____GWs_Opt_4kx10x1-16 2388837 1519 ns/op 8124.32 MB/s Benchmark____GWs_Opt_4kx10x1-16 2368044 1502 ns/op 8217.91 MB/s Benchmark____GWs_Opt_4kx10x1-16 2280055 1446 ns/op 8534.76 MB/s Benchmark____GWs_Opt_4kx10x1-16 2292746 1516 ns/op 8138.42 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12449612 292.5 ns/op 3555.53 MB/s Benchmark____GWs_Int_1kx01x0-16 12277868 293.9 ns/op 3539.16 MB/s Benchmark____GWs_Int_1kx01x0-16 11512536 295.6 ns/op 3518.06 MB/s Benchmark____GWs_Int_1kx01x0-16 12204466 289.8 ns/op 3588.79 MB/s Benchmark____GWs_Int_1kx01x0-16 12380793 292.9 ns/op 3550.24 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10242093 360.9 ns/op 5719.56 MB/s Benchmark____GWs_Int_2kx01x0-16 10735842 344.6 ns/op 5988.83 MB/s Benchmark____GWs_Int_2kx01x0-16 10127576 346.0 ns/op 5965.75 MB/s Benchmark____GWs_Int_2kx01x0-16 9862974 360.4 ns/op 5726.37 MB/s Benchmark____GWs_Int_2kx01x0-16 9795402 355.1 ns/op 5812.13 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5578968 662.2 ns/op 6209.25 MB/s Benchmark____GWs_Int_4kx01x0-16 5399678 667.1 ns/op 6163.79 MB/s Benchmark____GWs_Int_4kx01x0-16 5525211 651.1 ns/op 6315.70 MB/s Benchmark____GWs_Int_4kx01x0-16 5423846 658.3 ns/op 6246.74 MB/s Benchmark____GWs_Int_4kx01x0-16 5618910 655.3 ns/op 6275.29 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31088671 112.0 ns/op 9286.52 MB/s Benchmark____GWs_Int_1kx10x0-16 30842688 115.0 ns/op 9044.05 MB/s Benchmark____GWs_Int_1kx10x0-16 31301050 111.6 ns/op 9315.36 MB/s Benchmark____GWs_Int_1kx10x0-16 31691896 117.2 ns/op 8872.82 MB/s Benchmark____GWs_Int_1kx10x0-16 31024861 115.6 ns/op 8999.61 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24356126 141.5 ns/op 14591.59 MB/s Benchmark____GWs_Int_2kx10x0-16 23957847 150.9 ns/op 13677.74 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:51616->127.0.0.1:44617: 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:55536->127.0.0.1:40145: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 23225636 151.7 ns/op 13610.15 MB/s Benchmark____GWs_Int_2kx10x0-16 26217120 140.0 ns/op 14740.94 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11776268 304.2 ns/op 13519.44 MB/s Benchmark____GWs_Int_4kx10x0-16 12106052 334.8 ns/op 12282.98 MB/s Benchmark____GWs_Int_4kx10x0-16 12487051 294.7 ns/op 13952.56 MB/s Benchmark____GWs_Int_4kx10x0-16 11657380 302.0 ns/op 13615.57 MB/s Benchmark____GWs_Int_4kx10x0-16 13153320 328.3 ns/op 12526.22 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6200205 619.6 ns/op 5043.63 MB/s Benchmark____GWs_Int_1kx01x1-16 6343486 563.0 ns/op 5550.64 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:41928->127.0.0.1:37795: use of closed network connection --- FAIL: Benchmark____GWs_Int_1kx01x1 --- FAIL: Benchmark____GWs_Int_1kx01x1-16 Benchmark____GWs_Int_1kx01x1-16 6421196 570.4 ns/op 5478.32 MB/s Benchmark____GWs_Int_1kx01x1-16 6282171 572.7 ns/op 5456.75 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4668088 768.1 ns/op 8067.64 MB/s Benchmark____GWs_Int_2kx01x1-16 4625985 769.0 ns/op 8058.39 MB/s Benchmark____GWs_Int_2kx01x1-16 4553460 775.4 ns/op 7992.44 MB/s Benchmark____GWs_Int_2kx01x1-16 4727588 794.5 ns/op 7799.51 MB/s Benchmark____GWs_Int_2kx01x1-16 4805076 771.3 ns/op 8034.60 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2597214 1784 ns/op 6916.59 MB/s Benchmark____GWs_Int_4kx01x1-16 2643345 1465 ns/op 8422.75 MB/s Benchmark____GWs_Int_4kx01x1-16 2619026 1460 ns/op 8453.21 MB/s Benchmark____GWs_Int_4kx01x1-16 2645271 1392 ns/op 8867.63 MB/s Benchmark____GWs_Int_4kx01x1-16 2618994 1466 ns/op 8420.52 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6342879 555.7 ns/op 5623.55 MB/s Benchmark____GWs_Int_1kx10x1-16 6117783 555.6 ns/op 5625.04 MB/s Benchmark____GWs_Int_1kx10x1-16 6210230 557.0 ns/op 5610.88 MB/s Benchmark____GWs_Int_1kx10x1-16 6634240 559.2 ns/op 5588.47 MB/s Benchmark____GWs_Int_1kx10x1-16 6295933 577.3 ns/op 5413.55 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4160163 851.4 ns/op 7278.27 MB/s Benchmark____GWs_Int_2kx10x1-16 4180172 838.9 ns/op 7387.13 MB/s Benchmark____GWs_Int_2kx10x1-16 4151041 904.1 ns/op 6854.15 MB/s Benchmark____GWs_Int_2kx10x1-16 4163662 856.3 ns/op 7237.30 MB/s Benchmark____GWs_Int_2kx10x1-16 4170978 837.5 ns/op 7399.75 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2422015 1532 ns/op 8055.16 MB/s Benchmark____GWs_Int_4kx10x1-16 2290156 1525 ns/op 8091.72 MB/s Benchmark____GWs_Int_4kx10x1-16 2336041 1482 ns/op 8327.03 MB/s Benchmark____GWs_Int_4kx10x1-16 2479263 1515 ns/op 8147.97 MB/s Benchmark____GWs_Int_4kx10x1-16 2244298 1514 ns/op 8150.15 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8017543 443.0 ns/op 230.24 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8324126 440.0 ns/op 231.81 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7948363 444.3 ns/op 229.55 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8292814 449.4 ns/op 226.96 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7786384 443.9 ns/op 229.81 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 744201 4957 ns/op 35.71 MB/s Benchmark__GWs_Reqs_1SubEach-16 780495 5112 ns/op 34.63 MB/s Benchmark__GWs_Reqs_1SubEach-16 758385 5180 ns/op 34.17 MB/s Benchmark__GWs_Reqs_1SubEach-16 730120 5079 ns/op 34.85 MB/s Benchmark__GWs_Reqs_1SubEach-16 766323 5104 ns/op 34.68 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2111.230s ❌ Non-zero exit code: 1