> ROOT_DIR=/tmp/go-bench-away-job-c39df69a-273e-484b-b216-68d2c91f6b96-1283071606 > OUTPUT_FILE=/tmp/go-bench-away-job-c39df69a-273e-484b-b216-68d2c91f6b96-1283071606/results.txt > SHA_FILE=/tmp/go-bench-away-job-c39df69a-273e-484b-b216-68d2c91f6b96-1283071606/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-c39df69a-273e-484b-b216-68d2c91f6b96-1283071606/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-c39df69a-273e-484b-b216-68d2c91f6b96-1283071606/source.git SHA of main: 6ba23e6b4d2be88954a9ea70f3ed3c07312b2501 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-build494057443=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-c39df69a-273e-484b-b216-68d2c91f6b96-1283071606/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 48891367 73.90 ns/op 148.84 MB/s Benchmark______Pub0b_Payload-16 46226703 73.59 ns/op 149.48 MB/s Benchmark______Pub0b_Payload-16 47676546 73.95 ns/op 148.74 MB/s Benchmark______Pub0b_Payload-16 48861147 73.53 ns/op 149.61 MB/s Benchmark______Pub0b_Payload-16 46510017 73.89 ns/op 148.87 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45674644 74.21 ns/op 256.04 MB/s Benchmark______Pub8b_Payload-16 45980734 75.30 ns/op 252.34 MB/s Benchmark______Pub8b_Payload-16 45854781 74.25 ns/op 255.91 MB/s Benchmark______Pub8b_Payload-16 45738429 74.06 ns/op 256.54 MB/s Benchmark______Pub8b_Payload-16 48567538 74.63 ns/op 254.60 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 42655836 78.29 ns/op 561.99 MB/s Benchmark_____Pub32b_Payload-16 43423264 78.30 ns/op 561.96 MB/s Benchmark_____Pub32b_Payload-16 43650378 78.23 ns/op 562.43 MB/s Benchmark_____Pub32b_Payload-16 43695802 78.31 ns/op 561.89 MB/s Benchmark_____Pub32b_Payload-16 43399420 78.49 ns/op 560.57 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38824824 88.75 ns/op 1588.66 MB/s Benchmark____Pub128B_Payload-16 38449332 88.75 ns/op 1588.73 MB/s Benchmark____Pub128B_Payload-16 38273090 90.23 ns/op 1562.75 MB/s Benchmark____Pub128B_Payload-16 38176377 92.18 ns/op 1529.56 MB/s Benchmark____Pub128B_Payload-16 38301393 88.47 ns/op 1593.73 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 31235029 98.16 ns/op 2740.48 MB/s Benchmark____Pub256B_Payload-16 37330665 97.00 ns/op 2773.05 MB/s Benchmark____Pub256B_Payload-16 31896315 97.19 ns/op 2767.92 MB/s Benchmark____Pub256B_Payload-16 31543496 99.32 ns/op 2708.35 MB/s Benchmark____Pub256B_Payload-16 32229406 97.34 ns/op 2763.42 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25710980 137.5 ns/op 7550.81 MB/s Benchmark______Pub1K_Payload-16 25358677 137.4 ns/op 7553.43 MB/s Benchmark______Pub1K_Payload-16 22236301 144.8 ns/op 7167.29 MB/s Benchmark______Pub1K_Payload-16 24571954 160.5 ns/op 6467.39 MB/s Benchmark______Pub1K_Payload-16 25310554 139.2 ns/op 7457.20 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5813971 629.1 ns/op 6532.91 MB/s Benchmark______Pub4K_Payload-16 5506086 615.8 ns/op 6674.60 MB/s Benchmark______Pub4K_Payload-16 5425602 619.6 ns/op 6633.62 MB/s Benchmark______Pub4K_Payload-16 5614042 623.8 ns/op 6588.37 MB/s Benchmark______Pub4K_Payload-16 5496981 612.7 ns/op 6707.75 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2718010 1274 ns/op 6440.48 MB/s Benchmark______Pub8K_Payload-16 2712846 1288 ns/op 6371.33 MB/s Benchmark______Pub8K_Payload-16 2807084 1273 ns/op 6447.03 MB/s Benchmark______Pub8K_Payload-16 2814436 1275 ns/op 6436.74 MB/s Benchmark______Pub8K_Payload-16 2750300 1291 ns/op 6358.67 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 649730 5442 ns/op 6024.02 MB/s Benchmark_____Pub32K_Payload-16 660194 5439 ns/op 6027.80 MB/s Benchmark_____Pub32K_Payload-16 592220 5539 ns/op 5919.01 MB/s Benchmark_____Pub32K_Payload-16 567138 5336 ns/op 6143.71 MB/s Benchmark_____Pub32K_Payload-16 582016 5276 ns/op 6213.75 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 37481924 99.11 ns/op 110.99 MB/s Benchmark__AuthPub0b_Payload-16 32795288 97.75 ns/op 112.54 MB/s Benchmark__AuthPub0b_Payload-16 31847214 95.63 ns/op 115.03 MB/s Benchmark__AuthPub0b_Payload-16 36007387 96.53 ns/op 113.95 MB/s Benchmark__AuthPub0b_Payload-16 35963640 95.60 ns/op 115.06 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15534018 228.0 ns/op Benchmark_____________PubSub-16 15589483 228.1 ns/op Benchmark_____________PubSub-16 15719419 226.7 ns/op Benchmark_____________PubSub-16 15478114 227.5 ns/op Benchmark_____________PubSub-16 15726465 227.9 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15582046 225.5 ns/op Benchmark_____PubSubTwoConns-16 15821390 226.4 ns/op Benchmark_____PubSubTwoConns-16 15732568 225.8 ns/op Benchmark_____PubSubTwoConns-16 15794208 226.2 ns/op Benchmark_____PubSubTwoConns-16 15559476 225.2 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58514->127.0.0.1:45085: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:52758->127.0.0.1:37963: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:54136->127.0.0.1:44203: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50390->127.0.0.1:33049: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33796->127.0.0.1:40099: 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 14447588 246.9 ns/op Benchmark_____PubTwoQueueSub-16 14381635 245.8 ns/op Benchmark_____PubTwoQueueSub-16 14191268 247.1 ns/op Benchmark_____PubTwoQueueSub-16 14494804 247.3 ns/op Benchmark_____PubTwoQueueSub-16 14343957 247.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14332716 246.8 ns/op Benchmark____PubFourQueueSub-16 14396682 247.4 ns/op Benchmark____PubFourQueueSub-16 14181640 247.2 ns/op Benchmark____PubFourQueueSub-16 14438924 246.1 ns/op Benchmark____PubFourQueueSub-16 14436414 246.3 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14351335 246.2 ns/op Benchmark___PubEightQueueSub-16 14344603 247.2 ns/op Benchmark___PubEightQueueSub-16 14276174 246.8 ns/op Benchmark___PubEightQueueSub-16 14246199 247.0 ns/op Benchmark___PubEightQueueSub-16 14181292 247.6 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23128 157510 ns/op Benchmark_PubSub512kTwoConns-16 23233 155528 ns/op Benchmark_PubSub512kTwoConns-16 23181 155002 ns/op Benchmark_PubSub512kTwoConns-16 22995 155306 ns/op Benchmark_PubSub512kTwoConns-16 23221 155234 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15141702 229.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15181969 229.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15400804 229.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15222444 229.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15264045 229.0 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15246992 230.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 14723506 228.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15105010 230.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15189188 229.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15280174 229.1 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11355937 311.1 ns/op Benchmark____RoutedPubSub_0b-16 10983181 311.9 ns/op Benchmark____RoutedPubSub_0b-16 11217698 313.3 ns/op Benchmark____RoutedPubSub_0b-16 11569704 312.5 ns/op Benchmark____RoutedPubSub_0b-16 10953073 307.2 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6672102 528.5 ns/op Benchmark____RoutedPubSub_1K-16 6559580 541.1 ns/op Benchmark____RoutedPubSub_1K-16 6631312 535.9 ns/op Benchmark____RoutedPubSub_1K-16 6652400 531.9 ns/op Benchmark____RoutedPubSub_1K-16 6772106 541.5 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84336 42161 ns/op Benchmark__RoutedPubSub_100K-16 83710 43398 ns/op Benchmark__RoutedPubSub_100K-16 83781 42405 ns/op Benchmark__RoutedPubSub_100K-16 82057 44296 ns/op Benchmark__RoutedPubSub_100K-16 80120 44740 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9683066 313.6 ns/op Benchmark____Routed2QueueSub-16 9724986 318.8 ns/op Benchmark____Routed2QueueSub-16 10088172 311.9 ns/op Benchmark____Routed2QueueSub-16 10009299 310.1 ns/op Benchmark____Routed2QueueSub-16 9834009 312.5 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 11445408 319.5 ns/op Benchmark____Routed4QueueSub-16 9800944 321.6 ns/op Benchmark____Routed4QueueSub-16 9541396 320.2 ns/op Benchmark____Routed4QueueSub-16 9581118 318.3 ns/op Benchmark____Routed4QueueSub-16 9889587 315.1 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9268128 329.2 ns/op Benchmark____Routed8QueueSub-16 9448702 324.8 ns/op Benchmark____Routed8QueueSub-16 9568480 332.8 ns/op Benchmark____Routed8QueueSub-16 11006228 331.2 ns/op Benchmark____Routed8QueueSub-16 9255943 327.3 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8932750 344.1 ns/op Benchmark___Routed16QueueSub-16 8819138 345.1 ns/op Benchmark___Routed16QueueSub-16 8709818 349.1 ns/op Benchmark___Routed16QueueSub-16 8804052 342.5 ns/op Benchmark___Routed16QueueSub-16 8914716 344.3 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6275326 548.0 ns/op Benchmark____________RouteCompressOff-16 6305288 552.9 ns/op Benchmark____________RouteCompressOff-16 6461427 551.6 ns/op Benchmark____________RouteCompressOff-16 6459716 548.2 ns/op Benchmark____________RouteCompressOff-16 6413100 552.4 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6355317 548.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6475282 554.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6551866 544.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6488494 547.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6458829 548.6 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6378828 547.3 ns/op Benchmark_________RouteCompressS2Fast-16 6375328 554.6 ns/op Benchmark_________RouteCompressS2Fast-16 6409162 551.0 ns/op Benchmark_________RouteCompressS2Fast-16 6483730 550.9 ns/op Benchmark_________RouteCompressS2Fast-16 6576698 538.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6581589 551.2 ns/op Benchmark_______RouteCompressS2Better-16 6319621 541.8 ns/op Benchmark_______RouteCompressS2Better-16 6450734 548.3 ns/op Benchmark_______RouteCompressS2Better-16 6595478 545.9 ns/op Benchmark_______RouteCompressS2Better-16 6542700 550.6 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6494440 548.3 ns/op Benchmark_________RouteCompressS2Best-16 6264642 543.4 ns/op Benchmark_________RouteCompressS2Best-16 6518487 544.0 ns/op Benchmark_________RouteCompressS2Best-16 6508334 546.6 ns/op Benchmark_________RouteCompressS2Best-16 6483174 546.1 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4718757 765.6 ns/op 325.24 MB/s Benchmark______FanOut_8x1x10-16 4667893 763.0 ns/op 326.34 MB/s Benchmark______FanOut_8x1x10-16 4669860 761.2 ns/op 327.10 MB/s Benchmark______FanOut_8x1x10-16 4698895 762.4 ns/op 326.62 MB/s Benchmark______FanOut_8x1x10-16 4716518 772.2 ns/op 322.47 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 552729 6169 ns/op 375.90 MB/s Benchmark_____FanOut_8x1x100-16 555691 6120 ns/op 378.90 MB/s Benchmark_____FanOut_8x1x100-16 556076 5986 ns/op 387.39 MB/s Benchmark_____FanOut_8x1x100-16 570765 6038 ns/op 384.04 MB/s Benchmark_____FanOut_8x1x100-16 552024 6060 ns/op 382.70 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48496 74554 ns/op 308.75 MB/s Benchmark____FanOut_8x10x100-16 48492 73798 ns/op 311.92 MB/s Benchmark____FanOut_8x10x100-16 48535 74018 ns/op 310.99 MB/s Benchmark____FanOut_8x10x100-16 48409 74392 ns/op 309.43 MB/s Benchmark____FanOut_8x10x100-16 47932 74348 ns/op 309.61 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6052 593178 ns/op 404.63 MB/s Benchmark___FanOut_8x10x1000-16 5874 592717 ns/op 404.95 MB/s Benchmark___FanOut_8x10x1000-16 6133 594639 ns/op 403.64 MB/s Benchmark___FanOut_8x10x1000-16 5742 593695 ns/op 404.28 MB/s Benchmark___FanOut_8x10x1000-16 5788 593919 ns/op 404.13 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5016 706449 ns/op 325.60 MB/s Benchmark___FanOut_8x100x100-16 5068 700079 ns/op 328.56 MB/s Benchmark___FanOut_8x100x100-16 5035 702608 ns/op 327.38 MB/s Benchmark___FanOut_8x100x100-16 4951 700670 ns/op 328.28 MB/s Benchmark___FanOut_8x100x100-16 5019 710102 ns/op 323.92 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 543 6220377 ns/op 385.83 MB/s Benchmark__FanOut_8x100x1000-16 590 6191188 ns/op 387.65 MB/s Benchmark__FanOut_8x100x1000-16 589 6219055 ns/op 385.91 MB/s Benchmark__FanOut_8x100x1000-16 576 6065633 ns/op 395.67 MB/s Benchmark__FanOut_8x100x1000-16 578 6109757 ns/op 392.82 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 534 6654585 ns/op 375.68 MB/s Benchmark__FanOut_8x10x10000-16 520 6698894 ns/op 373.20 MB/s Benchmark__FanOut_8x10x10000-16 512 6665192 ns/op 375.09 MB/s Benchmark__FanOut_8x10x10000-16 549 6861990 ns/op 364.33 MB/s Benchmark__FanOut_8x10x10000-16 523 6903604 ns/op 362.13 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 943 3747684 ns/op 306.86 MB/s Benchmark___FanOut_8x500x100-16 950 3716746 ns/op 309.42 MB/s Benchmark___FanOut_8x500x100-16 956 3727576 ns/op 308.52 MB/s Benchmark___FanOut_8x500x100-16 957 3770543 ns/op 305.00 MB/s Benchmark___FanOut_8x500x100-16 951 3721193 ns/op 309.05 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 358688 9450 ns/op 1549.24 MB/s Benchmark___FanOut_128x1x100-16 368124 9516 ns/op 1538.53 MB/s Benchmark___FanOut_128x1x100-16 358816 9515 ns/op 1538.67 MB/s Benchmark___FanOut_128x1x100-16 353024 9481 ns/op 1544.25 MB/s Benchmark___FanOut_128x1x100-16 367886 9397 ns/op 1558.02 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32817 109218 ns/op 1328.91 MB/s Benchmark__FanOut_128x10x100-16 32756 109633 ns/op 1323.88 MB/s Benchmark__FanOut_128x10x100-16 33024 109390 ns/op 1326.82 MB/s Benchmark__FanOut_128x10x100-16 33038 110078 ns/op 1318.53 MB/s Benchmark__FanOut_128x10x100-16 32722 109366 ns/op 1327.11 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4106 869595 ns/op 1679.11 MB/s Benchmark_FanOut_128x10x1000-16 4024 858375 ns/op 1701.05 MB/s Benchmark_FanOut_128x10x1000-16 4170 858999 ns/op 1699.82 MB/s Benchmark_FanOut_128x10x1000-16 4135 859110 ns/op 1699.60 MB/s Benchmark_FanOut_128x10x1000-16 4200 858321 ns/op 1701.16 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3607 999092 ns/op 1451.46 MB/s Benchmark_FanOut_128x100x100-16 3516 1004445 ns/op 1443.72 MB/s Benchmark_FanOut_128x100x100-16 3538 1001103 ns/op 1448.54 MB/s Benchmark_FanOut_128x100x100-16 3500 1002663 ns/op 1446.29 MB/s Benchmark_FanOut_128x100x100-16 3618 1062483 ns/op 1364.86 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 394 9269670 ns/op 1575.04 MB/s BenchmarkFanOut_128x100x1000-16 388 9205359 ns/op 1586.05 MB/s BenchmarkFanOut_128x100x1000-16 388 9072883 ns/op 1609.21 MB/s BenchmarkFanOut_128x100x1000-16 388 9164133 ns/op 1593.18 MB/s BenchmarkFanOut_128x100x1000-16 386 9217414 ns/op 1583.97 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 379 9488571 ns/op 1549.25 MB/s BenchmarkFanOut_128x10x10000-16 374 9756657 ns/op 1506.68 MB/s BenchmarkFanOut_128x10x10000-16 373 9573755 ns/op 1535.46 MB/s BenchmarkFanOut_128x10x10000-16 376 9571829 ns/op 1535.77 MB/s BenchmarkFanOut_128x10x10000-16 376 9590604 ns/op 1532.76 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 675 5219443 ns/op 1389.06 MB/s BenchmarkFanOut__128x500x100-16 690 5240688 ns/op 1383.43 MB/s BenchmarkFanOut__128x500x100-16 675 5261035 ns/op 1378.08 MB/s BenchmarkFanOut__128x500x100-16 681 5199669 ns/op 1394.35 MB/s BenchmarkFanOut__128x500x100-16 682 5226855 ns/op 1387.09 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1923 1845908 ns/op 2866.08 MB/s Benchmark_FanOut_512x100x100-16 1908 1820085 ns/op 2906.75 MB/s Benchmark_FanOut_512x100x100-16 1962 1844482 ns/op 2868.30 MB/s Benchmark_FanOut_512x100x100-16 1910 1823420 ns/op 2901.43 MB/s Benchmark_FanOut_512x100x100-16 1965 1831025 ns/op 2889.38 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 217 16432029 ns/op 3225.44 MB/s Benchmark__FanOut_512x100x1k-16 217 16641480 ns/op 3184.84 MB/s Benchmark__FanOut_512x100x1k-16 213 16379668 ns/op 3235.75 MB/s Benchmark__FanOut_512x100x1k-16 216 16670590 ns/op 3179.28 MB/s Benchmark__FanOut_512x100x1k-16 216 16585778 ns/op 3195.54 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2977 1151981 ns/op 9054.87 MB/s Benchmark____FanOut_1kx10x1k-16 2923 1146228 ns/op 9100.32 MB/s Benchmark____FanOut_1kx10x1k-16 3243 1140648 ns/op 9144.84 MB/s Benchmark____FanOut_1kx10x1k-16 3303 1158534 ns/op 9003.65 MB/s Benchmark____FanOut_1kx10x1k-16 3001 1147729 ns/op 9088.42 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2785 1247657 ns/op 8352.48 MB/s Benchmark__FanOut_1kx100x100-16 2816 1250545 ns/op 8333.20 MB/s Benchmark__FanOut_1kx100x100-16 2781 1250405 ns/op 8334.13 MB/s Benchmark__FanOut_1kx100x100-16 2772 1241104 ns/op 8396.59 MB/s Benchmark__FanOut_1kx100x100-16 2864 1245728 ns/op 8365.42 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4418960 786.3 ns/op 316.68 MB/s Benchmark_____RFanOut_8x1x10-16 4594123 792.9 ns/op 314.04 MB/s Benchmark_____RFanOut_8x1x10-16 4472506 787.4 ns/op 316.23 MB/s Benchmark_____RFanOut_8x1x10-16 4521171 787.5 ns/op 316.19 MB/s Benchmark_____RFanOut_8x1x10-16 4469870 786.3 ns/op 316.66 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 536001 6377 ns/op 363.65 MB/s Benchmark____RFanOut_8x1x100-16 515059 6299 ns/op 368.18 MB/s Benchmark____RFanOut_8x1x100-16 546255 6315 ns/op 367.23 MB/s Benchmark____RFanOut_8x1x100-16 501357 6423 ns/op 361.05 MB/s Benchmark____RFanOut_8x1x100-16 517530 6317 ns/op 367.11 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48466 74890 ns/op 307.37 MB/s Benchmark___RFanOut_8x10x100-16 48250 74103 ns/op 310.64 MB/s Benchmark___RFanOut_8x10x100-16 48408 74124 ns/op 310.55 MB/s Benchmark___RFanOut_8x10x100-16 48505 73933 ns/op 311.35 MB/s Benchmark___RFanOut_8x10x100-16 48136 74099 ns/op 310.65 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5718 594387 ns/op 403.81 MB/s Benchmark__RFanOut_8x10x1000-16 5954 595748 ns/op 402.89 MB/s Benchmark__RFanOut_8x10x1000-16 5833 593730 ns/op 404.26 MB/s Benchmark__RFanOut_8x10x1000-16 6064 591136 ns/op 406.03 MB/s Benchmark__RFanOut_8x10x1000-16 5794 593450 ns/op 404.45 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5038 704674 ns/op 326.42 MB/s Benchmark__RFanOut_8x100x100-16 5005 702241 ns/op 327.55 MB/s Benchmark__RFanOut_8x100x100-16 5030 702013 ns/op 327.66 MB/s Benchmark__RFanOut_8x100x100-16 4993 699612 ns/op 328.78 MB/s Benchmark__RFanOut_8x100x100-16 4894 701367 ns/op 327.96 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 579 6088045 ns/op 394.22 MB/s Benchmark_RFanOut_8x100x1000-16 584 6112379 ns/op 392.65 MB/s Benchmark_RFanOut_8x100x1000-16 585 6184711 ns/op 388.06 MB/s Benchmark_RFanOut_8x100x1000-16 578 6066132 ns/op 395.64 MB/s Benchmark_RFanOut_8x100x1000-16 568 6109809 ns/op 392.81 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 523 6590747 ns/op 379.32 MB/s Benchmark_RFanOut_8x10x10000-16 532 6690664 ns/op 373.66 MB/s Benchmark_RFanOut_8x10x10000-16 525 6638178 ns/op 376.61 MB/s Benchmark_RFanOut_8x10x10000-16 547 6824661 ns/op 366.32 MB/s Benchmark_RFanOut_8x10x10000-16 541 6715443 ns/op 372.28 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2695 1156521 ns/op 9019.32 MB/s Benchmark_RFanOut_1kx10x1000-16 3022 1140879 ns/op 9142.99 MB/s Benchmark_RFanOut_1kx10x1000-16 3169 1146773 ns/op 9095.99 MB/s Benchmark_RFanOut_1kx10x1000-16 2715 1141937 ns/op 9134.51 MB/s Benchmark_RFanOut_1kx10x1000-16 2919 1139103 ns/op 9157.24 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7016595 506.3 ns/op 4103.93 MB/s Benchmark_____FanIn_1kx100x1-16 6333775 501.3 ns/op 4145.08 MB/s Benchmark_____FanIn_1kx100x1-16 6991287 505.0 ns/op 4115.10 MB/s Benchmark_____FanIn_1kx100x1-16 6920030 504.6 ns/op 4117.96 MB/s Benchmark_____FanIn_1kx100x1-16 6893547 505.5 ns/op 4110.51 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2541888 1353 ns/op 6075.91 MB/s Benchmark_____FanIn_4kx100x1-16 2632894 1337 ns/op 6149.34 MB/s Benchmark_____FanIn_4kx100x1-16 2589345 1367 ns/op 6014.96 MB/s Benchmark_____FanIn_4kx100x1-16 2584165 1342 ns/op 6128.40 MB/s Benchmark_____FanIn_4kx100x1-16 2611189 1362 ns/op 6037.50 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1713234 2100 ns/op 7814.79 MB/s Benchmark_____FanIn_8kx100x1-16 1715324 2073 ns/op 7916.13 MB/s Benchmark_____FanIn_8kx100x1-16 1722598 2135 ns/op 7686.28 MB/s Benchmark_____FanIn_8kx100x1-16 1705866 2101 ns/op 7810.83 MB/s Benchmark_____FanIn_8kx100x1-16 1705116 2095 ns/op 7835.20 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 875989 4118 ns/op 7965.83 MB/s Benchmark____FanIn_16kx100x1-16 869142 4134 ns/op 7934.24 MB/s Benchmark____FanIn_16kx100x1-16 859387 4148 ns/op 7906.84 MB/s Benchmark____FanIn_16kx100x1-16 870037 4131 ns/op 7939.82 MB/s Benchmark____FanIn_16kx100x1-16 875995 4153 ns/op 7898.27 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 168888 19716 ns/op 6649.62 MB/s Benchmark____FanIn_64kx100x1-16 172809 19853 ns/op 6603.89 MB/s Benchmark____FanIn_64kx100x1-16 167997 19989 ns/op 6558.74 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 5978564706 vs 11189897100 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60996->127.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:60480->127.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:60272->127.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:60512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60726->127.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:32846->127.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: 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:32820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60852->127.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: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: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: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:60438->127.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:60888->127.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: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:60648->127.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: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: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:60382->127.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:60454->127.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:60546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32842->127.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:60822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60528->127.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:60568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60182->127.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: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:60410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60384->127.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: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:60674->127.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:60288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60498->127.0.0.1:5222: write: connection reset by peer 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:60876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60850->127.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:60176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60952->127.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:60238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60188->127.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:60318->127.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: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:60470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60262->127.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: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:60782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32804->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 169848 19860 ns/op 6601.26 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1615684250 vs 11509702000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51742->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: 257591850 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53552->127.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:53572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:53076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53010->127.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:53136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53180->127.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:53428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53584->127.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:52894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:53156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:53260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53036->127.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:53516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53232->127.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:53342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53466->127.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: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: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:53072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52740->127.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:52824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53290->127.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: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:53048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53390->127.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:52862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52738->127.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:53536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52924->127.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:53454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53074->127.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:53418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52898->127.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:52752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52804->127.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:52838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53376->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: 451342870 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55010->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:54574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54536->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: 505089770 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56848->127.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:56580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56822->127.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:57052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56406->127.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:56228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56576->127.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:56332->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57032->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:56918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56232->127.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:56824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57058->127.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:56434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56284->127.0.0.1:5222: write: connection reset by peer 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:56612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56994->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: 1098534200 vs 11601465000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59280->127.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:59554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59484->127.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: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59966->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59138->127.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:59376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59112->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59204->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59134->127.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:59788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59508->127.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: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:59076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59536->127.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:59708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59676->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5590368 641.1 ns/op 442.98 MB/s Benchmark___BumpPubCount_1x3-16 5610991 635.8 ns/op 446.67 MB/s Benchmark___BumpPubCount_1x3-16 5629568 636.0 ns/op 446.52 MB/s Benchmark___BumpPubCount_1x3-16 5572323 645.0 ns/op 440.29 MB/s Benchmark___BumpPubCount_1x3-16 5590573 642.4 ns/op 442.07 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5320881 668.4 ns/op 424.91 MB/s Benchmark___BumpPubCount_2x3-16 5373016 672.0 ns/op 422.63 MB/s Benchmark___BumpPubCount_2x3-16 5306742 669.9 ns/op 423.93 MB/s Benchmark___BumpPubCount_2x3-16 5373069 670.3 ns/op 423.71 MB/s Benchmark___BumpPubCount_2x3-16 5317189 671.3 ns/op 423.04 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5449120 643.9 ns/op 441.04 MB/s Benchmark___BumpPubCount_5x3-16 5387724 637.7 ns/op 445.32 MB/s Benchmark___BumpPubCount_5x3-16 5627780 640.3 ns/op 443.51 MB/s Benchmark___BumpPubCount_5x3-16 5603215 637.8 ns/op 445.25 MB/s Benchmark___BumpPubCount_5x3-16 5166436 639.2 ns/op 444.31 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5618602 639.6 ns/op 444.06 MB/s Benchmark__BumpPubCount_10x3-16 5611129 640.2 ns/op 443.63 MB/s Benchmark__BumpPubCount_10x3-16 5591172 641.7 ns/op 442.60 MB/s Benchmark__BumpPubCount_10x3-16 5583475 638.7 ns/op 444.66 MB/s Benchmark__BumpPubCount_10x3-16 5595746 637.6 ns/op 445.44 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12962846 271.8 ns/op 3825.71 MB/s Benchmark____GWs_Opt_1kx01x0-16 12048789 274.1 ns/op 3793.89 MB/s Benchmark____GWs_Opt_1kx01x0-16 12138028 269.9 ns/op 3852.99 MB/s Benchmark____GWs_Opt_1kx01x0-16 12428899 277.1 ns/op 3752.61 MB/s Benchmark____GWs_Opt_1kx01x0-16 12743691 275.2 ns/op 3778.70 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10195837 348.9 ns/op 5916.26 MB/s Benchmark____GWs_Opt_2kx01x0-16 10631556 327.4 ns/op 6304.18 MB/s Benchmark____GWs_Opt_2kx01x0-16 9862068 315.8 ns/op 6534.82 MB/s Benchmark____GWs_Opt_2kx01x0-16 10949782 362.7 ns/op 5690.25 MB/s Benchmark____GWs_Opt_2kx01x0-16 10309208 324.6 ns/op 6359.06 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5821075 633.2 ns/op 6493.65 MB/s Benchmark____GWs_Opt_4kx01x0-16 5788324 604.5 ns/op 6802.63 MB/s Benchmark____GWs_Opt_4kx01x0-16 5995599 617.9 ns/op 6655.07 MB/s Benchmark____GWs_Opt_4kx01x0-16 5351659 634.7 ns/op 6478.45 MB/s Benchmark____GWs_Opt_4kx01x0-16 5569353 616.8 ns/op 6666.56 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28437052 114.4 ns/op 9089.55 MB/s Benchmark____GWs_Opt_1kx10x0-16 31585705 120.8 ns/op 8610.18 MB/s Benchmark____GWs_Opt_1kx10x0-16 31129621 112.0 ns/op 9288.64 MB/s Benchmark____GWs_Opt_1kx10x0-16 27173949 112.8 ns/op 9217.68 MB/s Benchmark____GWs_Opt_1kx10x0-16 32870570 115.0 ns/op 9041.01 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25116808 151.2 ns/op 13651.95 MB/s Benchmark____GWs_Opt_2kx10x0-16 25132245 145.1 ns/op 14226.01 MB/s Benchmark____GWs_Opt_2kx10x0-16 25224638 145.9 ns/op 14150.18 MB/s Benchmark____GWs_Opt_2kx10x0-16 22885119 143.6 ns/op 14372.81 MB/s Benchmark____GWs_Opt_2kx10x0-16 24501472 146.1 ns/op 14129.40 MB/s Benchmark____GWs_Opt_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:56234->127.0.0.1:35109: 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:38646->127.0.0.1:43409: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 12803929 295.5 ns/op 13914.31 MB/s Benchmark____GWs_Opt_4kx10x0-16 13158760 320.1 ns/op 12845.08 MB/s Benchmark____GWs_Opt_4kx10x0-16 12918243 285.5 ns/op 14402.58 MB/s Benchmark____GWs_Opt_4kx10x0-16 12777559 294.6 ns/op 13959.77 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6550678 544.5 ns/op 5739.33 MB/s Benchmark____GWs_Opt_1kx01x1-16 6511248 550.0 ns/op 5682.01 MB/s Benchmark____GWs_Opt_1kx01x1-16 6568822 545.1 ns/op 5732.93 MB/s Benchmark____GWs_Opt_1kx01x1-16 6568471 546.7 ns/op 5716.51 MB/s Benchmark____GWs_Opt_1kx01x1-16 6691568 541.2 ns/op 5774.56 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4795377 759.0 ns/op 8165.00 MB/s Benchmark____GWs_Opt_2kx01x1-16 4596486 746.5 ns/op 8301.11 MB/s Benchmark____GWs_Opt_2kx01x1-16 4687047 757.9 ns/op 8176.14 MB/s Benchmark____GWs_Opt_2kx01x1-16 4769140 752.0 ns/op 8240.89 MB/s Benchmark____GWs_Opt_2kx01x1-16 4756356 737.9 ns/op 8398.28 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2622382 1358 ns/op 9089.62 MB/s Benchmark____GWs_Opt_4kx01x1-16 2662497 1360 ns/op 9076.67 MB/s Benchmark____GWs_Opt_4kx01x1-16 2654644 1355 ns/op 9106.05 MB/s Benchmark____GWs_Opt_4kx01x1-16 2668166 1356 ns/op 9101.06 MB/s Benchmark____GWs_Opt_4kx01x1-16 2684661 1362 ns/op 9059.72 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6524966 541.3 ns/op 5773.33 MB/s Benchmark____GWs_Opt_1kx10x1-16 6625138 559.9 ns/op 5581.85 MB/s Benchmark____GWs_Opt_1kx10x1-16 6357730 552.9 ns/op 5651.67 MB/s Benchmark____GWs_Opt_1kx10x1-16 6654975 545.6 ns/op 5727.56 MB/s Benchmark____GWs_Opt_1kx10x1-16 6315046 547.9 ns/op 5703.59 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4241742 833.1 ns/op 7438.45 MB/s Benchmark____GWs_Opt_2kx10x1-16 4194710 795.8 ns/op 7787.30 MB/s Benchmark____GWs_Opt_2kx10x1-16 4374656 829.0 ns/op 7475.20 MB/s Benchmark____GWs_Opt_2kx10x1-16 4158174 831.9 ns/op 7449.63 MB/s Benchmark____GWs_Opt_2kx10x1-16 4688794 828.5 ns/op 7479.57 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2409536 1482 ns/op 8327.45 MB/s Benchmark____GWs_Opt_4kx10x1-16 2361987 1648 ns/op 7490.69 MB/s Benchmark____GWs_Opt_4kx10x1-16 2428452 1430 ns/op 8628.05 MB/s Benchmark____GWs_Opt_4kx10x1-16 2434840 1527 ns/op 8082.42 MB/s Benchmark____GWs_Opt_4kx10x1-16 2380660 1494 ns/op 8262.88 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12527679 287.0 ns/op 3623.98 MB/s Benchmark____GWs_Int_1kx01x0-16 11655896 288.6 ns/op 3603.04 MB/s Benchmark____GWs_Int_1kx01x0-16 12627642 295.3 ns/op 3522.25 MB/s Benchmark____GWs_Int_1kx01x0-16 12642692 285.6 ns/op 3641.82 MB/s Benchmark____GWs_Int_1kx01x0-16 12374383 287.9 ns/op 3611.80 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10451396 346.3 ns/op 5959.50 MB/s Benchmark____GWs_Int_2kx01x0-16 9362546 353.1 ns/op 5846.07 MB/s Benchmark____GWs_Int_2kx01x0-16 10180197 352.8 ns/op 5851.07 MB/s Benchmark____GWs_Int_2kx01x0-16 9702903 342.4 ns/op 6028.29 MB/s Benchmark____GWs_Int_2kx01x0-16 8721432 360.4 ns/op 5727.41 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5727826 626.1 ns/op 6567.31 MB/s Benchmark____GWs_Int_4kx01x0-16 5671006 626.3 ns/op 6565.31 MB/s Benchmark____GWs_Int_4kx01x0-16 5944789 636.1 ns/op 6464.59 MB/s Benchmark____GWs_Int_4kx01x0-16 5645330 603.9 ns/op 6809.25 MB/s Benchmark____GWs_Int_4kx01x0-16 5677936 630.9 ns/op 6517.77 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30190155 111.4 ns/op 9338.88 MB/s Benchmark____GWs_Int_1kx10x0-16 30837858 112.5 ns/op 9245.45 MB/s Benchmark____GWs_Int_1kx10x0-16 32970955 115.0 ns/op 9043.37 MB/s Benchmark____GWs_Int_1kx10x0-16 30718593 112.3 ns/op 9260.99 MB/s Benchmark____GWs_Int_1kx10x0-16 30923775 111.6 ns/op 9321.03 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25577468 141.4 ns/op 14598.85 MB/s Benchmark____GWs_Int_2kx10x0-16 25779429 149.3 ns/op 13822.57 MB/s Benchmark____GWs_Int_2kx10x0-16 22939029 171.0 ns/op 12068.71 MB/s Benchmark____GWs_Int_2kx10x0-16 25674913 143.1 ns/op 14423.16 MB/s Benchmark____GWs_Int_2kx10x0-16 25508734 145.4 ns/op 14199.63 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 10997157 308.5 ns/op 13330.56 MB/s Benchmark____GWs_Int_4kx10x0-16 13393904 302.9 ns/op 13574.57 MB/s Benchmark____GWs_Int_4kx10x0-16 12439512 303.1 ns/op 13568.27 MB/s Benchmark____GWs_Int_4kx10x0-16 10721989 318.1 ns/op 12928.12 MB/s Benchmark____GWs_Int_4kx10x0-16 9931018 335.4 ns/op 12260.59 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6613959 558.3 ns/op 5597.24 MB/s Benchmark____GWs_Int_1kx01x1-16 6418744 551.6 ns/op 5665.55 MB/s Benchmark____GWs_Int_1kx01x1-16 6574603 557.1 ns/op 5609.24 MB/s Benchmark____GWs_Int_1kx01x1-16 6543232 570.5 ns/op 5478.10 MB/s Benchmark____GWs_Int_1kx01x1-16 6496326 551.6 ns/op 5665.33 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4753611 760.4 ns/op 8149.76 MB/s Benchmark____GWs_Int_2kx01x1-16 4820328 756.7 ns/op 8189.77 MB/s Benchmark____GWs_Int_2kx01x1-16 4553091 778.0 ns/op 7965.02 MB/s Benchmark____GWs_Int_2kx01x1-16 4574308 767.1 ns/op 8078.44 MB/s Benchmark____GWs_Int_2kx01x1-16 4184296 757.6 ns/op 8179.89 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2658684 1354 ns/op 9116.92 MB/s Benchmark____GWs_Int_4kx01x1-16 2658684 1366 ns/op 9035.30 MB/s Benchmark____GWs_Int_4kx01x1-16 2635214 1354 ns/op 9112.37 MB/s Benchmark____GWs_Int_4kx01x1-16 2668849 1369 ns/op 9017.23 MB/s Benchmark____GWs_Int_4kx01x1-16 2688418 1771 ns/op 6966.85 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6375303 549.9 ns/op 5682.39 MB/s Benchmark____GWs_Int_1kx10x1-16 6560323 552.1 ns/op 5660.42 MB/s Benchmark____GWs_Int_1kx10x1-16 6575998 550.9 ns/op 5672.83 MB/s Benchmark____GWs_Int_1kx10x1-16 6543783 553.8 ns/op 5642.38 MB/s Benchmark____GWs_Int_1kx10x1-16 5640132 551.1 ns/op 5670.43 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4238661 848.6 ns/op 7302.27 MB/s Benchmark____GWs_Int_2kx10x1-16 4451380 858.3 ns/op 7220.00 MB/s Benchmark____GWs_Int_2kx10x1-16 3911680 832.7 ns/op 7441.95 MB/s Benchmark____GWs_Int_2kx10x1-16 4173962 842.6 ns/op 7354.71 MB/s Benchmark____GWs_Int_2kx10x1-16 4312165 817.8 ns/op 7577.61 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2434981 1456 ns/op 8477.27 MB/s Benchmark____GWs_Int_4kx10x1-16 2315324 1544 ns/op 7994.02 MB/s Benchmark____GWs_Int_4kx10x1-16 2355499 1530 ns/op 8064.27 MB/s Benchmark____GWs_Int_4kx10x1-16 2335898 1474 ns/op 8370.07 MB/s Benchmark____GWs_Int_4kx10x1-16 2450882 1530 ns/op 8064.21 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8100045 433.3 ns/op 235.42 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8260645 432.2 ns/op 236.00 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8145320 431.8 ns/op 236.23 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8461486 433.2 ns/op 235.45 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8370085 439.3 ns/op 232.17 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 633852 4986 ns/op 35.50 MB/s Benchmark__GWs_Reqs_1SubEach-16 792962 5164 ns/op 34.28 MB/s Benchmark__GWs_Reqs_1SubEach-16 743997 5203 ns/op 34.02 MB/s Benchmark__GWs_Reqs_1SubEach-16 749907 5243 ns/op 33.76 MB/s Benchmark__GWs_Reqs_1SubEach-16 746252 5274 ns/op 33.56 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2108.009s ❌ Non-zero exit code: 1