> ROOT_DIR=/tmp/go-bench-away-job-1f6799ba-9052-41cf-be0e-96fb751b8950-4215192228 > OUTPUT_FILE=/tmp/go-bench-away-job-1f6799ba-9052-41cf-be0e-96fb751b8950-4215192228/results.txt > SHA_FILE=/tmp/go-bench-away-job-1f6799ba-9052-41cf-be0e-96fb751b8950-4215192228/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-1f6799ba-9052-41cf-be0e-96fb751b8950-4215192228/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-1f6799ba-9052-41cf-be0e-96fb751b8950-4215192228/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-build2533629933=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-1f6799ba-9052-41cf-be0e-96fb751b8950-4215192228/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 54576220 66.09 ns/op 166.43 MB/s Benchmark______Pub0b_Payload-16 51679580 65.74 ns/op 167.33 MB/s Benchmark______Pub0b_Payload-16 51453898 65.72 ns/op 167.36 MB/s Benchmark______Pub0b_Payload-16 47472649 65.76 ns/op 167.27 MB/s Benchmark______Pub0b_Payload-16 51557031 65.67 ns/op 167.50 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 54213087 66.45 ns/op 285.95 MB/s Benchmark______Pub8b_Payload-16 51183511 66.37 ns/op 286.28 MB/s Benchmark______Pub8b_Payload-16 54301042 66.20 ns/op 286.99 MB/s Benchmark______Pub8b_Payload-16 50625673 66.81 ns/op 284.40 MB/s Benchmark______Pub8b_Payload-16 54196818 66.69 ns/op 284.91 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 47306509 70.81 ns/op 621.41 MB/s Benchmark_____Pub32b_Payload-16 44937289 71.42 ns/op 616.08 MB/s Benchmark_____Pub32b_Payload-16 48061968 71.11 ns/op 618.77 MB/s Benchmark_____Pub32b_Payload-16 47645523 70.87 ns/op 620.87 MB/s Benchmark_____Pub32b_Payload-16 47633236 75.68 ns/op 581.38 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 41917395 80.26 ns/op 1756.76 MB/s Benchmark____Pub128B_Payload-16 41838948 80.37 ns/op 1754.28 MB/s Benchmark____Pub128B_Payload-16 44846076 80.70 ns/op 1747.30 MB/s Benchmark____Pub128B_Payload-16 43004661 84.57 ns/op 1667.29 MB/s Benchmark____Pub128B_Payload-16 42341701 80.26 ns/op 1756.80 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 39012213 87.46 ns/op 3075.82 MB/s Benchmark____Pub256B_Payload-16 38115597 89.70 ns/op 2998.77 MB/s Benchmark____Pub256B_Payload-16 38403655 90.30 ns/op 2978.85 MB/s Benchmark____Pub256B_Payload-16 40058011 88.48 ns/op 3040.37 MB/s Benchmark____Pub256B_Payload-16 38378401 89.11 ns/op 3018.77 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 27547131 134.9 ns/op 7693.46 MB/s Benchmark______Pub1K_Payload-16 25435610 133.5 ns/op 7776.97 MB/s Benchmark______Pub1K_Payload-16 24831661 147.7 ns/op 7027.43 MB/s Benchmark______Pub1K_Payload-16 22077970 150.2 ns/op 6912.80 MB/s Benchmark______Pub1K_Payload-16 24725623 136.5 ns/op 7601.62 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5552431 620.9 ns/op 6619.07 MB/s Benchmark______Pub4K_Payload-16 5454692 621.5 ns/op 6612.63 MB/s Benchmark______Pub4K_Payload-16 5953585 618.3 ns/op 6646.84 MB/s Benchmark______Pub4K_Payload-16 5164100 635.6 ns/op 6466.07 MB/s Benchmark______Pub4K_Payload-16 5450984 621.6 ns/op 6612.14 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2740383 1282 ns/op 6403.22 MB/s Benchmark______Pub8K_Payload-16 2673723 1318 ns/op 6228.33 MB/s Benchmark______Pub8K_Payload-16 2728056 1279 ns/op 6417.84 MB/s Benchmark______Pub8K_Payload-16 2824028 1276 ns/op 6430.43 MB/s Benchmark______Pub8K_Payload-16 2788164 1270 ns/op 6463.17 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 472633 7456 ns/op 4396.94 MB/s Benchmark_____Pub32K_Payload-16 676149 5537 ns/op 5920.98 MB/s Benchmark_____Pub32K_Payload-16 661840 5426 ns/op 6041.82 MB/s Benchmark_____Pub32K_Payload-16 559080 5404 ns/op 6066.20 MB/s Benchmark_____Pub32K_Payload-16 582097 5540 ns/op 5918.00 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 41535506 87.83 ns/op 125.25 MB/s Benchmark__AuthPub0b_Payload-16 34588381 86.79 ns/op 126.74 MB/s Benchmark__AuthPub0b_Payload-16 36459812 87.07 ns/op 126.33 MB/s Benchmark__AuthPub0b_Payload-16 39601077 86.80 ns/op 126.73 MB/s Benchmark__AuthPub0b_Payload-16 34474778 88.13 ns/op 124.82 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 17022334 209.0 ns/op Benchmark_____________PubSub-16 17006532 209.2 ns/op Benchmark_____________PubSub-16 16723857 208.9 ns/op Benchmark_____________PubSub-16 16556190 209.7 ns/op Benchmark_____________PubSub-16 16944934 209.6 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 16902243 208.1 ns/op Benchmark_____PubSubTwoConns-16 17224130 208.1 ns/op Benchmark_____PubSubTwoConns-16 16819900 208.5 ns/op Benchmark_____PubSubTwoConns-16 16721352 207.8 ns/op Benchmark_____PubSubTwoConns-16 17002989 208.3 ns/op Benchmark__PubServiceImports bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:49748->127.0.0.1:44383: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:51902->127.0.0.1:32911: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:57546->127.0.0.1:36677: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:42164->127.0.0.1:42333: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:34402->127.0.0.1:40641: 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 15686707 226.7 ns/op Benchmark_____PubTwoQueueSub-16 15576873 227.4 ns/op Benchmark_____PubTwoQueueSub-16 15610461 226.9 ns/op Benchmark_____PubTwoQueueSub-16 15611362 227.1 ns/op Benchmark_____PubTwoQueueSub-16 15667082 227.3 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15670764 227.1 ns/op Benchmark____PubFourQueueSub-16 15372724 226.4 ns/op Benchmark____PubFourQueueSub-16 15706406 227.4 ns/op Benchmark____PubFourQueueSub-16 15595431 226.2 ns/op Benchmark____PubFourQueueSub-16 15601962 227.5 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15810126 226.8 ns/op Benchmark___PubEightQueueSub-16 15527575 227.0 ns/op Benchmark___PubEightQueueSub-16 15693380 228.2 ns/op Benchmark___PubEightQueueSub-16 15674492 227.0 ns/op Benchmark___PubEightQueueSub-16 15562903 227.3 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22321 155167 ns/op Benchmark_PubSub512kTwoConns-16 23091 155188 ns/op Benchmark_PubSub512kTwoConns-16 23480 154958 ns/op Benchmark_PubSub512kTwoConns-16 22894 155148 ns/op Benchmark_PubSub512kTwoConns-16 23224 156361 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16656442 210.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 16552651 210.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 16429123 212.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 16671988 210.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 16348048 212.7 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16252636 211.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 16279737 212.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 16218489 212.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 16428850 212.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 16227932 212.2 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 12574412 283.0 ns/op Benchmark____RoutedPubSub_0b-16 12386119 283.5 ns/op Benchmark____RoutedPubSub_0b-16 12595725 285.9 ns/op Benchmark____RoutedPubSub_0b-16 12508244 290.4 ns/op Benchmark____RoutedPubSub_0b-16 12346724 283.6 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6875738 504.1 ns/op Benchmark____RoutedPubSub_1K-16 6797384 519.3 ns/op Benchmark____RoutedPubSub_1K-16 6678224 509.3 ns/op Benchmark____RoutedPubSub_1K-16 7049672 518.3 ns/op Benchmark____RoutedPubSub_1K-16 6881096 507.1 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 73506 43935 ns/op Benchmark__RoutedPubSub_100K-16 80544 42800 ns/op Benchmark__RoutedPubSub_100K-16 84787 45765 ns/op Benchmark__RoutedPubSub_100K-16 77001 46851 ns/op Benchmark__RoutedPubSub_100K-16 77487 45898 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 10460758 339.3 ns/op Benchmark____Routed2QueueSub-16 10578262 341.0 ns/op Benchmark____Routed2QueueSub-16 10509486 335.9 ns/op Benchmark____Routed2QueueSub-16 10663548 341.5 ns/op Benchmark____Routed2QueueSub-16 10456293 332.5 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 10637827 340.9 ns/op Benchmark____Routed4QueueSub-16 8612248 351.9 ns/op Benchmark____Routed4QueueSub-16 10499620 344.2 ns/op Benchmark____Routed4QueueSub-16 10561394 337.8 ns/op Benchmark____Routed4QueueSub-16 10358770 347.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 10135491 349.8 ns/op Benchmark____Routed8QueueSub-16 10219995 354.1 ns/op Benchmark____Routed8QueueSub-16 10022586 348.8 ns/op Benchmark____Routed8QueueSub-16 10337178 350.5 ns/op Benchmark____Routed8QueueSub-16 10344039 348.6 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8159623 375.8 ns/op Benchmark___Routed16QueueSub-16 9700929 370.2 ns/op Benchmark___Routed16QueueSub-16 8140044 375.5 ns/op Benchmark___Routed16QueueSub-16 8116020 370.3 ns/op Benchmark___Routed16QueueSub-16 9797256 372.2 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 7075755 464.3 ns/op Benchmark____________RouteCompressOff-16 6680779 472.2 ns/op Benchmark____________RouteCompressOff-16 6819949 472.5 ns/op Benchmark____________RouteCompressOff-16 6994839 470.8 ns/op Benchmark____________RouteCompressOff-16 6884673 469.6 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 7164812 466.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 7117790 467.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6862641 466.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 7034151 468.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6827370 461.0 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 7117477 466.3 ns/op Benchmark_________RouteCompressS2Fast-16 7124344 471.6 ns/op Benchmark_________RouteCompressS2Fast-16 6848463 462.4 ns/op Benchmark_________RouteCompressS2Fast-16 7200529 471.8 ns/op Benchmark_________RouteCompressS2Fast-16 6945297 462.2 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 7077802 464.6 ns/op Benchmark_______RouteCompressS2Better-16 6819430 463.3 ns/op Benchmark_______RouteCompressS2Better-16 6915082 465.3 ns/op Benchmark_______RouteCompressS2Better-16 6805190 467.7 ns/op Benchmark_______RouteCompressS2Better-16 6694195 473.4 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6841548 466.7 ns/op Benchmark_________RouteCompressS2Best-16 6739118 471.7 ns/op Benchmark_________RouteCompressS2Best-16 7261113 469.6 ns/op Benchmark_________RouteCompressS2Best-16 7372176 463.8 ns/op Benchmark_________RouteCompressS2Best-16 7256403 469.1 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5098992 701.4 ns/op 354.98 MB/s Benchmark______FanOut_8x1x10-16 5142946 699.9 ns/op 355.77 MB/s Benchmark______FanOut_8x1x10-16 5113669 698.1 ns/op 356.68 MB/s Benchmark______FanOut_8x1x10-16 5107276 698.4 ns/op 356.54 MB/s Benchmark______FanOut_8x1x10-16 5125170 697.5 ns/op 356.99 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 626860 5506 ns/op 421.14 MB/s Benchmark_____FanOut_8x1x100-16 604822 5484 ns/op 422.86 MB/s Benchmark_____FanOut_8x1x100-16 582670 5528 ns/op 419.47 MB/s Benchmark_____FanOut_8x1x100-16 637956 5494 ns/op 422.12 MB/s Benchmark_____FanOut_8x1x100-16 607470 5480 ns/op 423.17 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 52884 67912 ns/op 338.95 MB/s Benchmark____FanOut_8x10x100-16 53084 67939 ns/op 338.82 MB/s Benchmark____FanOut_8x10x100-16 52468 69192 ns/op 332.68 MB/s Benchmark____FanOut_8x10x100-16 52915 68506 ns/op 336.02 MB/s Benchmark____FanOut_8x10x100-16 52849 67690 ns/op 340.07 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6423 538531 ns/op 445.69 MB/s Benchmark___FanOut_8x10x1000-16 6619 540160 ns/op 444.35 MB/s Benchmark___FanOut_8x10x1000-16 6747 535690 ns/op 448.06 MB/s Benchmark___FanOut_8x10x1000-16 6513 537492 ns/op 446.55 MB/s Benchmark___FanOut_8x10x1000-16 6554 533972 ns/op 449.50 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5485 634771 ns/op 362.37 MB/s Benchmark___FanOut_8x100x100-16 5572 635512 ns/op 361.94 MB/s Benchmark___FanOut_8x100x100-16 5510 633741 ns/op 362.95 MB/s Benchmark___FanOut_8x100x100-16 5505 635772 ns/op 361.79 MB/s Benchmark___FanOut_8x100x100-16 5509 634163 ns/op 362.71 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 648 5507150 ns/op 435.80 MB/s Benchmark__FanOut_8x100x1000-16 655 5600101 ns/op 428.57 MB/s Benchmark__FanOut_8x100x1000-16 642 5466714 ns/op 439.02 MB/s Benchmark__FanOut_8x100x1000-16 628 5595680 ns/op 428.91 MB/s Benchmark__FanOut_8x100x1000-16 656 5544489 ns/op 432.87 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 610 5850059 ns/op 427.35 MB/s Benchmark__FanOut_8x10x10000-16 603 5833127 ns/op 428.59 MB/s Benchmark__FanOut_8x10x10000-16 612 5933438 ns/op 421.34 MB/s Benchmark__FanOut_8x10x10000-16 607 5912921 ns/op 422.81 MB/s Benchmark__FanOut_8x10x10000-16 614 5966427 ns/op 419.01 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1042 3405528 ns/op 337.69 MB/s Benchmark___FanOut_8x500x100-16 1034 3414654 ns/op 336.79 MB/s Benchmark___FanOut_8x500x100-16 1032 3409008 ns/op 337.35 MB/s Benchmark___FanOut_8x500x100-16 1042 3414177 ns/op 336.84 MB/s Benchmark___FanOut_8x500x100-16 1040 3407975 ns/op 337.45 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 370886 8961 ns/op 1633.85 MB/s Benchmark___FanOut_128x1x100-16 382350 8945 ns/op 1636.69 MB/s Benchmark___FanOut_128x1x100-16 364933 8932 ns/op 1639.09 MB/s Benchmark___FanOut_128x1x100-16 379123 8921 ns/op 1641.13 MB/s Benchmark___FanOut_128x1x100-16 380970 8939 ns/op 1637.92 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 35068 102226 ns/op 1419.81 MB/s Benchmark__FanOut_128x10x100-16 35262 102947 ns/op 1409.86 MB/s Benchmark__FanOut_128x10x100-16 34939 102919 ns/op 1410.24 MB/s Benchmark__FanOut_128x10x100-16 34809 102868 ns/op 1410.94 MB/s Benchmark__FanOut_128x10x100-16 34954 102804 ns/op 1411.82 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4255 796528 ns/op 1833.13 MB/s Benchmark_FanOut_128x10x1000-16 4526 801609 ns/op 1821.51 MB/s Benchmark_FanOut_128x10x1000-16 4239 798578 ns/op 1828.43 MB/s Benchmark_FanOut_128x10x1000-16 4538 797105 ns/op 1831.81 MB/s Benchmark_FanOut_128x10x1000-16 4388 799306 ns/op 1826.76 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3756 943127 ns/op 1537.59 MB/s Benchmark_FanOut_128x100x100-16 3736 948881 ns/op 1528.26 MB/s Benchmark_FanOut_128x100x100-16 3764 952020 ns/op 1523.23 MB/s Benchmark_FanOut_128x100x100-16 3705 948727 ns/op 1528.51 MB/s Benchmark_FanOut_128x100x100-16 3736 942288 ns/op 1538.96 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 427 8436820 ns/op 1730.53 MB/s BenchmarkFanOut_128x100x1000-16 417 8517229 ns/op 1714.19 MB/s BenchmarkFanOut_128x100x1000-16 415 8553430 ns/op 1706.93 MB/s BenchmarkFanOut_128x100x1000-16 415 8357034 ns/op 1747.05 MB/s BenchmarkFanOut_128x100x1000-16 418 8501837 ns/op 1717.29 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 400 8841825 ns/op 1662.57 MB/s BenchmarkFanOut_128x10x10000-16 408 8820374 ns/op 1666.61 MB/s BenchmarkFanOut_128x10x10000-16 403 8851585 ns/op 1660.74 MB/s BenchmarkFanOut_128x10x10000-16 405 8821356 ns/op 1666.43 MB/s BenchmarkFanOut_128x10x10000-16 403 8883244 ns/op 1654.82 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 717 4989910 ns/op 1452.96 MB/s BenchmarkFanOut__128x500x100-16 704 5012166 ns/op 1446.51 MB/s BenchmarkFanOut__128x500x100-16 693 4985501 ns/op 1454.25 MB/s BenchmarkFanOut__128x500x100-16 712 4996308 ns/op 1451.10 MB/s BenchmarkFanOut__128x500x100-16 706 4978271 ns/op 1456.36 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 2019 1777096 ns/op 2977.06 MB/s Benchmark_FanOut_512x100x100-16 1996 1780906 ns/op 2970.69 MB/s Benchmark_FanOut_512x100x100-16 2011 1772680 ns/op 2984.48 MB/s Benchmark_FanOut_512x100x100-16 1987 1764718 ns/op 2997.94 MB/s Benchmark_FanOut_512x100x100-16 2012 1752536 ns/op 3018.78 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 223 15899877 ns/op 3333.39 MB/s Benchmark__FanOut_512x100x1k-16 222 15960609 ns/op 3320.71 MB/s Benchmark__FanOut_512x100x1k-16 223 15953837 ns/op 3322.12 MB/s Benchmark__FanOut_512x100x1k-16 225 16096648 ns/op 3292.64 MB/s Benchmark__FanOut_512x100x1k-16 228 15835776 ns/op 3346.89 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3097 1097991 ns/op 9500.11 MB/s Benchmark____FanOut_1kx10x1k-16 3106 1099678 ns/op 9485.54 MB/s Benchmark____FanOut_1kx10x1k-16 2962 1108340 ns/op 9411.41 MB/s Benchmark____FanOut_1kx10x1k-16 3325 1111455 ns/op 9385.03 MB/s Benchmark____FanOut_1kx10x1k-16 2824 1117480 ns/op 9334.43 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2942 1193444 ns/op 8731.90 MB/s Benchmark__FanOut_1kx100x100-16 2912 1198729 ns/op 8693.41 MB/s Benchmark__FanOut_1kx100x100-16 2864 1191558 ns/op 8745.73 MB/s Benchmark__FanOut_1kx100x100-16 2905 1191713 ns/op 8744.59 MB/s Benchmark__FanOut_1kx100x100-16 2925 1188270 ns/op 8769.92 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4590496 741.2 ns/op 335.96 MB/s Benchmark_____RFanOut_8x1x10-16 4528922 743.5 ns/op 334.91 MB/s Benchmark_____RFanOut_8x1x10-16 4667877 748.0 ns/op 332.88 MB/s Benchmark_____RFanOut_8x1x10-16 4833466 751.2 ns/op 331.48 MB/s Benchmark_____RFanOut_8x1x10-16 4656658 751.2 ns/op 331.46 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 599300 5534 ns/op 419.04 MB/s Benchmark____RFanOut_8x1x100-16 579229 5524 ns/op 419.82 MB/s Benchmark____RFanOut_8x1x100-16 593770 5501 ns/op 421.56 MB/s Benchmark____RFanOut_8x1x100-16 592972 5550 ns/op 417.82 MB/s Benchmark____RFanOut_8x1x100-16 575805 5521 ns/op 420.02 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 53119 67856 ns/op 339.23 MB/s Benchmark___RFanOut_8x10x100-16 53096 67719 ns/op 339.92 MB/s Benchmark___RFanOut_8x10x100-16 53070 67827 ns/op 339.38 MB/s Benchmark___RFanOut_8x10x100-16 53059 69194 ns/op 332.67 MB/s Benchmark___RFanOut_8x10x100-16 52688 67616 ns/op 340.44 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6302 543078 ns/op 441.96 MB/s Benchmark__RFanOut_8x10x1000-16 6535 549614 ns/op 436.70 MB/s Benchmark__RFanOut_8x10x1000-16 6516 538303 ns/op 445.88 MB/s Benchmark__RFanOut_8x10x1000-16 6520 537932 ns/op 446.19 MB/s Benchmark__RFanOut_8x10x1000-16 6734 534485 ns/op 449.07 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5551 634473 ns/op 362.54 MB/s Benchmark__RFanOut_8x100x100-16 5590 632148 ns/op 363.87 MB/s Benchmark__RFanOut_8x100x100-16 5564 635713 ns/op 361.83 MB/s Benchmark__RFanOut_8x100x100-16 5572 653479 ns/op 351.99 MB/s Benchmark__RFanOut_8x100x100-16 5574 632841 ns/op 363.47 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 626 5547403 ns/op 432.64 MB/s Benchmark_RFanOut_8x100x1000-16 627 5523879 ns/op 434.48 MB/s Benchmark_RFanOut_8x100x1000-16 662 5496177 ns/op 436.67 MB/s Benchmark_RFanOut_8x100x1000-16 622 5637878 ns/op 425.70 MB/s Benchmark_RFanOut_8x100x1000-16 642 5547846 ns/op 432.60 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 618 5901387 ns/op 423.63 MB/s Benchmark_RFanOut_8x10x10000-16 579 5892981 ns/op 424.24 MB/s Benchmark_RFanOut_8x10x10000-16 585 5878728 ns/op 425.27 MB/s Benchmark_RFanOut_8x10x10000-16 583 6087708 ns/op 410.67 MB/s Benchmark_RFanOut_8x10x10000-16 609 5943930 ns/op 420.60 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2905 1115660 ns/op 9349.65 MB/s Benchmark_RFanOut_1kx10x1000-16 2944 1111304 ns/op 9386.30 MB/s Benchmark_RFanOut_1kx10x1000-16 3487 1102415 ns/op 9461.99 MB/s Benchmark_RFanOut_1kx10x1000-16 3042 1108854 ns/op 9407.05 MB/s Benchmark_RFanOut_1kx10x1000-16 2860 1114450 ns/op 9359.81 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7221724 487.3 ns/op 4263.94 MB/s Benchmark_____FanIn_1kx100x1-16 7223035 486.4 ns/op 4272.34 MB/s Benchmark_____FanIn_1kx100x1-16 7171023 484.7 ns/op 4287.46 MB/s Benchmark_____FanIn_1kx100x1-16 7133697 485.3 ns/op 4281.59 MB/s Benchmark_____FanIn_1kx100x1-16 7212904 488.0 ns/op 4258.63 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2690599 1331 ns/op 6178.23 MB/s Benchmark_____FanIn_4kx100x1-16 2692244 1341 ns/op 6132.94 MB/s Benchmark_____FanIn_4kx100x1-16 2600610 1327 ns/op 6195.58 MB/s Benchmark_____FanIn_4kx100x1-16 2597065 1348 ns/op 6099.82 MB/s Benchmark_____FanIn_4kx100x1-16 2691292 1343 ns/op 6119.86 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1712931 2126 ns/op 7719.06 MB/s Benchmark_____FanIn_8kx100x1-16 1689769 2086 ns/op 7868.26 MB/s Benchmark_____FanIn_8kx100x1-16 1710819 2100 ns/op 7815.57 MB/s Benchmark_____FanIn_8kx100x1-16 1648812 2066 ns/op 7946.54 MB/s Benchmark_____FanIn_8kx100x1-16 1756066 2079 ns/op 7895.17 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 874051 4085 ns/op 8028.79 MB/s Benchmark____FanIn_16kx100x1-16 883694 4142 ns/op 7919.23 MB/s Benchmark____FanIn_16kx100x1-16 876313 4126 ns/op 7948.69 MB/s Benchmark____FanIn_16kx100x1-16 889360 4168 ns/op 7870.19 MB/s Benchmark____FanIn_16kx100x1-16 881083 4145 ns/op 7912.70 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 165259 19897 ns/op 6589.10 MB/s Benchmark____FanIn_64kx100x1-16 167808 19912 ns/op 6584.03 MB/s Benchmark____FanIn_64kx100x1-16 174894 19779 ns/op 6628.28 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 423406827 vs 10868687400 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:50948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:51618->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: 1519387434 vs 11203007700 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:53788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:54338->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 957874630 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:55886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:56004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:56114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:55742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:56264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:56240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:55724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:55534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:55766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:55708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:55996->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: 185754530 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:57994->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: 126239670 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59288->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: 673540420 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33506->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: 444264010 vs 11168868000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35980->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5994830 591.7 ns/op 480.00 MB/s Benchmark___BumpPubCount_1x3-16 6016718 590.4 ns/op 481.00 MB/s Benchmark___BumpPubCount_1x3-16 6031866 588.5 ns/op 482.58 MB/s Benchmark___BumpPubCount_1x3-16 6070262 589.7 ns/op 481.59 MB/s Benchmark___BumpPubCount_1x3-16 5996808 592.8 ns/op 479.05 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5717785 631.3 ns/op 449.85 MB/s Benchmark___BumpPubCount_2x3-16 5733009 632.1 ns/op 449.33 MB/s Benchmark___BumpPubCount_2x3-16 5714133 627.1 ns/op 452.88 MB/s Benchmark___BumpPubCount_2x3-16 5746905 629.3 ns/op 451.33 MB/s Benchmark___BumpPubCount_2x3-16 5686794 626.6 ns/op 453.27 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5663245 609.4 ns/op 465.99 MB/s Benchmark___BumpPubCount_5x3-16 5845910 611.9 ns/op 464.12 MB/s Benchmark___BumpPubCount_5x3-16 5398831 613.7 ns/op 462.73 MB/s Benchmark___BumpPubCount_5x3-16 5866530 611.3 ns/op 464.58 MB/s Benchmark___BumpPubCount_5x3-16 5032660 609.3 ns/op 466.10 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5924475 613.0 ns/op 463.32 MB/s Benchmark__BumpPubCount_10x3-16 5903989 611.4 ns/op 464.52 MB/s Benchmark__BumpPubCount_10x3-16 5923075 606.8 ns/op 468.00 MB/s Benchmark__BumpPubCount_10x3-16 5907584 605.5 ns/op 469.05 MB/s Benchmark__BumpPubCount_10x3-16 5919378 606.7 ns/op 468.08 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12350647 279.3 ns/op 3723.86 MB/s Benchmark____GWs_Opt_1kx01x0-16 13231759 287.0 ns/op 3624.21 MB/s Benchmark____GWs_Opt_1kx01x0-16 12725403 281.6 ns/op 3693.34 MB/s Benchmark____GWs_Opt_1kx01x0-16 12435889 264.0 ns/op 3939.44 MB/s Benchmark____GWs_Opt_1kx01x0-16 12734114 263.8 ns/op 3942.67 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10580131 332.3 ns/op 6211.92 MB/s Benchmark____GWs_Opt_2kx01x0-16 9861272 323.4 ns/op 6382.37 MB/s Benchmark____GWs_Opt_2kx01x0-16 10533644 341.1 ns/op 6050.79 MB/s Benchmark____GWs_Opt_2kx01x0-16 9120201 349.3 ns/op 5909.12 MB/s Benchmark____GWs_Opt_2kx01x0-16 10342972 340.6 ns/op 6059.53 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5505889 769.4 ns/op 5344.27 MB/s Benchmark____GWs_Opt_4kx01x0-16 5659221 685.0 ns/op 6002.66 MB/s Benchmark____GWs_Opt_4kx01x0-16 5833156 613.7 ns/op 6700.17 MB/s Benchmark____GWs_Opt_4kx01x0-16 5792331 603.0 ns/op 6819.42 MB/s Benchmark____GWs_Opt_4kx01x0-16 5818966 634.4 ns/op 6481.31 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30977284 112.6 ns/op 9240.18 MB/s Benchmark____GWs_Opt_1kx10x0-16 31717110 135.3 ns/op 7684.79 MB/s Benchmark____GWs_Opt_1kx10x0-16 30836095 112.9 ns/op 9211.24 MB/s Benchmark____GWs_Opt_1kx10x0-16 32923008 120.5 ns/op 8632.97 MB/s Benchmark____GWs_Opt_1kx10x0-16 30580868 111.6 ns/op 9320.95 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25388275 142.0 ns/op 14532.94 MB/s Benchmark____GWs_Opt_2kx10x0-16 23107694 151.9 ns/op 13586.50 MB/s Benchmark____GWs_Opt_2kx10x0-16 24260864 139.2 ns/op 14824.69 MB/s Benchmark____GWs_Opt_2kx10x0-16 24532999 145.7 ns/op 14169.12 MB/s Benchmark____GWs_Opt_2kx10x0-16 25002277 150.7 ns/op 13692.01 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11185441 353.4 ns/op 11634.76 MB/s Benchmark____GWs_Opt_4kx10x0-16 12623241 278.4 ns/op 14771.10 MB/s Benchmark____GWs_Opt_4kx10x0-16 12062599 289.9 ns/op 14182.99 MB/s Benchmark____GWs_Opt_4kx10x0-16 11111703 294.4 ns/op 13967.56 MB/s Benchmark____GWs_Opt_4kx10x0-16 10225827 333.9 ns/op 12316.52 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6484731 568.2 ns/op 5499.63 MB/s Benchmark____GWs_Opt_1kx01x1-16 6409748 561.9 ns/op 5561.96 MB/s Benchmark____GWs_Opt_1kx01x1-16 6357956 562.5 ns/op 5555.69 MB/s Benchmark____GWs_Opt_1kx01x1-16 6276986 563.1 ns/op 5550.06 MB/s Benchmark____GWs_Opt_1kx01x1-16 6178284 572.5 ns/op 5458.58 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4519383 1223 ns/op 5068.40 MB/s Benchmark____GWs_Opt_2kx01x1-16 4552226 770.9 ns/op 8038.26 MB/s Benchmark____GWs_Opt_2kx01x1-16 4489844 1654 ns/op 3747.73 MB/s Benchmark____GWs_Opt_2kx01x1-16 4296924 1013 ns/op 6116.24 MB/s Benchmark____GWs_Opt_2kx01x1-16 4445391 806.3 ns/op 7685.88 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2530566 1421 ns/op 8681.68 MB/s Benchmark____GWs_Opt_4kx01x1-16 2503275 1400 ns/op 8814.69 MB/s Benchmark____GWs_Opt_4kx01x1-16 2586350 1432 ns/op 8616.71 MB/s Benchmark____GWs_Opt_4kx01x1-16 2500004 1538 ns/op 8026.26 MB/s Benchmark____GWs_Opt_4kx01x1-16 2599137 1423 ns/op 8669.78 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6034851 569.6 ns/op 5485.92 MB/s Benchmark____GWs_Opt_1kx10x1-16 5987132 575.8 ns/op 5427.13 MB/s Benchmark____GWs_Opt_1kx10x1-16 5787594 576.5 ns/op 5421.09 MB/s Benchmark____GWs_Opt_1kx10x1-16 5794152 574.5 ns/op 5439.91 MB/s Benchmark____GWs_Opt_1kx10x1-16 5822552 577.8 ns/op 5408.82 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4016373 860.5 ns/op 7201.83 MB/s Benchmark____GWs_Opt_2kx10x1-16 4087780 865.7 ns/op 7158.62 MB/s Benchmark____GWs_Opt_2kx10x1-16 3969211 882.7 ns/op 7020.87 MB/s Benchmark____GWs_Opt_2kx10x1-16 3902660 865.7 ns/op 7158.14 MB/s Benchmark____GWs_Opt_2kx10x1-16 3952982 866.6 ns/op 7150.71 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2277844 1567 ns/op 7875.40 MB/s Benchmark____GWs_Opt_4kx10x1-16 2312833 1549 ns/op 7969.02 MB/s Benchmark____GWs_Opt_4kx10x1-16 2305752 1548 ns/op 7971.25 MB/s Benchmark____GWs_Opt_4kx10x1-16 2303413 1551 ns/op 7957.31 MB/s Benchmark____GWs_Opt_4kx10x1-16 2294536 1542 ns/op 8003.42 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12447171 288.2 ns/op 3608.22 MB/s Benchmark____GWs_Int_1kx01x0-16 12413596 288.5 ns/op 3604.47 MB/s Benchmark____GWs_Int_1kx01x0-16 11461994 294.1 ns/op 3536.63 MB/s Benchmark____GWs_Int_1kx01x0-16 11508285 290.2 ns/op 3583.61 MB/s Benchmark____GWs_Int_1kx01x0-16 12754948 286.6 ns/op 3629.07 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10198936 349.5 ns/op 5904.79 MB/s Benchmark____GWs_Int_2kx01x0-16 10301072 339.1 ns/op 6086.18 MB/s Benchmark____GWs_Int_2kx01x0-16 10068774 350.1 ns/op 5894.80 MB/s Benchmark____GWs_Int_2kx01x0-16 10201948 328.8 ns/op 6276.52 MB/s Benchmark____GWs_Int_2kx01x0-16 10278715 344.2 ns/op 5996.93 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5671932 622.6 ns/op 6605.08 MB/s Benchmark____GWs_Int_4kx01x0-16 5715614 628.2 ns/op 6545.72 MB/s Benchmark____GWs_Int_4kx01x0-16 5845458 616.5 ns/op 6669.39 MB/s Benchmark____GWs_Int_4kx01x0-16 5662420 643.5 ns/op 6389.58 MB/s Benchmark____GWs_Int_4kx01x0-16 6070422 636.7 ns/op 6458.10 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32328570 116.8 ns/op 8907.01 MB/s Benchmark____GWs_Int_1kx10x0-16 29458236 114.0 ns/op 9124.78 MB/s Benchmark____GWs_Int_1kx10x0-16 31765453 109.8 ns/op 9475.88 MB/s Benchmark____GWs_Int_1kx10x0-16 28455259 112.2 ns/op 9272.68 MB/s Benchmark____GWs_Int_1kx10x0-16 32121154 109.6 ns/op 9492.05 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 26037910 153.7 ns/op 13430.14 MB/s Benchmark____GWs_Int_2kx10x0-16 26087190 145.3 ns/op 14203.99 MB/s Benchmark____GWs_Int_2kx10x0-16 26111743 142.7 ns/op 14467.97 MB/s Benchmark____GWs_Int_2kx10x0-16 22407883 161.7 ns/op 12764.81 MB/s Benchmark____GWs_Int_2kx10x0-16 25729656 143.5 ns/op 14386.03 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11803510 297.4 ns/op 13828.63 MB/s Benchmark____GWs_Int_4kx10x0-16 9699288 309.9 ns/op 13268.23 MB/s Benchmark____GWs_Int_4kx10x0-16 13027572 298.6 ns/op 13771.75 MB/s Benchmark____GWs_Int_4kx10x0-16 13112226 292.0 ns/op 14084.45 MB/s Benchmark____GWs_Int_4kx10x0-16 11286726 280.8 ns/op 14646.24 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6337851 575.3 ns/op 5431.86 MB/s Benchmark____GWs_Int_1kx01x1-16 6098607 571.2 ns/op 5470.90 MB/s Benchmark____GWs_Int_1kx01x1-16 6373105 582.7 ns/op 5362.94 MB/s Benchmark____GWs_Int_1kx01x1-16 6205915 574.7 ns/op 5437.98 MB/s Benchmark____GWs_Int_1kx01x1-16 6364861 582.3 ns/op 5366.73 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4501065 1123 ns/op 5519.21 MB/s Benchmark____GWs_Int_2kx01x1-16 4416513 794.3 ns/op 7802.30 MB/s Benchmark____GWs_Int_2kx01x1-16 4641735 796.7 ns/op 7778.69 MB/s Benchmark____GWs_Int_2kx01x1-16 4593404 887.2 ns/op 6985.14 MB/s Benchmark____GWs_Int_2kx01x1-16 4141180 803.3 ns/op 7714.69 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2519358 1774 ns/op 6955.46 MB/s Benchmark____GWs_Int_4kx01x1-16 2623030 1537 ns/op 8026.75 MB/s Benchmark____GWs_Int_4kx01x1-16 2356352 1396 ns/op 8840.77 MB/s Benchmark____GWs_Int_4kx01x1-16 2541158 1401 ns/op 8810.55 MB/s Benchmark____GWs_Int_4kx01x1-16 2461046 1400 ns/op 8815.23 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6110788 586.8 ns/op 5325.67 MB/s Benchmark____GWs_Int_1kx10x1-16 5859057 582.0 ns/op 5369.13 MB/s Benchmark____GWs_Int_1kx10x1-16 6062796 578.7 ns/op 5400.49 MB/s Benchmark____GWs_Int_1kx10x1-16 5980928 575.8 ns/op 5427.54 MB/s Benchmark____GWs_Int_1kx10x1-16 5852061 581.3 ns/op 5376.27 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 3988004 876.5 ns/op 7069.91 MB/s Benchmark____GWs_Int_2kx10x1-16 3994725 867.6 ns/op 7142.52 MB/s Benchmark____GWs_Int_2kx10x1-16 4093239 880.8 ns/op 7036.01 MB/s Benchmark____GWs_Int_2kx10x1-16 4022942 866.8 ns/op 7149.55 MB/s Benchmark____GWs_Int_2kx10x1-16 4008717 858.0 ns/op 7222.70 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2319573 1553 ns/op 7944.60 MB/s Benchmark____GWs_Int_4kx10x1-16 2341129 1597 ns/op 7728.02 MB/s Benchmark____GWs_Int_4kx10x1-16 2315551 1590 ns/op 7763.04 MB/s Benchmark____GWs_Int_4kx10x1-16 2245468 1555 ns/op 7937.44 MB/s Benchmark____GWs_Int_4kx10x1-16 2291834 1726 ns/op 7149.11 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 7853666 448.6 ns/op 227.36 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8025814 446.2 ns/op 228.61 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8520621 448.5 ns/op 227.44 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7902697 446.0 ns/op 228.72 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7813288 473.0 ns/op 215.65 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 770929 4728 ns/op 37.43 MB/s Benchmark__GWs_Reqs_1SubEach-16 742872 4946 ns/op 35.79 MB/s Benchmark__GWs_Reqs_1SubEach-16 850984 4909 ns/op 36.06 MB/s Benchmark__GWs_Reqs_1SubEach-16 808591 4911 ns/op 36.04 MB/s Benchmark__GWs_Reqs_1SubEach-16 784705 4922 ns/op 35.96 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2143.115s ❌ Non-zero exit code: 1