> ROOT_DIR=/tmp/go-bench-away-job-f6bb16c9-d13b-48fb-aa47-0abef982947b-1757562077 > OUTPUT_FILE=/tmp/go-bench-away-job-f6bb16c9-d13b-48fb-aa47-0abef982947b-1757562077/results.txt > SHA_FILE=/tmp/go-bench-away-job-f6bb16c9-d13b-48fb-aa47-0abef982947b-1757562077/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-f6bb16c9-d13b-48fb-aa47-0abef982947b-1757562077/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=main > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.26.3/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: main to /tmp/go-bench-away-job-f6bb16c9-d13b-48fb-aa47-0abef982947b-1757562077/source.git SHA of main: b7aeab5cbada5fd2d9ffd8fbaab44faa172e400f Go runtime: go version go1.26.3 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build3136302074=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-f6bb16c9-d13b-48fb-aa47-0abef982947b-1757562077/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.26.3' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.26.3/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.3' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 49391092 72.94 ns/op 150.81 MB/s Benchmark______Pub0b_Payload-16 46801962 74.60 ns/op 147.45 MB/s Benchmark______Pub0b_Payload-16 46691119 72.65 ns/op 151.41 MB/s Benchmark______Pub0b_Payload-16 43494577 72.87 ns/op 150.95 MB/s Benchmark______Pub0b_Payload-16 43590564 72.65 ns/op 151.42 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 42862502 73.80 ns/op 257.45 MB/s Benchmark______Pub8b_Payload-16 46383664 73.41 ns/op 258.81 MB/s Benchmark______Pub8b_Payload-16 44885251 73.93 ns/op 256.98 MB/s Benchmark______Pub8b_Payload-16 48911767 74.31 ns/op 255.70 MB/s Benchmark______Pub8b_Payload-16 46300230 73.20 ns/op 259.55 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43544630 77.55 ns/op 567.37 MB/s Benchmark_____Pub32b_Payload-16 44232476 78.25 ns/op 562.28 MB/s Benchmark_____Pub32b_Payload-16 43973604 77.79 ns/op 565.61 MB/s Benchmark_____Pub32b_Payload-16 43957737 77.79 ns/op 565.61 MB/s Benchmark_____Pub32b_Payload-16 43943119 77.98 ns/op 564.28 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38969161 94.87 ns/op 1486.29 MB/s Benchmark____Pub128B_Payload-16 39355608 94.63 ns/op 1489.97 MB/s Benchmark____Pub128B_Payload-16 34793336 88.34 ns/op 1596.13 MB/s Benchmark____Pub128B_Payload-16 39627392 87.26 ns/op 1615.90 MB/s Benchmark____Pub128B_Payload-16 38892549 87.36 ns/op 1614.00 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 32550986 96.13 ns/op 2798.32 MB/s Benchmark____Pub256B_Payload-16 35625697 96.24 ns/op 2794.95 MB/s Benchmark____Pub256B_Payload-16 36781455 95.10 ns/op 2828.70 MB/s Benchmark____Pub256B_Payload-16 35254672 95.01 ns/op 2831.34 MB/s Benchmark____Pub256B_Payload-16 35179707 95.66 ns/op 2812.11 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24644486 137.4 ns/op 7555.40 MB/s Benchmark______Pub1K_Payload-16 24155529 143.1 ns/op 7255.58 MB/s Benchmark______Pub1K_Payload-16 24657876 142.9 ns/op 7265.98 MB/s Benchmark______Pub1K_Payload-16 24359547 142.7 ns/op 7272.71 MB/s Benchmark______Pub1K_Payload-16 23220445 137.6 ns/op 7545.88 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5445430 620.6 ns/op 6622.63 MB/s Benchmark______Pub4K_Payload-16 5755526 620.9 ns/op 6619.33 MB/s Benchmark______Pub4K_Payload-16 5681292 617.9 ns/op 6651.18 MB/s Benchmark______Pub4K_Payload-16 5361825 629.6 ns/op 6527.47 MB/s Benchmark______Pub4K_Payload-16 5695213 613.6 ns/op 6698.68 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2766973 1275 ns/op 6435.37 MB/s Benchmark______Pub8K_Payload-16 2753728 1285 ns/op 6386.59 MB/s Benchmark______Pub8K_Payload-16 2781588 1298 ns/op 6320.62 MB/s Benchmark______Pub8K_Payload-16 2795998 1289 ns/op 6365.39 MB/s Benchmark______Pub8K_Payload-16 2814967 1272 ns/op 6448.82 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 655246 5363 ns/op 6112.32 MB/s Benchmark_____Pub32K_Payload-16 654332 5293 ns/op 6193.78 MB/s Benchmark_____Pub32K_Payload-16 568154 5403 ns/op 6067.14 MB/s Benchmark_____Pub32K_Payload-16 544498 5529 ns/op 5929.50 MB/s Benchmark_____Pub32K_Payload-16 567778 5366 ns/op 6109.73 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32086543 94.74 ns/op 116.10 MB/s Benchmark__AuthPub0b_Payload-16 32236459 94.27 ns/op 116.68 MB/s Benchmark__AuthPub0b_Payload-16 32030910 94.88 ns/op 115.93 MB/s Benchmark__AuthPub0b_Payload-16 33292957 95.69 ns/op 114.95 MB/s Benchmark__AuthPub0b_Payload-16 32020630 98.53 ns/op 111.64 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15284541 230.1 ns/op Benchmark_____________PubSub-16 15377709 229.8 ns/op Benchmark_____________PubSub-16 15379634 229.8 ns/op Benchmark_____________PubSub-16 15487800 230.1 ns/op Benchmark_____________PubSub-16 15446259 230.1 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15590389 229.1 ns/op Benchmark_____PubSubTwoConns-16 15359959 228.4 ns/op Benchmark_____PubSubTwoConns-16 15509263 229.2 ns/op Benchmark_____PubSubTwoConns-16 15470972 228.4 ns/op Benchmark_____PubSubTwoConns-16 15533959 229.5 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:36796->127.0.0.1:43991: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:37060->127.0.0.1:35035: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41414->127.0.0.1:33471: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50950->127.0.0.1:33297: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:32886->127.0.0.1:34959: 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 14103168 247.5 ns/op Benchmark_____PubTwoQueueSub-16 14313650 248.1 ns/op Benchmark_____PubTwoQueueSub-16 14140143 247.5 ns/op Benchmark_____PubTwoQueueSub-16 14267178 248.0 ns/op Benchmark_____PubTwoQueueSub-16 14267086 248.4 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14425705 248.1 ns/op Benchmark____PubFourQueueSub-16 14269554 248.7 ns/op Benchmark____PubFourQueueSub-16 14312644 247.6 ns/op Benchmark____PubFourQueueSub-16 14194634 248.8 ns/op Benchmark____PubFourQueueSub-16 14273894 247.8 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14081211 248.2 ns/op Benchmark___PubEightQueueSub-16 14304950 247.9 ns/op Benchmark___PubEightQueueSub-16 14295806 248.6 ns/op Benchmark___PubEightQueueSub-16 14281488 248.3 ns/op Benchmark___PubEightQueueSub-16 14126551 250.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22018 156025 ns/op Benchmark_PubSub512kTwoConns-16 23144 155118 ns/op Benchmark_PubSub512kTwoConns-16 23191 154179 ns/op Benchmark_PubSub512kTwoConns-16 23294 166054 ns/op Benchmark_PubSub512kTwoConns-16 23121 154700 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14910463 232.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 14997583 233.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15133299 232.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15006787 232.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15013665 231.8 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14929466 233.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15096783 232.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15015363 231.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15130426 233.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15022196 233.1 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10735338 318.4 ns/op Benchmark____RoutedPubSub_0b-16 11108666 316.1 ns/op Benchmark____RoutedPubSub_0b-16 11375812 311.9 ns/op Benchmark____RoutedPubSub_0b-16 10999651 314.3 ns/op Benchmark____RoutedPubSub_0b-16 11467026 312.7 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6679017 532.7 ns/op Benchmark____RoutedPubSub_1K-16 6887432 529.2 ns/op Benchmark____RoutedPubSub_1K-16 6825222 535.9 ns/op Benchmark____RoutedPubSub_1K-16 6792486 527.6 ns/op Benchmark____RoutedPubSub_1K-16 6693721 534.9 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 86336 43619 ns/op Benchmark__RoutedPubSub_100K-16 86748 41946 ns/op Benchmark__RoutedPubSub_100K-16 87662 43194 ns/op Benchmark__RoutedPubSub_100K-16 83515 41018 ns/op Benchmark__RoutedPubSub_100K-16 84212 42434 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9764268 316.2 ns/op Benchmark____Routed2QueueSub-16 11510038 312.5 ns/op Benchmark____Routed2QueueSub-16 9825500 314.2 ns/op Benchmark____Routed2QueueSub-16 9806268 312.7 ns/op Benchmark____Routed2QueueSub-16 9918868 317.0 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9586308 319.1 ns/op Benchmark____Routed4QueueSub-16 9740394 317.8 ns/op Benchmark____Routed4QueueSub-16 9689368 320.0 ns/op Benchmark____Routed4QueueSub-16 9573261 322.7 ns/op Benchmark____Routed4QueueSub-16 9547897 327.1 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9147894 334.5 ns/op Benchmark____Routed8QueueSub-16 11163134 327.0 ns/op Benchmark____Routed8QueueSub-16 9309270 330.3 ns/op Benchmark____Routed8QueueSub-16 11087506 322.0 ns/op Benchmark____Routed8QueueSub-16 10929428 327.5 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8836352 346.9 ns/op Benchmark___Routed16QueueSub-16 10458015 347.6 ns/op Benchmark___Routed16QueueSub-16 9104972 348.6 ns/op Benchmark___Routed16QueueSub-16 8963851 345.9 ns/op Benchmark___Routed16QueueSub-16 9021292 346.0 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6402828 556.3 ns/op Benchmark____________RouteCompressOff-16 6314833 556.7 ns/op Benchmark____________RouteCompressOff-16 6320355 552.8 ns/op Benchmark____________RouteCompressOff-16 6340210 555.8 ns/op Benchmark____________RouteCompressOff-16 6147202 552.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6374298 554.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6461733 554.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6395358 559.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6397442 549.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6368800 553.0 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6397974 552.6 ns/op Benchmark_________RouteCompressS2Fast-16 6382770 552.2 ns/op Benchmark_________RouteCompressS2Fast-16 6379600 565.6 ns/op Benchmark_________RouteCompressS2Fast-16 6420525 555.7 ns/op Benchmark_________RouteCompressS2Fast-16 6340795 552.8 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6539982 557.4 ns/op Benchmark_______RouteCompressS2Better-16 6585892 557.1 ns/op Benchmark_______RouteCompressS2Better-16 6327228 557.7 ns/op Benchmark_______RouteCompressS2Better-16 6137296 558.0 ns/op Benchmark_______RouteCompressS2Better-16 6321190 544.4 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6352243 559.0 ns/op Benchmark_________RouteCompressS2Best-16 6443092 549.2 ns/op Benchmark_________RouteCompressS2Best-16 6496824 551.8 ns/op Benchmark_________RouteCompressS2Best-16 6527078 552.3 ns/op Benchmark_________RouteCompressS2Best-16 6337888 548.7 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4638300 771.8 ns/op 322.60 MB/s Benchmark______FanOut_8x1x10-16 4652211 770.2 ns/op 323.30 MB/s Benchmark______FanOut_8x1x10-16 4634697 770.7 ns/op 323.09 MB/s Benchmark______FanOut_8x1x10-16 4594111 773.2 ns/op 322.04 MB/s Benchmark______FanOut_8x1x10-16 4643721 772.6 ns/op 322.28 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 567296 6097 ns/op 380.38 MB/s Benchmark_____FanOut_8x1x100-16 568668 6058 ns/op 382.83 MB/s Benchmark_____FanOut_8x1x100-16 564300 6121 ns/op 378.88 MB/s Benchmark_____FanOut_8x1x100-16 558415 6103 ns/op 379.95 MB/s Benchmark_____FanOut_8x1x100-16 547814 6126 ns/op 378.57 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47467 75276 ns/op 305.79 MB/s Benchmark____FanOut_8x10x100-16 48268 74935 ns/op 307.19 MB/s Benchmark____FanOut_8x10x100-16 48340 74615 ns/op 308.50 MB/s Benchmark____FanOut_8x10x100-16 48060 75230 ns/op 305.98 MB/s Benchmark____FanOut_8x10x100-16 48002 74952 ns/op 307.12 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6034 594507 ns/op 403.73 MB/s Benchmark___FanOut_8x10x1000-16 5985 592022 ns/op 405.42 MB/s Benchmark___FanOut_8x10x1000-16 5930 592010 ns/op 405.43 MB/s Benchmark___FanOut_8x10x1000-16 5935 594229 ns/op 403.92 MB/s Benchmark___FanOut_8x10x1000-16 5472 592145 ns/op 405.34 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5097 702701 ns/op 327.34 MB/s Benchmark___FanOut_8x100x100-16 4999 701957 ns/op 327.68 MB/s Benchmark___FanOut_8x100x100-16 5088 705572 ns/op 326.00 MB/s Benchmark___FanOut_8x100x100-16 5089 702071 ns/op 327.63 MB/s Benchmark___FanOut_8x100x100-16 5030 710588 ns/op 323.70 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 560 6095706 ns/op 393.72 MB/s Benchmark__FanOut_8x100x1000-16 585 6109242 ns/op 392.85 MB/s Benchmark__FanOut_8x100x1000-16 580 6079767 ns/op 394.76 MB/s Benchmark__FanOut_8x100x1000-16 541 6069318 ns/op 395.43 MB/s Benchmark__FanOut_8x100x1000-16 584 6110851 ns/op 392.75 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 549 6672534 ns/op 374.67 MB/s Benchmark__FanOut_8x10x10000-16 542 6628150 ns/op 377.18 MB/s Benchmark__FanOut_8x10x10000-16 514 6685797 ns/op 373.93 MB/s Benchmark__FanOut_8x10x10000-16 540 6586586 ns/op 379.56 MB/s Benchmark__FanOut_8x10x10000-16 550 6744034 ns/op 370.70 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 958 3725290 ns/op 308.71 MB/s Benchmark___FanOut_8x500x100-16 938 3747010 ns/op 306.92 MB/s Benchmark___FanOut_8x500x100-16 954 3728801 ns/op 308.42 MB/s Benchmark___FanOut_8x500x100-16 958 3725402 ns/op 308.70 MB/s Benchmark___FanOut_8x500x100-16 961 3728675 ns/op 308.43 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 358161 9467 ns/op 1546.58 MB/s Benchmark___FanOut_128x1x100-16 356971 9450 ns/op 1549.32 MB/s Benchmark___FanOut_128x1x100-16 361536 9467 ns/op 1546.52 MB/s Benchmark___FanOut_128x1x100-16 363903 9505 ns/op 1540.30 MB/s Benchmark___FanOut_128x1x100-16 367552 9464 ns/op 1547.01 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32450 110848 ns/op 1309.38 MB/s Benchmark__FanOut_128x10x100-16 32709 110583 ns/op 1312.51 MB/s Benchmark__FanOut_128x10x100-16 32618 110822 ns/op 1309.67 MB/s Benchmark__FanOut_128x10x100-16 32617 109149 ns/op 1329.75 MB/s Benchmark__FanOut_128x10x100-16 32776 109667 ns/op 1323.47 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4147 864136 ns/op 1689.71 MB/s Benchmark_FanOut_128x10x1000-16 4138 858853 ns/op 1700.11 MB/s Benchmark_FanOut_128x10x1000-16 4136 872448 ns/op 1673.61 MB/s Benchmark_FanOut_128x10x1000-16 3943 861932 ns/op 1694.03 MB/s Benchmark_FanOut_128x10x1000-16 4047 855387 ns/op 1707.00 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3524 998224 ns/op 1452.72 MB/s Benchmark_FanOut_128x100x100-16 3519 998638 ns/op 1452.12 MB/s Benchmark_FanOut_128x100x100-16 3550 1005362 ns/op 1442.41 MB/s Benchmark_FanOut_128x100x100-16 3528 1003119 ns/op 1445.63 MB/s Benchmark_FanOut_128x100x100-16 3550 1005744 ns/op 1441.86 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 390 9232702 ns/op 1581.35 MB/s BenchmarkFanOut_128x100x1000-16 384 9263938 ns/op 1576.02 MB/s BenchmarkFanOut_128x100x1000-16 386 9177425 ns/op 1590.88 MB/s BenchmarkFanOut_128x100x1000-16 391 9203036 ns/op 1586.45 MB/s BenchmarkFanOut_128x100x1000-16 382 9180768 ns/op 1590.30 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 375 9599334 ns/op 1531.37 MB/s BenchmarkFanOut_128x10x10000-16 375 9529761 ns/op 1542.55 MB/s BenchmarkFanOut_128x10x10000-16 374 9566539 ns/op 1536.62 MB/s BenchmarkFanOut_128x10x10000-16 376 9625245 ns/op 1527.25 MB/s BenchmarkFanOut_128x10x10000-16 374 9613790 ns/op 1529.07 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 666 5263474 ns/op 1377.44 MB/s BenchmarkFanOut__128x500x100-16 685 5286246 ns/op 1371.51 MB/s BenchmarkFanOut__128x500x100-16 686 5229607 ns/op 1386.36 MB/s BenchmarkFanOut__128x500x100-16 670 5248617 ns/op 1381.34 MB/s BenchmarkFanOut__128x500x100-16 673 5246893 ns/op 1381.80 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1906 1831390 ns/op 2888.80 MB/s Benchmark_FanOut_512x100x100-16 1916 1833882 ns/op 2884.88 MB/s Benchmark_FanOut_512x100x100-16 1906 1827238 ns/op 2895.37 MB/s Benchmark_FanOut_512x100x100-16 1963 1820748 ns/op 2905.69 MB/s Benchmark_FanOut_512x100x100-16 1953 1837585 ns/op 2879.06 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 218 16834059 ns/op 3148.41 MB/s Benchmark__FanOut_512x100x1k-16 213 16616289 ns/op 3189.67 MB/s Benchmark__FanOut_512x100x1k-16 214 16577608 ns/op 3197.12 MB/s Benchmark__FanOut_512x100x1k-16 216 16814883 ns/op 3152.00 MB/s Benchmark__FanOut_512x100x1k-16 214 16709798 ns/op 3171.82 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3003 1152074 ns/op 9054.14 MB/s Benchmark____FanOut_1kx10x1k-16 3211 1150120 ns/op 9069.52 MB/s Benchmark____FanOut_1kx10x1k-16 2769 1162639 ns/op 8971.86 MB/s Benchmark____FanOut_1kx10x1k-16 3019 1142206 ns/op 9132.36 MB/s Benchmark____FanOut_1kx10x1k-16 2757 1137012 ns/op 9174.08 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2829 1242455 ns/op 8387.46 MB/s Benchmark__FanOut_1kx100x100-16 2748 1248784 ns/op 8344.95 MB/s Benchmark__FanOut_1kx100x100-16 2812 1259147 ns/op 8276.27 MB/s Benchmark__FanOut_1kx100x100-16 2863 1248180 ns/op 8348.98 MB/s Benchmark__FanOut_1kx100x100-16 2764 1248117 ns/op 8349.41 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4567401 764.5 ns/op 325.72 MB/s Benchmark_____RFanOut_8x1x10-16 4445685 793.4 ns/op 313.85 MB/s Benchmark_____RFanOut_8x1x10-16 4362718 792.4 ns/op 314.22 MB/s Benchmark_____RFanOut_8x1x10-16 4477038 781.9 ns/op 318.46 MB/s Benchmark_____RFanOut_8x1x10-16 4529454 794.8 ns/op 313.29 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 538666 6128 ns/op 378.43 MB/s Benchmark____RFanOut_8x1x100-16 513908 6022 ns/op 385.06 MB/s Benchmark____RFanOut_8x1x100-16 530356 6286 ns/op 368.89 MB/s Benchmark____RFanOut_8x1x100-16 562398 6318 ns/op 367.06 MB/s Benchmark____RFanOut_8x1x100-16 528120 6034 ns/op 384.35 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48604 75047 ns/op 306.73 MB/s Benchmark___RFanOut_8x10x100-16 48021 74121 ns/op 310.56 MB/s Benchmark___RFanOut_8x10x100-16 47992 74235 ns/op 310.08 MB/s Benchmark___RFanOut_8x10x100-16 48164 74376 ns/op 309.50 MB/s Benchmark___RFanOut_8x10x100-16 48147 74572 ns/op 308.68 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6061 591944 ns/op 405.48 MB/s Benchmark__RFanOut_8x10x1000-16 5866 600230 ns/op 399.88 MB/s Benchmark__RFanOut_8x10x1000-16 5786 605606 ns/op 396.33 MB/s Benchmark__RFanOut_8x10x1000-16 5718 594375 ns/op 403.82 MB/s Benchmark__RFanOut_8x10x1000-16 5902 595192 ns/op 403.26 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4992 703592 ns/op 326.92 MB/s Benchmark__RFanOut_8x100x100-16 5070 704241 ns/op 326.62 MB/s Benchmark__RFanOut_8x100x100-16 5032 702574 ns/op 327.39 MB/s Benchmark__RFanOut_8x100x100-16 5000 702799 ns/op 327.29 MB/s Benchmark__RFanOut_8x100x100-16 4995 704505 ns/op 326.50 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 586 6078328 ns/op 394.85 MB/s Benchmark_RFanOut_8x100x1000-16 579 6151447 ns/op 390.16 MB/s Benchmark_RFanOut_8x100x1000-16 579 6081640 ns/op 394.63 MB/s Benchmark_RFanOut_8x100x1000-16 579 6108883 ns/op 392.87 MB/s Benchmark_RFanOut_8x100x1000-16 586 6103104 ns/op 393.25 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 547 6694406 ns/op 373.45 MB/s Benchmark_RFanOut_8x10x10000-16 537 6612442 ns/op 378.08 MB/s Benchmark_RFanOut_8x10x10000-16 530 6660542 ns/op 375.35 MB/s Benchmark_RFanOut_8x10x10000-16 528 6736537 ns/op 371.11 MB/s Benchmark_RFanOut_8x10x10000-16 537 6676610 ns/op 374.44 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3094 1143978 ns/op 9118.22 MB/s Benchmark_RFanOut_1kx10x1000-16 3020 1168211 ns/op 8929.07 MB/s Benchmark_RFanOut_1kx10x1000-16 3172 1158027 ns/op 9007.59 MB/s Benchmark_RFanOut_1kx10x1000-16 3121 1151502 ns/op 9058.63 MB/s Benchmark_RFanOut_1kx10x1000-16 3063 1130892 ns/op 9223.72 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6945015 501.8 ns/op 4140.95 MB/s Benchmark_____FanIn_1kx100x1-16 6965704 505.2 ns/op 4113.05 MB/s Benchmark_____FanIn_1kx100x1-16 6926976 504.8 ns/op 4116.18 MB/s Benchmark_____FanIn_1kx100x1-16 6996106 506.4 ns/op 4103.26 MB/s Benchmark_____FanIn_1kx100x1-16 6971486 504.5 ns/op 4118.85 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2552418 1361 ns/op 6040.48 MB/s Benchmark_____FanIn_4kx100x1-16 2664930 1369 ns/op 6005.40 MB/s Benchmark_____FanIn_4kx100x1-16 2641210 1364 ns/op 6026.79 MB/s Benchmark_____FanIn_4kx100x1-16 2612238 1351 ns/op 6084.60 MB/s Benchmark_____FanIn_4kx100x1-16 2632696 1360 ns/op 6046.27 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1712643 2111 ns/op 7776.67 MB/s Benchmark_____FanIn_8kx100x1-16 1711297 2113 ns/op 7767.88 MB/s Benchmark_____FanIn_8kx100x1-16 1704518 2087 ns/op 7865.15 MB/s Benchmark_____FanIn_8kx100x1-16 1689430 2092 ns/op 7846.50 MB/s Benchmark_____FanIn_8kx100x1-16 1711886 2089 ns/op 7857.81 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 862484 4175 ns/op 7855.89 MB/s Benchmark____FanIn_16kx100x1-16 866290 4147 ns/op 7908.54 MB/s Benchmark____FanIn_16kx100x1-16 877112 4193 ns/op 7822.04 MB/s Benchmark____FanIn_16kx100x1-16 851636 4100 ns/op 7999.72 MB/s Benchmark____FanIn_16kx100x1-16 878787 4154 ns/op 7896.72 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 159217 19951 ns/op 6571.42 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1465437315 vs 10842466200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38298->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:38898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39018->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 166712 19896 ns/op 6589.42 MB/s Benchmark____FanIn_64kx100x1-16 173912 19963 ns/op 6567.45 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7419288540 vs 11130899400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39078->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1250991870 vs 11981626000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42008->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41720->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41838->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42018->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41588->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 2230234170 vs 11535920000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44374->127.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:44016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44004->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:44398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44508->127.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:44746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44312->127.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:44248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44710->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 988287510 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46708->127.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:45880->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: 167270840 vs 11221304000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48872->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: 255494410 vs 1310900000 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: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:50570->127.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:50534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50954->127.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:51022->127.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:50704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50612->127.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:50584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50600->127.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: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: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:51434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51416->127.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:51208->127.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:50624->127.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:51404->127.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:50962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50792->127.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:50972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51388->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51332->127.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:50696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51280->127.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:50778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50990->127.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:51054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51396->127.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:51318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50520->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5622640 643.4 ns/op 441.40 MB/s Benchmark___BumpPubCount_1x3-16 5539797 643.2 ns/op 441.51 MB/s Benchmark___BumpPubCount_1x3-16 5508255 643.9 ns/op 441.08 MB/s Benchmark___BumpPubCount_1x3-16 5551971 642.2 ns/op 442.25 MB/s Benchmark___BumpPubCount_1x3-16 5538050 642.2 ns/op 442.21 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5259225 677.8 ns/op 419.03 MB/s Benchmark___BumpPubCount_2x3-16 5232608 673.5 ns/op 421.69 MB/s Benchmark___BumpPubCount_2x3-16 5302198 677.4 ns/op 419.23 MB/s Benchmark___BumpPubCount_2x3-16 5279574 675.3 ns/op 420.55 MB/s Benchmark___BumpPubCount_2x3-16 5298345 671.2 ns/op 423.14 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5404698 648.0 ns/op 438.27 MB/s Benchmark___BumpPubCount_5x3-16 5479306 644.3 ns/op 440.80 MB/s Benchmark___BumpPubCount_5x3-16 5566214 642.6 ns/op 441.94 MB/s Benchmark___BumpPubCount_5x3-16 5517402 646.6 ns/op 439.19 MB/s Benchmark___BumpPubCount_5x3-16 5585781 642.9 ns/op 441.77 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5597384 644.7 ns/op 440.49 MB/s Benchmark__BumpPubCount_10x3-16 5611975 642.6 ns/op 441.97 MB/s Benchmark__BumpPubCount_10x3-16 5588920 640.9 ns/op 443.13 MB/s Benchmark__BumpPubCount_10x3-16 5578196 644.0 ns/op 441.00 MB/s Benchmark__BumpPubCount_10x3-16 5276689 642.6 ns/op 441.99 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12271658 285.6 ns/op 3641.59 MB/s Benchmark____GWs_Opt_1kx01x0-16 13109904 291.4 ns/op 3568.75 MB/s Benchmark____GWs_Opt_1kx01x0-16 12424035 270.9 ns/op 3839.69 MB/s Benchmark____GWs_Opt_1kx01x0-16 12114247 273.8 ns/op 3798.27 MB/s Benchmark____GWs_Opt_1kx01x0-16 12331197 275.3 ns/op 3778.17 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10181215 330.0 ns/op 6255.44 MB/s Benchmark____GWs_Opt_2kx01x0-16 10235284 336.6 ns/op 6132.11 MB/s Benchmark____GWs_Opt_2kx01x0-16 9991150 343.3 ns/op 6012.71 MB/s Benchmark____GWs_Opt_2kx01x0-16 9717583 331.5 ns/op 6225.73 MB/s Benchmark____GWs_Opt_2kx01x0-16 10989226 339.1 ns/op 6086.83 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5963272 614.5 ns/op 6691.86 MB/s Benchmark____GWs_Opt_4kx01x0-16 5974575 614.8 ns/op 6688.13 MB/s Benchmark____GWs_Opt_4kx01x0-16 5030156 629.4 ns/op 6533.36 MB/s Benchmark____GWs_Opt_4kx01x0-16 5515292 634.2 ns/op 6484.07 MB/s Benchmark____GWs_Opt_4kx01x0-16 5771647 591.1 ns/op 6956.40 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30139736 112.6 ns/op 9237.93 MB/s Benchmark____GWs_Opt_1kx10x0-16 30359972 114.1 ns/op 9116.95 MB/s Benchmark____GWs_Opt_1kx10x0-16 30128054 111.2 ns/op 9351.89 MB/s Benchmark____GWs_Opt_1kx10x0-16 31038133 112.6 ns/op 9238.94 MB/s Benchmark____GWs_Opt_1kx10x0-16 31725110 111.5 ns/op 9327.72 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 22973755 146.6 ns/op 14076.48 MB/s Benchmark____GWs_Opt_2kx10x0-16 25356300 149.2 ns/op 13829.34 MB/s Benchmark____GWs_Opt_2kx10x0-16 24487494 152.1 ns/op 13570.50 MB/s Benchmark____GWs_Opt_2kx10x0-16 21361390 174.5 ns/op 11825.99 MB/s Benchmark____GWs_Opt_2kx10x0-16 22143522 143.6 ns/op 14374.31 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 10058335 313.6 ns/op 13113.61 MB/s Benchmark____GWs_Opt_4kx10x0-16 12505964 340.1 ns/op 12090.09 MB/s Benchmark____GWs_Opt_4kx10x0-16 12191277 333.6 ns/op 12325.90 MB/s Benchmark____GWs_Opt_4kx10x0-16 12218337 294.8 ns/op 13946.72 MB/s Benchmark____GWs_Opt_4kx10x0-16 11220722 305.6 ns/op 13454.19 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6613136 544.3 ns/op 5741.67 MB/s Benchmark____GWs_Opt_1kx01x1-16 6782443 538.5 ns/op 5802.98 MB/s Benchmark____GWs_Opt_1kx01x1-16 6464355 547.8 ns/op 5705.01 MB/s Benchmark____GWs_Opt_1kx01x1-16 6250777 542.0 ns/op 5765.80 MB/s Benchmark____GWs_Opt_1kx01x1-16 6413024 539.7 ns/op 5789.72 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4543917 797.0 ns/op 7775.20 MB/s Benchmark____GWs_Opt_2kx01x1-16 4853770 755.7 ns/op 8200.08 MB/s Benchmark____GWs_Opt_2kx01x1-16 4675278 738.5 ns/op 8391.55 MB/s Benchmark____GWs_Opt_2kx01x1-16 4713117 759.9 ns/op 8154.65 MB/s Benchmark____GWs_Opt_2kx01x1-16 4672646 749.5 ns/op 8268.49 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2592126 1351 ns/op 9136.73 MB/s Benchmark____GWs_Opt_4kx01x1-16 2230120 1376 ns/op 8966.00 MB/s Benchmark____GWs_Opt_4kx01x1-16 2658518 1360 ns/op 9075.53 MB/s Benchmark____GWs_Opt_4kx01x1-16 2687098 1356 ns/op 9100.92 MB/s Benchmark____GWs_Opt_4kx01x1-16 2306361 1355 ns/op 9106.53 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6387783 554.0 ns/op 5640.65 MB/s Benchmark____GWs_Opt_1kx10x1-16 6655316 548.5 ns/op 5697.06 MB/s Benchmark____GWs_Opt_1kx10x1-16 6510134 552.2 ns/op 5659.55 MB/s Benchmark____GWs_Opt_1kx10x1-16 6445989 540.9 ns/op 5777.43 MB/s Benchmark____GWs_Opt_1kx10x1-16 6139915 556.6 ns/op 5614.90 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4157679 840.3 ns/op 7374.99 MB/s Benchmark____GWs_Opt_2kx10x1-16 4270884 838.8 ns/op 7387.59 MB/s Benchmark____GWs_Opt_2kx10x1-16 4245289 836.5 ns/op 7408.63 MB/s Benchmark____GWs_Opt_2kx10x1-16 4324498 783.9 ns/op 7905.09 MB/s Benchmark____GWs_Opt_2kx10x1-16 4267552 830.2 ns/op 7464.21 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2260646 1503 ns/op 8211.25 MB/s Benchmark____GWs_Opt_4kx10x1-16 2288994 1523 ns/op 8103.72 MB/s Benchmark____GWs_Opt_4kx10x1-16 2327967 1498 ns/op 8237.38 MB/s Benchmark____GWs_Opt_4kx10x1-16 2327748 1504 ns/op 8205.09 MB/s Benchmark____GWs_Opt_4kx10x1-16 2146302 1642 ns/op 7515.62 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12190146 299.9 ns/op 3468.08 MB/s Benchmark____GWs_Int_1kx01x0-16 11395406 297.4 ns/op 3496.88 MB/s Benchmark____GWs_Int_1kx01x0-16 12526341 294.0 ns/op 3537.50 MB/s Benchmark____GWs_Int_1kx01x0-16 12268628 295.0 ns/op 3525.98 MB/s Benchmark____GWs_Int_1kx01x0-16 11324260 286.9 ns/op 3624.35 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9857179 358.3 ns/op 5760.48 MB/s Benchmark____GWs_Int_2kx01x0-16 10524975 361.9 ns/op 5703.27 MB/s Benchmark____GWs_Int_2kx01x0-16 9723518 348.3 ns/op 5925.33 MB/s Benchmark____GWs_Int_2kx01x0-16 10121475 349.4 ns/op 5907.22 MB/s Benchmark____GWs_Int_2kx01x0-16 9363020 389.2 ns/op 5303.84 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5628544 642.1 ns/op 6404.15 MB/s Benchmark____GWs_Int_4kx01x0-16 5729839 633.8 ns/op 6488.21 MB/s Benchmark____GWs_Int_4kx01x0-16 5415158 629.7 ns/op 6530.43 MB/s Benchmark____GWs_Int_4kx01x0-16 5228433 640.8 ns/op 6417.03 MB/s Benchmark____GWs_Int_4kx01x0-16 5573174 632.5 ns/op 6500.74 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31412182 114.6 ns/op 9072.40 MB/s Benchmark____GWs_Int_1kx10x0-16 30209924 112.1 ns/op 9280.72 MB/s Benchmark____GWs_Int_1kx10x0-16 31410889 113.4 ns/op 9169.52 MB/s Benchmark____GWs_Int_1kx10x0-16 32411401 116.0 ns/op 8967.64 MB/s Benchmark____GWs_Int_1kx10x0-16 32186835 111.6 ns/op 9320.33 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25347700 146.3 ns/op 14110.49 MB/s Benchmark____GWs_Int_2kx10x0-16 25241976 138.8 ns/op 14870.88 MB/s Benchmark____GWs_Int_2kx10x0-16 24706350 143.1 ns/op 14423.29 MB/s Benchmark____GWs_Int_2kx10x0-16 25498771 152.3 ns/op 13552.31 MB/s Benchmark____GWs_Int_2kx10x0-16 26251418 161.2 ns/op 12802.70 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13283055 297.7 ns/op 13812.02 MB/s Benchmark____GWs_Int_4kx10x0-16 13159880 295.7 ns/op 13905.99 MB/s Benchmark____GWs_Int_4kx10x0-16 10597138 321.7 ns/op 12783.10 MB/s Benchmark____GWs_Int_4kx10x0-16 13288196 278.5 ns/op 14766.24 MB/s Benchmark____GWs_Int_4kx10x0-16 12546625 317.3 ns/op 12960.82 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6484525 549.0 ns/op 5692.41 MB/s Benchmark____GWs_Int_1kx01x1-16 6531476 555.9 ns/op 5621.66 MB/s Benchmark____GWs_Int_1kx01x1-16 6435562 551.1 ns/op 5670.19 MB/s Benchmark____GWs_Int_1kx01x1-16 6456111 551.4 ns/op 5667.32 MB/s Benchmark____GWs_Int_1kx01x1-16 6585823 556.7 ns/op 5613.15 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4726502 757.4 ns/op 8181.59 MB/s Benchmark____GWs_Int_2kx01x1-16 4421293 765.2 ns/op 8098.96 MB/s Benchmark____GWs_Int_2kx01x1-16 4734822 909.3 ns/op 6815.39 MB/s Benchmark____GWs_Int_2kx01x1-16 4692783 748.7 ns/op 8276.73 MB/s Benchmark____GWs_Int_2kx01x1-16 4685710 757.9 ns/op 8176.63 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2658309 1399 ns/op 8818.45 MB/s Benchmark____GWs_Int_4kx01x1-16 2660404 1498 ns/op 8237.93 MB/s Benchmark____GWs_Int_4kx01x1-16 2650555 1369 ns/op 9012.77 MB/s Benchmark____GWs_Int_4kx01x1-16 1000000 3537 ns/op 3488.77 MB/s Benchmark____GWs_Int_4kx01x1-16 2645402 1379 ns/op 8952.41 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6654050 554.1 ns/op 5639.72 MB/s Benchmark____GWs_Int_1kx10x1-16 6123360 553.9 ns/op 5641.80 MB/s Benchmark____GWs_Int_1kx10x1-16 6571574 554.7 ns/op 5634.10 MB/s Benchmark____GWs_Int_1kx10x1-16 6231970 552.8 ns/op 5652.57 MB/s Benchmark____GWs_Int_1kx10x1-16 6432699 548.8 ns/op 5694.69 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4102417 1353 ns/op 4580.97 MB/s Benchmark____GWs_Int_2kx10x1-16 4141058 873.3 ns/op 7096.35 MB/s Benchmark____GWs_Int_2kx10x1-16 4174159 863.1 ns/op 7179.55 MB/s Benchmark____GWs_Int_2kx10x1-16 4253464 838.5 ns/op 7390.70 MB/s Benchmark____GWs_Int_2kx10x1-16 4200182 894.7 ns/op 6926.17 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2427274 1502 ns/op 8214.54 MB/s Benchmark____GWs_Int_4kx10x1-16 2423332 1527 ns/op 8083.59 MB/s Benchmark____GWs_Int_4kx10x1-16 2393007 1751 ns/op 7049.86 MB/s Benchmark____GWs_Int_4kx10x1-16 2451114 1597 ns/op 7729.35 MB/s Benchmark____GWs_Int_4kx10x1-16 2285209 1465 ns/op 8426.45 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8382291 437.8 ns/op 232.98 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8255810 429.6 ns/op 237.43 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8233068 434.8 ns/op 234.58 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8344189 433.1 ns/op 235.51 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8238668 434.8 ns/op 234.62 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 607402 5040 ns/op 35.12 MB/s Benchmark__GWs_Reqs_1SubEach-16 778063 5259 ns/op 33.66 MB/s Benchmark__GWs_Reqs_1SubEach-16 728677 5215 ns/op 33.94 MB/s Benchmark__GWs_Reqs_1SubEach-16 752694 5290 ns/op 33.46 MB/s Benchmark__GWs_Reqs_1SubEach-16 761821 5267 ns/op 33.61 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2074.484s ❌ Non-zero exit code: 1