> ROOT_DIR=/tmp/go-bench-away-job-6ebda845-0bcc-4c58-8fe4-0c2b17acc59a-2965273036 > OUTPUT_FILE=/tmp/go-bench-away-job-6ebda845-0bcc-4c58-8fe4-0c2b17acc59a-2965273036/results.txt > SHA_FILE=/tmp/go-bench-away-job-6ebda845-0bcc-4c58-8fe4-0c2b17acc59a-2965273036/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-6ebda845-0bcc-4c58-8fe4-0c2b17acc59a-2965273036/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-6ebda845-0bcc-4c58-8fe4-0c2b17acc59a-2965273036/source.git SHA of main: 146b0be65b3591e925cce61ce9d2cae32cdeb227 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-build1100085821=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-6ebda845-0bcc-4c58-8fe4-0c2b17acc59a-2965273036/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 49411453 72.68 ns/op 151.35 MB/s Benchmark______Pub0b_Payload-16 46897330 78.71 ns/op 139.75 MB/s Benchmark______Pub0b_Payload-16 46808047 72.66 ns/op 151.39 MB/s Benchmark______Pub0b_Payload-16 49517716 72.71 ns/op 151.29 MB/s Benchmark______Pub0b_Payload-16 46860216 72.86 ns/op 150.98 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 47920641 73.44 ns/op 258.72 MB/s Benchmark______Pub8b_Payload-16 48782552 73.30 ns/op 259.21 MB/s Benchmark______Pub8b_Payload-16 46108380 73.29 ns/op 259.24 MB/s Benchmark______Pub8b_Payload-16 45080155 74.10 ns/op 256.41 MB/s Benchmark______Pub8b_Payload-16 48375436 73.38 ns/op 258.94 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44377910 78.12 ns/op 563.20 MB/s Benchmark_____Pub32b_Payload-16 44264422 76.83 ns/op 572.70 MB/s Benchmark_____Pub32b_Payload-16 46637337 77.31 ns/op 569.15 MB/s Benchmark_____Pub32b_Payload-16 44068500 77.47 ns/op 567.97 MB/s Benchmark_____Pub32b_Payload-16 46714720 77.43 ns/op 568.25 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39695365 88.22 ns/op 1598.31 MB/s Benchmark____Pub128B_Payload-16 41913553 86.57 ns/op 1628.69 MB/s Benchmark____Pub128B_Payload-16 36986724 86.02 ns/op 1639.13 MB/s Benchmark____Pub128B_Payload-16 39546427 86.96 ns/op 1621.50 MB/s Benchmark____Pub128B_Payload-16 39598395 87.10 ns/op 1618.79 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36970797 94.25 ns/op 2854.03 MB/s Benchmark____Pub256B_Payload-16 38171080 94.66 ns/op 2841.76 MB/s Benchmark____Pub256B_Payload-16 36606471 96.64 ns/op 2783.44 MB/s Benchmark____Pub256B_Payload-16 35971256 94.11 ns/op 2858.27 MB/s Benchmark____Pub256B_Payload-16 31533403 107.6 ns/op 2499.24 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24645633 147.4 ns/op 7043.27 MB/s Benchmark______Pub1K_Payload-16 24234219 138.5 ns/op 7495.86 MB/s Benchmark______Pub1K_Payload-16 23001603 136.8 ns/op 7588.30 MB/s Benchmark______Pub1K_Payload-16 26227833 140.0 ns/op 7414.95 MB/s Benchmark______Pub1K_Payload-16 22030596 147.4 ns/op 7040.98 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5790013 615.7 ns/op 6675.20 MB/s Benchmark______Pub4K_Payload-16 5439391 616.3 ns/op 6669.03 MB/s Benchmark______Pub4K_Payload-16 5435308 621.9 ns/op 6608.30 MB/s Benchmark______Pub4K_Payload-16 5389699 615.8 ns/op 6674.74 MB/s Benchmark______Pub4K_Payload-16 5655828 619.8 ns/op 6631.14 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2735619 1277 ns/op 6427.60 MB/s Benchmark______Pub8K_Payload-16 2786113 1286 ns/op 6382.36 MB/s Benchmark______Pub8K_Payload-16 2720917 1271 ns/op 6455.63 MB/s Benchmark______Pub8K_Payload-16 2738166 1290 ns/op 6362.16 MB/s Benchmark______Pub8K_Payload-16 2737078 1288 ns/op 6369.19 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 670360 6257 ns/op 5239.77 MB/s Benchmark_____Pub32K_Payload-16 576222 5414 ns/op 6054.86 MB/s Benchmark_____Pub32K_Payload-16 664225 5390 ns/op 6082.55 MB/s Benchmark_____Pub32K_Payload-16 661456 5531 ns/op 5927.59 MB/s Benchmark_____Pub32K_Payload-16 665853 5433 ns/op 6034.30 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32295769 99.47 ns/op 110.59 MB/s Benchmark__AuthPub0b_Payload-16 35989435 94.84 ns/op 115.99 MB/s Benchmark__AuthPub0b_Payload-16 36027243 94.82 ns/op 116.01 MB/s Benchmark__AuthPub0b_Payload-16 37932122 95.07 ns/op 115.70 MB/s Benchmark__AuthPub0b_Payload-16 36210148 94.77 ns/op 116.07 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15429802 228.1 ns/op Benchmark_____________PubSub-16 15470782 226.7 ns/op Benchmark_____________PubSub-16 15478086 227.1 ns/op Benchmark_____________PubSub-16 15616747 227.1 ns/op Benchmark_____________PubSub-16 15549315 227.9 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15667598 226.8 ns/op Benchmark_____PubSubTwoConns-16 15697334 226.3 ns/op Benchmark_____PubSubTwoConns-16 15524476 226.1 ns/op Benchmark_____PubSubTwoConns-16 15625663 225.6 ns/op Benchmark_____PubSubTwoConns-16 15708603 226.9 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:37170->127.0.0.1:39427: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:52512->127.0.0.1:46599: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46068->127.0.0.1:42465: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34552->127.0.0.1:42389: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:38632->127.0.0.1:42775: 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 14701086 244.4 ns/op Benchmark_____PubTwoQueueSub-16 14540288 242.4 ns/op Benchmark_____PubTwoQueueSub-16 14623396 244.5 ns/op Benchmark_____PubTwoQueueSub-16 14537802 243.9 ns/op Benchmark_____PubTwoQueueSub-16 14461964 242.9 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14415778 244.0 ns/op Benchmark____PubFourQueueSub-16 14645083 245.2 ns/op Benchmark____PubFourQueueSub-16 14393624 244.0 ns/op Benchmark____PubFourQueueSub-16 14462923 243.2 ns/op Benchmark____PubFourQueueSub-16 14627761 244.1 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14550272 244.6 ns/op Benchmark___PubEightQueueSub-16 14632424 244.6 ns/op Benchmark___PubEightQueueSub-16 14522275 243.1 ns/op Benchmark___PubEightQueueSub-16 14358483 244.4 ns/op Benchmark___PubEightQueueSub-16 14420077 243.1 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23178 154851 ns/op Benchmark_PubSub512kTwoConns-16 23047 154029 ns/op Benchmark_PubSub512kTwoConns-16 22552 157299 ns/op Benchmark_PubSub512kTwoConns-16 23086 157806 ns/op Benchmark_PubSub512kTwoConns-16 23878 153736 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15203874 230.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15041334 228.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15240078 230.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15314517 228.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15046987 229.9 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14968592 231.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15222104 231.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15056583 231.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15220633 230.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15112670 231.6 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11195511 314.9 ns/op Benchmark____RoutedPubSub_0b-16 11597482 314.1 ns/op Benchmark____RoutedPubSub_0b-16 10791604 313.4 ns/op Benchmark____RoutedPubSub_0b-16 11160409 319.3 ns/op Benchmark____RoutedPubSub_0b-16 11180503 315.5 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6683425 664.0 ns/op Benchmark____RoutedPubSub_1K-16 6749314 531.6 ns/op Benchmark____RoutedPubSub_1K-16 6527552 530.7 ns/op Benchmark____RoutedPubSub_1K-16 6564325 996.4 ns/op Benchmark____RoutedPubSub_1K-16 6539292 504.1 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85202 44499 ns/op Benchmark__RoutedPubSub_100K-16 84458 41861 ns/op Benchmark__RoutedPubSub_100K-16 87433 41879 ns/op Benchmark__RoutedPubSub_100K-16 83032 42153 ns/op Benchmark__RoutedPubSub_100K-16 85990 44176 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9809341 319.5 ns/op Benchmark____Routed2QueueSub-16 9627464 313.9 ns/op Benchmark____Routed2QueueSub-16 9573633 323.4 ns/op Benchmark____Routed2QueueSub-16 9651838 317.9 ns/op Benchmark____Routed2QueueSub-16 9558411 315.4 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 11123083 327.0 ns/op Benchmark____Routed4QueueSub-16 11363276 323.5 ns/op Benchmark____Routed4QueueSub-16 9509883 321.3 ns/op Benchmark____Routed4QueueSub-16 9367474 321.8 ns/op Benchmark____Routed4QueueSub-16 9336937 322.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9246128 325.8 ns/op Benchmark____Routed8QueueSub-16 10963875 330.8 ns/op Benchmark____Routed8QueueSub-16 9135750 337.4 ns/op Benchmark____Routed8QueueSub-16 9268479 329.0 ns/op Benchmark____Routed8QueueSub-16 9202722 336.7 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8916661 344.8 ns/op Benchmark___Routed16QueueSub-16 8815221 348.1 ns/op Benchmark___Routed16QueueSub-16 8849150 342.3 ns/op Benchmark___Routed16QueueSub-16 9046618 349.6 ns/op Benchmark___Routed16QueueSub-16 8922861 348.9 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6369499 563.4 ns/op Benchmark____________RouteCompressOff-16 6428446 556.4 ns/op Benchmark____________RouteCompressOff-16 6364834 556.5 ns/op Benchmark____________RouteCompressOff-16 6440331 555.6 ns/op Benchmark____________RouteCompressOff-16 6499026 462.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6309008 555.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6536637 552.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6487338 559.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6454909 556.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6422554 553.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6481587 554.9 ns/op Benchmark_________RouteCompressS2Fast-16 6429704 551.0 ns/op Benchmark_________RouteCompressS2Fast-16 6494424 556.5 ns/op Benchmark_________RouteCompressS2Fast-16 6359053 554.2 ns/op Benchmark_________RouteCompressS2Fast-16 6387087 557.5 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6444906 548.6 ns/op Benchmark_______RouteCompressS2Better-16 6677984 551.1 ns/op Benchmark_______RouteCompressS2Better-16 6476035 549.8 ns/op Benchmark_______RouteCompressS2Better-16 6402339 543.4 ns/op Benchmark_______RouteCompressS2Better-16 6424496 550.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6407586 556.5 ns/op Benchmark_________RouteCompressS2Best-16 6528298 548.5 ns/op Benchmark_________RouteCompressS2Best-16 6426124 551.0 ns/op Benchmark_________RouteCompressS2Best-16 6458439 553.5 ns/op Benchmark_________RouteCompressS2Best-16 6478092 550.2 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4618695 767.3 ns/op 324.51 MB/s Benchmark______FanOut_8x1x10-16 4720171 764.5 ns/op 325.69 MB/s Benchmark______FanOut_8x1x10-16 4635316 766.5 ns/op 324.87 MB/s Benchmark______FanOut_8x1x10-16 4627915 767.0 ns/op 324.66 MB/s Benchmark______FanOut_8x1x10-16 4601488 769.2 ns/op 323.72 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 564411 6049 ns/op 383.34 MB/s Benchmark_____FanOut_8x1x100-16 565513 6115 ns/op 379.25 MB/s Benchmark_____FanOut_8x1x100-16 553244 6077 ns/op 381.60 MB/s Benchmark_____FanOut_8x1x100-16 543037 6112 ns/op 379.40 MB/s Benchmark_____FanOut_8x1x100-16 560989 6073 ns/op 381.87 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47732 75378 ns/op 305.38 MB/s Benchmark____FanOut_8x10x100-16 48138 74515 ns/op 308.92 MB/s Benchmark____FanOut_8x10x100-16 47884 74615 ns/op 308.50 MB/s Benchmark____FanOut_8x10x100-16 48046 75148 ns/op 306.32 MB/s Benchmark____FanOut_8x10x100-16 47614 75225 ns/op 306.00 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6002 597670 ns/op 401.59 MB/s Benchmark___FanOut_8x10x1000-16 5923 593497 ns/op 404.41 MB/s Benchmark___FanOut_8x10x1000-16 5614 599473 ns/op 400.38 MB/s Benchmark___FanOut_8x10x1000-16 5780 598169 ns/op 401.26 MB/s Benchmark___FanOut_8x10x1000-16 5840 597299 ns/op 401.84 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4935 704968 ns/op 326.28 MB/s Benchmark___FanOut_8x100x100-16 5068 706761 ns/op 325.46 MB/s Benchmark___FanOut_8x100x100-16 4952 706841 ns/op 325.42 MB/s Benchmark___FanOut_8x100x100-16 5067 740768 ns/op 310.51 MB/s Benchmark___FanOut_8x100x100-16 4968 708102 ns/op 324.84 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 590 6115745 ns/op 392.43 MB/s Benchmark__FanOut_8x100x1000-16 574 6152925 ns/op 390.06 MB/s Benchmark__FanOut_8x100x1000-16 564 6122695 ns/op 391.99 MB/s Benchmark__FanOut_8x100x1000-16 585 6237199 ns/op 384.79 MB/s Benchmark__FanOut_8x100x1000-16 572 6126784 ns/op 391.73 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 535 6751284 ns/op 370.30 MB/s Benchmark__FanOut_8x10x10000-16 528 6697029 ns/op 373.30 MB/s Benchmark__FanOut_8x10x10000-16 523 6945041 ns/op 359.97 MB/s Benchmark__FanOut_8x10x10000-16 544 6670957 ns/op 374.76 MB/s Benchmark__FanOut_8x10x10000-16 520 6700435 ns/op 373.11 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 950 3788226 ns/op 303.58 MB/s Benchmark___FanOut_8x500x100-16 949 3740119 ns/op 307.48 MB/s Benchmark___FanOut_8x500x100-16 958 3792035 ns/op 303.27 MB/s Benchmark___FanOut_8x500x100-16 937 3794169 ns/op 303.10 MB/s Benchmark___FanOut_8x500x100-16 934 3792179 ns/op 303.26 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 369442 9455 ns/op 1548.44 MB/s Benchmark___FanOut_128x1x100-16 353872 9475 ns/op 1545.16 MB/s Benchmark___FanOut_128x1x100-16 360756 9525 ns/op 1537.06 MB/s Benchmark___FanOut_128x1x100-16 370423 9446 ns/op 1550.03 MB/s Benchmark___FanOut_128x1x100-16 348627 9475 ns/op 1545.29 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32619 109460 ns/op 1325.97 MB/s Benchmark__FanOut_128x10x100-16 32752 109905 ns/op 1320.60 MB/s Benchmark__FanOut_128x10x100-16 32454 109190 ns/op 1329.25 MB/s Benchmark__FanOut_128x10x100-16 32860 109839 ns/op 1321.39 MB/s Benchmark__FanOut_128x10x100-16 32886 109839 ns/op 1321.39 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4064 877278 ns/op 1664.40 MB/s Benchmark_FanOut_128x10x1000-16 4021 862237 ns/op 1693.43 MB/s Benchmark_FanOut_128x10x1000-16 3904 870448 ns/op 1677.46 MB/s Benchmark_FanOut_128x10x1000-16 4134 879802 ns/op 1659.62 MB/s Benchmark_FanOut_128x10x1000-16 4138 886470 ns/op 1647.14 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3469 1009029 ns/op 1437.17 MB/s Benchmark_FanOut_128x100x100-16 3464 1008489 ns/op 1437.93 MB/s Benchmark_FanOut_128x100x100-16 3488 1006567 ns/op 1440.68 MB/s Benchmark_FanOut_128x100x100-16 3412 1007499 ns/op 1439.35 MB/s Benchmark_FanOut_128x100x100-16 3488 1010794 ns/op 1434.66 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 388 9218210 ns/op 1583.84 MB/s BenchmarkFanOut_128x100x1000-16 385 9324297 ns/op 1565.82 MB/s BenchmarkFanOut_128x100x1000-16 379 9298586 ns/op 1570.15 MB/s BenchmarkFanOut_128x100x1000-16 390 9279297 ns/op 1573.41 MB/s BenchmarkFanOut_128x100x1000-16 379 9283819 ns/op 1572.64 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 374 9563791 ns/op 1537.06 MB/s BenchmarkFanOut_128x10x10000-16 373 9634992 ns/op 1525.70 MB/s BenchmarkFanOut_128x10x10000-16 376 9665114 ns/op 1520.95 MB/s BenchmarkFanOut_128x10x10000-16 376 9530276 ns/op 1542.47 MB/s BenchmarkFanOut_128x10x10000-16 374 9584039 ns/op 1533.81 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 673 5263064 ns/op 1377.55 MB/s BenchmarkFanOut__128x500x100-16 672 5247704 ns/op 1381.58 MB/s BenchmarkFanOut__128x500x100-16 678 5258401 ns/op 1378.77 MB/s BenchmarkFanOut__128x500x100-16 682 5259167 ns/op 1378.57 MB/s BenchmarkFanOut__128x500x100-16 684 5264396 ns/op 1377.20 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1969 1842266 ns/op 2871.75 MB/s Benchmark_FanOut_512x100x100-16 1945 1820832 ns/op 2905.55 MB/s Benchmark_FanOut_512x100x100-16 1939 1837271 ns/op 2879.56 MB/s Benchmark_FanOut_512x100x100-16 1942 1835431 ns/op 2882.44 MB/s Benchmark_FanOut_512x100x100-16 1959 1838142 ns/op 2878.19 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 210 16691193 ns/op 3175.36 MB/s Benchmark__FanOut_512x100x1k-16 213 16703829 ns/op 3172.96 MB/s Benchmark__FanOut_512x100x1k-16 213 16884298 ns/op 3139.04 MB/s Benchmark__FanOut_512x100x1k-16 217 16713246 ns/op 3171.17 MB/s Benchmark__FanOut_512x100x1k-16 214 16635842 ns/op 3185.92 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3092 1158241 ns/op 9005.93 MB/s Benchmark____FanOut_1kx10x1k-16 3272 1165664 ns/op 8948.58 MB/s Benchmark____FanOut_1kx10x1k-16 2889 1154175 ns/op 9037.66 MB/s Benchmark____FanOut_1kx10x1k-16 2737 1152846 ns/op 9048.07 MB/s Benchmark____FanOut_1kx10x1k-16 3087 1149909 ns/op 9071.18 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2797 1257773 ns/op 8285.31 MB/s Benchmark__FanOut_1kx100x100-16 2737 1257281 ns/op 8288.55 MB/s Benchmark__FanOut_1kx100x100-16 2804 1248073 ns/op 8349.70 MB/s Benchmark__FanOut_1kx100x100-16 2846 1261551 ns/op 8260.50 MB/s Benchmark__FanOut_1kx100x100-16 2724 1257310 ns/op 8288.36 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4461804 792.3 ns/op 314.26 MB/s Benchmark_____RFanOut_8x1x10-16 4438620 785.1 ns/op 317.15 MB/s Benchmark_____RFanOut_8x1x10-16 4393840 771.1 ns/op 322.92 MB/s Benchmark_____RFanOut_8x1x10-16 4563994 776.5 ns/op 320.65 MB/s Benchmark_____RFanOut_8x1x10-16 4470948 783.8 ns/op 317.68 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 538789 6048 ns/op 383.46 MB/s Benchmark____RFanOut_8x1x100-16 554688 6303 ns/op 367.89 MB/s Benchmark____RFanOut_8x1x100-16 563618 6290 ns/op 368.66 MB/s Benchmark____RFanOut_8x1x100-16 538368 6079 ns/op 381.51 MB/s Benchmark____RFanOut_8x1x100-16 548700 6082 ns/op 381.31 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48378 75968 ns/op 303.01 MB/s Benchmark___RFanOut_8x10x100-16 47966 85253 ns/op 270.01 MB/s Benchmark___RFanOut_8x10x100-16 47839 74901 ns/op 307.33 MB/s Benchmark___RFanOut_8x10x100-16 48343 74389 ns/op 309.44 MB/s Benchmark___RFanOut_8x10x100-16 47742 76313 ns/op 301.64 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5786 595398 ns/op 403.12 MB/s Benchmark__RFanOut_8x10x1000-16 5860 599846 ns/op 400.13 MB/s Benchmark__RFanOut_8x10x1000-16 5896 600236 ns/op 399.87 MB/s Benchmark__RFanOut_8x10x1000-16 5929 600973 ns/op 399.38 MB/s Benchmark__RFanOut_8x10x1000-16 5644 597405 ns/op 401.77 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5028 717690 ns/op 320.50 MB/s Benchmark__RFanOut_8x100x100-16 5030 708135 ns/op 324.82 MB/s Benchmark__RFanOut_8x100x100-16 4840 709966 ns/op 323.99 MB/s Benchmark__RFanOut_8x100x100-16 4963 709932 ns/op 324.00 MB/s Benchmark__RFanOut_8x100x100-16 5023 708750 ns/op 324.54 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 570 6138141 ns/op 391.00 MB/s Benchmark_RFanOut_8x100x1000-16 572 6219775 ns/op 385.87 MB/s Benchmark_RFanOut_8x100x1000-16 568 6216121 ns/op 386.10 MB/s Benchmark_RFanOut_8x100x1000-16 576 6338422 ns/op 378.65 MB/s Benchmark_RFanOut_8x100x1000-16 561 6319637 ns/op 379.77 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 524 6816017 ns/op 366.79 MB/s Benchmark_RFanOut_8x10x10000-16 511 6960015 ns/op 359.20 MB/s Benchmark_RFanOut_8x10x10000-16 532 6805324 ns/op 367.36 MB/s Benchmark_RFanOut_8x10x10000-16 535 6740076 ns/op 370.92 MB/s Benchmark_RFanOut_8x10x10000-16 505 6775080 ns/op 369.00 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2894 1166960 ns/op 8938.64 MB/s Benchmark_RFanOut_1kx10x1000-16 2923 1153200 ns/op 9045.29 MB/s Benchmark_RFanOut_1kx10x1000-16 2918 1150658 ns/op 9065.28 MB/s Benchmark_RFanOut_1kx10x1000-16 3080 1152038 ns/op 9054.42 MB/s Benchmark_RFanOut_1kx10x1000-16 2982 1185511 ns/op 8798.77 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6925770 505.3 ns/op 4112.74 MB/s Benchmark_____FanIn_1kx100x1-16 6881354 506.1 ns/op 4106.12 MB/s Benchmark_____FanIn_1kx100x1-16 6917830 506.4 ns/op 4103.59 MB/s Benchmark_____FanIn_1kx100x1-16 6880046 506.9 ns/op 4099.23 MB/s Benchmark_____FanIn_1kx100x1-16 6979308 505.5 ns/op 4111.10 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2630250 1336 ns/op 6154.08 MB/s Benchmark_____FanIn_4kx100x1-16 2639550 1364 ns/op 6029.73 MB/s Benchmark_____FanIn_4kx100x1-16 2667102 1353 ns/op 6075.94 MB/s Benchmark_____FanIn_4kx100x1-16 2573941 1347 ns/op 6104.54 MB/s Benchmark_____FanIn_4kx100x1-16 2620663 1350 ns/op 6091.56 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1673155 2102 ns/op 7806.94 MB/s Benchmark_____FanIn_8kx100x1-16 1720921 2116 ns/op 7756.17 MB/s Benchmark_____FanIn_8kx100x1-16 1711042 2095 ns/op 7834.06 MB/s Benchmark_____FanIn_8kx100x1-16 1708021 2145 ns/op 7651.97 MB/s Benchmark_____FanIn_8kx100x1-16 1717460 2103 ns/op 7806.44 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 875456 4118 ns/op 7965.96 MB/s Benchmark____FanIn_16kx100x1-16 880822 4138 ns/op 7926.27 MB/s Benchmark____FanIn_16kx100x1-16 879243 4118 ns/op 7964.76 MB/s Benchmark____FanIn_16kx100x1-16 871765 4055 ns/op 8089.46 MB/s Benchmark____FanIn_16kx100x1-16 866004 4204 ns/op 7802.18 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 164229 19760 ns/op 6634.71 MB/s Benchmark____FanIn_64kx100x1-16 172645 19892 ns/op 6590.63 MB/s Benchmark____FanIn_64kx100x1-16 172094 19865 ns/op 6599.68 MB/s Benchmark____FanIn_64kx100x1-16 165686 19873 ns/op 6596.95 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 8345683536 vs 11026014600 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34322->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34820->127.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:34326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34444->127.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:34790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34458->127.0.0.1:5222: write: connection reset by peer 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:34564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34780->127.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:34582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35052->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: 364036930 vs 11929190000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37390->127.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:37008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36990->127.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:36928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37486->127.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 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37588->127.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:37014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37204->127.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:37274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37594->127.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:36952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37066->127.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:37522->127.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:37628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37374->127.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:37614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37046->127.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:37472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36922->127.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:37280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36958->127.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:37028->127.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:37194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37176->127.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:36938->127.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:37556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37458->127.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:36970->127.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:37164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36984->127.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:36948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37566->127.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:37348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37676->127.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:36878->127.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:36976->127.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: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: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:37496->127.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:37610->127.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:37420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36864->127.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:37102->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: 489752240 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39118->127.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:39366->127.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:38900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38888->127.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:39312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38800->127.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:39012->127.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:38664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39156->127.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: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:38676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38832->127.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: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:38960->127.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:38686->127.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:39048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39272->127.0.0.1:5222: write: broken pipe 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:39392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39414->127.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:39158->127.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:39454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38886->127.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:39228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39390->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39124->127.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: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: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:38712->127.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:39478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38658->127.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:38988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39374->127.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:39328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39148->127.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: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38790->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38718->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: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:38990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39396->127.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:39102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39036->127.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:39462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39250->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: 229276410 vs 1310900000 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:40458->127.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:40536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40432->127.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: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:40576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41202->127.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:41256->127.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:40772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40786->127.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:40834->127.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: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: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:40954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40454->127.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:41166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40974->127.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:40426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41196->127.0.0.1:5222: write: connection reset by peer bench_test.go: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:41000->127.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:41140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40452->127.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:40970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40496->127.0.0.1:5222: write: connection reset by peer bench_test.go: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: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:41036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40750->127.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: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: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:41240->127.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:40914->127.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:40508->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: 266768150 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42748->127.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:42920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43006->127.0.0.1:5222: write: connection reset by peer bench_test.go: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:42438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42464->127.0.0.1:5222: write: connection reset by peer bench_test.go: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:42594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42908->127.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:42540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43052->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: 413982220 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44884->127.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: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:44536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44586->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44148->127.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:44796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44190->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44130->127.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: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44702->127.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: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:44266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44928->127.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:44484->127.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:44922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44602->127.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:44942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44212->127.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:44200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44420->127.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:44716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44222->127.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:44250->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44574->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5527467 637.6 ns/op 445.39 MB/s Benchmark___BumpPubCount_1x3-16 5541907 640.7 ns/op 443.24 MB/s Benchmark___BumpPubCount_1x3-16 5522926 640.2 ns/op 443.59 MB/s Benchmark___BumpPubCount_1x3-16 5594184 639.1 ns/op 444.35 MB/s Benchmark___BumpPubCount_1x3-16 5607806 641.8 ns/op 442.54 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5317933 671.1 ns/op 423.16 MB/s Benchmark___BumpPubCount_2x3-16 5203453 676.0 ns/op 420.12 MB/s Benchmark___BumpPubCount_2x3-16 5301951 670.7 ns/op 423.43 MB/s Benchmark___BumpPubCount_2x3-16 5352962 679.4 ns/op 418.02 MB/s Benchmark___BumpPubCount_2x3-16 5255130 676.0 ns/op 420.15 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5611252 638.9 ns/op 444.54 MB/s Benchmark___BumpPubCount_5x3-16 5606782 655.0 ns/op 433.56 MB/s Benchmark___BumpPubCount_5x3-16 5469104 642.9 ns/op 441.78 MB/s Benchmark___BumpPubCount_5x3-16 5418730 641.2 ns/op 442.95 MB/s Benchmark___BumpPubCount_5x3-16 5503454 656.8 ns/op 432.39 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5583112 641.8 ns/op 442.50 MB/s Benchmark__BumpPubCount_10x3-16 5599161 640.4 ns/op 443.45 MB/s Benchmark__BumpPubCount_10x3-16 5577847 640.0 ns/op 443.73 MB/s Benchmark__BumpPubCount_10x3-16 5575783 639.0 ns/op 444.46 MB/s Benchmark__BumpPubCount_10x3-16 5607034 644.6 ns/op 440.60 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12391353 278.7 ns/op 3731.93 MB/s Benchmark____GWs_Opt_1kx01x0-16 13210728 271.8 ns/op 3826.28 MB/s Benchmark____GWs_Opt_1kx01x0-16 12967780 268.2 ns/op 3877.20 MB/s Benchmark____GWs_Opt_1kx01x0-16 12882068 273.6 ns/op 3801.48 MB/s Benchmark____GWs_Opt_1kx01x0-16 12383233 265.6 ns/op 3915.40 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10281686 356.7 ns/op 5786.37 MB/s Benchmark____GWs_Opt_2kx01x0-16 10783920 338.6 ns/op 6095.80 MB/s Benchmark____GWs_Opt_2kx01x0-16 10630659 359.5 ns/op 5740.99 MB/s Benchmark____GWs_Opt_2kx01x0-16 10618998 339.7 ns/op 6076.43 MB/s Benchmark____GWs_Opt_2kx01x0-16 10381207 341.9 ns/op 6036.41 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5791177 616.6 ns/op 6668.44 MB/s Benchmark____GWs_Opt_4kx01x0-16 5927700 624.4 ns/op 6585.31 MB/s Benchmark____GWs_Opt_4kx01x0-16 5740586 604.9 ns/op 6798.04 MB/s Benchmark____GWs_Opt_4kx01x0-16 5683153 619.9 ns/op 6632.86 MB/s Benchmark____GWs_Opt_4kx01x0-16 5791999 600.2 ns/op 6850.92 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28308660 128.7 ns/op 8078.11 MB/s Benchmark____GWs_Opt_1kx10x0-16 30667086 115.5 ns/op 9001.74 MB/s Benchmark____GWs_Opt_1kx10x0-16 27979968 112.4 ns/op 9249.06 MB/s Benchmark____GWs_Opt_1kx10x0-16 31696732 111.6 ns/op 9319.24 MB/s Benchmark____GWs_Opt_1kx10x0-16 30498583 111.8 ns/op 9304.63 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23375823 148.2 ns/op 13929.59 MB/s Benchmark____GWs_Opt_2kx10x0-16 24044362 142.5 ns/op 14481.92 MB/s Benchmark____GWs_Opt_2kx10x0-16 23194434 154.2 ns/op 13385.13 MB/s Benchmark____GWs_Opt_2kx10x0-16 24092019 161.6 ns/op 12770.46 MB/s Benchmark____GWs_Opt_2kx10x0-16 25327437 147.2 ns/op 14017.07 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12941547 310.2 ns/op 13254.48 MB/s Benchmark____GWs_Opt_4kx10x0-16 12581552 324.8 ns/op 12658.96 MB/s Benchmark____GWs_Opt_4kx10x0-16 11970840 352.8 ns/op 11653.91 MB/s Benchmark____GWs_Opt_4kx10x0-16 12269214 314.9 ns/op 13057.76 MB/s Benchmark____GWs_Opt_4kx10x0-16 10310494 309.5 ns/op 13286.27 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6661191 546.4 ns/op 5718.76 MB/s Benchmark____GWs_Opt_1kx01x1-16 6544345 548.7 ns/op 5694.91 MB/s Benchmark____GWs_Opt_1kx01x1-16 6805902 554.5 ns/op 5635.84 MB/s Benchmark____GWs_Opt_1kx01x1-16 6781159 540.8 ns/op 5778.85 MB/s Benchmark____GWs_Opt_1kx01x1-16 6701156 550.1 ns/op 5680.91 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4771827 1233 ns/op 5026.06 MB/s Benchmark____GWs_Opt_2kx01x1-16 4719462 763.8 ns/op 8113.07 MB/s Benchmark____GWs_Opt_2kx01x1-16 4741096 770.9 ns/op 8038.16 MB/s Benchmark____GWs_Opt_2kx01x1-16 4597305 761.2 ns/op 8141.42 MB/s Benchmark____GWs_Opt_2kx01x1-16 4710555 796.6 ns/op 7778.85 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2587407 1374 ns/op 8984.60 MB/s Benchmark____GWs_Opt_4kx01x1-16 2423161 2380 ns/op 5184.98 MB/s Benchmark____GWs_Opt_4kx01x1-16 2626006 1367 ns/op 9024.70 MB/s Benchmark____GWs_Opt_4kx01x1-16 2603648 1373 ns/op 8991.54 MB/s Benchmark____GWs_Opt_4kx01x1-16 2633502 1373 ns/op 8989.06 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6215589 559.2 ns/op 5588.81 MB/s Benchmark____GWs_Opt_1kx10x1-16 5978544 555.2 ns/op 5628.66 MB/s Benchmark____GWs_Opt_1kx10x1-16 6547090 563.3 ns/op 5547.95 MB/s Benchmark____GWs_Opt_1kx10x1-16 6350820 565.6 ns/op 5525.06 MB/s Benchmark____GWs_Opt_1kx10x1-16 6205680 562.8 ns/op 5552.28 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4265382 846.0 ns/op 7324.63 MB/s Benchmark____GWs_Opt_2kx10x1-16 4105700 851.2 ns/op 7280.71 MB/s Benchmark____GWs_Opt_2kx10x1-16 4153352 826.0 ns/op 7502.40 MB/s Benchmark____GWs_Opt_2kx10x1-16 3988279 828.7 ns/op 7478.25 MB/s Benchmark____GWs_Opt_2kx10x1-16 4154864 850.3 ns/op 7288.07 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2306194 1543 ns/op 7996.00 MB/s Benchmark____GWs_Opt_4kx10x1-16 2370228 1519 ns/op 8122.01 MB/s Benchmark____GWs_Opt_4kx10x1-16 2336565 1426 ns/op 8652.06 MB/s Benchmark____GWs_Opt_4kx10x1-16 2384955 1524 ns/op 8096.09 MB/s Benchmark____GWs_Opt_4kx10x1-16 2374606 1530 ns/op 8067.00 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12314720 293.8 ns/op 3540.10 MB/s Benchmark____GWs_Int_1kx01x0-16 12186728 284.9 ns/op 3650.68 MB/s Benchmark____GWs_Int_1kx01x0-16 12651189 296.1 ns/op 3511.90 MB/s Benchmark____GWs_Int_1kx01x0-16 11555466 297.2 ns/op 3499.32 MB/s Benchmark____GWs_Int_1kx01x0-16 12431924 291.9 ns/op 3563.21 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10218834 358.0 ns/op 5765.53 MB/s Benchmark____GWs_Int_2kx01x0-16 9740328 339.4 ns/op 6081.20 MB/s Benchmark____GWs_Int_2kx01x0-16 10127722 356.4 ns/op 5791.82 MB/s Benchmark____GWs_Int_2kx01x0-16 10104190 364.3 ns/op 5665.20 MB/s Benchmark____GWs_Int_2kx01x0-16 10624570 336.6 ns/op 6131.88 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5753719 643.2 ns/op 6392.61 MB/s Benchmark____GWs_Int_4kx01x0-16 5695064 616.9 ns/op 6665.76 MB/s Benchmark____GWs_Int_4kx01x0-16 5841986 639.2 ns/op 6432.63 MB/s Benchmark____GWs_Int_4kx01x0-16 4958648 631.1 ns/op 6515.54 MB/s Benchmark____GWs_Int_4kx01x0-16 5530680 619.5 ns/op 6638.12 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31594461 116.0 ns/op 8964.83 MB/s Benchmark____GWs_Int_1kx10x0-16 31485706 109.4 ns/op 9508.85 MB/s Benchmark____GWs_Int_1kx10x0-16 32397436 115.6 ns/op 8992.76 MB/s Benchmark____GWs_Int_1kx10x0-16 30626512 115.5 ns/op 9001.18 MB/s Benchmark____GWs_Int_1kx10x0-16 31290300 111.1 ns/op 9359.17 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 22499888 150.4 ns/op 13727.71 MB/s Benchmark____GWs_Int_2kx10x0-16 26096941 137.5 ns/op 15006.76 MB/s Benchmark____GWs_Int_2kx10x0-16 22296409 139.3 ns/op 14821.47 MB/s Benchmark____GWs_Int_2kx10x0-16 21864646 138.4 ns/op 14915.95 MB/s Benchmark____GWs_Int_2kx10x0-16 22249221 139.6 ns/op 14785.37 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13157925 305.6 ns/op 13457.20 MB/s Benchmark____GWs_Int_4kx10x0-16 12684176 303.3 ns/op 13559.30 MB/s Benchmark____GWs_Int_4kx10x0-16 12642775 284.5 ns/op 14454.82 MB/s Benchmark____GWs_Int_4kx10x0-16 10846345 280.8 ns/op 14641.91 MB/s Benchmark____GWs_Int_4kx10x0-16 12708025 283.8 ns/op 14487.51 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6417513 558.7 ns/op 5593.84 MB/s Benchmark____GWs_Int_1kx01x1-16 6512746 552.2 ns/op 5659.64 MB/s Benchmark____GWs_Int_1kx01x1-16 6466190 562.6 ns/op 5554.85 MB/s Benchmark____GWs_Int_1kx01x1-16 6432564 559.5 ns/op 5585.25 MB/s Benchmark____GWs_Int_1kx01x1-16 6559374 559.1 ns/op 5589.53 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4775778 770.7 ns/op 8040.91 MB/s Benchmark____GWs_Int_2kx01x1-16 4632567 776.9 ns/op 7976.96 MB/s Benchmark____GWs_Int_2kx01x1-16 4597720 763.8 ns/op 8113.28 MB/s Benchmark____GWs_Int_2kx01x1-16 4244738 758.0 ns/op 8175.39 MB/s Benchmark____GWs_Int_2kx01x1-16 4701231 776.9 ns/op 7976.89 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2625714 1379 ns/op 8948.31 MB/s Benchmark____GWs_Int_4kx01x1-16 2324308 1368 ns/op 9020.79 MB/s Benchmark____GWs_Int_4kx01x1-16 1000000 4960 ns/op 2487.95 MB/s Benchmark____GWs_Int_4kx01x1-16 2589440 1375 ns/op 8976.03 MB/s Benchmark____GWs_Int_4kx01x1-16 2672926 1382 ns/op 8928.38 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6153957 563.4 ns/op 5547.01 MB/s Benchmark____GWs_Int_1kx10x1-16 6581427 566.8 ns/op 5513.60 MB/s Benchmark____GWs_Int_1kx10x1-16 6574591 564.8 ns/op 5533.42 MB/s Benchmark____GWs_Int_1kx10x1-16 6061852 557.1 ns/op 5609.17 MB/s Benchmark____GWs_Int_1kx10x1-16 6153021 563.8 ns/op 5543.03 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4164364 871.8 ns/op 7108.00 MB/s Benchmark____GWs_Int_2kx10x1-16 4165131 844.9 ns/op 7334.71 MB/s Benchmark____GWs_Int_2kx10x1-16 4074121 849.5 ns/op 7294.55 MB/s Benchmark____GWs_Int_2kx10x1-16 4041069 857.8 ns/op 7223.95 MB/s Benchmark____GWs_Int_2kx10x1-16 4046870 885.5 ns/op 6998.22 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2283141 1562 ns/op 7903.30 MB/s Benchmark____GWs_Int_4kx10x1-16 2097644 1506 ns/op 8192.55 MB/s Benchmark____GWs_Int_4kx10x1-16 2424070 1523 ns/op 8104.42 MB/s Benchmark____GWs_Int_4kx10x1-16 2317968 1484 ns/op 8314.44 MB/s Benchmark____GWs_Int_4kx10x1-16 2346370 1511 ns/op 8166.79 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8063212 456.0 ns/op 223.67 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7956133 430.1 ns/op 237.16 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8378960 437.0 ns/op 233.42 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8186304 483.3 ns/op 211.07 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8153952 431.9 ns/op 236.16 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 613640 5028 ns/op 35.20 MB/s Benchmark__GWs_Reqs_1SubEach-16 766597 5163 ns/op 34.28 MB/s Benchmark__GWs_Reqs_1SubEach-16 745302 5208 ns/op 33.99 MB/s Benchmark__GWs_Reqs_1SubEach-16 738854 5282 ns/op 33.51 MB/s Benchmark__GWs_Reqs_1SubEach-16 796657 5323 ns/op 33.25 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2100.149s ❌ Non-zero exit code: 1