> ROOT_DIR=/tmp/go-bench-away-job-bfaa2aff-e8b0-4f1b-8c1e-a7045829088b-3890424601 > OUTPUT_FILE=/tmp/go-bench-away-job-bfaa2aff-e8b0-4f1b-8c1e-a7045829088b-3890424601/results.txt > SHA_FILE=/tmp/go-bench-away-job-bfaa2aff-e8b0-4f1b-8c1e-a7045829088b-3890424601/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-bfaa2aff-e8b0-4f1b-8c1e-a7045829088b-3890424601/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.25.4/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-bfaa2aff-e8b0-4f1b-8c1e-a7045829088b-3890424601/source.git SHA of main: 51fbade1ed5aa9cd026e6be57ad9b0c6272f6709 Go runtime: go version go1.26.0 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build1712745780=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-bfaa2aff-e8b0-4f1b-8c1e-a7045829088b-3890424601/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.25.4' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.25.4/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.0' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 53197503 67.25 ns/op 163.57 MB/s Benchmark______Pub0b_Payload-16 50239368 67.49 ns/op 162.98 MB/s Benchmark______Pub0b_Payload-16 50222875 68.10 ns/op 161.53 MB/s Benchmark______Pub0b_Payload-16 50129554 67.49 ns/op 162.98 MB/s Benchmark______Pub0b_Payload-16 50693181 67.27 ns/op 163.53 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 49564446 67.85 ns/op 280.04 MB/s Benchmark______Pub8b_Payload-16 49771988 67.67 ns/op 280.77 MB/s Benchmark______Pub8b_Payload-16 52987977 67.90 ns/op 279.81 MB/s Benchmark______Pub8b_Payload-16 49829907 68.04 ns/op 279.24 MB/s Benchmark______Pub8b_Payload-16 49489090 67.74 ns/op 280.47 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 46299290 72.55 ns/op 606.47 MB/s Benchmark_____Pub32b_Payload-16 46536742 72.15 ns/op 609.86 MB/s Benchmark_____Pub32b_Payload-16 46945776 72.28 ns/op 608.74 MB/s Benchmark_____Pub32b_Payload-16 49814846 72.36 ns/op 608.09 MB/s Benchmark_____Pub32b_Payload-16 47011974 72.39 ns/op 607.84 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 42903244 83.42 ns/op 1690.21 MB/s Benchmark____Pub128B_Payload-16 41748934 82.70 ns/op 1704.97 MB/s Benchmark____Pub128B_Payload-16 40081855 88.92 ns/op 1585.70 MB/s Benchmark____Pub128B_Payload-16 43179223 82.15 ns/op 1716.39 MB/s Benchmark____Pub128B_Payload-16 40862943 81.82 ns/op 1723.21 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 38188792 89.99 ns/op 2989.28 MB/s Benchmark____Pub256B_Payload-16 33526215 94.16 ns/op 2856.92 MB/s Benchmark____Pub256B_Payload-16 37416314 96.20 ns/op 2796.17 MB/s Benchmark____Pub256B_Payload-16 37665370 90.53 ns/op 2971.32 MB/s Benchmark____Pub256B_Payload-16 39667183 89.71 ns/op 2998.42 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24605551 135.3 ns/op 7673.54 MB/s Benchmark______Pub1K_Payload-16 23126982 134.2 ns/op 7733.01 MB/s Benchmark______Pub1K_Payload-16 24276685 131.3 ns/op 7907.43 MB/s Benchmark______Pub1K_Payload-16 24210684 142.7 ns/op 7272.70 MB/s Benchmark______Pub1K_Payload-16 23621941 141.6 ns/op 7330.75 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5634007 622.2 ns/op 6605.66 MB/s Benchmark______Pub4K_Payload-16 5489832 623.6 ns/op 6590.51 MB/s Benchmark______Pub4K_Payload-16 5497618 622.6 ns/op 6601.49 MB/s Benchmark______Pub4K_Payload-16 5375598 621.6 ns/op 6611.67 MB/s Benchmark______Pub4K_Payload-16 5749759 617.5 ns/op 6655.39 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2711492 1277 ns/op 6426.36 MB/s Benchmark______Pub8K_Payload-16 2757540 1280 ns/op 6408.77 MB/s Benchmark______Pub8K_Payload-16 2740735 1304 ns/op 6293.72 MB/s Benchmark______Pub8K_Payload-16 2701113 1278 ns/op 6421.76 MB/s Benchmark______Pub8K_Payload-16 2708510 1271 ns/op 6454.53 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 590200 5421 ns/op 6047.72 MB/s Benchmark_____Pub32K_Payload-16 660478 5428 ns/op 6039.41 MB/s Benchmark_____Pub32K_Payload-16 658849 5464 ns/op 6000.17 MB/s Benchmark_____Pub32K_Payload-16 555043 5414 ns/op 6055.41 MB/s Benchmark_____Pub32K_Payload-16 657156 5443 ns/op 6022.95 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 34572579 89.35 ns/op 123.10 MB/s Benchmark__AuthPub0b_Payload-16 38902948 87.63 ns/op 125.53 MB/s Benchmark__AuthPub0b_Payload-16 39012933 88.93 ns/op 123.69 MB/s Benchmark__AuthPub0b_Payload-16 38715415 87.44 ns/op 125.79 MB/s Benchmark__AuthPub0b_Payload-16 36954447 87.62 ns/op 125.54 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 16703048 210.5 ns/op Benchmark_____________PubSub-16 16891443 209.8 ns/op Benchmark_____________PubSub-16 16621128 211.3 ns/op Benchmark_____________PubSub-16 16962111 211.0 ns/op Benchmark_____________PubSub-16 16418060 211.2 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 16764390 209.1 ns/op Benchmark_____PubSubTwoConns-16 16904451 210.2 ns/op Benchmark_____PubSubTwoConns-16 16814758 210.2 ns/op Benchmark_____PubSubTwoConns-16 16758654 209.1 ns/op Benchmark_____PubSubTwoConns-16 16865041 210.0 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42878->127.0.0.1:35703: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33108->127.0.0.1:39597: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57804->127.0.0.1:34713: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46676->127.0.0.1:33857: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58552->127.0.0.1:42867: 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 15530451 225.9 ns/op Benchmark_____PubTwoQueueSub-16 15649460 227.8 ns/op Benchmark_____PubTwoQueueSub-16 15629116 228.0 ns/op Benchmark_____PubTwoQueueSub-16 15482757 227.8 ns/op Benchmark_____PubTwoQueueSub-16 15351325 228.0 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15455712 227.2 ns/op Benchmark____PubFourQueueSub-16 15450973 227.0 ns/op Benchmark____PubFourQueueSub-16 15476218 225.6 ns/op Benchmark____PubFourQueueSub-16 15465330 227.1 ns/op Benchmark____PubFourQueueSub-16 15676779 226.9 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15736695 227.9 ns/op Benchmark___PubEightQueueSub-16 15625342 227.2 ns/op Benchmark___PubEightQueueSub-16 15634699 225.7 ns/op Benchmark___PubEightQueueSub-16 15448862 226.9 ns/op Benchmark___PubEightQueueSub-16 15676819 227.1 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23532 153595 ns/op Benchmark_PubSub512kTwoConns-16 23384 155452 ns/op Benchmark_PubSub512kTwoConns-16 21846 154912 ns/op Benchmark_PubSub512kTwoConns-16 23811 155795 ns/op Benchmark_PubSub512kTwoConns-16 23110 155870 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16152130 212.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 16471681 213.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 16288184 213.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 16235246 213.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 16358010 213.0 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16227808 213.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 16392962 213.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 16100236 212.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 16419015 213.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 16437033 213.9 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 12172268 275.0 ns/op Benchmark____RoutedPubSub_0b-16 11976320 284.1 ns/op Benchmark____RoutedPubSub_0b-16 12028468 294.8 ns/op Benchmark____RoutedPubSub_0b-16 11892225 296.8 ns/op Benchmark____RoutedPubSub_0b-16 11873164 297.8 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6791185 472.1 ns/op Benchmark____RoutedPubSub_1K-16 6729313 605.7 ns/op Benchmark____RoutedPubSub_1K-16 6917434 513.4 ns/op Benchmark____RoutedPubSub_1K-16 6905688 498.9 ns/op Benchmark____RoutedPubSub_1K-16 6885950 517.3 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84102 42729 ns/op Benchmark__RoutedPubSub_100K-16 80092 44549 ns/op Benchmark__RoutedPubSub_100K-16 76802 47061 ns/op Benchmark__RoutedPubSub_100K-16 72234 51169 ns/op Benchmark__RoutedPubSub_100K-16 70252 50450 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9944362 305.9 ns/op Benchmark____Routed2QueueSub-16 10061154 306.6 ns/op Benchmark____Routed2QueueSub-16 9842438 308.5 ns/op Benchmark____Routed2QueueSub-16 9902070 313.9 ns/op Benchmark____Routed2QueueSub-16 9837324 307.7 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9724566 312.0 ns/op Benchmark____Routed4QueueSub-16 9893040 309.8 ns/op Benchmark____Routed4QueueSub-16 11830929 303.0 ns/op Benchmark____Routed4QueueSub-16 11595064 306.5 ns/op Benchmark____Routed4QueueSub-16 9722600 311.3 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 11248648 309.6 ns/op Benchmark____Routed8QueueSub-16 9605179 317.1 ns/op Benchmark____Routed8QueueSub-16 9698986 312.4 ns/op Benchmark____Routed8QueueSub-16 9474003 321.7 ns/op Benchmark____Routed8QueueSub-16 11314626 316.8 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8995800 346.2 ns/op Benchmark___Routed16QueueSub-16 9134612 337.7 ns/op Benchmark___Routed16QueueSub-16 9052184 341.0 ns/op Benchmark___Routed16QueueSub-16 8931261 340.2 ns/op Benchmark___Routed16QueueSub-16 9012834 346.0 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6777396 531.5 ns/op Benchmark____________RouteCompressOff-16 6608332 462.3 ns/op Benchmark____________RouteCompressOff-16 6746065 527.1 ns/op Benchmark____________RouteCompressOff-16 6504231 530.6 ns/op Benchmark____________RouteCompressOff-16 6607143 527.7 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6567596 489.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6664732 530.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6844053 531.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6704365 479.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6872197 473.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6742090 448.5 ns/op Benchmark_________RouteCompressS2Fast-16 6634622 530.9 ns/op Benchmark_________RouteCompressS2Fast-16 6819190 536.9 ns/op Benchmark_________RouteCompressS2Fast-16 6714060 528.6 ns/op Benchmark_________RouteCompressS2Fast-16 6714812 523.5 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6926725 528.2 ns/op Benchmark_______RouteCompressS2Better-16 6915132 522.2 ns/op Benchmark_______RouteCompressS2Better-16 6658932 470.0 ns/op Benchmark_______RouteCompressS2Better-16 8173251 525.9 ns/op Benchmark_______RouteCompressS2Better-16 6697635 523.4 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6746161 526.7 ns/op Benchmark_________RouteCompressS2Best-16 7068064 529.2 ns/op Benchmark_________RouteCompressS2Best-16 6626048 526.4 ns/op Benchmark_________RouteCompressS2Best-16 6757093 534.0 ns/op Benchmark_________RouteCompressS2Best-16 6774361 529.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5188462 681.2 ns/op 365.53 MB/s Benchmark______FanOut_8x1x10-16 5228875 681.4 ns/op 365.40 MB/s Benchmark______FanOut_8x1x10-16 5255988 689.0 ns/op 361.39 MB/s Benchmark______FanOut_8x1x10-16 5242528 682.8 ns/op 364.68 MB/s Benchmark______FanOut_8x1x10-16 5250912 689.1 ns/op 361.36 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 613905 5258 ns/op 441.01 MB/s Benchmark_____FanOut_8x1x100-16 605055 5325 ns/op 435.51 MB/s Benchmark_____FanOut_8x1x100-16 644088 5288 ns/op 438.56 MB/s Benchmark_____FanOut_8x1x100-16 640977 5356 ns/op 432.97 MB/s Benchmark_____FanOut_8x1x100-16 641689 5334 ns/op 434.78 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 52515 69355 ns/op 331.90 MB/s Benchmark____FanOut_8x10x100-16 52189 68780 ns/op 334.67 MB/s Benchmark____FanOut_8x10x100-16 51522 68402 ns/op 336.53 MB/s Benchmark____FanOut_8x10x100-16 52489 68120 ns/op 337.92 MB/s Benchmark____FanOut_8x10x100-16 52543 68049 ns/op 338.27 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6608 533667 ns/op 449.75 MB/s Benchmark___FanOut_8x10x1000-16 6717 540140 ns/op 444.36 MB/s Benchmark___FanOut_8x10x1000-16 6291 535212 ns/op 448.46 MB/s Benchmark___FanOut_8x10x1000-16 6794 536045 ns/op 447.76 MB/s Benchmark___FanOut_8x10x1000-16 6572 535798 ns/op 447.97 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5589 634404 ns/op 362.57 MB/s Benchmark___FanOut_8x100x100-16 5611 632820 ns/op 363.48 MB/s Benchmark___FanOut_8x100x100-16 5566 631758 ns/op 364.09 MB/s Benchmark___FanOut_8x100x100-16 5508 632202 ns/op 363.84 MB/s Benchmark___FanOut_8x100x100-16 5583 645524 ns/op 356.33 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 622 5442817 ns/op 440.95 MB/s Benchmark__FanOut_8x100x1000-16 663 5641222 ns/op 425.44 MB/s Benchmark__FanOut_8x100x1000-16 638 5548645 ns/op 432.54 MB/s Benchmark__FanOut_8x100x1000-16 624 5542953 ns/op 432.99 MB/s Benchmark__FanOut_8x100x1000-16 634 5586282 ns/op 429.63 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 609 5900508 ns/op 423.70 MB/s Benchmark__FanOut_8x10x10000-16 616 5863385 ns/op 426.38 MB/s Benchmark__FanOut_8x10x10000-16 604 5833709 ns/op 428.55 MB/s Benchmark__FanOut_8x10x10000-16 598 5943907 ns/op 420.60 MB/s Benchmark__FanOut_8x10x10000-16 613 5962752 ns/op 419.27 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1044 3416222 ns/op 336.63 MB/s Benchmark___FanOut_8x500x100-16 1026 3398014 ns/op 338.44 MB/s Benchmark___FanOut_8x500x100-16 1036 3406948 ns/op 337.55 MB/s Benchmark___FanOut_8x500x100-16 1044 3407549 ns/op 337.49 MB/s Benchmark___FanOut_8x500x100-16 1045 3400418 ns/op 338.20 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 386221 8864 ns/op 1651.67 MB/s Benchmark___FanOut_128x1x100-16 380092 8855 ns/op 1653.33 MB/s Benchmark___FanOut_128x1x100-16 391285 8849 ns/op 1654.58 MB/s Benchmark___FanOut_128x1x100-16 398067 8819 ns/op 1660.18 MB/s Benchmark___FanOut_128x1x100-16 391077 8862 ns/op 1652.09 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 34830 102873 ns/op 1410.88 MB/s Benchmark__FanOut_128x10x100-16 34887 102911 ns/op 1410.36 MB/s Benchmark__FanOut_128x10x100-16 34740 102848 ns/op 1411.22 MB/s Benchmark__FanOut_128x10x100-16 34675 103184 ns/op 1406.62 MB/s Benchmark__FanOut_128x10x100-16 34483 103161 ns/op 1406.94 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4196 795083 ns/op 1836.46 MB/s Benchmark_FanOut_128x10x1000-16 4641 803305 ns/op 1817.67 MB/s Benchmark_FanOut_128x10x1000-16 4411 796951 ns/op 1832.16 MB/s Benchmark_FanOut_128x10x1000-16 4516 782936 ns/op 1864.96 MB/s Benchmark_FanOut_128x10x1000-16 4371 787708 ns/op 1853.66 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3745 945698 ns/op 1533.41 MB/s Benchmark_FanOut_128x100x100-16 3811 940229 ns/op 1542.33 MB/s Benchmark_FanOut_128x100x100-16 3704 942481 ns/op 1538.64 MB/s Benchmark_FanOut_128x100x100-16 3801 947276 ns/op 1530.85 MB/s Benchmark_FanOut_128x100x100-16 3688 940197 ns/op 1542.38 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 411 8419001 ns/op 1734.19 MB/s BenchmarkFanOut_128x100x1000-16 423 8493007 ns/op 1719.08 MB/s BenchmarkFanOut_128x100x1000-16 417 8614041 ns/op 1694.92 MB/s BenchmarkFanOut_128x100x1000-16 423 8527009 ns/op 1712.22 MB/s BenchmarkFanOut_128x100x1000-16 412 8445130 ns/op 1728.82 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 406 8826912 ns/op 1665.38 MB/s BenchmarkFanOut_128x10x10000-16 402 8852174 ns/op 1660.62 MB/s BenchmarkFanOut_128x10x10000-16 409 8832818 ns/op 1664.26 MB/s BenchmarkFanOut_128x10x10000-16 408 8832328 ns/op 1664.36 MB/s BenchmarkFanOut_128x10x10000-16 405 8879414 ns/op 1655.53 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 717 4997545 ns/op 1450.74 MB/s BenchmarkFanOut__128x500x100-16 712 4989791 ns/op 1452.99 MB/s BenchmarkFanOut__128x500x100-16 721 5043108 ns/op 1437.63 MB/s BenchmarkFanOut__128x500x100-16 702 4976821 ns/op 1456.78 MB/s BenchmarkFanOut__128x500x100-16 702 5016163 ns/op 1445.36 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 2047 1785740 ns/op 2962.65 MB/s Benchmark_FanOut_512x100x100-16 1989 1780643 ns/op 2971.13 MB/s Benchmark_FanOut_512x100x100-16 1971 1777851 ns/op 2975.80 MB/s Benchmark_FanOut_512x100x100-16 2024 1791703 ns/op 2952.79 MB/s Benchmark_FanOut_512x100x100-16 1959 1763713 ns/op 2999.65 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 223 15973498 ns/op 3318.03 MB/s Benchmark__FanOut_512x100x1k-16 222 16196099 ns/op 3272.43 MB/s Benchmark__FanOut_512x100x1k-16 223 16058746 ns/op 3300.42 MB/s Benchmark__FanOut_512x100x1k-16 223 16175618 ns/op 3276.57 MB/s Benchmark__FanOut_512x100x1k-16 220 16127634 ns/op 3286.32 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3447 1084011 ns/op 9622.63 MB/s Benchmark____FanOut_1kx10x1k-16 3403 1109505 ns/op 9401.52 MB/s Benchmark____FanOut_1kx10x1k-16 3100 1092279 ns/op 9549.79 MB/s Benchmark____FanOut_1kx10x1k-16 2728 1101030 ns/op 9473.89 MB/s Benchmark____FanOut_1kx10x1k-16 3219 1110654 ns/op 9391.79 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2977 1177818 ns/op 8847.75 MB/s Benchmark__FanOut_1kx100x100-16 2967 1185628 ns/op 8789.47 MB/s Benchmark__FanOut_1kx100x100-16 2972 1190141 ns/op 8756.14 MB/s Benchmark__FanOut_1kx100x100-16 2936 1192374 ns/op 8739.74 MB/s Benchmark__FanOut_1kx100x100-16 2972 1187362 ns/op 8776.63 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 5040508 704.2 ns/op 353.61 MB/s Benchmark_____RFanOut_8x1x10-16 4881274 708.0 ns/op 351.72 MB/s Benchmark_____RFanOut_8x1x10-16 4980873 711.2 ns/op 350.09 MB/s Benchmark_____RFanOut_8x1x10-16 4965646 695.2 ns/op 358.19 MB/s Benchmark_____RFanOut_8x1x10-16 4776606 690.9 ns/op 360.41 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 618476 5328 ns/op 435.29 MB/s Benchmark____RFanOut_8x1x100-16 614251 5428 ns/op 427.20 MB/s Benchmark____RFanOut_8x1x100-16 606016 5253 ns/op 441.49 MB/s Benchmark____RFanOut_8x1x100-16 638480 5301 ns/op 437.45 MB/s Benchmark____RFanOut_8x1x100-16 599830 5323 ns/op 435.62 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 52656 67183 ns/op 342.63 MB/s Benchmark___RFanOut_8x10x100-16 52604 68179 ns/op 337.63 MB/s Benchmark___RFanOut_8x10x100-16 53014 67948 ns/op 338.78 MB/s Benchmark___RFanOut_8x10x100-16 53128 68748 ns/op 334.83 MB/s Benchmark___RFanOut_8x10x100-16 52644 68781 ns/op 334.67 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6453 538551 ns/op 445.68 MB/s Benchmark__RFanOut_8x10x1000-16 6724 534525 ns/op 449.03 MB/s Benchmark__RFanOut_8x10x1000-16 6812 544297 ns/op 440.97 MB/s Benchmark__RFanOut_8x10x1000-16 6579 536587 ns/op 447.31 MB/s Benchmark__RFanOut_8x10x1000-16 6676 542500 ns/op 442.43 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5563 634606 ns/op 362.46 MB/s Benchmark__RFanOut_8x100x100-16 5546 637603 ns/op 360.76 MB/s Benchmark__RFanOut_8x100x100-16 5575 637780 ns/op 360.66 MB/s Benchmark__RFanOut_8x100x100-16 5503 634400 ns/op 362.58 MB/s Benchmark__RFanOut_8x100x100-16 5475 642184 ns/op 358.18 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 651 5631724 ns/op 426.16 MB/s Benchmark_RFanOut_8x100x1000-16 630 5604622 ns/op 428.22 MB/s Benchmark_RFanOut_8x100x1000-16 613 5600254 ns/op 428.56 MB/s Benchmark_RFanOut_8x100x1000-16 612 5527956 ns/op 434.16 MB/s Benchmark_RFanOut_8x100x1000-16 630 5552120 ns/op 432.27 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 607 5891912 ns/op 424.31 MB/s Benchmark_RFanOut_8x10x10000-16 615 5866291 ns/op 426.17 MB/s Benchmark_RFanOut_8x10x10000-16 613 5909687 ns/op 423.04 MB/s Benchmark_RFanOut_8x10x10000-16 606 5883076 ns/op 424.95 MB/s Benchmark_RFanOut_8x10x10000-16 613 5808363 ns/op 430.42 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3127 1138309 ns/op 9163.63 MB/s Benchmark_RFanOut_1kx10x1000-16 3483 1108047 ns/op 9413.89 MB/s Benchmark_RFanOut_1kx10x1000-16 2932 1107508 ns/op 9418.47 MB/s Benchmark_RFanOut_1kx10x1000-16 3014 1120939 ns/op 9305.62 MB/s Benchmark_RFanOut_1kx10x1000-16 2982 1134225 ns/op 9196.62 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7202598 489.0 ns/op 4249.25 MB/s Benchmark_____FanIn_1kx100x1-16 7153352 486.2 ns/op 4273.89 MB/s Benchmark_____FanIn_1kx100x1-16 7156598 489.8 ns/op 4242.23 MB/s Benchmark_____FanIn_1kx100x1-16 7227297 491.2 ns/op 4230.29 MB/s Benchmark_____FanIn_1kx100x1-16 7216257 486.8 ns/op 4269.03 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2676496 1326 ns/op 6201.66 MB/s Benchmark_____FanIn_4kx100x1-16 2718740 1341 ns/op 6132.74 MB/s Benchmark_____FanIn_4kx100x1-16 2646222 1338 ns/op 6147.16 MB/s Benchmark_____FanIn_4kx100x1-16 2680228 1339 ns/op 6139.79 MB/s Benchmark_____FanIn_4kx100x1-16 2736088 1360 ns/op 6044.62 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1741375 2079 ns/op 7895.15 MB/s Benchmark_____FanIn_8kx100x1-16 1711916 2098 ns/op 7823.88 MB/s Benchmark_____FanIn_8kx100x1-16 1730150 2078 ns/op 7899.44 MB/s Benchmark_____FanIn_8kx100x1-16 1720615 2076 ns/op 7908.13 MB/s Benchmark_____FanIn_8kx100x1-16 1753777 2085 ns/op 7873.98 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 876747 4141 ns/op 7921.43 MB/s Benchmark____FanIn_16kx100x1-16 870536 4140 ns/op 7923.17 MB/s Benchmark____FanIn_16kx100x1-16 857548 4092 ns/op 8014.75 MB/s Benchmark____FanIn_16kx100x1-16 874830 4142 ns/op 7918.24 MB/s Benchmark____FanIn_16kx100x1-16 866656 4125 ns/op 7951.11 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 169480 20124 ns/op 6514.71 MB/s Benchmark____FanIn_64kx100x1-16 169722 19814 ns/op 6616.61 MB/s Benchmark____FanIn_64kx100x1-16 169160 19585 ns/op 6694.17 MB/s Benchmark____FanIn_64kx100x1-16 170860 20100 ns/op 6522.58 MB/s Benchmark____FanIn_64kx100x1-16 172782 19807 ns/op 6619.10 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 84290870 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53444->127.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:52864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:53262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53524->127.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:53340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52886->127.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: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:53020->127.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: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:53522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:53348->127.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:53546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53634->127.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:53026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53404->127.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:53478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53148->127.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:53618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:53194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52954->127.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:53500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53490->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: 362726030 vs 11719446000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55674->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56266->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56128->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56372->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:56166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55566->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55912->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: 148918240 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57614->127.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: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:57660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57992->127.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:57744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57956->127.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:58132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57732->127.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:57552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58076->127.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:58218->127.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: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: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:58210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57510->127.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:57390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57942->127.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: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: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:58112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57922->127.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:57864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57422->127.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:57774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57548->127.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: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:58020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57686->127.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:58184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57918->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: 107493800 vs 11929190000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60478->127.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:60614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60720->127.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:60008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60000->127.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: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:60346->127.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:60656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59998->127.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:60246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60482->127.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:60532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60102->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: 704608750 vs 1310900000 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:33852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33798->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33966->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:33930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33890->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5944152 594.4 ns/op 477.76 MB/s Benchmark___BumpPubCount_1x3-16 6028099 598.0 ns/op 474.89 MB/s Benchmark___BumpPubCount_1x3-16 5959375 596.1 ns/op 476.44 MB/s Benchmark___BumpPubCount_1x3-16 5956024 593.9 ns/op 478.21 MB/s Benchmark___BumpPubCount_1x3-16 6024403 595.6 ns/op 476.82 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5624706 632.5 ns/op 449.03 MB/s Benchmark___BumpPubCount_2x3-16 5617396 635.4 ns/op 446.95 MB/s Benchmark___BumpPubCount_2x3-16 5656353 633.0 ns/op 448.64 MB/s Benchmark___BumpPubCount_2x3-16 5631958 629.4 ns/op 451.19 MB/s Benchmark___BumpPubCount_2x3-16 5674128 632.7 ns/op 448.88 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5853032 613.6 ns/op 462.86 MB/s Benchmark___BumpPubCount_5x3-16 5665288 612.9 ns/op 463.36 MB/s Benchmark___BumpPubCount_5x3-16 5868766 612.8 ns/op 463.48 MB/s Benchmark___BumpPubCount_5x3-16 5256734 611.6 ns/op 464.38 MB/s Benchmark___BumpPubCount_5x3-16 5856219 613.3 ns/op 463.05 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5923506 606.5 ns/op 468.29 MB/s Benchmark__BumpPubCount_10x3-16 5929273 606.7 ns/op 468.12 MB/s Benchmark__BumpPubCount_10x3-16 5898264 607.4 ns/op 467.55 MB/s Benchmark__BumpPubCount_10x3-16 5889847 607.6 ns/op 467.43 MB/s Benchmark__BumpPubCount_10x3-16 5903911 605.8 ns/op 468.77 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11630618 273.0 ns/op 3808.93 MB/s Benchmark____GWs_Opt_1kx01x0-16 13061349 279.7 ns/op 3717.65 MB/s Benchmark____GWs_Opt_1kx01x0-16 12264602 276.8 ns/op 3757.18 MB/s Benchmark____GWs_Opt_1kx01x0-16 12337616 276.5 ns/op 3760.65 MB/s Benchmark____GWs_Opt_1kx01x0-16 12940119 279.7 ns/op 3717.95 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10384294 334.3 ns/op 6174.64 MB/s Benchmark____GWs_Opt_2kx01x0-16 9951428 356.6 ns/op 5788.31 MB/s Benchmark____GWs_Opt_2kx01x0-16 10363052 363.8 ns/op 5674.06 MB/s Benchmark____GWs_Opt_2kx01x0-16 10216322 351.6 ns/op 5870.41 MB/s Benchmark____GWs_Opt_2kx01x0-16 10389170 329.9 ns/op 6255.71 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5803531 621.7 ns/op 6614.40 MB/s Benchmark____GWs_Opt_4kx01x0-16 5945419 708.7 ns/op 5802.06 MB/s Benchmark____GWs_Opt_4kx01x0-16 5987970 602.2 ns/op 6828.70 MB/s Benchmark____GWs_Opt_4kx01x0-16 5703373 613.3 ns/op 6704.95 MB/s Benchmark____GWs_Opt_4kx01x0-16 5566854 628.2 ns/op 6546.05 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 31075892 111.0 ns/op 9365.94 MB/s Benchmark____GWs_Opt_1kx10x0-16 31628192 111.3 ns/op 9343.77 MB/s Benchmark____GWs_Opt_1kx10x0-16 28221427 112.3 ns/op 9261.99 MB/s Benchmark____GWs_Opt_1kx10x0-16 32103099 111.8 ns/op 9300.89 MB/s Benchmark____GWs_Opt_1kx10x0-16 30747466 112.1 ns/op 9275.76 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 22042300 148.3 ns/op 13919.97 MB/s Benchmark____GWs_Opt_2kx10x0-16 25249845 151.9 ns/op 13587.09 MB/s Benchmark____GWs_Opt_2kx10x0-16 25792292 150.3 ns/op 13734.34 MB/s Benchmark____GWs_Opt_2kx10x0-16 24957240 173.0 ns/op 11932.93 MB/s Benchmark____GWs_Opt_2kx10x0-16 24087638 139.8 ns/op 14760.35 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12687897 310.9 ns/op 13225.61 MB/s Benchmark____GWs_Opt_4kx10x0-16 12944584 287.4 ns/op 14307.36 MB/s Benchmark____GWs_Opt_4kx10x0-16 12884361 316.2 ns/op 13004.83 MB/s Benchmark____GWs_Opt_4kx10x0-16 12560564 290.2 ns/op 14168.75 MB/s Benchmark____GWs_Opt_4kx10x0-16 11214016 318.3 ns/op 12919.54 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 5895880 542.4 ns/op 5761.55 MB/s Benchmark____GWs_Opt_1kx01x1-16 6761829 537.8 ns/op 5811.19 MB/s Benchmark____GWs_Opt_1kx01x1-16 6821676 534.8 ns/op 5843.20 MB/s Benchmark____GWs_Opt_1kx01x1-16 6744670 545.6 ns/op 5727.62 MB/s Benchmark____GWs_Opt_1kx01x1-16 6652782 546.1 ns/op 5721.98 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4775016 748.8 ns/op 8276.03 MB/s Benchmark____GWs_Opt_2kx01x1-16 4887393 735.3 ns/op 8427.36 MB/s Benchmark____GWs_Opt_2kx01x1-16 4671092 791.9 ns/op 7825.88 MB/s Benchmark____GWs_Opt_2kx01x1-16 4696704 753.9 ns/op 8219.63 MB/s Benchmark____GWs_Opt_2kx01x1-16 4649736 751.5 ns/op 8245.95 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2654319 1356 ns/op 9100.93 MB/s Benchmark____GWs_Opt_4kx01x1-16 2667337 1371 ns/op 9002.21 MB/s Benchmark____GWs_Opt_4kx01x1-16 2322052 1359 ns/op 9081.95 MB/s Benchmark____GWs_Opt_4kx01x1-16 2674263 1348 ns/op 9158.33 MB/s Benchmark____GWs_Opt_4kx01x1-16 2708510 1355 ns/op 9110.79 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6837844 536.8 ns/op 5821.67 MB/s Benchmark____GWs_Opt_1kx10x1-16 6552234 542.0 ns/op 5765.79 MB/s Benchmark____GWs_Opt_1kx10x1-16 6553458 545.4 ns/op 5729.93 MB/s Benchmark____GWs_Opt_1kx10x1-16 6602450 545.8 ns/op 5725.85 MB/s Benchmark____GWs_Opt_1kx10x1-16 6648715 541.6 ns/op 5770.06 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4256946 821.0 ns/op 7548.06 MB/s Benchmark____GWs_Opt_2kx10x1-16 4309866 825.7 ns/op 7505.23 MB/s Benchmark____GWs_Opt_2kx10x1-16 4870545 829.2 ns/op 7473.43 MB/s Benchmark____GWs_Opt_2kx10x1-16 4512472 833.1 ns/op 7438.13 MB/s Benchmark____GWs_Opt_2kx10x1-16 3995890 842.7 ns/op 7353.60 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2322860 1523 ns/op 8101.14 MB/s Benchmark____GWs_Opt_4kx10x1-16 2335656 1501 ns/op 8223.24 MB/s Benchmark____GWs_Opt_4kx10x1-16 2236178 1412 ns/op 8738.23 MB/s Benchmark____GWs_Opt_4kx10x1-16 2448849 1502 ns/op 8214.57 MB/s Benchmark____GWs_Opt_4kx10x1-16 2469211 1411 ns/op 8746.83 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11917230 283.3 ns/op 3671.46 MB/s Benchmark____GWs_Int_1kx01x0-16 12033735 289.7 ns/op 3589.41 MB/s Benchmark____GWs_Int_1kx01x0-16 12454852 297.7 ns/op 3492.98 MB/s Benchmark____GWs_Int_1kx01x0-16 12545724 286.4 ns/op 3631.42 MB/s Benchmark____GWs_Int_1kx01x0-16 12475560 290.8 ns/op 3575.78 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9794610 362.9 ns/op 5687.71 MB/s Benchmark____GWs_Int_2kx01x0-16 10016763 353.2 ns/op 5844.15 MB/s Benchmark____GWs_Int_2kx01x0-16 10157109 372.5 ns/op 5541.01 MB/s Benchmark____GWs_Int_2kx01x0-16 10248223 331.1 ns/op 6234.06 MB/s Benchmark____GWs_Int_2kx01x0-16 9785672 359.7 ns/op 5737.79 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5723476 624.2 ns/op 6587.82 MB/s Benchmark____GWs_Int_4kx01x0-16 5671380 622.5 ns/op 6605.56 MB/s Benchmark____GWs_Int_4kx01x0-16 5757765 629.2 ns/op 6535.77 MB/s Benchmark____GWs_Int_4kx01x0-16 5795552 627.1 ns/op 6557.52 MB/s Benchmark____GWs_Int_4kx01x0-16 5885283 630.2 ns/op 6525.19 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31128198 109.4 ns/op 9505.37 MB/s Benchmark____GWs_Int_1kx10x0-16 28940383 121.9 ns/op 8528.92 MB/s Benchmark____GWs_Int_1kx10x0-16 31017668 111.0 ns/op 9368.02 MB/s Benchmark____GWs_Int_1kx10x0-16 28989562 106.2 ns/op 9796.26 MB/s Benchmark____GWs_Int_1kx10x0-16 27470002 110.3 ns/op 9430.12 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 26676032 140.2 ns/op 14721.15 MB/s Benchmark____GWs_Int_2kx10x0-16 25932054 144.7 ns/op 14268.48 MB/s Benchmark____GWs_Int_2kx10x0-16 25931914 139.2 ns/op 14830.65 MB/s Benchmark____GWs_Int_2kx10x0-16 25706301 139.3 ns/op 14815.09 MB/s Benchmark____GWs_Int_2kx10x0-16 24782850 137.5 ns/op 15011.49 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 1000000 15812 ns/op 260.05 MB/s Benchmark____GWs_Int_4kx10x0-16 11815136 339.8 ns/op 12101.29 MB/s Benchmark____GWs_Int_4kx10x0-16 13495479 287.5 ns/op 14304.15 MB/s Benchmark____GWs_Int_4kx10x0-16 12526854 316.2 ns/op 13003.20 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:41128->127.0.0.1:38689: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6578535 538.0 ns/op 5809.08 MB/s Benchmark____GWs_Int_1kx01x1-16 6603680 541.0 ns/op 5776.69 MB/s Benchmark____GWs_Int_1kx01x1-16 6075212 542.2 ns/op 5763.72 MB/s Benchmark____GWs_Int_1kx01x1-16 6830420 552.8 ns/op 5652.70 MB/s Benchmark____GWs_Int_1kx01x1-16 6747976 541.5 ns/op 5770.60 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4834498 749.7 ns/op 8265.90 MB/s Benchmark____GWs_Int_2kx01x1-16 4641658 755.2 ns/op 8206.31 MB/s Benchmark____GWs_Int_2kx01x1-16 4742059 744.1 ns/op 8328.09 MB/s Benchmark____GWs_Int_2kx01x1-16 4714662 751.2 ns/op 8248.93 MB/s Benchmark____GWs_Int_2kx01x1-16 4817268 840.2 ns/op 7375.28 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2399113 1374 ns/op 8978.75 MB/s Benchmark____GWs_Int_4kx01x1-16 2630721 1354 ns/op 9115.51 MB/s Benchmark____GWs_Int_4kx01x1-16 2658409 1364 ns/op 9046.59 MB/s Benchmark____GWs_Int_4kx01x1-16 2698191 1366 ns/op 9035.40 MB/s Benchmark____GWs_Int_4kx01x1-16 2660289 1352 ns/op 9130.90 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 5763188 533.6 ns/op 5856.69 MB/s Benchmark____GWs_Int_1kx10x1-16 6845482 530.4 ns/op 5891.86 MB/s Benchmark____GWs_Int_1kx10x1-16 6754580 539.0 ns/op 5798.17 MB/s Benchmark____GWs_Int_1kx10x1-16 1000000 3066 ns/op 1019.30 MB/s Benchmark____GWs_Int_1kx10x1-16 6251959 532.0 ns/op 5873.90 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4276938 809.7 ns/op 7653.03 MB/s Benchmark____GWs_Int_2kx10x1-16 3963850 796.1 ns/op 7784.16 MB/s Benchmark____GWs_Int_2kx10x1-16 4297894 825.2 ns/op 7509.63 MB/s Benchmark____GWs_Int_2kx10x1-16 4260430 838.5 ns/op 7390.38 MB/s Benchmark____GWs_Int_2kx10x1-16 4290591 827.8 ns/op 7485.89 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2275862 1470 ns/op 8397.11 MB/s Benchmark____GWs_Int_4kx10x1-16 2297209 1492 ns/op 8273.87 MB/s Benchmark____GWs_Int_4kx10x1-16 2279767 1480 ns/op 8340.03 MB/s Benchmark____GWs_Int_4kx10x1-16 2392106 1491 ns/op 8279.64 MB/s Benchmark____GWs_Int_4kx10x1-16 2430961 1531 ns/op 8058.45 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8313363 428.4 ns/op 238.11 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8057947 433.1 ns/op 235.52 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8647700 453.8 ns/op 224.76 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7528222 431.5 ns/op 236.38 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8067164 425.1 ns/op 239.95 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 687332 4728 ns/op 37.44 MB/s Benchmark__GWs_Reqs_1SubEach-16 835246 4914 ns/op 36.02 MB/s Benchmark__GWs_Reqs_1SubEach-16 805052 4931 ns/op 35.89 MB/s Benchmark__GWs_Reqs_1SubEach-16 811612 5072 ns/op 34.90 MB/s Benchmark__GWs_Reqs_1SubEach-16 796951 4858 ns/op 36.43 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2083.655s ❌ Non-zero exit code: 1