> ROOT_DIR=/tmp/go-bench-away-job-2cbc5a57-d2fb-48ee-9f50-cf62ec5e4183-3475669842 > OUTPUT_FILE=/tmp/go-bench-away-job-2cbc5a57-d2fb-48ee-9f50-cf62ec5e4183-3475669842/results.txt > SHA_FILE=/tmp/go-bench-away-job-2cbc5a57-d2fb-48ee-9f50-cf62ec5e4183-3475669842/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-2cbc5a57-d2fb-48ee-9f50-cf62ec5e4183-3475669842/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-2cbc5a57-d2fb-48ee-9f50-cf62ec5e4183-3475669842/source.git SHA of main: c16afd1db4006237eb156ccaa77117f1ecd1835a 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-build2142036991=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-2cbc5a57-d2fb-48ee-9f50-cf62ec5e4183-3475669842/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 49893680 71.74 ns/op 153.34 MB/s Benchmark______Pub0b_Payload-16 47242917 71.80 ns/op 153.21 MB/s Benchmark______Pub0b_Payload-16 47614021 72.04 ns/op 152.69 MB/s Benchmark______Pub0b_Payload-16 47550146 71.74 ns/op 153.33 MB/s Benchmark______Pub0b_Payload-16 47436250 71.80 ns/op 153.20 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 47104351 72.60 ns/op 261.72 MB/s Benchmark______Pub8b_Payload-16 49712896 72.56 ns/op 261.86 MB/s Benchmark______Pub8b_Payload-16 47025975 76.86 ns/op 247.21 MB/s Benchmark______Pub8b_Payload-16 47019708 72.40 ns/op 262.41 MB/s Benchmark______Pub8b_Payload-16 41783940 74.29 ns/op 255.76 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 41380546 77.98 ns/op 564.25 MB/s Benchmark_____Pub32b_Payload-16 44344999 77.56 ns/op 567.32 MB/s Benchmark_____Pub32b_Payload-16 44555328 77.63 ns/op 566.80 MB/s Benchmark_____Pub32b_Payload-16 42177426 78.51 ns/op 560.42 MB/s Benchmark_____Pub32b_Payload-16 44029207 77.17 ns/op 570.15 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38843970 88.33 ns/op 1596.24 MB/s Benchmark____Pub128B_Payload-16 34769871 87.01 ns/op 1620.49 MB/s Benchmark____Pub128B_Payload-16 36312751 86.92 ns/op 1622.18 MB/s Benchmark____Pub128B_Payload-16 39341695 88.34 ns/op 1596.13 MB/s Benchmark____Pub128B_Payload-16 34866104 86.56 ns/op 1629.02 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35701068 95.24 ns/op 2824.52 MB/s Benchmark____Pub256B_Payload-16 31507455 97.43 ns/op 2760.99 MB/s Benchmark____Pub256B_Payload-16 37660478 96.94 ns/op 2774.79 MB/s Benchmark____Pub256B_Payload-16 35748488 97.07 ns/op 2771.10 MB/s Benchmark____Pub256B_Payload-16 31836682 95.75 ns/op 2809.31 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23816199 139.8 ns/op 7426.96 MB/s Benchmark______Pub1K_Payload-16 25554844 139.6 ns/op 7435.24 MB/s Benchmark______Pub1K_Payload-16 23714751 145.0 ns/op 7156.59 MB/s Benchmark______Pub1K_Payload-16 23691870 150.6 ns/op 6890.29 MB/s Benchmark______Pub1K_Payload-16 22178415 139.8 ns/op 7423.25 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5587166 629.6 ns/op 6527.88 MB/s Benchmark______Pub4K_Payload-16 5171301 620.0 ns/op 6629.55 MB/s Benchmark______Pub4K_Payload-16 5511642 617.8 ns/op 6652.44 MB/s Benchmark______Pub4K_Payload-16 5618203 615.5 ns/op 6678.03 MB/s Benchmark______Pub4K_Payload-16 5507343 613.8 ns/op 6696.39 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2719330 1274 ns/op 6443.61 MB/s Benchmark______Pub8K_Payload-16 2735826 1270 ns/op 6462.08 MB/s Benchmark______Pub8K_Payload-16 2788894 1288 ns/op 6368.85 MB/s Benchmark______Pub8K_Payload-16 2798011 1273 ns/op 6447.71 MB/s Benchmark______Pub8K_Payload-16 2770924 1281 ns/op 6406.66 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 659095 5589 ns/op 5865.22 MB/s Benchmark_____Pub32K_Payload-16 621156 5496 ns/op 5964.50 MB/s Benchmark_____Pub32K_Payload-16 599677 5550 ns/op 5906.46 MB/s Benchmark_____Pub32K_Payload-16 652137 5536 ns/op 5921.71 MB/s Benchmark_____Pub32K_Payload-16 647558 5841 ns/op 5612.93 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31844734 95.87 ns/op 114.74 MB/s Benchmark__AuthPub0b_Payload-16 34814683 97.54 ns/op 112.78 MB/s Benchmark__AuthPub0b_Payload-16 35586746 95.82 ns/op 114.80 MB/s Benchmark__AuthPub0b_Payload-16 33855907 95.59 ns/op 115.07 MB/s Benchmark__AuthPub0b_Payload-16 35889600 96.34 ns/op 114.18 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15596523 227.0 ns/op Benchmark_____________PubSub-16 15603283 227.6 ns/op Benchmark_____________PubSub-16 15519692 227.6 ns/op Benchmark_____________PubSub-16 15374772 227.1 ns/op Benchmark_____________PubSub-16 15480254 227.8 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15610551 226.5 ns/op Benchmark_____PubSubTwoConns-16 15896605 225.3 ns/op Benchmark_____PubSubTwoConns-16 15682125 228.2 ns/op Benchmark_____PubSubTwoConns-16 15739822 226.9 ns/op Benchmark_____PubSubTwoConns-16 15529646 225.2 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40010->127.0.0.1:37443: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:55312->127.0.0.1:41123: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58994->127.0.0.1:41581: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:60652->127.0.0.1:33505: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51518->127.0.0.1:39759: 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 14111386 248.9 ns/op Benchmark_____PubTwoQueueSub-16 14359016 248.7 ns/op Benchmark_____PubTwoQueueSub-16 14351475 248.7 ns/op Benchmark_____PubTwoQueueSub-16 14341550 248.0 ns/op Benchmark_____PubTwoQueueSub-16 14346213 249.2 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14308369 249.1 ns/op Benchmark____PubFourQueueSub-16 14253715 248.0 ns/op Benchmark____PubFourQueueSub-16 14357157 249.6 ns/op Benchmark____PubFourQueueSub-16 14098627 249.4 ns/op Benchmark____PubFourQueueSub-16 14177046 249.3 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14223100 248.6 ns/op Benchmark___PubEightQueueSub-16 14271195 248.7 ns/op Benchmark___PubEightQueueSub-16 14184004 249.2 ns/op Benchmark___PubEightQueueSub-16 14133160 249.6 ns/op Benchmark___PubEightQueueSub-16 14318174 249.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23304 156655 ns/op Benchmark_PubSub512kTwoConns-16 23119 156438 ns/op Benchmark_PubSub512kTwoConns-16 22108 164452 ns/op Benchmark_PubSub512kTwoConns-16 21697 162418 ns/op Benchmark_PubSub512kTwoConns-16 22316 160984 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15307192 228.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15342969 227.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15542202 227.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15174091 229.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15192369 229.2 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15064416 229.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15120756 230.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15260325 229.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15107529 229.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15304791 230.5 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10799404 314.0 ns/op Benchmark____RoutedPubSub_0b-16 11143280 312.7 ns/op Benchmark____RoutedPubSub_0b-16 11320896 316.4 ns/op Benchmark____RoutedPubSub_0b-16 11111479 311.9 ns/op Benchmark____RoutedPubSub_0b-16 11229580 318.9 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6756086 535.3 ns/op Benchmark____RoutedPubSub_1K-16 6581397 535.7 ns/op Benchmark____RoutedPubSub_1K-16 6712608 541.6 ns/op Benchmark____RoutedPubSub_1K-16 6522606 605.1 ns/op Benchmark____RoutedPubSub_1K-16 6618482 528.0 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84746 45742 ns/op Benchmark__RoutedPubSub_100K-16 81505 41876 ns/op Benchmark__RoutedPubSub_100K-16 69278 49482 ns/op Benchmark__RoutedPubSub_100K-16 68041 50094 ns/op Benchmark__RoutedPubSub_100K-16 70957 49692 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11339400 316.3 ns/op Benchmark____Routed2QueueSub-16 9552782 314.1 ns/op Benchmark____Routed2QueueSub-16 9472274 328.9 ns/op Benchmark____Routed2QueueSub-16 9674545 320.1 ns/op Benchmark____Routed2QueueSub-16 9757156 320.4 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9542630 321.0 ns/op Benchmark____Routed4QueueSub-16 9516823 324.7 ns/op Benchmark____Routed4QueueSub-16 9474000 327.3 ns/op Benchmark____Routed4QueueSub-16 9506455 328.7 ns/op Benchmark____Routed4QueueSub-16 11261811 317.9 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9191480 344.7 ns/op Benchmark____Routed8QueueSub-16 9346437 333.0 ns/op Benchmark____Routed8QueueSub-16 9259948 329.3 ns/op Benchmark____Routed8QueueSub-16 9217884 328.8 ns/op Benchmark____Routed8QueueSub-16 9270259 329.4 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8889998 352.7 ns/op Benchmark___Routed16QueueSub-16 8735278 346.4 ns/op Benchmark___Routed16QueueSub-16 10317800 350.7 ns/op Benchmark___Routed16QueueSub-16 8849202 345.2 ns/op Benchmark___Routed16QueueSub-16 8661718 355.1 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6441988 558.5 ns/op Benchmark____________RouteCompressOff-16 6522972 548.6 ns/op Benchmark____________RouteCompressOff-16 6349594 549.7 ns/op Benchmark____________RouteCompressOff-16 6377170 553.1 ns/op Benchmark____________RouteCompressOff-16 6527292 581.7 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6500503 548.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6351208 551.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6274905 548.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6286364 552.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6530163 550.8 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6421000 548.0 ns/op Benchmark_________RouteCompressS2Fast-16 6341271 544.1 ns/op Benchmark_________RouteCompressS2Fast-16 6338672 546.4 ns/op Benchmark_________RouteCompressS2Fast-16 6517982 546.5 ns/op Benchmark_________RouteCompressS2Fast-16 6471627 544.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6503930 544.3 ns/op Benchmark_______RouteCompressS2Better-16 6529296 548.2 ns/op Benchmark_______RouteCompressS2Better-16 6488724 548.4 ns/op Benchmark_______RouteCompressS2Better-16 6300060 555.6 ns/op Benchmark_______RouteCompressS2Better-16 6523496 546.4 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6388053 556.0 ns/op Benchmark_________RouteCompressS2Best-16 6547562 550.8 ns/op Benchmark_________RouteCompressS2Best-16 6600963 548.6 ns/op Benchmark_________RouteCompressS2Best-16 6563522 549.4 ns/op Benchmark_________RouteCompressS2Best-16 6483088 548.7 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4685197 766.5 ns/op 324.87 MB/s Benchmark______FanOut_8x1x10-16 4634912 765.8 ns/op 325.15 MB/s Benchmark______FanOut_8x1x10-16 4715252 764.7 ns/op 325.61 MB/s Benchmark______FanOut_8x1x10-16 4683316 773.5 ns/op 321.92 MB/s Benchmark______FanOut_8x1x10-16 4683014 774.9 ns/op 321.33 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 536038 6240 ns/op 371.62 MB/s Benchmark_____FanOut_8x1x100-16 551432 6201 ns/op 374.00 MB/s Benchmark_____FanOut_8x1x100-16 558661 6088 ns/op 380.90 MB/s Benchmark_____FanOut_8x1x100-16 554510 6142 ns/op 377.58 MB/s Benchmark_____FanOut_8x1x100-16 561242 6115 ns/op 379.26 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47542 76142 ns/op 302.32 MB/s Benchmark____FanOut_8x10x100-16 47355 75643 ns/op 304.31 MB/s Benchmark____FanOut_8x10x100-16 47588 75624 ns/op 304.39 MB/s Benchmark____FanOut_8x10x100-16 47420 75355 ns/op 305.47 MB/s Benchmark____FanOut_8x10x100-16 47512 75267 ns/op 305.83 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5847 618552 ns/op 388.03 MB/s Benchmark___FanOut_8x10x1000-16 5842 607140 ns/op 395.33 MB/s Benchmark___FanOut_8x10x1000-16 5749 609494 ns/op 393.80 MB/s Benchmark___FanOut_8x10x1000-16 5859 611562 ns/op 392.47 MB/s Benchmark___FanOut_8x10x1000-16 5390 610431 ns/op 393.20 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5016 737288 ns/op 311.98 MB/s Benchmark___FanOut_8x100x100-16 4912 722448 ns/op 318.39 MB/s Benchmark___FanOut_8x100x100-16 4928 720428 ns/op 319.28 MB/s Benchmark___FanOut_8x100x100-16 4911 721274 ns/op 318.91 MB/s Benchmark___FanOut_8x100x100-16 4891 723635 ns/op 317.87 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 570 6373684 ns/op 376.55 MB/s Benchmark__FanOut_8x100x1000-16 553 6356881 ns/op 377.55 MB/s Benchmark__FanOut_8x100x1000-16 560 6345955 ns/op 378.20 MB/s Benchmark__FanOut_8x100x1000-16 559 6420522 ns/op 373.80 MB/s Benchmark__FanOut_8x100x1000-16 562 6290626 ns/op 381.52 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 517 6858103 ns/op 364.54 MB/s Benchmark__FanOut_8x10x10000-16 530 6963450 ns/op 359.02 MB/s Benchmark__FanOut_8x10x10000-16 501 6737911 ns/op 371.04 MB/s Benchmark__FanOut_8x10x10000-16 530 6950615 ns/op 359.68 MB/s Benchmark__FanOut_8x10x10000-16 531 6773720 ns/op 369.08 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 933 3797084 ns/op 302.87 MB/s Benchmark___FanOut_8x500x100-16 934 3812652 ns/op 301.63 MB/s Benchmark___FanOut_8x500x100-16 937 3819630 ns/op 301.08 MB/s Benchmark___FanOut_8x500x100-16 928 3922317 ns/op 293.20 MB/s Benchmark___FanOut_8x500x100-16 934 3799733 ns/op 302.66 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 355803 9490 ns/op 1542.71 MB/s Benchmark___FanOut_128x1x100-16 362752 9518 ns/op 1538.32 MB/s Benchmark___FanOut_128x1x100-16 367885 9532 ns/op 1536.05 MB/s Benchmark___FanOut_128x1x100-16 359535 9481 ns/op 1544.24 MB/s Benchmark___FanOut_128x1x100-16 354075 9668 ns/op 1514.37 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32406 111208 ns/op 1305.13 MB/s Benchmark__FanOut_128x10x100-16 32122 111254 ns/op 1304.59 MB/s Benchmark__FanOut_128x10x100-16 32274 111307 ns/op 1303.97 MB/s Benchmark__FanOut_128x10x100-16 32341 111427 ns/op 1302.57 MB/s Benchmark__FanOut_128x10x100-16 32317 111101 ns/op 1306.39 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4035 894025 ns/op 1633.22 MB/s Benchmark_FanOut_128x10x1000-16 4023 879589 ns/op 1660.03 MB/s Benchmark_FanOut_128x10x1000-16 3897 882717 ns/op 1654.14 MB/s Benchmark_FanOut_128x10x1000-16 4045 886393 ns/op 1647.28 MB/s Benchmark_FanOut_128x10x1000-16 3900 907244 ns/op 1609.42 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3428 1019962 ns/op 1421.76 MB/s Benchmark_FanOut_128x100x100-16 3440 1021063 ns/op 1420.23 MB/s Benchmark_FanOut_128x100x100-16 3417 1027682 ns/op 1411.08 MB/s Benchmark_FanOut_128x100x100-16 3404 1026329 ns/op 1412.94 MB/s Benchmark_FanOut_128x100x100-16 3465 1019206 ns/op 1422.82 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 386 9421880 ns/op 1549.60 MB/s BenchmarkFanOut_128x100x1000-16 374 9400737 ns/op 1553.08 MB/s BenchmarkFanOut_128x100x1000-16 375 9562218 ns/op 1526.86 MB/s BenchmarkFanOut_128x100x1000-16 376 9349388 ns/op 1561.61 MB/s BenchmarkFanOut_128x100x1000-16 375 9441310 ns/op 1546.41 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 367 9779323 ns/op 1503.19 MB/s BenchmarkFanOut_128x10x10000-16 366 9807916 ns/op 1498.80 MB/s BenchmarkFanOut_128x10x10000-16 366 9770285 ns/op 1504.58 MB/s BenchmarkFanOut_128x10x10000-16 363 9676417 ns/op 1519.17 MB/s BenchmarkFanOut_128x10x10000-16 368 9750367 ns/op 1507.65 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 664 5364779 ns/op 1351.43 MB/s BenchmarkFanOut__128x500x100-16 664 5361400 ns/op 1352.28 MB/s BenchmarkFanOut__128x500x100-16 674 5292737 ns/op 1369.83 MB/s BenchmarkFanOut__128x500x100-16 661 5323927 ns/op 1361.80 MB/s BenchmarkFanOut__128x500x100-16 666 5305279 ns/op 1366.59 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1939 1833122 ns/op 2886.07 MB/s Benchmark_FanOut_512x100x100-16 1921 1853496 ns/op 2854.35 MB/s Benchmark_FanOut_512x100x100-16 1939 1857571 ns/op 2848.09 MB/s Benchmark_FanOut_512x100x100-16 1938 1860672 ns/op 2843.34 MB/s Benchmark_FanOut_512x100x100-16 1900 1846425 ns/op 2865.28 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 212 16663252 ns/op 3180.68 MB/s Benchmark__FanOut_512x100x1k-16 214 16879966 ns/op 3139.85 MB/s Benchmark__FanOut_512x100x1k-16 214 16808239 ns/op 3153.25 MB/s Benchmark__FanOut_512x100x1k-16 214 16762251 ns/op 3161.90 MB/s Benchmark__FanOut_512x100x1k-16 213 16951354 ns/op 3126.62 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3243 1151029 ns/op 9062.36 MB/s Benchmark____FanOut_1kx10x1k-16 3218 1162527 ns/op 8972.73 MB/s Benchmark____FanOut_1kx10x1k-16 3139 1169179 ns/op 8921.68 MB/s Benchmark____FanOut_1kx10x1k-16 3058 1158443 ns/op 9004.36 MB/s Benchmark____FanOut_1kx10x1k-16 3033 1148556 ns/op 9081.87 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2746 1280989 ns/op 8135.15 MB/s Benchmark__FanOut_1kx100x100-16 2796 1272296 ns/op 8190.73 MB/s Benchmark__FanOut_1kx100x100-16 2755 1276197 ns/op 8165.70 MB/s Benchmark__FanOut_1kx100x100-16 2716 1270593 ns/op 8201.71 MB/s Benchmark__FanOut_1kx100x100-16 2710 1280610 ns/op 8137.56 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4421827 780.4 ns/op 319.06 MB/s Benchmark_____RFanOut_8x1x10-16 4482628 781.9 ns/op 318.47 MB/s Benchmark_____RFanOut_8x1x10-16 4468718 827.1 ns/op 301.06 MB/s Benchmark_____RFanOut_8x1x10-16 4446556 772.6 ns/op 322.30 MB/s Benchmark_____RFanOut_8x1x10-16 4527226 780.0 ns/op 319.21 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 510334 6218 ns/op 372.95 MB/s Benchmark____RFanOut_8x1x100-16 515742 6289 ns/op 368.75 MB/s Benchmark____RFanOut_8x1x100-16 524588 6162 ns/op 376.35 MB/s Benchmark____RFanOut_8x1x100-16 556755 6227 ns/op 372.43 MB/s Benchmark____RFanOut_8x1x100-16 523299 6252 ns/op 370.94 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47325 75861 ns/op 303.44 MB/s Benchmark___RFanOut_8x10x100-16 47014 75425 ns/op 305.19 MB/s Benchmark___RFanOut_8x10x100-16 47503 75800 ns/op 303.68 MB/s Benchmark___RFanOut_8x10x100-16 47412 76054 ns/op 302.66 MB/s Benchmark___RFanOut_8x10x100-16 47018 76022 ns/op 302.80 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5762 618051 ns/op 388.35 MB/s Benchmark__RFanOut_8x10x1000-16 5736 610694 ns/op 393.03 MB/s Benchmark__RFanOut_8x10x1000-16 5901 606467 ns/op 395.77 MB/s Benchmark__RFanOut_8x10x1000-16 5666 620329 ns/op 386.92 MB/s Benchmark__RFanOut_8x10x1000-16 5778 623111 ns/op 385.19 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4982 722591 ns/op 318.33 MB/s Benchmark__RFanOut_8x100x100-16 4874 720245 ns/op 319.36 MB/s Benchmark__RFanOut_8x100x100-16 4902 715252 ns/op 321.59 MB/s Benchmark__RFanOut_8x100x100-16 4998 712079 ns/op 323.02 MB/s Benchmark__RFanOut_8x100x100-16 4936 713168 ns/op 322.53 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 549 6268125 ns/op 382.89 MB/s Benchmark_RFanOut_8x100x1000-16 553 6603011 ns/op 363.47 MB/s Benchmark_RFanOut_8x100x1000-16 554 6311768 ns/op 380.25 MB/s Benchmark_RFanOut_8x100x1000-16 560 6405960 ns/op 374.65 MB/s Benchmark_RFanOut_8x100x1000-16 559 6306216 ns/op 380.58 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 516 6863101 ns/op 364.27 MB/s Benchmark_RFanOut_8x10x10000-16 511 7001286 ns/op 357.08 MB/s Benchmark_RFanOut_8x10x10000-16 518 6956952 ns/op 359.36 MB/s Benchmark_RFanOut_8x10x10000-16 523 6890074 ns/op 362.84 MB/s Benchmark_RFanOut_8x10x10000-16 519 6817568 ns/op 366.70 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3091 1174579 ns/op 8880.66 MB/s Benchmark_RFanOut_1kx10x1000-16 2992 1155679 ns/op 9025.90 MB/s Benchmark_RFanOut_1kx10x1000-16 3066 1149207 ns/op 9076.72 MB/s Benchmark_RFanOut_1kx10x1000-16 3079 1173322 ns/op 8890.18 MB/s Benchmark_RFanOut_1kx10x1000-16 2944 1180455 ns/op 8836.45 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6943407 508.9 ns/op 4083.22 MB/s Benchmark_____FanIn_1kx100x1-16 6858364 508.4 ns/op 4087.10 MB/s Benchmark_____FanIn_1kx100x1-16 6914607 506.8 ns/op 4100.26 MB/s Benchmark_____FanIn_1kx100x1-16 6929281 509.4 ns/op 4079.24 MB/s Benchmark_____FanIn_1kx100x1-16 6954265 507.6 ns/op 4093.49 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2619283 1367 ns/op 6013.30 MB/s Benchmark_____FanIn_4kx100x1-16 2596508 1355 ns/op 6069.50 MB/s Benchmark_____FanIn_4kx100x1-16 2609889 1354 ns/op 6071.32 MB/s Benchmark_____FanIn_4kx100x1-16 2690304 1378 ns/op 5967.85 MB/s Benchmark_____FanIn_4kx100x1-16 2599834 1357 ns/op 6056.92 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1691360 2131 ns/op 7700.78 MB/s Benchmark_____FanIn_8kx100x1-16 1723570 2110 ns/op 7778.27 MB/s Benchmark_____FanIn_8kx100x1-16 1691574 2107 ns/op 7788.85 MB/s Benchmark_____FanIn_8kx100x1-16 1678286 2101 ns/op 7812.35 MB/s Benchmark_____FanIn_8kx100x1-16 1679028 2105 ns/op 7799.28 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 857126 4205 ns/op 7800.02 MB/s Benchmark____FanIn_16kx100x1-16 847848 4142 ns/op 7919.38 MB/s Benchmark____FanIn_16kx100x1-16 852249 4167 ns/op 7872.24 MB/s Benchmark____FanIn_16kx100x1-16 870771 4179 ns/op 7849.19 MB/s Benchmark____FanIn_16kx100x1-16 862677 4121 ns/op 7959.77 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 4416567822 vs 10750692000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54698->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55034->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 161128 19721 ns/op 6647.95 MB/s Benchmark____FanIn_64kx100x1-16 159513 20316 ns/op 6453.39 MB/s Benchmark____FanIn_64kx100x1-16 173208 19897 ns/op 6588.98 MB/s Benchmark____FanIn_64kx100x1-16 171255 19869 ns/op 6598.41 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 833208040 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:41940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41444->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1398074850 vs 11535920000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44208->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:43936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44050->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: 984223720 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46344->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: 801877530 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47880->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:48260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47850->127.0.0.1:5222: write: broken pipe bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 367707450 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50114->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5580534 642.1 ns/op 442.31 MB/s Benchmark___BumpPubCount_1x3-16 5590730 643.9 ns/op 441.04 MB/s Benchmark___BumpPubCount_1x3-16 5563687 646.3 ns/op 439.43 MB/s Benchmark___BumpPubCount_1x3-16 5545797 640.8 ns/op 443.19 MB/s Benchmark___BumpPubCount_1x3-16 5594116 645.1 ns/op 440.23 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5240790 676.7 ns/op 419.69 MB/s Benchmark___BumpPubCount_2x3-16 5233582 673.2 ns/op 421.89 MB/s Benchmark___BumpPubCount_2x3-16 5302249 675.9 ns/op 420.21 MB/s Benchmark___BumpPubCount_2x3-16 5299776 673.3 ns/op 421.83 MB/s Benchmark___BumpPubCount_2x3-16 5267028 677.0 ns/op 419.48 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5449166 648.9 ns/op 437.69 MB/s Benchmark___BumpPubCount_5x3-16 5503484 652.3 ns/op 435.40 MB/s Benchmark___BumpPubCount_5x3-16 5553158 650.4 ns/op 436.67 MB/s Benchmark___BumpPubCount_5x3-16 5510966 660.1 ns/op 430.26 MB/s Benchmark___BumpPubCount_5x3-16 5512963 650.7 ns/op 436.46 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5506264 651.8 ns/op 435.73 MB/s Benchmark__BumpPubCount_10x3-16 5492296 653.9 ns/op 434.34 MB/s Benchmark__BumpPubCount_10x3-16 5527551 648.8 ns/op 437.71 MB/s Benchmark__BumpPubCount_10x3-16 5524833 653.9 ns/op 434.29 MB/s Benchmark__BumpPubCount_10x3-16 5503713 652.5 ns/op 435.25 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12843626 280.4 ns/op 3708.65 MB/s Benchmark____GWs_Opt_1kx01x0-16 13040133 268.2 ns/op 3877.15 MB/s Benchmark____GWs_Opt_1kx01x0-16 12531528 273.4 ns/op 3804.09 MB/s Benchmark____GWs_Opt_1kx01x0-16 13191236 275.1 ns/op 3781.05 MB/s Benchmark____GWs_Opt_1kx01x0-16 13013437 271.5 ns/op 3830.95 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10428748 357.8 ns/op 5768.06 MB/s Benchmark____GWs_Opt_2kx01x0-16 10754757 347.5 ns/op 5939.44 MB/s Benchmark____GWs_Opt_2kx01x0-16 10421272 341.0 ns/op 6053.06 MB/s Benchmark____GWs_Opt_2kx01x0-16 9955508 342.2 ns/op 6031.40 MB/s Benchmark____GWs_Opt_2kx01x0-16 11066103 362.0 ns/op 5702.06 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 4991865 618.0 ns/op 6653.73 MB/s Benchmark____GWs_Opt_4kx01x0-16 5663820 643.2 ns/op 6393.04 MB/s Benchmark____GWs_Opt_4kx01x0-16 5628399 612.3 ns/op 6715.57 MB/s Benchmark____GWs_Opt_4kx01x0-16 5688496 891.9 ns/op 4610.38 MB/s Benchmark____GWs_Opt_4kx01x0-16 5673898 637.0 ns/op 6455.69 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30710839 116.1 ns/op 8956.91 MB/s Benchmark____GWs_Opt_1kx10x0-16 31046047 112.0 ns/op 9285.98 MB/s Benchmark____GWs_Opt_1kx10x0-16 31284056 123.5 ns/op 8421.66 MB/s Benchmark____GWs_Opt_1kx10x0-16 30651762 107.6 ns/op 9661.54 MB/s Benchmark____GWs_Opt_1kx10x0-16 31868155 108.7 ns/op 9565.02 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 18430513 164.2 ns/op 12567.48 MB/s Benchmark____GWs_Opt_2kx10x0-16 25945131 141.4 ns/op 14599.78 MB/s Benchmark____GWs_Opt_2kx10x0-16 25773342 145.0 ns/op 14229.79 MB/s Benchmark____GWs_Opt_2kx10x0-16 23631128 162.0 ns/op 12740.33 MB/s Benchmark____GWs_Opt_2kx10x0-16 25225471 144.7 ns/op 14260.18 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11117254 338.3 ns/op 12156.01 MB/s Benchmark____GWs_Opt_4kx10x0-16 11539492 297.9 ns/op 13801.36 MB/s Benchmark____GWs_Opt_4kx10x0-16 12456369 298.9 ns/op 13758.14 MB/s Benchmark____GWs_Opt_4kx10x0-16 13035504 404.6 ns/op 10162.59 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:49392->127.0.0.1:46749: 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:36546->127.0.0.1:38371: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6317662 557.2 ns/op 5608.30 MB/s Benchmark____GWs_Opt_1kx01x1-16 6524514 551.8 ns/op 5662.91 MB/s Benchmark____GWs_Opt_1kx01x1-16 6319482 553.6 ns/op 5645.33 MB/s Benchmark____GWs_Opt_1kx01x1-16 6456818 546.9 ns/op 5713.62 MB/s Benchmark____GWs_Opt_1kx01x1-16 6390399 561.5 ns/op 5565.13 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4536645 768.8 ns/op 8060.13 MB/s Benchmark____GWs_Opt_2kx01x1-16 4598480 770.6 ns/op 8041.83 MB/s Benchmark____GWs_Opt_2kx01x1-16 4617775 765.4 ns/op 8095.94 MB/s Benchmark____GWs_Opt_2kx01x1-16 4578320 820.3 ns/op 7554.51 MB/s Benchmark____GWs_Opt_2kx01x1-16 4726897 769.1 ns/op 8057.79 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2324946 2132 ns/op 5789.03 MB/s Benchmark____GWs_Opt_4kx01x1-16 2617484 1358 ns/op 9087.76 MB/s Benchmark____GWs_Opt_4kx01x1-16 2552089 1589 ns/op 7768.29 MB/s Benchmark____GWs_Opt_4kx01x1-16 2619108 1362 ns/op 9058.30 MB/s Benchmark____GWs_Opt_4kx01x1-16 2572324 1384 ns/op 8916.14 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6224125 556.5 ns/op 5615.88 MB/s Benchmark____GWs_Opt_1kx10x1-16 6090234 561.7 ns/op 5563.58 MB/s Benchmark____GWs_Opt_1kx10x1-16 6127219 558.6 ns/op 5594.31 MB/s Benchmark____GWs_Opt_1kx10x1-16 5985307 567.6 ns/op 5505.39 MB/s Benchmark____GWs_Opt_1kx10x1-16 6179888 552.4 ns/op 5657.32 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4342736 865.9 ns/op 7156.60 MB/s Benchmark____GWs_Opt_2kx10x1-16 4272552 844.6 ns/op 7337.08 MB/s Benchmark____GWs_Opt_2kx10x1-16 3917266 847.0 ns/op 7316.66 MB/s Benchmark____GWs_Opt_2kx10x1-16 4274827 845.3 ns/op 7330.74 MB/s Benchmark____GWs_Opt_2kx10x1-16 4359639 848.8 ns/op 7300.55 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2339276 1609 ns/op 7671.02 MB/s Benchmark____GWs_Opt_4kx10x1-16 2315535 1505 ns/op 8201.00 MB/s Benchmark____GWs_Opt_4kx10x1-16 2145516 1590 ns/op 7762.28 MB/s Benchmark____GWs_Opt_4kx10x1-16 2358588 1507 ns/op 8187.41 MB/s Benchmark____GWs_Opt_4kx10x1-16 2347504 1530 ns/op 8065.09 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12520126 292.2 ns/op 3559.04 MB/s Benchmark____GWs_Int_1kx01x0-16 12825438 282.7 ns/op 3678.27 MB/s Benchmark____GWs_Int_1kx01x0-16 12613713 286.0 ns/op 3636.40 MB/s Benchmark____GWs_Int_1kx01x0-16 12112702 289.5 ns/op 3592.05 MB/s Benchmark____GWs_Int_1kx01x0-16 11818087 297.6 ns/op 3494.42 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9984775 356.8 ns/op 5784.91 MB/s Benchmark____GWs_Int_2kx01x0-16 10081257 345.5 ns/op 5973.77 MB/s Benchmark____GWs_Int_2kx01x0-16 10219950 362.5 ns/op 5693.51 MB/s Benchmark____GWs_Int_2kx01x0-16 10179777 370.3 ns/op 5573.34 MB/s Benchmark____GWs_Int_2kx01x0-16 10259727 349.8 ns/op 5901.19 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5622961 650.8 ns/op 6318.13 MB/s Benchmark____GWs_Int_4kx01x0-16 5431480 651.7 ns/op 6309.90 MB/s Benchmark____GWs_Int_4kx01x0-16 5532145 694.5 ns/op 5921.02 MB/s Benchmark____GWs_Int_4kx01x0-16 5426172 649.0 ns/op 6336.16 MB/s Benchmark____GWs_Int_4kx01x0-16 5275249 653.2 ns/op 6294.88 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 29266224 112.3 ns/op 9264.22 MB/s Benchmark____GWs_Int_1kx10x0-16 30618186 112.0 ns/op 9285.38 MB/s Benchmark____GWs_Int_1kx10x0-16 32034236 110.2 ns/op 9434.90 MB/s Benchmark____GWs_Int_1kx10x0-16 30764484 112.3 ns/op 9261.94 MB/s Benchmark____GWs_Int_1kx10x0-16 32285680 110.1 ns/op 9448.39 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25678969 142.8 ns/op 14456.74 MB/s Benchmark____GWs_Int_2kx10x0-16 25686024 142.9 ns/op 14446.00 MB/s Benchmark____GWs_Int_2kx10x0-16 25953770 143.7 ns/op 14364.64 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:56972->127.0.0.1:44367: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 26138746 153.1 ns/op 13482.80 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13226109 306.5 ns/op 13416.56 MB/s Benchmark____GWs_Int_4kx10x0-16 11634805 328.6 ns/op 12514.56 MB/s Benchmark____GWs_Int_4kx10x0-16 6764061 2216 ns/op 1855.35 MB/s Benchmark____GWs_Int_4kx10x0-16 12948835 338.4 ns/op 12152.13 MB/s Benchmark____GWs_Int_4kx10x0-16 13250534 276.1 ns/op 14893.64 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6311881 558.6 ns/op 5594.43 MB/s Benchmark____GWs_Int_1kx01x1-16 6296510 623.0 ns/op 5016.16 MB/s Benchmark____GWs_Int_1kx01x1-16 6363721 559.5 ns/op 5585.26 MB/s Benchmark____GWs_Int_1kx01x1-16 6306620 567.1 ns/op 5510.37 MB/s Benchmark____GWs_Int_1kx01x1-16 6599503 564.8 ns/op 5532.65 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4551385 775.2 ns/op 7993.67 MB/s Benchmark____GWs_Int_2kx01x1-16 4725276 773.6 ns/op 8011.03 MB/s Benchmark____GWs_Int_2kx01x1-16 4566662 840.7 ns/op 7371.39 MB/s Benchmark____GWs_Int_2kx01x1-16 4664742 761.5 ns/op 8137.56 MB/s Benchmark____GWs_Int_2kx01x1-16 4627014 766.3 ns/op 8086.89 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2375191 1361 ns/op 9067.41 MB/s Benchmark____GWs_Int_4kx01x1-16 2550468 1375 ns/op 8972.12 MB/s Benchmark____GWs_Int_4kx01x1-16 2620338 1403 ns/op 8797.47 MB/s Benchmark____GWs_Int_4kx01x1-16 2622433 1381 ns/op 8937.23 MB/s Benchmark____GWs_Int_4kx01x1-16 2572286 1382 ns/op 8932.80 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6349927 558.8 ns/op 5592.83 MB/s Benchmark____GWs_Int_1kx10x1-16 5986274 563.7 ns/op 5544.07 MB/s Benchmark____GWs_Int_1kx10x1-16 6297268 565.0 ns/op 5530.74 MB/s Benchmark____GWs_Int_1kx10x1-16 6215282 565.8 ns/op 5523.45 MB/s Benchmark____GWs_Int_1kx10x1-16 5381871 557.8 ns/op 5602.23 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4233211 845.8 ns/op 7327.18 MB/s Benchmark____GWs_Int_2kx10x1-16 3996565 835.5 ns/op 7416.79 MB/s Benchmark____GWs_Int_2kx10x1-16 4207363 848.4 ns/op 7303.94 MB/s Benchmark____GWs_Int_2kx10x1-16 4127109 851.4 ns/op 7278.85 MB/s Benchmark____GWs_Int_2kx10x1-16 4179553 852.4 ns/op 7269.76 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2088926 1658 ns/op 7441.51 MB/s Benchmark____GWs_Int_4kx10x1-16 2332539 1527 ns/op 8080.80 MB/s Benchmark____GWs_Int_4kx10x1-16 2368141 1582 ns/op 7802.76 MB/s Benchmark____GWs_Int_4kx10x1-16 2373950 1511 ns/op 8167.58 MB/s Benchmark____GWs_Int_4kx10x1-16 2316028 1479 ns/op 8343.61 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 7979607 437.2 ns/op 233.31 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8025940 440.4 ns/op 231.62 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8213670 443.2 ns/op 230.12 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8185873 436.4 ns/op 233.71 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8178862 439.9 ns/op 231.85 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 626367 5066 ns/op 34.94 MB/s Benchmark__GWs_Reqs_1SubEach-16 769986 5314 ns/op 33.31 MB/s Benchmark__GWs_Reqs_1SubEach-16 734683 5215 ns/op 33.94 MB/s Benchmark__GWs_Reqs_1SubEach-16 688534 5240 ns/op 33.78 MB/s Benchmark__GWs_Reqs_1SubEach-16 731787 5348 ns/op 33.10 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2124.860s ❌ Non-zero exit code: 1