> ROOT_DIR=/tmp/go-bench-away-job-6a41131d-8a0f-47a5-9558-b1a82b6f9696-3652685818 > OUTPUT_FILE=/tmp/go-bench-away-job-6a41131d-8a0f-47a5-9558-b1a82b6f9696-3652685818/results.txt > SHA_FILE=/tmp/go-bench-away-job-6a41131d-8a0f-47a5-9558-b1a82b6f9696-3652685818/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-6a41131d-8a0f-47a5-9558-b1a82b6f9696-3652685818/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-6a41131d-8a0f-47a5-9558-b1a82b6f9696-3652685818/source.git SHA of main: f7d78f68993c74af5674fa49898481e3ee6a15a1 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-build3022930837=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-6a41131d-8a0f-47a5-9558-b1a82b6f9696-3652685818/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 39666291 76.51 ns/op 143.77 MB/s Benchmark______Pub0b_Payload-16 46098326 74.40 ns/op 147.85 MB/s Benchmark______Pub0b_Payload-16 45891355 76.83 ns/op 143.18 MB/s Benchmark______Pub0b_Payload-16 44520554 74.06 ns/op 148.52 MB/s Benchmark______Pub0b_Payload-16 46043449 74.05 ns/op 148.56 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 48256983 75.06 ns/op 253.14 MB/s Benchmark______Pub8b_Payload-16 47293988 74.72 ns/op 254.29 MB/s Benchmark______Pub8b_Payload-16 45749298 74.76 ns/op 254.14 MB/s Benchmark______Pub8b_Payload-16 45753351 78.68 ns/op 241.48 MB/s Benchmark______Pub8b_Payload-16 45782192 74.67 ns/op 254.45 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 42689269 80.04 ns/op 549.73 MB/s Benchmark_____Pub32b_Payload-16 43105142 79.25 ns/op 555.17 MB/s Benchmark_____Pub32b_Payload-16 45468176 79.94 ns/op 550.43 MB/s Benchmark_____Pub32b_Payload-16 43172476 79.32 ns/op 554.71 MB/s Benchmark_____Pub32b_Payload-16 42575263 79.37 ns/op 554.36 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 34030166 89.42 ns/op 1576.82 MB/s Benchmark____Pub128B_Payload-16 38060745 89.52 ns/op 1575.14 MB/s Benchmark____Pub128B_Payload-16 38650218 89.07 ns/op 1582.96 MB/s Benchmark____Pub128B_Payload-16 33875152 90.24 ns/op 1562.45 MB/s Benchmark____Pub128B_Payload-16 37281424 89.13 ns/op 1582.00 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35676930 97.03 ns/op 2772.41 MB/s Benchmark____Pub256B_Payload-16 35127579 96.16 ns/op 2797.30 MB/s Benchmark____Pub256B_Payload-16 31742106 102.9 ns/op 2615.29 MB/s Benchmark____Pub256B_Payload-16 30915064 98.38 ns/op 2734.39 MB/s Benchmark____Pub256B_Payload-16 35284444 99.42 ns/op 2705.77 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24972412 145.2 ns/op 7147.31 MB/s Benchmark______Pub1K_Payload-16 22700607 144.4 ns/op 7185.89 MB/s Benchmark______Pub1K_Payload-16 23992275 141.8 ns/op 7320.48 MB/s Benchmark______Pub1K_Payload-16 23949982 141.7 ns/op 7325.18 MB/s Benchmark______Pub1K_Payload-16 24787166 144.6 ns/op 7178.42 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5846995 618.4 ns/op 6645.88 MB/s Benchmark______Pub4K_Payload-16 5560419 625.3 ns/op 6573.20 MB/s Benchmark______Pub4K_Payload-16 5793000 622.7 ns/op 6600.72 MB/s Benchmark______Pub4K_Payload-16 5741305 622.5 ns/op 6602.91 MB/s Benchmark______Pub4K_Payload-16 5631415 623.0 ns/op 6597.31 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2734939 1280 ns/op 6413.20 MB/s Benchmark______Pub8K_Payload-16 2796063 1273 ns/op 6444.45 MB/s Benchmark______Pub8K_Payload-16 2792090 1279 ns/op 6413.71 MB/s Benchmark______Pub8K_Payload-16 2781584 1271 ns/op 6458.32 MB/s Benchmark______Pub8K_Payload-16 2684389 1275 ns/op 6436.28 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 648022 5537 ns/op 5920.67 MB/s Benchmark_____Pub32K_Payload-16 636858 5407 ns/op 6062.63 MB/s Benchmark_____Pub32K_Payload-16 657501 5341 ns/op 6137.72 MB/s Benchmark_____Pub32K_Payload-16 671920 5430 ns/op 6037.83 MB/s Benchmark_____Pub32K_Payload-16 506670 6698 ns/op 4894.15 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31801353 95.94 ns/op 114.66 MB/s Benchmark__AuthPub0b_Payload-16 31552315 95.55 ns/op 115.12 MB/s Benchmark__AuthPub0b_Payload-16 35782762 96.07 ns/op 114.50 MB/s Benchmark__AuthPub0b_Payload-16 35793692 95.83 ns/op 114.78 MB/s Benchmark__AuthPub0b_Payload-16 35853228 95.53 ns/op 115.15 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15519026 227.9 ns/op Benchmark_____________PubSub-16 15620235 227.3 ns/op Benchmark_____________PubSub-16 15571508 227.2 ns/op Benchmark_____________PubSub-16 15521701 226.4 ns/op Benchmark_____________PubSub-16 15596823 226.9 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15393718 225.8 ns/op Benchmark_____PubSubTwoConns-16 15511982 226.1 ns/op Benchmark_____PubSubTwoConns-16 15357259 225.6 ns/op Benchmark_____PubSubTwoConns-16 15174327 226.1 ns/op Benchmark_____PubSubTwoConns-16 15470618 225.6 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33232->127.0.0.1:35651: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46600->127.0.0.1:35189: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46360->127.0.0.1:45435: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:45710->127.0.0.1:36181: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49210->127.0.0.1:38847: 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 14309920 246.4 ns/op Benchmark_____PubTwoQueueSub-16 14278060 244.5 ns/op Benchmark_____PubTwoQueueSub-16 14470340 245.2 ns/op Benchmark_____PubTwoQueueSub-16 14402662 243.7 ns/op Benchmark_____PubTwoQueueSub-16 14346381 245.5 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14424920 244.9 ns/op Benchmark____PubFourQueueSub-16 14243918 246.0 ns/op Benchmark____PubFourQueueSub-16 14471082 244.7 ns/op Benchmark____PubFourQueueSub-16 14481104 245.6 ns/op Benchmark____PubFourQueueSub-16 14540204 245.6 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14411380 245.5 ns/op Benchmark___PubEightQueueSub-16 14285452 245.6 ns/op Benchmark___PubEightQueueSub-16 14516955 245.3 ns/op Benchmark___PubEightQueueSub-16 14211946 243.7 ns/op Benchmark___PubEightQueueSub-16 14375217 245.7 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23018 155667 ns/op Benchmark_PubSub512kTwoConns-16 22977 155605 ns/op Benchmark_PubSub512kTwoConns-16 22779 156528 ns/op Benchmark_PubSub512kTwoConns-16 22622 158835 ns/op Benchmark_PubSub512kTwoConns-16 22298 159521 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15298153 231.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15282226 230.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15149306 231.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15122972 231.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15039608 231.5 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15138108 233.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 14934776 231.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15153016 231.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15157658 232.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 14963466 231.0 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11392303 319.1 ns/op Benchmark____RoutedPubSub_0b-16 10835144 320.6 ns/op Benchmark____RoutedPubSub_0b-16 10951611 318.0 ns/op Benchmark____RoutedPubSub_0b-16 11041680 321.4 ns/op Benchmark____RoutedPubSub_0b-16 11111964 315.7 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6651375 537.4 ns/op Benchmark____RoutedPubSub_1K-16 6591316 540.2 ns/op Benchmark____RoutedPubSub_1K-16 6407484 537.5 ns/op Benchmark____RoutedPubSub_1K-16 6544285 531.5 ns/op Benchmark____RoutedPubSub_1K-16 6537607 537.3 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84330 41886 ns/op Benchmark__RoutedPubSub_100K-16 85474 43891 ns/op Benchmark__RoutedPubSub_100K-16 81471 43929 ns/op Benchmark__RoutedPubSub_100K-16 84805 44329 ns/op Benchmark__RoutedPubSub_100K-16 82256 43801 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9515625 321.0 ns/op Benchmark____Routed2QueueSub-16 9824412 321.3 ns/op Benchmark____Routed2QueueSub-16 9871987 324.6 ns/op Benchmark____Routed2QueueSub-16 9778180 329.0 ns/op Benchmark____Routed2QueueSub-16 9502177 326.3 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9494590 326.0 ns/op Benchmark____Routed4QueueSub-16 9357838 326.4 ns/op Benchmark____Routed4QueueSub-16 9308337 331.4 ns/op Benchmark____Routed4QueueSub-16 9535142 324.3 ns/op Benchmark____Routed4QueueSub-16 9662052 327.9 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9125241 333.6 ns/op Benchmark____Routed8QueueSub-16 9340597 336.1 ns/op Benchmark____Routed8QueueSub-16 9146862 330.3 ns/op Benchmark____Routed8QueueSub-16 9207207 327.3 ns/op Benchmark____Routed8QueueSub-16 9248724 339.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 9044578 349.5 ns/op Benchmark___Routed16QueueSub-16 10291094 348.4 ns/op Benchmark___Routed16QueueSub-16 10351215 348.3 ns/op Benchmark___Routed16QueueSub-16 8853439 350.6 ns/op Benchmark___Routed16QueueSub-16 8951602 353.1 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6489943 564.7 ns/op Benchmark____________RouteCompressOff-16 6465452 560.1 ns/op Benchmark____________RouteCompressOff-16 6461234 556.4 ns/op Benchmark____________RouteCompressOff-16 6257564 552.7 ns/op Benchmark____________RouteCompressOff-16 6372634 566.0 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6347540 557.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6426100 561.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6420574 557.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6426882 557.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6326906 553.9 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6306846 557.1 ns/op Benchmark_________RouteCompressS2Fast-16 6403819 551.8 ns/op Benchmark_________RouteCompressS2Fast-16 6360493 550.8 ns/op Benchmark_________RouteCompressS2Fast-16 6288211 562.7 ns/op Benchmark_________RouteCompressS2Fast-16 6220005 558.7 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6437289 551.0 ns/op Benchmark_______RouteCompressS2Better-16 6298095 560.2 ns/op Benchmark_______RouteCompressS2Better-16 6310459 553.1 ns/op Benchmark_______RouteCompressS2Better-16 6407930 564.1 ns/op Benchmark_______RouteCompressS2Better-16 6480793 550.7 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6541353 566.3 ns/op Benchmark_________RouteCompressS2Best-16 6330183 554.7 ns/op Benchmark_________RouteCompressS2Best-16 6178604 561.1 ns/op Benchmark_________RouteCompressS2Best-16 6416341 556.2 ns/op Benchmark_________RouteCompressS2Best-16 6422482 556.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4686126 775.7 ns/op 321.01 MB/s Benchmark______FanOut_8x1x10-16 4652192 776.7 ns/op 320.59 MB/s Benchmark______FanOut_8x1x10-16 4666354 768.3 ns/op 324.09 MB/s Benchmark______FanOut_8x1x10-16 4672548 767.1 ns/op 324.59 MB/s Benchmark______FanOut_8x1x10-16 4643998 768.4 ns/op 324.07 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 552049 6294 ns/op 368.47 MB/s Benchmark_____FanOut_8x1x100-16 520322 6182 ns/op 375.15 MB/s Benchmark_____FanOut_8x1x100-16 532885 6200 ns/op 374.04 MB/s Benchmark_____FanOut_8x1x100-16 557257 6232 ns/op 372.09 MB/s Benchmark_____FanOut_8x1x100-16 554560 6154 ns/op 376.86 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47865 75338 ns/op 305.54 MB/s Benchmark____FanOut_8x10x100-16 46770 75115 ns/op 306.45 MB/s Benchmark____FanOut_8x10x100-16 47776 75952 ns/op 303.07 MB/s Benchmark____FanOut_8x10x100-16 47776 75267 ns/op 305.83 MB/s Benchmark____FanOut_8x10x100-16 47557 75194 ns/op 306.13 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5833 607844 ns/op 394.87 MB/s Benchmark___FanOut_8x10x1000-16 5916 605651 ns/op 396.30 MB/s Benchmark___FanOut_8x10x1000-16 5863 605832 ns/op 396.18 MB/s Benchmark___FanOut_8x10x1000-16 5974 610941 ns/op 392.87 MB/s Benchmark___FanOut_8x10x1000-16 5818 612698 ns/op 391.74 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5028 714692 ns/op 321.84 MB/s Benchmark___FanOut_8x100x100-16 4784 715398 ns/op 321.53 MB/s Benchmark___FanOut_8x100x100-16 5000 721389 ns/op 318.86 MB/s Benchmark___FanOut_8x100x100-16 4725 716297 ns/op 321.12 MB/s Benchmark___FanOut_8x100x100-16 4884 715046 ns/op 321.68 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 577 6226605 ns/op 385.45 MB/s Benchmark__FanOut_8x100x1000-16 568 6333198 ns/op 378.96 MB/s Benchmark__FanOut_8x100x1000-16 565 6210755 ns/op 386.43 MB/s Benchmark__FanOut_8x100x1000-16 568 6447411 ns/op 372.25 MB/s Benchmark__FanOut_8x100x1000-16 568 6248247 ns/op 384.11 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 524 6855571 ns/op 364.67 MB/s Benchmark__FanOut_8x10x10000-16 525 6883956 ns/op 363.17 MB/s Benchmark__FanOut_8x10x10000-16 522 6719243 ns/op 372.07 MB/s Benchmark__FanOut_8x10x10000-16 525 6807255 ns/op 367.26 MB/s Benchmark__FanOut_8x10x10000-16 525 6863300 ns/op 364.26 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 936 3799347 ns/op 302.69 MB/s Benchmark___FanOut_8x500x100-16 944 3786346 ns/op 303.73 MB/s Benchmark___FanOut_8x500x100-16 942 3805721 ns/op 302.18 MB/s Benchmark___FanOut_8x500x100-16 936 3796637 ns/op 302.90 MB/s Benchmark___FanOut_8x500x100-16 934 3784878 ns/op 303.85 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 366566 9624 ns/op 1521.23 MB/s Benchmark___FanOut_128x1x100-16 354466 9492 ns/op 1542.47 MB/s Benchmark___FanOut_128x1x100-16 356899 9573 ns/op 1529.44 MB/s Benchmark___FanOut_128x1x100-16 360234 9547 ns/op 1533.51 MB/s Benchmark___FanOut_128x1x100-16 356352 9585 ns/op 1527.44 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32136 111179 ns/op 1305.47 MB/s Benchmark__FanOut_128x10x100-16 31908 111570 ns/op 1300.89 MB/s Benchmark__FanOut_128x10x100-16 32388 112377 ns/op 1291.55 MB/s Benchmark__FanOut_128x10x100-16 32064 111878 ns/op 1297.32 MB/s Benchmark__FanOut_128x10x100-16 32109 111353 ns/op 1303.43 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4074 883358 ns/op 1652.94 MB/s Benchmark_FanOut_128x10x1000-16 3987 885292 ns/op 1649.33 MB/s Benchmark_FanOut_128x10x1000-16 4066 890829 ns/op 1639.08 MB/s Benchmark_FanOut_128x10x1000-16 3964 890368 ns/op 1639.93 MB/s Benchmark_FanOut_128x10x1000-16 4053 890659 ns/op 1639.39 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3490 1015754 ns/op 1427.65 MB/s Benchmark_FanOut_128x100x100-16 3471 1020246 ns/op 1421.36 MB/s Benchmark_FanOut_128x100x100-16 3474 1017765 ns/op 1424.83 MB/s Benchmark_FanOut_128x100x100-16 3511 1021152 ns/op 1420.10 MB/s Benchmark_FanOut_128x100x100-16 3476 1018609 ns/op 1423.65 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 385 9416071 ns/op 1550.56 MB/s BenchmarkFanOut_128x100x1000-16 376 9361826 ns/op 1559.54 MB/s BenchmarkFanOut_128x100x1000-16 384 9410536 ns/op 1551.47 MB/s BenchmarkFanOut_128x100x1000-16 378 9313226 ns/op 1567.68 MB/s BenchmarkFanOut_128x100x1000-16 381 9434100 ns/op 1547.59 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 370 9738040 ns/op 1509.56 MB/s BenchmarkFanOut_128x10x10000-16 378 9729160 ns/op 1510.94 MB/s BenchmarkFanOut_128x10x10000-16 369 9726297 ns/op 1511.38 MB/s BenchmarkFanOut_128x10x10000-16 374 9653880 ns/op 1522.72 MB/s BenchmarkFanOut_128x10x10000-16 366 9737716 ns/op 1509.61 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 676 5330893 ns/op 1360.02 MB/s BenchmarkFanOut__128x500x100-16 672 5312568 ns/op 1364.71 MB/s BenchmarkFanOut__128x500x100-16 664 5306454 ns/op 1366.29 MB/s BenchmarkFanOut__128x500x100-16 668 5300131 ns/op 1367.92 MB/s BenchmarkFanOut__128x500x100-16 666 5322824 ns/op 1362.09 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1906 1853864 ns/op 2853.78 MB/s Benchmark_FanOut_512x100x100-16 1922 1869294 ns/op 2830.23 MB/s Benchmark_FanOut_512x100x100-16 1927 1855376 ns/op 2851.46 MB/s Benchmark_FanOut_512x100x100-16 1909 1850015 ns/op 2859.72 MB/s Benchmark_FanOut_512x100x100-16 1898 1855127 ns/op 2851.84 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16821599 ns/op 3150.74 MB/s Benchmark__FanOut_512x100x1k-16 213 16494829 ns/op 3213.16 MB/s Benchmark__FanOut_512x100x1k-16 216 16542616 ns/op 3203.88 MB/s Benchmark__FanOut_512x100x1k-16 214 16718025 ns/op 3170.26 MB/s Benchmark__FanOut_512x100x1k-16 216 16687833 ns/op 3176.00 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3144 1145039 ns/op 9109.76 MB/s Benchmark____FanOut_1kx10x1k-16 2815 1147996 ns/op 9086.30 MB/s Benchmark____FanOut_1kx10x1k-16 3126 1153985 ns/op 9039.14 MB/s Benchmark____FanOut_1kx10x1k-16 3058 1147361 ns/op 9091.33 MB/s Benchmark____FanOut_1kx10x1k-16 2842 1148567 ns/op 9081.79 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2756 1254282 ns/op 8308.37 MB/s Benchmark__FanOut_1kx100x100-16 2767 1263656 ns/op 8246.74 MB/s Benchmark__FanOut_1kx100x100-16 2768 1264146 ns/op 8243.54 MB/s Benchmark__FanOut_1kx100x100-16 2792 1261423 ns/op 8261.33 MB/s Benchmark__FanOut_1kx100x100-16 2811 1263400 ns/op 8248.41 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4586265 763.9 ns/op 325.97 MB/s Benchmark_____RFanOut_8x1x10-16 4534323 765.8 ns/op 325.16 MB/s Benchmark_____RFanOut_8x1x10-16 4534378 774.6 ns/op 321.47 MB/s Benchmark_____RFanOut_8x1x10-16 4548544 773.0 ns/op 322.10 MB/s Benchmark_____RFanOut_8x1x10-16 4563115 764.1 ns/op 325.87 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 524673 6217 ns/op 372.99 MB/s Benchmark____RFanOut_8x1x100-16 569365 6168 ns/op 376.00 MB/s Benchmark____RFanOut_8x1x100-16 545623 6249 ns/op 371.08 MB/s Benchmark____RFanOut_8x1x100-16 539610 6676 ns/op 347.34 MB/s Benchmark____RFanOut_8x1x100-16 532314 6229 ns/op 372.29 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47587 75146 ns/op 306.32 MB/s Benchmark___RFanOut_8x10x100-16 46398 76865 ns/op 299.47 MB/s Benchmark___RFanOut_8x10x100-16 47684 75805 ns/op 303.66 MB/s Benchmark___RFanOut_8x10x100-16 45800 75664 ns/op 304.22 MB/s Benchmark___RFanOut_8x10x100-16 46123 75053 ns/op 306.70 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5593 626181 ns/op 383.31 MB/s Benchmark__RFanOut_8x10x1000-16 5660 617037 ns/op 388.99 MB/s Benchmark__RFanOut_8x10x1000-16 5980 616083 ns/op 389.59 MB/s Benchmark__RFanOut_8x10x1000-16 5742 602881 ns/op 398.12 MB/s Benchmark__RFanOut_8x10x1000-16 5878 609431 ns/op 393.84 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5010 713023 ns/op 322.60 MB/s Benchmark__RFanOut_8x100x100-16 4994 708002 ns/op 324.88 MB/s Benchmark__RFanOut_8x100x100-16 4964 720473 ns/op 319.26 MB/s Benchmark__RFanOut_8x100x100-16 4908 708949 ns/op 324.45 MB/s Benchmark__RFanOut_8x100x100-16 4998 716595 ns/op 320.99 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 562 6466522 ns/op 371.15 MB/s Benchmark_RFanOut_8x100x1000-16 574 6208017 ns/op 386.60 MB/s Benchmark_RFanOut_8x100x1000-16 574 6539528 ns/op 367.00 MB/s Benchmark_RFanOut_8x100x1000-16 566 6330270 ns/op 379.13 MB/s Benchmark_RFanOut_8x100x1000-16 550 6457193 ns/op 371.68 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 512 6763842 ns/op 369.62 MB/s Benchmark_RFanOut_8x10x10000-16 532 6746285 ns/op 370.58 MB/s Benchmark_RFanOut_8x10x10000-16 530 6815369 ns/op 366.82 MB/s Benchmark_RFanOut_8x10x10000-16 526 6769225 ns/op 369.32 MB/s Benchmark_RFanOut_8x10x10000-16 519 6920731 ns/op 361.24 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2797 1153578 ns/op 9042.33 MB/s Benchmark_RFanOut_1kx10x1000-16 3006 1136606 ns/op 9177.35 MB/s Benchmark_RFanOut_1kx10x1000-16 3152 1145932 ns/op 9102.66 MB/s Benchmark_RFanOut_1kx10x1000-16 3015 1159693 ns/op 8994.65 MB/s Benchmark_RFanOut_1kx10x1000-16 2918 1148858 ns/op 9079.48 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6968854 509.3 ns/op 4080.21 MB/s Benchmark_____FanIn_1kx100x1-16 6889320 509.9 ns/op 4075.69 MB/s Benchmark_____FanIn_1kx100x1-16 6902893 508.8 ns/op 4084.15 MB/s Benchmark_____FanIn_1kx100x1-16 6863992 508.1 ns/op 4089.78 MB/s Benchmark_____FanIn_1kx100x1-16 6837369 508.5 ns/op 4086.89 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2613181 1379 ns/op 5961.67 MB/s Benchmark_____FanIn_4kx100x1-16 2628207 1363 ns/op 6031.77 MB/s Benchmark_____FanIn_4kx100x1-16 2622676 1354 ns/op 6071.39 MB/s Benchmark_____FanIn_4kx100x1-16 2636065 1374 ns/op 5983.68 MB/s Benchmark_____FanIn_4kx100x1-16 2595336 1381 ns/op 5955.28 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1706234 2190 ns/op 7496.64 MB/s Benchmark_____FanIn_8kx100x1-16 1689295 2095 ns/op 7835.89 MB/s Benchmark_____FanIn_8kx100x1-16 1673500 2110 ns/op 7778.28 MB/s Benchmark_____FanIn_8kx100x1-16 1689078 2144 ns/op 7657.14 MB/s Benchmark_____FanIn_8kx100x1-16 1682766 2158 ns/op 7605.10 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 872031 4132 ns/op 7938.76 MB/s Benchmark____FanIn_16kx100x1-16 870949 4155 ns/op 7894.60 MB/s Benchmark____FanIn_16kx100x1-16 858207 4176 ns/op 7854.15 MB/s Benchmark____FanIn_16kx100x1-16 846800 4146 ns/op 7910.56 MB/s Benchmark____FanIn_16kx100x1-16 869828 4147 ns/op 7910.17 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 155290 20294 ns/op 6460.28 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1188410337 vs 10737581400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49132->127.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:49154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48770->127.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:48740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49186->127.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:49600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49598->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:49360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49110->127.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:49058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49286->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 160801 19757 ns/op 6635.84 MB/s Benchmark____FanIn_64kx100x1-16 170562 20084 ns/op 6527.86 MB/s Benchmark____FanIn_64kx100x1-16 172927 20061 ns/op 6535.33 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 405985730 vs 11837427000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53916->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: 1018176030 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55158->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: 309503490 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57530->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: 590298270 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59106->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: 701331500 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32806->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60826->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5555712 642.5 ns/op 442.00 MB/s Benchmark___BumpPubCount_1x3-16 5599537 648.9 ns/op 437.68 MB/s Benchmark___BumpPubCount_1x3-16 5567676 635.8 ns/op 446.69 MB/s Benchmark___BumpPubCount_1x3-16 5543256 641.8 ns/op 442.52 MB/s Benchmark___BumpPubCount_1x3-16 5559735 644.2 ns/op 440.89 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5244948 676.1 ns/op 420.03 MB/s Benchmark___BumpPubCount_2x3-16 5272065 674.2 ns/op 421.21 MB/s Benchmark___BumpPubCount_2x3-16 5324985 671.9 ns/op 422.67 MB/s Benchmark___BumpPubCount_2x3-16 5314850 673.9 ns/op 421.40 MB/s Benchmark___BumpPubCount_2x3-16 5293797 676.2 ns/op 420.02 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5368272 650.5 ns/op 436.56 MB/s Benchmark___BumpPubCount_5x3-16 5485156 651.9 ns/op 435.64 MB/s Benchmark___BumpPubCount_5x3-16 5550910 648.5 ns/op 437.95 MB/s Benchmark___BumpPubCount_5x3-16 5501550 649.6 ns/op 437.21 MB/s Benchmark___BumpPubCount_5x3-16 5535385 648.4 ns/op 438.00 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5499726 651.8 ns/op 435.72 MB/s Benchmark__BumpPubCount_10x3-16 5498860 651.4 ns/op 436.00 MB/s Benchmark__BumpPubCount_10x3-16 5521140 652.9 ns/op 434.95 MB/s Benchmark__BumpPubCount_10x3-16 5539051 652.3 ns/op 435.38 MB/s Benchmark__BumpPubCount_10x3-16 5450110 652.9 ns/op 434.99 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12135602 272.6 ns/op 3815.70 MB/s Benchmark____GWs_Opt_1kx01x0-16 12197746 279.3 ns/op 3723.01 MB/s Benchmark____GWs_Opt_1kx01x0-16 12843147 276.8 ns/op 3757.15 MB/s Benchmark____GWs_Opt_1kx01x0-16 12953979 277.5 ns/op 3747.69 MB/s Benchmark____GWs_Opt_1kx01x0-16 12103762 279.7 ns/op 3717.61 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 8965587 345.8 ns/op 5968.96 MB/s Benchmark____GWs_Opt_2kx01x0-16 10570501 330.1 ns/op 6252.50 MB/s Benchmark____GWs_Opt_2kx01x0-16 10166982 340.8 ns/op 6057.15 MB/s Benchmark____GWs_Opt_2kx01x0-16 9941401 328.8 ns/op 6277.80 MB/s Benchmark____GWs_Opt_2kx01x0-16 10038399 330.3 ns/op 6248.78 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5683383 602.1 ns/op 6829.53 MB/s Benchmark____GWs_Opt_4kx01x0-16 5906840 623.4 ns/op 6595.60 MB/s Benchmark____GWs_Opt_4kx01x0-16 5661962 649.7 ns/op 6329.14 MB/s Benchmark____GWs_Opt_4kx01x0-16 5794332 637.4 ns/op 6450.75 MB/s Benchmark____GWs_Opt_4kx01x0-16 5776477 753.7 ns/op 5455.93 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29506131 111.3 ns/op 9347.06 MB/s Benchmark____GWs_Opt_1kx10x0-16 30657757 109.3 ns/op 9512.38 MB/s Benchmark____GWs_Opt_1kx10x0-16 33638755 111.5 ns/op 9328.68 MB/s Benchmark____GWs_Opt_1kx10x0-16 31420028 116.0 ns/op 8964.21 MB/s Benchmark____GWs_Opt_1kx10x0-16 31301262 110.0 ns/op 9453.05 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24006346 153.3 ns/op 13467.35 MB/s Benchmark____GWs_Opt_2kx10x0-16 24143620 143.8 ns/op 14348.66 MB/s Benchmark____GWs_Opt_2kx10x0-16 23087101 152.3 ns/op 13550.76 MB/s Benchmark____GWs_Opt_2kx10x0-16 22965103 159.7 ns/op 12923.52 MB/s Benchmark____GWs_Opt_2kx10x0-16 25126965 149.5 ns/op 13806.77 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11117964 328.4 ns/op 12520.42 MB/s Benchmark____GWs_Opt_4kx10x0-16 11380848 385.8 ns/op 10659.46 MB/s Benchmark____GWs_Opt_4kx10x0-16 12861154 281.3 ns/op 14615.31 MB/s Benchmark____GWs_Opt_4kx10x0-16 12789058 292.9 ns/op 14037.41 MB/s Benchmark____GWs_Opt_4kx10x0-16 9995560 301.1 ns/op 13654.88 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6390115 562.8 ns/op 5552.66 MB/s Benchmark____GWs_Opt_1kx01x1-16 6339684 554.7 ns/op 5633.80 MB/s Benchmark____GWs_Opt_1kx01x1-16 6414291 552.6 ns/op 5654.69 MB/s Benchmark____GWs_Opt_1kx01x1-16 6396354 558.8 ns/op 5592.77 MB/s Benchmark____GWs_Opt_1kx01x1-16 6369792 553.0 ns/op 5651.49 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4663482 779.4 ns/op 7950.78 MB/s Benchmark____GWs_Opt_2kx01x1-16 4669304 761.2 ns/op 8140.95 MB/s Benchmark____GWs_Opt_2kx01x1-16 4615525 770.8 ns/op 8039.30 MB/s Benchmark____GWs_Opt_2kx01x1-16 4587865 766.1 ns/op 8088.52 MB/s Benchmark____GWs_Opt_2kx01x1-16 4770998 855.1 ns/op 7246.85 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2628726 1359 ns/op 9082.23 MB/s Benchmark____GWs_Opt_4kx01x1-16 2584846 1537 ns/op 8030.35 MB/s Benchmark____GWs_Opt_4kx01x1-16 2548780 1384 ns/op 8919.95 MB/s Benchmark____GWs_Opt_4kx01x1-16 2606979 1653 ns/op 7464.36 MB/s Benchmark____GWs_Opt_4kx01x1-16 2618446 1380 ns/op 8943.18 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6404379 553.5 ns/op 5645.45 MB/s Benchmark____GWs_Opt_1kx10x1-16 6525682 557.9 ns/op 5601.24 MB/s Benchmark____GWs_Opt_1kx10x1-16 6359584 555.5 ns/op 5625.49 MB/s Benchmark____GWs_Opt_1kx10x1-16 6052653 566.5 ns/op 5515.86 MB/s Benchmark____GWs_Opt_1kx10x1-16 6601795 558.8 ns/op 5592.10 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4051508 846.6 ns/op 7319.67 MB/s Benchmark____GWs_Opt_2kx10x1-16 4088076 852.6 ns/op 7268.58 MB/s Benchmark____GWs_Opt_2kx10x1-16 4112449 849.2 ns/op 7297.46 MB/s Benchmark____GWs_Opt_2kx10x1-16 4099556 857.2 ns/op 7229.00 MB/s Benchmark____GWs_Opt_2kx10x1-16 4067782 850.8 ns/op 7283.70 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2307525 1540 ns/op 8015.80 MB/s Benchmark____GWs_Opt_4kx10x1-16 2394244 1532 ns/op 8057.97 MB/s Benchmark____GWs_Opt_4kx10x1-16 2316804 1528 ns/op 8075.47 MB/s Benchmark____GWs_Opt_4kx10x1-16 2393380 1552 ns/op 7953.96 MB/s Benchmark____GWs_Opt_4kx10x1-16 2392668 1522 ns/op 8106.20 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12212586 293.2 ns/op 3547.22 MB/s Benchmark____GWs_Int_1kx01x0-16 11835031 305.0 ns/op 3409.90 MB/s Benchmark____GWs_Int_1kx01x0-16 12517154 288.7 ns/op 3602.56 MB/s Benchmark____GWs_Int_1kx01x0-16 12475153 284.7 ns/op 3652.86 MB/s Benchmark____GWs_Int_1kx01x0-16 12449008 293.3 ns/op 3545.71 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10242843 357.7 ns/op 5769.75 MB/s Benchmark____GWs_Int_2kx01x0-16 9856639 361.9 ns/op 5703.89 MB/s Benchmark____GWs_Int_2kx01x0-16 9899596 358.1 ns/op 5764.25 MB/s Benchmark____GWs_Int_2kx01x0-16 10208418 372.1 ns/op 5546.59 MB/s Benchmark____GWs_Int_2kx01x0-16 10111520 362.5 ns/op 5693.75 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5668276 641.3 ns/op 6412.20 MB/s Benchmark____GWs_Int_4kx01x0-16 5684529 636.7 ns/op 6458.72 MB/s Benchmark____GWs_Int_4kx01x0-16 5115114 646.8 ns/op 6357.47 MB/s Benchmark____GWs_Int_4kx01x0-16 5694000 651.5 ns/op 6311.69 MB/s Benchmark____GWs_Int_4kx01x0-16 5604394 644.3 ns/op 6381.84 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31296660 111.1 ns/op 9361.29 MB/s Benchmark____GWs_Int_1kx10x0-16 27904416 115.8 ns/op 8978.09 MB/s Benchmark____GWs_Int_1kx10x0-16 32049640 111.2 ns/op 9351.13 MB/s Benchmark____GWs_Int_1kx10x0-16 30914635 113.8 ns/op 9137.74 MB/s Benchmark____GWs_Int_1kx10x0-16 31047513 112.4 ns/op 9254.76 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24834758 138.8 ns/op 14870.84 MB/s Benchmark____GWs_Int_2kx10x0-16 24937555 141.9 ns/op 14543.33 MB/s Benchmark____GWs_Int_2kx10x0-16 25271181 142.2 ns/op 14519.24 MB/s Benchmark____GWs_Int_2kx10x0-16 24470374 144.9 ns/op 14246.54 MB/s Benchmark____GWs_Int_2kx10x0-16 24170612 142.6 ns/op 14472.25 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 3417303 4359 ns/op 943.24 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:41532->127.0.0.1:32823: 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:59578->127.0.0.1:40119: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12140526 283.4 ns/op 14511.69 MB/s Benchmark____GWs_Int_4kx10x0-16 12678891 312.1 ns/op 13174.20 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:50018->127.0.0.1:35721: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6395653 552.0 ns/op 5661.59 MB/s Benchmark____GWs_Int_1kx01x1-16 6471440 576.6 ns/op 5419.25 MB/s Benchmark____GWs_Int_1kx01x1-16 6317640 571.9 ns/op 5464.35 MB/s Benchmark____GWs_Int_1kx01x1-16 6438784 557.4 ns/op 5606.39 MB/s Benchmark____GWs_Int_1kx01x1-16 6422544 558.0 ns/op 5600.32 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4646128 777.9 ns/op 7966.74 MB/s Benchmark____GWs_Int_2kx01x1-16 4516528 782.9 ns/op 7915.70 MB/s Benchmark____GWs_Int_2kx01x1-16 4566794 768.3 ns/op 8066.09 MB/s Benchmark____GWs_Int_2kx01x1-16 4313590 780.4 ns/op 7940.55 MB/s Benchmark____GWs_Int_2kx01x1-16 4805239 766.4 ns/op 8085.48 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2605893 1381 ns/op 8936.30 MB/s Benchmark____GWs_Int_4kx01x1-16 2548636 1398 ns/op 8829.72 MB/s Benchmark____GWs_Int_4kx01x1-16 2599474 1376 ns/op 8967.48 MB/s Benchmark____GWs_Int_4kx01x1-16 2535046 1375 ns/op 8972.71 MB/s Benchmark____GWs_Int_4kx01x1-16 2610540 1388 ns/op 8891.01 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6646957 560.6 ns/op 5574.76 MB/s Benchmark____GWs_Int_1kx10x1-16 6267730 557.6 ns/op 5604.58 MB/s Benchmark____GWs_Int_1kx10x1-16 6017884 551.9 ns/op 5661.83 MB/s Benchmark____GWs_Int_1kx10x1-16 6549253 612.4 ns/op 5103.01 MB/s Benchmark____GWs_Int_1kx10x1-16 5992824 562.7 ns/op 5553.26 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 3811978 867.7 ns/op 7142.12 MB/s Benchmark____GWs_Int_2kx10x1-16 4141195 846.9 ns/op 7317.56 MB/s Benchmark____GWs_Int_2kx10x1-16 4180466 843.0 ns/op 7351.52 MB/s Benchmark____GWs_Int_2kx10x1-16 4194754 889.1 ns/op 6970.08 MB/s Benchmark____GWs_Int_2kx10x1-16 4190835 1016 ns/op 6100.35 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2309116 1536 ns/op 8033.50 MB/s Benchmark____GWs_Int_4kx10x1-16 2146256 1551 ns/op 7954.96 MB/s Benchmark____GWs_Int_4kx10x1-16 2311609 1656 ns/op 7451.04 MB/s Benchmark____GWs_Int_4kx10x1-16 2328722 1942 ns/op 6355.18 MB/s Benchmark____GWs_Int_4kx10x1-16 2356069 1523 ns/op 8100.82 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8290603 441.4 ns/op 231.07 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8324842 437.9 ns/op 232.91 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8136201 438.9 ns/op 232.38 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8519671 437.7 ns/op 233.03 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7966917 432.3 ns/op 235.97 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 620680 4997 ns/op 35.42 MB/s Benchmark__GWs_Reqs_1SubEach-16 799093 5146 ns/op 34.40 MB/s Benchmark__GWs_Reqs_1SubEach-16 775417 5304 ns/op 33.37 MB/s Benchmark__GWs_Reqs_1SubEach-16 720150 5212 ns/op 33.96 MB/s Benchmark__GWs_Reqs_1SubEach-16 734794 5326 ns/op 33.23 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2131.641s ❌ Non-zero exit code: 1