> ROOT_DIR=/tmp/go-bench-away-job-45e959c6-e283-46e3-bc61-bd6bc159ab0a-2574129792 > OUTPUT_FILE=/tmp/go-bench-away-job-45e959c6-e283-46e3-bc61-bd6bc159ab0a-2574129792/results.txt > SHA_FILE=/tmp/go-bench-away-job-45e959c6-e283-46e3-bc61-bd6bc159ab0a-2574129792/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-45e959c6-e283-46e3-bc61-bd6bc159ab0a-2574129792/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-45e959c6-e283-46e3-bc61-bd6bc159ab0a-2574129792/source.git SHA of main: d998ae7416defc42d7cbfc99c0d9b2ecea20a98f 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-build2437548738=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-45e959c6-e283-46e3-bc61-bd6bc159ab0a-2574129792/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 49756543 74.14 ns/op 148.36 MB/s Benchmark______Pub0b_Payload-16 47277657 72.57 ns/op 151.57 MB/s Benchmark______Pub0b_Payload-16 47349219 72.62 ns/op 151.48 MB/s Benchmark______Pub0b_Payload-16 47308020 72.14 ns/op 152.48 MB/s Benchmark______Pub0b_Payload-16 41851209 72.19 ns/op 152.37 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45849007 73.02 ns/op 260.19 MB/s Benchmark______Pub8b_Payload-16 46460150 72.79 ns/op 261.03 MB/s Benchmark______Pub8b_Payload-16 46577372 73.22 ns/op 259.49 MB/s Benchmark______Pub8b_Payload-16 44813558 72.83 ns/op 260.90 MB/s Benchmark______Pub8b_Payload-16 44497627 72.63 ns/op 261.58 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44038048 77.14 ns/op 570.41 MB/s Benchmark_____Pub32b_Payload-16 46575753 77.03 ns/op 571.23 MB/s Benchmark_____Pub32b_Payload-16 44497095 80.39 ns/op 547.33 MB/s Benchmark_____Pub32b_Payload-16 44031592 78.38 ns/op 561.37 MB/s Benchmark_____Pub32b_Payload-16 44238392 77.18 ns/op 570.11 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39189822 86.71 ns/op 1626.07 MB/s Benchmark____Pub128B_Payload-16 40033386 86.52 ns/op 1629.72 MB/s Benchmark____Pub128B_Payload-16 34714448 93.46 ns/op 1508.65 MB/s Benchmark____Pub128B_Payload-16 41732121 86.73 ns/op 1625.71 MB/s Benchmark____Pub128B_Payload-16 41707932 86.63 ns/op 1627.56 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36232549 94.93 ns/op 2833.66 MB/s Benchmark____Pub256B_Payload-16 35191489 95.17 ns/op 2826.41 MB/s Benchmark____Pub256B_Payload-16 36499633 94.76 ns/op 2838.68 MB/s Benchmark____Pub256B_Payload-16 35251046 95.35 ns/op 2821.04 MB/s Benchmark____Pub256B_Payload-16 31880186 98.67 ns/op 2726.23 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23264696 142.3 ns/op 7294.50 MB/s Benchmark______Pub1K_Payload-16 25469854 143.7 ns/op 7224.59 MB/s Benchmark______Pub1K_Payload-16 23408352 134.8 ns/op 7698.84 MB/s Benchmark______Pub1K_Payload-16 26323773 135.1 ns/op 7682.80 MB/s Benchmark______Pub1K_Payload-16 24437366 141.8 ns/op 7320.21 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5496490 634.2 ns/op 6480.11 MB/s Benchmark______Pub4K_Payload-16 5548368 624.5 ns/op 6581.34 MB/s Benchmark______Pub4K_Payload-16 5565368 623.6 ns/op 6590.87 MB/s Benchmark______Pub4K_Payload-16 5425741 621.2 ns/op 6616.62 MB/s Benchmark______Pub4K_Payload-16 5570826 621.5 ns/op 6613.23 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2800509 1280 ns/op 6413.36 MB/s Benchmark______Pub8K_Payload-16 2744554 1276 ns/op 6432.36 MB/s Benchmark______Pub8K_Payload-16 2675703 1313 ns/op 6251.44 MB/s Benchmark______Pub8K_Payload-16 2714652 1266 ns/op 6480.94 MB/s Benchmark______Pub8K_Payload-16 2732808 1286 ns/op 6382.73 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 646588 5475 ns/op 5987.81 MB/s Benchmark_____Pub32K_Payload-16 649027 5558 ns/op 5897.86 MB/s Benchmark_____Pub32K_Payload-16 652430 5497 ns/op 5963.51 MB/s Benchmark_____Pub32K_Payload-16 641574 5402 ns/op 6068.34 MB/s Benchmark_____Pub32K_Payload-16 642064 5420 ns/op 6048.18 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32596639 94.19 ns/op 116.79 MB/s Benchmark__AuthPub0b_Payload-16 34608955 93.74 ns/op 117.34 MB/s Benchmark__AuthPub0b_Payload-16 36453136 94.16 ns/op 116.82 MB/s Benchmark__AuthPub0b_Payload-16 36598018 94.23 ns/op 116.74 MB/s Benchmark__AuthPub0b_Payload-16 36554823 94.10 ns/op 116.90 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15546506 228.5 ns/op Benchmark_____________PubSub-16 15517204 228.4 ns/op Benchmark_____________PubSub-16 15285044 229.6 ns/op Benchmark_____________PubSub-16 15543327 229.3 ns/op Benchmark_____________PubSub-16 15369692 228.9 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15607056 227.2 ns/op Benchmark_____PubSubTwoConns-16 15578272 227.8 ns/op Benchmark_____PubSubTwoConns-16 15401337 228.9 ns/op Benchmark_____PubSubTwoConns-16 15317797 227.1 ns/op Benchmark_____PubSubTwoConns-16 15320846 228.0 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33854->127.0.0.1:34895: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:54982->127.0.0.1:45121: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50728->127.0.0.1:33339: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:45314->127.0.0.1:34175: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:47936->127.0.0.1:44343: 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 14217320 249.2 ns/op Benchmark_____PubTwoQueueSub-16 13881571 249.8 ns/op Benchmark_____PubTwoQueueSub-16 14165925 249.4 ns/op Benchmark_____PubTwoQueueSub-16 14123593 249.7 ns/op Benchmark_____PubTwoQueueSub-16 14141964 249.3 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14203288 249.8 ns/op Benchmark____PubFourQueueSub-16 14039272 249.4 ns/op Benchmark____PubFourQueueSub-16 14217254 250.1 ns/op Benchmark____PubFourQueueSub-16 14169640 250.3 ns/op Benchmark____PubFourQueueSub-16 14227075 249.8 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14197189 250.0 ns/op Benchmark___PubEightQueueSub-16 14214646 250.3 ns/op Benchmark___PubEightQueueSub-16 14126799 250.2 ns/op Benchmark___PubEightQueueSub-16 14096400 250.6 ns/op Benchmark___PubEightQueueSub-16 13965954 249.5 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23254 154577 ns/op Benchmark_PubSub512kTwoConns-16 23116 155834 ns/op Benchmark_PubSub512kTwoConns-16 23226 154882 ns/op Benchmark_PubSub512kTwoConns-16 22897 155414 ns/op Benchmark_PubSub512kTwoConns-16 23340 157323 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15187152 231.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 14966029 231.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15204073 230.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 14885104 231.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15289929 231.6 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15083385 231.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 14979435 231.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15025369 231.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 14894779 231.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 14947990 231.9 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11083765 312.1 ns/op Benchmark____RoutedPubSub_0b-16 11175198 315.6 ns/op Benchmark____RoutedPubSub_0b-16 11744562 312.4 ns/op Benchmark____RoutedPubSub_0b-16 11315448 311.7 ns/op Benchmark____RoutedPubSub_0b-16 11469097 310.6 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6629686 548.4 ns/op Benchmark____RoutedPubSub_1K-16 6726927 540.0 ns/op Benchmark____RoutedPubSub_1K-16 6535915 541.7 ns/op Benchmark____RoutedPubSub_1K-16 6588025 540.2 ns/op Benchmark____RoutedPubSub_1K-16 6893624 971.0 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85302 42040 ns/op Benchmark__RoutedPubSub_100K-16 85610 42420 ns/op Benchmark__RoutedPubSub_100K-16 83025 42554 ns/op Benchmark__RoutedPubSub_100K-16 84129 42500 ns/op Benchmark__RoutedPubSub_100K-16 77136 43364 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9658616 320.3 ns/op Benchmark____Routed2QueueSub-16 9361551 329.2 ns/op Benchmark____Routed2QueueSub-16 9754098 320.7 ns/op Benchmark____Routed2QueueSub-16 9782280 318.0 ns/op Benchmark____Routed2QueueSub-16 9542989 325.0 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9740434 320.7 ns/op Benchmark____Routed4QueueSub-16 9541576 324.9 ns/op Benchmark____Routed4QueueSub-16 9689946 322.8 ns/op Benchmark____Routed4QueueSub-16 9543861 320.5 ns/op Benchmark____Routed4QueueSub-16 9441709 326.1 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9298938 334.5 ns/op Benchmark____Routed8QueueSub-16 9502364 332.4 ns/op Benchmark____Routed8QueueSub-16 9339640 330.3 ns/op Benchmark____Routed8QueueSub-16 9106618 332.3 ns/op Benchmark____Routed8QueueSub-16 9276642 329.8 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8677093 346.7 ns/op Benchmark___Routed16QueueSub-16 9003976 352.7 ns/op Benchmark___Routed16QueueSub-16 10347344 349.1 ns/op Benchmark___Routed16QueueSub-16 8713947 354.3 ns/op Benchmark___Routed16QueueSub-16 8910392 353.9 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6467490 545.8 ns/op Benchmark____________RouteCompressOff-16 6223148 548.0 ns/op Benchmark____________RouteCompressOff-16 6456030 544.0 ns/op Benchmark____________RouteCompressOff-16 6572209 546.7 ns/op Benchmark____________RouteCompressOff-16 6290295 548.4 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6537543 545.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6600446 551.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6430519 558.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6511378 542.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6485496 550.1 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6617559 542.6 ns/op Benchmark_________RouteCompressS2Fast-16 6318079 542.1 ns/op Benchmark_________RouteCompressS2Fast-16 6336084 549.5 ns/op Benchmark_________RouteCompressS2Fast-16 6432793 487.6 ns/op Benchmark_________RouteCompressS2Fast-16 6519974 544.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6461737 551.0 ns/op Benchmark_______RouteCompressS2Better-16 6484195 549.7 ns/op Benchmark_______RouteCompressS2Better-16 6432027 550.0 ns/op Benchmark_______RouteCompressS2Better-16 6262149 543.9 ns/op Benchmark_______RouteCompressS2Better-16 6442638 547.5 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6359924 492.5 ns/op Benchmark_________RouteCompressS2Best-16 6525901 549.1 ns/op Benchmark_________RouteCompressS2Best-16 6572547 547.9 ns/op Benchmark_________RouteCompressS2Best-16 6285006 549.5 ns/op Benchmark_________RouteCompressS2Best-16 6593851 550.5 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4635080 769.8 ns/op 323.46 MB/s Benchmark______FanOut_8x1x10-16 4623271 776.0 ns/op 320.86 MB/s Benchmark______FanOut_8x1x10-16 4647451 770.7 ns/op 323.07 MB/s Benchmark______FanOut_8x1x10-16 4681436 776.9 ns/op 320.50 MB/s Benchmark______FanOut_8x1x10-16 4629139 768.0 ns/op 324.23 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 525404 6082 ns/op 381.26 MB/s Benchmark_____FanOut_8x1x100-16 539487 6041 ns/op 383.88 MB/s Benchmark_____FanOut_8x1x100-16 535334 6081 ns/op 381.35 MB/s Benchmark_____FanOut_8x1x100-16 549229 6225 ns/op 372.54 MB/s Benchmark_____FanOut_8x1x100-16 556486 6143 ns/op 377.49 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47911 74957 ns/op 307.09 MB/s Benchmark____FanOut_8x10x100-16 48285 74433 ns/op 309.26 MB/s Benchmark____FanOut_8x10x100-16 47762 74212 ns/op 310.18 MB/s Benchmark____FanOut_8x10x100-16 47158 74340 ns/op 309.64 MB/s Benchmark____FanOut_8x10x100-16 48110 74687 ns/op 308.20 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5696 595907 ns/op 402.78 MB/s Benchmark___FanOut_8x10x1000-16 5858 602480 ns/op 398.39 MB/s Benchmark___FanOut_8x10x1000-16 5992 594728 ns/op 403.58 MB/s Benchmark___FanOut_8x10x1000-16 5948 608888 ns/op 394.19 MB/s Benchmark___FanOut_8x10x1000-16 5803 602248 ns/op 398.54 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5019 704039 ns/op 326.71 MB/s Benchmark___FanOut_8x100x100-16 4972 704544 ns/op 326.48 MB/s Benchmark___FanOut_8x100x100-16 4874 703878 ns/op 326.79 MB/s Benchmark___FanOut_8x100x100-16 4928 706303 ns/op 325.67 MB/s Benchmark___FanOut_8x100x100-16 5106 703700 ns/op 326.87 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 583 6088251 ns/op 394.21 MB/s Benchmark__FanOut_8x100x1000-16 564 6106332 ns/op 393.04 MB/s Benchmark__FanOut_8x100x1000-16 570 6164271 ns/op 389.34 MB/s Benchmark__FanOut_8x100x1000-16 573 6134153 ns/op 391.26 MB/s Benchmark__FanOut_8x100x1000-16 567 6469837 ns/op 370.96 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 520 6732318 ns/op 371.35 MB/s Benchmark__FanOut_8x10x10000-16 534 6727592 ns/op 371.61 MB/s Benchmark__FanOut_8x10x10000-16 532 6721491 ns/op 371.94 MB/s Benchmark__FanOut_8x10x10000-16 532 6661280 ns/op 375.31 MB/s Benchmark__FanOut_8x10x10000-16 538 6667877 ns/op 374.93 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 949 3755745 ns/op 306.20 MB/s Benchmark___FanOut_8x500x100-16 940 3786235 ns/op 303.74 MB/s Benchmark___FanOut_8x500x100-16 952 3746855 ns/op 306.93 MB/s Benchmark___FanOut_8x500x100-16 952 3744913 ns/op 307.09 MB/s Benchmark___FanOut_8x500x100-16 956 3794070 ns/op 303.11 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 362930 9418 ns/op 1554.66 MB/s Benchmark___FanOut_128x1x100-16 363464 9416 ns/op 1554.83 MB/s Benchmark___FanOut_128x1x100-16 363694 9534 ns/op 1535.72 MB/s Benchmark___FanOut_128x1x100-16 374967 9497 ns/op 1541.70 MB/s Benchmark___FanOut_128x1x100-16 361260 9419 ns/op 1554.44 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32769 110206 ns/op 1317.00 MB/s Benchmark__FanOut_128x10x100-16 32575 110011 ns/op 1319.34 MB/s Benchmark__FanOut_128x10x100-16 32804 109702 ns/op 1323.05 MB/s Benchmark__FanOut_128x10x100-16 32739 110157 ns/op 1317.59 MB/s Benchmark__FanOut_128x10x100-16 32751 109562 ns/op 1324.74 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3951 866976 ns/op 1684.18 MB/s Benchmark_FanOut_128x10x1000-16 4062 861626 ns/op 1694.63 MB/s Benchmark_FanOut_128x10x1000-16 4069 864808 ns/op 1688.40 MB/s Benchmark_FanOut_128x10x1000-16 4125 868398 ns/op 1681.42 MB/s Benchmark_FanOut_128x10x1000-16 4075 870820 ns/op 1676.74 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3553 1004718 ns/op 1443.33 MB/s Benchmark_FanOut_128x100x100-16 3488 1010458 ns/op 1435.13 MB/s Benchmark_FanOut_128x100x100-16 3529 1002019 ns/op 1447.22 MB/s Benchmark_FanOut_128x100x100-16 3541 1002768 ns/op 1446.14 MB/s Benchmark_FanOut_128x100x100-16 3500 1003181 ns/op 1445.54 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 396 9171648 ns/op 1591.88 MB/s BenchmarkFanOut_128x100x1000-16 381 9337521 ns/op 1563.60 MB/s BenchmarkFanOut_128x100x1000-16 390 9171909 ns/op 1591.83 MB/s BenchmarkFanOut_128x100x1000-16 387 9344556 ns/op 1562.42 MB/s BenchmarkFanOut_128x100x1000-16 384 9205835 ns/op 1585.97 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 378 9557155 ns/op 1538.13 MB/s BenchmarkFanOut_128x10x10000-16 378 9549476 ns/op 1539.37 MB/s BenchmarkFanOut_128x10x10000-16 372 9510842 ns/op 1545.62 MB/s BenchmarkFanOut_128x10x10000-16 370 9506088 ns/op 1546.39 MB/s BenchmarkFanOut_128x10x10000-16 373 9538330 ns/op 1541.17 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 666 5265803 ns/op 1376.83 MB/s BenchmarkFanOut__128x500x100-16 676 5252974 ns/op 1380.20 MB/s BenchmarkFanOut__128x500x100-16 685 5261032 ns/op 1378.08 MB/s BenchmarkFanOut__128x500x100-16 666 5262178 ns/op 1377.78 MB/s BenchmarkFanOut__128x500x100-16 678 5261589 ns/op 1377.94 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1938 1837703 ns/op 2878.88 MB/s Benchmark_FanOut_512x100x100-16 1902 1824214 ns/op 2900.17 MB/s Benchmark_FanOut_512x100x100-16 1948 1825583 ns/op 2897.99 MB/s Benchmark_FanOut_512x100x100-16 1969 1840559 ns/op 2874.41 MB/s Benchmark_FanOut_512x100x100-16 1941 1836519 ns/op 2880.74 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 217 16623076 ns/op 3188.37 MB/s Benchmark__FanOut_512x100x1k-16 217 16475662 ns/op 3216.90 MB/s Benchmark__FanOut_512x100x1k-16 217 16442850 ns/op 3223.32 MB/s Benchmark__FanOut_512x100x1k-16 217 16495705 ns/op 3212.99 MB/s Benchmark__FanOut_512x100x1k-16 216 16475871 ns/op 3216.86 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3079 1123618 ns/op 9283.44 MB/s Benchmark____FanOut_1kx10x1k-16 2916 1151327 ns/op 9060.02 MB/s Benchmark____FanOut_1kx10x1k-16 3201 1164947 ns/op 8954.09 MB/s Benchmark____FanOut_1kx10x1k-16 3304 1160891 ns/op 8985.38 MB/s Benchmark____FanOut_1kx10x1k-16 3151 1171501 ns/op 8904.00 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2733 1253861 ns/op 8311.16 MB/s Benchmark__FanOut_1kx100x100-16 2800 1246694 ns/op 8358.94 MB/s Benchmark__FanOut_1kx100x100-16 2798 1249143 ns/op 8342.55 MB/s Benchmark__FanOut_1kx100x100-16 2776 1252081 ns/op 8322.98 MB/s Benchmark__FanOut_1kx100x100-16 2812 1247355 ns/op 8354.51 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4555894 785.1 ns/op 317.14 MB/s Benchmark_____RFanOut_8x1x10-16 4370098 763.7 ns/op 326.06 MB/s Benchmark_____RFanOut_8x1x10-16 4554777 788.4 ns/op 315.85 MB/s Benchmark_____RFanOut_8x1x10-16 4481780 792.7 ns/op 314.11 MB/s Benchmark_____RFanOut_8x1x10-16 4330759 765.6 ns/op 325.26 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 543612 6033 ns/op 384.38 MB/s Benchmark____RFanOut_8x1x100-16 505939 6076 ns/op 381.64 MB/s Benchmark____RFanOut_8x1x100-16 527763 6114 ns/op 379.29 MB/s Benchmark____RFanOut_8x1x100-16 543456 6322 ns/op 366.82 MB/s Benchmark____RFanOut_8x1x100-16 508321 6445 ns/op 359.80 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47820 74952 ns/op 307.11 MB/s Benchmark___RFanOut_8x10x100-16 47880 74577 ns/op 308.66 MB/s Benchmark___RFanOut_8x10x100-16 47821 74689 ns/op 308.20 MB/s Benchmark___RFanOut_8x10x100-16 48334 74698 ns/op 308.16 MB/s Benchmark___RFanOut_8x10x100-16 48021 75300 ns/op 305.70 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5792 601975 ns/op 398.72 MB/s Benchmark__RFanOut_8x10x1000-16 5683 599688 ns/op 400.24 MB/s Benchmark__RFanOut_8x10x1000-16 5832 600569 ns/op 399.65 MB/s Benchmark__RFanOut_8x10x1000-16 6034 594407 ns/op 403.80 MB/s Benchmark__RFanOut_8x10x1000-16 5968 595940 ns/op 402.76 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5001 704588 ns/op 326.46 MB/s Benchmark__RFanOut_8x100x100-16 5031 703681 ns/op 326.88 MB/s Benchmark__RFanOut_8x100x100-16 5052 704421 ns/op 326.54 MB/s Benchmark__RFanOut_8x100x100-16 4957 715149 ns/op 321.64 MB/s Benchmark__RFanOut_8x100x100-16 4972 706990 ns/op 325.35 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 571 6146466 ns/op 390.47 MB/s Benchmark_RFanOut_8x100x1000-16 567 6183153 ns/op 388.15 MB/s Benchmark_RFanOut_8x100x1000-16 556 6144692 ns/op 390.58 MB/s Benchmark_RFanOut_8x100x1000-16 567 6143328 ns/op 390.67 MB/s Benchmark_RFanOut_8x100x1000-16 560 6178578 ns/op 388.44 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 531 6753605 ns/op 370.18 MB/s Benchmark_RFanOut_8x10x10000-16 532 6759215 ns/op 369.87 MB/s Benchmark_RFanOut_8x10x10000-16 536 6726055 ns/op 371.69 MB/s Benchmark_RFanOut_8x10x10000-16 524 6726442 ns/op 371.67 MB/s Benchmark_RFanOut_8x10x10000-16 532 6759022 ns/op 369.88 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2958 1137106 ns/op 9173.32 MB/s Benchmark_RFanOut_1kx10x1000-16 2931 1150230 ns/op 9068.65 MB/s Benchmark_RFanOut_1kx10x1000-16 3178 1144475 ns/op 9114.26 MB/s Benchmark_RFanOut_1kx10x1000-16 3256 1159246 ns/op 8998.12 MB/s Benchmark_RFanOut_1kx10x1000-16 3170 1144391 ns/op 9114.93 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7009311 501.2 ns/op 4146.01 MB/s Benchmark_____FanIn_1kx100x1-16 6972583 501.2 ns/op 4145.73 MB/s Benchmark_____FanIn_1kx100x1-16 6995977 502.4 ns/op 4135.89 MB/s Benchmark_____FanIn_1kx100x1-16 6942024 503.9 ns/op 4123.96 MB/s Benchmark_____FanIn_1kx100x1-16 7025709 502.4 ns/op 4135.93 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2651671 1357 ns/op 6057.60 MB/s Benchmark_____FanIn_4kx100x1-16 2655458 1372 ns/op 5993.64 MB/s Benchmark_____FanIn_4kx100x1-16 2611332 1348 ns/op 6101.16 MB/s Benchmark_____FanIn_4kx100x1-16 2587844 1366 ns/op 6019.58 MB/s Benchmark_____FanIn_4kx100x1-16 2636596 1343 ns/op 6120.54 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1711485 2095 ns/op 7833.42 MB/s Benchmark_____FanIn_8kx100x1-16 1675448 2090 ns/op 7851.91 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 80454816 vs 8208000000 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:54218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53534->127.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:53928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54408->127.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:53912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53664->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53658->127.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: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:54176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54370->127.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:53884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54258->127.0.0.1:5222: write: broken pipe --- FAIL: Benchmark_____FanIn_8kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54430->127.0.0.1:5222: write: connection reset by peer Benchmark_____FanIn_8kx100x1-16 1679368 2093 ns/op 7843.80 MB/s Benchmark_____FanIn_8kx100x1-16 1726369 2097 ns/op 7825.64 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 865348 4137 ns/op 7927.52 MB/s Benchmark____FanIn_16kx100x1-16 854770 4212 ns/op 7786.82 MB/s Benchmark____FanIn_16kx100x1-16 861546 4168 ns/op 7869.94 MB/s Benchmark____FanIn_16kx100x1-16 874440 4191 ns/op 7826.06 MB/s Benchmark____FanIn_16kx100x1-16 873478 4188 ns/op 7831.56 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 168958 20003 ns/op 6554.28 MB/s Benchmark____FanIn_64kx100x1-16 154798 19847 ns/op 6605.78 MB/s Benchmark____FanIn_64kx100x1-16 171961 19662 ns/op 6667.76 MB/s Benchmark____FanIn_64kx100x1-16 164865 19900 ns/op 6588.23 MB/s Benchmark____FanIn_64kx100x1-16 169627 19767 ns/op 6632.45 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 520034030 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37340->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:37194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37034->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: 1063926440 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39566->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: 800566630 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40838->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: 200960970 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42802->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42910->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:43010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42624->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: 425255960 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50646->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5551909 641.8 ns/op 442.50 MB/s Benchmark___BumpPubCount_1x3-16 5593195 640.4 ns/op 443.44 MB/s Benchmark___BumpPubCount_1x3-16 5579414 641.6 ns/op 442.62 MB/s Benchmark___BumpPubCount_1x3-16 5597094 644.7 ns/op 440.48 MB/s Benchmark___BumpPubCount_1x3-16 5604157 640.8 ns/op 443.21 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5335750 669.3 ns/op 424.30 MB/s Benchmark___BumpPubCount_2x3-16 5348247 676.3 ns/op 419.93 MB/s Benchmark___BumpPubCount_2x3-16 5364796 671.2 ns/op 423.12 MB/s Benchmark___BumpPubCount_2x3-16 5312104 668.5 ns/op 424.81 MB/s Benchmark___BumpPubCount_2x3-16 5323909 670.2 ns/op 423.73 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5559165 646.1 ns/op 439.54 MB/s Benchmark___BumpPubCount_5x3-16 5598372 646.6 ns/op 439.25 MB/s Benchmark___BumpPubCount_5x3-16 5591688 638.6 ns/op 444.75 MB/s Benchmark___BumpPubCount_5x3-16 5610282 639.5 ns/op 444.09 MB/s Benchmark___BumpPubCount_5x3-16 5532258 638.1 ns/op 445.11 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5522484 637.9 ns/op 445.18 MB/s Benchmark__BumpPubCount_10x3-16 5584656 640.5 ns/op 443.40 MB/s Benchmark__BumpPubCount_10x3-16 5606313 639.4 ns/op 444.20 MB/s Benchmark__BumpPubCount_10x3-16 5612800 642.8 ns/op 441.81 MB/s Benchmark__BumpPubCount_10x3-16 5594762 641.2 ns/op 442.90 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11612800 270.2 ns/op 3848.82 MB/s Benchmark____GWs_Opt_1kx01x0-16 13064430 271.6 ns/op 3829.36 MB/s Benchmark____GWs_Opt_1kx01x0-16 12796761 282.2 ns/op 3685.56 MB/s Benchmark____GWs_Opt_1kx01x0-16 10756693 286.2 ns/op 3633.81 MB/s Benchmark____GWs_Opt_1kx01x0-16 12487652 273.0 ns/op 3809.02 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10040628 343.9 ns/op 6001.21 MB/s Benchmark____GWs_Opt_2kx01x0-16 11284146 338.1 ns/op 6104.13 MB/s Benchmark____GWs_Opt_2kx01x0-16 10944670 338.5 ns/op 6097.52 MB/s Benchmark____GWs_Opt_2kx01x0-16 9179478 328.8 ns/op 6276.67 MB/s Benchmark____GWs_Opt_2kx01x0-16 10659243 322.5 ns/op 6400.11 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5778981 618.6 ns/op 6647.03 MB/s Benchmark____GWs_Opt_4kx01x0-16 5994652 612.6 ns/op 6712.35 MB/s Benchmark____GWs_Opt_4kx01x0-16 5841421 625.7 ns/op 6571.66 MB/s Benchmark____GWs_Opt_4kx01x0-16 5603563 668.1 ns/op 6155.12 MB/s Benchmark____GWs_Opt_4kx01x0-16 5346636 674.6 ns/op 6095.10 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28547120 115.8 ns/op 8979.82 MB/s Benchmark____GWs_Opt_1kx10x0-16 30863881 117.8 ns/op 8827.55 MB/s Benchmark____GWs_Opt_1kx10x0-16 29735604 113.4 ns/op 9167.32 MB/s Benchmark____GWs_Opt_1kx10x0-16 25939864 125.5 ns/op 8283.85 MB/s Benchmark____GWs_Opt_1kx10x0-16 29097964 114.5 ns/op 9080.66 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 21785370 146.8 ns/op 14064.14 MB/s Benchmark____GWs_Opt_2kx10x0-16 19820336 153.9 ns/op 13413.03 MB/s Benchmark____GWs_Opt_2kx10x0-16 25609950 159.6 ns/op 12935.12 MB/s Benchmark____GWs_Opt_2kx10x0-16 26042638 155.6 ns/op 13266.22 MB/s Benchmark____GWs_Opt_2kx10x0-16 25114166 145.7 ns/op 14162.63 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 9453316 338.5 ns/op 12148.06 MB/s Benchmark____GWs_Opt_4kx10x0-16 11921996 341.8 ns/op 12032.04 MB/s Benchmark____GWs_Opt_4kx10x0-16 12812872 306.4 ns/op 13419.40 MB/s Benchmark____GWs_Opt_4kx10x0-16 13024670 309.0 ns/op 13307.21 MB/s Benchmark____GWs_Opt_4kx10x0-16 12698270 304.8 ns/op 13492.65 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6612469 548.7 ns/op 5695.12 MB/s Benchmark____GWs_Opt_1kx01x1-16 6484245 543.3 ns/op 5752.32 MB/s Benchmark____GWs_Opt_1kx01x1-16 6483985 538.1 ns/op 5807.82 MB/s Benchmark____GWs_Opt_1kx01x1-16 6419229 542.2 ns/op 5763.99 MB/s Benchmark____GWs_Opt_1kx01x1-16 6402906 549.4 ns/op 5688.53 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4700740 754.0 ns/op 8218.50 MB/s Benchmark____GWs_Opt_2kx01x1-16 4802182 744.3 ns/op 8326.48 MB/s Benchmark____GWs_Opt_2kx01x1-16 4760068 772.1 ns/op 8025.71 MB/s Benchmark____GWs_Opt_2kx01x1-16 4793113 755.5 ns/op 8202.07 MB/s Benchmark____GWs_Opt_2kx01x1-16 4667082 761.2 ns/op 8140.74 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2672754 1354 ns/op 9115.97 MB/s Benchmark____GWs_Opt_4kx01x1-16 2400082 1352 ns/op 9130.07 MB/s Benchmark____GWs_Opt_4kx01x1-16 2638584 1370 ns/op 9010.73 MB/s Benchmark____GWs_Opt_4kx01x1-16 2524994 1357 ns/op 9092.71 MB/s Benchmark____GWs_Opt_4kx01x1-16 2632346 1358 ns/op 9084.65 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6103729 593.9 ns/op 5262.10 MB/s Benchmark____GWs_Opt_1kx10x1-16 6402350 547.9 ns/op 5704.06 MB/s Benchmark____GWs_Opt_1kx10x1-16 6290563 552.2 ns/op 5659.03 MB/s Benchmark____GWs_Opt_1kx10x1-16 6431013 550.5 ns/op 5676.92 MB/s Benchmark____GWs_Opt_1kx10x1-16 6637402 541.4 ns/op 5772.40 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4194066 832.5 ns/op 7443.84 MB/s Benchmark____GWs_Opt_2kx10x1-16 4094305 847.0 ns/op 7316.84 MB/s Benchmark____GWs_Opt_2kx10x1-16 4100757 870.8 ns/op 7116.22 MB/s Benchmark____GWs_Opt_2kx10x1-16 4425169 836.2 ns/op 7410.80 MB/s Benchmark____GWs_Opt_2kx10x1-16 4133672 839.8 ns/op 7379.42 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2347134 1471 ns/op 8389.95 MB/s Benchmark____GWs_Opt_4kx10x1-16 2470428 1503 ns/op 8210.59 MB/s Benchmark____GWs_Opt_4kx10x1-16 2493508 1503 ns/op 8209.92 MB/s Benchmark____GWs_Opt_4kx10x1-16 2309216 1501 ns/op 8221.45 MB/s Benchmark____GWs_Opt_4kx10x1-16 2361871 1454 ns/op 8487.26 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12838543 281.9 ns/op 3689.63 MB/s Benchmark____GWs_Int_1kx01x0-16 12563685 292.7 ns/op 3552.80 MB/s Benchmark____GWs_Int_1kx01x0-16 12711010 277.2 ns/op 3752.35 MB/s Benchmark____GWs_Int_1kx01x0-16 12145708 285.8 ns/op 3638.59 MB/s Benchmark____GWs_Int_1kx01x0-16 12631778 285.7 ns/op 3640.77 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10408950 351.2 ns/op 5877.62 MB/s Benchmark____GWs_Int_2kx01x0-16 10146674 336.4 ns/op 6134.79 MB/s Benchmark____GWs_Int_2kx01x0-16 9922664 378.1 ns/op 5458.92 MB/s Benchmark____GWs_Int_2kx01x0-16 9668898 343.8 ns/op 6004.18 MB/s Benchmark____GWs_Int_2kx01x0-16 10757361 342.7 ns/op 6022.93 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5902986 632.5 ns/op 6501.03 MB/s Benchmark____GWs_Int_4kx01x0-16 5864396 632.3 ns/op 6502.93 MB/s Benchmark____GWs_Int_4kx01x0-16 5783120 641.6 ns/op 6408.69 MB/s Benchmark____GWs_Int_4kx01x0-16 5787102 617.6 ns/op 6658.46 MB/s Benchmark____GWs_Int_4kx01x0-16 5608610 636.6 ns/op 6459.14 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31090462 110.9 ns/op 9380.25 MB/s Benchmark____GWs_Int_1kx10x0-16 31102740 124.6 ns/op 8348.59 MB/s Benchmark____GWs_Int_1kx10x0-16 31982044 116.6 ns/op 8920.96 MB/s Benchmark____GWs_Int_1kx10x0-16 32589708 111.7 ns/op 9310.40 MB/s Benchmark____GWs_Int_1kx10x0-16 31433454 122.0 ns/op 8527.41 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 22661116 141.5 ns/op 14583.88 MB/s Benchmark____GWs_Int_2kx10x0-16 25590055 139.4 ns/op 14806.97 MB/s Benchmark____GWs_Int_2kx10x0-16 20684175 146.2 ns/op 14122.32 MB/s Benchmark____GWs_Int_2kx10x0-16 26025609 148.3 ns/op 13915.46 MB/s Benchmark____GWs_Int_2kx10x0-16 24929553 147.7 ns/op 13969.68 MB/s Benchmark____GWs_Int_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:43056->127.0.0.1:33975: 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:54810->127.0.0.1:39217: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 13177718 297.6 ns/op 13815.61 MB/s Benchmark____GWs_Int_4kx10x0-16 13268302 309.7 ns/op 13278.68 MB/s Benchmark____GWs_Int_4kx10x0-16 9763686 327.4 ns/op 12560.06 MB/s Benchmark____GWs_Int_4kx10x0-16 13228328 329.4 ns/op 12481.55 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6553123 545.6 ns/op 5727.49 MB/s Benchmark____GWs_Int_1kx01x1-16 6750744 557.2 ns/op 5608.29 MB/s Benchmark____GWs_Int_1kx01x1-16 6640765 578.1 ns/op 5405.77 MB/s Benchmark____GWs_Int_1kx01x1-16 6564494 561.4 ns/op 5566.21 MB/s Benchmark____GWs_Int_1kx01x1-16 6554740 563.7 ns/op 5543.80 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4676494 762.3 ns/op 8129.22 MB/s Benchmark____GWs_Int_2kx01x1-16 4716640 758.3 ns/op 8171.71 MB/s Benchmark____GWs_Int_2kx01x1-16 4152024 759.0 ns/op 8164.83 MB/s Benchmark____GWs_Int_2kx01x1-16 4638760 763.3 ns/op 8118.19 MB/s Benchmark____GWs_Int_2kx01x1-16 4772048 757.2 ns/op 8184.61 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2664044 1449 ns/op 8518.48 MB/s Benchmark____GWs_Int_4kx01x1-16 2252497 1486 ns/op 8307.27 MB/s Benchmark____GWs_Int_4kx01x1-16 2610591 1364 ns/op 9045.39 MB/s Benchmark____GWs_Int_4kx01x1-16 2620146 1380 ns/op 8942.35 MB/s Benchmark____GWs_Int_4kx01x1-16 2624149 1436 ns/op 8591.97 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6553735 550.1 ns/op 5680.39 MB/s Benchmark____GWs_Int_1kx10x1-16 6262849 559.6 ns/op 5584.70 MB/s Benchmark____GWs_Int_1kx10x1-16 6474882 561.1 ns/op 5569.06 MB/s Benchmark____GWs_Int_1kx10x1-16 6575670 554.1 ns/op 5639.68 MB/s Benchmark____GWs_Int_1kx10x1-16 6501226 555.5 ns/op 5625.25 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4283918 865.1 ns/op 7163.35 MB/s Benchmark____GWs_Int_2kx10x1-16 4215088 829.1 ns/op 7474.73 MB/s Benchmark____GWs_Int_2kx10x1-16 4180460 840.7 ns/op 7371.29 MB/s Benchmark____GWs_Int_2kx10x1-16 4272597 843.3 ns/op 7348.60 MB/s Benchmark____GWs_Int_2kx10x1-16 4234220 849.3 ns/op 7296.48 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2425917 1522 ns/op 8110.61 MB/s Benchmark____GWs_Int_4kx10x1-16 2278674 1648 ns/op 7488.64 MB/s Benchmark____GWs_Int_4kx10x1-16 2238717 1509 ns/op 8175.94 MB/s Benchmark____GWs_Int_4kx10x1-16 2366059 1648 ns/op 7486.83 MB/s Benchmark____GWs_Int_4kx10x1-16 2338965 1517 ns/op 8137.07 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8045856 437.8 ns/op 232.96 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7923690 427.5 ns/op 238.62 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8089926 427.3 ns/op 238.73 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8075540 434.5 ns/op 234.76 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8200113 430.3 ns/op 237.02 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 712183 5118 ns/op 34.58 MB/s Benchmark__GWs_Reqs_1SubEach-16 747484 5270 ns/op 33.59 MB/s Benchmark__GWs_Reqs_1SubEach-16 755494 5229 ns/op 33.85 MB/s Benchmark__GWs_Reqs_1SubEach-16 752774 5274 ns/op 33.56 MB/s Benchmark__GWs_Reqs_1SubEach-16 740958 5286 ns/op 33.48 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2086.060s ❌ Non-zero exit code: 1