> ROOT_DIR=/tmp/go-bench-away-job-a94c1e32-d90a-457e-abaa-fb84f8333b8a-825739126 > OUTPUT_FILE=/tmp/go-bench-away-job-a94c1e32-d90a-457e-abaa-fb84f8333b8a-825739126/results.txt > SHA_FILE=/tmp/go-bench-away-job-a94c1e32-d90a-457e-abaa-fb84f8333b8a-825739126/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-a94c1e32-d90a-457e-abaa-fb84f8333b8a-825739126/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.26.3/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-a94c1e32-d90a-457e-abaa-fb84f8333b8a-825739126/source.git SHA of main: 146b0be65b3591e925cce61ce9d2cae32cdeb227 Go runtime: go version go1.26.3 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build1344724432=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-a94c1e32-d90a-457e-abaa-fb84f8333b8a-825739126/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.26.3' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.26.3/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.3' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 40002368 76.57 ns/op 143.66 MB/s Benchmark______Pub0b_Payload-16 46642683 72.75 ns/op 151.19 MB/s Benchmark______Pub0b_Payload-16 47156942 75.33 ns/op 146.03 MB/s Benchmark______Pub0b_Payload-16 46734706 72.74 ns/op 151.22 MB/s Benchmark______Pub0b_Payload-16 47054984 72.90 ns/op 150.89 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46157840 73.37 ns/op 258.97 MB/s Benchmark______Pub8b_Payload-16 46261057 73.27 ns/op 259.31 MB/s Benchmark______Pub8b_Payload-16 45889676 73.37 ns/op 258.95 MB/s Benchmark______Pub8b_Payload-16 44742320 73.76 ns/op 257.60 MB/s Benchmark______Pub8b_Payload-16 46488307 77.51 ns/op 245.12 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43916461 77.02 ns/op 571.24 MB/s Benchmark_____Pub32b_Payload-16 44114076 77.38 ns/op 568.65 MB/s Benchmark_____Pub32b_Payload-16 44409660 77.05 ns/op 571.07 MB/s Benchmark_____Pub32b_Payload-16 46634614 77.01 ns/op 571.32 MB/s Benchmark_____Pub32b_Payload-16 44004481 77.21 ns/op 569.90 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39389810 86.74 ns/op 1625.50 MB/s Benchmark____Pub128B_Payload-16 40097190 86.40 ns/op 1631.98 MB/s Benchmark____Pub128B_Payload-16 38202309 86.80 ns/op 1624.51 MB/s Benchmark____Pub128B_Payload-16 38889657 85.28 ns/op 1653.42 MB/s Benchmark____Pub128B_Payload-16 35164976 87.71 ns/op 1607.66 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36191064 94.22 ns/op 2855.13 MB/s Benchmark____Pub256B_Payload-16 34221578 93.88 ns/op 2865.39 MB/s Benchmark____Pub256B_Payload-16 35515270 95.10 ns/op 2828.75 MB/s Benchmark____Pub256B_Payload-16 38002629 94.73 ns/op 2839.53 MB/s Benchmark____Pub256B_Payload-16 31819663 95.41 ns/op 2819.55 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24023502 152.0 ns/op 6826.76 MB/s Benchmark______Pub1K_Payload-16 25190444 137.6 ns/op 7546.27 MB/s Benchmark______Pub1K_Payload-16 22105723 137.6 ns/op 7542.17 MB/s Benchmark______Pub1K_Payload-16 25640654 135.2 ns/op 7679.87 MB/s Benchmark______Pub1K_Payload-16 23273608 141.7 ns/op 7324.21 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5353989 614.1 ns/op 6693.23 MB/s Benchmark______Pub4K_Payload-16 5533842 615.8 ns/op 6674.78 MB/s Benchmark______Pub4K_Payload-16 5572054 624.0 ns/op 6586.86 MB/s Benchmark______Pub4K_Payload-16 5561992 618.9 ns/op 6640.28 MB/s Benchmark______Pub4K_Payload-16 5545368 626.1 ns/op 6564.46 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2683257 1267 ns/op 6474.71 MB/s Benchmark______Pub8K_Payload-16 2815224 1287 ns/op 6374.01 MB/s Benchmark______Pub8K_Payload-16 2792364 1279 ns/op 6418.41 MB/s Benchmark______Pub8K_Payload-16 2767048 1277 ns/op 6424.36 MB/s Benchmark______Pub8K_Payload-16 2735488 1271 ns/op 6454.25 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 643122 5420 ns/op 6048.32 MB/s Benchmark_____Pub32K_Payload-16 553017 6484 ns/op 5056.01 MB/s Benchmark_____Pub32K_Payload-16 659322 5511 ns/op 5948.36 MB/s Benchmark_____Pub32K_Payload-16 659002 5380 ns/op 6093.85 MB/s Benchmark_____Pub32K_Payload-16 526244 6812 ns/op 4812.88 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31918368 95.13 ns/op 115.63 MB/s Benchmark__AuthPub0b_Payload-16 36111196 95.13 ns/op 115.63 MB/s Benchmark__AuthPub0b_Payload-16 36030379 94.76 ns/op 116.09 MB/s Benchmark__AuthPub0b_Payload-16 33859875 94.79 ns/op 116.05 MB/s Benchmark__AuthPub0b_Payload-16 35690937 95.27 ns/op 115.47 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15466340 227.5 ns/op Benchmark_____________PubSub-16 15530581 227.7 ns/op Benchmark_____________PubSub-16 15547794 228.0 ns/op Benchmark_____________PubSub-16 15623612 227.2 ns/op Benchmark_____________PubSub-16 15577276 228.0 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15513598 226.3 ns/op Benchmark_____PubSubTwoConns-16 15698310 228.3 ns/op Benchmark_____PubSubTwoConns-16 15837632 227.6 ns/op Benchmark_____PubSubTwoConns-16 15479660 226.7 ns/op Benchmark_____PubSubTwoConns-16 15693750 226.8 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59714->127.0.0.1:39393: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57518->127.0.0.1:42847: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:56798->127.0.0.1:42353: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:60858->127.0.0.1:39455: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:53664->127.0.0.1:34867: 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 14525896 243.1 ns/op Benchmark_____PubTwoQueueSub-16 14332042 244.2 ns/op Benchmark_____PubTwoQueueSub-16 14500238 243.5 ns/op Benchmark_____PubTwoQueueSub-16 14541895 243.5 ns/op Benchmark_____PubTwoQueueSub-16 14534079 243.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14601568 244.1 ns/op Benchmark____PubFourQueueSub-16 14693805 244.4 ns/op Benchmark____PubFourQueueSub-16 14487115 244.0 ns/op Benchmark____PubFourQueueSub-16 14565909 243.9 ns/op Benchmark____PubFourQueueSub-16 14417581 244.5 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14617815 243.7 ns/op Benchmark___PubEightQueueSub-16 14500641 243.4 ns/op Benchmark___PubEightQueueSub-16 14291053 245.2 ns/op Benchmark___PubEightQueueSub-16 14453664 245.1 ns/op Benchmark___PubEightQueueSub-16 14447541 244.6 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 21638 155643 ns/op Benchmark_PubSub512kTwoConns-16 23110 155705 ns/op Benchmark_PubSub512kTwoConns-16 23070 155562 ns/op Benchmark_PubSub512kTwoConns-16 22948 155317 ns/op Benchmark_PubSub512kTwoConns-16 23017 154705 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15113392 229.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15044298 229.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15051836 229.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15431446 229.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15245227 228.9 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15297924 229.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15274250 230.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15204585 230.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15181696 229.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15214330 229.0 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11146036 310.3 ns/op Benchmark____RoutedPubSub_0b-16 11210168 313.7 ns/op Benchmark____RoutedPubSub_0b-16 11252996 309.8 ns/op Benchmark____RoutedPubSub_0b-16 11266670 310.7 ns/op Benchmark____RoutedPubSub_0b-16 11385165 309.5 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6722265 542.5 ns/op Benchmark____RoutedPubSub_1K-16 6538467 538.3 ns/op Benchmark____RoutedPubSub_1K-16 6716274 538.7 ns/op Benchmark____RoutedPubSub_1K-16 6637040 534.2 ns/op Benchmark____RoutedPubSub_1K-16 6778112 536.3 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84457 42046 ns/op Benchmark__RoutedPubSub_100K-16 73021 43917 ns/op Benchmark__RoutedPubSub_100K-16 81454 43716 ns/op Benchmark__RoutedPubSub_100K-16 80734 43626 ns/op Benchmark__RoutedPubSub_100K-16 83540 45519 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11483830 315.8 ns/op Benchmark____Routed2QueueSub-16 10194218 314.4 ns/op Benchmark____Routed2QueueSub-16 9694981 315.8 ns/op Benchmark____Routed2QueueSub-16 9520700 318.7 ns/op Benchmark____Routed2QueueSub-16 9767020 314.1 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9505780 315.8 ns/op Benchmark____Routed4QueueSub-16 9428798 325.7 ns/op Benchmark____Routed4QueueSub-16 9591384 325.6 ns/op Benchmark____Routed4QueueSub-16 9386524 322.0 ns/op Benchmark____Routed4QueueSub-16 9646338 321.0 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9415818 325.9 ns/op Benchmark____Routed8QueueSub-16 9489225 323.8 ns/op Benchmark____Routed8QueueSub-16 9158054 330.1 ns/op Benchmark____Routed8QueueSub-16 9173274 328.5 ns/op Benchmark____Routed8QueueSub-16 9211317 327.4 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8913706 354.7 ns/op Benchmark___Routed16QueueSub-16 8941276 349.6 ns/op Benchmark___Routed16QueueSub-16 8884471 342.5 ns/op Benchmark___Routed16QueueSub-16 10511941 346.7 ns/op Benchmark___Routed16QueueSub-16 8938479 351.2 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6363525 555.2 ns/op Benchmark____________RouteCompressOff-16 6297345 552.9 ns/op Benchmark____________RouteCompressOff-16 6443119 549.8 ns/op Benchmark____________RouteCompressOff-16 6543607 553.9 ns/op Benchmark____________RouteCompressOff-16 6359804 556.3 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6364390 554.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6377600 548.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6430594 549.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6255331 556.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6518126 551.9 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6479188 553.1 ns/op Benchmark_________RouteCompressS2Fast-16 6421353 549.3 ns/op Benchmark_________RouteCompressS2Fast-16 6478820 554.7 ns/op Benchmark_________RouteCompressS2Fast-16 6341533 481.6 ns/op Benchmark_________RouteCompressS2Fast-16 6288303 562.3 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6170300 553.4 ns/op Benchmark_______RouteCompressS2Better-16 6438843 547.7 ns/op Benchmark_______RouteCompressS2Better-16 6306853 519.8 ns/op Benchmark_______RouteCompressS2Better-16 6435266 552.1 ns/op Benchmark_______RouteCompressS2Better-16 6467064 556.2 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6559183 554.8 ns/op Benchmark_________RouteCompressS2Best-16 6466552 555.3 ns/op Benchmark_________RouteCompressS2Best-16 6311529 550.6 ns/op Benchmark_________RouteCompressS2Best-16 6551241 551.3 ns/op Benchmark_________RouteCompressS2Best-16 6405847 555.0 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4672550 780.7 ns/op 318.93 MB/s Benchmark______FanOut_8x1x10-16 4671522 765.6 ns/op 325.24 MB/s Benchmark______FanOut_8x1x10-16 4684246 769.0 ns/op 323.80 MB/s Benchmark______FanOut_8x1x10-16 4693864 764.9 ns/op 325.54 MB/s Benchmark______FanOut_8x1x10-16 4693668 770.8 ns/op 323.04 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 525668 6109 ns/op 379.60 MB/s Benchmark_____FanOut_8x1x100-16 552798 6108 ns/op 379.64 MB/s Benchmark_____FanOut_8x1x100-16 541759 6287 ns/op 368.88 MB/s Benchmark_____FanOut_8x1x100-16 536320 6083 ns/op 381.21 MB/s Benchmark_____FanOut_8x1x100-16 555589 6186 ns/op 374.91 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47571 74744 ns/op 307.97 MB/s Benchmark____FanOut_8x10x100-16 48190 74407 ns/op 309.36 MB/s Benchmark____FanOut_8x10x100-16 47881 75008 ns/op 306.89 MB/s Benchmark____FanOut_8x10x100-16 48004 74528 ns/op 308.86 MB/s Benchmark____FanOut_8x10x100-16 47780 74282 ns/op 309.89 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5983 596977 ns/op 402.06 MB/s Benchmark___FanOut_8x10x1000-16 5907 594576 ns/op 403.68 MB/s Benchmark___FanOut_8x10x1000-16 5727 596660 ns/op 402.27 MB/s Benchmark___FanOut_8x10x1000-16 5812 607619 ns/op 395.02 MB/s Benchmark___FanOut_8x10x1000-16 5952 594868 ns/op 403.48 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5056 705162 ns/op 326.19 MB/s Benchmark___FanOut_8x100x100-16 5010 706428 ns/op 325.61 MB/s Benchmark___FanOut_8x100x100-16 4953 704643 ns/op 326.43 MB/s Benchmark___FanOut_8x100x100-16 5037 703665 ns/op 326.89 MB/s Benchmark___FanOut_8x100x100-16 4952 703064 ns/op 327.17 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 582 6119213 ns/op 392.21 MB/s Benchmark__FanOut_8x100x1000-16 573 6146027 ns/op 390.50 MB/s Benchmark__FanOut_8x100x1000-16 584 6116070 ns/op 392.41 MB/s Benchmark__FanOut_8x100x1000-16 571 6115607 ns/op 392.44 MB/s Benchmark__FanOut_8x100x1000-16 585 6172238 ns/op 388.84 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 543 6734131 ns/op 371.25 MB/s Benchmark__FanOut_8x10x10000-16 526 6786643 ns/op 368.37 MB/s Benchmark__FanOut_8x10x10000-16 531 6965412 ns/op 358.92 MB/s Benchmark__FanOut_8x10x10000-16 522 6784419 ns/op 368.49 MB/s Benchmark__FanOut_8x10x10000-16 518 6877621 ns/op 363.50 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 946 3775327 ns/op 304.61 MB/s Benchmark___FanOut_8x500x100-16 928 3795519 ns/op 302.99 MB/s Benchmark___FanOut_8x500x100-16 943 3789372 ns/op 303.49 MB/s Benchmark___FanOut_8x500x100-16 931 3749830 ns/op 306.69 MB/s Benchmark___FanOut_8x500x100-16 950 3760926 ns/op 305.78 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 359174 9438 ns/op 1551.25 MB/s Benchmark___FanOut_128x1x100-16 355326 9486 ns/op 1543.39 MB/s Benchmark___FanOut_128x1x100-16 366152 9469 ns/op 1546.26 MB/s Benchmark___FanOut_128x1x100-16 367167 9523 ns/op 1537.49 MB/s Benchmark___FanOut_128x1x100-16 356328 9531 ns/op 1536.08 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32638 111292 ns/op 1304.14 MB/s Benchmark__FanOut_128x10x100-16 32444 111192 ns/op 1305.32 MB/s Benchmark__FanOut_128x10x100-16 32322 111200 ns/op 1305.22 MB/s Benchmark__FanOut_128x10x100-16 32419 110253 ns/op 1316.44 MB/s Benchmark__FanOut_128x10x100-16 32625 110378 ns/op 1314.95 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4173 878572 ns/op 1661.95 MB/s Benchmark_FanOut_128x10x1000-16 3786 872171 ns/op 1674.15 MB/s Benchmark_FanOut_128x10x1000-16 3912 872956 ns/op 1672.64 MB/s Benchmark_FanOut_128x10x1000-16 3859 869204 ns/op 1679.86 MB/s Benchmark_FanOut_128x10x1000-16 3985 874310 ns/op 1670.05 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3520 1002999 ns/op 1445.81 MB/s Benchmark_FanOut_128x100x100-16 3532 1004503 ns/op 1443.64 MB/s Benchmark_FanOut_128x100x100-16 3516 1009345 ns/op 1436.71 MB/s Benchmark_FanOut_128x100x100-16 3417 1005763 ns/op 1441.83 MB/s Benchmark_FanOut_128x100x100-16 3538 1006634 ns/op 1440.58 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 396 9224576 ns/op 1582.74 MB/s BenchmarkFanOut_128x100x1000-16 385 9429270 ns/op 1548.39 MB/s BenchmarkFanOut_128x100x1000-16 390 9282092 ns/op 1572.94 MB/s BenchmarkFanOut_128x100x1000-16 388 9232165 ns/op 1581.44 MB/s BenchmarkFanOut_128x100x1000-16 376 9245709 ns/op 1579.13 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 373 9593603 ns/op 1532.29 MB/s BenchmarkFanOut_128x10x10000-16 373 9618915 ns/op 1528.25 MB/s BenchmarkFanOut_128x10x10000-16 372 9616493 ns/op 1528.64 MB/s BenchmarkFanOut_128x10x10000-16 372 9647427 ns/op 1523.74 MB/s BenchmarkFanOut_128x10x10000-16 375 9606368 ns/op 1530.25 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 670 5353110 ns/op 1354.38 MB/s BenchmarkFanOut__128x500x100-16 673 5266575 ns/op 1376.63 MB/s BenchmarkFanOut__128x500x100-16 668 5257516 ns/op 1379.00 MB/s BenchmarkFanOut__128x500x100-16 668 5286822 ns/op 1371.36 MB/s BenchmarkFanOut__128x500x100-16 668 5296474 ns/op 1368.86 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1905 1847713 ns/op 2863.28 MB/s Benchmark_FanOut_512x100x100-16 1963 1840652 ns/op 2874.27 MB/s Benchmark_FanOut_512x100x100-16 1936 1840718 ns/op 2874.16 MB/s Benchmark_FanOut_512x100x100-16 1940 1855073 ns/op 2851.92 MB/s Benchmark_FanOut_512x100x100-16 1921 1830214 ns/op 2890.66 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16710780 ns/op 3171.64 MB/s Benchmark__FanOut_512x100x1k-16 216 16821368 ns/op 3150.79 MB/s Benchmark__FanOut_512x100x1k-16 216 16672883 ns/op 3178.85 MB/s Benchmark__FanOut_512x100x1k-16 213 16907859 ns/op 3134.67 MB/s Benchmark__FanOut_512x100x1k-16 211 16607939 ns/op 3191.28 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2947 1123280 ns/op 9286.24 MB/s Benchmark____FanOut_1kx10x1k-16 3015 1164813 ns/op 8955.12 MB/s Benchmark____FanOut_1kx10x1k-16 2878 1135533 ns/op 9186.03 MB/s Benchmark____FanOut_1kx10x1k-16 3196 1148907 ns/op 9079.09 MB/s Benchmark____FanOut_1kx10x1k-16 3196 1141119 ns/op 9141.06 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2793 1248040 ns/op 8349.92 MB/s Benchmark__FanOut_1kx100x100-16 2755 1251528 ns/op 8326.65 MB/s Benchmark__FanOut_1kx100x100-16 2780 1255810 ns/op 8298.26 MB/s Benchmark__FanOut_1kx100x100-16 2846 1265973 ns/op 8231.65 MB/s Benchmark__FanOut_1kx100x100-16 2799 1257153 ns/op 8289.40 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4316607 806.3 ns/op 308.83 MB/s Benchmark_____RFanOut_8x1x10-16 4393826 785.0 ns/op 317.21 MB/s Benchmark_____RFanOut_8x1x10-16 4282648 787.0 ns/op 316.40 MB/s Benchmark_____RFanOut_8x1x10-16 4475636 790.9 ns/op 314.84 MB/s Benchmark_____RFanOut_8x1x10-16 4568186 779.9 ns/op 319.27 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 497721 6160 ns/op 376.46 MB/s Benchmark____RFanOut_8x1x100-16 534534 6118 ns/op 379.03 MB/s Benchmark____RFanOut_8x1x100-16 546673 6327 ns/op 366.50 MB/s Benchmark____RFanOut_8x1x100-16 529473 6067 ns/op 382.23 MB/s Benchmark____RFanOut_8x1x100-16 526548 6099 ns/op 380.22 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48428 74546 ns/op 308.79 MB/s Benchmark___RFanOut_8x10x100-16 48148 74440 ns/op 309.23 MB/s Benchmark___RFanOut_8x10x100-16 47964 74084 ns/op 310.71 MB/s Benchmark___RFanOut_8x10x100-16 48062 74507 ns/op 308.95 MB/s Benchmark___RFanOut_8x10x100-16 47955 74716 ns/op 308.09 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5836 602881 ns/op 398.12 MB/s Benchmark__RFanOut_8x10x1000-16 5943 601215 ns/op 399.22 MB/s Benchmark__RFanOut_8x10x1000-16 5954 600540 ns/op 399.67 MB/s Benchmark__RFanOut_8x10x1000-16 6000 607939 ns/op 394.81 MB/s Benchmark__RFanOut_8x10x1000-16 5866 600828 ns/op 399.48 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5050 707764 ns/op 324.99 MB/s Benchmark__RFanOut_8x100x100-16 5050 708704 ns/op 324.56 MB/s Benchmark__RFanOut_8x100x100-16 4996 713916 ns/op 322.19 MB/s Benchmark__RFanOut_8x100x100-16 4971 707002 ns/op 325.34 MB/s Benchmark__RFanOut_8x100x100-16 4992 707077 ns/op 325.31 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 562 6254034 ns/op 383.76 MB/s Benchmark_RFanOut_8x100x1000-16 561 6260181 ns/op 383.38 MB/s Benchmark_RFanOut_8x100x1000-16 582 6136239 ns/op 391.12 MB/s Benchmark_RFanOut_8x100x1000-16 584 6215482 ns/op 386.14 MB/s Benchmark_RFanOut_8x100x1000-16 571 6160422 ns/op 389.59 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 525 6695588 ns/op 373.38 MB/s Benchmark_RFanOut_8x10x10000-16 528 6709300 ns/op 372.62 MB/s Benchmark_RFanOut_8x10x10000-16 534 6834867 ns/op 365.77 MB/s Benchmark_RFanOut_8x10x10000-16 520 6780584 ns/op 368.70 MB/s Benchmark_RFanOut_8x10x10000-16 537 6777971 ns/op 368.84 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3004 1136935 ns/op 9174.70 MB/s Benchmark_RFanOut_1kx10x1000-16 3015 1149056 ns/op 9077.92 MB/s Benchmark_RFanOut_1kx10x1000-16 3009 1160130 ns/op 8991.27 MB/s Benchmark_RFanOut_1kx10x1000-16 2971 1144385 ns/op 9114.97 MB/s Benchmark_RFanOut_1kx10x1000-16 2898 1166612 ns/op 8941.31 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6980324 505.1 ns/op 4114.26 MB/s Benchmark_____FanIn_1kx100x1-16 6915937 507.5 ns/op 4094.35 MB/s Benchmark_____FanIn_1kx100x1-16 6984021 507.3 ns/op 4096.07 MB/s Benchmark_____FanIn_1kx100x1-16 6924409 506.1 ns/op 4105.56 MB/s Benchmark_____FanIn_1kx100x1-16 6901579 503.7 ns/op 4125.37 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2635801 1384 ns/op 5939.17 MB/s Benchmark_____FanIn_4kx100x1-16 2637768 1364 ns/op 6029.61 MB/s Benchmark_____FanIn_4kx100x1-16 2578034 1358 ns/op 6053.55 MB/s Benchmark_____FanIn_4kx100x1-16 2661906 1356 ns/op 6064.43 MB/s Benchmark_____FanIn_4kx100x1-16 2634878 1382 ns/op 5948.67 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1680582 2076 ns/op 7904.70 MB/s Benchmark_____FanIn_8kx100x1-16 1671042 2106 ns/op 7793.48 MB/s Benchmark_____FanIn_8kx100x1-16 1663197 2107 ns/op 7790.64 MB/s Benchmark_____FanIn_8kx100x1-16 1670752 2139 ns/op 7674.13 MB/s Benchmark_____FanIn_8kx100x1-16 1703484 2085 ns/op 7871.93 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 872100 4182 ns/op 7842.70 MB/s Benchmark____FanIn_16kx100x1-16 867976 4193 ns/op 7823.14 MB/s Benchmark____FanIn_16kx100x1-16 861441 4177 ns/op 7852.20 MB/s Benchmark____FanIn_16kx100x1-16 868786 4161 ns/op 7882.28 MB/s Benchmark____FanIn_16kx100x1-16 862966 4142 ns/op 7918.46 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 171704 19902 ns/op 6587.54 MB/s Benchmark____FanIn_64kx100x1-16 165212 19720 ns/op 6648.35 MB/s Benchmark____FanIn_64kx100x1-16 166608 19966 ns/op 6566.22 MB/s Benchmark____FanIn_64kx100x1-16 172476 20071 ns/op 6531.88 MB/s Benchmark____FanIn_64kx100x1-16 161701 19821 ns/op 6614.41 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 341227270 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52458->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:52998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52728->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: 434956620 vs 1310900000 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:54674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54400->127.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:54944->127.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:54474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55086->127.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:55232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54752->127.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:54924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54862->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54972->127.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:54352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55030->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: 1231197280 vs 11496593000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57926->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:57410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57172->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: 877385370 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59438->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: 1027614510 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32934->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5520936 643.5 ns/op 441.36 MB/s Benchmark___BumpPubCount_1x3-16 5559280 639.0 ns/op 444.41 MB/s Benchmark___BumpPubCount_1x3-16 5554732 645.1 ns/op 440.27 MB/s Benchmark___BumpPubCount_1x3-16 5569440 644.9 ns/op 440.39 MB/s Benchmark___BumpPubCount_1x3-16 5528762 640.0 ns/op 443.76 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5296767 664.6 ns/op 427.32 MB/s Benchmark___BumpPubCount_2x3-16 5292410 670.5 ns/op 423.54 MB/s Benchmark___BumpPubCount_2x3-16 5276551 670.6 ns/op 423.47 MB/s Benchmark___BumpPubCount_2x3-16 5323243 671.4 ns/op 423.00 MB/s Benchmark___BumpPubCount_2x3-16 5346073 671.7 ns/op 422.83 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5591370 639.1 ns/op 444.36 MB/s Benchmark___BumpPubCount_5x3-16 5560098 639.7 ns/op 443.96 MB/s Benchmark___BumpPubCount_5x3-16 5442988 642.0 ns/op 442.37 MB/s Benchmark___BumpPubCount_5x3-16 5359466 642.8 ns/op 441.82 MB/s Benchmark___BumpPubCount_5x3-16 5610082 643.2 ns/op 441.55 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5590736 642.3 ns/op 442.13 MB/s Benchmark__BumpPubCount_10x3-16 5611442 640.3 ns/op 443.53 MB/s Benchmark__BumpPubCount_10x3-16 5568916 642.8 ns/op 441.79 MB/s Benchmark__BumpPubCount_10x3-16 5568764 642.4 ns/op 442.10 MB/s Benchmark__BumpPubCount_10x3-16 5596172 644.5 ns/op 440.66 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12200504 273.7 ns/op 3799.58 MB/s Benchmark____GWs_Opt_1kx01x0-16 13076330 282.6 ns/op 3680.24 MB/s Benchmark____GWs_Opt_1kx01x0-16 12777698 283.2 ns/op 3672.31 MB/s Benchmark____GWs_Opt_1kx01x0-16 13163139 286.4 ns/op 3631.82 MB/s Benchmark____GWs_Opt_1kx01x0-16 12798380 274.9 ns/op 3782.60 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10776886 343.0 ns/op 6017.86 MB/s Benchmark____GWs_Opt_2kx01x0-16 11151588 336.6 ns/op 6131.02 MB/s Benchmark____GWs_Opt_2kx01x0-16 11013274 343.4 ns/op 6009.78 MB/s Benchmark____GWs_Opt_2kx01x0-16 10764433 336.9 ns/op 6127.19 MB/s Benchmark____GWs_Opt_2kx01x0-16 9820054 327.8 ns/op 6297.34 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5700810 619.4 ns/op 6638.29 MB/s Benchmark____GWs_Opt_4kx01x0-16 5042965 608.9 ns/op 6753.20 MB/s Benchmark____GWs_Opt_4kx01x0-16 5775933 590.2 ns/op 6967.62 MB/s Benchmark____GWs_Opt_4kx01x0-16 5777227 626.7 ns/op 6560.90 MB/s Benchmark____GWs_Opt_4kx01x0-16 5701735 659.7 ns/op 6233.09 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29079735 112.1 ns/op 9274.91 MB/s Benchmark____GWs_Opt_1kx10x0-16 31491645 109.8 ns/op 9474.05 MB/s Benchmark____GWs_Opt_1kx10x0-16 28631457 134.6 ns/op 7727.34 MB/s Benchmark____GWs_Opt_1kx10x0-16 31291416 115.2 ns/op 9027.87 MB/s Benchmark____GWs_Opt_1kx10x0-16 29685036 116.0 ns/op 8964.28 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23953671 161.8 ns/op 12757.02 MB/s Benchmark____GWs_Opt_2kx10x0-16 21376028 154.9 ns/op 13326.71 MB/s Benchmark____GWs_Opt_2kx10x0-16 25510789 147.1 ns/op 14027.09 MB/s Benchmark____GWs_Opt_2kx10x0-16 24593486 149.7 ns/op 13791.12 MB/s Benchmark____GWs_Opt_2kx10x0-16 26341758 143.5 ns/op 14380.88 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 9050586 352.6 ns/op 11661.72 MB/s Benchmark____GWs_Opt_4kx10x0-16 12444729 300.0 ns/op 13706.61 MB/s Benchmark____GWs_Opt_4kx10x0-16 7415979 409.9 ns/op 10031.92 MB/s Benchmark____GWs_Opt_4kx10x0-16 10656880 289.8 ns/op 14187.75 MB/s Benchmark____GWs_Opt_4kx10x0-16 11458904 302.5 ns/op 13593.30 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6774649 549.4 ns/op 5687.90 MB/s Benchmark____GWs_Opt_1kx01x1-16 6647887 543.1 ns/op 5754.32 MB/s Benchmark____GWs_Opt_1kx01x1-16 6369657 545.1 ns/op 5732.71 MB/s Benchmark____GWs_Opt_1kx01x1-16 6668781 544.4 ns/op 5740.26 MB/s Benchmark____GWs_Opt_1kx01x1-16 6396980 540.5 ns/op 5781.87 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4261000 772.3 ns/op 8024.19 MB/s Benchmark____GWs_Opt_2kx01x1-16 4554168 762.2 ns/op 8130.72 MB/s Benchmark____GWs_Opt_2kx01x1-16 4711400 772.0 ns/op 8026.68 MB/s Benchmark____GWs_Opt_2kx01x1-16 4453676 778.7 ns/op 7957.81 MB/s Benchmark____GWs_Opt_2kx01x1-16 4632036 772.2 ns/op 8025.47 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2608521 1368 ns/op 9024.48 MB/s Benchmark____GWs_Opt_4kx01x1-16 2623994 1380 ns/op 8945.76 MB/s Benchmark____GWs_Opt_4kx01x1-16 2462828 1385 ns/op 8912.03 MB/s Benchmark____GWs_Opt_4kx01x1-16 2561251 1378 ns/op 8954.35 MB/s Benchmark____GWs_Opt_4kx01x1-16 2587558 1645 ns/op 7503.10 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6143638 563.3 ns/op 5548.06 MB/s Benchmark____GWs_Opt_1kx10x1-16 6084006 566.4 ns/op 5517.27 MB/s Benchmark____GWs_Opt_1kx10x1-16 6031586 595.1 ns/op 5251.06 MB/s Benchmark____GWs_Opt_1kx10x1-16 6130107 556.7 ns/op 5613.00 MB/s Benchmark____GWs_Opt_1kx10x1-16 6498390 583.3 ns/op 5357.21 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4117806 848.4 ns/op 7304.08 MB/s Benchmark____GWs_Opt_2kx10x1-16 4716968 865.8 ns/op 7157.35 MB/s Benchmark____GWs_Opt_2kx10x1-16 4071169 830.7 ns/op 7459.60 MB/s Benchmark____GWs_Opt_2kx10x1-16 4066501 838.0 ns/op 7394.96 MB/s Benchmark____GWs_Opt_2kx10x1-16 4044691 854.5 ns/op 7252.22 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2291113 1536 ns/op 8034.85 MB/s Benchmark____GWs_Opt_4kx10x1-16 2363571 1527 ns/op 8084.25 MB/s Benchmark____GWs_Opt_4kx10x1-16 2329932 1526 ns/op 8089.65 MB/s Benchmark____GWs_Opt_4kx10x1-16 2056072 1529 ns/op 8073.61 MB/s Benchmark____GWs_Opt_4kx10x1-16 2353945 1541 ns/op 8008.20 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12861771 297.1 ns/op 3500.17 MB/s Benchmark____GWs_Int_1kx01x0-16 11801906 294.5 ns/op 3531.40 MB/s Benchmark____GWs_Int_1kx01x0-16 12117801 295.3 ns/op 3521.30 MB/s Benchmark____GWs_Int_1kx01x0-16 11699100 289.1 ns/op 3597.01 MB/s Benchmark____GWs_Int_1kx01x0-16 11273719 288.4 ns/op 3606.67 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9239071 345.7 ns/op 5969.73 MB/s Benchmark____GWs_Int_2kx01x0-16 9936997 368.8 ns/op 5596.18 MB/s Benchmark____GWs_Int_2kx01x0-16 9585424 362.4 ns/op 5695.56 MB/s Benchmark____GWs_Int_2kx01x0-16 10479500 371.2 ns/op 5560.36 MB/s Benchmark____GWs_Int_2kx01x0-16 9736401 357.2 ns/op 5778.15 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5802195 634.2 ns/op 6484.18 MB/s Benchmark____GWs_Int_4kx01x0-16 5331158 634.4 ns/op 6481.94 MB/s Benchmark____GWs_Int_4kx01x0-16 5687269 732.5 ns/op 5613.40 MB/s Benchmark____GWs_Int_4kx01x0-16 4773915 646.0 ns/op 6365.57 MB/s Benchmark____GWs_Int_4kx01x0-16 5358592 635.0 ns/op 6475.15 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30354834 106.3 ns/op 9779.84 MB/s Benchmark____GWs_Int_1kx10x0-16 30586156 115.9 ns/op 8974.09 MB/s Benchmark____GWs_Int_1kx10x0-16 31110230 117.0 ns/op 8887.71 MB/s Benchmark____GWs_Int_1kx10x0-16 32203630 112.0 ns/op 9286.50 MB/s Benchmark____GWs_Int_1kx10x0-16 26426407 117.2 ns/op 8876.76 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25597018 148.2 ns/op 13927.05 MB/s Benchmark____GWs_Int_2kx10x0-16 25942352 143.7 ns/op 14360.80 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:42462->127.0.0.1:43803: 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:47090->127.0.0.1:42787: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 25767177 143.0 ns/op 14438.27 MB/s Benchmark____GWs_Int_2kx10x0-16 26227021 146.4 ns/op 14100.82 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13344494 321.7 ns/op 12781.76 MB/s Benchmark____GWs_Int_4kx10x0-16 12367906 283.6 ns/op 14499.25 MB/s Benchmark____GWs_Int_4kx10x0-16 13157288 333.1 ns/op 12344.72 MB/s Benchmark____GWs_Int_4kx10x0-16 11521636 290.9 ns/op 14136.18 MB/s Benchmark____GWs_Int_4kx10x0-16 12367332 287.3 ns/op 14313.62 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6530584 554.5 ns/op 5635.79 MB/s Benchmark____GWs_Int_1kx01x1-16 6487856 564.9 ns/op 5531.54 MB/s Benchmark____GWs_Int_1kx01x1-16 6457917 560.3 ns/op 5577.24 MB/s Benchmark____GWs_Int_1kx01x1-16 6389380 561.8 ns/op 5562.91 MB/s Benchmark____GWs_Int_1kx01x1-16 6529388 555.6 ns/op 5624.60 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4410696 823.8 ns/op 7522.72 MB/s Benchmark____GWs_Int_2kx01x1-16 4309243 777.8 ns/op 7967.31 MB/s Benchmark____GWs_Int_2kx01x1-16 4556740 779.4 ns/op 7950.55 MB/s Benchmark____GWs_Int_2kx01x1-16 4656048 779.1 ns/op 7954.56 MB/s Benchmark____GWs_Int_2kx01x1-16 4676073 769.4 ns/op 8054.48 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2619108 1595 ns/op 7735.31 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:34556->127.0.0.1:41839: i/o timeout bench_test.go:167: Did not receive all bytes: 6563537316 vs 9305773400 --- FAIL: Benchmark____GWs_Int_4kx01x1-16 Benchmark____GWs_Int_4kx01x1-16 2276469 1369 ns/op 9012.07 MB/s Benchmark____GWs_Int_4kx01x1-16 2665327 1396 ns/op 8841.59 MB/s Benchmark____GWs_Int_4kx01x1-16 2580150 1393 ns/op 8856.96 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6096037 564.5 ns/op 5536.14 MB/s Benchmark____GWs_Int_1kx10x1-16 6314385 634.5 ns/op 4925.25 MB/s Benchmark____GWs_Int_1kx10x1-16 6315421 556.5 ns/op 5615.60 MB/s Benchmark____GWs_Int_1kx10x1-16 6180168 562.9 ns/op 5551.71 MB/s Benchmark____GWs_Int_1kx10x1-16 6559009 561.2 ns/op 5568.36 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4027704 843.5 ns/op 7346.72 MB/s Benchmark____GWs_Int_2kx10x1-16 4272402 884.3 ns/op 7007.82 MB/s Benchmark____GWs_Int_2kx10x1-16 4087742 852.3 ns/op 7271.29 MB/s Benchmark____GWs_Int_2kx10x1-16 4225035 845.6 ns/op 7328.91 MB/s Benchmark____GWs_Int_2kx10x1-16 3876446 855.3 ns/op 7245.44 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2324949 1557 ns/op 7925.41 MB/s Benchmark____GWs_Int_4kx10x1-16 2321373 1512 ns/op 8161.06 MB/s Benchmark____GWs_Int_4kx10x1-16 2148381 1514 ns/op 8152.62 MB/s Benchmark____GWs_Int_4kx10x1-16 2297599 1532 ns/op 8055.23 MB/s Benchmark____GWs_Int_4kx10x1-16 2306023 1506 ns/op 8193.32 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8382873 432.8 ns/op 235.70 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8169848 440.8 ns/op 231.41 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8315338 463.2 ns/op 220.23 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8230742 435.8 ns/op 234.04 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8524680 431.7 ns/op 236.29 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 634908 5042 ns/op 35.11 MB/s Benchmark__GWs_Reqs_1SubEach-16 795405 5214 ns/op 33.95 MB/s Benchmark__GWs_Reqs_1SubEach-16 726366 5289 ns/op 33.46 MB/s Benchmark__GWs_Reqs_1SubEach-16 733837 5307 ns/op 33.35 MB/s Benchmark__GWs_Reqs_1SubEach-16 788086 5304 ns/op 33.37 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2275.565s ❌ Non-zero exit code: 1