> ROOT_DIR=/tmp/go-bench-away-job-9a77d3e3-2f67-4a09-b308-b792f3c7d966-1321858132 > OUTPUT_FILE=/tmp/go-bench-away-job-9a77d3e3-2f67-4a09-b308-b792f3c7d966-1321858132/results.txt > SHA_FILE=/tmp/go-bench-away-job-9a77d3e3-2f67-4a09-b308-b792f3c7d966-1321858132/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-9a77d3e3-2f67-4a09-b308-b792f3c7d966-1321858132/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=v2.11.17 > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.25.4/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: v2.11.17 to /tmp/go-bench-away-job-9a77d3e3-2f67-4a09-b308-b792f3c7d966-1321858132/source.git SHA of v2.11.17: 0d922d193a4423a26b38d7a647a8d50343dec2de Go runtime: go version go1.26.0 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build296427289=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-9a77d3e3-2f67-4a09-b308-b792f3c7d966-1321858132/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.25.4' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.25.4/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.0' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 57291363 63.11 ns/op 174.29 MB/s Benchmark______Pub0b_Payload-16 53970586 62.40 ns/op 176.28 MB/s Benchmark______Pub0b_Payload-16 54444792 63.87 ns/op 172.21 MB/s Benchmark______Pub0b_Payload-16 53973106 62.69 ns/op 175.46 MB/s Benchmark______Pub0b_Payload-16 54298988 63.96 ns/op 171.97 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 53259596 63.92 ns/op 297.26 MB/s Benchmark______Pub8b_Payload-16 53264554 63.06 ns/op 301.28 MB/s Benchmark______Pub8b_Payload-16 53950792 65.93 ns/op 288.17 MB/s Benchmark______Pub8b_Payload-16 57206156 62.82 ns/op 302.46 MB/s Benchmark______Pub8b_Payload-16 57246993 64.38 ns/op 295.10 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 50287960 68.25 ns/op 644.64 MB/s Benchmark_____Pub32b_Payload-16 50389291 67.72 ns/op 649.74 MB/s Benchmark_____Pub32b_Payload-16 50042667 67.80 ns/op 648.93 MB/s Benchmark_____Pub32b_Payload-16 50178008 67.46 ns/op 652.27 MB/s Benchmark_____Pub32b_Payload-16 49991834 68.03 ns/op 646.73 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 43243554 79.68 ns/op 1769.68 MB/s Benchmark____Pub128B_Payload-16 38533713 79.76 ns/op 1767.75 MB/s Benchmark____Pub128B_Payload-16 43645003 75.87 ns/op 1858.50 MB/s Benchmark____Pub128B_Payload-16 37881118 83.76 ns/op 1683.47 MB/s Benchmark____Pub128B_Payload-16 47413778 76.38 ns/op 1846.07 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35311449 89.58 ns/op 3002.74 MB/s Benchmark____Pub256B_Payload-16 34962298 86.85 ns/op 3097.34 MB/s Benchmark____Pub256B_Payload-16 35129272 87.50 ns/op 3074.43 MB/s Benchmark____Pub256B_Payload-16 42418826 82.59 ns/op 3257.21 MB/s Benchmark____Pub256B_Payload-16 40782462 83.98 ns/op 3203.12 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23357901 143.8 ns/op 7220.70 MB/s Benchmark______Pub1K_Payload-16 24399171 140.2 ns/op 7403.83 MB/s Benchmark______Pub1K_Payload-16 25938091 135.5 ns/op 7661.97 MB/s Benchmark______Pub1K_Payload-16 27673120 124.6 ns/op 8329.62 MB/s Benchmark______Pub1K_Payload-16 26265217 124.4 ns/op 8340.86 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5394134 629.7 ns/op 6527.39 MB/s Benchmark______Pub4K_Payload-16 5310961 621.6 ns/op 6611.95 MB/s Benchmark______Pub4K_Payload-16 5028764 622.1 ns/op 6606.40 MB/s Benchmark______Pub4K_Payload-16 5583079 622.6 ns/op 6601.66 MB/s Benchmark______Pub4K_Payload-16 5581302 628.8 ns/op 6536.34 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2729116 1278 ns/op 6421.68 MB/s Benchmark______Pub8K_Payload-16 2747313 1272 ns/op 6453.12 MB/s Benchmark______Pub8K_Payload-16 2635366 1273 ns/op 6446.53 MB/s Benchmark______Pub8K_Payload-16 2748634 1269 ns/op 6468.54 MB/s Benchmark______Pub8K_Payload-16 2795896 1280 ns/op 6410.20 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 676490 5333 ns/op 6147.58 MB/s Benchmark_____Pub32K_Payload-16 603321 5336 ns/op 6143.53 MB/s Benchmark_____Pub32K_Payload-16 654478 5364 ns/op 6112.07 MB/s Benchmark_____Pub32K_Payload-16 673058 5276 ns/op 6213.29 MB/s Benchmark_____Pub32K_Payload-16 683385 5367 ns/op 6108.19 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 35544956 84.92 ns/op 129.54 MB/s Benchmark__AuthPub0b_Payload-16 40506657 86.76 ns/op 126.78 MB/s Benchmark__AuthPub0b_Payload-16 40685359 82.98 ns/op 132.57 MB/s Benchmark__AuthPub0b_Payload-16 40531686 82.88 ns/op 132.72 MB/s Benchmark__AuthPub0b_Payload-16 39704169 83.21 ns/op 132.19 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 17491876 204.0 ns/op Benchmark_____________PubSub-16 17335167 202.6 ns/op Benchmark_____________PubSub-16 17231955 204.5 ns/op Benchmark_____________PubSub-16 17024366 204.3 ns/op Benchmark_____________PubSub-16 17432282 203.4 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 17260364 202.7 ns/op Benchmark_____PubSubTwoConns-16 17256255 202.2 ns/op Benchmark_____PubSubTwoConns-16 17385873 202.9 ns/op Benchmark_____PubSubTwoConns-16 17437234 202.3 ns/op Benchmark_____PubSubTwoConns-16 17284306 202.8 ns/op Benchmark__PubServiceImports bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:51706->127.0.0.1:40023: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:34046->127.0.0.1:40921: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:54232->127.0.0.1:41513: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:44376->127.0.0.1:38903: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:46960->127.0.0.1:38487: 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 15982638 224.2 ns/op Benchmark_____PubTwoQueueSub-16 15827002 223.3 ns/op Benchmark_____PubTwoQueueSub-16 15853150 223.9 ns/op Benchmark_____PubTwoQueueSub-16 15858840 223.7 ns/op Benchmark_____PubTwoQueueSub-16 15891222 224.0 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15888676 223.6 ns/op Benchmark____PubFourQueueSub-16 15854698 221.5 ns/op Benchmark____PubFourQueueSub-16 15811448 224.4 ns/op Benchmark____PubFourQueueSub-16 15923146 223.5 ns/op Benchmark____PubFourQueueSub-16 15871467 223.8 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15851995 223.9 ns/op Benchmark___PubEightQueueSub-16 15899785 223.6 ns/op Benchmark___PubEightQueueSub-16 15440170 225.1 ns/op Benchmark___PubEightQueueSub-16 15703411 224.3 ns/op Benchmark___PubEightQueueSub-16 15926646 224.6 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23179 156908 ns/op Benchmark_PubSub512kTwoConns-16 22826 158955 ns/op Benchmark_PubSub512kTwoConns-16 21870 156323 ns/op Benchmark_PubSub512kTwoConns-16 23106 156858 ns/op Benchmark_PubSub512kTwoConns-16 22678 157166 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 17013470 205.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 17109904 204.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 17024274 207.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 16831884 206.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 16789086 206.0 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16972142 206.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 16942468 206.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 16800306 205.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 17041652 205.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 17042318 205.7 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 12524308 275.0 ns/op Benchmark____RoutedPubSub_0b-16 12838593 278.9 ns/op Benchmark____RoutedPubSub_0b-16 12853524 271.9 ns/op Benchmark____RoutedPubSub_0b-16 12787510 275.7 ns/op Benchmark____RoutedPubSub_0b-16 12708301 283.1 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6873482 516.6 ns/op Benchmark____RoutedPubSub_1K-16 6751200 517.2 ns/op Benchmark____RoutedPubSub_1K-16 6929852 505.9 ns/op Benchmark____RoutedPubSub_1K-16 6895909 517.6 ns/op Benchmark____RoutedPubSub_1K-16 6505077 507.6 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84753 41589 ns/op Benchmark__RoutedPubSub_100K-16 82041 42405 ns/op Benchmark__RoutedPubSub_100K-16 82051 42913 ns/op Benchmark__RoutedPubSub_100K-16 79722 41440 ns/op Benchmark__RoutedPubSub_100K-16 86565 42010 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 10525687 331.5 ns/op Benchmark____Routed2QueueSub-16 10561950 333.5 ns/op Benchmark____Routed2QueueSub-16 10649072 333.7 ns/op Benchmark____Routed2QueueSub-16 10703258 330.3 ns/op Benchmark____Routed2QueueSub-16 10917828 330.3 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 10643065 343.6 ns/op Benchmark____Routed4QueueSub-16 10220398 345.5 ns/op Benchmark____Routed4QueueSub-16 10327130 339.3 ns/op Benchmark____Routed4QueueSub-16 10483772 340.1 ns/op Benchmark____Routed4QueueSub-16 10602667 335.3 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 10233270 349.8 ns/op Benchmark____Routed8QueueSub-16 10259674 352.7 ns/op Benchmark____Routed8QueueSub-16 8536989 351.5 ns/op Benchmark____Routed8QueueSub-16 10258977 353.9 ns/op Benchmark____Routed8QueueSub-16 10451182 346.9 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8289572 374.6 ns/op Benchmark___Routed16QueueSub-16 8196529 374.4 ns/op Benchmark___Routed16QueueSub-16 8439850 378.9 ns/op Benchmark___Routed16QueueSub-16 8542884 367.2 ns/op Benchmark___Routed16QueueSub-16 8098695 370.9 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 7071205 469.9 ns/op Benchmark____________RouteCompressOff-16 6885346 459.7 ns/op Benchmark____________RouteCompressOff-16 7213100 466.1 ns/op Benchmark____________RouteCompressOff-16 7368187 462.4 ns/op Benchmark____________RouteCompressOff-16 6976198 468.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 7297952 461.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 7484613 456.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 7130613 474.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 7085665 468.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 7405159 469.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 7123368 461.9 ns/op Benchmark_________RouteCompressS2Fast-16 7041601 463.1 ns/op Benchmark_________RouteCompressS2Fast-16 6838813 462.2 ns/op Benchmark_________RouteCompressS2Fast-16 6877878 457.0 ns/op Benchmark_________RouteCompressS2Fast-16 6965227 459.0 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 7227816 462.6 ns/op Benchmark_______RouteCompressS2Better-16 7060392 462.5 ns/op Benchmark_______RouteCompressS2Better-16 7018908 459.6 ns/op Benchmark_______RouteCompressS2Better-16 7007134 464.7 ns/op Benchmark_______RouteCompressS2Better-16 7163700 465.8 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 7308985 468.0 ns/op Benchmark_________RouteCompressS2Best-16 7162046 460.1 ns/op Benchmark_________RouteCompressS2Best-16 7099372 473.6 ns/op Benchmark_________RouteCompressS2Best-16 7361478 464.7 ns/op Benchmark_________RouteCompressS2Best-16 6983696 465.7 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5300318 675.4 ns/op 368.66 MB/s Benchmark______FanOut_8x1x10-16 5260938 679.5 ns/op 366.44 MB/s Benchmark______FanOut_8x1x10-16 5305996 677.8 ns/op 367.36 MB/s Benchmark______FanOut_8x1x10-16 5245088 674.6 ns/op 369.12 MB/s Benchmark______FanOut_8x1x10-16 5273858 678.7 ns/op 366.85 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 635851 5351 ns/op 433.35 MB/s Benchmark_____FanOut_8x1x100-16 603860 5334 ns/op 434.72 MB/s Benchmark_____FanOut_8x1x100-16 630186 5315 ns/op 436.33 MB/s Benchmark_____FanOut_8x1x100-16 616652 5332 ns/op 434.94 MB/s Benchmark_____FanOut_8x1x100-16 618876 5269 ns/op 440.13 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 53298 67318 ns/op 341.95 MB/s Benchmark____FanOut_8x10x100-16 53349 67249 ns/op 342.30 MB/s Benchmark____FanOut_8x10x100-16 53257 67582 ns/op 340.61 MB/s Benchmark____FanOut_8x10x100-16 53433 67248 ns/op 342.30 MB/s Benchmark____FanOut_8x10x100-16 53347 67557 ns/op 340.73 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6849 527718 ns/op 454.82 MB/s Benchmark___FanOut_8x10x1000-16 6667 526692 ns/op 455.71 MB/s Benchmark___FanOut_8x10x1000-16 6693 521055 ns/op 460.64 MB/s Benchmark___FanOut_8x10x1000-16 6859 523904 ns/op 458.14 MB/s Benchmark___FanOut_8x10x1000-16 6589 534848 ns/op 448.76 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5661 625212 ns/op 367.91 MB/s Benchmark___FanOut_8x100x100-16 5638 619227 ns/op 371.46 MB/s Benchmark___FanOut_8x100x100-16 5545 623786 ns/op 368.75 MB/s Benchmark___FanOut_8x100x100-16 5620 625282 ns/op 367.86 MB/s Benchmark___FanOut_8x100x100-16 5607 622414 ns/op 369.56 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 667 5393843 ns/op 444.96 MB/s Benchmark__FanOut_8x100x1000-16 668 5400591 ns/op 444.40 MB/s Benchmark__FanOut_8x100x1000-16 614 5355569 ns/op 448.14 MB/s Benchmark__FanOut_8x100x1000-16 658 5422889 ns/op 442.57 MB/s Benchmark__FanOut_8x100x1000-16 654 5392171 ns/op 445.09 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 595 5977383 ns/op 418.25 MB/s Benchmark__FanOut_8x10x10000-16 598 5946291 ns/op 420.43 MB/s Benchmark__FanOut_8x10x10000-16 620 5880729 ns/op 425.12 MB/s Benchmark__FanOut_8x10x10000-16 621 5918197 ns/op 422.43 MB/s Benchmark__FanOut_8x10x10000-16 594 5990231 ns/op 417.35 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1044 3408925 ns/op 337.36 MB/s Benchmark___FanOut_8x500x100-16 1059 3390830 ns/op 339.16 MB/s Benchmark___FanOut_8x500x100-16 1054 3358542 ns/op 342.42 MB/s Benchmark___FanOut_8x500x100-16 1058 3336444 ns/op 344.68 MB/s Benchmark___FanOut_8x500x100-16 1058 3371751 ns/op 341.07 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 388291 8817 ns/op 1660.53 MB/s Benchmark___FanOut_128x1x100-16 391170 8775 ns/op 1668.45 MB/s Benchmark___FanOut_128x1x100-16 393571 8859 ns/op 1652.67 MB/s Benchmark___FanOut_128x1x100-16 396432 8806 ns/op 1662.58 MB/s Benchmark___FanOut_128x1x100-16 402765 8854 ns/op 1653.63 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 35070 102458 ns/op 1416.59 MB/s Benchmark__FanOut_128x10x100-16 35060 102619 ns/op 1414.37 MB/s Benchmark__FanOut_128x10x100-16 35187 102452 ns/op 1416.67 MB/s Benchmark__FanOut_128x10x100-16 34846 102518 ns/op 1415.76 MB/s Benchmark__FanOut_128x10x100-16 34887 102909 ns/op 1410.38 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4153 794094 ns/op 1838.75 MB/s Benchmark_FanOut_128x10x1000-16 4488 800324 ns/op 1824.44 MB/s Benchmark_FanOut_128x10x1000-16 4460 797959 ns/op 1829.84 MB/s Benchmark_FanOut_128x10x1000-16 4502 797389 ns/op 1831.15 MB/s Benchmark_FanOut_128x10x1000-16 4297 797255 ns/op 1831.46 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3685 951117 ns/op 1524.67 MB/s Benchmark_FanOut_128x100x100-16 3795 941912 ns/op 1539.57 MB/s Benchmark_FanOut_128x100x100-16 3612 951525 ns/op 1524.02 MB/s Benchmark_FanOut_128x100x100-16 3781 945986 ns/op 1532.94 MB/s Benchmark_FanOut_128x100x100-16 3721 949786 ns/op 1526.81 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 422 8541335 ns/op 1709.35 MB/s BenchmarkFanOut_128x100x1000-16 417 8581602 ns/op 1701.33 MB/s BenchmarkFanOut_128x100x1000-16 421 8499544 ns/op 1717.76 MB/s BenchmarkFanOut_128x100x1000-16 420 8495469 ns/op 1718.58 MB/s BenchmarkFanOut_128x100x1000-16 414 8601225 ns/op 1697.45 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 404 8835314 ns/op 1663.79 MB/s BenchmarkFanOut_128x10x10000-16 404 8980613 ns/op 1636.88 MB/s BenchmarkFanOut_128x10x10000-16 411 8894052 ns/op 1652.81 MB/s BenchmarkFanOut_128x10x10000-16 396 8877599 ns/op 1655.87 MB/s BenchmarkFanOut_128x10x10000-16 399 8936808 ns/op 1644.90 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 709 4996645 ns/op 1451.00 MB/s BenchmarkFanOut__128x500x100-16 718 5046196 ns/op 1436.75 MB/s BenchmarkFanOut__128x500x100-16 700 5019836 ns/op 1444.30 MB/s BenchmarkFanOut__128x500x100-16 718 5021718 ns/op 1443.76 MB/s BenchmarkFanOut__128x500x100-16 705 5009412 ns/op 1447.30 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 2024 1768228 ns/op 2991.99 MB/s Benchmark_FanOut_512x100x100-16 2019 1785481 ns/op 2963.08 MB/s Benchmark_FanOut_512x100x100-16 2002 1778418 ns/op 2974.85 MB/s Benchmark_FanOut_512x100x100-16 1983 1776297 ns/op 2978.40 MB/s Benchmark_FanOut_512x100x100-16 2035 1788718 ns/op 2957.72 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 224 16217640 ns/op 3268.08 MB/s Benchmark__FanOut_512x100x1k-16 222 16039875 ns/op 3304.30 MB/s Benchmark__FanOut_512x100x1k-16 224 16149564 ns/op 3281.85 MB/s Benchmark__FanOut_512x100x1k-16 223 16050710 ns/op 3302.07 MB/s Benchmark__FanOut_512x100x1k-16 223 16178157 ns/op 3276.05 MB/s Benchmark____FanOut_1kx10x1k bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 13238799 vs 3287536000 --- FAIL: Benchmark____FanOut_1kx10x1k-16 Benchmark____FanOut_1kx10x1k-16 3133 1141258 ns/op 9139.94 MB/s Benchmark____FanOut_1kx10x1k-16 3344 1112658 ns/op 9374.88 MB/s Benchmark____FanOut_1kx10x1k-16 2929 1093011 ns/op 9543.40 MB/s Benchmark____FanOut_1kx10x1k-16 3147 1113676 ns/op 9366.31 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2974 1180595 ns/op 8826.94 MB/s Benchmark__FanOut_1kx100x100-16 2952 1188134 ns/op 8770.93 MB/s Benchmark__FanOut_1kx100x100-16 2892 1185881 ns/op 8787.59 MB/s Benchmark__FanOut_1kx100x100-16 2938 1191999 ns/op 8742.49 MB/s Benchmark__FanOut_1kx100x100-16 2896 1192331 ns/op 8740.05 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4541268 765.3 ns/op 325.37 MB/s Benchmark_____RFanOut_8x1x10-16 4487634 766.7 ns/op 324.77 MB/s Benchmark_____RFanOut_8x1x10-16 4430989 764.6 ns/op 325.65 MB/s Benchmark_____RFanOut_8x1x10-16 4374300 771.6 ns/op 322.73 MB/s Benchmark_____RFanOut_8x1x10-16 4517757 767.0 ns/op 324.65 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 569700 5853 ns/op 396.20 MB/s Benchmark____RFanOut_8x1x100-16 554619 5784 ns/op 400.91 MB/s Benchmark____RFanOut_8x1x100-16 576429 5871 ns/op 394.97 MB/s Benchmark____RFanOut_8x1x100-16 538380 5847 ns/op 396.64 MB/s Benchmark____RFanOut_8x1x100-16 540528 5827 ns/op 397.98 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 49978 72530 ns/op 317.37 MB/s Benchmark___RFanOut_8x10x100-16 49728 71779 ns/op 320.69 MB/s Benchmark___RFanOut_8x10x100-16 50067 72455 ns/op 317.70 MB/s Benchmark___RFanOut_8x10x100-16 49744 71644 ns/op 321.30 MB/s Benchmark___RFanOut_8x10x100-16 49113 72586 ns/op 317.13 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6031 579721 ns/op 414.02 MB/s Benchmark__RFanOut_8x10x1000-16 6153 575699 ns/op 416.92 MB/s Benchmark__RFanOut_8x10x1000-16 6097 577624 ns/op 415.53 MB/s Benchmark__RFanOut_8x10x1000-16 6132 575679 ns/op 416.93 MB/s Benchmark__RFanOut_8x10x1000-16 6064 577466 ns/op 415.64 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5197 679065 ns/op 338.73 MB/s Benchmark__RFanOut_8x100x100-16 5205 681066 ns/op 337.73 MB/s Benchmark__RFanOut_8x100x100-16 5031 677586 ns/op 339.47 MB/s Benchmark__RFanOut_8x100x100-16 5032 685113 ns/op 335.74 MB/s Benchmark__RFanOut_8x100x100-16 5240 679028 ns/op 338.75 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 596 5931011 ns/op 404.66 MB/s Benchmark_RFanOut_8x100x1000-16 586 5934140 ns/op 404.44 MB/s Benchmark_RFanOut_8x100x1000-16 603 5878219 ns/op 408.29 MB/s Benchmark_RFanOut_8x100x1000-16 606 6053829 ns/op 396.45 MB/s Benchmark_RFanOut_8x100x1000-16 597 5944401 ns/op 403.74 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 554 6474724 ns/op 386.12 MB/s Benchmark_RFanOut_8x10x10000-16 554 6449843 ns/op 387.61 MB/s Benchmark_RFanOut_8x10x10000-16 559 6574149 ns/op 380.28 MB/s Benchmark_RFanOut_8x10x10000-16 549 6385996 ns/op 391.48 MB/s Benchmark_RFanOut_8x10x10000-16 552 6372226 ns/op 392.33 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2982 1157753 ns/op 9009.73 MB/s Benchmark_RFanOut_1kx10x1000-16 3314 1147402 ns/op 9091.01 MB/s Benchmark_RFanOut_1kx10x1000-16 3202 1150510 ns/op 9066.45 MB/s Benchmark_RFanOut_1kx10x1000-16 3006 1136476 ns/op 9178.41 MB/s Benchmark_RFanOut_1kx10x1000-16 3148 1153421 ns/op 9043.57 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7417676 480.9 ns/op 4320.84 MB/s Benchmark_____FanIn_1kx100x1-16 7287297 482.8 ns/op 4304.36 MB/s Benchmark_____FanIn_1kx100x1-16 7259421 484.0 ns/op 4293.05 MB/s Benchmark_____FanIn_1kx100x1-16 7236609 483.0 ns/op 4302.46 MB/s Benchmark_____FanIn_1kx100x1-16 7211205 481.4 ns/op 4316.69 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2663383 1344 ns/op 6118.80 MB/s Benchmark_____FanIn_4kx100x1-16 2616104 1336 ns/op 6153.55 MB/s Benchmark_____FanIn_4kx100x1-16 2714821 1330 ns/op 6184.16 MB/s Benchmark_____FanIn_4kx100x1-16 2672148 1330 ns/op 6179.78 MB/s Benchmark_____FanIn_4kx100x1-16 2644840 1326 ns/op 6199.79 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1732827 2091 ns/op 7849.17 MB/s Benchmark_____FanIn_8kx100x1-16 1704008 2084 ns/op 7877.59 MB/s Benchmark_____FanIn_8kx100x1-16 1695213 2069 ns/op 7931.46 MB/s Benchmark_____FanIn_8kx100x1-16 1732952 2082 ns/op 7883.80 MB/s Benchmark_____FanIn_8kx100x1-16 1720198 2061 ns/op 7965.45 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 879699 4141 ns/op 7920.12 MB/s Benchmark____FanIn_16kx100x1-16 861758 4105 ns/op 7989.55 MB/s Benchmark____FanIn_16kx100x1-16 877287 4096 ns/op 8008.65 MB/s Benchmark____FanIn_16kx100x1-16 872324 4150 ns/op 7902.74 MB/s Benchmark____FanIn_16kx100x1-16 884911 4158 ns/op 7888.46 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 156892 19878 ns/op 6595.42 MB/s Benchmark____FanIn_64kx100x1-16 165932 20037 ns/op 6542.97 MB/s Benchmark____FanIn_64kx100x1-16 169196 19966 ns/op 6566.37 MB/s Benchmark____FanIn_64kx100x1-16 164638 20046 ns/op 6540.30 MB/s Benchmark____FanIn_64kx100x1-16 173029 19915 ns/op 6583.14 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 281581320 vs 1310900000 bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: 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:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:34568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34250->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: 294165960 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36148->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:35964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36586->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: 337032390 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38192->127.0.0.1:5222: write: broken pipe bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38046->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 356695890 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:40214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:39674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:40000->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: 115752470 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:41804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:42108->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 6062506 590.7 ns/op 480.80 MB/s Benchmark___BumpPubCount_1x3-16 6102310 592.2 ns/op 479.57 MB/s Benchmark___BumpPubCount_1x3-16 6073774 589.0 ns/op 482.17 MB/s Benchmark___BumpPubCount_1x3-16 6072501 585.2 ns/op 485.33 MB/s Benchmark___BumpPubCount_1x3-16 6057244 587.3 ns/op 483.55 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5693524 629.4 ns/op 451.22 MB/s Benchmark___BumpPubCount_2x3-16 5681122 625.7 ns/op 453.89 MB/s Benchmark___BumpPubCount_2x3-16 5655774 625.3 ns/op 454.18 MB/s Benchmark___BumpPubCount_2x3-16 5721638 628.8 ns/op 451.62 MB/s Benchmark___BumpPubCount_2x3-16 5663233 627.7 ns/op 452.43 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5822890 612.5 ns/op 463.67 MB/s Benchmark___BumpPubCount_5x3-16 5362381 611.2 ns/op 464.66 MB/s Benchmark___BumpPubCount_5x3-16 5858197 611.6 ns/op 464.34 MB/s Benchmark___BumpPubCount_5x3-16 5631004 611.4 ns/op 464.53 MB/s Benchmark___BumpPubCount_5x3-16 5854545 613.5 ns/op 462.93 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5912377 606.1 ns/op 468.60 MB/s Benchmark__BumpPubCount_10x3-16 5957564 606.5 ns/op 468.24 MB/s Benchmark__BumpPubCount_10x3-16 5899148 606.1 ns/op 468.59 MB/s Benchmark__BumpPubCount_10x3-16 5915611 607.2 ns/op 467.72 MB/s Benchmark__BumpPubCount_10x3-16 5941966 608.0 ns/op 467.14 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 13243820 253.8 ns/op 4097.35 MB/s Benchmark____GWs_Opt_1kx01x0-16 14155348 257.3 ns/op 4041.24 MB/s Benchmark____GWs_Opt_1kx01x0-16 13688787 261.3 ns/op 3980.20 MB/s Benchmark____GWs_Opt_1kx01x0-16 14059371 258.1 ns/op 4030.03 MB/s Benchmark____GWs_Opt_1kx01x0-16 13094533 255.6 ns/op 4068.35 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10954651 304.3 ns/op 6782.10 MB/s Benchmark____GWs_Opt_2kx01x0-16 11424406 304.5 ns/op 6778.35 MB/s Benchmark____GWs_Opt_2kx01x0-16 9915404 303.6 ns/op 6799.15 MB/s Benchmark____GWs_Opt_2kx01x0-16 10967413 312.2 ns/op 6611.12 MB/s Benchmark____GWs_Opt_2kx01x0-16 10705152 312.0 ns/op 6615.20 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5439566 638.3 ns/op 6442.17 MB/s Benchmark____GWs_Opt_4kx01x0-16 5530621 635.0 ns/op 6475.37 MB/s Benchmark____GWs_Opt_4kx01x0-16 5501623 637.0 ns/op 6454.81 MB/s Benchmark____GWs_Opt_4kx01x0-16 5325888 632.3 ns/op 6502.80 MB/s Benchmark____GWs_Opt_4kx01x0-16 5291613 621.0 ns/op 6621.42 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30562725 107.7 ns/op 9655.22 MB/s Benchmark____GWs_Opt_1kx10x0-16 32875521 115.2 ns/op 9027.25 MB/s Benchmark____GWs_Opt_1kx10x0-16 33344376 111.4 ns/op 9339.84 MB/s Benchmark____GWs_Opt_1kx10x0-16 30634494 107.1 ns/op 9707.78 MB/s Benchmark____GWs_Opt_1kx10x0-16 30681061 111.6 ns/op 9321.67 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23758117 149.7 ns/op 13784.38 MB/s Benchmark____GWs_Opt_2kx10x0-16 22251507 143.7 ns/op 14364.44 MB/s Benchmark____GWs_Opt_2kx10x0-16 23825277 146.4 ns/op 14098.57 MB/s Benchmark____GWs_Opt_2kx10x0-16 25515138 148.7 ns/op 13883.55 MB/s Benchmark____GWs_Opt_2kx10x0-16 25558521 146.9 ns/op 14046.84 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12190132 296.3 ns/op 13877.59 MB/s Benchmark____GWs_Opt_4kx10x0-16 12682107 295.0 ns/op 13940.06 MB/s Benchmark____GWs_Opt_4kx10x0-16 12591240 322.8 ns/op 12738.65 MB/s Benchmark____GWs_Opt_4kx10x0-16 12487681 281.2 ns/op 14621.89 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:58154->127.0.0.1:37565: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6301593 561.0 ns/op 5570.71 MB/s Benchmark____GWs_Opt_1kx01x1-16 6429980 556.6 ns/op 5614.39 MB/s Benchmark____GWs_Opt_1kx01x1-16 5806131 563.6 ns/op 5544.56 MB/s Benchmark____GWs_Opt_1kx01x1-16 6316476 555.6 ns/op 5624.85 MB/s Benchmark____GWs_Opt_1kx01x1-16 6295272 553.9 ns/op 5642.12 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4598541 856.4 ns/op 7236.17 MB/s Benchmark____GWs_Opt_2kx01x1-16 4384092 814.0 ns/op 7613.01 MB/s Benchmark____GWs_Opt_2kx01x1-16 4091546 805.8 ns/op 7690.62 MB/s Benchmark____GWs_Opt_2kx01x1-16 3994363 812.8 ns/op 7624.55 MB/s Benchmark____GWs_Opt_2kx01x1-16 4343770 797.1 ns/op 7774.46 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2537823 1421 ns/op 8682.13 MB/s Benchmark____GWs_Opt_4kx01x1-16 2571426 1816 ns/op 6796.01 MB/s Benchmark____GWs_Opt_4kx01x1-16 2492126 1436 ns/op 8595.12 MB/s Benchmark____GWs_Opt_4kx01x1-16 2489592 1422 ns/op 8681.15 MB/s Benchmark____GWs_Opt_4kx01x1-16 2534020 1564 ns/op 7888.53 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 5874028 568.1 ns/op 5501.24 MB/s Benchmark____GWs_Opt_1kx10x1-16 5803092 576.3 ns/op 5422.82 MB/s Benchmark____GWs_Opt_1kx10x1-16 5933203 573.4 ns/op 5450.20 MB/s Benchmark____GWs_Opt_1kx10x1-16 5901614 576.7 ns/op 5419.14 MB/s Benchmark____GWs_Opt_1kx10x1-16 5886730 577.2 ns/op 5414.52 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4012638 869.0 ns/op 7131.05 MB/s Benchmark____GWs_Opt_2kx10x1-16 3968757 865.6 ns/op 7159.20 MB/s Benchmark____GWs_Opt_2kx10x1-16 4030579 872.1 ns/op 7105.95 MB/s Benchmark____GWs_Opt_2kx10x1-16 4046522 866.7 ns/op 7150.51 MB/s Benchmark____GWs_Opt_2kx10x1-16 3977330 867.3 ns/op 7144.91 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2192298 1641 ns/op 7521.79 MB/s Benchmark____GWs_Opt_4kx10x1-16 2294804 1547 ns/op 7976.02 MB/s Benchmark____GWs_Opt_4kx10x1-16 2301344 1528 ns/op 8077.75 MB/s Benchmark____GWs_Opt_4kx10x1-16 2313140 1559 ns/op 7918.32 MB/s Benchmark____GWs_Opt_4kx10x1-16 2299844 1545 ns/op 7987.15 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 13313966 274.3 ns/op 3791.93 MB/s Benchmark____GWs_Int_1kx01x0-16 12955176 266.0 ns/op 3909.99 MB/s Benchmark____GWs_Int_1kx01x0-16 12932149 280.3 ns/op 3710.52 MB/s Benchmark____GWs_Int_1kx01x0-16 12822192 273.6 ns/op 3801.56 MB/s Benchmark____GWs_Int_1kx01x0-16 13446618 272.5 ns/op 3816.22 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10490372 336.3 ns/op 6137.50 MB/s Benchmark____GWs_Int_2kx01x0-16 10801773 337.8 ns/op 6110.22 MB/s Benchmark____GWs_Int_2kx01x0-16 10333822 342.1 ns/op 6033.88 MB/s Benchmark____GWs_Int_2kx01x0-16 10789114 328.0 ns/op 6292.09 MB/s Benchmark____GWs_Int_2kx01x0-16 10806470 339.7 ns/op 6075.38 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5383819 658.3 ns/op 6246.10 MB/s Benchmark____GWs_Int_4kx01x0-16 5373633 655.3 ns/op 6275.32 MB/s Benchmark____GWs_Int_4kx01x0-16 5465248 659.3 ns/op 6236.78 MB/s Benchmark____GWs_Int_4kx01x0-16 5483790 642.6 ns/op 6399.45 MB/s Benchmark____GWs_Int_4kx01x0-16 5115390 626.1 ns/op 6567.31 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30705028 107.9 ns/op 9642.89 MB/s Benchmark____GWs_Int_1kx10x0-16 32265914 108.4 ns/op 9594.71 MB/s Benchmark____GWs_Int_1kx10x0-16 29558628 111.1 ns/op 9359.20 MB/s Benchmark____GWs_Int_1kx10x0-16 33014590 111.9 ns/op 9294.98 MB/s Benchmark____GWs_Int_1kx10x0-16 33706227 110.7 ns/op 9393.07 MB/s Benchmark____GWs_Int_2kx10x0 bench_test.go:55: Failed read: read tcp 127.0.0.1:45588->127.0.0.1:34731: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 26119754 140.8 ns/op 14662.24 MB/s Benchmark____GWs_Int_2kx10x0-16 22986662 140.5 ns/op 14691.51 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:42380->127.0.0.1:44965: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:41656->127.0.0.1:34439: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 26786191 145.5 ns/op 14181.41 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 9781870 360.9 ns/op 11394.21 MB/s Benchmark____GWs_Int_4kx10x0-16 13256794 323.9 ns/op 12694.46 MB/s Benchmark____GWs_Int_4kx10x0-16 11388642 300.4 ns/op 13688.80 MB/s Benchmark____GWs_Int_4kx10x0-16 11553789 291.3 ns/op 14115.06 MB/s Benchmark____GWs_Int_4kx10x0-16 12788152 314.4 ns/op 13079.33 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6247832 576.3 ns/op 5422.64 MB/s Benchmark____GWs_Int_1kx01x1-16 6239061 578.0 ns/op 5406.60 MB/s Benchmark____GWs_Int_1kx01x1-16 6108336 578.1 ns/op 5405.66 MB/s Benchmark____GWs_Int_1kx01x1-16 6286117 571.1 ns/op 5472.25 MB/s Benchmark____GWs_Int_1kx01x1-16 6465086 559.0 ns/op 5590.63 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4219437 845.8 ns/op 7327.06 MB/s Benchmark____GWs_Int_2kx01x1-16 4485961 804.5 ns/op 7702.58 MB/s Benchmark____GWs_Int_2kx01x1-16 4249807 806.5 ns/op 7683.81 MB/s Benchmark____GWs_Int_2kx01x1-16 4474933 817.3 ns/op 7582.73 MB/s Benchmark____GWs_Int_2kx01x1-16 4416744 1260 ns/op 4918.24 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2551189 1453 ns/op 8493.19 MB/s Benchmark____GWs_Int_4kx01x1-16 2239635 1429 ns/op 8635.28 MB/s Benchmark____GWs_Int_4kx01x1-16 2529723 1420 ns/op 8689.48 MB/s Benchmark____GWs_Int_4kx01x1-16 2490820 1442 ns/op 8557.59 MB/s Benchmark____GWs_Int_4kx01x1-16 2437930 1425 ns/op 8660.92 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 5723718 572.2 ns/op 5461.09 MB/s Benchmark____GWs_Int_1kx10x1-16 6036512 567.3 ns/op 5509.00 MB/s Benchmark____GWs_Int_1kx10x1-16 5998344 575.9 ns/op 5426.68 MB/s Benchmark____GWs_Int_1kx10x1-16 6008540 582.6 ns/op 5363.69 MB/s Benchmark____GWs_Int_1kx10x1-16 5889556 577.2 ns/op 5414.17 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 3938448 883.1 ns/op 7017.16 MB/s Benchmark____GWs_Int_2kx10x1-16 4023056 876.6 ns/op 7069.19 MB/s Benchmark____GWs_Int_2kx10x1-16 4003629 865.6 ns/op 7159.36 MB/s Benchmark____GWs_Int_2kx10x1-16 4066816 864.4 ns/op 7169.32 MB/s Benchmark____GWs_Int_2kx10x1-16 4089513 891.8 ns/op 6948.78 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2300919 1529 ns/op 8073.76 MB/s Benchmark____GWs_Int_4kx10x1-16 2237407 1552 ns/op 7950.59 MB/s Benchmark____GWs_Int_4kx10x1-16 2253740 1559 ns/op 7916.37 MB/s Benchmark____GWs_Int_4kx10x1-16 2321266 1543 ns/op 7997.00 MB/s Benchmark____GWs_Int_4kx10x1-16 2301156 1607 ns/op 7679.43 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8222862 440.2 ns/op 231.71 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7894052 449.2 ns/op 227.09 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8299327 436.8 ns/op 233.53 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8463284 440.4 ns/op 231.60 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7930054 434.5 ns/op 234.75 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 769168 4706 ns/op 37.61 MB/s Benchmark__GWs_Reqs_1SubEach-16 770227 4929 ns/op 35.91 MB/s Benchmark__GWs_Reqs_1SubEach-16 785816 4993 ns/op 35.45 MB/s Benchmark__GWs_Reqs_1SubEach-16 797098 5013 ns/op 35.31 MB/s Benchmark__GWs_Reqs_1SubEach-16 801586 5128 ns/op 34.52 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2153.760s ❌ Non-zero exit code: 1