> ROOT_DIR=/tmp/go-bench-away-job-cb36c6a1-aca4-4a74-8bdf-98021bb5bb09-4068715764 > OUTPUT_FILE=/tmp/go-bench-away-job-cb36c6a1-aca4-4a74-8bdf-98021bb5bb09-4068715764/results.txt > SHA_FILE=/tmp/go-bench-away-job-cb36c6a1-aca4-4a74-8bdf-98021bb5bb09-4068715764/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-cb36c6a1-aca4-4a74-8bdf-98021bb5bb09-4068715764/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-cb36c6a1-aca4-4a74-8bdf-98021bb5bb09-4068715764/source.git SHA of main: f7d78f68993c74af5674fa49898481e3ee6a15a1 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-build2814048842=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-cb36c6a1-aca4-4a74-8bdf-98021bb5bb09-4068715764/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 48473083 73.92 ns/op 148.82 MB/s Benchmark______Pub0b_Payload-16 46015622 74.85 ns/op 146.97 MB/s Benchmark______Pub0b_Payload-16 46222620 74.29 ns/op 148.06 MB/s Benchmark______Pub0b_Payload-16 46217566 73.98 ns/op 148.69 MB/s Benchmark______Pub0b_Payload-16 44772326 73.98 ns/op 148.70 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45593482 74.72 ns/op 254.30 MB/s Benchmark______Pub8b_Payload-16 45464161 74.63 ns/op 254.61 MB/s Benchmark______Pub8b_Payload-16 42507601 74.62 ns/op 254.62 MB/s Benchmark______Pub8b_Payload-16 43206295 74.53 ns/op 254.95 MB/s Benchmark______Pub8b_Payload-16 45594142 74.93 ns/op 253.57 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43168486 79.15 ns/op 555.91 MB/s Benchmark_____Pub32b_Payload-16 43055828 79.57 ns/op 552.99 MB/s Benchmark_____Pub32b_Payload-16 42821310 79.30 ns/op 554.84 MB/s Benchmark_____Pub32b_Payload-16 37888149 79.20 ns/op 555.54 MB/s Benchmark_____Pub32b_Payload-16 42939763 80.88 ns/op 544.03 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 37132579 89.08 ns/op 1582.78 MB/s Benchmark____Pub128B_Payload-16 37955956 90.97 ns/op 1549.88 MB/s Benchmark____Pub128B_Payload-16 38445602 88.42 ns/op 1594.71 MB/s Benchmark____Pub128B_Payload-16 37536955 92.95 ns/op 1517.00 MB/s Benchmark____Pub128B_Payload-16 38224909 89.53 ns/op 1574.95 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 34632086 97.89 ns/op 2747.99 MB/s Benchmark____Pub256B_Payload-16 32078881 96.64 ns/op 2783.42 MB/s Benchmark____Pub256B_Payload-16 34828941 97.03 ns/op 2772.40 MB/s Benchmark____Pub256B_Payload-16 35428030 108.3 ns/op 2483.53 MB/s Benchmark____Pub256B_Payload-16 31484571 101.5 ns/op 2650.25 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24089940 142.9 ns/op 7261.63 MB/s Benchmark______Pub1K_Payload-16 21768140 144.2 ns/op 7196.84 MB/s Benchmark______Pub1K_Payload-16 24023205 150.2 ns/op 6909.96 MB/s Benchmark______Pub1K_Payload-16 21051985 144.0 ns/op 7209.15 MB/s Benchmark______Pub1K_Payload-16 19286485 158.6 ns/op 6545.08 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5821398 622.8 ns/op 6599.39 MB/s Benchmark______Pub4K_Payload-16 5766555 609.1 ns/op 6747.68 MB/s Benchmark______Pub4K_Payload-16 5524124 613.9 ns/op 6694.90 MB/s Benchmark______Pub4K_Payload-16 5855017 620.9 ns/op 6619.49 MB/s Benchmark______Pub4K_Payload-16 5185374 613.0 ns/op 6704.70 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2771966 1264 ns/op 6492.12 MB/s Benchmark______Pub8K_Payload-16 2698946 1283 ns/op 6395.23 MB/s Benchmark______Pub8K_Payload-16 2748160 1280 ns/op 6412.67 MB/s Benchmark______Pub8K_Payload-16 2733645 1276 ns/op 6429.67 MB/s Benchmark______Pub8K_Payload-16 2789382 1286 ns/op 6381.06 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 787267 7740 ns/op 4235.51 MB/s Benchmark_____Pub32K_Payload-16 568854 5402 ns/op 6068.67 MB/s Benchmark_____Pub32K_Payload-16 631297 5314 ns/op 6168.66 MB/s Benchmark_____Pub32K_Payload-16 668373 5332 ns/op 6148.84 MB/s Benchmark_____Pub32K_Payload-16 590544 5394 ns/op 6077.57 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31476813 96.10 ns/op 114.47 MB/s Benchmark__AuthPub0b_Payload-16 35893564 96.00 ns/op 114.58 MB/s Benchmark__AuthPub0b_Payload-16 35780853 96.05 ns/op 114.52 MB/s Benchmark__AuthPub0b_Payload-16 35764170 95.97 ns/op 114.62 MB/s Benchmark__AuthPub0b_Payload-16 32086550 95.70 ns/op 114.94 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15569266 226.6 ns/op Benchmark_____________PubSub-16 15525112 227.8 ns/op Benchmark_____________PubSub-16 15619406 227.4 ns/op Benchmark_____________PubSub-16 15603027 226.9 ns/op Benchmark_____________PubSub-16 15363584 226.8 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15696429 226.6 ns/op Benchmark_____PubSubTwoConns-16 15813841 225.7 ns/op Benchmark_____PubSubTwoConns-16 15762759 225.5 ns/op Benchmark_____PubSubTwoConns-16 15847632 227.0 ns/op Benchmark_____PubSubTwoConns-16 15705675 225.1 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58368->127.0.0.1:35327: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46722->127.0.0.1:33837: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:44628->127.0.0.1:33869: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46542->127.0.0.1:39491: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:39526->127.0.0.1:37221: 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 14495022 245.6 ns/op Benchmark_____PubTwoQueueSub-16 14357239 244.8 ns/op Benchmark_____PubTwoQueueSub-16 14398195 245.8 ns/op Benchmark_____PubTwoQueueSub-16 14424628 245.2 ns/op Benchmark_____PubTwoQueueSub-16 14399455 244.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14452482 244.4 ns/op Benchmark____PubFourQueueSub-16 14364645 244.3 ns/op Benchmark____PubFourQueueSub-16 14412231 244.8 ns/op Benchmark____PubFourQueueSub-16 14415410 244.7 ns/op Benchmark____PubFourQueueSub-16 14422834 244.8 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14417863 245.0 ns/op Benchmark___PubEightQueueSub-16 14391057 244.2 ns/op Benchmark___PubEightQueueSub-16 14585762 244.5 ns/op Benchmark___PubEightQueueSub-16 14489990 245.4 ns/op Benchmark___PubEightQueueSub-16 14524027 245.1 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22950 156121 ns/op Benchmark_PubSub512kTwoConns-16 22916 156764 ns/op Benchmark_PubSub512kTwoConns-16 22994 155159 ns/op Benchmark_PubSub512kTwoConns-16 22988 156263 ns/op Benchmark_PubSub512kTwoConns-16 23042 155838 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15324586 228.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15087469 228.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15108855 227.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15217653 230.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15218917 228.8 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15222122 229.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15255590 229.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15174232 229.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15331041 229.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15270369 228.2 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11234516 313.3 ns/op Benchmark____RoutedPubSub_0b-16 11653578 316.0 ns/op Benchmark____RoutedPubSub_0b-16 11168091 316.1 ns/op Benchmark____RoutedPubSub_0b-16 11758989 318.5 ns/op Benchmark____RoutedPubSub_0b-16 11716324 316.9 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6676656 538.9 ns/op Benchmark____RoutedPubSub_1K-16 6653065 631.1 ns/op Benchmark____RoutedPubSub_1K-16 6647179 537.3 ns/op Benchmark____RoutedPubSub_1K-16 6549964 534.7 ns/op Benchmark____RoutedPubSub_1K-16 6644791 538.4 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84884 41799 ns/op Benchmark__RoutedPubSub_100K-16 88438 42629 ns/op Benchmark__RoutedPubSub_100K-16 84234 46787 ns/op Benchmark__RoutedPubSub_100K-16 76681 46789 ns/op Benchmark__RoutedPubSub_100K-16 81453 46370 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9672247 319.0 ns/op Benchmark____Routed2QueueSub-16 9643323 320.7 ns/op Benchmark____Routed2QueueSub-16 9572848 323.4 ns/op Benchmark____Routed2QueueSub-16 9774423 320.2 ns/op Benchmark____Routed2QueueSub-16 9717670 328.6 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9426319 331.5 ns/op Benchmark____Routed4QueueSub-16 9480974 324.8 ns/op Benchmark____Routed4QueueSub-16 11232865 325.0 ns/op Benchmark____Routed4QueueSub-16 9515276 327.0 ns/op Benchmark____Routed4QueueSub-16 9621766 322.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9120326 329.7 ns/op Benchmark____Routed8QueueSub-16 9389772 332.7 ns/op Benchmark____Routed8QueueSub-16 9237846 328.7 ns/op Benchmark____Routed8QueueSub-16 9119880 331.5 ns/op Benchmark____Routed8QueueSub-16 10989618 330.9 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8846161 349.6 ns/op Benchmark___Routed16QueueSub-16 8851874 350.3 ns/op Benchmark___Routed16QueueSub-16 8659779 348.0 ns/op Benchmark___Routed16QueueSub-16 10309352 347.8 ns/op Benchmark___Routed16QueueSub-16 8729812 361.9 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6395014 550.7 ns/op Benchmark____________RouteCompressOff-16 6443546 550.3 ns/op Benchmark____________RouteCompressOff-16 6412590 555.2 ns/op Benchmark____________RouteCompressOff-16 6225772 553.6 ns/op Benchmark____________RouteCompressOff-16 6305737 552.0 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6442753 552.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6421650 555.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6183794 561.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6404100 555.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6395583 547.5 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6478170 554.5 ns/op Benchmark_________RouteCompressS2Fast-16 6345664 543.8 ns/op Benchmark_________RouteCompressS2Fast-16 6390872 553.7 ns/op Benchmark_________RouteCompressS2Fast-16 6349825 553.7 ns/op Benchmark_________RouteCompressS2Fast-16 6558988 550.4 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6361882 545.4 ns/op Benchmark_______RouteCompressS2Better-16 6311806 550.6 ns/op Benchmark_______RouteCompressS2Better-16 6528552 542.4 ns/op Benchmark_______RouteCompressS2Better-16 6432416 552.7 ns/op Benchmark_______RouteCompressS2Better-16 6292191 550.6 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6385970 551.5 ns/op Benchmark_________RouteCompressS2Best-16 6489010 552.9 ns/op Benchmark_________RouteCompressS2Best-16 6463567 555.1 ns/op Benchmark_________RouteCompressS2Best-16 6431092 554.2 ns/op Benchmark_________RouteCompressS2Best-16 6322638 548.6 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4675021 762.3 ns/op 326.64 MB/s Benchmark______FanOut_8x1x10-16 4699636 766.3 ns/op 324.95 MB/s Benchmark______FanOut_8x1x10-16 4743651 762.5 ns/op 326.55 MB/s Benchmark______FanOut_8x1x10-16 4710676 759.8 ns/op 327.73 MB/s Benchmark______FanOut_8x1x10-16 4648444 768.9 ns/op 323.84 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 579642 6158 ns/op 376.61 MB/s Benchmark_____FanOut_8x1x100-16 522506 6088 ns/op 380.93 MB/s Benchmark_____FanOut_8x1x100-16 545941 6071 ns/op 381.96 MB/s Benchmark_____FanOut_8x1x100-16 556141 6106 ns/op 379.80 MB/s Benchmark_____FanOut_8x1x100-16 555562 6071 ns/op 381.99 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47514 74859 ns/op 307.50 MB/s Benchmark____FanOut_8x10x100-16 47972 75778 ns/op 303.77 MB/s Benchmark____FanOut_8x10x100-16 47708 75020 ns/op 306.84 MB/s Benchmark____FanOut_8x10x100-16 47395 74920 ns/op 307.25 MB/s Benchmark____FanOut_8x10x100-16 48085 74924 ns/op 307.23 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5834 599282 ns/op 400.51 MB/s Benchmark___FanOut_8x10x1000-16 5908 606556 ns/op 395.71 MB/s Benchmark___FanOut_8x10x1000-16 5917 602501 ns/op 398.37 MB/s Benchmark___FanOut_8x10x1000-16 5686 608729 ns/op 394.30 MB/s Benchmark___FanOut_8x10x1000-16 5901 605046 ns/op 396.70 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4974 712013 ns/op 323.05 MB/s Benchmark___FanOut_8x100x100-16 4928 718579 ns/op 320.10 MB/s Benchmark___FanOut_8x100x100-16 4929 713519 ns/op 322.37 MB/s Benchmark___FanOut_8x100x100-16 4932 715983 ns/op 321.26 MB/s Benchmark___FanOut_8x100x100-16 4956 718061 ns/op 320.33 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 582 6232922 ns/op 385.06 MB/s Benchmark__FanOut_8x100x1000-16 566 6236098 ns/op 384.86 MB/s Benchmark__FanOut_8x100x1000-16 567 6276865 ns/op 382.36 MB/s Benchmark__FanOut_8x100x1000-16 556 6318768 ns/op 379.82 MB/s Benchmark__FanOut_8x100x1000-16 571 6214783 ns/op 386.18 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 517 6797539 ns/op 367.78 MB/s Benchmark__FanOut_8x10x10000-16 510 6790044 ns/op 368.19 MB/s Benchmark__FanOut_8x10x10000-16 523 6858350 ns/op 364.52 MB/s Benchmark__FanOut_8x10x10000-16 532 6786394 ns/op 368.39 MB/s Benchmark__FanOut_8x10x10000-16 518 6881568 ns/op 363.29 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 933 3809956 ns/op 301.85 MB/s Benchmark___FanOut_8x500x100-16 950 3815771 ns/op 301.39 MB/s Benchmark___FanOut_8x500x100-16 946 3825692 ns/op 300.60 MB/s Benchmark___FanOut_8x500x100-16 945 3800600 ns/op 302.59 MB/s Benchmark___FanOut_8x500x100-16 942 3789873 ns/op 303.45 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 367135 9521 ns/op 1537.83 MB/s Benchmark___FanOut_128x1x100-16 363128 9511 ns/op 1539.45 MB/s Benchmark___FanOut_128x1x100-16 363306 9496 ns/op 1541.76 MB/s Benchmark___FanOut_128x1x100-16 358395 9675 ns/op 1513.36 MB/s Benchmark___FanOut_128x1x100-16 366900 9463 ns/op 1547.24 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32516 111481 ns/op 1301.94 MB/s Benchmark__FanOut_128x10x100-16 32277 110171 ns/op 1317.41 MB/s Benchmark__FanOut_128x10x100-16 32269 111147 ns/op 1305.84 MB/s Benchmark__FanOut_128x10x100-16 31912 110856 ns/op 1309.28 MB/s Benchmark__FanOut_128x10x100-16 32607 111509 ns/op 1301.61 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3975 874499 ns/op 1669.69 MB/s Benchmark_FanOut_128x10x1000-16 4116 878823 ns/op 1661.47 MB/s Benchmark_FanOut_128x10x1000-16 3934 870086 ns/op 1678.16 MB/s Benchmark_FanOut_128x10x1000-16 4137 888369 ns/op 1643.62 MB/s Benchmark_FanOut_128x10x1000-16 3966 874251 ns/op 1670.16 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3496 1016035 ns/op 1427.25 MB/s Benchmark_FanOut_128x100x100-16 3483 1016749 ns/op 1426.25 MB/s Benchmark_FanOut_128x100x100-16 3406 1012726 ns/op 1431.92 MB/s Benchmark_FanOut_128x100x100-16 3478 1017681 ns/op 1424.95 MB/s Benchmark_FanOut_128x100x100-16 3480 1020474 ns/op 1421.05 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 376 9368934 ns/op 1558.36 MB/s BenchmarkFanOut_128x100x1000-16 380 9410950 ns/op 1551.40 MB/s BenchmarkFanOut_128x100x1000-16 382 9358740 ns/op 1560.05 MB/s BenchmarkFanOut_128x100x1000-16 378 9340421 ns/op 1563.11 MB/s BenchmarkFanOut_128x100x1000-16 381 9251695 ns/op 1578.10 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 368 9699816 ns/op 1515.51 MB/s BenchmarkFanOut_128x10x10000-16 368 9739150 ns/op 1509.39 MB/s BenchmarkFanOut_128x10x10000-16 369 9673378 ns/op 1519.65 MB/s BenchmarkFanOut_128x10x10000-16 367 9808183 ns/op 1498.76 MB/s BenchmarkFanOut_128x10x10000-16 367 9671428 ns/op 1519.96 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 673 5355851 ns/op 1353.69 MB/s BenchmarkFanOut__128x500x100-16 667 5303653 ns/op 1367.01 MB/s BenchmarkFanOut__128x500x100-16 669 5311547 ns/op 1364.98 MB/s BenchmarkFanOut__128x500x100-16 668 5319029 ns/op 1363.06 MB/s BenchmarkFanOut__128x500x100-16 662 5307126 ns/op 1366.11 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1954 1865226 ns/op 2836.40 MB/s Benchmark_FanOut_512x100x100-16 1933 1858508 ns/op 2846.65 MB/s Benchmark_FanOut_512x100x100-16 1947 1850164 ns/op 2859.49 MB/s Benchmark_FanOut_512x100x100-16 1912 1863685 ns/op 2838.74 MB/s Benchmark_FanOut_512x100x100-16 1909 1858009 ns/op 2847.42 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 16911284 ns/op 3134.03 MB/s Benchmark__FanOut_512x100x1k-16 213 16966110 ns/op 3123.91 MB/s Benchmark__FanOut_512x100x1k-16 216 16690088 ns/op 3175.57 MB/s Benchmark__FanOut_512x100x1k-16 216 16713702 ns/op 3171.08 MB/s Benchmark__FanOut_512x100x1k-16 213 16528076 ns/op 3206.70 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2725 1137274 ns/op 9171.96 MB/s Benchmark____FanOut_1kx10x1k-16 2959 1142588 ns/op 9129.31 MB/s Benchmark____FanOut_1kx10x1k-16 3100 1155932 ns/op 9023.92 MB/s Benchmark____FanOut_1kx10x1k-16 2956 1155853 ns/op 9024.53 MB/s Benchmark____FanOut_1kx10x1k-16 3172 1148696 ns/op 9080.76 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2755 1268940 ns/op 8212.40 MB/s Benchmark__FanOut_1kx100x100-16 2712 1271295 ns/op 8197.18 MB/s Benchmark__FanOut_1kx100x100-16 2740 1264835 ns/op 8239.05 MB/s Benchmark__FanOut_1kx100x100-16 2738 1268655 ns/op 8214.24 MB/s Benchmark__FanOut_1kx100x100-16 2828 1266011 ns/op 8231.40 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4506674 771.3 ns/op 322.83 MB/s Benchmark_____RFanOut_8x1x10-16 4476380 788.2 ns/op 315.89 MB/s Benchmark_____RFanOut_8x1x10-16 4513326 766.6 ns/op 324.80 MB/s Benchmark_____RFanOut_8x1x10-16 4458998 777.0 ns/op 320.46 MB/s Benchmark_____RFanOut_8x1x10-16 4531051 769.2 ns/op 323.72 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 525440 6258 ns/op 370.54 MB/s Benchmark____RFanOut_8x1x100-16 529740 6175 ns/op 375.55 MB/s Benchmark____RFanOut_8x1x100-16 522745 6246 ns/op 371.28 MB/s Benchmark____RFanOut_8x1x100-16 535078 6247 ns/op 371.20 MB/s Benchmark____RFanOut_8x1x100-16 535047 6260 ns/op 370.45 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47434 75669 ns/op 304.21 MB/s Benchmark___RFanOut_8x10x100-16 46414 74887 ns/op 307.38 MB/s Benchmark___RFanOut_8x10x100-16 47455 75899 ns/op 303.28 MB/s Benchmark___RFanOut_8x10x100-16 47768 75800 ns/op 303.68 MB/s Benchmark___RFanOut_8x10x100-16 47402 76853 ns/op 299.52 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5695 616428 ns/op 389.37 MB/s Benchmark__RFanOut_8x10x1000-16 5353 611785 ns/op 392.33 MB/s Benchmark__RFanOut_8x10x1000-16 5935 610965 ns/op 392.85 MB/s Benchmark__RFanOut_8x10x1000-16 5932 603168 ns/op 397.93 MB/s Benchmark__RFanOut_8x10x1000-16 5918 601828 ns/op 398.82 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4902 715717 ns/op 321.38 MB/s Benchmark__RFanOut_8x100x100-16 4959 708673 ns/op 324.58 MB/s Benchmark__RFanOut_8x100x100-16 4924 717837 ns/op 320.43 MB/s Benchmark__RFanOut_8x100x100-16 4942 717827 ns/op 320.44 MB/s Benchmark__RFanOut_8x100x100-16 4908 707279 ns/op 325.22 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 555 6250659 ns/op 383.96 MB/s Benchmark_RFanOut_8x100x1000-16 559 6263602 ns/op 383.17 MB/s Benchmark_RFanOut_8x100x1000-16 561 6310006 ns/op 380.35 MB/s Benchmark_RFanOut_8x100x1000-16 558 6238994 ns/op 384.68 MB/s Benchmark_RFanOut_8x100x1000-16 552 6497095 ns/op 369.40 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 528 6728406 ns/op 371.56 MB/s Benchmark_RFanOut_8x10x10000-16 514 6849234 ns/op 365.01 MB/s Benchmark_RFanOut_8x10x10000-16 520 6732096 ns/op 371.36 MB/s Benchmark_RFanOut_8x10x10000-16 525 6728117 ns/op 371.58 MB/s Benchmark_RFanOut_8x10x10000-16 517 6749077 ns/op 370.42 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3166 1171540 ns/op 8903.70 MB/s Benchmark_RFanOut_1kx10x1000-16 3223 1180642 ns/op 8835.05 MB/s Benchmark_RFanOut_1kx10x1000-16 2980 1153183 ns/op 9045.43 MB/s Benchmark_RFanOut_1kx10x1000-16 3014 1163323 ns/op 8966.59 MB/s Benchmark_RFanOut_1kx10x1000-16 2840 1191321 ns/op 8755.86 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6933391 509.3 ns/op 4080.13 MB/s Benchmark_____FanIn_1kx100x1-16 6974636 507.7 ns/op 4093.33 MB/s Benchmark_____FanIn_1kx100x1-16 6887343 508.2 ns/op 4088.72 MB/s Benchmark_____FanIn_1kx100x1-16 6894990 508.5 ns/op 4086.15 MB/s Benchmark_____FanIn_1kx100x1-16 6941396 508.6 ns/op 4085.85 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2636486 1390 ns/op 5915.05 MB/s Benchmark_____FanIn_4kx100x1-16 2636245 1376 ns/op 5976.60 MB/s Benchmark_____FanIn_4kx100x1-16 2599902 1382 ns/op 5951.44 MB/s Benchmark_____FanIn_4kx100x1-16 2645023 1374 ns/op 5984.95 MB/s Benchmark_____FanIn_4kx100x1-16 2625908 1382 ns/op 5948.98 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1665039 2113 ns/op 7766.80 MB/s Benchmark_____FanIn_8kx100x1-16 1688946 2128 ns/op 7714.24 MB/s Benchmark_____FanIn_8kx100x1-16 1710116 2118 ns/op 7751.42 MB/s Benchmark_____FanIn_8kx100x1-16 1703698 2133 ns/op 7695.84 MB/s Benchmark_____FanIn_8kx100x1-16 1673445 2128 ns/op 7713.88 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 871110 4168 ns/op 7869.62 MB/s Benchmark____FanIn_16kx100x1-16 861920 4174 ns/op 7857.29 MB/s Benchmark____FanIn_16kx100x1-16 853666 4196 ns/op 7817.07 MB/s Benchmark____FanIn_16kx100x1-16 876187 4143 ns/op 7916.80 MB/s Benchmark____FanIn_16kx100x1-16 866534 4171 ns/op 7863.23 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 165380 19789 ns/op 6624.95 MB/s Benchmark____FanIn_64kx100x1-16 168266 19882 ns/op 6594.03 MB/s Benchmark____FanIn_64kx100x1-16 171427 20014 ns/op 6550.46 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 523440705 vs 10082051400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32784->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:60692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60638->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: 1340231085 vs 10691694300 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35378->127.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:34998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35648->127.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: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: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:35254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35200->127.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:34878->127.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:35274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34894->127.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:35598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34906->127.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:35422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35658->127.0.0.1:5222: write: connection reset by peer bench_test.go: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:35496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35008->127.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:35148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35106->127.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:35122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35368->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 369804890 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37580->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:36750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36916->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: 409000800 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38882->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: 117325550 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40602->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: 851691730 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42812->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 263097630 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44596->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5505961 646.7 ns/op 439.13 MB/s Benchmark___BumpPubCount_1x3-16 5571294 639.1 ns/op 444.40 MB/s Benchmark___BumpPubCount_1x3-16 5577868 648.0 ns/op 438.30 MB/s Benchmark___BumpPubCount_1x3-16 5495018 642.1 ns/op 442.28 MB/s Benchmark___BumpPubCount_1x3-16 5591414 639.0 ns/op 444.46 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5296717 674.7 ns/op 420.90 MB/s Benchmark___BumpPubCount_2x3-16 5280148 679.3 ns/op 418.07 MB/s Benchmark___BumpPubCount_2x3-16 5269983 675.5 ns/op 420.43 MB/s Benchmark___BumpPubCount_2x3-16 5255245 674.6 ns/op 421.02 MB/s Benchmark___BumpPubCount_2x3-16 5288112 677.9 ns/op 418.91 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5375106 647.8 ns/op 438.40 MB/s Benchmark___BumpPubCount_5x3-16 5541751 648.8 ns/op 437.70 MB/s Benchmark___BumpPubCount_5x3-16 5503231 647.2 ns/op 438.84 MB/s Benchmark___BumpPubCount_5x3-16 5315412 646.9 ns/op 439.01 MB/s Benchmark___BumpPubCount_5x3-16 5519688 646.3 ns/op 439.40 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5493505 648.0 ns/op 438.25 MB/s Benchmark__BumpPubCount_10x3-16 5550386 647.8 ns/op 438.40 MB/s Benchmark__BumpPubCount_10x3-16 5555551 649.0 ns/op 437.62 MB/s Benchmark__BumpPubCount_10x3-16 5473071 650.4 ns/op 436.63 MB/s Benchmark__BumpPubCount_10x3-16 5525996 650.4 ns/op 436.63 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12148900 289.4 ns/op 3593.02 MB/s Benchmark____GWs_Opt_1kx01x0-16 12199740 286.4 ns/op 3630.92 MB/s Benchmark____GWs_Opt_1kx01x0-16 12720174 281.9 ns/op 3688.67 MB/s Benchmark____GWs_Opt_1kx01x0-16 12913569 281.5 ns/op 3694.01 MB/s Benchmark____GWs_Opt_1kx01x0-16 12800368 276.3 ns/op 3763.87 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10307323 356.1 ns/op 5795.96 MB/s Benchmark____GWs_Opt_2kx01x0-16 10731511 343.1 ns/op 6016.31 MB/s Benchmark____GWs_Opt_2kx01x0-16 11147983 358.1 ns/op 5763.40 MB/s Benchmark____GWs_Opt_2kx01x0-16 9906586 336.5 ns/op 6133.47 MB/s Benchmark____GWs_Opt_2kx01x0-16 10387712 352.8 ns/op 5849.87 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5574988 607.9 ns/op 6764.14 MB/s Benchmark____GWs_Opt_4kx01x0-16 5916627 638.4 ns/op 6440.86 MB/s Benchmark____GWs_Opt_4kx01x0-16 5711466 623.9 ns/op 6590.67 MB/s Benchmark____GWs_Opt_4kx01x0-16 5736663 610.7 ns/op 6733.29 MB/s Benchmark____GWs_Opt_4kx01x0-16 5855840 632.1 ns/op 6505.07 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30455974 117.7 ns/op 8835.74 MB/s Benchmark____GWs_Opt_1kx10x0-16 28300393 124.1 ns/op 8378.46 MB/s Benchmark____GWs_Opt_1kx10x0-16 30275518 114.8 ns/op 9058.45 MB/s Benchmark____GWs_Opt_1kx10x0-16 31801521 111.1 ns/op 9358.72 MB/s Benchmark____GWs_Opt_1kx10x0-16 33477531 127.0 ns/op 8187.21 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23786594 144.9 ns/op 14242.11 MB/s Benchmark____GWs_Opt_2kx10x0-16 22331869 141.6 ns/op 14576.99 MB/s Benchmark____GWs_Opt_2kx10x0-16 24304320 147.7 ns/op 13977.46 MB/s Benchmark____GWs_Opt_2kx10x0-16 24721897 138.2 ns/op 14930.34 MB/s Benchmark____GWs_Opt_2kx10x0-16 20615852 154.1 ns/op 13391.06 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 9194049 358.5 ns/op 11469.29 MB/s Benchmark____GWs_Opt_4kx10x0-16 12349368 282.4 ns/op 14563.45 MB/s Benchmark____GWs_Opt_4kx10x0-16 12453850 293.5 ns/op 14011.33 MB/s Benchmark____GWs_Opt_4kx10x0-16 11986270 305.4 ns/op 13462.25 MB/s Benchmark____GWs_Opt_4kx10x0-16 12708378 293.9 ns/op 13991.12 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6606114 546.1 ns/op 5722.48 MB/s Benchmark____GWs_Opt_1kx01x1-16 6553851 552.9 ns/op 5652.24 MB/s Benchmark____GWs_Opt_1kx01x1-16 6398833 548.9 ns/op 5692.91 MB/s Benchmark____GWs_Opt_1kx01x1-16 6293894 550.0 ns/op 5681.92 MB/s Benchmark____GWs_Opt_1kx01x1-16 6336057 559.6 ns/op 5584.31 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4521387 772.0 ns/op 8027.25 MB/s Benchmark____GWs_Opt_2kx01x1-16 4488706 1008 ns/op 6150.23 MB/s Benchmark____GWs_Opt_2kx01x1-16 4697752 759.2 ns/op 8162.01 MB/s Benchmark____GWs_Opt_2kx01x1-16 4582489 950.0 ns/op 6523.29 MB/s Benchmark____GWs_Opt_2kx01x1-16 4615000 1067 ns/op 5806.50 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2625165 1348 ns/op 9157.11 MB/s Benchmark____GWs_Opt_4kx01x1-16 2498742 1369 ns/op 9016.94 MB/s Benchmark____GWs_Opt_4kx01x1-16 2613391 1590 ns/op 7760.92 MB/s Benchmark____GWs_Opt_4kx01x1-16 2681035 1354 ns/op 9116.84 MB/s Benchmark____GWs_Opt_4kx01x1-16 2466586 1371 ns/op 9002.08 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 5886422 558.8 ns/op 5591.92 MB/s Benchmark____GWs_Opt_1kx10x1-16 6080682 558.0 ns/op 5600.55 MB/s Benchmark____GWs_Opt_1kx10x1-16 6140044 552.5 ns/op 5656.13 MB/s Benchmark____GWs_Opt_1kx10x1-16 6146527 570.2 ns/op 5480.81 MB/s Benchmark____GWs_Opt_1kx10x1-16 6405632 561.0 ns/op 5569.99 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4132053 823.5 ns/op 7525.20 MB/s Benchmark____GWs_Opt_2kx10x1-16 4154158 856.7 ns/op 7233.97 MB/s Benchmark____GWs_Opt_2kx10x1-16 4053132 838.5 ns/op 7391.01 MB/s Benchmark____GWs_Opt_2kx10x1-16 4142666 853.6 ns/op 7260.21 MB/s Benchmark____GWs_Opt_2kx10x1-16 4115193 839.6 ns/op 7380.50 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2375676 1540 ns/op 8014.31 MB/s Benchmark____GWs_Opt_4kx10x1-16 2319976 1514 ns/op 8151.13 MB/s Benchmark____GWs_Opt_4kx10x1-16 2386671 1480 ns/op 8336.78 MB/s Benchmark____GWs_Opt_4kx10x1-16 2353104 2066 ns/op 5973.72 MB/s Benchmark____GWs_Opt_4kx10x1-16 2400483 1519 ns/op 8121.97 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12465595 286.6 ns/op 3628.20 MB/s Benchmark____GWs_Int_1kx01x0-16 12291945 286.9 ns/op 3625.08 MB/s Benchmark____GWs_Int_1kx01x0-16 12090706 283.3 ns/op 3670.55 MB/s Benchmark____GWs_Int_1kx01x0-16 12670640 294.1 ns/op 3536.11 MB/s Benchmark____GWs_Int_1kx01x0-16 12456372 293.5 ns/op 3543.82 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9610902 371.3 ns/op 5558.28 MB/s Benchmark____GWs_Int_2kx01x0-16 9249688 353.7 ns/op 5835.14 MB/s Benchmark____GWs_Int_2kx01x0-16 10258998 353.4 ns/op 5840.11 MB/s Benchmark____GWs_Int_2kx01x0-16 10146705 367.1 ns/op 5623.00 MB/s Benchmark____GWs_Int_2kx01x0-16 9952077 348.9 ns/op 5915.24 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5786544 613.5 ns/op 6702.41 MB/s Benchmark____GWs_Int_4kx01x0-16 5683425 633.4 ns/op 6492.33 MB/s Benchmark____GWs_Int_4kx01x0-16 5704144 637.8 ns/op 6446.86 MB/s Benchmark____GWs_Int_4kx01x0-16 5481298 628.3 ns/op 6544.31 MB/s Benchmark____GWs_Int_4kx01x0-16 5890704 631.6 ns/op 6510.91 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 28458896 109.0 ns/op 9541.54 MB/s Benchmark____GWs_Int_1kx10x0-16 29749274 112.2 ns/op 9271.24 MB/s Benchmark____GWs_Int_1kx10x0-16 32519184 110.5 ns/op 9410.71 MB/s Benchmark____GWs_Int_1kx10x0-16 31293901 110.2 ns/op 9440.83 MB/s Benchmark____GWs_Int_1kx10x0-16 28256418 111.2 ns/op 9354.70 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24427882 142.3 ns/op 14509.29 MB/s Benchmark____GWs_Int_2kx10x0-16 26477768 145.2 ns/op 14210.20 MB/s Benchmark____GWs_Int_2kx10x0-16 25060119 140.1 ns/op 14733.85 MB/s Benchmark____GWs_Int_2kx10x0-16 21495756 149.0 ns/op 13852.31 MB/s Benchmark____GWs_Int_2kx10x0-16 22980825 152.8 ns/op 13504.50 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 7650622 1906 ns/op 2156.90 MB/s Benchmark____GWs_Int_4kx10x0-16 13475283 306.0 ns/op 13437.07 MB/s Benchmark____GWs_Int_4kx10x0-16 13418836 2507 ns/op 1640.11 MB/s Benchmark____GWs_Int_4kx10x0-16 13250397 314.2 ns/op 13087.24 MB/s Benchmark____GWs_Int_4kx10x0-16 13110668 283.7 ns/op 14493.75 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6323097 562.7 ns/op 5553.30 MB/s Benchmark____GWs_Int_1kx01x1-16 6541693 565.7 ns/op 5524.27 MB/s Benchmark____GWs_Int_1kx01x1-16 6685648 561.0 ns/op 5570.50 MB/s Benchmark____GWs_Int_1kx01x1-16 6461670 556.7 ns/op 5613.19 MB/s Benchmark____GWs_Int_1kx01x1-16 6431038 562.6 ns/op 5554.81 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4574709 774.9 ns/op 7996.68 MB/s Benchmark____GWs_Int_2kx01x1-16 4705639 766.0 ns/op 8090.44 MB/s Benchmark____GWs_Int_2kx01x1-16 4651843 763.9 ns/op 8111.84 MB/s Benchmark____GWs_Int_2kx01x1-16 4632451 811.8 ns/op 7633.92 MB/s Benchmark____GWs_Int_2kx01x1-16 4673864 778.4 ns/op 7960.97 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2384124 1367 ns/op 9025.42 MB/s Benchmark____GWs_Int_4kx01x1-16 2622907 1370 ns/op 9007.09 MB/s Benchmark____GWs_Int_4kx01x1-16 2633059 1373 ns/op 8987.15 MB/s Benchmark____GWs_Int_4kx01x1-16 2531085 1376 ns/op 8970.04 MB/s Benchmark____GWs_Int_4kx01x1-16 2612065 1570 ns/op 7861.55 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6437089 566.8 ns/op 5513.46 MB/s Benchmark____GWs_Int_1kx10x1-16 6107251 563.1 ns/op 5549.53 MB/s Benchmark____GWs_Int_1kx10x1-16 6247164 584.0 ns/op 5351.31 MB/s Benchmark____GWs_Int_1kx10x1-16 6254752 560.7 ns/op 5573.19 MB/s Benchmark____GWs_Int_1kx10x1-16 6111153 561.2 ns/op 5568.52 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4151083 864.3 ns/op 7170.34 MB/s Benchmark____GWs_Int_2kx10x1-16 4138365 857.6 ns/op 7225.59 MB/s Benchmark____GWs_Int_2kx10x1-16 4111962 858.7 ns/op 7216.75 MB/s Benchmark____GWs_Int_2kx10x1-16 4147561 843.7 ns/op 7344.77 MB/s Benchmark____GWs_Int_2kx10x1-16 4064932 846.9 ns/op 7316.97 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2257777 1506 ns/op 8194.54 MB/s Benchmark____GWs_Int_4kx10x1-16 2256867 1587 ns/op 7776.71 MB/s Benchmark____GWs_Int_4kx10x1-16 2392900 1545 ns/op 7985.40 MB/s Benchmark____GWs_Int_4kx10x1-16 2325829 1553 ns/op 7945.90 MB/s Benchmark____GWs_Int_4kx10x1-16 2350185 1498 ns/op 8241.02 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8274817 438.9 ns/op 232.40 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8242914 436.1 ns/op 233.91 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8505645 443.1 ns/op 230.22 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8136430 436.9 ns/op 233.49 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8363650 442.2 ns/op 230.65 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 640058 4989 ns/op 35.48 MB/s Benchmark__GWs_Reqs_1SubEach-16 739917 5159 ns/op 34.31 MB/s Benchmark__GWs_Reqs_1SubEach-16 733232 5315 ns/op 33.30 MB/s Benchmark__GWs_Reqs_1SubEach-16 731252 5312 ns/op 33.32 MB/s Benchmark__GWs_Reqs_1SubEach-16 709940 5264 ns/op 33.62 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2095.453s ❌ Non-zero exit code: 1