> ROOT_DIR=/tmp/go-bench-away-job-447a9b55-6ca8-4e38-8233-e43b2ce9a26a-3790332573 > OUTPUT_FILE=/tmp/go-bench-away-job-447a9b55-6ca8-4e38-8233-e43b2ce9a26a-3790332573/results.txt > SHA_FILE=/tmp/go-bench-away-job-447a9b55-6ca8-4e38-8233-e43b2ce9a26a-3790332573/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-447a9b55-6ca8-4e38-8233-e43b2ce9a26a-3790332573/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.26.3/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-447a9b55-6ca8-4e38-8233-e43b2ce9a26a-3790332573/source.git SHA of main: db0a2c8ce3241df7dbc6cd730b989cfa05677068 Go runtime: go version go1.26.3 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build2156471387=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-447a9b55-6ca8-4e38-8233-e43b2ce9a26a-3790332573/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.26.3' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.26.3/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.3' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 49056103 73.51 ns/op 149.63 MB/s Benchmark______Pub0b_Payload-16 46500201 73.65 ns/op 149.36 MB/s Benchmark______Pub0b_Payload-16 46715300 74.85 ns/op 146.95 MB/s Benchmark______Pub0b_Payload-16 43432035 73.89 ns/op 148.87 MB/s Benchmark______Pub0b_Payload-16 46417227 74.37 ns/op 147.91 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45774482 74.11 ns/op 256.37 MB/s Benchmark______Pub8b_Payload-16 45808237 74.20 ns/op 256.06 MB/s Benchmark______Pub8b_Payload-16 45776464 74.34 ns/op 255.58 MB/s Benchmark______Pub8b_Payload-16 46346115 74.14 ns/op 256.27 MB/s Benchmark______Pub8b_Payload-16 45932328 74.28 ns/op 255.79 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 42137186 78.86 ns/op 557.94 MB/s Benchmark_____Pub32b_Payload-16 43407672 78.96 ns/op 557.23 MB/s Benchmark_____Pub32b_Payload-16 43275555 78.51 ns/op 560.45 MB/s Benchmark_____Pub32b_Payload-16 43475194 78.45 ns/op 560.90 MB/s Benchmark_____Pub32b_Payload-16 43212627 80.56 ns/op 546.19 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38406895 88.83 ns/op 1587.27 MB/s Benchmark____Pub128B_Payload-16 34397677 87.81 ns/op 1605.69 MB/s Benchmark____Pub128B_Payload-16 40588392 88.48 ns/op 1593.66 MB/s Benchmark____Pub128B_Payload-16 38817518 87.84 ns/op 1605.27 MB/s Benchmark____Pub128B_Payload-16 38934576 88.38 ns/op 1595.41 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35586726 98.47 ns/op 2731.87 MB/s Benchmark____Pub256B_Payload-16 36851416 97.34 ns/op 2763.57 MB/s Benchmark____Pub256B_Payload-16 35925252 98.05 ns/op 2743.43 MB/s Benchmark____Pub256B_Payload-16 32059186 97.09 ns/op 2770.70 MB/s Benchmark____Pub256B_Payload-16 31206378 97.11 ns/op 2770.17 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23495768 149.4 ns/op 6946.82 MB/s Benchmark______Pub1K_Payload-16 23492660 140.5 ns/op 7386.58 MB/s Benchmark______Pub1K_Payload-16 24240068 145.5 ns/op 7133.59 MB/s Benchmark______Pub1K_Payload-16 23894618 139.7 ns/op 7428.32 MB/s Benchmark______Pub1K_Payload-16 23422666 140.3 ns/op 7397.61 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5515527 628.6 ns/op 6538.07 MB/s Benchmark______Pub4K_Payload-16 5601248 621.1 ns/op 6616.77 MB/s Benchmark______Pub4K_Payload-16 5832013 621.9 ns/op 6608.43 MB/s Benchmark______Pub4K_Payload-16 5750385 625.0 ns/op 6575.75 MB/s Benchmark______Pub4K_Payload-16 5570642 638.0 ns/op 6441.81 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2821224 1276 ns/op 6432.03 MB/s Benchmark______Pub8K_Payload-16 2750815 1272 ns/op 6451.64 MB/s Benchmark______Pub8K_Payload-16 2689789 1280 ns/op 6410.36 MB/s Benchmark______Pub8K_Payload-16 2735101 1274 ns/op 6443.13 MB/s Benchmark______Pub8K_Payload-16 2751008 1282 ns/op 6401.60 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 474880 6976 ns/op 4699.65 MB/s Benchmark_____Pub32K_Payload-16 669520 5379 ns/op 6094.55 MB/s Benchmark_____Pub32K_Payload-16 656106 5480 ns/op 5982.79 MB/s Benchmark_____Pub32K_Payload-16 660580 6782 ns/op 4833.85 MB/s Benchmark_____Pub32K_Payload-16 649982 5508 ns/op 5951.92 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31611042 96.50 ns/op 113.99 MB/s Benchmark__AuthPub0b_Payload-16 35911732 95.94 ns/op 114.66 MB/s Benchmark__AuthPub0b_Payload-16 35762588 95.83 ns/op 114.79 MB/s Benchmark__AuthPub0b_Payload-16 31992140 95.96 ns/op 114.63 MB/s Benchmark__AuthPub0b_Payload-16 32550462 95.91 ns/op 114.69 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15185794 227.9 ns/op Benchmark_____________PubSub-16 15513404 228.7 ns/op Benchmark_____________PubSub-16 15370462 228.6 ns/op Benchmark_____________PubSub-16 15543854 228.9 ns/op Benchmark_____________PubSub-16 15465525 229.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15614637 226.9 ns/op Benchmark_____PubSubTwoConns-16 15552766 227.3 ns/op Benchmark_____PubSubTwoConns-16 15536917 226.7 ns/op Benchmark_____PubSubTwoConns-16 15632042 227.2 ns/op Benchmark_____PubSubTwoConns-16 15674600 227.3 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40184->127.0.0.1:41609: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42916->127.0.0.1:34737: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43782->127.0.0.1:33641: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33004->127.0.0.1:39685: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43068->127.0.0.1:35095: 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 14375787 246.4 ns/op Benchmark_____PubTwoQueueSub-16 14340741 246.6 ns/op Benchmark_____PubTwoQueueSub-16 14459758 246.4 ns/op Benchmark_____PubTwoQueueSub-16 14412691 247.1 ns/op Benchmark_____PubTwoQueueSub-16 14230370 246.3 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14159637 246.2 ns/op Benchmark____PubFourQueueSub-16 14570120 246.1 ns/op Benchmark____PubFourQueueSub-16 14293225 246.4 ns/op Benchmark____PubFourQueueSub-16 14403907 246.8 ns/op Benchmark____PubFourQueueSub-16 14416480 245.7 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14209744 247.4 ns/op Benchmark___PubEightQueueSub-16 14262169 246.6 ns/op Benchmark___PubEightQueueSub-16 14349996 246.3 ns/op Benchmark___PubEightQueueSub-16 14417371 246.6 ns/op Benchmark___PubEightQueueSub-16 14337849 246.8 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23382 154874 ns/op Benchmark_PubSub512kTwoConns-16 23277 153026 ns/op Benchmark_PubSub512kTwoConns-16 23148 155782 ns/op Benchmark_PubSub512kTwoConns-16 23190 153484 ns/op Benchmark_PubSub512kTwoConns-16 23098 154495 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14933604 230.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15231276 229.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15146100 230.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 15401602 230.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15143346 230.9 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15056872 230.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15058659 228.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15212169 230.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15329372 230.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15168960 230.4 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10901534 321.7 ns/op Benchmark____RoutedPubSub_0b-16 10853352 317.9 ns/op Benchmark____RoutedPubSub_0b-16 11062305 322.5 ns/op Benchmark____RoutedPubSub_0b-16 11132840 319.1 ns/op Benchmark____RoutedPubSub_0b-16 11160021 320.6 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6754062 541.9 ns/op Benchmark____RoutedPubSub_1K-16 6587766 539.1 ns/op Benchmark____RoutedPubSub_1K-16 6656642 532.5 ns/op Benchmark____RoutedPubSub_1K-16 6530304 622.1 ns/op Benchmark____RoutedPubSub_1K-16 6551229 542.2 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 83547 42150 ns/op Benchmark__RoutedPubSub_100K-16 79814 51096 ns/op Benchmark__RoutedPubSub_100K-16 68372 52085 ns/op Benchmark__RoutedPubSub_100K-16 69111 52738 ns/op Benchmark__RoutedPubSub_100K-16 80420 50767 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9688389 320.6 ns/op Benchmark____Routed2QueueSub-16 9591399 327.5 ns/op Benchmark____Routed2QueueSub-16 9612535 325.6 ns/op Benchmark____Routed2QueueSub-16 9704650 322.7 ns/op Benchmark____Routed2QueueSub-16 9420331 324.7 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 11054400 324.4 ns/op Benchmark____Routed4QueueSub-16 9744414 330.8 ns/op Benchmark____Routed4QueueSub-16 9733441 329.8 ns/op Benchmark____Routed4QueueSub-16 9396459 330.3 ns/op Benchmark____Routed4QueueSub-16 9500974 327.6 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9308922 329.3 ns/op Benchmark____Routed8QueueSub-16 9261676 331.9 ns/op Benchmark____Routed8QueueSub-16 8967996 334.9 ns/op Benchmark____Routed8QueueSub-16 11120426 327.2 ns/op Benchmark____Routed8QueueSub-16 9155950 333.7 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 10304652 351.1 ns/op Benchmark___Routed16QueueSub-16 8853957 345.6 ns/op Benchmark___Routed16QueueSub-16 8726289 344.1 ns/op Benchmark___Routed16QueueSub-16 8504342 358.2 ns/op Benchmark___Routed16QueueSub-16 10237772 348.2 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6476326 560.2 ns/op Benchmark____________RouteCompressOff-16 6429280 561.2 ns/op Benchmark____________RouteCompressOff-16 6368319 555.9 ns/op Benchmark____________RouteCompressOff-16 6432505 560.4 ns/op Benchmark____________RouteCompressOff-16 6373566 558.9 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6300081 559.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6228972 564.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6552859 551.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6293912 562.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6176638 567.7 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6410925 556.4 ns/op Benchmark_________RouteCompressS2Fast-16 6450912 553.8 ns/op Benchmark_________RouteCompressS2Fast-16 6335898 554.3 ns/op Benchmark_________RouteCompressS2Fast-16 6359134 554.9 ns/op Benchmark_________RouteCompressS2Fast-16 6473505 560.0 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6409063 552.3 ns/op Benchmark_______RouteCompressS2Better-16 6301801 553.5 ns/op Benchmark_______RouteCompressS2Better-16 6592228 554.8 ns/op Benchmark_______RouteCompressS2Better-16 6416022 559.1 ns/op Benchmark_______RouteCompressS2Better-16 6361146 554.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6401049 553.2 ns/op Benchmark_________RouteCompressS2Best-16 6350852 553.6 ns/op Benchmark_________RouteCompressS2Best-16 6444688 554.8 ns/op Benchmark_________RouteCompressS2Best-16 6487390 553.9 ns/op Benchmark_________RouteCompressS2Best-16 6357896 559.6 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4612725 778.0 ns/op 320.05 MB/s Benchmark______FanOut_8x1x10-16 4649529 774.5 ns/op 321.50 MB/s Benchmark______FanOut_8x1x10-16 4601448 771.1 ns/op 322.93 MB/s Benchmark______FanOut_8x1x10-16 4597425 774.4 ns/op 321.54 MB/s Benchmark______FanOut_8x1x10-16 4626684 775.4 ns/op 321.11 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 522868 6123 ns/op 378.75 MB/s Benchmark_____FanOut_8x1x100-16 527751 6080 ns/op 381.39 MB/s Benchmark_____FanOut_8x1x100-16 556626 6108 ns/op 379.69 MB/s Benchmark_____FanOut_8x1x100-16 565173 6126 ns/op 378.58 MB/s Benchmark_____FanOut_8x1x100-16 542589 6107 ns/op 379.74 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48086 74294 ns/op 309.84 MB/s Benchmark____FanOut_8x10x100-16 48061 75485 ns/op 304.95 MB/s Benchmark____FanOut_8x10x100-16 48360 74544 ns/op 308.80 MB/s Benchmark____FanOut_8x10x100-16 48099 74816 ns/op 307.68 MB/s Benchmark____FanOut_8x10x100-16 48172 74603 ns/op 308.55 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5814 593477 ns/op 404.43 MB/s Benchmark___FanOut_8x10x1000-16 5918 597768 ns/op 401.53 MB/s Benchmark___FanOut_8x10x1000-16 5912 608899 ns/op 394.19 MB/s Benchmark___FanOut_8x10x1000-16 5931 592585 ns/op 405.04 MB/s Benchmark___FanOut_8x10x1000-16 5976 603597 ns/op 397.65 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4999 706421 ns/op 325.61 MB/s Benchmark___FanOut_8x100x100-16 5043 707583 ns/op 325.08 MB/s Benchmark___FanOut_8x100x100-16 5000 705191 ns/op 326.18 MB/s Benchmark___FanOut_8x100x100-16 4984 706194 ns/op 325.72 MB/s Benchmark___FanOut_8x100x100-16 5041 704943 ns/op 326.29 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 582 6146171 ns/op 390.49 MB/s Benchmark__FanOut_8x100x1000-16 573 6193542 ns/op 387.50 MB/s Benchmark__FanOut_8x100x1000-16 573 6186468 ns/op 387.95 MB/s Benchmark__FanOut_8x100x1000-16 567 6069034 ns/op 395.45 MB/s Benchmark__FanOut_8x100x1000-16 574 6099771 ns/op 393.46 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 541 6769827 ns/op 369.29 MB/s Benchmark__FanOut_8x10x10000-16 537 6661459 ns/op 375.30 MB/s Benchmark__FanOut_8x10x10000-16 532 6772279 ns/op 369.15 MB/s Benchmark__FanOut_8x10x10000-16 530 6706006 ns/op 372.80 MB/s Benchmark__FanOut_8x10x10000-16 532 6832180 ns/op 365.92 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 950 3740838 ns/op 307.42 MB/s Benchmark___FanOut_8x500x100-16 949 3749026 ns/op 306.75 MB/s Benchmark___FanOut_8x500x100-16 946 3764837 ns/op 305.46 MB/s Benchmark___FanOut_8x500x100-16 945 3755212 ns/op 306.25 MB/s Benchmark___FanOut_8x500x100-16 945 3770556 ns/op 305.00 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 357373 9528 ns/op 1536.63 MB/s Benchmark___FanOut_128x1x100-16 362445 9489 ns/op 1542.98 MB/s Benchmark___FanOut_128x1x100-16 365230 9503 ns/op 1540.74 MB/s Benchmark___FanOut_128x1x100-16 365238 9512 ns/op 1539.29 MB/s Benchmark___FanOut_128x1x100-16 368464 9469 ns/op 1546.13 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32419 110754 ns/op 1310.48 MB/s Benchmark__FanOut_128x10x100-16 32427 110636 ns/op 1311.88 MB/s Benchmark__FanOut_128x10x100-16 32346 111384 ns/op 1303.07 MB/s Benchmark__FanOut_128x10x100-16 32650 110906 ns/op 1308.68 MB/s Benchmark__FanOut_128x10x100-16 32646 110478 ns/op 1313.76 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4024 876934 ns/op 1665.05 MB/s Benchmark_FanOut_128x10x1000-16 4060 873942 ns/op 1670.75 MB/s Benchmark_FanOut_128x10x1000-16 4006 879497 ns/op 1660.20 MB/s Benchmark_FanOut_128x10x1000-16 3856 870908 ns/op 1676.57 MB/s Benchmark_FanOut_128x10x1000-16 4099 877342 ns/op 1664.28 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3464 1011175 ns/op 1434.12 MB/s Benchmark_FanOut_128x100x100-16 3468 1012185 ns/op 1432.68 MB/s Benchmark_FanOut_128x100x100-16 3540 1013149 ns/op 1431.32 MB/s Benchmark_FanOut_128x100x100-16 3522 1018003 ns/op 1424.50 MB/s Benchmark_FanOut_128x100x100-16 3505 1011960 ns/op 1433.00 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 391 9270906 ns/op 1574.83 MB/s BenchmarkFanOut_128x100x1000-16 386 9272766 ns/op 1574.52 MB/s BenchmarkFanOut_128x100x1000-16 387 9185482 ns/op 1589.48 MB/s BenchmarkFanOut_128x100x1000-16 381 9290542 ns/op 1571.51 MB/s BenchmarkFanOut_128x100x1000-16 384 9334363 ns/op 1564.13 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 374 9708545 ns/op 1514.14 MB/s BenchmarkFanOut_128x10x10000-16 374 9610598 ns/op 1529.58 MB/s BenchmarkFanOut_128x10x10000-16 372 9582952 ns/op 1533.99 MB/s BenchmarkFanOut_128x10x10000-16 379 9622045 ns/op 1527.76 MB/s BenchmarkFanOut_128x10x10000-16 375 9588771 ns/op 1533.06 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 686 5253744 ns/op 1379.99 MB/s BenchmarkFanOut__128x500x100-16 681 5241962 ns/op 1383.10 MB/s BenchmarkFanOut__128x500x100-16 663 5219596 ns/op 1389.02 MB/s BenchmarkFanOut__128x500x100-16 678 5239336 ns/op 1383.79 MB/s BenchmarkFanOut__128x500x100-16 687 5225522 ns/op 1387.45 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1911 1844363 ns/op 2868.48 MB/s Benchmark_FanOut_512x100x100-16 1917 1845466 ns/op 2866.77 MB/s Benchmark_FanOut_512x100x100-16 1962 1848999 ns/op 2861.29 MB/s Benchmark_FanOut_512x100x100-16 1905 1833768 ns/op 2885.06 MB/s Benchmark_FanOut_512x100x100-16 1912 1837606 ns/op 2879.03 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 219 16544840 ns/op 3203.45 MB/s Benchmark__FanOut_512x100x1k-16 214 16687539 ns/op 3176.05 MB/s Benchmark__FanOut_512x100x1k-16 216 16855095 ns/op 3144.48 MB/s Benchmark__FanOut_512x100x1k-16 217 16554510 ns/op 3201.58 MB/s Benchmark__FanOut_512x100x1k-16 216 16740697 ns/op 3165.97 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3121 1157718 ns/op 9010.00 MB/s Benchmark____FanOut_1kx10x1k-16 3079 1157334 ns/op 9012.99 MB/s Benchmark____FanOut_1kx10x1k-16 3044 1133229 ns/op 9204.70 MB/s Benchmark____FanOut_1kx10x1k-16 3196 1147270 ns/op 9092.05 MB/s Benchmark____FanOut_1kx10x1k-16 2943 1168547 ns/op 8926.50 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2772 1263492 ns/op 8247.81 MB/s Benchmark__FanOut_1kx100x100-16 2826 1250838 ns/op 8331.25 MB/s Benchmark__FanOut_1kx100x100-16 2726 1251331 ns/op 8327.96 MB/s Benchmark__FanOut_1kx100x100-16 2787 1247491 ns/op 8353.60 MB/s Benchmark__FanOut_1kx100x100-16 2770 1265605 ns/op 8234.03 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4386648 782.8 ns/op 318.09 MB/s Benchmark_____RFanOut_8x1x10-16 4551451 773.5 ns/op 321.91 MB/s Benchmark_____RFanOut_8x1x10-16 4388566 782.0 ns/op 318.40 MB/s Benchmark_____RFanOut_8x1x10-16 4518799 780.0 ns/op 319.25 MB/s Benchmark_____RFanOut_8x1x10-16 4529724 766.5 ns/op 324.83 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 544324 6113 ns/op 379.37 MB/s Benchmark____RFanOut_8x1x100-16 552390 6057 ns/op 382.84 MB/s Benchmark____RFanOut_8x1x100-16 515835 6160 ns/op 376.48 MB/s Benchmark____RFanOut_8x1x100-16 536283 6026 ns/op 384.86 MB/s Benchmark____RFanOut_8x1x100-16 529644 5981 ns/op 387.75 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48771 73561 ns/op 312.93 MB/s Benchmark___RFanOut_8x10x100-16 48885 73868 ns/op 311.63 MB/s Benchmark___RFanOut_8x10x100-16 48716 74705 ns/op 308.13 MB/s Benchmark___RFanOut_8x10x100-16 48687 73709 ns/op 312.30 MB/s Benchmark___RFanOut_8x10x100-16 48900 74782 ns/op 307.81 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5701 586596 ns/op 409.17 MB/s Benchmark__RFanOut_8x10x1000-16 6180 590491 ns/op 406.47 MB/s Benchmark__RFanOut_8x10x1000-16 6091 584292 ns/op 410.79 MB/s Benchmark__RFanOut_8x10x1000-16 6138 588684 ns/op 407.72 MB/s Benchmark__RFanOut_8x10x1000-16 5912 594840 ns/op 403.50 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5084 695453 ns/op 330.75 MB/s Benchmark__RFanOut_8x100x100-16 5042 697063 ns/op 329.98 MB/s Benchmark__RFanOut_8x100x100-16 5083 708496 ns/op 324.66 MB/s Benchmark__RFanOut_8x100x100-16 4974 696689 ns/op 330.16 MB/s Benchmark__RFanOut_8x100x100-16 4970 696824 ns/op 330.10 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 590 6009646 ns/op 399.36 MB/s Benchmark_RFanOut_8x100x1000-16 595 5997781 ns/op 400.15 MB/s Benchmark_RFanOut_8x100x1000-16 591 6039882 ns/op 397.36 MB/s Benchmark_RFanOut_8x100x1000-16 596 5997034 ns/op 400.20 MB/s Benchmark_RFanOut_8x100x1000-16 589 6056022 ns/op 396.30 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 550 6584213 ns/op 379.70 MB/s Benchmark_RFanOut_8x10x10000-16 544 6686105 ns/op 373.91 MB/s Benchmark_RFanOut_8x10x10000-16 547 6637326 ns/op 376.66 MB/s Benchmark_RFanOut_8x10x10000-16 547 6625334 ns/op 377.34 MB/s Benchmark_RFanOut_8x10x10000-16 530 6603243 ns/op 378.60 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2757 1152905 ns/op 9047.62 MB/s Benchmark_RFanOut_1kx10x1000-16 3152 1143198 ns/op 9124.44 MB/s Benchmark_RFanOut_1kx10x1000-16 3098 1150598 ns/op 9065.75 MB/s Benchmark_RFanOut_1kx10x1000-16 3006 1149474 ns/op 9074.62 MB/s Benchmark_RFanOut_1kx10x1000-16 3205 1156629 ns/op 9018.49 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6936679 501.9 ns/op 4140.13 MB/s Benchmark_____FanIn_1kx100x1-16 6969895 504.8 ns/op 4116.47 MB/s Benchmark_____FanIn_1kx100x1-16 6898216 505.0 ns/op 4114.84 MB/s Benchmark_____FanIn_1kx100x1-16 6928238 506.3 ns/op 4104.67 MB/s Benchmark_____FanIn_1kx100x1-16 6866932 503.5 ns/op 4126.97 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2634315 1364 ns/op 6029.78 MB/s Benchmark_____FanIn_4kx100x1-16 2609130 1373 ns/op 5986.71 MB/s Benchmark_____FanIn_4kx100x1-16 2677975 1373 ns/op 5988.13 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 60808256 vs 4112000000 bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:36012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:36098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35754->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark_____FanIn_4kx100x1-16 Benchmark_____FanIn_4kx100x1-16 2639667 1347 ns/op 6105.52 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1672498 2108 ns/op 7786.42 MB/s Benchmark_____FanIn_8kx100x1-16 1717435 2120 ns/op 7742.46 MB/s Benchmark_____FanIn_8kx100x1-16 1682408 2110 ns/op 7777.78 MB/s Benchmark_____FanIn_8kx100x1-16 1728505 2114 ns/op 7764.68 MB/s Benchmark_____FanIn_8kx100x1-16 1670103 2094 ns/op 7839.70 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 859080 4146 ns/op 7911.09 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 95404617 vs 10613087100 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53886->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53948->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:53288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53578->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:53632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53352->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:53614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53648->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53396->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:53674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53584->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54008->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53594->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_16kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53546->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_16kx100x1-16 867806 4149 ns/op 7904.95 MB/s Benchmark____FanIn_16kx100x1-16 865698 4127 ns/op 7947.15 MB/s Benchmark____FanIn_16kx100x1-16 875119 4169 ns/op 7868.26 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 173052 19811 ns/op 6617.69 MB/s Benchmark____FanIn_64kx100x1-16 169754 20073 ns/op 6531.49 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 3444089067 vs 10717915500 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:51908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:52198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52600->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52040->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 161096 19949 ns/op 6572.01 MB/s Benchmark____FanIn_64kx100x1-16 156540 20174 ns/op 6498.53 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1098927470 vs 11562138000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53486->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52922->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 318679790 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54676->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:54968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54536->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1091717520 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56504->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: 277517530 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:58536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58604->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58478->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 896524510 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60016->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5544933 646.5 ns/op 439.30 MB/s Benchmark___BumpPubCount_1x3-16 5541092 642.8 ns/op 441.81 MB/s Benchmark___BumpPubCount_1x3-16 5520174 646.2 ns/op 439.47 MB/s Benchmark___BumpPubCount_1x3-16 5584740 642.5 ns/op 442.01 MB/s Benchmark___BumpPubCount_1x3-16 5516155 643.3 ns/op 441.45 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5303409 677.5 ns/op 419.21 MB/s Benchmark___BumpPubCount_2x3-16 5235802 672.5 ns/op 422.30 MB/s Benchmark___BumpPubCount_2x3-16 5294188 674.0 ns/op 421.38 MB/s Benchmark___BumpPubCount_2x3-16 5240694 677.2 ns/op 419.38 MB/s Benchmark___BumpPubCount_2x3-16 5309012 678.9 ns/op 418.30 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5529579 648.7 ns/op 437.81 MB/s Benchmark___BumpPubCount_5x3-16 5259558 646.1 ns/op 439.57 MB/s Benchmark___BumpPubCount_5x3-16 5487178 649.1 ns/op 437.51 MB/s Benchmark___BumpPubCount_5x3-16 5538196 646.8 ns/op 439.09 MB/s Benchmark___BumpPubCount_5x3-16 5487681 647.7 ns/op 438.49 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5535559 648.0 ns/op 438.30 MB/s Benchmark__BumpPubCount_10x3-16 5526027 648.5 ns/op 437.95 MB/s Benchmark__BumpPubCount_10x3-16 5543822 649.5 ns/op 437.27 MB/s Benchmark__BumpPubCount_10x3-16 5569684 646.3 ns/op 439.43 MB/s Benchmark__BumpPubCount_10x3-16 5529930 648.0 ns/op 438.25 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12426024 274.4 ns/op 3790.26 MB/s Benchmark____GWs_Opt_1kx01x0-16 11695344 282.7 ns/op 3679.10 MB/s Benchmark____GWs_Opt_1kx01x0-16 12865066 263.3 ns/op 3949.81 MB/s Benchmark____GWs_Opt_1kx01x0-16 12283460 279.9 ns/op 3715.12 MB/s Benchmark____GWs_Opt_1kx01x0-16 12986689 276.2 ns/op 3765.80 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9272089 349.1 ns/op 5912.44 MB/s Benchmark____GWs_Opt_2kx01x0-16 9752454 338.6 ns/op 6095.89 MB/s Benchmark____GWs_Opt_2kx01x0-16 10045650 328.8 ns/op 6277.12 MB/s Benchmark____GWs_Opt_2kx01x0-16 10280361 345.9 ns/op 5966.79 MB/s Benchmark____GWs_Opt_2kx01x0-16 9563148 334.8 ns/op 6164.18 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5693860 630.6 ns/op 6520.48 MB/s Benchmark____GWs_Opt_4kx01x0-16 6027547 605.7 ns/op 6789.13 MB/s Benchmark____GWs_Opt_4kx01x0-16 5595376 627.2 ns/op 6555.94 MB/s Benchmark____GWs_Opt_4kx01x0-16 5545646 627.4 ns/op 6554.43 MB/s Benchmark____GWs_Opt_4kx01x0-16 5857186 709.3 ns/op 5797.44 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28880445 112.2 ns/op 9270.10 MB/s Benchmark____GWs_Opt_1kx10x0-16 27689002 109.8 ns/op 9468.06 MB/s Benchmark____GWs_Opt_1kx10x0-16 30027462 117.0 ns/op 8888.11 MB/s Benchmark____GWs_Opt_1kx10x0-16 27821338 111.1 ns/op 9361.76 MB/s Benchmark____GWs_Opt_1kx10x0-16 31494147 112.9 ns/op 9209.66 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25058823 144.7 ns/op 14262.69 MB/s Benchmark____GWs_Opt_2kx10x0-16 23973146 138.7 ns/op 14881.78 MB/s Benchmark____GWs_Opt_2kx10x0-16 25989336 164.0 ns/op 12583.57 MB/s Benchmark____GWs_Opt_2kx10x0-16 20952163 162.3 ns/op 12718.57 MB/s Benchmark____GWs_Opt_2kx10x0-16 25127650 138.9 ns/op 14855.86 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11740326 328.0 ns/op 12535.01 MB/s Benchmark____GWs_Opt_4kx10x0-16 11754764 364.8 ns/op 11270.72 MB/s Benchmark____GWs_Opt_4kx10x0-16 10456929 303.9 ns/op 13529.61 MB/s Benchmark____GWs_Opt_4kx10x0-16 12102618 287.6 ns/op 14299.59 MB/s Benchmark____GWs_Opt_4kx10x0-16 12106426 299.3 ns/op 13737.39 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6317389 563.8 ns/op 5542.35 MB/s Benchmark____GWs_Opt_1kx01x1-16 6310810 564.4 ns/op 5536.64 MB/s Benchmark____GWs_Opt_1kx01x1-16 6620114 557.9 ns/op 5601.60 MB/s Benchmark____GWs_Opt_1kx01x1-16 6356034 551.2 ns/op 5669.69 MB/s Benchmark____GWs_Opt_1kx01x1-16 6599800 564.5 ns/op 5535.84 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4573585 767.1 ns/op 8078.02 MB/s Benchmark____GWs_Opt_2kx01x1-16 4531866 776.4 ns/op 7981.30 MB/s Benchmark____GWs_Opt_2kx01x1-16 4755278 772.3 ns/op 8024.45 MB/s Benchmark____GWs_Opt_2kx01x1-16 4630024 774.4 ns/op 8002.23 MB/s Benchmark____GWs_Opt_2kx01x1-16 4618867 765.7 ns/op 8093.27 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2504988 1392 ns/op 8867.81 MB/s Benchmark____GWs_Opt_4kx01x1-16 2591554 1378 ns/op 8958.41 MB/s Benchmark____GWs_Opt_4kx01x1-16 2625136 1388 ns/op 8891.98 MB/s Benchmark____GWs_Opt_4kx01x1-16 2517526 1371 ns/op 9002.61 MB/s Benchmark____GWs_Opt_4kx01x1-16 2548854 1371 ns/op 9000.59 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 5954601 556.7 ns/op 5613.80 MB/s Benchmark____GWs_Opt_1kx10x1-16 5962341 556.2 ns/op 5618.47 MB/s Benchmark____GWs_Opt_1kx10x1-16 6276087 556.7 ns/op 5613.66 MB/s Benchmark____GWs_Opt_1kx10x1-16 6455899 561.3 ns/op 5567.34 MB/s Benchmark____GWs_Opt_1kx10x1-16 6507414 560.8 ns/op 5571.90 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4249029 839.3 ns/op 7383.70 MB/s Benchmark____GWs_Opt_2kx10x1-16 4134561 840.4 ns/op 7373.56 MB/s Benchmark____GWs_Opt_2kx10x1-16 4135272 849.4 ns/op 7295.81 MB/s Benchmark____GWs_Opt_2kx10x1-16 4038188 884.3 ns/op 7007.99 MB/s Benchmark____GWs_Opt_2kx10x1-16 4093100 838.6 ns/op 7389.54 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2355675 1518 ns/op 8130.56 MB/s Benchmark____GWs_Opt_4kx10x1-16 2304939 1532 ns/op 8056.61 MB/s Benchmark____GWs_Opt_4kx10x1-16 2370448 1529 ns/op 8070.47 MB/s Benchmark____GWs_Opt_4kx10x1-16 2158195 1517 ns/op 8135.06 MB/s Benchmark____GWs_Opt_4kx10x1-16 2337901 1527 ns/op 8083.58 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12630487 289.8 ns/op 3588.31 MB/s Benchmark____GWs_Int_1kx01x0-16 11765296 285.7 ns/op 3640.34 MB/s Benchmark____GWs_Int_1kx01x0-16 12839842 292.2 ns/op 3559.65 MB/s Benchmark____GWs_Int_1kx01x0-16 12132724 296.0 ns/op 3512.99 MB/s Benchmark____GWs_Int_1kx01x0-16 12051847 301.2 ns/op 3452.76 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10125372 340.3 ns/op 6065.03 MB/s Benchmark____GWs_Int_2kx01x0-16 9251366 359.7 ns/op 5738.76 MB/s Benchmark____GWs_Int_2kx01x0-16 10159478 358.8 ns/op 5752.57 MB/s Benchmark____GWs_Int_2kx01x0-16 9578684 355.2 ns/op 5810.34 MB/s Benchmark____GWs_Int_2kx01x0-16 10081476 368.5 ns/op 5600.46 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5722855 775.5 ns/op 5302.69 MB/s Benchmark____GWs_Int_4kx01x0-16 5796682 623.7 ns/op 6592.73 MB/s Benchmark____GWs_Int_4kx01x0-16 5660314 648.4 ns/op 6341.38 MB/s Benchmark____GWs_Int_4kx01x0-16 5699589 632.0 ns/op 6506.01 MB/s Benchmark____GWs_Int_4kx01x0-16 5597734 632.2 ns/op 6504.71 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31543653 113.1 ns/op 9197.88 MB/s Benchmark____GWs_Int_1kx10x0-16 30669502 124.5 ns/op 8350.85 MB/s Benchmark____GWs_Int_1kx10x0-16 31220749 111.0 ns/op 9369.78 MB/s Benchmark____GWs_Int_1kx10x0-16 24808273 128.7 ns/op 8082.62 MB/s Benchmark____GWs_Int_1kx10x0-16 31815957 108.8 ns/op 9558.06 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25685932 146.2 ns/op 14118.89 MB/s Benchmark____GWs_Int_2kx10x0-16 25400635 150.8 ns/op 13689.65 MB/s Benchmark____GWs_Int_2kx10x0-16 25912326 147.6 ns/op 13982.29 MB/s Benchmark____GWs_Int_2kx10x0-16 1000000 3526 ns/op 585.29 MB/s Benchmark____GWs_Int_2kx10x0-16 25797048 143.7 ns/op 14366.67 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11743830 275.4 ns/op 14931.11 MB/s Benchmark____GWs_Int_4kx10x0-16 13382305 283.3 ns/op 14514.39 MB/s Benchmark____GWs_Int_4kx10x0-16 13228161 314.9 ns/op 13059.08 MB/s Benchmark____GWs_Int_4kx10x0-16 10656549 285.0 ns/op 14429.71 MB/s Benchmark____GWs_Int_4kx10x0-16 9670768 322.6 ns/op 12746.53 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6156421 574.6 ns/op 5438.69 MB/s Benchmark____GWs_Int_1kx01x1-16 6359973 566.3 ns/op 5518.64 MB/s Benchmark____GWs_Int_1kx01x1-16 6280255 569.8 ns/op 5484.07 MB/s Benchmark____GWs_Int_1kx01x1-16 6670413 566.6 ns/op 5515.12 MB/s Benchmark____GWs_Int_1kx01x1-16 6438602 563.5 ns/op 5546.09 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4700384 772.6 ns/op 8020.95 MB/s Benchmark____GWs_Int_2kx01x1-16 4720086 765.3 ns/op 8097.15 MB/s Benchmark____GWs_Int_2kx01x1-16 4569360 779.4 ns/op 7951.37 MB/s Benchmark____GWs_Int_2kx01x1-16 4634492 769.9 ns/op 8048.67 MB/s Benchmark____GWs_Int_2kx01x1-16 4743782 856.5 ns/op 7235.11 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2615430 1579 ns/op 7814.01 MB/s Benchmark____GWs_Int_4kx01x1-16 2531090 1566 ns/op 7878.90 MB/s Benchmark____GWs_Int_4kx01x1-16 2622628 1368 ns/op 9022.74 MB/s Benchmark____GWs_Int_4kx01x1-16 2596365 1373 ns/op 8985.88 MB/s Benchmark____GWs_Int_4kx01x1-16 2481171 1381 ns/op 8937.38 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6511296 581.7 ns/op 5372.12 MB/s Benchmark____GWs_Int_1kx10x1-16 6165262 561.4 ns/op 5566.29 MB/s Benchmark____GWs_Int_1kx10x1-16 6522628 564.1 ns/op 5539.60 MB/s Benchmark____GWs_Int_1kx10x1-16 6090561 551.9 ns/op 5662.29 MB/s Benchmark____GWs_Int_1kx10x1-16 6551001 565.5 ns/op 5526.52 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4141754 856.1 ns/op 7238.42 MB/s Benchmark____GWs_Int_2kx10x1-16 4050036 831.5 ns/op 7452.60 MB/s Benchmark____GWs_Int_2kx10x1-16 4192296 843.8 ns/op 7344.33 MB/s Benchmark____GWs_Int_2kx10x1-16 4119322 846.8 ns/op 7317.94 MB/s Benchmark____GWs_Int_2kx10x1-16 4028594 844.0 ns/op 7342.21 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2324812 1583 ns/op 7793.92 MB/s Benchmark____GWs_Int_4kx10x1-16 2304178 1630 ns/op 7571.70 MB/s Benchmark____GWs_Int_4kx10x1-16 2286621 1550 ns/op 7960.55 MB/s Benchmark____GWs_Int_4kx10x1-16 2143039 1690 ns/op 7302.20 MB/s Benchmark____GWs_Int_4kx10x1-16 2335657 1494 ns/op 8261.90 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8023371 440.6 ns/op 231.49 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8605834 436.5 ns/op 233.70 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8164329 451.8 ns/op 225.76 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8043903 443.7 ns/op 229.87 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8378742 436.3 ns/op 233.77 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 718084 5056 ns/op 35.01 MB/s Benchmark__GWs_Reqs_1SubEach-16 738302 5299 ns/op 33.40 MB/s Benchmark__GWs_Reqs_1SubEach-16 727400 5291 ns/op 33.46 MB/s Benchmark__GWs_Reqs_1SubEach-16 768740 5323 ns/op 33.25 MB/s Benchmark__GWs_Reqs_1SubEach-16 741222 5199 ns/op 34.05 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2074.519s ❌ Non-zero exit code: 1