> ROOT_DIR=/tmp/go-bench-away-job-040f58aa-1f96-43e6-868b-a62aaa5477fc-3605186918 > OUTPUT_FILE=/tmp/go-bench-away-job-040f58aa-1f96-43e6-868b-a62aaa5477fc-3605186918/results.txt > SHA_FILE=/tmp/go-bench-away-job-040f58aa-1f96-43e6-868b-a62aaa5477fc-3605186918/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-040f58aa-1f96-43e6-868b-a62aaa5477fc-3605186918/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.25.4/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-040f58aa-1f96-43e6-868b-a62aaa5477fc-3605186918/source.git SHA of main: bae1d6c752e0550901d0a79a76fb2fabe79c1eff Go runtime: go version go1.26.0 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build3651838567=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-040f58aa-1f96-43e6-868b-a62aaa5477fc-3605186918/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.25.4' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.25.4/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.0' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 54678546 65.50 ns/op 167.94 MB/s Benchmark______Pub0b_Payload-16 51754202 65.42 ns/op 168.16 MB/s Benchmark______Pub0b_Payload-16 47523790 65.42 ns/op 168.14 MB/s Benchmark______Pub0b_Payload-16 51909619 65.50 ns/op 167.93 MB/s Benchmark______Pub0b_Payload-16 51907576 65.13 ns/op 168.89 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 51137162 66.05 ns/op 287.66 MB/s Benchmark______Pub8b_Payload-16 49413372 66.07 ns/op 287.57 MB/s Benchmark______Pub8b_Payload-16 51625802 66.03 ns/op 287.73 MB/s Benchmark______Pub8b_Payload-16 49399671 68.57 ns/op 277.11 MB/s Benchmark______Pub8b_Payload-16 51474129 73.78 ns/op 257.51 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 47308345 70.54 ns/op 623.74 MB/s Benchmark_____Pub32b_Payload-16 47752239 70.81 ns/op 621.37 MB/s Benchmark_____Pub32b_Payload-16 47235705 70.42 ns/op 624.80 MB/s Benchmark_____Pub32b_Payload-16 47892470 70.99 ns/op 619.77 MB/s Benchmark_____Pub32b_Payload-16 50902712 70.53 ns/op 623.85 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 42734484 82.78 ns/op 1703.29 MB/s Benchmark____Pub128B_Payload-16 44570790 79.98 ns/op 1762.99 MB/s Benchmark____Pub128B_Payload-16 42145660 88.34 ns/op 1596.16 MB/s Benchmark____Pub128B_Payload-16 44625471 80.32 ns/op 1755.55 MB/s Benchmark____Pub128B_Payload-16 42164552 80.26 ns/op 1756.79 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 37947182 103.7 ns/op 2592.90 MB/s Benchmark____Pub256B_Payload-16 38332168 89.58 ns/op 3002.81 MB/s Benchmark____Pub256B_Payload-16 37943030 89.18 ns/op 3016.36 MB/s Benchmark____Pub256B_Payload-16 34854020 92.02 ns/op 2923.43 MB/s Benchmark____Pub256B_Payload-16 34223700 89.66 ns/op 3000.33 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 28044603 137.2 ns/op 7565.71 MB/s Benchmark______Pub1K_Payload-16 28241922 128.4 ns/op 8083.96 MB/s Benchmark______Pub1K_Payload-16 24673635 135.0 ns/op 7689.66 MB/s Benchmark______Pub1K_Payload-16 23795168 145.9 ns/op 7112.48 MB/s Benchmark______Pub1K_Payload-16 22816304 140.4 ns/op 7392.33 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5629270 637.6 ns/op 6445.92 MB/s Benchmark______Pub4K_Payload-16 5334273 619.1 ns/op 6638.60 MB/s Benchmark______Pub4K_Payload-16 5315127 623.4 ns/op 6593.15 MB/s Benchmark______Pub4K_Payload-16 5478294 621.5 ns/op 6613.28 MB/s Benchmark______Pub4K_Payload-16 5513673 622.3 ns/op 6604.28 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2789288 1280 ns/op 6410.92 MB/s Benchmark______Pub8K_Payload-16 2748444 1278 ns/op 6423.02 MB/s Benchmark______Pub8K_Payload-16 2763176 1280 ns/op 6412.73 MB/s Benchmark______Pub8K_Payload-16 2782179 1282 ns/op 6399.86 MB/s Benchmark______Pub8K_Payload-16 2680723 1285 ns/op 6387.16 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 656983 5282 ns/op 6206.72 MB/s Benchmark_____Pub32K_Payload-16 653775 5329 ns/op 6152.05 MB/s Benchmark_____Pub32K_Payload-16 663840 5473 ns/op 5989.77 MB/s Benchmark_____Pub32K_Payload-16 648825 9236 ns/op 3549.36 MB/s Benchmark_____Pub32K_Payload-16 708735 6227 ns/op 5264.67 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 41979862 86.84 ns/op 126.67 MB/s Benchmark__AuthPub0b_Payload-16 39846104 86.92 ns/op 126.55 MB/s Benchmark__AuthPub0b_Payload-16 39732980 85.80 ns/op 128.20 MB/s Benchmark__AuthPub0b_Payload-16 39838705 85.63 ns/op 128.46 MB/s Benchmark__AuthPub0b_Payload-16 39296744 85.69 ns/op 128.37 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 16982383 205.6 ns/op Benchmark_____________PubSub-16 17279802 206.7 ns/op Benchmark_____________PubSub-16 17379193 206.1 ns/op Benchmark_____________PubSub-16 17245226 206.5 ns/op Benchmark_____________PubSub-16 17054421 205.7 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 17160175 205.5 ns/op Benchmark_____PubSubTwoConns-16 17247216 204.8 ns/op Benchmark_____PubSubTwoConns-16 17277598 205.6 ns/op Benchmark_____PubSubTwoConns-16 17113363 204.6 ns/op Benchmark_____PubSubTwoConns-16 17301576 204.9 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42288->127.0.0.1:42387: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:47052->127.0.0.1:39851: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:37926->127.0.0.1:37443: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49084->127.0.0.1:43859: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:60446->127.0.0.1:42761: 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 15851556 226.1 ns/op Benchmark_____PubTwoQueueSub-16 15737643 225.4 ns/op Benchmark_____PubTwoQueueSub-16 15663927 226.2 ns/op Benchmark_____PubTwoQueueSub-16 15705247 226.3 ns/op Benchmark_____PubTwoQueueSub-16 15729554 225.3 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15661730 226.5 ns/op Benchmark____PubFourQueueSub-16 15449390 225.6 ns/op Benchmark____PubFourQueueSub-16 15604417 226.0 ns/op Benchmark____PubFourQueueSub-16 15522512 225.5 ns/op Benchmark____PubFourQueueSub-16 15912438 225.7 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15635743 227.5 ns/op Benchmark___PubEightQueueSub-16 15675511 226.6 ns/op Benchmark___PubEightQueueSub-16 15726290 226.8 ns/op Benchmark___PubEightQueueSub-16 15713182 225.2 ns/op Benchmark___PubEightQueueSub-16 15465600 227.2 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22996 155358 ns/op Benchmark_PubSub512kTwoConns-16 22435 155339 ns/op Benchmark_PubSub512kTwoConns-16 23208 154554 ns/op Benchmark_PubSub512kTwoConns-16 23079 155532 ns/op Benchmark_PubSub512kTwoConns-16 23505 154450 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 17082175 208.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 16960563 209.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 16715088 208.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 16634563 208.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 16867087 209.4 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16634749 208.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 16853269 208.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 16792442 209.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 16545846 208.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 16797494 208.4 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 12173239 289.8 ns/op Benchmark____RoutedPubSub_0b-16 11882848 290.4 ns/op Benchmark____RoutedPubSub_0b-16 11920412 292.9 ns/op Benchmark____RoutedPubSub_0b-16 12108754 293.6 ns/op Benchmark____RoutedPubSub_0b-16 11911203 292.4 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6997968 502.1 ns/op Benchmark____RoutedPubSub_1K-16 6933224 502.9 ns/op Benchmark____RoutedPubSub_1K-16 6828974 828.7 ns/op Benchmark____RoutedPubSub_1K-16 6964120 509.3 ns/op Benchmark____RoutedPubSub_1K-16 6743481 506.6 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84640 42975 ns/op Benchmark__RoutedPubSub_100K-16 82148 41421 ns/op Benchmark__RoutedPubSub_100K-16 86257 42246 ns/op Benchmark__RoutedPubSub_100K-16 79038 42524 ns/op Benchmark__RoutedPubSub_100K-16 86173 42472 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11957722 297.3 ns/op Benchmark____Routed2QueueSub-16 11873132 298.8 ns/op Benchmark____Routed2QueueSub-16 9896671 304.7 ns/op Benchmark____Routed2QueueSub-16 10347955 295.6 ns/op Benchmark____Routed2QueueSub-16 10363597 295.2 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9834004 307.6 ns/op Benchmark____Routed4QueueSub-16 11985436 304.0 ns/op Benchmark____Routed4QueueSub-16 10094626 301.5 ns/op Benchmark____Routed4QueueSub-16 9960258 303.3 ns/op Benchmark____Routed4QueueSub-16 11997282 296.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 11730746 309.2 ns/op Benchmark____Routed8QueueSub-16 9669436 315.1 ns/op Benchmark____Routed8QueueSub-16 9920485 305.6 ns/op Benchmark____Routed8QueueSub-16 11725002 304.3 ns/op Benchmark____Routed8QueueSub-16 9789948 312.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 9337484 332.9 ns/op Benchmark___Routed16QueueSub-16 9224756 327.5 ns/op Benchmark___Routed16QueueSub-16 10911556 335.9 ns/op Benchmark___Routed16QueueSub-16 9621247 333.5 ns/op Benchmark___Routed16QueueSub-16 11005150 328.5 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6431298 522.6 ns/op Benchmark____________RouteCompressOff-16 6836775 528.6 ns/op Benchmark____________RouteCompressOff-16 6671884 519.9 ns/op Benchmark____________RouteCompressOff-16 6476118 524.8 ns/op Benchmark____________RouteCompressOff-16 6726433 527.0 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6721152 519.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6770092 466.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6749180 526.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6739400 527.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6722050 524.2 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6785988 523.8 ns/op Benchmark_________RouteCompressS2Fast-16 6830712 527.5 ns/op Benchmark_________RouteCompressS2Fast-16 6803505 517.1 ns/op Benchmark_________RouteCompressS2Fast-16 6767430 524.3 ns/op Benchmark_________RouteCompressS2Fast-16 6585098 520.4 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6746222 518.9 ns/op Benchmark_______RouteCompressS2Better-16 6840783 523.9 ns/op Benchmark_______RouteCompressS2Better-16 6762802 528.7 ns/op Benchmark_______RouteCompressS2Better-16 6885441 555.6 ns/op Benchmark_______RouteCompressS2Better-16 6765439 527.0 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6759771 522.9 ns/op Benchmark_________RouteCompressS2Best-16 6812568 525.3 ns/op Benchmark_________RouteCompressS2Best-16 6778468 547.1 ns/op Benchmark_________RouteCompressS2Best-16 6584442 523.4 ns/op Benchmark_________RouteCompressS2Best-16 6750001 526.0 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5275411 681.0 ns/op 365.63 MB/s Benchmark______FanOut_8x1x10-16 5280668 688.4 ns/op 361.70 MB/s Benchmark______FanOut_8x1x10-16 5278202 676.8 ns/op 367.89 MB/s Benchmark______FanOut_8x1x10-16 5272297 679.9 ns/op 366.22 MB/s Benchmark______FanOut_8x1x10-16 5256048 682.9 ns/op 364.61 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 632736 5268 ns/op 440.18 MB/s Benchmark_____FanOut_8x1x100-16 609075 5352 ns/op 433.32 MB/s Benchmark_____FanOut_8x1x100-16 647697 5327 ns/op 435.30 MB/s Benchmark_____FanOut_8x1x100-16 618980 5298 ns/op 437.70 MB/s Benchmark_____FanOut_8x1x100-16 623936 5307 ns/op 436.98 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 52938 68204 ns/op 337.50 MB/s Benchmark____FanOut_8x10x100-16 52831 68146 ns/op 337.79 MB/s Benchmark____FanOut_8x10x100-16 52734 68054 ns/op 338.25 MB/s Benchmark____FanOut_8x10x100-16 53043 68348 ns/op 336.79 MB/s Benchmark____FanOut_8x10x100-16 52827 68231 ns/op 337.37 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6489 533027 ns/op 450.29 MB/s Benchmark___FanOut_8x10x1000-16 6360 530586 ns/op 452.37 MB/s Benchmark___FanOut_8x10x1000-16 6717 538624 ns/op 445.62 MB/s Benchmark___FanOut_8x10x1000-16 6530 531333 ns/op 451.73 MB/s Benchmark___FanOut_8x10x1000-16 6697 538904 ns/op 445.38 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5534 643801 ns/op 357.28 MB/s Benchmark___FanOut_8x100x100-16 5508 633792 ns/op 362.93 MB/s Benchmark___FanOut_8x100x100-16 5566 629836 ns/op 365.20 MB/s Benchmark___FanOut_8x100x100-16 5617 633387 ns/op 363.16 MB/s Benchmark___FanOut_8x100x100-16 5584 633451 ns/op 363.12 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 656 5542384 ns/op 433.03 MB/s Benchmark__FanOut_8x100x1000-16 651 5505265 ns/op 435.95 MB/s Benchmark__FanOut_8x100x1000-16 630 5444371 ns/op 440.83 MB/s Benchmark__FanOut_8x100x1000-16 626 5568456 ns/op 431.00 MB/s Benchmark__FanOut_8x100x1000-16 657 5527121 ns/op 434.23 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 613 5846697 ns/op 427.60 MB/s Benchmark__FanOut_8x10x10000-16 603 5852988 ns/op 427.14 MB/s Benchmark__FanOut_8x10x10000-16 619 5883407 ns/op 424.93 MB/s Benchmark__FanOut_8x10x10000-16 600 5889406 ns/op 424.49 MB/s Benchmark__FanOut_8x10x10000-16 601 5886436 ns/op 424.71 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1045 3389869 ns/op 339.25 MB/s Benchmark___FanOut_8x500x100-16 1047 3413272 ns/op 336.93 MB/s Benchmark___FanOut_8x500x100-16 1046 3402069 ns/op 338.04 MB/s Benchmark___FanOut_8x500x100-16 1035 3391741 ns/op 339.06 MB/s Benchmark___FanOut_8x500x100-16 1036 3384108 ns/op 339.83 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 382141 8889 ns/op 1647.15 MB/s Benchmark___FanOut_128x1x100-16 386349 8896 ns/op 1645.85 MB/s Benchmark___FanOut_128x1x100-16 388975 8876 ns/op 1649.48 MB/s Benchmark___FanOut_128x1x100-16 383564 8852 ns/op 1654.04 MB/s Benchmark___FanOut_128x1x100-16 395138 8863 ns/op 1651.86 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 34652 103273 ns/op 1405.41 MB/s Benchmark__FanOut_128x10x100-16 34760 103580 ns/op 1401.24 MB/s Benchmark__FanOut_128x10x100-16 34771 103026 ns/op 1408.78 MB/s Benchmark__FanOut_128x10x100-16 34736 103230 ns/op 1406.00 MB/s Benchmark__FanOut_128x10x100-16 34905 103255 ns/op 1405.65 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4476 794808 ns/op 1837.10 MB/s Benchmark_FanOut_128x10x1000-16 4452 798818 ns/op 1827.88 MB/s Benchmark_FanOut_128x10x1000-16 4560 799418 ns/op 1826.50 MB/s Benchmark_FanOut_128x10x1000-16 4395 801855 ns/op 1820.95 MB/s Benchmark_FanOut_128x10x1000-16 4368 797825 ns/op 1830.15 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3716 945276 ns/op 1534.09 MB/s Benchmark_FanOut_128x100x100-16 3712 944446 ns/op 1535.44 MB/s Benchmark_FanOut_128x100x100-16 3754 940363 ns/op 1542.11 MB/s Benchmark_FanOut_128x100x100-16 3760 942102 ns/op 1539.26 MB/s Benchmark_FanOut_128x100x100-16 3760 943435 ns/op 1537.09 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 418 8580658 ns/op 1701.52 MB/s BenchmarkFanOut_128x100x1000-16 422 8339213 ns/op 1750.78 MB/s BenchmarkFanOut_128x100x1000-16 422 8458480 ns/op 1726.10 MB/s BenchmarkFanOut_128x100x1000-16 421 8463178 ns/op 1725.14 MB/s BenchmarkFanOut_128x100x1000-16 418 8634687 ns/op 1690.87 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 405 8832451 ns/op 1664.33 MB/s BenchmarkFanOut_128x10x10000-16 410 8861332 ns/op 1658.91 MB/s BenchmarkFanOut_128x10x10000-16 406 8920959 ns/op 1647.82 MB/s BenchmarkFanOut_128x10x10000-16 411 8814085 ns/op 1667.80 MB/s BenchmarkFanOut_128x10x10000-16 406 8898720 ns/op 1651.94 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 705 5023266 ns/op 1443.31 MB/s BenchmarkFanOut__128x500x100-16 710 5000017 ns/op 1450.02 MB/s BenchmarkFanOut__128x500x100-16 714 5006102 ns/op 1448.26 MB/s BenchmarkFanOut__128x500x100-16 709 4972771 ns/op 1457.97 MB/s BenchmarkFanOut__128x500x100-16 710 5002704 ns/op 1449.24 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1983 1775805 ns/op 2979.23 MB/s Benchmark_FanOut_512x100x100-16 1959 1762304 ns/op 3002.05 MB/s Benchmark_FanOut_512x100x100-16 1987 1764195 ns/op 2998.83 MB/s Benchmark_FanOut_512x100x100-16 2002 1777302 ns/op 2976.72 MB/s Benchmark_FanOut_512x100x100-16 2052 1761137 ns/op 3004.04 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 220 16154737 ns/op 3280.80 MB/s Benchmark__FanOut_512x100x1k-16 222 16027771 ns/op 3306.79 MB/s Benchmark__FanOut_512x100x1k-16 224 16037382 ns/op 3304.81 MB/s Benchmark__FanOut_512x100x1k-16 220 16159380 ns/op 3279.86 MB/s Benchmark__FanOut_512x100x1k-16 222 16054689 ns/op 3301.25 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3441 1111011 ns/op 9388.78 MB/s Benchmark____FanOut_1kx10x1k-16 3325 1114598 ns/op 9358.56 MB/s Benchmark____FanOut_1kx10x1k-16 3196 1138277 ns/op 9163.89 MB/s Benchmark____FanOut_1kx10x1k-16 3253 1109429 ns/op 9402.17 MB/s Benchmark____FanOut_1kx10x1k-16 3020 1112843 ns/op 9373.33 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2904 1188434 ns/op 8768.71 MB/s Benchmark__FanOut_1kx100x100-16 2907 1190352 ns/op 8754.58 MB/s Benchmark__FanOut_1kx100x100-16 2912 1177857 ns/op 8847.45 MB/s Benchmark__FanOut_1kx100x100-16 2875 1191694 ns/op 8744.73 MB/s Benchmark__FanOut_1kx100x100-16 2881 1194064 ns/op 8727.37 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 5190276 693.6 ns/op 358.99 MB/s Benchmark_____RFanOut_8x1x10-16 4921257 697.5 ns/op 356.99 MB/s Benchmark_____RFanOut_8x1x10-16 4921004 690.9 ns/op 360.40 MB/s Benchmark_____RFanOut_8x1x10-16 5102713 688.8 ns/op 361.48 MB/s Benchmark_____RFanOut_8x1x10-16 5029028 684.1 ns/op 363.97 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 589303 5590 ns/op 414.85 MB/s Benchmark____RFanOut_8x1x100-16 601812 5405 ns/op 429.06 MB/s Benchmark____RFanOut_8x1x100-16 589779 5296 ns/op 437.89 MB/s Benchmark____RFanOut_8x1x100-16 615490 5415 ns/op 428.22 MB/s Benchmark____RFanOut_8x1x100-16 603220 5280 ns/op 439.17 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 52360 67799 ns/op 339.52 MB/s Benchmark___RFanOut_8x10x100-16 52520 67914 ns/op 338.94 MB/s Benchmark___RFanOut_8x10x100-16 52618 68330 ns/op 336.88 MB/s Benchmark___RFanOut_8x10x100-16 53013 68149 ns/op 337.78 MB/s Benchmark___RFanOut_8x10x100-16 51519 68325 ns/op 336.90 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6872 536655 ns/op 447.25 MB/s Benchmark__RFanOut_8x10x1000-16 6584 538615 ns/op 445.62 MB/s Benchmark__RFanOut_8x10x1000-16 6720 538811 ns/op 445.46 MB/s Benchmark__RFanOut_8x10x1000-16 6505 542191 ns/op 442.68 MB/s Benchmark__RFanOut_8x10x1000-16 6639 542116 ns/op 442.75 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5562 633230 ns/op 363.25 MB/s Benchmark__RFanOut_8x100x100-16 5468 635048 ns/op 362.21 MB/s Benchmark__RFanOut_8x100x100-16 5515 636867 ns/op 361.17 MB/s Benchmark__RFanOut_8x100x100-16 5528 643609 ns/op 357.39 MB/s Benchmark__RFanOut_8x100x100-16 5606 636580 ns/op 361.34 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 651 5577433 ns/op 430.31 MB/s Benchmark_RFanOut_8x100x1000-16 628 5637971 ns/op 425.69 MB/s Benchmark_RFanOut_8x100x1000-16 634 5504363 ns/op 436.02 MB/s Benchmark_RFanOut_8x100x1000-16 643 5647524 ns/op 424.97 MB/s Benchmark_RFanOut_8x100x1000-16 649 5552668 ns/op 432.23 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 606 5946706 ns/op 420.40 MB/s Benchmark_RFanOut_8x10x10000-16 622 5871920 ns/op 425.76 MB/s Benchmark_RFanOut_8x10x10000-16 612 5943454 ns/op 420.63 MB/s Benchmark_RFanOut_8x10x10000-16 604 5949632 ns/op 420.20 MB/s Benchmark_RFanOut_8x10x10000-16 591 5909888 ns/op 423.02 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3020 1124888 ns/op 9272.96 MB/s Benchmark_RFanOut_1kx10x1000-16 3190 1118494 ns/op 9325.97 MB/s Benchmark_RFanOut_1kx10x1000-16 3313 1091928 ns/op 9552.86 MB/s Benchmark_RFanOut_1kx10x1000-16 3142 1120730 ns/op 9307.36 MB/s Benchmark_RFanOut_1kx10x1000-16 3376 1099136 ns/op 9490.22 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7431322 487.4 ns/op 4263.59 MB/s Benchmark_____FanIn_1kx100x1-16 7208877 487.6 ns/op 4261.83 MB/s Benchmark_____FanIn_1kx100x1-16 7243980 484.6 ns/op 4287.65 MB/s Benchmark_____FanIn_1kx100x1-16 7168290 486.9 ns/op 4267.77 MB/s Benchmark_____FanIn_1kx100x1-16 7233385 486.6 ns/op 4270.32 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2705461 1338 ns/op 6143.14 MB/s Benchmark_____FanIn_4kx100x1-16 2687160 1347 ns/op 6102.15 MB/s Benchmark_____FanIn_4kx100x1-16 2661650 1354 ns/op 6070.42 MB/s Benchmark_____FanIn_4kx100x1-16 2681894 1325 ns/op 6206.19 MB/s Benchmark_____FanIn_4kx100x1-16 2628510 1345 ns/op 6110.85 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1687994 2120 ns/op 7740.83 MB/s Benchmark_____FanIn_8kx100x1-16 1728998 2093 ns/op 7841.12 MB/s Benchmark_____FanIn_8kx100x1-16 1710589 2077 ns/op 7902.96 MB/s Benchmark_____FanIn_8kx100x1-16 1742421 2091 ns/op 7848.71 MB/s Benchmark_____FanIn_8kx100x1-16 1725163 2081 ns/op 7887.96 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 880864 4112 ns/op 7976.84 MB/s Benchmark____FanIn_16kx100x1-16 875216 4430 ns/op 7403.75 MB/s Benchmark____FanIn_16kx100x1-16 875802 4114 ns/op 7972.65 MB/s Benchmark____FanIn_16kx100x1-16 872931 4129 ns/op 7944.02 MB/s Benchmark____FanIn_16kx100x1-16 873994 4150 ns/op 7903.17 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 170846 20141 ns/op 6509.43 MB/s Benchmark____FanIn_64kx100x1-16 170799 19788 ns/op 6625.45 MB/s Benchmark____FanIn_64kx100x1-16 169495 19860 ns/op 6601.32 MB/s Benchmark____FanIn_64kx100x1-16 180716 19943 ns/op 6574.07 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 6331043187 vs 11517662100 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57030->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57548->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57232->127.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:57018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57254->127.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:57492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57720->127.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:57390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57350->127.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:57258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57460->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 410311700 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52528->127.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:51872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51966->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52148->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:51732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52422->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: 954728470 vs 11431048000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:55270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55084->127.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:54874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54618->127.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:54698->127.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:55126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54988->127.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:55036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55158->127.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: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:54656->127.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: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:55142->127.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:54790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54438->127.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:55282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55202->127.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:54918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54718->127.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: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:54682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55066->127.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:54602->127.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:55170->127.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:54738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:55268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54630->127.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:54598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55176->127.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: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: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:54400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54376->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54990->127.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: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:54428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54482->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: 737905610 vs 1310900000 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:56872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56644->127.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:56556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57154->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: 569061690 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59036->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:58414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58828->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: 603407270 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60226->127.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:60922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:60300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60402->127.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:60026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:60208->127.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:60548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:60086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:60038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60558->127.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 --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5969144 603.8 ns/op 470.36 MB/s Benchmark___BumpPubCount_1x3-16 5896387 600.8 ns/op 472.71 MB/s Benchmark___BumpPubCount_1x3-16 5925370 597.8 ns/op 475.05 MB/s Benchmark___BumpPubCount_1x3-16 5916646 597.2 ns/op 475.55 MB/s Benchmark___BumpPubCount_1x3-16 5991392 600.6 ns/op 472.85 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5634122 632.6 ns/op 448.96 MB/s Benchmark___BumpPubCount_2x3-16 5592985 633.2 ns/op 448.49 MB/s Benchmark___BumpPubCount_2x3-16 5637531 633.4 ns/op 448.36 MB/s Benchmark___BumpPubCount_2x3-16 5609298 635.6 ns/op 446.84 MB/s Benchmark___BumpPubCount_2x3-16 5572269 636.6 ns/op 446.15 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5818076 616.6 ns/op 460.57 MB/s Benchmark___BumpPubCount_5x3-16 5778008 615.1 ns/op 461.70 MB/s Benchmark___BumpPubCount_5x3-16 5846322 614.3 ns/op 462.33 MB/s Benchmark___BumpPubCount_5x3-16 5621160 612.7 ns/op 463.52 MB/s Benchmark___BumpPubCount_5x3-16 5731878 614.8 ns/op 461.96 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5878668 612.3 ns/op 463.83 MB/s Benchmark__BumpPubCount_10x3-16 5853592 611.1 ns/op 464.72 MB/s Benchmark__BumpPubCount_10x3-16 5856098 616.9 ns/op 460.36 MB/s Benchmark__BumpPubCount_10x3-16 5852896 611.8 ns/op 464.21 MB/s Benchmark__BumpPubCount_10x3-16 5842160 612.2 ns/op 463.90 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12381212 270.1 ns/op 3850.14 MB/s Benchmark____GWs_Opt_1kx01x0-16 13408018 276.0 ns/op 3768.27 MB/s Benchmark____GWs_Opt_1kx01x0-16 13431927 268.2 ns/op 3877.85 MB/s Benchmark____GWs_Opt_1kx01x0-16 12135592 263.0 ns/op 3955.10 MB/s Benchmark____GWs_Opt_1kx01x0-16 13112508 272.8 ns/op 3812.22 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10798988 314.9 ns/op 6554.55 MB/s Benchmark____GWs_Opt_2kx01x0-16 9747456 340.7 ns/op 6057.57 MB/s Benchmark____GWs_Opt_2kx01x0-16 10292679 332.4 ns/op 6209.96 MB/s Benchmark____GWs_Opt_2kx01x0-16 10673199 317.6 ns/op 6499.09 MB/s Benchmark____GWs_Opt_2kx01x0-16 10946919 347.2 ns/op 5945.38 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5938761 716.1 ns/op 5742.49 MB/s Benchmark____GWs_Opt_4kx01x0-16 5752219 627.0 ns/op 6558.19 MB/s Benchmark____GWs_Opt_4kx01x0-16 5556192 624.4 ns/op 6585.07 MB/s Benchmark____GWs_Opt_4kx01x0-16 5685867 613.2 ns/op 6705.73 MB/s Benchmark____GWs_Opt_4kx01x0-16 5657335 629.2 ns/op 6535.42 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 32523764 111.7 ns/op 9307.28 MB/s Benchmark____GWs_Opt_1kx10x0-16 31401495 114.0 ns/op 9125.42 MB/s Benchmark____GWs_Opt_1kx10x0-16 33002024 130.4 ns/op 7973.98 MB/s Benchmark____GWs_Opt_1kx10x0-16 32484939 107.6 ns/op 9661.10 MB/s Benchmark____GWs_Opt_1kx10x0-16 31411059 115.4 ns/op 9009.66 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23812188 142.4 ns/op 14492.87 MB/s Benchmark____GWs_Opt_2kx10x0-16 25553479 165.0 ns/op 12507.32 MB/s Benchmark____GWs_Opt_2kx10x0-16 26195335 158.7 ns/op 13003.96 MB/s Benchmark____GWs_Opt_2kx10x0-16 25043030 150.3 ns/op 13731.21 MB/s Benchmark____GWs_Opt_2kx10x0-16 25040976 140.4 ns/op 14699.39 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11599828 364.1 ns/op 11293.86 MB/s Benchmark____GWs_Opt_4kx10x0-16 12828721 281.0 ns/op 14635.18 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:33942->127.0.0.1:40151: 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:60202->127.0.0.1:37953: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 10642518 285.5 ns/op 14402.71 MB/s Benchmark____GWs_Opt_4kx10x0-16 11298669 2528 ns/op 1626.45 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6690189 533.2 ns/op 5860.63 MB/s Benchmark____GWs_Opt_1kx01x1-16 6824716 534.9 ns/op 5841.83 MB/s Benchmark____GWs_Opt_1kx01x1-16 6515523 543.0 ns/op 5755.04 MB/s Benchmark____GWs_Opt_1kx01x1-16 6507951 538.5 ns/op 5803.47 MB/s Benchmark____GWs_Opt_1kx01x1-16 6581088 539.9 ns/op 5788.46 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4792002 743.8 ns/op 8331.10 MB/s Benchmark____GWs_Opt_2kx01x1-16 4881206 779.8 ns/op 7947.03 MB/s Benchmark____GWs_Opt_2kx01x1-16 4847030 739.0 ns/op 8385.68 MB/s Benchmark____GWs_Opt_2kx01x1-16 4832715 739.3 ns/op 8382.56 MB/s Benchmark____GWs_Opt_2kx01x1-16 4776880 744.9 ns/op 8319.71 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2674999 1343 ns/op 9191.64 MB/s Benchmark____GWs_Opt_4kx01x1-16 2681374 1361 ns/op 9070.09 MB/s Benchmark____GWs_Opt_4kx01x1-16 2644036 1360 ns/op 9074.65 MB/s Benchmark____GWs_Opt_4kx01x1-16 2637704 1366 ns/op 9034.28 MB/s Benchmark____GWs_Opt_4kx01x1-16 2697207 1357 ns/op 9096.10 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6683253 528.6 ns/op 5911.65 MB/s Benchmark____GWs_Opt_1kx10x1-16 6457453 537.2 ns/op 5817.43 MB/s Benchmark____GWs_Opt_1kx10x1-16 6705286 543.8 ns/op 5746.29 MB/s Benchmark____GWs_Opt_1kx10x1-16 6267410 521.8 ns/op 5988.60 MB/s Benchmark____GWs_Opt_1kx10x1-16 6444434 543.6 ns/op 5749.17 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4381093 836.5 ns/op 7408.03 MB/s Benchmark____GWs_Opt_2kx10x1-16 4886043 822.9 ns/op 7530.53 MB/s Benchmark____GWs_Opt_2kx10x1-16 4300826 820.8 ns/op 7550.35 MB/s Benchmark____GWs_Opt_2kx10x1-16 4239397 817.1 ns/op 7584.52 MB/s Benchmark____GWs_Opt_2kx10x1-16 4133124 828.2 ns/op 7482.19 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2394559 2036 ns/op 6061.33 MB/s Benchmark____GWs_Opt_4kx10x1-16 2296465 1464 ns/op 8426.82 MB/s Benchmark____GWs_Opt_4kx10x1-16 2298949 1491 ns/op 8279.56 MB/s Benchmark____GWs_Opt_4kx10x1-16 2363114 1499 ns/op 8235.45 MB/s Benchmark____GWs_Opt_4kx10x1-16 2395194 1461 ns/op 8449.69 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 13014595 281.5 ns/op 3694.25 MB/s Benchmark____GWs_Int_1kx01x0-16 11580566 283.3 ns/op 3670.94 MB/s Benchmark____GWs_Int_1kx01x0-16 12261670 277.6 ns/op 3745.86 MB/s Benchmark____GWs_Int_1kx01x0-16 12077476 281.5 ns/op 3694.10 MB/s Benchmark____GWs_Int_1kx01x0-16 13371618 284.8 ns/op 3652.01 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10335902 344.7 ns/op 5988.61 MB/s Benchmark____GWs_Int_2kx01x0-16 9285542 356.8 ns/op 5784.26 MB/s Benchmark____GWs_Int_2kx01x0-16 10265613 358.1 ns/op 5763.67 MB/s Benchmark____GWs_Int_2kx01x0-16 10443430 334.1 ns/op 6177.57 MB/s Benchmark____GWs_Int_2kx01x0-16 10103068 351.1 ns/op 5878.78 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5671717 631.5 ns/op 6511.41 MB/s Benchmark____GWs_Int_4kx01x0-16 5774055 616.7 ns/op 6667.37 MB/s Benchmark____GWs_Int_4kx01x0-16 5383836 616.3 ns/op 6671.81 MB/s Benchmark____GWs_Int_4kx01x0-16 5738701 638.4 ns/op 6441.04 MB/s Benchmark____GWs_Int_4kx01x0-16 5810068 664.7 ns/op 6185.87 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31531370 106.1 ns/op 9804.63 MB/s Benchmark____GWs_Int_1kx10x0-16 31742090 111.8 ns/op 9303.35 MB/s Benchmark____GWs_Int_1kx10x0-16 30936436 106.1 ns/op 9800.87 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:52678->127.0.0.1:46571: 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:59836->127.0.0.1:45651: use of closed network connection --- FAIL: Benchmark____GWs_Int_1kx10x0-16 Benchmark____GWs_Int_1kx10x0-16 32097056 111.6 ns/op 9316.84 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25877019 146.2 ns/op 14113.96 MB/s Benchmark____GWs_Int_2kx10x0-16 25938280 143.0 ns/op 14430.57 MB/s Benchmark____GWs_Int_2kx10x0-16 26265367 152.2 ns/op 13561.50 MB/s Benchmark____GWs_Int_2kx10x0-16 21965806 141.4 ns/op 14598.67 MB/s Benchmark____GWs_Int_2kx10x0-16 22604095 140.3 ns/op 14707.88 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13159173 276.6 ns/op 14867.05 MB/s Benchmark____GWs_Int_4kx10x0-16 11253996 295.6 ns/op 13911.67 MB/s Benchmark____GWs_Int_4kx10x0-16 11324649 293.8 ns/op 13994.21 MB/s Benchmark____GWs_Int_4kx10x0-16 13284687 287.8 ns/op 14287.98 MB/s Benchmark____GWs_Int_4kx10x0-16 13183146 280.4 ns/op 14662.61 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6416293 544.5 ns/op 5739.11 MB/s Benchmark____GWs_Int_1kx01x1-16 6491650 557.5 ns/op 5605.60 MB/s Benchmark____GWs_Int_1kx01x1-16 6739816 542.4 ns/op 5761.63 MB/s Benchmark____GWs_Int_1kx01x1-16 6410356 537.7 ns/op 5811.55 MB/s Benchmark____GWs_Int_1kx01x1-16 6730624 542.1 ns/op 5764.50 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4681921 747.4 ns/op 8291.07 MB/s Benchmark____GWs_Int_2kx01x1-16 4896164 753.3 ns/op 8226.06 MB/s Benchmark____GWs_Int_2kx01x1-16 4954471 755.3 ns/op 8204.18 MB/s Benchmark____GWs_Int_2kx01x1-16 4729108 745.7 ns/op 8310.43 MB/s Benchmark____GWs_Int_2kx01x1-16 4760290 744.2 ns/op 8327.57 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2620042 1341 ns/op 9202.25 MB/s Benchmark____GWs_Int_4kx01x1-16 2672637 1356 ns/op 9098.51 MB/s Benchmark____GWs_Int_4kx01x1-16 2632570 1342 ns/op 9195.57 MB/s Benchmark____GWs_Int_4kx01x1-16 2671782 1429 ns/op 8637.44 MB/s Benchmark____GWs_Int_4kx01x1-16 2656761 1349 ns/op 9147.50 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6362289 529.5 ns/op 5901.86 MB/s Benchmark____GWs_Int_1kx10x1-16 6559308 540.8 ns/op 5778.36 MB/s Benchmark____GWs_Int_1kx10x1-16 6780909 575.1 ns/op 5433.41 MB/s Benchmark____GWs_Int_1kx10x1-16 6809973 529.0 ns/op 5907.59 MB/s Benchmark____GWs_Int_1kx10x1-16 6311032 655.6 ns/op 4766.82 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4297869 821.7 ns/op 7542.05 MB/s Benchmark____GWs_Int_2kx10x1-16 4177054 824.1 ns/op 7519.49 MB/s Benchmark____GWs_Int_2kx10x1-16 4400436 812.5 ns/op 7627.05 MB/s Benchmark____GWs_Int_2kx10x1-16 4204273 827.1 ns/op 7492.25 MB/s Benchmark____GWs_Int_2kx10x1-16 4313233 807.0 ns/op 7678.70 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2347255 1485 ns/op 8310.16 MB/s Benchmark____GWs_Int_4kx10x1-16 2363426 1484 ns/op 8315.33 MB/s Benchmark____GWs_Int_4kx10x1-16 2466400 1428 ns/op 8643.56 MB/s Benchmark____GWs_Int_4kx10x1-16 2432157 1468 ns/op 8405.54 MB/s Benchmark____GWs_Int_4kx10x1-16 2293656 1488 ns/op 8294.64 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8227633 425.5 ns/op 239.71 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8402220 427.3 ns/op 238.70 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8405140 422.7 ns/op 241.30 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8523700 430.7 ns/op 236.84 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8326317 422.8 ns/op 241.24 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 647836 4683 ns/op 37.79 MB/s Benchmark__GWs_Reqs_1SubEach-16 800137 4886 ns/op 36.22 MB/s Benchmark__GWs_Reqs_1SubEach-16 839275 5024 ns/op 35.23 MB/s Benchmark__GWs_Reqs_1SubEach-16 751212 4917 ns/op 36.00 MB/s Benchmark__GWs_Reqs_1SubEach-16 811418 5053 ns/op 35.03 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2182.240s ❌ Non-zero exit code: 1