> ROOT_DIR=/tmp/go-bench-away-job-1495dae1-7022-4cfa-996f-725a760e0f8c-923558022 > OUTPUT_FILE=/tmp/go-bench-away-job-1495dae1-7022-4cfa-996f-725a760e0f8c-923558022/results.txt > SHA_FILE=/tmp/go-bench-away-job-1495dae1-7022-4cfa-996f-725a760e0f8c-923558022/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-1495dae1-7022-4cfa-996f-725a760e0f8c-923558022/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-1495dae1-7022-4cfa-996f-725a760e0f8c-923558022/source.git SHA of main: 1be499156d9bc757ea08bd148608b622e38b7514 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-build1955167491=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-1495dae1-7022-4cfa-996f-725a760e0f8c-923558022/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 49417328 72.77 ns/op 151.15 MB/s Benchmark______Pub0b_Payload-16 46695774 73.81 ns/op 149.04 MB/s Benchmark______Pub0b_Payload-16 46616665 72.30 ns/op 152.15 MB/s Benchmark______Pub0b_Payload-16 46857378 72.45 ns/op 151.82 MB/s Benchmark______Pub0b_Payload-16 47027929 72.39 ns/op 151.94 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46741058 73.40 ns/op 258.86 MB/s Benchmark______Pub8b_Payload-16 46221052 73.44 ns/op 258.72 MB/s Benchmark______Pub8b_Payload-16 45041094 73.83 ns/op 257.36 MB/s Benchmark______Pub8b_Payload-16 48875608 73.22 ns/op 259.50 MB/s Benchmark______Pub8b_Payload-16 46296849 73.21 ns/op 259.53 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43931875 78.36 ns/op 561.51 MB/s Benchmark_____Pub32b_Payload-16 43322505 79.10 ns/op 556.24 MB/s Benchmark_____Pub32b_Payload-16 39559334 78.28 ns/op 562.10 MB/s Benchmark_____Pub32b_Payload-16 43959994 79.64 ns/op 552.51 MB/s Benchmark_____Pub32b_Payload-16 43678608 78.16 ns/op 562.93 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 37970121 88.55 ns/op 1592.33 MB/s Benchmark____Pub128B_Payload-16 38473046 87.40 ns/op 1613.24 MB/s Benchmark____Pub128B_Payload-16 38663397 88.54 ns/op 1592.56 MB/s Benchmark____Pub128B_Payload-16 41348175 87.99 ns/op 1602.53 MB/s Benchmark____Pub128B_Payload-16 41197428 87.28 ns/op 1615.57 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35116182 98.27 ns/op 2737.22 MB/s Benchmark____Pub256B_Payload-16 35631938 96.56 ns/op 2785.78 MB/s Benchmark____Pub256B_Payload-16 35528340 95.77 ns/op 2808.82 MB/s Benchmark____Pub256B_Payload-16 35633254 95.05 ns/op 2830.21 MB/s Benchmark____Pub256B_Payload-16 34788933 100.8 ns/op 2668.57 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24996207 146.6 ns/op 7078.35 MB/s Benchmark______Pub1K_Payload-16 24445237 140.6 ns/op 7384.20 MB/s Benchmark______Pub1K_Payload-16 24601215 153.8 ns/op 6749.42 MB/s Benchmark______Pub1K_Payload-16 25623183 145.5 ns/op 7136.37 MB/s Benchmark______Pub1K_Payload-16 23872255 142.3 ns/op 7295.67 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5670208 618.3 ns/op 6647.41 MB/s Benchmark______Pub4K_Payload-16 5002963 609.1 ns/op 6748.02 MB/s Benchmark______Pub4K_Payload-16 5570763 623.2 ns/op 6595.31 MB/s Benchmark______Pub4K_Payload-16 5875365 623.0 ns/op 6596.69 MB/s Benchmark______Pub4K_Payload-16 5725507 626.6 ns/op 6559.55 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2761405 1312 ns/op 6254.12 MB/s Benchmark______Pub8K_Payload-16 2759782 1281 ns/op 6407.03 MB/s Benchmark______Pub8K_Payload-16 2751883 1294 ns/op 6340.81 MB/s Benchmark______Pub8K_Payload-16 2676150 1284 ns/op 6393.44 MB/s Benchmark______Pub8K_Payload-16 2729445 1276 ns/op 6433.47 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 661506 5504 ns/op 5955.76 MB/s Benchmark_____Pub32K_Payload-16 649911 5540 ns/op 5917.10 MB/s Benchmark_____Pub32K_Payload-16 656200 5896 ns/op 5559.90 MB/s Benchmark_____Pub32K_Payload-16 649372 5479 ns/op 5983.78 MB/s Benchmark_____Pub32K_Payload-16 638761 5658 ns/op 5794.59 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32735227 93.86 ns/op 117.19 MB/s Benchmark__AuthPub0b_Payload-16 32566204 94.00 ns/op 117.02 MB/s Benchmark__AuthPub0b_Payload-16 36324660 94.99 ns/op 115.80 MB/s Benchmark__AuthPub0b_Payload-16 36137750 94.28 ns/op 116.67 MB/s Benchmark__AuthPub0b_Payload-16 36421922 94.00 ns/op 117.02 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15344670 231.4 ns/op Benchmark_____________PubSub-16 15444211 231.5 ns/op Benchmark_____________PubSub-16 15226700 231.5 ns/op Benchmark_____________PubSub-16 15291390 231.6 ns/op Benchmark_____________PubSub-16 15363440 232.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15200133 230.7 ns/op Benchmark_____PubSubTwoConns-16 15339621 229.3 ns/op Benchmark_____PubSubTwoConns-16 15408933 229.3 ns/op Benchmark_____PubSubTwoConns-16 15460082 230.0 ns/op Benchmark_____PubSubTwoConns-16 15142144 230.3 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34346->127.0.0.1:34581: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:54544->127.0.0.1:40291: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:52826->127.0.0.1:45783: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46318->127.0.0.1:33511: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49802->127.0.0.1:37675: 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 14064104 250.4 ns/op Benchmark_____PubTwoQueueSub-16 14193537 250.1 ns/op Benchmark_____PubTwoQueueSub-16 14180151 249.9 ns/op Benchmark_____PubTwoQueueSub-16 14197347 249.2 ns/op Benchmark_____PubTwoQueueSub-16 14099983 249.8 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14180422 249.5 ns/op Benchmark____PubFourQueueSub-16 14171782 249.1 ns/op Benchmark____PubFourQueueSub-16 14250574 249.8 ns/op Benchmark____PubFourQueueSub-16 14146711 249.7 ns/op Benchmark____PubFourQueueSub-16 14383028 250.0 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14145612 250.3 ns/op Benchmark___PubEightQueueSub-16 14204064 249.7 ns/op Benchmark___PubEightQueueSub-16 14273461 250.5 ns/op Benchmark___PubEightQueueSub-16 14270264 250.1 ns/op Benchmark___PubEightQueueSub-16 14185952 250.1 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23115 156423 ns/op Benchmark_PubSub512kTwoConns-16 22958 154977 ns/op Benchmark_PubSub512kTwoConns-16 23139 156037 ns/op Benchmark_PubSub512kTwoConns-16 22996 158175 ns/op Benchmark_PubSub512kTwoConns-16 22128 161964 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15056876 233.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15094774 235.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 14810605 233.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 14972340 235.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15054716 233.6 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14839036 234.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 14951336 234.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 14936598 234.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 14856998 232.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 14982408 234.5 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11076010 320.1 ns/op Benchmark____RoutedPubSub_0b-16 11075172 316.1 ns/op Benchmark____RoutedPubSub_0b-16 11190374 321.6 ns/op Benchmark____RoutedPubSub_0b-16 10842049 318.1 ns/op Benchmark____RoutedPubSub_0b-16 11259171 314.4 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6503332 540.4 ns/op Benchmark____RoutedPubSub_1K-16 6334818 540.4 ns/op Benchmark____RoutedPubSub_1K-16 6540847 543.1 ns/op Benchmark____RoutedPubSub_1K-16 6616914 539.6 ns/op Benchmark____RoutedPubSub_1K-16 6688300 538.3 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 77167 44879 ns/op Benchmark__RoutedPubSub_100K-16 80152 45253 ns/op Benchmark__RoutedPubSub_100K-16 77276 47791 ns/op Benchmark__RoutedPubSub_100K-16 72709 48228 ns/op Benchmark__RoutedPubSub_100K-16 81655 44418 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9895275 309.8 ns/op Benchmark____Routed2QueueSub-16 9787144 317.6 ns/op Benchmark____Routed2QueueSub-16 9926637 319.1 ns/op Benchmark____Routed2QueueSub-16 9705770 325.1 ns/op Benchmark____Routed2QueueSub-16 9670028 317.8 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9621187 316.5 ns/op Benchmark____Routed4QueueSub-16 9797353 321.6 ns/op Benchmark____Routed4QueueSub-16 11478496 320.4 ns/op Benchmark____Routed4QueueSub-16 9382663 322.0 ns/op Benchmark____Routed4QueueSub-16 9304944 323.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 10974768 324.2 ns/op Benchmark____Routed8QueueSub-16 11086299 323.5 ns/op Benchmark____Routed8QueueSub-16 9316202 329.6 ns/op Benchmark____Routed8QueueSub-16 9341811 330.8 ns/op Benchmark____Routed8QueueSub-16 9318081 324.8 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8936805 344.1 ns/op Benchmark___Routed16QueueSub-16 10513964 340.8 ns/op Benchmark___Routed16QueueSub-16 8880433 343.6 ns/op Benchmark___Routed16QueueSub-16 8756767 343.2 ns/op Benchmark___Routed16QueueSub-16 8899761 340.8 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6393187 544.1 ns/op Benchmark____________RouteCompressOff-16 6223443 553.7 ns/op Benchmark____________RouteCompressOff-16 6478723 559.3 ns/op Benchmark____________RouteCompressOff-16 6427576 548.4 ns/op Benchmark____________RouteCompressOff-16 6411832 550.0 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6539439 555.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6467514 556.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6390763 551.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6260203 550.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6302899 560.9 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6593131 548.8 ns/op Benchmark_________RouteCompressS2Fast-16 6543830 550.6 ns/op Benchmark_________RouteCompressS2Fast-16 6372655 549.3 ns/op Benchmark_________RouteCompressS2Fast-16 6316669 554.5 ns/op Benchmark_________RouteCompressS2Fast-16 6527983 545.1 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6473496 545.6 ns/op Benchmark_______RouteCompressS2Better-16 6310696 555.6 ns/op Benchmark_______RouteCompressS2Better-16 6393313 546.2 ns/op Benchmark_______RouteCompressS2Better-16 6276891 552.0 ns/op Benchmark_______RouteCompressS2Better-16 6621170 546.3 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6438036 549.9 ns/op Benchmark_________RouteCompressS2Best-16 6461191 549.4 ns/op Benchmark_________RouteCompressS2Best-16 6454918 553.2 ns/op Benchmark_________RouteCompressS2Best-16 6322185 544.2 ns/op Benchmark_________RouteCompressS2Best-16 6492748 542.9 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4648806 763.5 ns/op 326.12 MB/s Benchmark______FanOut_8x1x10-16 4674621 769.6 ns/op 323.56 MB/s Benchmark______FanOut_8x1x10-16 4644370 773.1 ns/op 322.09 MB/s Benchmark______FanOut_8x1x10-16 4615552 764.7 ns/op 325.63 MB/s Benchmark______FanOut_8x1x10-16 4625923 766.8 ns/op 324.71 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 562549 6123 ns/op 378.72 MB/s Benchmark_____FanOut_8x1x100-16 548256 6101 ns/op 380.09 MB/s Benchmark_____FanOut_8x1x100-16 569182 6021 ns/op 385.15 MB/s Benchmark_____FanOut_8x1x100-16 552211 6021 ns/op 385.14 MB/s Benchmark_____FanOut_8x1x100-16 569108 6074 ns/op 381.81 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47618 75023 ns/op 306.83 MB/s Benchmark____FanOut_8x10x100-16 48349 74118 ns/op 310.57 MB/s Benchmark____FanOut_8x10x100-16 48110 74316 ns/op 309.75 MB/s Benchmark____FanOut_8x10x100-16 48294 74216 ns/op 310.16 MB/s Benchmark____FanOut_8x10x100-16 48103 74328 ns/op 309.69 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5947 591627 ns/op 405.69 MB/s Benchmark___FanOut_8x10x1000-16 5774 596270 ns/op 402.53 MB/s Benchmark___FanOut_8x10x1000-16 5791 596305 ns/op 402.51 MB/s Benchmark___FanOut_8x10x1000-16 5995 591607 ns/op 405.71 MB/s Benchmark___FanOut_8x10x1000-16 5528 596623 ns/op 402.30 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5082 708795 ns/op 324.52 MB/s Benchmark___FanOut_8x100x100-16 5106 702181 ns/op 327.58 MB/s Benchmark___FanOut_8x100x100-16 5083 700401 ns/op 328.41 MB/s Benchmark___FanOut_8x100x100-16 5073 715102 ns/op 321.66 MB/s Benchmark___FanOut_8x100x100-16 4965 705304 ns/op 326.13 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 594 6083290 ns/op 394.53 MB/s Benchmark__FanOut_8x100x1000-16 586 6059937 ns/op 396.05 MB/s Benchmark__FanOut_8x100x1000-16 583 6083197 ns/op 394.53 MB/s Benchmark__FanOut_8x100x1000-16 584 6030645 ns/op 397.97 MB/s Benchmark__FanOut_8x100x1000-16 588 6143984 ns/op 390.63 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 535 6717812 ns/op 372.15 MB/s Benchmark__FanOut_8x10x10000-16 537 6695519 ns/op 373.39 MB/s Benchmark__FanOut_8x10x10000-16 538 6936817 ns/op 360.40 MB/s Benchmark__FanOut_8x10x10000-16 511 6763822 ns/op 369.62 MB/s Benchmark__FanOut_8x10x10000-16 519 6704154 ns/op 372.91 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 951 3753680 ns/op 306.37 MB/s Benchmark___FanOut_8x500x100-16 951 3733085 ns/op 308.06 MB/s Benchmark___FanOut_8x500x100-16 952 3724468 ns/op 308.77 MB/s Benchmark___FanOut_8x500x100-16 956 3724341 ns/op 308.78 MB/s Benchmark___FanOut_8x500x100-16 956 3716139 ns/op 309.47 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 369052 9434 ns/op 1551.94 MB/s Benchmark___FanOut_128x1x100-16 356667 9452 ns/op 1549.05 MB/s Benchmark___FanOut_128x1x100-16 367623 9512 ns/op 1539.15 MB/s Benchmark___FanOut_128x1x100-16 361626 9476 ns/op 1545.08 MB/s Benchmark___FanOut_128x1x100-16 359529 9427 ns/op 1553.03 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32853 110165 ns/op 1317.49 MB/s Benchmark__FanOut_128x10x100-16 32706 109054 ns/op 1330.91 MB/s Benchmark__FanOut_128x10x100-16 32952 109158 ns/op 1329.64 MB/s Benchmark__FanOut_128x10x100-16 32856 108854 ns/op 1333.35 MB/s Benchmark__FanOut_128x10x100-16 32946 109068 ns/op 1330.73 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4143 869641 ns/op 1679.02 MB/s Benchmark_FanOut_128x10x1000-16 4166 870394 ns/op 1677.56 MB/s Benchmark_FanOut_128x10x1000-16 3968 863017 ns/op 1691.90 MB/s Benchmark_FanOut_128x10x1000-16 4101 863279 ns/op 1691.39 MB/s Benchmark_FanOut_128x10x1000-16 4184 871135 ns/op 1676.14 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3568 999026 ns/op 1451.55 MB/s Benchmark_FanOut_128x100x100-16 3486 1004257 ns/op 1443.99 MB/s Benchmark_FanOut_128x100x100-16 3583 999420 ns/op 1450.98 MB/s Benchmark_FanOut_128x100x100-16 3574 998611 ns/op 1452.16 MB/s Benchmark_FanOut_128x100x100-16 3518 1004877 ns/op 1443.10 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 394 9187481 ns/op 1589.13 MB/s BenchmarkFanOut_128x100x1000-16 391 9064776 ns/op 1610.65 MB/s BenchmarkFanOut_128x100x1000-16 384 9334344 ns/op 1564.13 MB/s BenchmarkFanOut_128x100x1000-16 388 9066297 ns/op 1610.38 MB/s BenchmarkFanOut_128x100x1000-16 388 9224051 ns/op 1582.83 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 380 9529713 ns/op 1542.56 MB/s BenchmarkFanOut_128x10x10000-16 373 9477792 ns/op 1551.01 MB/s BenchmarkFanOut_128x10x10000-16 375 9473482 ns/op 1551.71 MB/s BenchmarkFanOut_128x10x10000-16 378 9574322 ns/op 1535.37 MB/s BenchmarkFanOut_128x10x10000-16 374 9509864 ns/op 1545.78 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 676 5236384 ns/op 1384.57 MB/s BenchmarkFanOut__128x500x100-16 686 5227084 ns/op 1387.03 MB/s BenchmarkFanOut__128x500x100-16 679 5242024 ns/op 1383.08 MB/s BenchmarkFanOut__128x500x100-16 680 5239287 ns/op 1383.80 MB/s BenchmarkFanOut__128x500x100-16 679 5232989 ns/op 1385.47 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1915 1831796 ns/op 2888.16 MB/s Benchmark_FanOut_512x100x100-16 1948 1819791 ns/op 2907.22 MB/s Benchmark_FanOut_512x100x100-16 1946 1837515 ns/op 2879.17 MB/s Benchmark_FanOut_512x100x100-16 1950 1824075 ns/op 2900.39 MB/s Benchmark_FanOut_512x100x100-16 1918 1823736 ns/op 2900.93 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 218 16426264 ns/op 3226.57 MB/s Benchmark__FanOut_512x100x1k-16 217 16644474 ns/op 3184.27 MB/s Benchmark__FanOut_512x100x1k-16 217 16615787 ns/op 3189.77 MB/s Benchmark__FanOut_512x100x1k-16 217 16634687 ns/op 3186.15 MB/s Benchmark__FanOut_512x100x1k-16 214 16380239 ns/op 3235.64 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3147 1141360 ns/op 9139.13 MB/s Benchmark____FanOut_1kx10x1k-16 2938 1147074 ns/op 9093.60 MB/s Benchmark____FanOut_1kx10x1k-16 2888 1135180 ns/op 9188.89 MB/s Benchmark____FanOut_1kx10x1k-16 2869 1119043 ns/op 9321.39 MB/s Benchmark____FanOut_1kx10x1k-16 2811 1121420 ns/op 9301.63 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2775 1246184 ns/op 8362.36 MB/s Benchmark__FanOut_1kx100x100-16 2827 1245767 ns/op 8365.16 MB/s Benchmark__FanOut_1kx100x100-16 2836 1243849 ns/op 8378.06 MB/s Benchmark__FanOut_1kx100x100-16 2823 1251249 ns/op 8328.51 MB/s Benchmark__FanOut_1kx100x100-16 2785 1248900 ns/op 8344.18 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4496610 832.4 ns/op 299.13 MB/s Benchmark_____RFanOut_8x1x10-16 4395578 771.0 ns/op 322.96 MB/s Benchmark_____RFanOut_8x1x10-16 4351630 762.6 ns/op 326.51 MB/s Benchmark_____RFanOut_8x1x10-16 4494186 781.0 ns/op 318.81 MB/s Benchmark_____RFanOut_8x1x10-16 4537424 767.3 ns/op 324.50 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 536463 6052 ns/op 383.16 MB/s Benchmark____RFanOut_8x1x100-16 502935 6068 ns/op 382.16 MB/s Benchmark____RFanOut_8x1x100-16 512089 6104 ns/op 379.93 MB/s Benchmark____RFanOut_8x1x100-16 498481 6048 ns/op 383.44 MB/s Benchmark____RFanOut_8x1x100-16 533324 6076 ns/op 381.64 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48062 74195 ns/op 310.25 MB/s Benchmark___RFanOut_8x10x100-16 48422 74031 ns/op 310.94 MB/s Benchmark___RFanOut_8x10x100-16 48432 73996 ns/op 311.08 MB/s Benchmark___RFanOut_8x10x100-16 48354 73892 ns/op 311.52 MB/s Benchmark___RFanOut_8x10x100-16 48243 74876 ns/op 307.43 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6003 593430 ns/op 404.46 MB/s Benchmark__RFanOut_8x10x1000-16 5565 590525 ns/op 406.45 MB/s Benchmark__RFanOut_8x10x1000-16 5793 591980 ns/op 405.45 MB/s Benchmark__RFanOut_8x10x1000-16 5846 592012 ns/op 405.43 MB/s Benchmark__RFanOut_8x10x1000-16 6012 596536 ns/op 402.35 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5005 699718 ns/op 328.73 MB/s Benchmark__RFanOut_8x100x100-16 5040 700603 ns/op 328.32 MB/s Benchmark__RFanOut_8x100x100-16 5013 703350 ns/op 327.03 MB/s Benchmark__RFanOut_8x100x100-16 5026 702678 ns/op 327.35 MB/s Benchmark__RFanOut_8x100x100-16 4962 703407 ns/op 327.01 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 564 6112312 ns/op 392.65 MB/s Benchmark_RFanOut_8x100x1000-16 584 6079089 ns/op 394.80 MB/s Benchmark_RFanOut_8x100x1000-16 588 6178318 ns/op 388.46 MB/s Benchmark_RFanOut_8x100x1000-16 586 6179124 ns/op 388.41 MB/s Benchmark_RFanOut_8x100x1000-16 583 6363925 ns/op 377.13 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 532 6698312 ns/op 373.23 MB/s Benchmark_RFanOut_8x10x10000-16 528 6670310 ns/op 374.80 MB/s Benchmark_RFanOut_8x10x10000-16 530 6780916 ns/op 368.68 MB/s Benchmark_RFanOut_8x10x10000-16 534 6696643 ns/op 373.32 MB/s Benchmark_RFanOut_8x10x10000-16 532 6734902 ns/op 371.20 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2834 1142654 ns/op 9128.78 MB/s Benchmark_RFanOut_1kx10x1000-16 2820 1151408 ns/op 9059.38 MB/s Benchmark_RFanOut_1kx10x1000-16 3039 1154355 ns/op 9036.25 MB/s Benchmark_RFanOut_1kx10x1000-16 3140 1159390 ns/op 8997.00 MB/s Benchmark_RFanOut_1kx10x1000-16 2871 1136682 ns/op 9176.74 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6976590 504.6 ns/op 4118.08 MB/s Benchmark_____FanIn_1kx100x1-16 6973064 505.9 ns/op 4107.74 MB/s Benchmark_____FanIn_1kx100x1-16 6977576 505.6 ns/op 4109.84 MB/s Benchmark_____FanIn_1kx100x1-16 6980809 508.0 ns/op 4090.69 MB/s Benchmark_____FanIn_1kx100x1-16 6934830 503.0 ns/op 4131.26 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2642167 1335 ns/op 6157.97 MB/s Benchmark_____FanIn_4kx100x1-16 2574943 1359 ns/op 6049.96 MB/s Benchmark_____FanIn_4kx100x1-16 2591730 1356 ns/op 6061.40 MB/s Benchmark_____FanIn_4kx100x1-16 2509701 1360 ns/op 6044.96 MB/s Benchmark_____FanIn_4kx100x1-16 2618649 1370 ns/op 6000.05 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1725650 2109 ns/op 7783.84 MB/s Benchmark_____FanIn_8kx100x1-16 1680027 2113 ns/op 7769.06 MB/s Benchmark_____FanIn_8kx100x1-16 1716861 2123 ns/op 7731.23 MB/s Benchmark_____FanIn_8kx100x1-16 1705825 2100 ns/op 7816.68 MB/s Benchmark_____FanIn_8kx100x1-16 1714976 2074 ns/op 7913.40 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 873638 4123 ns/op 7955.73 MB/s Benchmark____FanIn_16kx100x1-16 862728 4162 ns/op 7880.26 MB/s Benchmark____FanIn_16kx100x1-16 878344 4106 ns/op 7987.79 MB/s Benchmark____FanIn_16kx100x1-16 793323 4157 ns/op 7891.21 MB/s Benchmark____FanIn_16kx100x1-16 867789 4160 ns/op 7885.56 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 170755 20058 ns/op 6536.19 MB/s Benchmark____FanIn_64kx100x1-16 162292 19866 ns/op 6599.44 MB/s Benchmark____FanIn_64kx100x1-16 168152 19983 ns/op 6560.94 MB/s Benchmark____FanIn_64kx100x1-16 171512 19892 ns/op 6590.76 MB/s Benchmark____FanIn_64kx100x1-16 163388 19682 ns/op 6661.00 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 510595550 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57116->127.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:57286->127.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:57316->127.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:57150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56982->127.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:1096: Received error on PUB write: write tcp 127.0.0.1:57532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57520->127.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: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:57414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57238->127.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:57066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57508->127.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: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:57002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57204->127.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:56890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57572->127.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:56980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57182->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:57446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57402->127.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:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 552806530 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58844->127.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:59278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58854->127.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:59114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59240->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:58668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59012->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: 500370530 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33038->127.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:60658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60800->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32898->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32844->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32956->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60440->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32836->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60524->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:60448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60982->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 588856280 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34518->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34746->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: 1103122350 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36132->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5583380 644.2 ns/op 440.88 MB/s Benchmark___BumpPubCount_1x3-16 5554999 650.1 ns/op 436.89 MB/s Benchmark___BumpPubCount_1x3-16 5538804 644.3 ns/op 440.77 MB/s Benchmark___BumpPubCount_1x3-16 5575752 649.9 ns/op 436.98 MB/s Benchmark___BumpPubCount_1x3-16 5479062 647.7 ns/op 438.46 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5256280 670.1 ns/op 423.84 MB/s Benchmark___BumpPubCount_2x3-16 5210612 672.4 ns/op 422.40 MB/s Benchmark___BumpPubCount_2x3-16 5338057 674.2 ns/op 421.23 MB/s Benchmark___BumpPubCount_2x3-16 5306529 669.8 ns/op 424.02 MB/s Benchmark___BumpPubCount_2x3-16 5338603 672.6 ns/op 422.24 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5567499 643.8 ns/op 441.12 MB/s Benchmark___BumpPubCount_5x3-16 5432518 644.5 ns/op 440.63 MB/s Benchmark___BumpPubCount_5x3-16 5399859 640.8 ns/op 443.22 MB/s Benchmark___BumpPubCount_5x3-16 5587875 642.1 ns/op 442.27 MB/s Benchmark___BumpPubCount_5x3-16 5550194 643.9 ns/op 441.05 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5581587 642.3 ns/op 442.18 MB/s Benchmark__BumpPubCount_10x3-16 4835054 644.7 ns/op 440.52 MB/s Benchmark__BumpPubCount_10x3-16 5570740 644.4 ns/op 440.75 MB/s Benchmark__BumpPubCount_10x3-16 5587512 649.7 ns/op 437.12 MB/s Benchmark__BumpPubCount_10x3-16 5609908 644.4 ns/op 440.70 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11916903 279.9 ns/op 3716.00 MB/s Benchmark____GWs_Opt_1kx01x0-16 12373050 278.3 ns/op 3737.12 MB/s Benchmark____GWs_Opt_1kx01x0-16 12482784 278.8 ns/op 3729.87 MB/s Benchmark____GWs_Opt_1kx01x0-16 12560841 274.3 ns/op 3791.32 MB/s Benchmark____GWs_Opt_1kx01x0-16 12454422 276.5 ns/op 3760.99 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10221786 349.4 ns/op 5907.62 MB/s Benchmark____GWs_Opt_2kx01x0-16 10022360 322.9 ns/op 6391.24 MB/s Benchmark____GWs_Opt_2kx01x0-16 10005386 321.8 ns/op 6413.56 MB/s Benchmark____GWs_Opt_2kx01x0-16 10149847 342.5 ns/op 6027.03 MB/s Benchmark____GWs_Opt_2kx01x0-16 9957732 335.7 ns/op 6148.44 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5387101 660.2 ns/op 6228.42 MB/s Benchmark____GWs_Opt_4kx01x0-16 5441703 717.8 ns/op 5729.00 MB/s Benchmark____GWs_Opt_4kx01x0-16 5818618 661.5 ns/op 6216.38 MB/s Benchmark____GWs_Opt_4kx01x0-16 5605352 621.7 ns/op 6614.56 MB/s Benchmark____GWs_Opt_4kx01x0-16 5837953 628.3 ns/op 6544.16 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30859600 112.0 ns/op 9289.07 MB/s Benchmark____GWs_Opt_1kx10x0-16 31243935 112.6 ns/op 9235.08 MB/s Benchmark____GWs_Opt_1kx10x0-16 30847215 122.4 ns/op 8497.45 MB/s Benchmark____GWs_Opt_1kx10x0-16 30871317 115.6 ns/op 8994.32 MB/s Benchmark____GWs_Opt_1kx10x0-16 29707444 117.7 ns/op 8836.22 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24575610 150.5 ns/op 13714.96 MB/s Benchmark____GWs_Opt_2kx10x0-16 25569867 142.7 ns/op 14459.11 MB/s Benchmark____GWs_Opt_2kx10x0-16 23802200 159.4 ns/op 12945.54 MB/s Benchmark____GWs_Opt_2kx10x0-16 24232429 151.8 ns/op 13597.89 MB/s Benchmark____GWs_Opt_2kx10x0-16 23796714 142.8 ns/op 14450.97 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12554838 289.3 ns/op 14211.43 MB/s Benchmark____GWs_Opt_4kx10x0-16 11328696 398.9 ns/op 10308.29 MB/s Benchmark____GWs_Opt_4kx10x0-16 10030443 333.4 ns/op 12333.64 MB/s Benchmark____GWs_Opt_4kx10x0-16 11284447 296.6 ns/op 13862.90 MB/s Benchmark____GWs_Opt_4kx10x0-16 12594040 304.3 ns/op 13513.11 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6640917 551.7 ns/op 5664.57 MB/s Benchmark____GWs_Opt_1kx01x1-16 6457503 553.3 ns/op 5648.39 MB/s Benchmark____GWs_Opt_1kx01x1-16 6396267 545.7 ns/op 5726.16 MB/s Benchmark____GWs_Opt_1kx01x1-16 6745144 550.5 ns/op 5677.06 MB/s Benchmark____GWs_Opt_1kx01x1-16 6476090 552.8 ns/op 5653.14 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4777956 757.6 ns/op 8179.79 MB/s Benchmark____GWs_Opt_2kx01x1-16 4670396 758.4 ns/op 8171.30 MB/s Benchmark____GWs_Opt_2kx01x1-16 4616164 756.1 ns/op 8195.51 MB/s Benchmark____GWs_Opt_2kx01x1-16 4542025 769.7 ns/op 8051.35 MB/s Benchmark____GWs_Opt_2kx01x1-16 4675186 761.0 ns/op 8143.36 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2592679 1372 ns/op 8997.61 MB/s Benchmark____GWs_Opt_4kx01x1-16 2587873 3337 ns/op 3698.69 MB/s Benchmark____GWs_Opt_4kx01x1-16 2647528 1371 ns/op 8998.87 MB/s Benchmark____GWs_Opt_4kx01x1-16 2635212 1397 ns/op 8835.37 MB/s Benchmark____GWs_Opt_4kx01x1-16 2590332 1367 ns/op 9025.98 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6420853 547.7 ns/op 5706.15 MB/s Benchmark____GWs_Opt_1kx10x1-16 6431690 544.9 ns/op 5734.53 MB/s Benchmark____GWs_Opt_1kx10x1-16 5905587 544.7 ns/op 5736.87 MB/s Benchmark____GWs_Opt_1kx10x1-16 6568750 549.3 ns/op 5689.30 MB/s Benchmark____GWs_Opt_1kx10x1-16 6418377 545.8 ns/op 5725.39 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4217109 835.1 ns/op 7421.09 MB/s Benchmark____GWs_Opt_2kx10x1-16 4309486 849.2 ns/op 7297.49 MB/s Benchmark____GWs_Opt_2kx10x1-16 4290613 846.2 ns/op 7323.65 MB/s Benchmark____GWs_Opt_2kx10x1-16 4358328 821.9 ns/op 7539.77 MB/s Benchmark____GWs_Opt_2kx10x1-16 4301494 855.4 ns/op 7244.47 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2440387 1568 ns/op 7871.77 MB/s Benchmark____GWs_Opt_4kx10x1-16 2273890 1512 ns/op 8163.25 MB/s Benchmark____GWs_Opt_4kx10x1-16 2303740 1735 ns/op 7113.90 MB/s Benchmark____GWs_Opt_4kx10x1-16 2445548 1469 ns/op 8399.69 MB/s Benchmark____GWs_Opt_4kx10x1-16 2344854 1649 ns/op 7482.95 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12343166 300.0 ns/op 3466.67 MB/s Benchmark____GWs_Int_1kx01x0-16 12308473 295.0 ns/op 3525.23 MB/s Benchmark____GWs_Int_1kx01x0-16 12298710 291.6 ns/op 3566.32 MB/s Benchmark____GWs_Int_1kx01x0-16 12383731 288.0 ns/op 3611.71 MB/s Benchmark____GWs_Int_1kx01x0-16 11903727 290.3 ns/op 3582.83 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10711731 362.6 ns/op 5691.90 MB/s Benchmark____GWs_Int_2kx01x0-16 10098720 344.2 ns/op 5997.13 MB/s Benchmark____GWs_Int_2kx01x0-16 9402278 358.2 ns/op 5762.41 MB/s Benchmark____GWs_Int_2kx01x0-16 10393768 362.3 ns/op 5696.58 MB/s Benchmark____GWs_Int_2kx01x0-16 9804504 370.1 ns/op 5577.52 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5707022 652.7 ns/op 6300.03 MB/s Benchmark____GWs_Int_4kx01x0-16 5639101 640.8 ns/op 6416.88 MB/s Benchmark____GWs_Int_4kx01x0-16 5565867 651.2 ns/op 6314.33 MB/s Benchmark____GWs_Int_4kx01x0-16 5695489 652.7 ns/op 6300.35 MB/s Benchmark____GWs_Int_4kx01x0-16 5661465 649.4 ns/op 6331.57 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30689937 113.9 ns/op 9126.99 MB/s Benchmark____GWs_Int_1kx10x0-16 31652395 112.1 ns/op 9276.83 MB/s Benchmark____GWs_Int_1kx10x0-16 31514116 114.4 ns/op 9093.42 MB/s Benchmark____GWs_Int_1kx10x0-16 31486298 112.6 ns/op 9236.57 MB/s Benchmark____GWs_Int_1kx10x0-16 31569933 109.0 ns/op 9540.35 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24067526 137.9 ns/op 14969.54 MB/s Benchmark____GWs_Int_2kx10x0-16 25963938 152.4 ns/op 13545.85 MB/s Benchmark____GWs_Int_2kx10x0-16 25912776 142.7 ns/op 14460.17 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:55456->127.0.0.1:38895: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 24829921 136.5 ns/op 15116.27 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12581596 313.4 ns/op 13122.45 MB/s Benchmark____GWs_Int_4kx10x0-16 12822474 289.1 ns/op 14223.18 MB/s Benchmark____GWs_Int_4kx10x0-16 12162241 299.1 ns/op 13747.82 MB/s Benchmark____GWs_Int_4kx10x0-16 13272574 285.5 ns/op 14402.75 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:48260->127.0.0.1:42659: 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:38734->127.0.0.1:44213: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6530204 560.3 ns/op 5577.69 MB/s Benchmark____GWs_Int_1kx01x1-16 6543356 554.6 ns/op 5634.75 MB/s Benchmark____GWs_Int_1kx01x1-16 6670436 567.0 ns/op 5511.32 MB/s Benchmark____GWs_Int_1kx01x1-16 6364404 564.6 ns/op 5534.65 MB/s Benchmark____GWs_Int_1kx01x1-16 6444382 558.9 ns/op 5591.41 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4678197 913.5 ns/op 6783.78 MB/s Benchmark____GWs_Int_2kx01x1-16 4645856 765.8 ns/op 8092.62 MB/s Benchmark____GWs_Int_2kx01x1-16 4644765 768.5 ns/op 8063.86 MB/s Benchmark____GWs_Int_2kx01x1-16 4725470 768.1 ns/op 8068.40 MB/s Benchmark____GWs_Int_2kx01x1-16 4760072 770.0 ns/op 8048.31 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2617388 1431 ns/op 8624.58 MB/s Benchmark____GWs_Int_4kx01x1-16 2601085 1546 ns/op 7982.18 MB/s Benchmark____GWs_Int_4kx01x1-16 2672305 1373 ns/op 8987.28 MB/s Benchmark____GWs_Int_4kx01x1-16 2625880 1374 ns/op 8980.68 MB/s Benchmark____GWs_Int_4kx01x1-16 2316268 1406 ns/op 8780.40 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6610461 580.2 ns/op 5386.21 MB/s Benchmark____GWs_Int_1kx10x1-16 6554446 549.4 ns/op 5688.35 MB/s Benchmark____GWs_Int_1kx10x1-16 6092286 546.5 ns/op 5718.37 MB/s Benchmark____GWs_Int_1kx10x1-16 6413454 544.0 ns/op 5744.26 MB/s Benchmark____GWs_Int_1kx10x1-16 6716830 543.2 ns/op 5753.00 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4611297 837.1 ns/op 7402.75 MB/s Benchmark____GWs_Int_2kx10x1-16 3862779 838.3 ns/op 7392.55 MB/s Benchmark____GWs_Int_2kx10x1-16 4037960 848.2 ns/op 7306.26 MB/s Benchmark____GWs_Int_2kx10x1-16 4189615 843.1 ns/op 7350.48 MB/s Benchmark____GWs_Int_2kx10x1-16 4332934 827.5 ns/op 7489.06 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2399800 1520 ns/op 8119.66 MB/s Benchmark____GWs_Int_4kx10x1-16 2289037 1662 ns/op 7426.31 MB/s Benchmark____GWs_Int_4kx10x1-16 2469127 1480 ns/op 8338.09 MB/s Benchmark____GWs_Int_4kx10x1-16 2353819 1509 ns/op 8178.74 MB/s Benchmark____GWs_Int_4kx10x1-16 2547522 1498 ns/op 8237.47 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8387761 440.0 ns/op 231.82 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7793154 432.5 ns/op 235.85 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8359736 434.2 ns/op 234.93 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8051254 435.9 ns/op 233.99 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8598052 435.4 ns/op 234.27 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 718360 5104 ns/op 34.68 MB/s Benchmark__GWs_Reqs_1SubEach-16 729824 5279 ns/op 33.53 MB/s Benchmark__GWs_Reqs_1SubEach-16 696241 5264 ns/op 33.63 MB/s Benchmark__GWs_Reqs_1SubEach-16 749536 5308 ns/op 33.35 MB/s Benchmark__GWs_Reqs_1SubEach-16 797815 5348 ns/op 33.10 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2108.597s ❌ Non-zero exit code: 1