> ROOT_DIR=/tmp/go-bench-away-job-15d0d849-feec-4ca6-a0b2-0bf29062ea9e-1845530527 > OUTPUT_FILE=/tmp/go-bench-away-job-15d0d849-feec-4ca6-a0b2-0bf29062ea9e-1845530527/results.txt > SHA_FILE=/tmp/go-bench-away-job-15d0d849-feec-4ca6-a0b2-0bf29062ea9e-1845530527/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-15d0d849-feec-4ca6-a0b2-0bf29062ea9e-1845530527/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-15d0d849-feec-4ca6-a0b2-0bf29062ea9e-1845530527/source.git SHA of main: 5e645df4c0ce2a0b4e0c985f6a51a34cd4f53367 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-build1456845065=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-15d0d849-feec-4ca6-a0b2-0bf29062ea9e-1845530527/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 46679964 73.19 ns/op 150.30 MB/s Benchmark______Pub0b_Payload-16 46813498 72.72 ns/op 151.26 MB/s Benchmark______Pub0b_Payload-16 46730276 73.02 ns/op 150.65 MB/s Benchmark______Pub0b_Payload-16 46820374 72.64 ns/op 151.44 MB/s Benchmark______Pub0b_Payload-16 46906938 72.94 ns/op 150.80 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46278043 73.37 ns/op 258.97 MB/s Benchmark______Pub8b_Payload-16 49134494 73.14 ns/op 259.79 MB/s Benchmark______Pub8b_Payload-16 49129144 73.33 ns/op 259.10 MB/s Benchmark______Pub8b_Payload-16 46468778 73.41 ns/op 258.82 MB/s Benchmark______Pub8b_Payload-16 46214414 73.43 ns/op 258.74 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43729251 77.89 ns/op 564.88 MB/s Benchmark_____Pub32b_Payload-16 43546874 79.12 ns/op 556.13 MB/s Benchmark_____Pub32b_Payload-16 45991626 78.36 ns/op 561.52 MB/s Benchmark_____Pub32b_Payload-16 42449245 77.94 ns/op 564.57 MB/s Benchmark_____Pub32b_Payload-16 43989733 79.26 ns/op 555.11 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 41055658 87.26 ns/op 1615.78 MB/s Benchmark____Pub128B_Payload-16 38129241 87.96 ns/op 1603.01 MB/s Benchmark____Pub128B_Payload-16 38500992 87.49 ns/op 1611.60 MB/s Benchmark____Pub128B_Payload-16 38140728 88.99 ns/op 1584.49 MB/s Benchmark____Pub128B_Payload-16 39182016 88.55 ns/op 1592.39 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35071330 95.34 ns/op 2821.60 MB/s Benchmark____Pub256B_Payload-16 35670186 95.82 ns/op 2807.43 MB/s Benchmark____Pub256B_Payload-16 32074250 95.77 ns/op 2808.73 MB/s Benchmark____Pub256B_Payload-16 32091555 100.7 ns/op 2671.35 MB/s Benchmark____Pub256B_Payload-16 35750089 95.72 ns/op 2810.36 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25351632 148.2 ns/op 7004.74 MB/s Benchmark______Pub1K_Payload-16 24824590 142.7 ns/op 7272.41 MB/s Benchmark______Pub1K_Payload-16 24243379 138.2 ns/op 7512.91 MB/s Benchmark______Pub1K_Payload-16 23568856 141.3 ns/op 7347.76 MB/s Benchmark______Pub1K_Payload-16 23852818 142.0 ns/op 7310.79 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5454327 630.8 ns/op 6515.23 MB/s Benchmark______Pub4K_Payload-16 5541895 614.4 ns/op 6689.00 MB/s Benchmark______Pub4K_Payload-16 5479426 637.1 ns/op 6450.87 MB/s Benchmark______Pub4K_Payload-16 5621888 624.8 ns/op 6578.52 MB/s Benchmark______Pub4K_Payload-16 5711306 620.2 ns/op 6626.68 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2719042 1276 ns/op 6431.98 MB/s Benchmark______Pub8K_Payload-16 2766658 1284 ns/op 6392.08 MB/s Benchmark______Pub8K_Payload-16 2741299 1293 ns/op 6347.28 MB/s Benchmark______Pub8K_Payload-16 2768047 1283 ns/op 6398.32 MB/s Benchmark______Pub8K_Payload-16 2763816 1273 ns/op 6447.76 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 656943 5550 ns/op 5906.99 MB/s Benchmark_____Pub32K_Payload-16 656469 5392 ns/op 6080.16 MB/s Benchmark_____Pub32K_Payload-16 658046 5583 ns/op 5871.78 MB/s Benchmark_____Pub32K_Payload-16 659118 5379 ns/op 6094.42 MB/s Benchmark_____Pub32K_Payload-16 649328 5375 ns/op 6098.71 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31935792 95.54 ns/op 115.14 MB/s Benchmark__AuthPub0b_Payload-16 36214498 94.85 ns/op 115.97 MB/s Benchmark__AuthPub0b_Payload-16 36061338 94.75 ns/op 116.10 MB/s Benchmark__AuthPub0b_Payload-16 32074327 94.58 ns/op 116.31 MB/s Benchmark__AuthPub0b_Payload-16 36176792 96.90 ns/op 113.52 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15356486 228.5 ns/op Benchmark_____________PubSub-16 15525373 229.2 ns/op Benchmark_____________PubSub-16 15460713 229.3 ns/op Benchmark_____________PubSub-16 15217869 229.6 ns/op Benchmark_____________PubSub-16 15364450 229.6 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15374036 228.6 ns/op Benchmark_____PubSubTwoConns-16 15387158 228.0 ns/op Benchmark_____PubSubTwoConns-16 15487051 228.1 ns/op Benchmark_____PubSubTwoConns-16 15443420 227.8 ns/op Benchmark_____PubSubTwoConns-16 15439827 227.3 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33954->127.0.0.1:35445: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:45690->127.0.0.1:34745: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59806->127.0.0.1:34133: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57694->127.0.0.1:45703: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:36546->127.0.0.1:46819: 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 14070282 250.3 ns/op Benchmark_____PubTwoQueueSub-16 14041442 249.6 ns/op Benchmark_____PubTwoQueueSub-16 14136772 248.6 ns/op Benchmark_____PubTwoQueueSub-16 14245274 249.7 ns/op Benchmark_____PubTwoQueueSub-16 14104646 251.0 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14079708 250.7 ns/op Benchmark____PubFourQueueSub-16 14180343 251.0 ns/op Benchmark____PubFourQueueSub-16 14190572 250.5 ns/op Benchmark____PubFourQueueSub-16 14156007 249.7 ns/op Benchmark____PubFourQueueSub-16 14317533 250.9 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14158300 250.4 ns/op Benchmark___PubEightQueueSub-16 13960002 250.5 ns/op Benchmark___PubEightQueueSub-16 14052445 250.0 ns/op Benchmark___PubEightQueueSub-16 14275065 250.5 ns/op Benchmark___PubEightQueueSub-16 14140855 250.9 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23283 155949 ns/op Benchmark_PubSub512kTwoConns-16 22996 155997 ns/op Benchmark_PubSub512kTwoConns-16 23151 155049 ns/op Benchmark_PubSub512kTwoConns-16 23252 155297 ns/op Benchmark_PubSub512kTwoConns-16 23246 154459 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15081045 231.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15068629 229.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15115408 232.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15078786 230.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15134172 231.9 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15020078 231.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 14997912 231.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15182816 231.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15114571 231.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15135726 231.6 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11463841 309.4 ns/op Benchmark____RoutedPubSub_0b-16 11298706 312.5 ns/op Benchmark____RoutedPubSub_0b-16 11219282 310.9 ns/op Benchmark____RoutedPubSub_0b-16 11543347 314.0 ns/op Benchmark____RoutedPubSub_0b-16 11407658 312.1 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6632050 535.9 ns/op Benchmark____RoutedPubSub_1K-16 6752532 532.6 ns/op Benchmark____RoutedPubSub_1K-16 6764512 529.0 ns/op Benchmark____RoutedPubSub_1K-16 6608482 507.6 ns/op Benchmark____RoutedPubSub_1K-16 6249420 540.0 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85592 40052 ns/op Benchmark__RoutedPubSub_100K-16 84394 43923 ns/op Benchmark__RoutedPubSub_100K-16 79102 42352 ns/op Benchmark__RoutedPubSub_100K-16 86610 43239 ns/op Benchmark__RoutedPubSub_100K-16 81768 43124 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11347494 317.6 ns/op Benchmark____Routed2QueueSub-16 9559719 326.9 ns/op Benchmark____Routed2QueueSub-16 9532428 316.2 ns/op Benchmark____Routed2QueueSub-16 11439040 321.8 ns/op Benchmark____Routed2QueueSub-16 9947966 313.1 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 11367200 327.2 ns/op Benchmark____Routed4QueueSub-16 9513066 324.7 ns/op Benchmark____Routed4QueueSub-16 9446307 324.9 ns/op Benchmark____Routed4QueueSub-16 9216937 330.4 ns/op Benchmark____Routed4QueueSub-16 9307563 322.5 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9206146 330.5 ns/op Benchmark____Routed8QueueSub-16 9342092 329.3 ns/op Benchmark____Routed8QueueSub-16 10803268 332.8 ns/op Benchmark____Routed8QueueSub-16 8941467 337.5 ns/op Benchmark____Routed8QueueSub-16 10822381 334.2 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8704200 346.0 ns/op Benchmark___Routed16QueueSub-16 8802656 344.6 ns/op Benchmark___Routed16QueueSub-16 8932122 344.2 ns/op Benchmark___Routed16QueueSub-16 8764392 354.2 ns/op Benchmark___Routed16QueueSub-16 8731414 348.8 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6556876 546.6 ns/op Benchmark____________RouteCompressOff-16 6447915 548.2 ns/op Benchmark____________RouteCompressOff-16 6477276 546.5 ns/op Benchmark____________RouteCompressOff-16 6602095 549.1 ns/op Benchmark____________RouteCompressOff-16 6524200 545.9 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6324277 542.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 7819272 554.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6318458 556.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6273242 560.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6364776 551.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6521574 559.0 ns/op Benchmark_________RouteCompressS2Fast-16 6211822 560.9 ns/op Benchmark_________RouteCompressS2Fast-16 6318805 552.0 ns/op Benchmark_________RouteCompressS2Fast-16 6456408 555.0 ns/op Benchmark_________RouteCompressS2Fast-16 6229149 541.8 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6405009 544.3 ns/op Benchmark_______RouteCompressS2Better-16 6423837 552.3 ns/op Benchmark_______RouteCompressS2Better-16 6557982 554.3 ns/op Benchmark_______RouteCompressS2Better-16 6253303 554.2 ns/op Benchmark_______RouteCompressS2Better-16 6418200 545.9 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6442549 555.5 ns/op Benchmark_________RouteCompressS2Best-16 6369085 549.3 ns/op Benchmark_________RouteCompressS2Best-16 6397724 551.4 ns/op Benchmark_________RouteCompressS2Best-16 6612363 545.9 ns/op Benchmark_________RouteCompressS2Best-16 6427780 552.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4635613 778.6 ns/op 319.83 MB/s Benchmark______FanOut_8x1x10-16 4649679 773.9 ns/op 321.75 MB/s Benchmark______FanOut_8x1x10-16 4646178 771.1 ns/op 322.92 MB/s Benchmark______FanOut_8x1x10-16 4640294 771.8 ns/op 322.64 MB/s Benchmark______FanOut_8x1x10-16 4614882 780.9 ns/op 318.88 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 525913 6100 ns/op 380.19 MB/s Benchmark_____FanOut_8x1x100-16 549284 6158 ns/op 376.58 MB/s Benchmark_____FanOut_8x1x100-16 569022 6085 ns/op 381.09 MB/s Benchmark_____FanOut_8x1x100-16 561108 6140 ns/op 377.66 MB/s Benchmark_____FanOut_8x1x100-16 578396 6201 ns/op 373.99 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48134 75185 ns/op 306.16 MB/s Benchmark____FanOut_8x10x100-16 48152 75851 ns/op 303.47 MB/s Benchmark____FanOut_8x10x100-16 47698 74387 ns/op 309.45 MB/s Benchmark____FanOut_8x10x100-16 48481 74399 ns/op 309.40 MB/s Benchmark____FanOut_8x10x100-16 47634 74488 ns/op 309.03 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5979 597731 ns/op 401.55 MB/s Benchmark___FanOut_8x10x1000-16 5708 599957 ns/op 400.06 MB/s Benchmark___FanOut_8x10x1000-16 5966 598327 ns/op 401.15 MB/s Benchmark___FanOut_8x10x1000-16 5551 598857 ns/op 400.80 MB/s Benchmark___FanOut_8x10x1000-16 5738 593543 ns/op 404.38 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4938 705241 ns/op 326.16 MB/s Benchmark___FanOut_8x100x100-16 5013 706972 ns/op 325.36 MB/s Benchmark___FanOut_8x100x100-16 5061 705709 ns/op 325.94 MB/s Benchmark___FanOut_8x100x100-16 5035 704131 ns/op 326.67 MB/s Benchmark___FanOut_8x100x100-16 5097 705878 ns/op 325.86 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 556 6337706 ns/op 378.69 MB/s Benchmark__FanOut_8x100x1000-16 582 6193588 ns/op 387.50 MB/s Benchmark__FanOut_8x100x1000-16 579 6144602 ns/op 390.59 MB/s Benchmark__FanOut_8x100x1000-16 576 6284632 ns/op 381.89 MB/s Benchmark__FanOut_8x100x1000-16 577 6245296 ns/op 384.29 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 519 6704669 ns/op 372.88 MB/s Benchmark__FanOut_8x10x10000-16 547 6604440 ns/op 378.54 MB/s Benchmark__FanOut_8x10x10000-16 528 6802583 ns/op 367.51 MB/s Benchmark__FanOut_8x10x10000-16 528 6767024 ns/op 369.44 MB/s Benchmark__FanOut_8x10x10000-16 529 6978659 ns/op 358.24 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 948 3747909 ns/op 306.84 MB/s Benchmark___FanOut_8x500x100-16 950 3811749 ns/op 301.70 MB/s Benchmark___FanOut_8x500x100-16 937 3750974 ns/op 306.59 MB/s Benchmark___FanOut_8x500x100-16 955 3747330 ns/op 306.89 MB/s Benchmark___FanOut_8x500x100-16 943 3741160 ns/op 307.40 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 367389 9405 ns/op 1556.76 MB/s Benchmark___FanOut_128x1x100-16 364578 9579 ns/op 1528.44 MB/s Benchmark___FanOut_128x1x100-16 356725 9683 ns/op 1512.03 MB/s Benchmark___FanOut_128x1x100-16 360710 9476 ns/op 1545.11 MB/s Benchmark___FanOut_128x1x100-16 359737 9429 ns/op 1552.80 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32654 110620 ns/op 1312.07 MB/s Benchmark__FanOut_128x10x100-16 32449 110750 ns/op 1310.53 MB/s Benchmark__FanOut_128x10x100-16 32433 111119 ns/op 1306.18 MB/s Benchmark__FanOut_128x10x100-16 32514 110647 ns/op 1311.75 MB/s Benchmark__FanOut_128x10x100-16 32680 110316 ns/op 1315.68 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4132 873985 ns/op 1670.67 MB/s Benchmark_FanOut_128x10x1000-16 3901 877368 ns/op 1664.23 MB/s Benchmark_FanOut_128x10x1000-16 3927 872611 ns/op 1673.30 MB/s Benchmark_FanOut_128x10x1000-16 4248 867124 ns/op 1683.89 MB/s Benchmark_FanOut_128x10x1000-16 4072 870480 ns/op 1677.40 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3500 1015070 ns/op 1428.61 MB/s Benchmark_FanOut_128x100x100-16 3466 1008536 ns/op 1437.87 MB/s Benchmark_FanOut_128x100x100-16 3512 1006724 ns/op 1440.46 MB/s Benchmark_FanOut_128x100x100-16 3495 1008320 ns/op 1438.17 MB/s Benchmark_FanOut_128x100x100-16 3486 1007270 ns/op 1439.67 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 381 9233827 ns/op 1581.16 MB/s BenchmarkFanOut_128x100x1000-16 388 9282146 ns/op 1572.93 MB/s BenchmarkFanOut_128x100x1000-16 390 9303533 ns/op 1569.31 MB/s BenchmarkFanOut_128x100x1000-16 385 9426735 ns/op 1548.80 MB/s BenchmarkFanOut_128x100x1000-16 380 9233754 ns/op 1581.17 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 374 9594704 ns/op 1532.11 MB/s BenchmarkFanOut_128x10x10000-16 373 9556401 ns/op 1538.25 MB/s BenchmarkFanOut_128x10x10000-16 375 9686282 ns/op 1517.62 MB/s BenchmarkFanOut_128x10x10000-16 372 9589526 ns/op 1532.94 MB/s BenchmarkFanOut_128x10x10000-16 373 9570268 ns/op 1536.02 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 679 5254634 ns/op 1379.76 MB/s BenchmarkFanOut__128x500x100-16 674 5250857 ns/op 1380.75 MB/s BenchmarkFanOut__128x500x100-16 668 5286689 ns/op 1371.40 MB/s BenchmarkFanOut__128x500x100-16 688 5247134 ns/op 1381.73 MB/s BenchmarkFanOut__128x500x100-16 681 5239415 ns/op 1383.77 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1927 1836905 ns/op 2880.13 MB/s Benchmark_FanOut_512x100x100-16 1960 1827749 ns/op 2894.56 MB/s Benchmark_FanOut_512x100x100-16 1938 1840877 ns/op 2873.92 MB/s Benchmark_FanOut_512x100x100-16 1927 1837526 ns/op 2879.16 MB/s Benchmark_FanOut_512x100x100-16 1958 1830821 ns/op 2889.70 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 216 16710743 ns/op 3171.64 MB/s Benchmark__FanOut_512x100x1k-16 217 16542497 ns/op 3203.90 MB/s Benchmark__FanOut_512x100x1k-16 217 16778180 ns/op 3158.90 MB/s Benchmark__FanOut_512x100x1k-16 217 16513426 ns/op 3209.54 MB/s Benchmark__FanOut_512x100x1k-16 214 16623980 ns/op 3188.20 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3234 1139012 ns/op 9157.97 MB/s Benchmark____FanOut_1kx10x1k-16 2980 1133440 ns/op 9202.99 MB/s Benchmark____FanOut_1kx10x1k-16 3058 1152380 ns/op 9051.73 MB/s Benchmark____FanOut_1kx10x1k-16 3217 1147013 ns/op 9094.09 MB/s Benchmark____FanOut_1kx10x1k-16 2864 1163664 ns/op 8963.96 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2780 1252366 ns/op 8321.08 MB/s Benchmark__FanOut_1kx100x100-16 2736 1259819 ns/op 8271.85 MB/s Benchmark__FanOut_1kx100x100-16 2799 1249255 ns/op 8341.80 MB/s Benchmark__FanOut_1kx100x100-16 2757 1257003 ns/op 8290.38 MB/s Benchmark__FanOut_1kx100x100-16 2817 1263485 ns/op 8247.86 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4422999 782.5 ns/op 318.20 MB/s Benchmark_____RFanOut_8x1x10-16 4557513 769.6 ns/op 323.53 MB/s Benchmark_____RFanOut_8x1x10-16 4439703 792.3 ns/op 314.26 MB/s Benchmark_____RFanOut_8x1x10-16 4589691 790.9 ns/op 314.81 MB/s Benchmark_____RFanOut_8x1x10-16 4470426 771.7 ns/op 322.64 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 509324 6439 ns/op 360.14 MB/s Benchmark____RFanOut_8x1x100-16 517418 6332 ns/op 366.26 MB/s Benchmark____RFanOut_8x1x100-16 593815 6066 ns/op 382.28 MB/s Benchmark____RFanOut_8x1x100-16 516903 6301 ns/op 368.05 MB/s Benchmark____RFanOut_8x1x100-16 523878 6040 ns/op 383.92 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47970 74796 ns/op 307.76 MB/s Benchmark___RFanOut_8x10x100-16 48134 74491 ns/op 309.02 MB/s Benchmark___RFanOut_8x10x100-16 48072 76552 ns/op 300.70 MB/s Benchmark___RFanOut_8x10x100-16 48148 74571 ns/op 308.69 MB/s Benchmark___RFanOut_8x10x100-16 48211 74736 ns/op 308.00 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5772 603211 ns/op 397.90 MB/s Benchmark__RFanOut_8x10x1000-16 5924 604073 ns/op 397.33 MB/s Benchmark__RFanOut_8x10x1000-16 5701 600040 ns/op 400.01 MB/s Benchmark__RFanOut_8x10x1000-16 5674 597254 ns/op 401.87 MB/s Benchmark__RFanOut_8x10x1000-16 5790 596460 ns/op 402.41 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4930 706039 ns/op 325.79 MB/s Benchmark__RFanOut_8x100x100-16 5004 707433 ns/op 325.15 MB/s Benchmark__RFanOut_8x100x100-16 4960 706020 ns/op 325.80 MB/s Benchmark__RFanOut_8x100x100-16 4995 709386 ns/op 324.25 MB/s Benchmark__RFanOut_8x100x100-16 4874 708821 ns/op 324.51 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 580 6188285 ns/op 387.83 MB/s Benchmark_RFanOut_8x100x1000-16 571 6149839 ns/op 390.26 MB/s Benchmark_RFanOut_8x100x1000-16 582 6169814 ns/op 388.99 MB/s Benchmark_RFanOut_8x100x1000-16 573 6245349 ns/op 384.29 MB/s Benchmark_RFanOut_8x100x1000-16 579 6154453 ns/op 389.96 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 536 6668046 ns/op 374.93 MB/s Benchmark_RFanOut_8x10x10000-16 526 6676484 ns/op 374.45 MB/s Benchmark_RFanOut_8x10x10000-16 534 6778472 ns/op 368.82 MB/s Benchmark_RFanOut_8x10x10000-16 529 6805726 ns/op 367.34 MB/s Benchmark_RFanOut_8x10x10000-16 532 6626641 ns/op 377.27 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3082 1153677 ns/op 9041.56 MB/s Benchmark_RFanOut_1kx10x1000-16 3099 1179008 ns/op 8847.30 MB/s Benchmark_RFanOut_1kx10x1000-16 3051 1143744 ns/op 9120.08 MB/s Benchmark_RFanOut_1kx10x1000-16 3034 1175100 ns/op 8876.73 MB/s Benchmark_RFanOut_1kx10x1000-16 2995 1163354 ns/op 8966.35 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6960724 503.5 ns/op 4127.18 MB/s Benchmark_____FanIn_1kx100x1-16 7037919 502.0 ns/op 4139.60 MB/s Benchmark_____FanIn_1kx100x1-16 6947391 503.3 ns/op 4129.13 MB/s Benchmark_____FanIn_1kx100x1-16 6832309 506.0 ns/op 4107.02 MB/s Benchmark_____FanIn_1kx100x1-16 6926698 502.1 ns/op 4139.02 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2617909 1351 ns/op 6086.73 MB/s Benchmark_____FanIn_4kx100x1-16 2602593 1370 ns/op 6003.26 MB/s Benchmark_____FanIn_4kx100x1-16 2644383 1357 ns/op 6057.18 MB/s Benchmark_____FanIn_4kx100x1-16 2634758 1366 ns/op 6018.38 MB/s Benchmark_____FanIn_4kx100x1-16 2629178 1369 ns/op 6006.44 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1703334 2100 ns/op 7817.22 MB/s Benchmark_____FanIn_8kx100x1-16 1717710 2105 ns/op 7797.55 MB/s Benchmark_____FanIn_8kx100x1-16 1707928 2110 ns/op 7779.80 MB/s Benchmark_____FanIn_8kx100x1-16 1702239 2085 ns/op 7870.58 MB/s Benchmark_____FanIn_8kx100x1-16 1720224 2122 ns/op 7736.17 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 864512 4147 ns/op 7909.49 MB/s Benchmark____FanIn_16kx100x1-16 859430 4132 ns/op 7937.73 MB/s Benchmark____FanIn_16kx100x1-16 869298 4116 ns/op 7969.53 MB/s Benchmark____FanIn_16kx100x1-16 868231 4111 ns/op 7978.85 MB/s Benchmark____FanIn_16kx100x1-16 875769 4161 ns/op 7882.68 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 169200 20027 ns/op 6546.31 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 8693245542 vs 11130899400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44710->127.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:44288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44538->127.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:44650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44090->127.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:44406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44324->127.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:44856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44772->127.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:44872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44150->127.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:44356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44120->127.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:44036->127.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: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:44264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44354->127.0.0.1:5222: write: connection reset by peer 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:44272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44558->127.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:44408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44202->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:44666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44604->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 165078 19909 ns/op 6585.21 MB/s Benchmark____FanIn_64kx100x1-16 167736 19849 ns/op 6605.00 MB/s Benchmark____FanIn_64kx100x1-16 167842 19931 ns/op 6577.76 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 334672770 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37150->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: 477954140 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39074->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: 605111440 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41390->127.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:41180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40644->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: 371509060 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42578->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 195193010 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44782->127.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:44784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44280->127.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:44712->127.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: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:44296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44546->127.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:44672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44364->127.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: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:44852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45066->127.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:45054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44334->127.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: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: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:44646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44974->127.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:44874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44566->127.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:44846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44266->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5542934 640.0 ns/op 443.77 MB/s Benchmark___BumpPubCount_1x3-16 5600233 641.9 ns/op 442.42 MB/s Benchmark___BumpPubCount_1x3-16 5545348 638.8 ns/op 444.59 MB/s Benchmark___BumpPubCount_1x3-16 5549642 638.5 ns/op 444.80 MB/s Benchmark___BumpPubCount_1x3-16 5583600 641.7 ns/op 442.59 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5325115 670.0 ns/op 423.90 MB/s Benchmark___BumpPubCount_2x3-16 5319148 667.8 ns/op 425.27 MB/s Benchmark___BumpPubCount_2x3-16 5309408 667.8 ns/op 425.27 MB/s Benchmark___BumpPubCount_2x3-16 5305593 666.8 ns/op 425.89 MB/s Benchmark___BumpPubCount_2x3-16 5364342 671.0 ns/op 423.28 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5567976 645.4 ns/op 440.06 MB/s Benchmark___BumpPubCount_5x3-16 5402317 639.7 ns/op 443.95 MB/s Benchmark___BumpPubCount_5x3-16 5602216 663.3 ns/op 428.16 MB/s Benchmark___BumpPubCount_5x3-16 5613789 641.7 ns/op 442.58 MB/s Benchmark___BumpPubCount_5x3-16 5584060 641.4 ns/op 442.80 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5575627 645.7 ns/op 439.81 MB/s Benchmark__BumpPubCount_10x3-16 5561109 643.7 ns/op 441.17 MB/s Benchmark__BumpPubCount_10x3-16 5595672 642.7 ns/op 441.88 MB/s Benchmark__BumpPubCount_10x3-16 5564214 644.2 ns/op 440.82 MB/s Benchmark__BumpPubCount_10x3-16 5552697 645.1 ns/op 440.27 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12299934 274.9 ns/op 3783.73 MB/s Benchmark____GWs_Opt_1kx01x0-16 12377514 276.3 ns/op 3763.69 MB/s Benchmark____GWs_Opt_1kx01x0-16 12568528 275.7 ns/op 3771.91 MB/s Benchmark____GWs_Opt_1kx01x0-16 13317177 280.8 ns/op 3703.82 MB/s Benchmark____GWs_Opt_1kx01x0-16 12310130 284.3 ns/op 3658.52 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9699027 338.5 ns/op 6097.51 MB/s Benchmark____GWs_Opt_2kx01x0-16 10453336 352.9 ns/op 5849.29 MB/s Benchmark____GWs_Opt_2kx01x0-16 10780494 347.6 ns/op 5937.66 MB/s Benchmark____GWs_Opt_2kx01x0-16 9721776 347.8 ns/op 5935.15 MB/s Benchmark____GWs_Opt_2kx01x0-16 10070226 332.4 ns/op 6208.52 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5619861 637.2 ns/op 6453.10 MB/s Benchmark____GWs_Opt_4kx01x0-16 5380324 639.9 ns/op 6426.11 MB/s Benchmark____GWs_Opt_4kx01x0-16 5393905 641.4 ns/op 6410.61 MB/s Benchmark____GWs_Opt_4kx01x0-16 5647455 643.6 ns/op 6388.57 MB/s Benchmark____GWs_Opt_4kx01x0-16 5523976 676.6 ns/op 6077.01 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29039908 126.4 ns/op 8226.60 MB/s Benchmark____GWs_Opt_1kx10x0-16 33752557 114.9 ns/op 9054.20 MB/s Benchmark____GWs_Opt_1kx10x0-16 28135329 110.6 ns/op 9399.93 MB/s Benchmark____GWs_Opt_1kx10x0-16 31486717 109.7 ns/op 9478.93 MB/s Benchmark____GWs_Opt_1kx10x0-16 31417525 117.8 ns/op 8827.54 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23968472 146.5 ns/op 14084.54 MB/s Benchmark____GWs_Opt_2kx10x0-16 24794166 141.9 ns/op 14550.25 MB/s Benchmark____GWs_Opt_2kx10x0-16 21621460 152.0 ns/op 13579.24 MB/s Benchmark____GWs_Opt_2kx10x0-16 23974521 146.8 ns/op 14055.60 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:37284->127.0.0.1:39941: 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:59494->127.0.0.1:35011: use of closed network connection --- FAIL: Benchmark____GWs_Opt_2kx10x0-16 Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12391815 288.3 ns/op 14264.29 MB/s Benchmark____GWs_Opt_4kx10x0-16 12608908 284.6 ns/op 14450.68 MB/s Benchmark____GWs_Opt_4kx10x0-16 12383851 311.7 ns/op 13194.19 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:34590->127.0.0.1:35897: 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:38416->127.0.0.1:38305: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 10221964 307.5 ns/op 13373.68 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6516572 547.3 ns/op 5710.29 MB/s Benchmark____GWs_Opt_1kx01x1-16 6562852 549.4 ns/op 5687.78 MB/s Benchmark____GWs_Opt_1kx01x1-16 6607088 546.9 ns/op 5714.35 MB/s Benchmark____GWs_Opt_1kx01x1-16 6383623 550.9 ns/op 5672.50 MB/s Benchmark____GWs_Opt_1kx01x1-16 6477530 550.8 ns/op 5673.29 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4737660 768.9 ns/op 8059.92 MB/s Benchmark____GWs_Opt_2kx01x1-16 4627322 763.9 ns/op 8112.38 MB/s Benchmark____GWs_Opt_2kx01x1-16 4753905 760.6 ns/op 8147.93 MB/s Benchmark____GWs_Opt_2kx01x1-16 4375014 762.1 ns/op 8131.92 MB/s Benchmark____GWs_Opt_2kx01x1-16 4480166 752.4 ns/op 8236.01 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2604391 1381 ns/op 8939.15 MB/s Benchmark____GWs_Opt_4kx01x1-16 2588676 1399 ns/op 8818.39 MB/s Benchmark____GWs_Opt_4kx01x1-16 2269184 1395 ns/op 8845.06 MB/s Benchmark____GWs_Opt_4kx01x1-16 2594232 1371 ns/op 8998.20 MB/s Benchmark____GWs_Opt_4kx01x1-16 2642901 1389 ns/op 8887.58 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6562897 558.9 ns/op 5590.96 MB/s Benchmark____GWs_Opt_1kx10x1-16 6504399 556.0 ns/op 5620.87 MB/s Benchmark____GWs_Opt_1kx10x1-16 6230556 552.5 ns/op 5655.74 MB/s Benchmark____GWs_Opt_1kx10x1-16 6121383 544.2 ns/op 5742.00 MB/s Benchmark____GWs_Opt_1kx10x1-16 6075716 544.2 ns/op 5742.57 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4112628 839.6 ns/op 7381.30 MB/s Benchmark____GWs_Opt_2kx10x1-16 4001215 843.6 ns/op 7346.18 MB/s Benchmark____GWs_Opt_2kx10x1-16 4176273 840.3 ns/op 7374.34 MB/s Benchmark____GWs_Opt_2kx10x1-16 4431886 835.6 ns/op 7416.01 MB/s Benchmark____GWs_Opt_2kx10x1-16 4252812 840.6 ns/op 7372.49 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2342785 1519 ns/op 8124.60 MB/s Benchmark____GWs_Opt_4kx10x1-16 2332485 1569 ns/op 7867.19 MB/s Benchmark____GWs_Opt_4kx10x1-16 2352616 1537 ns/op 8026.76 MB/s Benchmark____GWs_Opt_4kx10x1-16 2128322 1507 ns/op 8191.29 MB/s Benchmark____GWs_Opt_4kx10x1-16 2345438 1564 ns/op 7891.83 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12240877 292.3 ns/op 3558.57 MB/s Benchmark____GWs_Int_1kx01x0-16 12563595 287.9 ns/op 3612.38 MB/s Benchmark____GWs_Int_1kx01x0-16 12740126 280.0 ns/op 3714.84 MB/s Benchmark____GWs_Int_1kx01x0-16 12326224 278.0 ns/op 3741.26 MB/s Benchmark____GWs_Int_1kx01x0-16 12673408 286.2 ns/op 3634.00 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9019316 348.7 ns/op 5918.40 MB/s Benchmark____GWs_Int_2kx01x0-16 10466248 357.6 ns/op 5771.08 MB/s Benchmark____GWs_Int_2kx01x0-16 9973550 355.7 ns/op 5802.36 MB/s Benchmark____GWs_Int_2kx01x0-16 10381720 366.0 ns/op 5638.83 MB/s Benchmark____GWs_Int_2kx01x0-16 10605920 350.5 ns/op 5888.92 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5373417 650.7 ns/op 6319.43 MB/s Benchmark____GWs_Int_4kx01x0-16 5490895 654.2 ns/op 6285.65 MB/s Benchmark____GWs_Int_4kx01x0-16 5548288 656.5 ns/op 6263.70 MB/s Benchmark____GWs_Int_4kx01x0-16 5482519 666.4 ns/op 6170.19 MB/s Benchmark____GWs_Int_4kx01x0-16 5454930 645.4 ns/op 6370.88 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31641895 111.3 ns/op 9344.97 MB/s Benchmark____GWs_Int_1kx10x0-16 31207533 116.4 ns/op 8937.33 MB/s Benchmark____GWs_Int_1kx10x0-16 31081734 113.8 ns/op 9141.10 MB/s Benchmark____GWs_Int_1kx10x0-16 31650590 110.0 ns/op 9455.77 MB/s Benchmark____GWs_Int_1kx10x0-16 30749835 121.7 ns/op 8546.09 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25819848 136.7 ns/op 15093.61 MB/s Benchmark____GWs_Int_2kx10x0-16 24805676 152.5 ns/op 13533.66 MB/s Benchmark____GWs_Int_2kx10x0-16 25641290 157.9 ns/op 13069.62 MB/s Benchmark____GWs_Int_2kx10x0-16 25494060 140.6 ns/op 14683.20 MB/s Benchmark____GWs_Int_2kx10x0-16 24337220 143.9 ns/op 14343.22 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13000491 322.3 ns/op 12759.67 MB/s Benchmark____GWs_Int_4kx10x0-16 12201190 318.9 ns/op 12895.14 MB/s Benchmark____GWs_Int_4kx10x0-16 11759809 298.0 ns/op 13796.60 MB/s Benchmark____GWs_Int_4kx10x0-16 12066042 302.9 ns/op 13573.56 MB/s Benchmark____GWs_Int_4kx10x0-16 13260709 343.7 ns/op 11965.33 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6471796 554.5 ns/op 5635.59 MB/s Benchmark____GWs_Int_1kx01x1-16 6647456 555.5 ns/op 5625.07 MB/s Benchmark____GWs_Int_1kx01x1-16 6761346 556.4 ns/op 5616.80 MB/s Benchmark____GWs_Int_1kx01x1-16 6720564 556.7 ns/op 5613.73 MB/s Benchmark____GWs_Int_1kx01x1-16 6477265 565.9 ns/op 5522.05 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4479063 763.4 ns/op 8117.43 MB/s Benchmark____GWs_Int_2kx01x1-16 4598800 753.5 ns/op 8224.33 MB/s Benchmark____GWs_Int_2kx01x1-16 4768778 775.9 ns/op 7986.95 MB/s Benchmark____GWs_Int_2kx01x1-16 4669143 932.1 ns/op 6648.41 MB/s Benchmark____GWs_Int_2kx01x1-16 4761758 755.5 ns/op 8202.86 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2631402 1388 ns/op 8893.45 MB/s Benchmark____GWs_Int_4kx01x1-16 2653725 1389 ns/op 8884.20 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 17027846 vs 10906909288 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:51720->127.0.0.1:41719: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx01x1-16 Benchmark____GWs_Int_4kx01x1-16 2667375 1375 ns/op 8978.36 MB/s Benchmark____GWs_Int_4kx01x1-16 2582126 1391 ns/op 8871.06 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6500455 624.1 ns/op 5006.82 MB/s Benchmark____GWs_Int_1kx10x1-16 6515498 564.2 ns/op 5538.37 MB/s Benchmark____GWs_Int_1kx10x1-16 6541437 551.6 ns/op 5665.21 MB/s Benchmark____GWs_Int_1kx10x1-16 6072680 556.4 ns/op 5616.61 MB/s Benchmark____GWs_Int_1kx10x1-16 6575122 553.5 ns/op 5645.82 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4353609 914.8 ns/op 6774.26 MB/s Benchmark____GWs_Int_2kx10x1-16 4047444 834.3 ns/op 7428.01 MB/s Benchmark____GWs_Int_2kx10x1-16 4296795 843.7 ns/op 7345.00 MB/s Benchmark____GWs_Int_2kx10x1-16 4138557 835.1 ns/op 7420.53 MB/s Benchmark____GWs_Int_2kx10x1-16 4272882 847.8 ns/op 7309.22 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2260866 1527 ns/op 8081.95 MB/s Benchmark____GWs_Int_4kx10x1-16 2379117 1693 ns/op 7287.31 MB/s Benchmark____GWs_Int_4kx10x1-16 2310908 1516 ns/op 8139.79 MB/s Benchmark____GWs_Int_4kx10x1-16 2413849 1529 ns/op 8071.99 MB/s Benchmark____GWs_Int_4kx10x1-16 2499907 1522 ns/op 8106.20 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 7837418 430.5 ns/op 236.93 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8217925 426.2 ns/op 239.34 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8202414 434.6 ns/op 234.72 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8178789 429.6 ns/op 237.44 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8376795 431.9 ns/op 236.19 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 718383 5132 ns/op 34.49 MB/s Benchmark__GWs_Reqs_1SubEach-16 724281 5342 ns/op 33.14 MB/s Benchmark__GWs_Reqs_1SubEach-16 751303 5445 ns/op 32.51 MB/s Benchmark__GWs_Reqs_1SubEach-16 742110 5310 ns/op 33.34 MB/s Benchmark__GWs_Reqs_1SubEach-16 752359 5443 ns/op 32.52 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2155.147s ❌ Non-zero exit code: 1