> ROOT_DIR=/tmp/go-bench-away-job-aeb918d0-a060-455c-8cbe-89c2e7ba9e21-136426891 > OUTPUT_FILE=/tmp/go-bench-away-job-aeb918d0-a060-455c-8cbe-89c2e7ba9e21-136426891/results.txt > SHA_FILE=/tmp/go-bench-away-job-aeb918d0-a060-455c-8cbe-89c2e7ba9e21-136426891/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-aeb918d0-a060-455c-8cbe-89c2e7ba9e21-136426891/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=v2.12.4 > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.25.4/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: v2.12.4 to /tmp/go-bench-away-job-aeb918d0-a060-455c-8cbe-89c2e7ba9e21-136426891/source.git SHA of v2.12.4: 2429cd357a0837d7f936b5124e5ffb428b97ce79 Go runtime: go version go1.26.0 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build3469230472=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-aeb918d0-a060-455c-8cbe-89c2e7ba9e21-136426891/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.25.4' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.25.4/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.0' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 54708314 65.73 ns/op 167.35 MB/s Benchmark______Pub0b_Payload-16 46012862 65.66 ns/op 167.54 MB/s Benchmark______Pub0b_Payload-16 51542722 68.51 ns/op 160.55 MB/s Benchmark______Pub0b_Payload-16 51138537 65.79 ns/op 167.20 MB/s Benchmark______Pub0b_Payload-16 51816121 65.69 ns/op 167.44 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 50666248 66.35 ns/op 286.38 MB/s Benchmark______Pub8b_Payload-16 50892842 66.50 ns/op 285.71 MB/s Benchmark______Pub8b_Payload-16 50875552 66.56 ns/op 285.47 MB/s Benchmark______Pub8b_Payload-16 48828108 66.27 ns/op 286.69 MB/s Benchmark______Pub8b_Payload-16 50534901 69.19 ns/op 274.60 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 50575776 70.90 ns/op 620.63 MB/s Benchmark_____Pub32b_Payload-16 50839371 72.03 ns/op 610.83 MB/s Benchmark_____Pub32b_Payload-16 48267675 70.96 ns/op 620.02 MB/s Benchmark_____Pub32b_Payload-16 47510560 71.01 ns/op 619.66 MB/s Benchmark_____Pub32b_Payload-16 47879226 71.11 ns/op 618.79 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 41822337 79.86 ns/op 1765.65 MB/s Benchmark____Pub128B_Payload-16 45067441 80.31 ns/op 1755.64 MB/s Benchmark____Pub128B_Payload-16 37134394 90.77 ns/op 1553.30 MB/s Benchmark____Pub128B_Payload-16 42647396 80.30 ns/op 1755.83 MB/s Benchmark____Pub128B_Payload-16 44688753 80.73 ns/op 1746.54 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 40859974 94.93 ns/op 2833.53 MB/s Benchmark____Pub256B_Payload-16 38828922 90.26 ns/op 2980.16 MB/s Benchmark____Pub256B_Payload-16 38766172 91.77 ns/op 2931.22 MB/s Benchmark____Pub256B_Payload-16 35321085 89.78 ns/op 2996.16 MB/s Benchmark____Pub256B_Payload-16 38554789 87.87 ns/op 3061.43 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24282355 134.3 ns/op 7731.26 MB/s Benchmark______Pub1K_Payload-16 24686497 136.7 ns/op 7592.03 MB/s Benchmark______Pub1K_Payload-16 23572417 133.8 ns/op 7760.27 MB/s Benchmark______Pub1K_Payload-16 27960310 132.2 ns/op 7852.12 MB/s Benchmark______Pub1K_Payload-16 24461431 132.5 ns/op 7834.26 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5845900 617.4 ns/op 6657.09 MB/s Benchmark______Pub4K_Payload-16 5641420 621.3 ns/op 6615.08 MB/s Benchmark______Pub4K_Payload-16 5594134 634.6 ns/op 6476.36 MB/s Benchmark______Pub4K_Payload-16 5655586 621.8 ns/op 6609.83 MB/s Benchmark______Pub4K_Payload-16 5360155 620.7 ns/op 6621.52 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2785748 1277 ns/op 6424.48 MB/s Benchmark______Pub8K_Payload-16 2687319 1279 ns/op 6416.92 MB/s Benchmark______Pub8K_Payload-16 2657594 1281 ns/op 6406.89 MB/s Benchmark______Pub8K_Payload-16 2734413 1289 ns/op 6367.84 MB/s Benchmark______Pub8K_Payload-16 2733994 1286 ns/op 6380.28 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 593028 5557 ns/op 5898.93 MB/s Benchmark_____Pub32K_Payload-16 675541 5459 ns/op 6005.11 MB/s Benchmark_____Pub32K_Payload-16 655684 5329 ns/op 6152.32 MB/s Benchmark_____Pub32K_Payload-16 673353 5422 ns/op 6046.13 MB/s Benchmark_____Pub32K_Payload-16 657224 5414 ns/op 6055.38 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 40243824 89.49 ns/op 122.92 MB/s Benchmark__AuthPub0b_Payload-16 34946722 87.18 ns/op 126.18 MB/s Benchmark__AuthPub0b_Payload-16 39410245 86.68 ns/op 126.90 MB/s Benchmark__AuthPub0b_Payload-16 39364879 86.78 ns/op 126.75 MB/s Benchmark__AuthPub0b_Payload-16 39545301 86.97 ns/op 126.49 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 16786078 208.5 ns/op Benchmark_____________PubSub-16 16773589 209.7 ns/op Benchmark_____________PubSub-16 16681425 209.4 ns/op Benchmark_____________PubSub-16 16993933 209.5 ns/op Benchmark_____________PubSub-16 16963748 209.6 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 17056650 207.3 ns/op Benchmark_____PubSubTwoConns-16 16857674 208.2 ns/op Benchmark_____PubSubTwoConns-16 17002238 209.0 ns/op Benchmark_____PubSubTwoConns-16 16879437 209.1 ns/op Benchmark_____PubSubTwoConns-16 16792192 208.1 ns/op Benchmark__PubServiceImports bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:32884->127.0.0.1:43503: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:58158->127.0.0.1:46549: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:33158->127.0.0.1:46845: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:38236->127.0.0.1:46597: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:52592->127.0.0.1:39981: 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 15653022 226.6 ns/op Benchmark_____PubTwoQueueSub-16 15520412 227.7 ns/op Benchmark_____PubTwoQueueSub-16 15593223 226.5 ns/op Benchmark_____PubTwoQueueSub-16 15533071 226.7 ns/op Benchmark_____PubTwoQueueSub-16 15478018 227.1 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15472254 227.6 ns/op Benchmark____PubFourQueueSub-16 15581599 227.2 ns/op Benchmark____PubFourQueueSub-16 15557869 226.5 ns/op Benchmark____PubFourQueueSub-16 15703268 226.8 ns/op Benchmark____PubFourQueueSub-16 15449344 227.4 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15753264 227.7 ns/op Benchmark___PubEightQueueSub-16 15609405 227.4 ns/op Benchmark___PubEightQueueSub-16 15562432 227.8 ns/op Benchmark___PubEightQueueSub-16 15445342 226.7 ns/op Benchmark___PubEightQueueSub-16 15692228 227.2 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23674 152292 ns/op Benchmark_PubSub512kTwoConns-16 23433 156371 ns/op Benchmark_PubSub512kTwoConns-16 23392 155886 ns/op Benchmark_PubSub512kTwoConns-16 23478 151629 ns/op Benchmark_PubSub512kTwoConns-16 23418 152729 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16764441 211.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 16359546 210.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 16551168 210.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 16482913 211.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 16518960 211.5 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16355034 211.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 16475218 211.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 16289319 212.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 16404318 211.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 16500838 212.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 12315906 284.3 ns/op Benchmark____RoutedPubSub_0b-16 12153882 286.2 ns/op Benchmark____RoutedPubSub_0b-16 12462210 286.1 ns/op Benchmark____RoutedPubSub_0b-16 12157560 286.6 ns/op Benchmark____RoutedPubSub_0b-16 11928836 283.7 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6422244 523.2 ns/op Benchmark____RoutedPubSub_1K-16 6743438 518.4 ns/op Benchmark____RoutedPubSub_1K-16 6779128 522.9 ns/op Benchmark____RoutedPubSub_1K-16 6653438 516.9 ns/op Benchmark____RoutedPubSub_1K-16 6708831 513.0 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85214 42892 ns/op Benchmark__RoutedPubSub_100K-16 83323 42459 ns/op Benchmark__RoutedPubSub_100K-16 85002 43270 ns/op Benchmark__RoutedPubSub_100K-16 82342 42571 ns/op Benchmark__RoutedPubSub_100K-16 83942 42481 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 10441888 339.4 ns/op Benchmark____Routed2QueueSub-16 10535150 332.1 ns/op Benchmark____Routed2QueueSub-16 10348015 336.1 ns/op Benchmark____Routed2QueueSub-16 10674679 334.4 ns/op Benchmark____Routed2QueueSub-16 10555880 337.8 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 10481130 344.2 ns/op Benchmark____Routed4QueueSub-16 8537956 358.3 ns/op Benchmark____Routed4QueueSub-16 10435638 343.3 ns/op Benchmark____Routed4QueueSub-16 10270322 343.1 ns/op Benchmark____Routed4QueueSub-16 10525580 344.5 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9849435 357.5 ns/op Benchmark____Routed8QueueSub-16 8559470 354.9 ns/op Benchmark____Routed8QueueSub-16 10120088 350.0 ns/op Benchmark____Routed8QueueSub-16 10174358 352.4 ns/op Benchmark____Routed8QueueSub-16 8383510 358.1 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8084420 378.2 ns/op Benchmark___Routed16QueueSub-16 9761772 373.5 ns/op Benchmark___Routed16QueueSub-16 9691311 371.6 ns/op Benchmark___Routed16QueueSub-16 9728799 374.1 ns/op Benchmark___Routed16QueueSub-16 9548505 367.5 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 7121044 472.6 ns/op Benchmark____________RouteCompressOff-16 6688046 470.3 ns/op Benchmark____________RouteCompressOff-16 7281591 458.7 ns/op Benchmark____________RouteCompressOff-16 6957571 472.8 ns/op Benchmark____________RouteCompressOff-16 7270922 464.6 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6835938 465.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6844146 478.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 7101399 466.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6524804 468.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6451555 484.0 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6985276 470.1 ns/op Benchmark_________RouteCompressS2Fast-16 6984546 461.3 ns/op Benchmark_________RouteCompressS2Fast-16 7134928 458.5 ns/op Benchmark_________RouteCompressS2Fast-16 7206322 473.0 ns/op Benchmark_________RouteCompressS2Fast-16 6614422 464.8 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6508900 463.9 ns/op Benchmark_______RouteCompressS2Better-16 6598616 468.5 ns/op Benchmark_______RouteCompressS2Better-16 7270368 467.8 ns/op Benchmark_______RouteCompressS2Better-16 6887071 480.0 ns/op Benchmark_______RouteCompressS2Better-16 6824624 468.9 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6898208 469.3 ns/op Benchmark_________RouteCompressS2Best-16 7006018 470.1 ns/op Benchmark_________RouteCompressS2Best-16 7077159 468.0 ns/op Benchmark_________RouteCompressS2Best-16 7072058 463.0 ns/op Benchmark_________RouteCompressS2Best-16 6927112 479.0 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5131874 695.5 ns/op 358.02 MB/s Benchmark______FanOut_8x1x10-16 5146713 698.0 ns/op 356.73 MB/s Benchmark______FanOut_8x1x10-16 5117971 697.3 ns/op 357.10 MB/s Benchmark______FanOut_8x1x10-16 5098196 695.9 ns/op 357.82 MB/s Benchmark______FanOut_8x1x10-16 5121476 696.8 ns/op 357.35 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 609750 5484 ns/op 422.86 MB/s Benchmark_____FanOut_8x1x100-16 611289 5517 ns/op 420.31 MB/s Benchmark_____FanOut_8x1x100-16 620916 5457 ns/op 424.99 MB/s Benchmark_____FanOut_8x1x100-16 602482 5474 ns/op 423.66 MB/s Benchmark_____FanOut_8x1x100-16 619675 5515 ns/op 420.52 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 52730 68433 ns/op 336.37 MB/s Benchmark____FanOut_8x10x100-16 52669 68066 ns/op 338.19 MB/s Benchmark____FanOut_8x10x100-16 52891 67988 ns/op 338.57 MB/s Benchmark____FanOut_8x10x100-16 52771 68056 ns/op 338.24 MB/s Benchmark____FanOut_8x10x100-16 52729 68221 ns/op 337.42 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6624 537265 ns/op 446.74 MB/s Benchmark___FanOut_8x10x1000-16 6810 539194 ns/op 445.14 MB/s Benchmark___FanOut_8x10x1000-16 6571 536462 ns/op 447.41 MB/s Benchmark___FanOut_8x10x1000-16 6723 543017 ns/op 442.01 MB/s Benchmark___FanOut_8x10x1000-16 6438 536882 ns/op 447.06 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5536 634393 ns/op 362.58 MB/s Benchmark___FanOut_8x100x100-16 5511 634596 ns/op 362.47 MB/s Benchmark___FanOut_8x100x100-16 5564 634286 ns/op 362.64 MB/s Benchmark___FanOut_8x100x100-16 5372 638193 ns/op 360.42 MB/s Benchmark___FanOut_8x100x100-16 5629 633753 ns/op 362.95 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 648 5490012 ns/op 437.16 MB/s Benchmark__FanOut_8x100x1000-16 634 5529572 ns/op 434.03 MB/s Benchmark__FanOut_8x100x1000-16 654 5587094 ns/op 429.56 MB/s Benchmark__FanOut_8x100x1000-16 634 5597940 ns/op 428.73 MB/s Benchmark__FanOut_8x100x1000-16 648 5524023 ns/op 434.47 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 614 5828193 ns/op 428.95 MB/s Benchmark__FanOut_8x10x10000-16 609 5870832 ns/op 425.84 MB/s Benchmark__FanOut_8x10x10000-16 607 5896169 ns/op 424.01 MB/s Benchmark__FanOut_8x10x10000-16 608 5866700 ns/op 426.14 MB/s Benchmark__FanOut_8x10x10000-16 597 5904063 ns/op 423.44 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1039 3403497 ns/op 337.89 MB/s Benchmark___FanOut_8x500x100-16 1044 3395977 ns/op 338.64 MB/s Benchmark___FanOut_8x500x100-16 1045 3408110 ns/op 337.44 MB/s Benchmark___FanOut_8x500x100-16 1044 3402035 ns/op 338.04 MB/s Benchmark___FanOut_8x500x100-16 1041 3398572 ns/op 338.38 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 383724 8924 ns/op 1640.66 MB/s Benchmark___FanOut_128x1x100-16 376578 8940 ns/op 1637.66 MB/s Benchmark___FanOut_128x1x100-16 378822 8954 ns/op 1635.18 MB/s Benchmark___FanOut_128x1x100-16 392448 8940 ns/op 1637.67 MB/s Benchmark___FanOut_128x1x100-16 388692 8909 ns/op 1643.38 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 34918 102791 ns/op 1412.01 MB/s Benchmark__FanOut_128x10x100-16 35140 102475 ns/op 1416.36 MB/s Benchmark__FanOut_128x10x100-16 34928 102859 ns/op 1411.07 MB/s Benchmark__FanOut_128x10x100-16 34729 102600 ns/op 1414.63 MB/s Benchmark__FanOut_128x10x100-16 34912 102809 ns/op 1411.75 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4203 796909 ns/op 1832.26 MB/s Benchmark_FanOut_128x10x1000-16 4537 797211 ns/op 1831.56 MB/s Benchmark_FanOut_128x10x1000-16 4414 797084 ns/op 1831.85 MB/s Benchmark_FanOut_128x10x1000-16 4396 797602 ns/op 1830.66 MB/s Benchmark_FanOut_128x10x1000-16 4466 800814 ns/op 1823.32 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3724 948114 ns/op 1529.50 MB/s Benchmark_FanOut_128x100x100-16 3735 945430 ns/op 1533.84 MB/s Benchmark_FanOut_128x100x100-16 3739 946682 ns/op 1531.81 MB/s Benchmark_FanOut_128x100x100-16 3699 946130 ns/op 1532.71 MB/s Benchmark_FanOut_128x100x100-16 3727 944560 ns/op 1535.26 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 429 8437499 ns/op 1730.39 MB/s BenchmarkFanOut_128x100x1000-16 422 8611407 ns/op 1695.44 MB/s BenchmarkFanOut_128x100x1000-16 410 8572872 ns/op 1703.06 MB/s BenchmarkFanOut_128x100x1000-16 417 8421730 ns/op 1733.63 MB/s BenchmarkFanOut_128x100x1000-16 423 8509028 ns/op 1715.84 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 406 8903250 ns/op 1651.10 MB/s BenchmarkFanOut_128x10x10000-16 397 8880105 ns/op 1655.40 MB/s BenchmarkFanOut_128x10x10000-16 403 8914020 ns/op 1649.10 MB/s BenchmarkFanOut_128x10x10000-16 406 8882302 ns/op 1654.99 MB/s BenchmarkFanOut_128x10x10000-16 409 8915509 ns/op 1648.83 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 709 4977865 ns/op 1456.48 MB/s BenchmarkFanOut__128x500x100-16 704 5005879 ns/op 1448.33 MB/s BenchmarkFanOut__128x500x100-16 703 5020690 ns/op 1444.05 MB/s BenchmarkFanOut__128x500x100-16 716 5032664 ns/op 1440.62 MB/s BenchmarkFanOut__128x500x100-16 715 5017711 ns/op 1444.91 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 2035 1766530 ns/op 2994.87 MB/s Benchmark_FanOut_512x100x100-16 2023 1771005 ns/op 2987.30 MB/s Benchmark_FanOut_512x100x100-16 1996 1785737 ns/op 2962.66 MB/s Benchmark_FanOut_512x100x100-16 1993 1783468 ns/op 2966.42 MB/s Benchmark_FanOut_512x100x100-16 1981 1777537 ns/op 2976.32 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 225 16138413 ns/op 3284.12 MB/s Benchmark__FanOut_512x100x1k-16 228 16166281 ns/op 3278.46 MB/s Benchmark__FanOut_512x100x1k-16 223 16065606 ns/op 3299.01 MB/s Benchmark__FanOut_512x100x1k-16 226 15923861 ns/op 3328.37 MB/s Benchmark__FanOut_512x100x1k-16 225 15852974 ns/op 3343.25 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3171 1105418 ns/op 9436.28 MB/s Benchmark____FanOut_1kx10x1k-16 3357 1102333 ns/op 9462.70 MB/s Benchmark____FanOut_1kx10x1k-16 3276 1113498 ns/op 9367.81 MB/s Benchmark____FanOut_1kx10x1k-16 3110 1121060 ns/op 9304.62 MB/s Benchmark____FanOut_1kx10x1k-16 3370 1116313 ns/op 9344.19 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2922 1198723 ns/op 8693.45 MB/s Benchmark__FanOut_1kx100x100-16 2911 1200350 ns/op 8681.67 MB/s Benchmark__FanOut_1kx100x100-16 2889 1195005 ns/op 8720.49 MB/s Benchmark__FanOut_1kx100x100-16 2935 1201248 ns/op 8675.18 MB/s Benchmark__FanOut_1kx100x100-16 2898 1198931 ns/op 8691.94 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4658295 741.5 ns/op 335.80 MB/s Benchmark_____RFanOut_8x1x10-16 4554801 744.9 ns/op 334.29 MB/s Benchmark_____RFanOut_8x1x10-16 4583110 748.5 ns/op 332.68 MB/s Benchmark_____RFanOut_8x1x10-16 4647598 758.4 ns/op 328.34 MB/s Benchmark_____RFanOut_8x1x10-16 4641618 743.8 ns/op 334.77 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 577360 5543 ns/op 418.40 MB/s Benchmark____RFanOut_8x1x100-16 582463 5539 ns/op 418.66 MB/s Benchmark____RFanOut_8x1x100-16 596662 5523 ns/op 419.87 MB/s Benchmark____RFanOut_8x1x100-16 565862 5494 ns/op 422.11 MB/s Benchmark____RFanOut_8x1x100-16 586496 5494 ns/op 422.10 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 52750 68382 ns/op 336.62 MB/s Benchmark___RFanOut_8x10x100-16 52828 68838 ns/op 334.39 MB/s Benchmark___RFanOut_8x10x100-16 52819 67987 ns/op 338.58 MB/s Benchmark___RFanOut_8x10x100-16 52441 68008 ns/op 338.47 MB/s Benchmark___RFanOut_8x10x100-16 52593 67906 ns/op 338.98 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6716 537888 ns/op 446.23 MB/s Benchmark__RFanOut_8x10x1000-16 6735 545755 ns/op 439.79 MB/s Benchmark__RFanOut_8x10x1000-16 6536 534069 ns/op 449.42 MB/s Benchmark__RFanOut_8x10x1000-16 6699 538306 ns/op 445.88 MB/s Benchmark__RFanOut_8x10x1000-16 6538 541171 ns/op 443.52 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5535 638805 ns/op 360.08 MB/s Benchmark__RFanOut_8x100x100-16 5523 637266 ns/op 360.95 MB/s Benchmark__RFanOut_8x100x100-16 5488 635409 ns/op 362.00 MB/s Benchmark__RFanOut_8x100x100-16 5554 634942 ns/op 362.27 MB/s Benchmark__RFanOut_8x100x100-16 5506 635743 ns/op 361.81 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 625 5561234 ns/op 431.56 MB/s Benchmark_RFanOut_8x100x1000-16 654 5548538 ns/op 432.55 MB/s Benchmark_RFanOut_8x100x1000-16 645 5580071 ns/op 430.11 MB/s Benchmark_RFanOut_8x100x1000-16 652 5473027 ns/op 438.52 MB/s Benchmark_RFanOut_8x100x1000-16 634 5571472 ns/op 430.77 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 596 5934028 ns/op 421.30 MB/s Benchmark_RFanOut_8x10x10000-16 618 5866729 ns/op 426.14 MB/s Benchmark_RFanOut_8x10x10000-16 606 5902292 ns/op 423.57 MB/s Benchmark_RFanOut_8x10x10000-16 602 5928806 ns/op 421.67 MB/s Benchmark_RFanOut_8x10x10000-16 602 5989283 ns/op 417.42 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3342 1122447 ns/op 9293.12 MB/s Benchmark_RFanOut_1kx10x1000-16 3106 1116211 ns/op 9345.04 MB/s Benchmark_RFanOut_1kx10x1000-16 3205 1101457 ns/op 9470.22 MB/s Benchmark_RFanOut_1kx10x1000-16 3388 1123237 ns/op 9286.58 MB/s Benchmark_RFanOut_1kx10x1000-16 3244 1103227 ns/op 9455.02 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7248645 488.0 ns/op 4258.10 MB/s Benchmark_____FanIn_1kx100x1-16 7174752 484.2 ns/op 4292.00 MB/s Benchmark_____FanIn_1kx100x1-16 7183158 487.8 ns/op 4259.94 MB/s Benchmark_____FanIn_1kx100x1-16 7253119 486.6 ns/op 4270.44 MB/s Benchmark_____FanIn_1kx100x1-16 7180040 489.4 ns/op 4246.22 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2719387 1342 ns/op 6125.71 MB/s Benchmark_____FanIn_4kx100x1-16 2696392 1350 ns/op 6090.04 MB/s Benchmark_____FanIn_4kx100x1-16 2706458 1344 ns/op 6118.50 MB/s Benchmark_____FanIn_4kx100x1-16 2660580 1331 ns/op 6179.56 MB/s Benchmark_____FanIn_4kx100x1-16 2661577 1321 ns/op 6225.39 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1723478 2081 ns/op 7887.04 MB/s Benchmark_____FanIn_8kx100x1-16 1689524 2089 ns/op 7857.04 MB/s Benchmark_____FanIn_8kx100x1-16 1745782 2101 ns/op 7813.47 MB/s Benchmark_____FanIn_8kx100x1-16 1712680 2064 ns/op 7953.85 MB/s Benchmark_____FanIn_8kx100x1-16 1737520 2091 ns/op 7851.51 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 876660 4121 ns/op 7959.11 MB/s Benchmark____FanIn_16kx100x1-16 864182 4097 ns/op 8005.09 MB/s Benchmark____FanIn_16kx100x1-16 871023 4075 ns/op 8048.49 MB/s Benchmark____FanIn_16kx100x1-16 871752 4105 ns/op 7991.12 MB/s Benchmark____FanIn_16kx100x1-16 873746 4128 ns/op 7945.66 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 164362 19710 ns/op 6651.54 MB/s Benchmark____FanIn_64kx100x1-16 172282 19658 ns/op 6669.28 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1102273695 vs 11484885600 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37984->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7386184275 vs 10868687400 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40924->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40666->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 169984 19859 ns/op 6601.64 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 122700240 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40704->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40356->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: 550315820 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43072->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:43022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42518->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: 1727241840 vs 11378612000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:44988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:45696->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: 868209070 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:47366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:47162->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:46986->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: 138693220 vs 11588356000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:49926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:50490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:50096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:49948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:49816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:50260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:50216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:50404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49718->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:50460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:50400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:49818->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5921743 599.1 ns/op 474.02 MB/s Benchmark___BumpPubCount_1x3-16 5918378 601.7 ns/op 471.98 MB/s Benchmark___BumpPubCount_1x3-16 5978794 598.6 ns/op 474.43 MB/s Benchmark___BumpPubCount_1x3-16 5954077 598.9 ns/op 474.21 MB/s Benchmark___BumpPubCount_1x3-16 5938899 599.1 ns/op 474.04 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5657767 633.8 ns/op 448.06 MB/s Benchmark___BumpPubCount_2x3-16 5655818 633.6 ns/op 448.25 MB/s Benchmark___BumpPubCount_2x3-16 5663215 635.8 ns/op 446.67 MB/s Benchmark___BumpPubCount_2x3-16 5609936 632.3 ns/op 449.16 MB/s Benchmark___BumpPubCount_2x3-16 5544734 633.1 ns/op 448.58 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5881431 611.5 ns/op 464.39 MB/s Benchmark___BumpPubCount_5x3-16 5868471 616.8 ns/op 460.45 MB/s Benchmark___BumpPubCount_5x3-16 5439538 613.2 ns/op 463.12 MB/s Benchmark___BumpPubCount_5x3-16 5667739 610.1 ns/op 465.52 MB/s Benchmark___BumpPubCount_5x3-16 5650833 618.3 ns/op 459.33 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5932816 608.8 ns/op 466.49 MB/s Benchmark__BumpPubCount_10x3-16 5926514 607.9 ns/op 467.18 MB/s Benchmark__BumpPubCount_10x3-16 5918067 607.4 ns/op 467.56 MB/s Benchmark__BumpPubCount_10x3-16 5933121 606.6 ns/op 468.18 MB/s Benchmark__BumpPubCount_10x3-16 5875821 610.4 ns/op 465.29 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12290442 275.0 ns/op 3781.84 MB/s Benchmark____GWs_Opt_1kx01x0-16 12805294 276.5 ns/op 3761.02 MB/s Benchmark____GWs_Opt_1kx01x0-16 12449076 271.1 ns/op 3836.57 MB/s Benchmark____GWs_Opt_1kx01x0-16 12333756 275.3 ns/op 3778.11 MB/s Benchmark____GWs_Opt_1kx01x0-16 13168196 285.0 ns/op 3649.09 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10916902 318.2 ns/op 6487.21 MB/s Benchmark____GWs_Opt_2kx01x0-16 11092134 337.0 ns/op 6125.54 MB/s Benchmark____GWs_Opt_2kx01x0-16 10520320 338.1 ns/op 6103.90 MB/s Benchmark____GWs_Opt_2kx01x0-16 10898484 346.7 ns/op 5952.62 MB/s Benchmark____GWs_Opt_2kx01x0-16 10359682 356.3 ns/op 5792.77 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5970042 695.5 ns/op 5912.27 MB/s Benchmark____GWs_Opt_4kx01x0-16 5790873 628.3 ns/op 6545.00 MB/s Benchmark____GWs_Opt_4kx01x0-16 5953882 618.6 ns/op 6647.07 MB/s Benchmark____GWs_Opt_4kx01x0-16 5715183 618.2 ns/op 6651.18 MB/s Benchmark____GWs_Opt_4kx01x0-16 5883121 631.9 ns/op 6507.48 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30668302 111.7 ns/op 9311.46 MB/s Benchmark____GWs_Opt_1kx10x0-16 32175849 110.4 ns/op 9419.79 MB/s Benchmark____GWs_Opt_1kx10x0-16 33027505 113.4 ns/op 9167.27 MB/s Benchmark____GWs_Opt_1kx10x0-16 28483783 109.2 ns/op 9527.84 MB/s Benchmark____GWs_Opt_1kx10x0-16 32724946 116.6 ns/op 8922.44 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25212204 142.4 ns/op 14492.78 MB/s Benchmark____GWs_Opt_2kx10x0-16 25769245 152.3 ns/op 13555.74 MB/s Benchmark____GWs_Opt_2kx10x0-16 24124698 148.8 ns/op 13875.56 MB/s Benchmark____GWs_Opt_2kx10x0-16 23400492 155.3 ns/op 13287.25 MB/s Benchmark____GWs_Opt_2kx10x0-16 25572918 140.8 ns/op 14662.86 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 10630996 342.2 ns/op 12017.60 MB/s Benchmark____GWs_Opt_4kx10x0-16 10736835 341.2 ns/op 12052.09 MB/s Benchmark____GWs_Opt_4kx10x0-16 12512317 299.0 ns/op 13750.34 MB/s Benchmark____GWs_Opt_4kx10x0-16 13158032 306.1 ns/op 13434.34 MB/s Benchmark____GWs_Opt_4kx10x0-16 12234300 310.7 ns/op 13236.55 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6296508 557.2 ns/op 5607.95 MB/s Benchmark____GWs_Opt_1kx01x1-16 6213446 558.9 ns/op 5591.73 MB/s Benchmark____GWs_Opt_1kx01x1-16 6241521 568.8 ns/op 5493.55 MB/s Benchmark____GWs_Opt_1kx01x1-16 6399638 565.4 ns/op 5527.11 MB/s Benchmark____GWs_Opt_1kx01x1-16 6301251 559.9 ns/op 5580.87 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4364263 811.1 ns/op 7640.02 MB/s Benchmark____GWs_Opt_2kx01x1-16 4204989 797.8 ns/op 7768.08 MB/s Benchmark____GWs_Opt_2kx01x1-16 4446751 1101 ns/op 5626.72 MB/s Benchmark____GWs_Opt_2kx01x1-16 4274028 796.3 ns/op 7782.23 MB/s Benchmark____GWs_Opt_2kx01x1-16 4047192 867.4 ns/op 7144.11 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2593411 1406 ns/op 8777.79 MB/s Benchmark____GWs_Opt_4kx01x1-16 2532241 1431 ns/op 8621.29 MB/s Benchmark____GWs_Opt_4kx01x1-16 2598720 1386 ns/op 8901.08 MB/s Benchmark____GWs_Opt_4kx01x1-16 2524587 1392 ns/op 8868.24 MB/s Benchmark____GWs_Opt_4kx01x1-16 2571133 1414 ns/op 8725.95 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 5663182 571.8 ns/op 5465.15 MB/s Benchmark____GWs_Opt_1kx10x1-16 5843130 572.2 ns/op 5461.66 MB/s Benchmark____GWs_Opt_1kx10x1-16 5960493 573.4 ns/op 5450.23 MB/s Benchmark____GWs_Opt_1kx10x1-16 5908226 574.7 ns/op 5437.81 MB/s Benchmark____GWs_Opt_1kx10x1-16 5937580 589.4 ns/op 5301.70 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4043223 865.4 ns/op 7160.74 MB/s Benchmark____GWs_Opt_2kx10x1-16 4024294 861.4 ns/op 7193.72 MB/s Benchmark____GWs_Opt_2kx10x1-16 4031946 867.0 ns/op 7147.82 MB/s Benchmark____GWs_Opt_2kx10x1-16 4096742 874.0 ns/op 7090.11 MB/s Benchmark____GWs_Opt_2kx10x1-16 3979758 870.6 ns/op 7118.01 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2218731 1552 ns/op 7950.67 MB/s Benchmark____GWs_Opt_4kx10x1-16 2364123 1550 ns/op 7962.67 MB/s Benchmark____GWs_Opt_4kx10x1-16 2293006 1565 ns/op 7886.82 MB/s Benchmark____GWs_Opt_4kx10x1-16 2322422 1539 ns/op 8019.55 MB/s Benchmark____GWs_Opt_4kx10x1-16 2269732 1552 ns/op 7954.15 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11731030 297.2 ns/op 3499.59 MB/s Benchmark____GWs_Int_1kx01x0-16 12304837 287.2 ns/op 3621.72 MB/s Benchmark____GWs_Int_1kx01x0-16 12573114 287.8 ns/op 3613.81 MB/s Benchmark____GWs_Int_1kx01x0-16 12219801 284.8 ns/op 3651.82 MB/s Benchmark____GWs_Int_1kx01x0-16 12269934 314.8 ns/op 3303.63 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9156795 343.3 ns/op 6011.79 MB/s Benchmark____GWs_Int_2kx01x0-16 8684641 359.0 ns/op 5749.64 MB/s Benchmark____GWs_Int_2kx01x0-16 10114766 355.8 ns/op 5801.67 MB/s Benchmark____GWs_Int_2kx01x0-16 9904456 355.9 ns/op 5799.02 MB/s Benchmark____GWs_Int_2kx01x0-16 9878238 347.9 ns/op 5933.57 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5642067 622.4 ns/op 6606.84 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:50726->127.0.0.1:38287: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx01x0-16 Benchmark____GWs_Int_4kx01x0-16 5633422 641.4 ns/op 6410.87 MB/s Benchmark____GWs_Int_4kx01x0-16 5643921 635.1 ns/op 6474.19 MB/s Benchmark____GWs_Int_4kx01x0-16 5774258 633.6 ns/op 6489.43 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32210547 113.1 ns/op 9193.94 MB/s Benchmark____GWs_Int_1kx10x0-16 32562386 121.1 ns/op 8588.27 MB/s Benchmark____GWs_Int_1kx10x0-16 32594636 118.2 ns/op 8797.81 MB/s Benchmark____GWs_Int_1kx10x0-16 32641680 112.5 ns/op 9246.00 MB/s Benchmark____GWs_Int_1kx10x0-16 32751619 113.2 ns/op 9186.55 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 22635018 137.8 ns/op 14975.47 MB/s Benchmark____GWs_Int_2kx10x0-16 20847130 149.9 ns/op 13773.57 MB/s Benchmark____GWs_Int_2kx10x0-16 24516465 160.3 ns/op 12875.52 MB/s Benchmark____GWs_Int_2kx10x0-16 26387308 148.3 ns/op 13920.05 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:59506->127.0.0.1:34125: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13171970 315.8 ns/op 13020.97 MB/s Benchmark____GWs_Int_4kx10x0-16 13171420 278.5 ns/op 14765.42 MB/s Benchmark____GWs_Int_4kx10x0-16 11553151 341.6 ns/op 12039.17 MB/s Benchmark____GWs_Int_4kx10x0-16 12616485 312.7 ns/op 13148.33 MB/s Benchmark____GWs_Int_4kx10x0-16 12649669 280.1 ns/op 14680.35 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6353294 576.2 ns/op 5423.64 MB/s Benchmark____GWs_Int_1kx01x1-16 6266546 581.8 ns/op 5371.31 MB/s Benchmark____GWs_Int_1kx01x1-16 6281014 583.2 ns/op 5358.05 MB/s Benchmark____GWs_Int_1kx01x1-16 6245889 578.1 ns/op 5405.70 MB/s Benchmark____GWs_Int_1kx01x1-16 6280894 573.8 ns/op 5445.97 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4160847 807.3 ns/op 7676.23 MB/s Benchmark____GWs_Int_2kx01x1-16 4546917 804.6 ns/op 7702.30 MB/s Benchmark____GWs_Int_2kx01x1-16 4179912 806.0 ns/op 7688.68 MB/s Benchmark____GWs_Int_2kx01x1-16 4142391 1076 ns/op 5761.54 MB/s Benchmark____GWs_Int_2kx01x1-16 4542219 798.4 ns/op 7761.39 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2564912 1460 ns/op 8452.38 MB/s Benchmark____GWs_Int_4kx01x1-16 2554156 1500 ns/op 8226.07 MB/s Benchmark____GWs_Int_4kx01x1-16 2551506 1410 ns/op 8749.40 MB/s Benchmark____GWs_Int_4kx01x1-16 2585342 1793 ns/op 6881.58 MB/s Benchmark____GWs_Int_4kx01x1-16 2529807 1394 ns/op 8850.32 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 5922474 582.2 ns/op 5367.64 MB/s Benchmark____GWs_Int_1kx10x1-16 5940248 576.8 ns/op 5417.65 MB/s Benchmark____GWs_Int_1kx10x1-16 5967242 585.3 ns/op 5339.17 MB/s Benchmark____GWs_Int_1kx10x1-16 5859466 582.7 ns/op 5362.59 MB/s Benchmark____GWs_Int_1kx10x1-16 5919277 591.6 ns/op 5282.65 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4003459 875.8 ns/op 7075.69 MB/s Benchmark____GWs_Int_2kx10x1-16 4093836 868.7 ns/op 7133.60 MB/s Benchmark____GWs_Int_2kx10x1-16 4055154 874.5 ns/op 7086.48 MB/s Benchmark____GWs_Int_2kx10x1-16 3985818 866.2 ns/op 7154.25 MB/s Benchmark____GWs_Int_2kx10x1-16 3880314 920.3 ns/op 6733.36 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2324413 1619 ns/op 7623.29 MB/s Benchmark____GWs_Int_4kx10x1-16 2116297 1550 ns/op 7960.57 MB/s Benchmark____GWs_Int_4kx10x1-16 2315959 1660 ns/op 7432.78 MB/s Benchmark____GWs_Int_4kx10x1-16 2282324 1550 ns/op 7959.43 MB/s Benchmark____GWs_Int_4kx10x1-16 2309384 1540 ns/op 8011.49 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 7802443 445.2 ns/op 229.10 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7910556 450.5 ns/op 226.40 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7679751 449.1 ns/op 227.12 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8031255 450.6 ns/op 226.39 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7747653 447.7 ns/op 227.81 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 661600 4679 ns/op 37.83 MB/s Benchmark__GWs_Reqs_1SubEach-16 922705 4814 ns/op 36.77 MB/s Benchmark__GWs_Reqs_1SubEach-16 806668 4902 ns/op 36.11 MB/s Benchmark__GWs_Reqs_1SubEach-16 794258 4995 ns/op 35.44 MB/s Benchmark__GWs_Reqs_1SubEach-16 838467 4988 ns/op 35.48 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2136.703s ❌ Non-zero exit code: 1