> ROOT_DIR=/tmp/go-bench-away-job-ad3e9098-5523-40b8-b468-94e1fc5a30c5-772089846 > OUTPUT_FILE=/tmp/go-bench-away-job-ad3e9098-5523-40b8-b468-94e1fc5a30c5-772089846/results.txt > SHA_FILE=/tmp/go-bench-away-job-ad3e9098-5523-40b8-b468-94e1fc5a30c5-772089846/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-ad3e9098-5523-40b8-b468-94e1fc5a30c5-772089846/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-ad3e9098-5523-40b8-b468-94e1fc5a30c5-772089846/source.git SHA of main: 5e645df4c0ce2a0b4e0c985f6a51a34cd4f53367 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-build3812552739=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-ad3e9098-5523-40b8-b468-94e1fc5a30c5-772089846/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 49335123 72.52 ns/op 151.68 MB/s Benchmark______Pub0b_Payload-16 42845634 72.76 ns/op 151.19 MB/s Benchmark______Pub0b_Payload-16 46833046 72.89 ns/op 150.91 MB/s Benchmark______Pub0b_Payload-16 45101316 72.79 ns/op 151.11 MB/s Benchmark______Pub0b_Payload-16 47010067 72.69 ns/op 151.33 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 44015400 73.41 ns/op 258.80 MB/s Benchmark______Pub8b_Payload-16 46444192 73.58 ns/op 258.21 MB/s Benchmark______Pub8b_Payload-16 43212952 73.10 ns/op 259.92 MB/s Benchmark______Pub8b_Payload-16 46210089 76.56 ns/op 248.16 MB/s Benchmark______Pub8b_Payload-16 46406942 73.62 ns/op 258.09 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43525646 78.11 ns/op 563.29 MB/s Benchmark_____Pub32b_Payload-16 43142527 77.81 ns/op 565.49 MB/s Benchmark_____Pub32b_Payload-16 42815296 77.95 ns/op 564.48 MB/s Benchmark_____Pub32b_Payload-16 43007544 77.82 ns/op 565.37 MB/s Benchmark_____Pub32b_Payload-16 43484883 77.86 ns/op 565.11 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38351389 87.73 ns/op 1607.15 MB/s Benchmark____Pub128B_Payload-16 39215636 88.08 ns/op 1600.74 MB/s Benchmark____Pub128B_Payload-16 38409036 88.86 ns/op 1586.73 MB/s Benchmark____Pub128B_Payload-16 39250975 88.15 ns/op 1599.61 MB/s Benchmark____Pub128B_Payload-16 34476699 87.55 ns/op 1610.43 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 31509254 104.4 ns/op 2576.22 MB/s Benchmark____Pub256B_Payload-16 36042537 97.50 ns/op 2758.89 MB/s Benchmark____Pub256B_Payload-16 35969593 95.51 ns/op 2816.32 MB/s Benchmark____Pub256B_Payload-16 35723287 97.22 ns/op 2767.04 MB/s Benchmark____Pub256B_Payload-16 35560138 96.28 ns/op 2794.06 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24100471 143.5 ns/op 7232.43 MB/s Benchmark______Pub1K_Payload-16 23978253 143.5 ns/op 7231.72 MB/s Benchmark______Pub1K_Payload-16 24480682 146.0 ns/op 7109.58 MB/s Benchmark______Pub1K_Payload-16 23680873 135.4 ns/op 7666.80 MB/s Benchmark______Pub1K_Payload-16 25777737 144.4 ns/op 7189.11 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5724808 624.4 ns/op 6582.60 MB/s Benchmark______Pub4K_Payload-16 5465485 632.8 ns/op 6494.61 MB/s Benchmark______Pub4K_Payload-16 5813674 611.6 ns/op 6719.88 MB/s Benchmark______Pub4K_Payload-16 5427777 625.8 ns/op 6568.09 MB/s Benchmark______Pub4K_Payload-16 5396319 625.2 ns/op 6574.00 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2735848 1288 ns/op 6370.27 MB/s Benchmark______Pub8K_Payload-16 2708226 1288 ns/op 6370.74 MB/s Benchmark______Pub8K_Payload-16 2721222 1277 ns/op 6425.29 MB/s Benchmark______Pub8K_Payload-16 2746351 1271 ns/op 6455.76 MB/s Benchmark______Pub8K_Payload-16 2655849 1286 ns/op 6379.71 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 655178 5536 ns/op 5922.23 MB/s Benchmark_____Pub32K_Payload-16 622042 5371 ns/op 6104.06 MB/s Benchmark_____Pub32K_Payload-16 653145 5533 ns/op 5924.62 MB/s Benchmark_____Pub32K_Payload-16 666746 5509 ns/op 5950.29 MB/s Benchmark_____Pub32K_Payload-16 649422 7034 ns/op 4660.80 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32020813 95.85 ns/op 114.76 MB/s Benchmark__AuthPub0b_Payload-16 36003165 94.60 ns/op 116.28 MB/s Benchmark__AuthPub0b_Payload-16 36062264 94.43 ns/op 116.48 MB/s Benchmark__AuthPub0b_Payload-16 35769672 94.55 ns/op 116.34 MB/s Benchmark__AuthPub0b_Payload-16 36086516 94.40 ns/op 116.52 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15325246 228.0 ns/op Benchmark_____________PubSub-16 15480660 228.5 ns/op Benchmark_____________PubSub-16 15509704 228.0 ns/op Benchmark_____________PubSub-16 15543804 228.6 ns/op Benchmark_____________PubSub-16 15605791 228.9 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15479073 227.2 ns/op Benchmark_____PubSubTwoConns-16 15682580 227.4 ns/op Benchmark_____PubSubTwoConns-16 15684855 227.9 ns/op Benchmark_____PubSubTwoConns-16 15633562 227.8 ns/op Benchmark_____PubSubTwoConns-16 15653504 227.0 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43084->127.0.0.1:34331: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51540->127.0.0.1:34589: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43524->127.0.0.1:40831: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58514->127.0.0.1:35311: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:56294->127.0.0.1:42883: 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 14092297 249.3 ns/op Benchmark_____PubTwoQueueSub-16 14270695 249.9 ns/op Benchmark_____PubTwoQueueSub-16 14182644 249.5 ns/op Benchmark_____PubTwoQueueSub-16 14192011 250.3 ns/op Benchmark_____PubTwoQueueSub-16 14180845 249.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14132361 248.5 ns/op Benchmark____PubFourQueueSub-16 14083172 250.1 ns/op Benchmark____PubFourQueueSub-16 14065423 250.3 ns/op Benchmark____PubFourQueueSub-16 14335436 249.3 ns/op Benchmark____PubFourQueueSub-16 14267193 249.9 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14015216 250.5 ns/op Benchmark___PubEightQueueSub-16 14232368 251.3 ns/op Benchmark___PubEightQueueSub-16 14096088 249.8 ns/op Benchmark___PubEightQueueSub-16 14201367 249.8 ns/op Benchmark___PubEightQueueSub-16 14161638 250.1 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23209 154560 ns/op Benchmark_PubSub512kTwoConns-16 23372 154706 ns/op Benchmark_PubSub512kTwoConns-16 22880 157060 ns/op Benchmark_PubSub512kTwoConns-16 23076 155136 ns/op Benchmark_PubSub512kTwoConns-16 22800 156656 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14925614 232.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15125503 231.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15081540 232.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15030702 231.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 14883076 231.7 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14992432 232.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15003709 232.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15267352 231.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15150525 231.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15125092 231.6 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11403961 311.0 ns/op Benchmark____RoutedPubSub_0b-16 11255197 313.2 ns/op Benchmark____RoutedPubSub_0b-16 11277499 311.7 ns/op Benchmark____RoutedPubSub_0b-16 11319997 311.1 ns/op Benchmark____RoutedPubSub_0b-16 11184049 315.7 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6589068 543.6 ns/op Benchmark____RoutedPubSub_1K-16 6636044 530.4 ns/op Benchmark____RoutedPubSub_1K-16 6777774 535.3 ns/op Benchmark____RoutedPubSub_1K-16 6548961 531.3 ns/op Benchmark____RoutedPubSub_1K-16 6787138 540.9 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 82855 40718 ns/op Benchmark__RoutedPubSub_100K-16 81453 42368 ns/op Benchmark__RoutedPubSub_100K-16 83890 42689 ns/op Benchmark__RoutedPubSub_100K-16 77078 46442 ns/op Benchmark__RoutedPubSub_100K-16 80502 45906 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9747092 324.8 ns/op Benchmark____Routed2QueueSub-16 9782817 318.7 ns/op Benchmark____Routed2QueueSub-16 9763784 320.7 ns/op Benchmark____Routed2QueueSub-16 9721267 326.3 ns/op Benchmark____Routed2QueueSub-16 9911518 326.7 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9357447 326.0 ns/op Benchmark____Routed4QueueSub-16 11331489 321.0 ns/op Benchmark____Routed4QueueSub-16 9705285 317.1 ns/op Benchmark____Routed4QueueSub-16 9638642 316.9 ns/op Benchmark____Routed4QueueSub-16 9442154 327.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9251775 328.7 ns/op Benchmark____Routed8QueueSub-16 9365497 333.2 ns/op Benchmark____Routed8QueueSub-16 9393793 328.4 ns/op Benchmark____Routed8QueueSub-16 10776340 332.7 ns/op Benchmark____Routed8QueueSub-16 9180141 331.2 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 10356290 346.6 ns/op Benchmark___Routed16QueueSub-16 8850506 356.2 ns/op Benchmark___Routed16QueueSub-16 8831312 346.6 ns/op Benchmark___Routed16QueueSub-16 10539991 342.6 ns/op Benchmark___Routed16QueueSub-16 8864368 343.3 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6517946 581.6 ns/op Benchmark____________RouteCompressOff-16 6441009 550.8 ns/op Benchmark____________RouteCompressOff-16 6569954 544.8 ns/op Benchmark____________RouteCompressOff-16 6444488 544.6 ns/op Benchmark____________RouteCompressOff-16 6551152 551.8 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6277748 544.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6335325 498.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6582271 544.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 7863652 545.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6388651 551.2 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6326623 543.4 ns/op Benchmark_________RouteCompressS2Fast-16 6589500 545.8 ns/op Benchmark_________RouteCompressS2Fast-16 6556342 546.8 ns/op Benchmark_________RouteCompressS2Fast-16 6500982 547.9 ns/op Benchmark_________RouteCompressS2Fast-16 6491227 549.4 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6461542 538.6 ns/op Benchmark_______RouteCompressS2Better-16 6452004 547.8 ns/op Benchmark_______RouteCompressS2Better-16 6526632 547.3 ns/op Benchmark_______RouteCompressS2Better-16 6535399 549.4 ns/op Benchmark_______RouteCompressS2Better-16 6349450 552.6 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6661527 545.2 ns/op Benchmark_________RouteCompressS2Best-16 6484579 550.4 ns/op Benchmark_________RouteCompressS2Best-16 6422930 543.3 ns/op Benchmark_________RouteCompressS2Best-16 6445219 550.2 ns/op Benchmark_________RouteCompressS2Best-16 6546082 521.4 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4697283 777.6 ns/op 320.20 MB/s Benchmark______FanOut_8x1x10-16 4650481 773.9 ns/op 321.76 MB/s Benchmark______FanOut_8x1x10-16 4682473 770.6 ns/op 323.14 MB/s Benchmark______FanOut_8x1x10-16 4662037 775.2 ns/op 321.20 MB/s Benchmark______FanOut_8x1x10-16 4681330 768.0 ns/op 324.20 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 556852 6102 ns/op 380.04 MB/s Benchmark_____FanOut_8x1x100-16 554437 6122 ns/op 378.83 MB/s Benchmark_____FanOut_8x1x100-16 543561 6043 ns/op 383.73 MB/s Benchmark_____FanOut_8x1x100-16 534086 6117 ns/op 379.08 MB/s Benchmark_____FanOut_8x1x100-16 549526 6097 ns/op 380.37 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47863 75505 ns/op 304.87 MB/s Benchmark____FanOut_8x10x100-16 48148 74685 ns/op 308.21 MB/s Benchmark____FanOut_8x10x100-16 48061 74330 ns/op 309.69 MB/s Benchmark____FanOut_8x10x100-16 47514 74341 ns/op 309.64 MB/s Benchmark____FanOut_8x10x100-16 47998 74573 ns/op 308.68 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6021 592641 ns/op 405.00 MB/s Benchmark___FanOut_8x10x1000-16 5901 598556 ns/op 401.00 MB/s Benchmark___FanOut_8x10x1000-16 6031 594233 ns/op 403.91 MB/s Benchmark___FanOut_8x10x1000-16 5942 597609 ns/op 401.63 MB/s Benchmark___FanOut_8x10x1000-16 5883 591082 ns/op 406.07 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5054 704993 ns/op 326.27 MB/s Benchmark___FanOut_8x100x100-16 4989 704009 ns/op 326.73 MB/s Benchmark___FanOut_8x100x100-16 4968 708384 ns/op 324.71 MB/s Benchmark___FanOut_8x100x100-16 5018 706365 ns/op 325.64 MB/s Benchmark___FanOut_8x100x100-16 4976 704008 ns/op 326.73 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 576 6271378 ns/op 382.69 MB/s Benchmark__FanOut_8x100x1000-16 568 6141896 ns/op 390.76 MB/s Benchmark__FanOut_8x100x1000-16 577 6095070 ns/op 393.76 MB/s Benchmark__FanOut_8x100x1000-16 565 6152483 ns/op 390.09 MB/s Benchmark__FanOut_8x100x1000-16 583 6157258 ns/op 389.79 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 544 6788896 ns/op 368.25 MB/s Benchmark__FanOut_8x10x10000-16 525 7141091 ns/op 350.09 MB/s Benchmark__FanOut_8x10x10000-16 540 6769735 ns/op 369.29 MB/s Benchmark__FanOut_8x10x10000-16 524 6648333 ns/op 376.04 MB/s Benchmark__FanOut_8x10x10000-16 544 6804347 ns/op 367.41 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 943 3752112 ns/op 306.50 MB/s Benchmark___FanOut_8x500x100-16 954 3747180 ns/op 306.90 MB/s Benchmark___FanOut_8x500x100-16 949 3743774 ns/op 307.18 MB/s Benchmark___FanOut_8x500x100-16 946 3754327 ns/op 306.32 MB/s Benchmark___FanOut_8x500x100-16 948 3752280 ns/op 306.49 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 354814 9391 ns/op 1558.97 MB/s Benchmark___FanOut_128x1x100-16 370396 9543 ns/op 1534.19 MB/s Benchmark___FanOut_128x1x100-16 363772 9411 ns/op 1555.74 MB/s Benchmark___FanOut_128x1x100-16 352494 9424 ns/op 1553.52 MB/s Benchmark___FanOut_128x1x100-16 374728 9462 ns/op 1547.29 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32522 110140 ns/op 1317.79 MB/s Benchmark__FanOut_128x10x100-16 32293 110418 ns/op 1314.47 MB/s Benchmark__FanOut_128x10x100-16 32535 110097 ns/op 1318.30 MB/s Benchmark__FanOut_128x10x100-16 32536 109852 ns/op 1321.24 MB/s Benchmark__FanOut_128x10x100-16 32788 109902 ns/op 1320.65 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4162 869737 ns/op 1678.83 MB/s Benchmark_FanOut_128x10x1000-16 4066 867318 ns/op 1683.51 MB/s Benchmark_FanOut_128x10x1000-16 3973 859373 ns/op 1699.08 MB/s Benchmark_FanOut_128x10x1000-16 3954 875297 ns/op 1668.17 MB/s Benchmark_FanOut_128x10x1000-16 4138 875724 ns/op 1667.35 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3598 1011061 ns/op 1434.28 MB/s Benchmark_FanOut_128x100x100-16 3558 1003661 ns/op 1444.85 MB/s Benchmark_FanOut_128x100x100-16 3529 1006700 ns/op 1440.49 MB/s Benchmark_FanOut_128x100x100-16 3518 1007550 ns/op 1439.27 MB/s Benchmark_FanOut_128x100x100-16 3580 1019385 ns/op 1422.56 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 388 9151551 ns/op 1595.37 MB/s BenchmarkFanOut_128x100x1000-16 381 9239054 ns/op 1580.26 MB/s BenchmarkFanOut_128x100x1000-16 390 9211286 ns/op 1585.03 MB/s BenchmarkFanOut_128x100x1000-16 382 9221518 ns/op 1583.27 MB/s BenchmarkFanOut_128x100x1000-16 393 9392499 ns/op 1554.45 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 369 9597663 ns/op 1531.64 MB/s BenchmarkFanOut_128x10x10000-16 378 9515444 ns/op 1544.87 MB/s BenchmarkFanOut_128x10x10000-16 372 9592825 ns/op 1532.41 MB/s BenchmarkFanOut_128x10x10000-16 372 9587657 ns/op 1533.24 MB/s BenchmarkFanOut_128x10x10000-16 373 9649455 ns/op 1523.42 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 684 5219463 ns/op 1389.06 MB/s BenchmarkFanOut__128x500x100-16 672 5318715 ns/op 1363.14 MB/s BenchmarkFanOut__128x500x100-16 673 5279347 ns/op 1373.30 MB/s BenchmarkFanOut__128x500x100-16 673 5289876 ns/op 1370.57 MB/s BenchmarkFanOut__128x500x100-16 681 5225609 ns/op 1387.43 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1915 1840738 ns/op 2874.13 MB/s Benchmark_FanOut_512x100x100-16 1939 1825617 ns/op 2897.94 MB/s Benchmark_FanOut_512x100x100-16 1938 1828303 ns/op 2893.68 MB/s Benchmark_FanOut_512x100x100-16 1923 1835462 ns/op 2882.39 MB/s Benchmark_FanOut_512x100x100-16 1957 1824867 ns/op 2899.13 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 216 16415876 ns/op 3228.61 MB/s Benchmark__FanOut_512x100x1k-16 214 16556173 ns/op 3201.25 MB/s Benchmark__FanOut_512x100x1k-16 217 16507196 ns/op 3210.75 MB/s Benchmark__FanOut_512x100x1k-16 217 16566121 ns/op 3199.33 MB/s Benchmark__FanOut_512x100x1k-16 216 16501491 ns/op 3211.86 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3039 1139516 ns/op 9153.92 MB/s Benchmark____FanOut_1kx10x1k-16 3051 1141152 ns/op 9140.79 MB/s Benchmark____FanOut_1kx10x1k-16 3180 1157097 ns/op 9014.83 MB/s Benchmark____FanOut_1kx10x1k-16 3068 1140893 ns/op 9142.87 MB/s Benchmark____FanOut_1kx10x1k-16 2977 1146201 ns/op 9100.53 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2817 1255056 ns/op 8303.24 MB/s Benchmark__FanOut_1kx100x100-16 2823 1249383 ns/op 8340.95 MB/s Benchmark__FanOut_1kx100x100-16 2814 1251222 ns/op 8328.69 MB/s Benchmark__FanOut_1kx100x100-16 2779 1249336 ns/op 8341.26 MB/s Benchmark__FanOut_1kx100x100-16 2809 1251238 ns/op 8328.58 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4386700 786.2 ns/op 316.72 MB/s Benchmark_____RFanOut_8x1x10-16 4375986 801.7 ns/op 310.57 MB/s Benchmark_____RFanOut_8x1x10-16 4466612 772.4 ns/op 322.36 MB/s Benchmark_____RFanOut_8x1x10-16 4595794 767.5 ns/op 324.43 MB/s Benchmark_____RFanOut_8x1x10-16 4574066 793.4 ns/op 313.85 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 512670 6455 ns/op 359.24 MB/s Benchmark____RFanOut_8x1x100-16 500068 6068 ns/op 382.18 MB/s Benchmark____RFanOut_8x1x100-16 510618 6110 ns/op 379.55 MB/s Benchmark____RFanOut_8x1x100-16 536671 6349 ns/op 365.25 MB/s Benchmark____RFanOut_8x1x100-16 518058 6280 ns/op 369.25 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47966 74781 ns/op 307.82 MB/s Benchmark___RFanOut_8x10x100-16 47952 74634 ns/op 308.42 MB/s Benchmark___RFanOut_8x10x100-16 47560 74609 ns/op 308.53 MB/s Benchmark___RFanOut_8x10x100-16 47989 74517 ns/op 308.91 MB/s Benchmark___RFanOut_8x10x100-16 48172 74635 ns/op 308.42 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5695 595447 ns/op 403.09 MB/s Benchmark__RFanOut_8x10x1000-16 5970 603611 ns/op 397.64 MB/s Benchmark__RFanOut_8x10x1000-16 5835 598552 ns/op 401.00 MB/s Benchmark__RFanOut_8x10x1000-16 5919 600094 ns/op 399.97 MB/s Benchmark__RFanOut_8x10x1000-16 5916 595683 ns/op 402.93 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4900 710688 ns/op 323.66 MB/s Benchmark__RFanOut_8x100x100-16 4963 707546 ns/op 325.09 MB/s Benchmark__RFanOut_8x100x100-16 4974 706698 ns/op 325.48 MB/s Benchmark__RFanOut_8x100x100-16 4838 709247 ns/op 324.31 MB/s Benchmark__RFanOut_8x100x100-16 4863 706924 ns/op 325.38 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 580 6140463 ns/op 390.85 MB/s Benchmark_RFanOut_8x100x1000-16 586 6153213 ns/op 390.04 MB/s Benchmark_RFanOut_8x100x1000-16 582 6161233 ns/op 389.54 MB/s Benchmark_RFanOut_8x100x1000-16 574 6177866 ns/op 388.49 MB/s Benchmark_RFanOut_8x100x1000-16 574 6131106 ns/op 391.45 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 536 6676977 ns/op 374.42 MB/s Benchmark_RFanOut_8x10x10000-16 532 6744027 ns/op 370.70 MB/s Benchmark_RFanOut_8x10x10000-16 525 6721251 ns/op 371.96 MB/s Benchmark_RFanOut_8x10x10000-16 531 6775331 ns/op 368.99 MB/s Benchmark_RFanOut_8x10x10000-16 541 6668455 ns/op 374.90 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2832 1134718 ns/op 9192.62 MB/s Benchmark_RFanOut_1kx10x1000-16 2930 1141172 ns/op 9140.64 MB/s Benchmark_RFanOut_1kx10x1000-16 2973 1138893 ns/op 9158.93 MB/s Benchmark_RFanOut_1kx10x1000-16 3066 1155327 ns/op 9028.65 MB/s Benchmark_RFanOut_1kx10x1000-16 3075 1155547 ns/op 9026.92 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6962146 504.9 ns/op 4115.71 MB/s Benchmark_____FanIn_1kx100x1-16 7001532 503.2 ns/op 4129.33 MB/s Benchmark_____FanIn_1kx100x1-16 7030030 503.1 ns/op 4130.64 MB/s Benchmark_____FanIn_1kx100x1-16 7004296 503.4 ns/op 4128.30 MB/s Benchmark_____FanIn_1kx100x1-16 7056009 503.1 ns/op 4130.53 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2600373 1379 ns/op 5962.72 MB/s Benchmark_____FanIn_4kx100x1-16 2683677 1355 ns/op 6067.92 MB/s Benchmark_____FanIn_4kx100x1-16 2637817 1336 ns/op 6153.07 MB/s Benchmark_____FanIn_4kx100x1-16 2595652 1359 ns/op 6048.15 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 59373168 vs 10666528000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48772->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark_____FanIn_4kx100x1-16 Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1689213 2116 ns/op 7757.73 MB/s Benchmark_____FanIn_8kx100x1-16 1702695 2098 ns/op 7823.22 MB/s Benchmark_____FanIn_8kx100x1-16 1694218 2095 ns/op 7833.80 MB/s Benchmark_____FanIn_8kx100x1-16 1720924 2120 ns/op 7741.58 MB/s Benchmark_____FanIn_8kx100x1-16 1681605 2097 ns/op 7827.90 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 864105 4125 ns/op 7951.17 MB/s Benchmark____FanIn_16kx100x1-16 868280 4104 ns/op 7991.78 MB/s Benchmark____FanIn_16kx100x1-16 872976 4120 ns/op 7960.96 MB/s Benchmark____FanIn_16kx100x1-16 872604 4078 ns/op 8042.71 MB/s Benchmark____FanIn_16kx100x1-16 880490 4158 ns/op 7887.50 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 171181 19895 ns/op 6589.90 MB/s Benchmark____FanIn_64kx100x1-16 167764 19902 ns/op 6587.34 MB/s Benchmark____FanIn_64kx100x1-16 167264 19999 ns/op 6555.47 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 3520327206 vs 10429482300 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40076->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39730->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 169892 19923 ns/op 6580.69 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 716537940 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47298->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:47904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48026->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: 492111860 vs 11784991000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50568->127.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:50092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50814->127.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:50656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50634->127.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: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:50788->127.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:50242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50526->127.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:50410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50306->127.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:50422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50706->127.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:50262->127.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:50722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50792->127.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:50750->127.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: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:50620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50020->127.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:50026->127.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:50040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50588->127.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:50246->127.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:50124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50320->127.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: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:50424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50284->127.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:50806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50170->127.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:50694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50356->127.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:50102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50014->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: 563949180 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52608->127.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:52174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51812->127.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:52246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52264->127.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:52560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52162->127.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:52642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51866->127.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:52526->127.0.0.1:5222: write: connection reset by peer 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:51852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51888->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:52352->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: 194668650 vs 1310900000 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:54104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53976->127.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:54190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53846->127.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:53996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54020->127.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:53956->127.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:54302->127.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:53672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54138->127.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: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:54324->127.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: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:54268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54380->127.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:54476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53988->127.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:53716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54092->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: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:53892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54338->127.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:53686->127.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:54130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54344->127.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: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:54372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53714->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: 1308278200 vs 11680119000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56350->127.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:56654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56628->127.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:56778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56708->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56694->127.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:56792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57178->127.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:56914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56916->127.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:56408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56730->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5598812 637.1 ns/op 445.75 MB/s Benchmark___BumpPubCount_1x3-16 5607896 641.6 ns/op 442.66 MB/s Benchmark___BumpPubCount_1x3-16 5597991 636.1 ns/op 446.46 MB/s Benchmark___BumpPubCount_1x3-16 5670463 636.4 ns/op 446.25 MB/s Benchmark___BumpPubCount_1x3-16 5654037 639.1 ns/op 444.39 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5382307 665.8 ns/op 426.54 MB/s Benchmark___BumpPubCount_2x3-16 5367272 664.2 ns/op 427.58 MB/s Benchmark___BumpPubCount_2x3-16 5329422 667.3 ns/op 425.63 MB/s Benchmark___BumpPubCount_2x3-16 5291808 665.2 ns/op 426.91 MB/s Benchmark___BumpPubCount_2x3-16 5400706 675.5 ns/op 420.40 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5623052 641.5 ns/op 442.72 MB/s Benchmark___BumpPubCount_5x3-16 5561025 639.3 ns/op 444.24 MB/s Benchmark___BumpPubCount_5x3-16 5591064 635.8 ns/op 446.71 MB/s Benchmark___BumpPubCount_5x3-16 5284009 637.1 ns/op 445.80 MB/s Benchmark___BumpPubCount_5x3-16 5556626 636.4 ns/op 446.23 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5599310 641.7 ns/op 442.60 MB/s Benchmark__BumpPubCount_10x3-16 5552688 639.6 ns/op 444.06 MB/s Benchmark__BumpPubCount_10x3-16 5610153 637.8 ns/op 445.27 MB/s Benchmark__BumpPubCount_10x3-16 5602630 637.0 ns/op 445.83 MB/s Benchmark__BumpPubCount_10x3-16 5614692 638.5 ns/op 444.81 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11885379 281.2 ns/op 3698.79 MB/s Benchmark____GWs_Opt_1kx01x0-16 12561957 278.3 ns/op 3737.26 MB/s Benchmark____GWs_Opt_1kx01x0-16 13046154 272.3 ns/op 3819.17 MB/s Benchmark____GWs_Opt_1kx01x0-16 13023885 272.8 ns/op 3812.42 MB/s Benchmark____GWs_Opt_1kx01x0-16 12573186 279.7 ns/op 3718.78 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9827462 329.5 ns/op 6263.81 MB/s Benchmark____GWs_Opt_2kx01x0-16 10212226 322.8 ns/op 6394.86 MB/s Benchmark____GWs_Opt_2kx01x0-16 9725941 317.9 ns/op 6492.57 MB/s Benchmark____GWs_Opt_2kx01x0-16 10131766 328.1 ns/op 6290.67 MB/s Benchmark____GWs_Opt_2kx01x0-16 10606768 350.6 ns/op 5887.83 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5516991 607.2 ns/op 6771.89 MB/s Benchmark____GWs_Opt_4kx01x0-16 5544138 592.8 ns/op 6936.44 MB/s Benchmark____GWs_Opt_4kx01x0-16 5539983 606.4 ns/op 6780.73 MB/s Benchmark____GWs_Opt_4kx01x0-16 5620336 605.7 ns/op 6788.91 MB/s Benchmark____GWs_Opt_4kx01x0-16 5811325 610.0 ns/op 6740.64 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29312640 113.8 ns/op 9141.68 MB/s Benchmark____GWs_Opt_1kx10x0-16 27155740 111.3 ns/op 9345.11 MB/s Benchmark____GWs_Opt_1kx10x0-16 31650318 140.2 ns/op 7415.69 MB/s Benchmark____GWs_Opt_1kx10x0-16 31100767 115.5 ns/op 9003.64 MB/s Benchmark____GWs_Opt_1kx10x0-16 31228896 108.8 ns/op 9557.47 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 19209326 163.5 ns/op 12622.98 MB/s Benchmark____GWs_Opt_2kx10x0-16 25098687 147.1 ns/op 14030.32 MB/s Benchmark____GWs_Opt_2kx10x0-16 23714469 151.5 ns/op 13622.13 MB/s Benchmark____GWs_Opt_2kx10x0-16 23876130 149.3 ns/op 13820.42 MB/s Benchmark____GWs_Opt_2kx10x0-16 24372968 382.6 ns/op 5395.05 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 1000000 4723 ns/op 870.71 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:51232->127.0.0.1:34153: 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:57426->127.0.0.1:38425: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 12590433 295.5 ns/op 13917.65 MB/s Benchmark____GWs_Opt_4kx10x0-16 10923344 280.5 ns/op 14660.11 MB/s Benchmark____GWs_Opt_4kx10x0-16 3099877 2431 ns/op 1691.67 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6414530 556.6 ns/op 5614.07 MB/s Benchmark____GWs_Opt_1kx01x1-16 6329989 546.3 ns/op 5720.21 MB/s Benchmark____GWs_Opt_1kx01x1-16 6791871 542.0 ns/op 5765.64 MB/s Benchmark____GWs_Opt_1kx01x1-16 6654414 545.3 ns/op 5731.11 MB/s Benchmark____GWs_Opt_1kx01x1-16 6502027 537.7 ns/op 5811.50 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4664067 755.9 ns/op 8197.77 MB/s Benchmark____GWs_Opt_2kx01x1-16 4583599 811.1 ns/op 7640.25 MB/s Benchmark____GWs_Opt_2kx01x1-16 4801315 749.1 ns/op 8272.20 MB/s Benchmark____GWs_Opt_2kx01x1-16 4806088 752.1 ns/op 8239.86 MB/s Benchmark____GWs_Opt_2kx01x1-16 4880001 765.6 ns/op 8094.08 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2567754 1355 ns/op 9104.69 MB/s Benchmark____GWs_Opt_4kx01x1-16 2652274 1349 ns/op 9151.49 MB/s Benchmark____GWs_Opt_4kx01x1-16 2622438 1364 ns/op 9046.34 MB/s Benchmark____GWs_Opt_4kx01x1-16 2633060 1343 ns/op 9188.07 MB/s Benchmark____GWs_Opt_4kx01x1-16 2276763 1373 ns/op 8986.47 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6603664 557.7 ns/op 5603.67 MB/s Benchmark____GWs_Opt_1kx10x1-16 6669975 550.5 ns/op 5676.65 MB/s Benchmark____GWs_Opt_1kx10x1-16 6557906 544.7 ns/op 5736.83 MB/s Benchmark____GWs_Opt_1kx10x1-16 6126447 550.1 ns/op 5680.71 MB/s Benchmark____GWs_Opt_1kx10x1-16 6661574 554.4 ns/op 5636.48 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4715252 858.2 ns/op 7221.29 MB/s Benchmark____GWs_Opt_2kx10x1-16 4296586 849.6 ns/op 7294.40 MB/s Benchmark____GWs_Opt_2kx10x1-16 4139056 871.8 ns/op 7107.98 MB/s Benchmark____GWs_Opt_2kx10x1-16 4150591 829.9 ns/op 7467.25 MB/s Benchmark____GWs_Opt_2kx10x1-16 3993884 815.1 ns/op 7602.68 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2389752 1518 ns/op 8131.32 MB/s Benchmark____GWs_Opt_4kx10x1-16 2330629 1558 ns/op 7922.81 MB/s Benchmark____GWs_Opt_4kx10x1-16 2441203 1518 ns/op 8131.89 MB/s Benchmark____GWs_Opt_4kx10x1-16 2240637 1395 ns/op 8846.01 MB/s Benchmark____GWs_Opt_4kx10x1-16 2369496 1547 ns/op 7976.02 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12594102 287.4 ns/op 3619.19 MB/s Benchmark____GWs_Int_1kx01x0-16 12289320 286.7 ns/op 3628.02 MB/s Benchmark____GWs_Int_1kx01x0-16 12964185 283.3 ns/op 3671.37 MB/s Benchmark____GWs_Int_1kx01x0-16 12661684 287.8 ns/op 3613.33 MB/s Benchmark____GWs_Int_1kx01x0-16 11885742 281.7 ns/op 3691.66 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10393540 369.5 ns/op 5586.49 MB/s Benchmark____GWs_Int_2kx01x0-16 10369036 357.7 ns/op 5769.81 MB/s Benchmark____GWs_Int_2kx01x0-16 10261378 355.4 ns/op 5807.08 MB/s Benchmark____GWs_Int_2kx01x0-16 10268788 356.8 ns/op 5785.07 MB/s Benchmark____GWs_Int_2kx01x0-16 10689697 356.5 ns/op 5789.28 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5712901 615.4 ns/op 6681.61 MB/s Benchmark____GWs_Int_4kx01x0-16 5836729 636.2 ns/op 6463.31 MB/s Benchmark____GWs_Int_4kx01x0-16 5656568 643.5 ns/op 6389.58 MB/s Benchmark____GWs_Int_4kx01x0-16 5552202 630.1 ns/op 6525.57 MB/s Benchmark____GWs_Int_4kx01x0-16 5856337 623.0 ns/op 6600.03 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31905652 115.5 ns/op 9005.91 MB/s Benchmark____GWs_Int_1kx10x0-16 30808831 127.4 ns/op 8162.49 MB/s Benchmark____GWs_Int_1kx10x0-16 30890570 111.7 ns/op 9314.21 MB/s Benchmark____GWs_Int_1kx10x0-16 30952840 117.2 ns/op 8872.38 MB/s Benchmark____GWs_Int_1kx10x0-16 31756143 114.4 ns/op 9091.72 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25196845 171.2 ns/op 12058.05 MB/s Benchmark____GWs_Int_2kx10x0-16 25642369 149.6 ns/op 13792.38 MB/s Benchmark____GWs_Int_2kx10x0-16 25785302 164.0 ns/op 12585.99 MB/s Benchmark____GWs_Int_2kx10x0-16 25221081 145.8 ns/op 14153.84 MB/s Benchmark____GWs_Int_2kx10x0-16 26171112 139.1 ns/op 14838.99 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 10254000 292.6 ns/op 14053.68 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:35346->127.0.0.1:41487: 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:35964->127.0.0.1:45939: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 bench_test.go:158: Error on read: read tcp 127.0.0.1:58278->127.0.0.1:38671: 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:43572->127.0.0.1:44119: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 11464478 282.2 ns/op 14572.25 MB/s Benchmark____GWs_Int_4kx10x0-16 13248616 287.5 ns/op 14302.43 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6756370 546.2 ns/op 5721.67 MB/s Benchmark____GWs_Int_1kx01x1-16 6632032 550.9 ns/op 5672.87 MB/s Benchmark____GWs_Int_1kx01x1-16 6479566 547.4 ns/op 5708.79 MB/s Benchmark____GWs_Int_1kx01x1-16 6593067 549.2 ns/op 5690.43 MB/s Benchmark____GWs_Int_1kx01x1-16 6406036 552.2 ns/op 5658.75 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4759952 956.9 ns/op 6475.87 MB/s Benchmark____GWs_Int_2kx01x1-16 4760028 752.7 ns/op 8232.55 MB/s Benchmark____GWs_Int_2kx01x1-16 4874589 752.0 ns/op 8240.41 MB/s Benchmark____GWs_Int_2kx01x1-16 4613685 845.4 ns/op 7330.21 MB/s Benchmark____GWs_Int_2kx01x1-16 4752442 770.2 ns/op 8046.48 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2684700 1362 ns/op 9060.88 MB/s Benchmark____GWs_Int_4kx01x1-16 2707299 1366 ns/op 9032.51 MB/s Benchmark____GWs_Int_4kx01x1-16 2520650 1355 ns/op 9105.43 MB/s Benchmark____GWs_Int_4kx01x1-16 2699520 1366 ns/op 9033.68 MB/s Benchmark____GWs_Int_4kx01x1-16 2693367 1372 ns/op 8993.70 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6606217 554.1 ns/op 5639.50 MB/s Benchmark____GWs_Int_1kx10x1-16 5542854 557.8 ns/op 5601.94 MB/s Benchmark____GWs_Int_1kx10x1-16 6454119 556.5 ns/op 5615.46 MB/s Benchmark____GWs_Int_1kx10x1-16 6458794 558.7 ns/op 5593.46 MB/s Benchmark____GWs_Int_1kx10x1-16 6276488 553.9 ns/op 5641.37 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4208937 836.9 ns/op 7404.82 MB/s Benchmark____GWs_Int_2kx10x1-16 3953553 802.1 ns/op 7726.34 MB/s Benchmark____GWs_Int_2kx10x1-16 4232793 851.3 ns/op 7279.36 MB/s Benchmark____GWs_Int_2kx10x1-16 4183596 851.0 ns/op 7281.73 MB/s Benchmark____GWs_Int_2kx10x1-16 4193697 831.2 ns/op 7455.27 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2222072 1525 ns/op 8090.93 MB/s Benchmark____GWs_Int_4kx10x1-16 2409843 1497 ns/op 8244.32 MB/s Benchmark____GWs_Int_4kx10x1-16 2440059 1497 ns/op 8244.79 MB/s Benchmark____GWs_Int_4kx10x1-16 2326365 1503 ns/op 8208.59 MB/s Benchmark____GWs_Int_4kx10x1-16 2265122 1519 ns/op 8126.96 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8551209 429.3 ns/op 237.62 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8240274 434.0 ns/op 235.00 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8254328 431.3 ns/op 236.48 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8480770 432.0 ns/op 236.09 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8387858 430.5 ns/op 236.91 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 628677 5027 ns/op 35.21 MB/s Benchmark__GWs_Reqs_1SubEach-16 777267 5266 ns/op 33.61 MB/s Benchmark__GWs_Reqs_1SubEach-16 761732 5176 ns/op 34.20 MB/s Benchmark__GWs_Reqs_1SubEach-16 747484 5247 ns/op 33.73 MB/s Benchmark__GWs_Reqs_1SubEach-16 747070 5260 ns/op 33.65 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2167.879s ❌ Non-zero exit code: 1