> ROOT_DIR=/tmp/go-bench-away-job-4c6b85b9-a227-461a-8051-b140279a5d34-372550959 > OUTPUT_FILE=/tmp/go-bench-away-job-4c6b85b9-a227-461a-8051-b140279a5d34-372550959/results.txt > SHA_FILE=/tmp/go-bench-away-job-4c6b85b9-a227-461a-8051-b140279a5d34-372550959/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-4c6b85b9-a227-461a-8051-b140279a5d34-372550959/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-4c6b85b9-a227-461a-8051-b140279a5d34-372550959/source.git SHA of main: 09c721a5326c66679f9597fae79f08740ef91455 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-build4203139775=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-4c6b85b9-a227-461a-8051-b140279a5d34-372550959/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 43928934 72.17 ns/op 152.42 MB/s Benchmark______Pub0b_Payload-16 47635746 74.57 ns/op 147.52 MB/s Benchmark______Pub0b_Payload-16 47502190 71.47 ns/op 153.92 MB/s Benchmark______Pub0b_Payload-16 47679014 71.50 ns/op 153.85 MB/s Benchmark______Pub0b_Payload-16 47389383 71.59 ns/op 153.65 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 47362792 74.36 ns/op 255.52 MB/s Benchmark______Pub8b_Payload-16 46089921 72.76 ns/op 261.13 MB/s Benchmark______Pub8b_Payload-16 47225642 72.25 ns/op 262.97 MB/s Benchmark______Pub8b_Payload-16 40663166 74.59 ns/op 254.74 MB/s Benchmark______Pub8b_Payload-16 47256308 72.32 ns/op 262.73 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44217286 76.83 ns/op 572.72 MB/s Benchmark_____Pub32b_Payload-16 46780792 78.12 ns/op 563.24 MB/s Benchmark_____Pub32b_Payload-16 44385610 76.74 ns/op 573.33 MB/s Benchmark_____Pub32b_Payload-16 42326228 76.80 ns/op 572.95 MB/s Benchmark_____Pub32b_Payload-16 44408187 76.88 ns/op 572.34 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39232110 86.18 ns/op 1636.14 MB/s Benchmark____Pub128B_Payload-16 34402716 87.71 ns/op 1607.54 MB/s Benchmark____Pub128B_Payload-16 41802456 86.67 ns/op 1626.84 MB/s Benchmark____Pub128B_Payload-16 36299409 90.78 ns/op 1553.23 MB/s Benchmark____Pub128B_Payload-16 39859017 87.45 ns/op 1612.39 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35744436 94.59 ns/op 2843.76 MB/s Benchmark____Pub256B_Payload-16 35251888 94.82 ns/op 2836.91 MB/s Benchmark____Pub256B_Payload-16 35383740 94.79 ns/op 2837.80 MB/s Benchmark____Pub256B_Payload-16 32403240 95.41 ns/op 2819.35 MB/s Benchmark____Pub256B_Payload-16 35764353 94.56 ns/op 2844.66 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24096014 141.5 ns/op 7333.47 MB/s Benchmark______Pub1K_Payload-16 21928100 142.1 ns/op 7305.06 MB/s Benchmark______Pub1K_Payload-16 23845658 135.9 ns/op 7635.99 MB/s Benchmark______Pub1K_Payload-16 23113676 138.7 ns/op 7484.61 MB/s Benchmark______Pub1K_Payload-16 24239728 144.6 ns/op 7180.77 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5580813 634.3 ns/op 6480.02 MB/s Benchmark______Pub4K_Payload-16 5662208 608.3 ns/op 6756.25 MB/s Benchmark______Pub4K_Payload-16 5253037 607.9 ns/op 6761.30 MB/s Benchmark______Pub4K_Payload-16 5442699 612.9 ns/op 6705.64 MB/s Benchmark______Pub4K_Payload-16 5584266 619.2 ns/op 6637.20 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2745835 1276 ns/op 6431.75 MB/s Benchmark______Pub8K_Payload-16 2824540 1279 ns/op 6417.76 MB/s Benchmark______Pub8K_Payload-16 2812039 1299 ns/op 6315.28 MB/s Benchmark______Pub8K_Payload-16 2720229 1287 ns/op 6378.28 MB/s Benchmark______Pub8K_Payload-16 2726047 1279 ns/op 6414.10 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 652688 9899 ns/op 3311.61 MB/s Benchmark_____Pub32K_Payload-16 587212 5530 ns/op 5927.94 MB/s Benchmark_____Pub32K_Payload-16 558051 5478 ns/op 5984.00 MB/s Benchmark_____Pub32K_Payload-16 647184 5470 ns/op 5993.54 MB/s Benchmark_____Pub32K_Payload-16 647508 5507 ns/op 5952.53 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32086338 94.03 ns/op 116.98 MB/s Benchmark__AuthPub0b_Payload-16 36275958 94.10 ns/op 116.90 MB/s Benchmark__AuthPub0b_Payload-16 36352924 94.33 ns/op 116.61 MB/s Benchmark__AuthPub0b_Payload-16 36563074 97.09 ns/op 113.30 MB/s Benchmark__AuthPub0b_Payload-16 36499923 94.53 ns/op 116.37 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15838029 224.6 ns/op Benchmark_____________PubSub-16 15735394 227.2 ns/op Benchmark_____________PubSub-16 15777298 225.5 ns/op Benchmark_____________PubSub-16 15699670 224.8 ns/op Benchmark_____________PubSub-16 15750538 225.1 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15897870 223.4 ns/op Benchmark_____PubSubTwoConns-16 15762052 223.8 ns/op Benchmark_____PubSubTwoConns-16 15662053 222.8 ns/op Benchmark_____PubSubTwoConns-16 15916941 224.3 ns/op Benchmark_____PubSubTwoConns-16 15861793 224.6 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41454->127.0.0.1:44879: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59768->127.0.0.1:36229: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57268->127.0.0.1:38537: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49708->127.0.0.1:39379: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:55248->127.0.0.1:33829: 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 14357622 245.5 ns/op Benchmark_____PubTwoQueueSub-16 14446267 245.2 ns/op Benchmark_____PubTwoQueueSub-16 14410574 245.8 ns/op Benchmark_____PubTwoQueueSub-16 14374604 244.8 ns/op Benchmark_____PubTwoQueueSub-16 14404144 245.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14529080 245.1 ns/op Benchmark____PubFourQueueSub-16 14439088 246.0 ns/op Benchmark____PubFourQueueSub-16 14429521 245.8 ns/op Benchmark____PubFourQueueSub-16 14295332 245.1 ns/op Benchmark____PubFourQueueSub-16 14501961 246.1 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14445555 245.1 ns/op Benchmark___PubEightQueueSub-16 14515533 246.3 ns/op Benchmark___PubEightQueueSub-16 14318772 244.2 ns/op Benchmark___PubEightQueueSub-16 14471977 244.9 ns/op Benchmark___PubEightQueueSub-16 14365290 246.5 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23017 156280 ns/op Benchmark_PubSub512kTwoConns-16 23156 156081 ns/op Benchmark_PubSub512kTwoConns-16 22950 154761 ns/op Benchmark_PubSub512kTwoConns-16 23138 155127 ns/op Benchmark_PubSub512kTwoConns-16 23224 155732 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15391214 227.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15300774 228.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15406323 228.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15360002 227.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15272931 227.0 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15128530 228.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15510801 228.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15446646 226.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15247214 228.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15187545 228.5 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10767758 310.8 ns/op Benchmark____RoutedPubSub_0b-16 11274282 315.2 ns/op Benchmark____RoutedPubSub_0b-16 11476794 311.2 ns/op Benchmark____RoutedPubSub_0b-16 11511424 311.0 ns/op Benchmark____RoutedPubSub_0b-16 11416438 309.8 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6609272 537.7 ns/op Benchmark____RoutedPubSub_1K-16 6228733 538.6 ns/op Benchmark____RoutedPubSub_1K-16 6450295 540.8 ns/op Benchmark____RoutedPubSub_1K-16 6497779 805.5 ns/op Benchmark____RoutedPubSub_1K-16 6458196 554.6 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 82420 41898 ns/op Benchmark__RoutedPubSub_100K-16 87126 42747 ns/op Benchmark__RoutedPubSub_100K-16 84188 42191 ns/op Benchmark__RoutedPubSub_100K-16 82987 43319 ns/op Benchmark__RoutedPubSub_100K-16 83004 43567 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9402414 325.3 ns/op Benchmark____Routed2QueueSub-16 9852204 324.8 ns/op Benchmark____Routed2QueueSub-16 9469708 321.6 ns/op Benchmark____Routed2QueueSub-16 9561230 330.1 ns/op Benchmark____Routed2QueueSub-16 9581108 324.0 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9419700 330.1 ns/op Benchmark____Routed4QueueSub-16 9281613 329.3 ns/op Benchmark____Routed4QueueSub-16 9325252 326.2 ns/op Benchmark____Routed4QueueSub-16 9652282 320.6 ns/op Benchmark____Routed4QueueSub-16 9662457 330.2 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9168344 331.2 ns/op Benchmark____Routed8QueueSub-16 9043513 337.3 ns/op Benchmark____Routed8QueueSub-16 10974842 327.0 ns/op Benchmark____Routed8QueueSub-16 10968954 330.4 ns/op Benchmark____Routed8QueueSub-16 9046405 336.1 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8762404 349.2 ns/op Benchmark___Routed16QueueSub-16 8816637 350.5 ns/op Benchmark___Routed16QueueSub-16 8777971 352.5 ns/op Benchmark___Routed16QueueSub-16 8561077 358.1 ns/op Benchmark___Routed16QueueSub-16 8774298 355.1 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6521745 555.0 ns/op Benchmark____________RouteCompressOff-16 6522696 558.0 ns/op Benchmark____________RouteCompressOff-16 6297770 551.4 ns/op Benchmark____________RouteCompressOff-16 6489122 543.1 ns/op Benchmark____________RouteCompressOff-16 6466215 543.9 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6394706 548.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6419990 552.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6353167 550.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6479164 548.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6234639 553.2 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6376747 544.2 ns/op Benchmark_________RouteCompressS2Fast-16 6395180 550.8 ns/op Benchmark_________RouteCompressS2Fast-16 6548127 547.4 ns/op Benchmark_________RouteCompressS2Fast-16 6440773 547.9 ns/op Benchmark_________RouteCompressS2Fast-16 6421666 549.8 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6368420 550.1 ns/op Benchmark_______RouteCompressS2Better-16 6444063 548.6 ns/op Benchmark_______RouteCompressS2Better-16 6511809 545.9 ns/op Benchmark_______RouteCompressS2Better-16 6380580 548.5 ns/op Benchmark_______RouteCompressS2Better-16 6532623 549.7 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6469814 549.1 ns/op Benchmark_________RouteCompressS2Best-16 6308019 547.2 ns/op Benchmark_________RouteCompressS2Best-16 6298684 546.7 ns/op Benchmark_________RouteCompressS2Best-16 6518788 544.3 ns/op Benchmark_________RouteCompressS2Best-16 6288976 546.3 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4649397 768.4 ns/op 324.04 MB/s Benchmark______FanOut_8x1x10-16 4622906 765.4 ns/op 325.34 MB/s Benchmark______FanOut_8x1x10-16 4632218 766.4 ns/op 324.89 MB/s Benchmark______FanOut_8x1x10-16 4657803 766.7 ns/op 324.76 MB/s Benchmark______FanOut_8x1x10-16 4650308 768.4 ns/op 324.06 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 528799 6144 ns/op 377.43 MB/s Benchmark_____FanOut_8x1x100-16 543825 6127 ns/op 378.51 MB/s Benchmark_____FanOut_8x1x100-16 533882 6126 ns/op 378.53 MB/s Benchmark_____FanOut_8x1x100-16 554180 6113 ns/op 379.38 MB/s Benchmark_____FanOut_8x1x100-16 539755 6121 ns/op 378.86 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47576 75495 ns/op 304.91 MB/s Benchmark____FanOut_8x10x100-16 46780 75344 ns/op 305.52 MB/s Benchmark____FanOut_8x10x100-16 47758 75466 ns/op 305.03 MB/s Benchmark____FanOut_8x10x100-16 47760 75750 ns/op 303.88 MB/s Benchmark____FanOut_8x10x100-16 47900 76056 ns/op 302.66 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5718 611585 ns/op 392.45 MB/s Benchmark___FanOut_8x10x1000-16 5896 618542 ns/op 388.04 MB/s Benchmark___FanOut_8x10x1000-16 5798 606928 ns/op 395.47 MB/s Benchmark___FanOut_8x10x1000-16 5828 611105 ns/op 392.76 MB/s Benchmark___FanOut_8x10x1000-16 5991 610319 ns/op 393.27 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4909 719503 ns/op 319.69 MB/s Benchmark___FanOut_8x100x100-16 4926 719291 ns/op 319.79 MB/s Benchmark___FanOut_8x100x100-16 4886 723805 ns/op 317.79 MB/s Benchmark___FanOut_8x100x100-16 4869 720363 ns/op 319.31 MB/s Benchmark___FanOut_8x100x100-16 4886 720059 ns/op 319.44 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 565 6407942 ns/op 374.54 MB/s Benchmark__FanOut_8x100x1000-16 558 6274402 ns/op 382.51 MB/s Benchmark__FanOut_8x100x1000-16 562 6318040 ns/op 379.87 MB/s Benchmark__FanOut_8x100x1000-16 553 6421310 ns/op 373.76 MB/s Benchmark__FanOut_8x100x1000-16 548 6280847 ns/op 382.12 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 529 6767796 ns/op 369.40 MB/s Benchmark__FanOut_8x10x10000-16 531 6860897 ns/op 364.39 MB/s Benchmark__FanOut_8x10x10000-16 522 6826303 ns/op 366.23 MB/s Benchmark__FanOut_8x10x10000-16 522 6875049 ns/op 363.64 MB/s Benchmark__FanOut_8x10x10000-16 513 6840841 ns/op 365.45 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 932 3821444 ns/op 300.94 MB/s Benchmark___FanOut_8x500x100-16 932 3811261 ns/op 301.74 MB/s Benchmark___FanOut_8x500x100-16 928 3805706 ns/op 302.18 MB/s Benchmark___FanOut_8x500x100-16 936 3805862 ns/op 302.17 MB/s Benchmark___FanOut_8x500x100-16 939 3810128 ns/op 301.83 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 363334 9632 ns/op 1520.07 MB/s Benchmark___FanOut_128x1x100-16 352464 9540 ns/op 1534.73 MB/s Benchmark___FanOut_128x1x100-16 358741 9522 ns/op 1537.63 MB/s Benchmark___FanOut_128x1x100-16 342560 9569 ns/op 1530.09 MB/s Benchmark___FanOut_128x1x100-16 358738 9626 ns/op 1520.93 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32114 111856 ns/op 1297.57 MB/s Benchmark__FanOut_128x10x100-16 32191 111863 ns/op 1297.49 MB/s Benchmark__FanOut_128x10x100-16 31981 112642 ns/op 1288.52 MB/s Benchmark__FanOut_128x10x100-16 32167 112035 ns/op 1295.50 MB/s Benchmark__FanOut_128x10x100-16 32070 111593 ns/op 1300.62 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3846 888787 ns/op 1642.85 MB/s Benchmark_FanOut_128x10x1000-16 3999 892622 ns/op 1635.79 MB/s Benchmark_FanOut_128x10x1000-16 3969 894229 ns/op 1632.85 MB/s Benchmark_FanOut_128x10x1000-16 3906 891234 ns/op 1638.34 MB/s Benchmark_FanOut_128x10x1000-16 3898 891959 ns/op 1637.01 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3508 1027046 ns/op 1411.95 MB/s Benchmark_FanOut_128x100x100-16 3433 1025023 ns/op 1414.74 MB/s Benchmark_FanOut_128x100x100-16 3469 1024379 ns/op 1415.63 MB/s Benchmark_FanOut_128x100x100-16 3422 1020318 ns/op 1421.26 MB/s Benchmark_FanOut_128x100x100-16 3475 1023660 ns/op 1416.62 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 374 9489401 ns/op 1538.57 MB/s BenchmarkFanOut_128x100x1000-16 381 9463317 ns/op 1542.81 MB/s BenchmarkFanOut_128x100x1000-16 376 9473287 ns/op 1541.19 MB/s BenchmarkFanOut_128x100x1000-16 374 9529689 ns/op 1532.07 MB/s BenchmarkFanOut_128x100x1000-16 381 9567361 ns/op 1526.04 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 366 9747677 ns/op 1508.07 MB/s BenchmarkFanOut_128x10x10000-16 369 9883692 ns/op 1487.31 MB/s BenchmarkFanOut_128x10x10000-16 366 9755177 ns/op 1506.91 MB/s BenchmarkFanOut_128x10x10000-16 367 9755956 ns/op 1506.79 MB/s BenchmarkFanOut_128x10x10000-16 366 9876491 ns/op 1488.40 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 666 5351685 ns/op 1354.74 MB/s BenchmarkFanOut__128x500x100-16 658 5402422 ns/op 1342.02 MB/s BenchmarkFanOut__128x500x100-16 661 5353286 ns/op 1354.33 MB/s BenchmarkFanOut__128x500x100-16 667 5306776 ns/op 1366.20 MB/s BenchmarkFanOut__128x500x100-16 673 5343347 ns/op 1356.85 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1926 1847454 ns/op 2863.68 MB/s Benchmark_FanOut_512x100x100-16 1906 1842345 ns/op 2871.63 MB/s Benchmark_FanOut_512x100x100-16 1929 1843937 ns/op 2869.15 MB/s Benchmark_FanOut_512x100x100-16 1910 1855373 ns/op 2851.46 MB/s Benchmark_FanOut_512x100x100-16 1940 1844736 ns/op 2867.90 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 16763137 ns/op 3161.73 MB/s Benchmark__FanOut_512x100x1k-16 217 16659423 ns/op 3181.41 MB/s Benchmark__FanOut_512x100x1k-16 212 16934903 ns/op 3129.66 MB/s Benchmark__FanOut_512x100x1k-16 214 16931474 ns/op 3130.30 MB/s Benchmark__FanOut_512x100x1k-16 212 16871248 ns/op 3141.47 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3306 1158975 ns/op 9000.23 MB/s Benchmark____FanOut_1kx10x1k-16 3158 1166663 ns/op 8940.92 MB/s Benchmark____FanOut_1kx10x1k-16 3135 1156842 ns/op 9016.82 MB/s Benchmark____FanOut_1kx10x1k-16 2751 1152838 ns/op 9048.14 MB/s Benchmark____FanOut_1kx10x1k-16 3122 1160191 ns/op 8990.79 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2731 1270829 ns/op 8200.19 MB/s Benchmark__FanOut_1kx100x100-16 2785 1268636 ns/op 8214.36 MB/s Benchmark__FanOut_1kx100x100-16 2710 1271435 ns/op 8196.28 MB/s Benchmark__FanOut_1kx100x100-16 2745 1272653 ns/op 8188.44 MB/s Benchmark__FanOut_1kx100x100-16 2752 1272890 ns/op 8186.91 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4445300 775.2 ns/op 321.22 MB/s Benchmark_____RFanOut_8x1x10-16 4529533 786.8 ns/op 316.46 MB/s Benchmark_____RFanOut_8x1x10-16 4467280 780.1 ns/op 319.20 MB/s Benchmark_____RFanOut_8x1x10-16 4409671 792.9 ns/op 314.05 MB/s Benchmark_____RFanOut_8x1x10-16 4477299 780.0 ns/op 319.22 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 524168 6333 ns/op 366.21 MB/s Benchmark____RFanOut_8x1x100-16 523282 6179 ns/op 375.31 MB/s Benchmark____RFanOut_8x1x100-16 521090 6214 ns/op 373.20 MB/s Benchmark____RFanOut_8x1x100-16 526922 6291 ns/op 368.62 MB/s Benchmark____RFanOut_8x1x100-16 548178 6521 ns/op 355.61 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47276 76255 ns/op 301.87 MB/s Benchmark___RFanOut_8x10x100-16 47587 75574 ns/op 304.59 MB/s Benchmark___RFanOut_8x10x100-16 47077 75740 ns/op 303.92 MB/s Benchmark___RFanOut_8x10x100-16 47644 77751 ns/op 296.06 MB/s Benchmark___RFanOut_8x10x100-16 47542 76593 ns/op 300.54 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5678 622094 ns/op 385.82 MB/s Benchmark__RFanOut_8x10x1000-16 5610 606426 ns/op 395.79 MB/s Benchmark__RFanOut_8x10x1000-16 5968 616635 ns/op 389.24 MB/s Benchmark__RFanOut_8x10x1000-16 5582 629643 ns/op 381.20 MB/s Benchmark__RFanOut_8x10x1000-16 5878 607110 ns/op 395.35 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4971 722344 ns/op 318.43 MB/s Benchmark__RFanOut_8x100x100-16 4903 714782 ns/op 321.80 MB/s Benchmark__RFanOut_8x100x100-16 4905 714730 ns/op 321.83 MB/s Benchmark__RFanOut_8x100x100-16 4920 714037 ns/op 322.14 MB/s Benchmark__RFanOut_8x100x100-16 4896 730680 ns/op 314.80 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 570 6399959 ns/op 375.01 MB/s Benchmark_RFanOut_8x100x1000-16 552 6439330 ns/op 372.71 MB/s Benchmark_RFanOut_8x100x1000-16 550 6449983 ns/op 372.10 MB/s Benchmark_RFanOut_8x100x1000-16 565 6684184 ns/op 359.06 MB/s Benchmark_RFanOut_8x100x1000-16 571 6336554 ns/op 378.76 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 512 6769265 ns/op 369.32 MB/s Benchmark_RFanOut_8x10x10000-16 524 6802315 ns/op 367.52 MB/s Benchmark_RFanOut_8x10x10000-16 513 6806168 ns/op 367.32 MB/s Benchmark_RFanOut_8x10x10000-16 512 6787458 ns/op 368.33 MB/s Benchmark_RFanOut_8x10x10000-16 526 6756291 ns/op 370.03 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3108 1146455 ns/op 9098.51 MB/s Benchmark_RFanOut_1kx10x1000-16 2928 1149235 ns/op 9076.50 MB/s Benchmark_RFanOut_1kx10x1000-16 3147 1147374 ns/op 9091.22 MB/s Benchmark_RFanOut_1kx10x1000-16 3018 1195038 ns/op 8728.62 MB/s Benchmark_RFanOut_1kx10x1000-16 2940 1173574 ns/op 8888.26 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6970737 506.0 ns/op 4106.93 MB/s Benchmark_____FanIn_1kx100x1-16 6874891 506.7 ns/op 4101.11 MB/s Benchmark_____FanIn_1kx100x1-16 6975720 506.6 ns/op 4101.52 MB/s Benchmark_____FanIn_1kx100x1-16 6982418 505.4 ns/op 4111.47 MB/s Benchmark_____FanIn_1kx100x1-16 6955005 505.7 ns/op 4109.05 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2632908 1361 ns/op 6040.25 MB/s Benchmark_____FanIn_4kx100x1-16 2643848 1369 ns/op 6007.29 MB/s Benchmark_____FanIn_4kx100x1-16 2624052 1367 ns/op 6013.56 MB/s Benchmark_____FanIn_4kx100x1-16 2645048 1379 ns/op 5964.36 MB/s Benchmark_____FanIn_4kx100x1-16 2592018 1356 ns/op 6061.69 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1672071 2114 ns/op 7763.44 MB/s Benchmark_____FanIn_8kx100x1-16 1692906 2139 ns/op 7673.97 MB/s Benchmark_____FanIn_8kx100x1-16 1681582 2114 ns/op 7766.02 MB/s Benchmark_____FanIn_8kx100x1-16 1668196 2119 ns/op 7746.16 MB/s Benchmark_____FanIn_8kx100x1-16 1692961 2105 ns/op 7798.15 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 881077 4154 ns/op 7896.29 MB/s Benchmark____FanIn_16kx100x1-16 868683 4138 ns/op 7926.83 MB/s Benchmark____FanIn_16kx100x1-16 858081 4188 ns/op 7832.13 MB/s Benchmark____FanIn_16kx100x1-16 859214 4216 ns/op 7779.74 MB/s Benchmark____FanIn_16kx100x1-16 866379 4136 ns/op 7930.53 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 170713 19830 ns/op 6611.53 MB/s Benchmark____FanIn_64kx100x1-16 167014 19861 ns/op 6601.24 MB/s Benchmark____FanIn_64kx100x1-16 169888 19796 ns/op 6622.73 MB/s Benchmark____FanIn_64kx100x1-16 166039 19890 ns/op 6591.35 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 526587249 vs 655530000 --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1235392160 vs 11575247000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56772->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:56516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56194->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: 290102170 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58100->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:58530->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: 370067070 vs 11326176000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60866->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: 1067859140 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34760->127.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:34246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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: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:34506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34316->127.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 --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 262180000 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:36488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:36012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:36360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:36000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:35994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:36706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:36502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:36026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:36494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:36400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36582->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35972->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5521246 641.7 ns/op 442.55 MB/s Benchmark___BumpPubCount_1x3-16 5563232 638.7 ns/op 444.64 MB/s Benchmark___BumpPubCount_1x3-16 5549870 643.8 ns/op 441.13 MB/s Benchmark___BumpPubCount_1x3-16 5591928 643.0 ns/op 441.71 MB/s Benchmark___BumpPubCount_1x3-16 5612320 642.9 ns/op 441.75 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5304619 676.0 ns/op 420.13 MB/s Benchmark___BumpPubCount_2x3-16 5325328 671.2 ns/op 423.11 MB/s Benchmark___BumpPubCount_2x3-16 5327191 670.9 ns/op 423.34 MB/s Benchmark___BumpPubCount_2x3-16 5263995 674.5 ns/op 421.05 MB/s Benchmark___BumpPubCount_2x3-16 5298996 676.4 ns/op 419.84 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5438916 648.5 ns/op 437.93 MB/s Benchmark___BumpPubCount_5x3-16 5543583 651.2 ns/op 436.10 MB/s Benchmark___BumpPubCount_5x3-16 5369703 649.7 ns/op 437.11 MB/s Benchmark___BumpPubCount_5x3-16 5519091 648.1 ns/op 438.20 MB/s Benchmark___BumpPubCount_5x3-16 5553871 648.8 ns/op 437.75 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5483710 650.3 ns/op 436.69 MB/s Benchmark__BumpPubCount_10x3-16 5514991 648.0 ns/op 438.24 MB/s Benchmark__BumpPubCount_10x3-16 5529385 648.6 ns/op 437.88 MB/s Benchmark__BumpPubCount_10x3-16 5494321 647.9 ns/op 438.33 MB/s Benchmark__BumpPubCount_10x3-16 5534535 648.1 ns/op 438.21 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12622503 265.5 ns/op 3917.11 MB/s Benchmark____GWs_Opt_1kx01x0-16 11593453 273.9 ns/op 3796.99 MB/s Benchmark____GWs_Opt_1kx01x0-16 12560184 271.6 ns/op 3828.66 MB/s Benchmark____GWs_Opt_1kx01x0-16 12524841 278.2 ns/op 3738.00 MB/s Benchmark____GWs_Opt_1kx01x0-16 12873714 268.6 ns/op 3872.14 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10177962 342.8 ns/op 6020.25 MB/s Benchmark____GWs_Opt_2kx01x0-16 11003972 344.9 ns/op 5984.83 MB/s Benchmark____GWs_Opt_2kx01x0-16 10339394 349.5 ns/op 5905.16 MB/s Benchmark____GWs_Opt_2kx01x0-16 10478395 335.7 ns/op 6148.47 MB/s Benchmark____GWs_Opt_2kx01x0-16 10516916 332.1 ns/op 6215.84 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5677060 619.1 ns/op 6641.41 MB/s Benchmark____GWs_Opt_4kx01x0-16 5575452 626.9 ns/op 6559.41 MB/s Benchmark____GWs_Opt_4kx01x0-16 5856907 625.1 ns/op 6578.55 MB/s Benchmark____GWs_Opt_4kx01x0-16 5522349 650.8 ns/op 6318.49 MB/s Benchmark____GWs_Opt_4kx01x0-16 5844757 632.6 ns/op 6499.69 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28556100 122.8 ns/op 8465.93 MB/s Benchmark____GWs_Opt_1kx10x0-16 29800594 112.7 ns/op 9230.48 MB/s Benchmark____GWs_Opt_1kx10x0-16 31344369 117.5 ns/op 8853.16 MB/s Benchmark____GWs_Opt_1kx10x0-16 31372207 112.5 ns/op 9240.82 MB/s Benchmark____GWs_Opt_1kx10x0-16 32246284 118.8 ns/op 8753.77 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24924267 151.6 ns/op 13615.68 MB/s Benchmark____GWs_Opt_2kx10x0-16 24389907 150.8 ns/op 13684.07 MB/s Benchmark____GWs_Opt_2kx10x0-16 24808731 174.9 ns/op 11798.09 MB/s Benchmark____GWs_Opt_2kx10x0-16 21854515 139.0 ns/op 14846.67 MB/s Benchmark____GWs_Opt_2kx10x0-16 20495239 149.7 ns/op 13789.33 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 8865870 340.7 ns/op 12069.41 MB/s Benchmark____GWs_Opt_4kx10x0-16 11619038 306.2 ns/op 13429.95 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:39022->127.0.0.1:33519: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:54578->127.0.0.1:38861: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 12331422 291.4 ns/op 14110.28 MB/s Benchmark____GWs_Opt_4kx10x0-16 10627862 283.1 ns/op 14525.79 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6562238 545.7 ns/op 5726.86 MB/s Benchmark____GWs_Opt_1kx01x1-16 6465898 548.8 ns/op 5694.42 MB/s Benchmark____GWs_Opt_1kx01x1-16 6577057 549.6 ns/op 5686.00 MB/s Benchmark____GWs_Opt_1kx01x1-16 6333300 548.1 ns/op 5701.53 MB/s Benchmark____GWs_Opt_1kx01x1-16 6266492 553.0 ns/op 5651.46 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4737577 749.4 ns/op 8269.08 MB/s Benchmark____GWs_Opt_2kx01x1-16 4680646 785.8 ns/op 7886.67 MB/s Benchmark____GWs_Opt_2kx01x1-16 4748234 759.5 ns/op 8158.94 MB/s Benchmark____GWs_Opt_2kx01x1-16 4850926 871.6 ns/op 7109.73 MB/s Benchmark____GWs_Opt_2kx01x1-16 4740181 768.4 ns/op 8064.45 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2587356 3607 ns/op 3421.55 MB/s Benchmark____GWs_Opt_4kx01x1-16 2578827 1373 ns/op 8990.35 MB/s Benchmark____GWs_Opt_4kx01x1-16 2625802 1375 ns/op 8974.51 MB/s Benchmark____GWs_Opt_4kx01x1-16 2615131 1359 ns/op 9078.19 MB/s Benchmark____GWs_Opt_4kx01x1-16 2597884 1367 ns/op 9029.67 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6079380 559.0 ns/op 5589.89 MB/s Benchmark____GWs_Opt_1kx10x1-16 6179662 562.0 ns/op 5560.44 MB/s Benchmark____GWs_Opt_1kx10x1-16 6287390 561.0 ns/op 5570.70 MB/s Benchmark____GWs_Opt_1kx10x1-16 6214326 564.9 ns/op 5532.00 MB/s Benchmark____GWs_Opt_1kx10x1-16 6167764 561.6 ns/op 5564.59 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4738768 838.2 ns/op 7393.28 MB/s Benchmark____GWs_Opt_2kx10x1-16 4278819 841.5 ns/op 7363.99 MB/s Benchmark____GWs_Opt_2kx10x1-16 4078558 832.2 ns/op 7446.58 MB/s Benchmark____GWs_Opt_2kx10x1-16 4102707 845.8 ns/op 7326.98 MB/s Benchmark____GWs_Opt_2kx10x1-16 4693458 847.8 ns/op 7309.14 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2352684 1523 ns/op 8103.55 MB/s Benchmark____GWs_Opt_4kx10x1-16 2344870 1511 ns/op 8166.03 MB/s Benchmark____GWs_Opt_4kx10x1-16 2338077 1496 ns/op 8247.30 MB/s Benchmark____GWs_Opt_4kx10x1-16 2377082 1506 ns/op 8193.77 MB/s Benchmark____GWs_Opt_4kx10x1-16 2214518 1508 ns/op 8185.77 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12566343 298.6 ns/op 3483.03 MB/s Benchmark____GWs_Int_1kx01x0-16 12885638 287.6 ns/op 3616.13 MB/s Benchmark____GWs_Int_1kx01x0-16 11863783 286.0 ns/op 3636.69 MB/s Benchmark____GWs_Int_1kx01x0-16 12598963 279.4 ns/op 3722.24 MB/s Benchmark____GWs_Int_1kx01x0-16 12849624 281.1 ns/op 3700.30 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10994235 349.5 ns/op 5905.70 MB/s Benchmark____GWs_Int_2kx01x0-16 9855814 353.7 ns/op 5836.05 MB/s Benchmark____GWs_Int_2kx01x0-16 10374364 346.2 ns/op 5962.37 MB/s Benchmark____GWs_Int_2kx01x0-16 10347564 356.7 ns/op 5786.79 MB/s Benchmark____GWs_Int_2kx01x0-16 9668521 355.1 ns/op 5812.82 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5832387 622.7 ns/op 6603.54 MB/s Benchmark____GWs_Int_4kx01x0-16 5738780 635.0 ns/op 6476.09 MB/s Benchmark____GWs_Int_4kx01x0-16 5773858 626.0 ns/op 6569.11 MB/s Benchmark____GWs_Int_4kx01x0-16 5705277 631.2 ns/op 6514.94 MB/s Benchmark____GWs_Int_4kx01x0-16 5857252 627.2 ns/op 6555.90 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31225232 109.9 ns/op 9464.73 MB/s Benchmark____GWs_Int_1kx10x0-16 30989211 129.7 ns/op 8019.22 MB/s Benchmark____GWs_Int_1kx10x0-16 30725504 110.2 ns/op 9440.38 MB/s Benchmark____GWs_Int_1kx10x0-16 32426565 109.0 ns/op 9544.53 MB/s Benchmark____GWs_Int_1kx10x0-16 31649330 111.1 ns/op 9358.28 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24303328 144.5 ns/op 14284.95 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:58568->127.0.0.1:40059: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:53920->127.0.0.1:39091: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 24631928 147.1 ns/op 14027.51 MB/s Benchmark____GWs_Int_2kx10x0-16 24389200 164.0 ns/op 12583.83 MB/s Benchmark____GWs_Int_2kx10x0-16 25787727 138.4 ns/op 14909.87 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11323934 297.2 ns/op 13834.54 MB/s Benchmark____GWs_Int_4kx10x0-16 13225726 287.1 ns/op 14321.65 MB/s Benchmark____GWs_Int_4kx10x0-16 13088173 279.7 ns/op 14701.84 MB/s Benchmark____GWs_Int_4kx10x0-16 12437712 287.0 ns/op 14329.69 MB/s Benchmark____GWs_Int_4kx10x0-16 7777926 408.5 ns/op 10065.33 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6139150 564.9 ns/op 5531.60 MB/s Benchmark____GWs_Int_1kx01x1-16 6363224 559.3 ns/op 5587.46 MB/s Benchmark____GWs_Int_1kx01x1-16 6432750 567.0 ns/op 5511.75 MB/s Benchmark____GWs_Int_1kx01x1-16 6648684 559.2 ns/op 5587.90 MB/s Benchmark____GWs_Int_1kx01x1-16 6533308 549.6 ns/op 5685.49 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4655367 776.2 ns/op 7983.56 MB/s Benchmark____GWs_Int_2kx01x1-16 4748912 771.1 ns/op 8036.26 MB/s Benchmark____GWs_Int_2kx01x1-16 4701025 766.5 ns/op 8084.34 MB/s Benchmark____GWs_Int_2kx01x1-16 4340850 772.8 ns/op 8019.16 MB/s Benchmark____GWs_Int_2kx01x1-16 4677418 836.8 ns/op 7405.53 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2628181 1370 ns/op 9010.92 MB/s Benchmark____GWs_Int_4kx01x1-16 2629996 1395 ns/op 8846.23 MB/s Benchmark____GWs_Int_4kx01x1-16 2640082 1369 ns/op 9015.89 MB/s Benchmark____GWs_Int_4kx01x1-16 2612906 1354 ns/op 9112.31 MB/s Benchmark____GWs_Int_4kx01x1-16 2648029 1357 ns/op 9091.28 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 5940018 557.8 ns/op 5602.54 MB/s Benchmark____GWs_Int_1kx10x1-16 6303036 554.9 ns/op 5631.81 MB/s Benchmark____GWs_Int_1kx10x1-16 6187044 560.7 ns/op 5573.67 MB/s Benchmark____GWs_Int_1kx10x1-16 6438931 567.2 ns/op 5509.91 MB/s Benchmark____GWs_Int_1kx10x1-16 6188776 563.2 ns/op 5548.71 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 3889650 837.9 ns/op 7395.58 MB/s Benchmark____GWs_Int_2kx10x1-16 3944106 845.7 ns/op 7327.56 MB/s Benchmark____GWs_Int_2kx10x1-16 4169860 860.4 ns/op 7202.60 MB/s Benchmark____GWs_Int_2kx10x1-16 4160772 853.3 ns/op 7262.07 MB/s Benchmark____GWs_Int_2kx10x1-16 4103668 847.6 ns/op 7311.53 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2224201 1525 ns/op 8090.56 MB/s Benchmark____GWs_Int_4kx10x1-16 2342798 1541 ns/op 8009.78 MB/s Benchmark____GWs_Int_4kx10x1-16 2345097 1532 ns/op 8054.74 MB/s Benchmark____GWs_Int_4kx10x1-16 2401425 1659 ns/op 7438.27 MB/s Benchmark____GWs_Int_4kx10x1-16 2384842 1537 ns/op 8031.57 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8052439 435.0 ns/op 234.49 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8434724 438.9 ns/op 232.39 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8249376 429.2 ns/op 237.65 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7978461 440.1 ns/op 231.74 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8290912 435.7 ns/op 234.13 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 718066 5128 ns/op 34.52 MB/s Benchmark__GWs_Reqs_1SubEach-16 764618 5460 ns/op 32.42 MB/s Benchmark__GWs_Reqs_1SubEach-16 696452 5347 ns/op 33.10 MB/s Benchmark__GWs_Reqs_1SubEach-16 771956 5378 ns/op 32.91 MB/s Benchmark__GWs_Reqs_1SubEach-16 760258 5267 ns/op 33.61 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2130.777s ❌ Non-zero exit code: 1