> ROOT_DIR=/tmp/go-bench-away-job-0927a98a-93d9-468b-b3be-c103102eb854-3748149077 > OUTPUT_FILE=/tmp/go-bench-away-job-0927a98a-93d9-468b-b3be-c103102eb854-3748149077/results.txt > SHA_FILE=/tmp/go-bench-away-job-0927a98a-93d9-468b-b3be-c103102eb854-3748149077/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-0927a98a-93d9-468b-b3be-c103102eb854-3748149077/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.25.4/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-0927a98a-93d9-468b-b3be-c103102eb854-3748149077/source.git SHA of main: 51fbade1ed5aa9cd026e6be57ad9b0c6272f6709 Go runtime: go version go1.26.0 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build3501049444=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-0927a98a-93d9-468b-b3be-c103102eb854-3748149077/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.25.4' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.25.4/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.0' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 53213018 67.54 ns/op 162.87 MB/s Benchmark______Pub0b_Payload-16 49916278 67.47 ns/op 163.04 MB/s Benchmark______Pub0b_Payload-16 53127700 69.03 ns/op 159.35 MB/s Benchmark______Pub0b_Payload-16 50537217 67.53 ns/op 162.90 MB/s Benchmark______Pub0b_Payload-16 50453860 67.46 ns/op 163.06 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 49887477 70.75 ns/op 268.55 MB/s Benchmark______Pub8b_Payload-16 53103786 68.01 ns/op 279.37 MB/s Benchmark______Pub8b_Payload-16 47409834 68.26 ns/op 278.33 MB/s Benchmark______Pub8b_Payload-16 53146182 68.15 ns/op 278.81 MB/s Benchmark______Pub8b_Payload-16 49482303 68.42 ns/op 277.69 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 47423143 72.82 ns/op 604.24 MB/s Benchmark_____Pub32b_Payload-16 47169900 72.99 ns/op 602.83 MB/s Benchmark_____Pub32b_Payload-16 49568241 72.53 ns/op 606.67 MB/s Benchmark_____Pub32b_Payload-16 46815410 72.22 ns/op 609.21 MB/s Benchmark_____Pub32b_Payload-16 47194808 72.49 ns/op 606.95 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 42160723 83.83 ns/op 1681.88 MB/s Benchmark____Pub128B_Payload-16 41501127 81.68 ns/op 1726.30 MB/s Benchmark____Pub128B_Payload-16 41261442 83.16 ns/op 1695.44 MB/s Benchmark____Pub128B_Payload-16 42078955 81.99 ns/op 1719.63 MB/s Benchmark____Pub128B_Payload-16 41102620 81.70 ns/op 1725.83 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 39296436 90.69 ns/op 2966.24 MB/s Benchmark____Pub256B_Payload-16 38383766 90.69 ns/op 2966.23 MB/s Benchmark____Pub256B_Payload-16 37685938 90.86 ns/op 2960.65 MB/s Benchmark____Pub256B_Payload-16 35653339 89.50 ns/op 3005.63 MB/s Benchmark____Pub256B_Payload-16 37543114 89.49 ns/op 3005.95 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 21671378 138.7 ns/op 7485.29 MB/s Benchmark______Pub1K_Payload-16 21886137 138.4 ns/op 7502.31 MB/s Benchmark______Pub1K_Payload-16 22274085 138.5 ns/op 7494.12 MB/s Benchmark______Pub1K_Payload-16 24734305 145.0 ns/op 7159.64 MB/s Benchmark______Pub1K_Payload-16 26451456 132.3 ns/op 7847.73 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5716288 640.2 ns/op 6420.00 MB/s Benchmark______Pub4K_Payload-16 5508024 617.5 ns/op 6655.55 MB/s Benchmark______Pub4K_Payload-16 5684787 660.0 ns/op 6227.22 MB/s Benchmark______Pub4K_Payload-16 5511220 634.7 ns/op 6475.14 MB/s Benchmark______Pub4K_Payload-16 5435626 642.2 ns/op 6400.14 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2721811 1274 ns/op 6442.20 MB/s Benchmark______Pub8K_Payload-16 2757398 1275 ns/op 6436.79 MB/s Benchmark______Pub8K_Payload-16 2773202 1282 ns/op 6401.37 MB/s Benchmark______Pub8K_Payload-16 2752036 1282 ns/op 6400.19 MB/s Benchmark______Pub8K_Payload-16 2754730 1292 ns/op 6350.09 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 672297 5241 ns/op 6255.02 MB/s Benchmark_____Pub32K_Payload-16 586382 6629 ns/op 4945.38 MB/s Benchmark_____Pub32K_Payload-16 656448 5448 ns/op 6017.42 MB/s Benchmark_____Pub32K_Payload-16 668362 5374 ns/op 6100.73 MB/s Benchmark_____Pub32K_Payload-16 565887 6793 ns/op 4825.77 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 34225293 87.96 ns/op 125.06 MB/s Benchmark__AuthPub0b_Payload-16 38947278 89.35 ns/op 123.11 MB/s Benchmark__AuthPub0b_Payload-16 38740737 87.62 ns/op 125.54 MB/s Benchmark__AuthPub0b_Payload-16 39047988 88.68 ns/op 124.05 MB/s Benchmark__AuthPub0b_Payload-16 41085054 87.59 ns/op 125.59 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 16756566 210.6 ns/op Benchmark_____________PubSub-16 16872517 209.7 ns/op Benchmark_____________PubSub-16 16743466 210.5 ns/op Benchmark_____________PubSub-16 17013348 211.5 ns/op Benchmark_____________PubSub-16 16835228 210.9 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 16885868 209.1 ns/op Benchmark_____PubSubTwoConns-16 17024264 209.5 ns/op Benchmark_____PubSubTwoConns-16 16846532 210.4 ns/op Benchmark_____PubSubTwoConns-16 16867776 209.1 ns/op Benchmark_____PubSubTwoConns-16 16908088 209.4 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58038->127.0.0.1:45233: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:35596->127.0.0.1:37897: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:37562->127.0.0.1:43301: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:38278->127.0.0.1:43339: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33884->127.0.0.1:45133: 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 15618254 227.4 ns/op Benchmark_____PubTwoQueueSub-16 15735928 227.2 ns/op Benchmark_____PubTwoQueueSub-16 15561444 227.5 ns/op Benchmark_____PubTwoQueueSub-16 15591649 226.3 ns/op Benchmark_____PubTwoQueueSub-16 15625227 226.5 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15536192 227.1 ns/op Benchmark____PubFourQueueSub-16 15483100 224.7 ns/op Benchmark____PubFourQueueSub-16 15586881 227.0 ns/op Benchmark____PubFourQueueSub-16 15668834 227.0 ns/op Benchmark____PubFourQueueSub-16 15597186 227.0 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15719546 226.3 ns/op Benchmark___PubEightQueueSub-16 15574027 227.2 ns/op Benchmark___PubEightQueueSub-16 15715490 225.4 ns/op Benchmark___PubEightQueueSub-16 15583826 227.0 ns/op Benchmark___PubEightQueueSub-16 15575196 227.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23079 155708 ns/op Benchmark_PubSub512kTwoConns-16 22995 166142 ns/op Benchmark_PubSub512kTwoConns-16 23038 155690 ns/op Benchmark_PubSub512kTwoConns-16 22958 155650 ns/op Benchmark_PubSub512kTwoConns-16 22836 155811 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16444509 213.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 16202815 214.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 16231252 214.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 16244464 213.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 16401493 214.4 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16331156 214.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 16399368 214.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 16376947 214.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 16281994 214.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 16077494 213.8 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 12090198 284.6 ns/op Benchmark____RoutedPubSub_0b-16 11669502 298.4 ns/op Benchmark____RoutedPubSub_0b-16 11490027 297.9 ns/op Benchmark____RoutedPubSub_0b-16 11590006 301.2 ns/op Benchmark____RoutedPubSub_0b-16 12136548 275.5 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6762825 487.2 ns/op Benchmark____RoutedPubSub_1K-16 6877532 518.6 ns/op Benchmark____RoutedPubSub_1K-16 6738052 502.9 ns/op Benchmark____RoutedPubSub_1K-16 7015912 500.0 ns/op Benchmark____RoutedPubSub_1K-16 7009230 500.5 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85395 40970 ns/op Benchmark__RoutedPubSub_100K-16 82693 44210 ns/op Benchmark__RoutedPubSub_100K-16 73830 47834 ns/op Benchmark__RoutedPubSub_100K-16 79026 43844 ns/op Benchmark__RoutedPubSub_100K-16 83910 41990 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9971446 303.9 ns/op Benchmark____Routed2QueueSub-16 9952608 304.4 ns/op Benchmark____Routed2QueueSub-16 10109308 308.3 ns/op Benchmark____Routed2QueueSub-16 10008972 306.9 ns/op Benchmark____Routed2QueueSub-16 10021016 305.3 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 11940604 306.6 ns/op Benchmark____Routed4QueueSub-16 9842550 307.9 ns/op Benchmark____Routed4QueueSub-16 9703573 312.4 ns/op Benchmark____Routed4QueueSub-16 9833487 316.9 ns/op Benchmark____Routed4QueueSub-16 9572659 313.5 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9614036 316.0 ns/op Benchmark____Routed8QueueSub-16 9650340 316.0 ns/op Benchmark____Routed8QueueSub-16 11482610 313.1 ns/op Benchmark____Routed8QueueSub-16 11528726 317.9 ns/op Benchmark____Routed8QueueSub-16 9411429 319.7 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 9094994 336.5 ns/op Benchmark___Routed16QueueSub-16 9384476 340.1 ns/op Benchmark___Routed16QueueSub-16 8862388 339.2 ns/op Benchmark___Routed16QueueSub-16 9164716 337.1 ns/op Benchmark___Routed16QueueSub-16 9023959 339.1 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6611850 482.5 ns/op Benchmark____________RouteCompressOff-16 6650043 544.2 ns/op Benchmark____________RouteCompressOff-16 6448965 470.8 ns/op Benchmark____________RouteCompressOff-16 6700219 530.1 ns/op Benchmark____________RouteCompressOff-16 6929319 532.6 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6686961 458.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6718155 533.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6684033 529.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6555946 522.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6746628 525.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6716454 525.9 ns/op Benchmark_________RouteCompressS2Fast-16 6750460 454.2 ns/op Benchmark_________RouteCompressS2Fast-16 6766726 528.3 ns/op Benchmark_________RouteCompressS2Fast-16 6629286 523.3 ns/op Benchmark_________RouteCompressS2Fast-16 6769764 525.8 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6704584 528.1 ns/op Benchmark_______RouteCompressS2Better-16 6619912 533.1 ns/op Benchmark_______RouteCompressS2Better-16 6632636 527.6 ns/op Benchmark_______RouteCompressS2Better-16 6770475 527.5 ns/op Benchmark_______RouteCompressS2Better-16 6795710 528.2 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6772682 524.8 ns/op Benchmark_________RouteCompressS2Best-16 6592725 525.2 ns/op Benchmark_________RouteCompressS2Best-16 6691162 525.8 ns/op Benchmark_________RouteCompressS2Best-16 6536137 528.3 ns/op Benchmark_________RouteCompressS2Best-16 6916392 523.9 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5209467 683.8 ns/op 364.13 MB/s Benchmark______FanOut_8x1x10-16 5273535 681.2 ns/op 365.55 MB/s Benchmark______FanOut_8x1x10-16 5250079 689.1 ns/op 361.32 MB/s Benchmark______FanOut_8x1x10-16 5238483 681.6 ns/op 365.33 MB/s Benchmark______FanOut_8x1x10-16 5242580 682.7 ns/op 364.74 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 620485 5304 ns/op 437.20 MB/s Benchmark_____FanOut_8x1x100-16 610434 5298 ns/op 437.72 MB/s Benchmark_____FanOut_8x1x100-16 632421 5286 ns/op 438.70 MB/s Benchmark_____FanOut_8x1x100-16 639026 5319 ns/op 435.99 MB/s Benchmark_____FanOut_8x1x100-16 642998 5264 ns/op 440.57 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 51637 67722 ns/op 339.91 MB/s Benchmark____FanOut_8x10x100-16 52878 67830 ns/op 339.36 MB/s Benchmark____FanOut_8x10x100-16 53187 67864 ns/op 339.19 MB/s Benchmark____FanOut_8x10x100-16 52945 67683 ns/op 340.10 MB/s Benchmark____FanOut_8x10x100-16 52329 67574 ns/op 340.65 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6644 535155 ns/op 448.50 MB/s Benchmark___FanOut_8x10x1000-16 6560 530998 ns/op 452.02 MB/s Benchmark___FanOut_8x10x1000-16 6829 531834 ns/op 451.30 MB/s Benchmark___FanOut_8x10x1000-16 6613 536769 ns/op 447.16 MB/s Benchmark___FanOut_8x10x1000-16 6813 536395 ns/op 447.47 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5611 634205 ns/op 362.69 MB/s Benchmark___FanOut_8x100x100-16 5570 630938 ns/op 364.57 MB/s Benchmark___FanOut_8x100x100-16 5529 630807 ns/op 364.64 MB/s Benchmark___FanOut_8x100x100-16 5511 632452 ns/op 363.69 MB/s Benchmark___FanOut_8x100x100-16 5589 634541 ns/op 362.50 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 645 5551333 ns/op 432.33 MB/s Benchmark__FanOut_8x100x1000-16 625 5541681 ns/op 433.09 MB/s Benchmark__FanOut_8x100x1000-16 651 5529937 ns/op 434.00 MB/s Benchmark__FanOut_8x100x1000-16 645 5740327 ns/op 418.10 MB/s Benchmark__FanOut_8x100x1000-16 651 5463711 ns/op 439.27 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 606 5998198 ns/op 416.79 MB/s Benchmark__FanOut_8x10x10000-16 594 5835516 ns/op 428.41 MB/s Benchmark__FanOut_8x10x10000-16 602 5865274 ns/op 426.24 MB/s Benchmark__FanOut_8x10x10000-16 591 5854063 ns/op 427.06 MB/s Benchmark__FanOut_8x10x10000-16 607 5853250 ns/op 427.12 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1039 3382749 ns/op 339.97 MB/s Benchmark___FanOut_8x500x100-16 1057 3392297 ns/op 339.01 MB/s Benchmark___FanOut_8x500x100-16 1022 3386746 ns/op 339.56 MB/s Benchmark___FanOut_8x500x100-16 1056 3392908 ns/op 338.95 MB/s Benchmark___FanOut_8x500x100-16 1045 3364659 ns/op 341.79 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 389689 8901 ns/op 1644.90 MB/s Benchmark___FanOut_128x1x100-16 393270 8831 ns/op 1657.99 MB/s Benchmark___FanOut_128x1x100-16 390708 8930 ns/op 1639.60 MB/s Benchmark___FanOut_128x1x100-16 381116 8870 ns/op 1650.70 MB/s Benchmark___FanOut_128x1x100-16 391281 8845 ns/op 1655.31 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 35109 101967 ns/op 1423.41 MB/s Benchmark__FanOut_128x10x100-16 35310 102640 ns/op 1414.08 MB/s Benchmark__FanOut_128x10x100-16 35122 102077 ns/op 1421.88 MB/s Benchmark__FanOut_128x10x100-16 35190 102481 ns/op 1416.28 MB/s Benchmark__FanOut_128x10x100-16 35282 103568 ns/op 1401.40 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4473 794247 ns/op 1838.40 MB/s Benchmark_FanOut_128x10x1000-16 4442 784090 ns/op 1862.21 MB/s Benchmark_FanOut_128x10x1000-16 4756 792898 ns/op 1841.53 MB/s Benchmark_FanOut_128x10x1000-16 4534 794934 ns/op 1836.81 MB/s Benchmark_FanOut_128x10x1000-16 4413 790201 ns/op 1847.81 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3776 935903 ns/op 1549.46 MB/s Benchmark_FanOut_128x100x100-16 3769 938664 ns/op 1544.90 MB/s Benchmark_FanOut_128x100x100-16 3748 939117 ns/op 1544.15 MB/s Benchmark_FanOut_128x100x100-16 3735 938032 ns/op 1545.94 MB/s Benchmark_FanOut_128x100x100-16 3686 936527 ns/op 1548.42 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 426 8397355 ns/op 1738.66 MB/s BenchmarkFanOut_128x100x1000-16 428 8540091 ns/op 1709.60 MB/s BenchmarkFanOut_128x100x1000-16 429 8395734 ns/op 1739.00 MB/s BenchmarkFanOut_128x100x1000-16 428 8385580 ns/op 1741.10 MB/s BenchmarkFanOut_128x100x1000-16 421 8545608 ns/op 1708.50 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 404 8790609 ns/op 1672.26 MB/s BenchmarkFanOut_128x10x10000-16 405 8840362 ns/op 1662.84 MB/s BenchmarkFanOut_128x10x10000-16 405 8870371 ns/op 1657.22 MB/s BenchmarkFanOut_128x10x10000-16 408 8796842 ns/op 1671.07 MB/s BenchmarkFanOut_128x10x10000-16 403 8836323 ns/op 1663.60 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 718 4927005 ns/op 1471.51 MB/s BenchmarkFanOut__128x500x100-16 721 4967495 ns/op 1459.52 MB/s BenchmarkFanOut__128x500x100-16 718 4965678 ns/op 1460.05 MB/s BenchmarkFanOut__128x500x100-16 716 4930732 ns/op 1470.40 MB/s BenchmarkFanOut__128x500x100-16 730 4946853 ns/op 1465.61 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 2026 1754914 ns/op 3014.69 MB/s Benchmark_FanOut_512x100x100-16 2013 1760628 ns/op 3004.91 MB/s Benchmark_FanOut_512x100x100-16 2017 1762005 ns/op 3002.56 MB/s Benchmark_FanOut_512x100x100-16 2006 1764459 ns/op 2998.38 MB/s Benchmark_FanOut_512x100x100-16 2011 1781577 ns/op 2969.57 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 223 16037266 ns/op 3304.84 MB/s Benchmark__FanOut_512x100x1k-16 220 15975958 ns/op 3317.52 MB/s Benchmark__FanOut_512x100x1k-16 224 16104891 ns/op 3290.96 MB/s Benchmark__FanOut_512x100x1k-16 223 16062479 ns/op 3299.65 MB/s Benchmark__FanOut_512x100x1k-16 223 16205572 ns/op 3270.51 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3078 1108711 ns/op 9408.26 MB/s Benchmark____FanOut_1kx10x1k-16 3182 1101488 ns/op 9469.95 MB/s Benchmark____FanOut_1kx10x1k-16 3351 1094495 ns/op 9530.46 MB/s Benchmark____FanOut_1kx10x1k-16 3127 1088479 ns/op 9583.13 MB/s Benchmark____FanOut_1kx10x1k-16 3282 1071607 ns/op 9734.01 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2979 1193919 ns/op 8728.43 MB/s Benchmark__FanOut_1kx100x100-16 2950 1192427 ns/op 8739.35 MB/s Benchmark__FanOut_1kx100x100-16 2920 1211045 ns/op 8605.00 MB/s Benchmark__FanOut_1kx100x100-16 2918 1193559 ns/op 8731.06 MB/s Benchmark__FanOut_1kx100x100-16 2961 1191832 ns/op 8743.71 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 5019380 691.8 ns/op 359.94 MB/s Benchmark_____RFanOut_8x1x10-16 4891447 705.5 ns/op 352.93 MB/s Benchmark_____RFanOut_8x1x10-16 5030395 701.4 ns/op 354.98 MB/s Benchmark_____RFanOut_8x1x10-16 4945018 696.9 ns/op 357.32 MB/s Benchmark_____RFanOut_8x1x10-16 5053339 697.4 ns/op 357.05 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 633148 5288 ns/op 438.53 MB/s Benchmark____RFanOut_8x1x100-16 570771 5277 ns/op 439.42 MB/s Benchmark____RFanOut_8x1x100-16 580359 5447 ns/op 425.73 MB/s Benchmark____RFanOut_8x1x100-16 625257 5297 ns/op 437.76 MB/s Benchmark____RFanOut_8x1x100-16 610906 5276 ns/op 439.57 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 52611 67829 ns/op 339.37 MB/s Benchmark___RFanOut_8x10x100-16 51885 68927 ns/op 333.96 MB/s Benchmark___RFanOut_8x10x100-16 52678 67404 ns/op 341.51 MB/s Benchmark___RFanOut_8x10x100-16 52359 69181 ns/op 332.74 MB/s Benchmark___RFanOut_8x10x100-16 52503 67804 ns/op 339.49 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6441 538920 ns/op 445.37 MB/s Benchmark__RFanOut_8x10x1000-16 6476 545376 ns/op 440.10 MB/s Benchmark__RFanOut_8x10x1000-16 6607 535720 ns/op 448.03 MB/s Benchmark__RFanOut_8x10x1000-16 6488 546818 ns/op 438.94 MB/s Benchmark__RFanOut_8x10x1000-16 6562 536938 ns/op 447.01 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5536 636796 ns/op 361.21 MB/s Benchmark__RFanOut_8x100x100-16 5582 632940 ns/op 363.41 MB/s Benchmark__RFanOut_8x100x100-16 5443 634229 ns/op 362.67 MB/s Benchmark__RFanOut_8x100x100-16 5482 635978 ns/op 361.68 MB/s Benchmark__RFanOut_8x100x100-16 5481 644136 ns/op 357.10 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 621 5606124 ns/op 428.11 MB/s Benchmark_RFanOut_8x100x1000-16 643 5549443 ns/op 432.48 MB/s Benchmark_RFanOut_8x100x1000-16 638 5558257 ns/op 431.79 MB/s Benchmark_RFanOut_8x100x1000-16 650 5548007 ns/op 432.59 MB/s Benchmark_RFanOut_8x100x1000-16 622 5626835 ns/op 426.53 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 604 5915168 ns/op 422.65 MB/s Benchmark_RFanOut_8x10x10000-16 589 5939000 ns/op 420.95 MB/s Benchmark_RFanOut_8x10x10000-16 597 5987527 ns/op 417.54 MB/s Benchmark_RFanOut_8x10x10000-16 602 5911104 ns/op 422.94 MB/s Benchmark_RFanOut_8x10x10000-16 600 5979352 ns/op 418.11 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2977 1113652 ns/op 9366.51 MB/s Benchmark_RFanOut_1kx10x1000-16 3440 1107392 ns/op 9419.46 MB/s Benchmark_RFanOut_1kx10x1000-16 3195 1112001 ns/op 9380.42 MB/s Benchmark_RFanOut_1kx10x1000-16 3411 1123666 ns/op 9283.04 MB/s Benchmark_RFanOut_1kx10x1000-16 3031 1110885 ns/op 9389.85 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7136523 489.3 ns/op 4247.10 MB/s Benchmark_____FanIn_1kx100x1-16 7259608 488.4 ns/op 4254.75 MB/s Benchmark_____FanIn_1kx100x1-16 7088151 486.6 ns/op 4270.13 MB/s Benchmark_____FanIn_1kx100x1-16 7151299 487.6 ns/op 4261.34 MB/s Benchmark_____FanIn_1kx100x1-16 7155067 485.5 ns/op 4280.34 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2642140 1329 ns/op 6188.82 MB/s Benchmark_____FanIn_4kx100x1-16 2694499 1361 ns/op 6039.36 MB/s Benchmark_____FanIn_4kx100x1-16 2614926 1335 ns/op 6157.45 MB/s Benchmark_____FanIn_4kx100x1-16 2660446 1329 ns/op 6185.43 MB/s Benchmark_____FanIn_4kx100x1-16 2684826 1341 ns/op 6129.41 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1718343 2090 ns/op 7851.85 MB/s Benchmark_____FanIn_8kx100x1-16 1711184 2085 ns/op 7873.60 MB/s Benchmark_____FanIn_8kx100x1-16 1696629 2063 ns/op 7957.88 MB/s Benchmark_____FanIn_8kx100x1-16 1699159 2068 ns/op 7935.85 MB/s Benchmark_____FanIn_8kx100x1-16 1686272 2094 ns/op 7837.24 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 874371 4141 ns/op 7920.78 MB/s Benchmark____FanIn_16kx100x1-16 867140 4118 ns/op 7965.34 MB/s Benchmark____FanIn_16kx100x1-16 832740 4186 ns/op 7835.64 MB/s Benchmark____FanIn_16kx100x1-16 874099 4106 ns/op 7988.31 MB/s Benchmark____FanIn_16kx100x1-16 863538 4157 ns/op 7890.69 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 6405249183 vs 10462258800 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57696->127.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:58204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57896->127.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:57836->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:58054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58302->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 170359 19665 ns/op 6666.80 MB/s Benchmark____FanIn_64kx100x1-16 165152 19735 ns/op 6643.21 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 2567973222 vs 11039125200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38078->127.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:37512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37504->127.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:37888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37732->127.0.0.1:5222: write: connection reset by peer bench_test.go: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:37548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37608->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 163478 19782 ns/op 6627.37 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 569717140 vs 1310900000 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:42802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43216->127.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:42672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42630->127.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: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:43388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42830->127.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: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:42978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43446->127.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:43082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43252->127.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:42624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43214->127.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:43342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43032->127.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:42696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43414->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: 301900270 vs 1310900000 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:44564->127.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:44736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44678->127.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:45256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44786->127.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: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: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:45168->127.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:45080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44432->127.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: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:45140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45218->127.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:44500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45156->127.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:44992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45200->127.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:44892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45306->127.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:45110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45150->127.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: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:44460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45132->127.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: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: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:44536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45152->127.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:44648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44854->127.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:44816->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: 205811300 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46656->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46486->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: 1016996220 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48332->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: 402315210 vs 11549029000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51274->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51312->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51146->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5933728 600.9 ns/op 472.65 MB/s Benchmark___BumpPubCount_1x3-16 5944933 601.0 ns/op 472.52 MB/s Benchmark___BumpPubCount_1x3-16 5953035 594.7 ns/op 477.54 MB/s Benchmark___BumpPubCount_1x3-16 5962092 599.8 ns/op 473.47 MB/s Benchmark___BumpPubCount_1x3-16 5941528 600.7 ns/op 472.77 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5643474 635.4 ns/op 446.95 MB/s Benchmark___BumpPubCount_2x3-16 5627611 637.9 ns/op 445.20 MB/s Benchmark___BumpPubCount_2x3-16 5607748 629.8 ns/op 450.90 MB/s Benchmark___BumpPubCount_2x3-16 5534868 636.1 ns/op 446.47 MB/s Benchmark___BumpPubCount_2x3-16 5609230 632.8 ns/op 448.78 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5863266 615.6 ns/op 461.31 MB/s Benchmark___BumpPubCount_5x3-16 5797190 614.0 ns/op 462.54 MB/s Benchmark___BumpPubCount_5x3-16 5841240 614.6 ns/op 462.07 MB/s Benchmark___BumpPubCount_5x3-16 5786389 617.7 ns/op 459.76 MB/s Benchmark___BumpPubCount_5x3-16 5672742 616.5 ns/op 460.64 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5857508 611.7 ns/op 464.28 MB/s Benchmark__BumpPubCount_10x3-16 5823547 611.3 ns/op 464.62 MB/s Benchmark__BumpPubCount_10x3-16 5872491 613.8 ns/op 462.69 MB/s Benchmark__BumpPubCount_10x3-16 5828270 611.1 ns/op 464.75 MB/s Benchmark__BumpPubCount_10x3-16 5845740 613.3 ns/op 463.06 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11566456 276.7 ns/op 3758.79 MB/s Benchmark____GWs_Opt_1kx01x0-16 12956114 278.5 ns/op 3734.71 MB/s Benchmark____GWs_Opt_1kx01x0-16 12227236 275.6 ns/op 3773.14 MB/s Benchmark____GWs_Opt_1kx01x0-16 12616159 271.2 ns/op 3834.87 MB/s Benchmark____GWs_Opt_1kx01x0-16 12623748 277.9 ns/op 3742.78 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9130524 340.3 ns/op 6064.47 MB/s Benchmark____GWs_Opt_2kx01x0-16 9472986 336.2 ns/op 6139.70 MB/s Benchmark____GWs_Opt_2kx01x0-16 10159268 316.6 ns/op 6520.18 MB/s Benchmark____GWs_Opt_2kx01x0-16 10807269 330.9 ns/op 6237.75 MB/s Benchmark____GWs_Opt_2kx01x0-16 10036386 352.5 ns/op 5855.81 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5667331 816.7 ns/op 5035.04 MB/s Benchmark____GWs_Opt_4kx01x0-16 5491036 627.2 ns/op 6556.03 MB/s Benchmark____GWs_Opt_4kx01x0-16 5790890 694.7 ns/op 5918.94 MB/s Benchmark____GWs_Opt_4kx01x0-16 5864829 651.8 ns/op 6309.17 MB/s Benchmark____GWs_Opt_4kx01x0-16 5689182 636.9 ns/op 6456.25 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30429634 112.9 ns/op 9208.74 MB/s Benchmark____GWs_Opt_1kx10x0-16 31993987 119.0 ns/op 8736.07 MB/s Benchmark____GWs_Opt_1kx10x0-16 30644938 120.1 ns/op 8656.63 MB/s Benchmark____GWs_Opt_1kx10x0-16 28861566 112.7 ns/op 9229.07 MB/s Benchmark____GWs_Opt_1kx10x0-16 31356712 108.3 ns/op 9598.63 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25623244 146.2 ns/op 14113.22 MB/s Benchmark____GWs_Opt_2kx10x0-16 25145209 156.3 ns/op 13209.20 MB/s Benchmark____GWs_Opt_2kx10x0-16 22227499 143.6 ns/op 14368.68 MB/s Benchmark____GWs_Opt_2kx10x0-16 23799808 154.4 ns/op 13363.56 MB/s Benchmark____GWs_Opt_2kx10x0-16 25448412 142.6 ns/op 14476.63 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 10484066 331.2 ns/op 12416.88 MB/s Benchmark____GWs_Opt_4kx10x0-16 10176698 295.7 ns/op 13904.00 MB/s Benchmark____GWs_Opt_4kx10x0-16 12953587 293.8 ns/op 13995.01 MB/s Benchmark____GWs_Opt_4kx10x0-16 12462706 302.2 ns/op 13609.04 MB/s Benchmark____GWs_Opt_4kx10x0-16 10664845 370.6 ns/op 11094.88 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6628910 542.8 ns/op 5756.70 MB/s Benchmark____GWs_Opt_1kx01x1-16 6685656 539.2 ns/op 5795.47 MB/s Benchmark____GWs_Opt_1kx01x1-16 6766696 541.2 ns/op 5773.72 MB/s Benchmark____GWs_Opt_1kx01x1-16 6536035 536.7 ns/op 5822.71 MB/s Benchmark____GWs_Opt_1kx01x1-16 6641204 545.2 ns/op 5732.16 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4798113 748.4 ns/op 8280.33 MB/s Benchmark____GWs_Opt_2kx01x1-16 4813411 755.6 ns/op 8201.55 MB/s Benchmark____GWs_Opt_2kx01x1-16 4714786 781.9 ns/op 7925.83 MB/s Benchmark____GWs_Opt_2kx01x1-16 4658968 748.8 ns/op 8275.81 MB/s Benchmark____GWs_Opt_2kx01x1-16 4652550 759.2 ns/op 8162.10 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 1000000 3332 ns/op 3704.16 MB/s Benchmark____GWs_Opt_4kx01x1-16 2653416 1364 ns/op 9050.78 MB/s Benchmark____GWs_Opt_4kx01x1-16 2616946 1383 ns/op 8920.74 MB/s Benchmark____GWs_Opt_4kx01x1-16 2649327 1352 ns/op 9126.27 MB/s Benchmark____GWs_Opt_4kx01x1-16 2614842 1526 ns/op 8088.75 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6622063 542.6 ns/op 5759.07 MB/s Benchmark____GWs_Opt_1kx10x1-16 6682797 545.2 ns/op 5731.48 MB/s Benchmark____GWs_Opt_1kx10x1-16 6682544 538.4 ns/op 5804.56 MB/s Benchmark____GWs_Opt_1kx10x1-16 6655358 550.1 ns/op 5680.93 MB/s Benchmark____GWs_Opt_1kx10x1-16 6790934 547.8 ns/op 5705.15 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4026234 826.0 ns/op 7502.02 MB/s Benchmark____GWs_Opt_2kx10x1-16 4242949 841.2 ns/op 7367.13 MB/s Benchmark____GWs_Opt_2kx10x1-16 4403449 829.7 ns/op 7468.58 MB/s Benchmark____GWs_Opt_2kx10x1-16 4135195 837.8 ns/op 7396.80 MB/s Benchmark____GWs_Opt_2kx10x1-16 4710672 828.7 ns/op 7478.05 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2286655 1492 ns/op 8273.83 MB/s Benchmark____GWs_Opt_4kx10x1-16 2535752 1553 ns/op 7944.99 MB/s Benchmark____GWs_Opt_4kx10x1-16 2490788 1488 ns/op 8293.88 MB/s Benchmark____GWs_Opt_4kx10x1-16 2379972 1492 ns/op 8270.49 MB/s Benchmark____GWs_Opt_4kx10x1-16 2361646 1517 ns/op 8136.40 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12200680 288.8 ns/op 3601.02 MB/s Benchmark____GWs_Int_1kx01x0-16 11846883 289.7 ns/op 3590.21 MB/s Benchmark____GWs_Int_1kx01x0-16 12502366 291.3 ns/op 3570.36 MB/s Benchmark____GWs_Int_1kx01x0-16 12326074 288.6 ns/op 3603.33 MB/s Benchmark____GWs_Int_1kx01x0-16 12352300 285.4 ns/op 3643.42 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10089292 371.8 ns/op 5551.24 MB/s Benchmark____GWs_Int_2kx01x0-16 10162932 355.6 ns/op 5803.46 MB/s Benchmark____GWs_Int_2kx01x0-16 10246677 361.3 ns/op 5712.85 MB/s Benchmark____GWs_Int_2kx01x0-16 9287864 363.1 ns/op 5684.84 MB/s Benchmark____GWs_Int_2kx01x0-16 10061508 354.7 ns/op 5819.47 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5713603 644.4 ns/op 6381.59 MB/s Benchmark____GWs_Int_4kx01x0-16 5593316 648.3 ns/op 6342.94 MB/s Benchmark____GWs_Int_4kx01x0-16 5536946 636.6 ns/op 6459.16 MB/s Benchmark____GWs_Int_4kx01x0-16 5489053 649.4 ns/op 6331.71 MB/s Benchmark____GWs_Int_4kx01x0-16 5540632 679.4 ns/op 6052.09 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31904689 110.8 ns/op 9389.48 MB/s Benchmark____GWs_Int_1kx10x0-16 32737570 107.1 ns/op 9714.57 MB/s Benchmark____GWs_Int_1kx10x0-16 32089875 107.6 ns/op 9667.37 MB/s Benchmark____GWs_Int_1kx10x0-16 32558294 108.9 ns/op 9550.97 MB/s Benchmark____GWs_Int_1kx10x0-16 32196891 110.9 ns/op 9374.81 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 26585562 145.0 ns/op 14234.51 MB/s Benchmark____GWs_Int_2kx10x0-16 24819183 148.1 ns/op 13936.81 MB/s Benchmark____GWs_Int_2kx10x0-16 25921867 137.8 ns/op 14975.55 MB/s Benchmark____GWs_Int_2kx10x0-16 25459867 148.2 ns/op 13922.69 MB/s Benchmark____GWs_Int_2kx10x0-16 25061935 146.7 ns/op 14067.29 MB/s Benchmark____GWs_Int_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:36472->127.0.0.1:46169: 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:57768->127.0.0.1:33439: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12451399 289.0 ns/op 14230.19 MB/s Benchmark____GWs_Int_4kx10x0-16 12771706 295.9 ns/op 13898.60 MB/s Benchmark____GWs_Int_4kx10x0-16 13272170 311.8 ns/op 13185.97 MB/s Benchmark____GWs_Int_4kx10x0-16 12500211 295.1 ns/op 13936.33 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6630106 544.7 ns/op 5737.15 MB/s Benchmark____GWs_Int_1kx01x1-16 6536794 555.6 ns/op 5624.07 MB/s Benchmark____GWs_Int_1kx01x1-16 6525691 553.4 ns/op 5647.42 MB/s Benchmark____GWs_Int_1kx01x1-16 6601477 547.7 ns/op 5705.43 MB/s Benchmark____GWs_Int_1kx01x1-16 6443818 543.5 ns/op 5749.44 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4814540 761.0 ns/op 8142.91 MB/s Benchmark____GWs_Int_2kx01x1-16 4666796 1270 ns/op 4880.63 MB/s Benchmark____GWs_Int_2kx01x1-16 4772798 790.0 ns/op 7843.94 MB/s Benchmark____GWs_Int_2kx01x1-16 4775806 757.3 ns/op 8182.97 MB/s Benchmark____GWs_Int_2kx01x1-16 4733292 930.3 ns/op 6661.53 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2623396 1547 ns/op 7976.51 MB/s Benchmark____GWs_Int_4kx01x1-16 2639725 1376 ns/op 8965.55 MB/s Benchmark____GWs_Int_4kx01x1-16 2381756 1371 ns/op 9003.26 MB/s Benchmark____GWs_Int_4kx01x1-16 2674155 1482 ns/op 8328.27 MB/s Benchmark____GWs_Int_4kx01x1-16 2594562 1382 ns/op 8932.03 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6632736 544.1 ns/op 5743.33 MB/s Benchmark____GWs_Int_1kx10x1-16 6689518 542.5 ns/op 5760.23 MB/s Benchmark____GWs_Int_1kx10x1-16 6727538 543.2 ns/op 5752.70 MB/s Benchmark____GWs_Int_1kx10x1-16 6587446 540.9 ns/op 5777.55 MB/s Benchmark____GWs_Int_1kx10x1-16 6450667 559.8 ns/op 5582.57 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4101244 850.7 ns/op 7284.27 MB/s Benchmark____GWs_Int_2kx10x1-16 4270677 813.5 ns/op 7618.06 MB/s Benchmark____GWs_Int_2kx10x1-16 3807897 829.1 ns/op 7474.49 MB/s Benchmark____GWs_Int_2kx10x1-16 4158356 816.1 ns/op 7593.87 MB/s Benchmark____GWs_Int_2kx10x1-16 4183044 832.2 ns/op 7446.31 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2160199 1453 ns/op 8494.32 MB/s Benchmark____GWs_Int_4kx10x1-16 2291924 1473 ns/op 8380.57 MB/s Benchmark____GWs_Int_4kx10x1-16 2396811 1550 ns/op 7959.82 MB/s Benchmark____GWs_Int_4kx10x1-16 2370151 1449 ns/op 8515.61 MB/s Benchmark____GWs_Int_4kx10x1-16 2352608 1478 ns/op 8348.35 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8453922 430.7 ns/op 236.82 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8085160 434.1 ns/op 234.98 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8411986 433.1 ns/op 235.53 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8182143 426.6 ns/op 239.09 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8560221 433.8 ns/op 235.12 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 769125 4781 ns/op 37.03 MB/s Benchmark__GWs_Reqs_1SubEach-16 753805 4911 ns/op 36.04 MB/s Benchmark__GWs_Reqs_1SubEach-16 829380 5037 ns/op 35.14 MB/s Benchmark__GWs_Reqs_1SubEach-16 796908 4915 ns/op 36.01 MB/s Benchmark__GWs_Reqs_1SubEach-16 796267 5038 ns/op 35.13 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2105.449s ❌ Non-zero exit code: 1