> ROOT_DIR=/tmp/go-bench-away-job-0c4a23e2-12db-43aa-ab6d-441b8fa8500c-2303488129 > OUTPUT_FILE=/tmp/go-bench-away-job-0c4a23e2-12db-43aa-ab6d-441b8fa8500c-2303488129/results.txt > SHA_FILE=/tmp/go-bench-away-job-0c4a23e2-12db-43aa-ab6d-441b8fa8500c-2303488129/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-0c4a23e2-12db-43aa-ab6d-441b8fa8500c-2303488129/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-0c4a23e2-12db-43aa-ab6d-441b8fa8500c-2303488129/source.git SHA of main: ccd898ea86accf40861f1dd651df8e7fb9c0e5f3 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-build2738332769=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-0c4a23e2-12db-43aa-ab6d-441b8fa8500c-2303488129/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 48771580 73.84 ns/op 148.97 MB/s Benchmark______Pub0b_Payload-16 46036364 73.98 ns/op 148.69 MB/s Benchmark______Pub0b_Payload-16 43088221 73.86 ns/op 148.94 MB/s Benchmark______Pub0b_Payload-16 45950906 73.85 ns/op 148.95 MB/s Benchmark______Pub0b_Payload-16 46281649 74.05 ns/op 148.55 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 48271248 74.26 ns/op 255.86 MB/s Benchmark______Pub8b_Payload-16 44864948 74.40 ns/op 255.37 MB/s Benchmark______Pub8b_Payload-16 45487770 74.61 ns/op 254.66 MB/s Benchmark______Pub8b_Payload-16 48437878 74.51 ns/op 254.99 MB/s Benchmark______Pub8b_Payload-16 45673506 77.79 ns/op 244.25 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43641015 78.85 ns/op 558.02 MB/s Benchmark_____Pub32b_Payload-16 43417380 80.96 ns/op 543.49 MB/s Benchmark_____Pub32b_Payload-16 43541672 78.98 ns/op 557.10 MB/s Benchmark_____Pub32b_Payload-16 43682106 79.23 ns/op 555.35 MB/s Benchmark_____Pub32b_Payload-16 43581969 78.74 ns/op 558.80 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 37762935 88.07 ns/op 1601.06 MB/s Benchmark____Pub128B_Payload-16 34385248 91.53 ns/op 1540.55 MB/s Benchmark____Pub128B_Payload-16 38915764 88.42 ns/op 1594.58 MB/s Benchmark____Pub128B_Payload-16 39171447 88.15 ns/op 1599.49 MB/s Benchmark____Pub128B_Payload-16 38671467 88.47 ns/op 1593.85 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36018294 97.64 ns/op 2754.96 MB/s Benchmark____Pub256B_Payload-16 31495389 97.25 ns/op 2766.01 MB/s Benchmark____Pub256B_Payload-16 37354314 98.11 ns/op 2741.91 MB/s Benchmark____Pub256B_Payload-16 36173842 96.57 ns/op 2785.63 MB/s Benchmark____Pub256B_Payload-16 35705553 96.09 ns/op 2799.53 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25305526 138.2 ns/op 7510.78 MB/s Benchmark______Pub1K_Payload-16 23407699 146.2 ns/op 7102.06 MB/s Benchmark______Pub1K_Payload-16 23915046 139.7 ns/op 7429.72 MB/s Benchmark______Pub1K_Payload-16 25055186 137.6 ns/op 7543.99 MB/s Benchmark______Pub1K_Payload-16 26712960 137.2 ns/op 7565.97 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5619865 612.3 ns/op 6712.82 MB/s Benchmark______Pub4K_Payload-16 5694322 618.8 ns/op 6641.55 MB/s Benchmark______Pub4K_Payload-16 5644861 624.2 ns/op 6584.34 MB/s Benchmark______Pub4K_Payload-16 5660138 612.7 ns/op 6707.74 MB/s Benchmark______Pub4K_Payload-16 5801176 613.9 ns/op 6694.47 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2754649 1271 ns/op 6454.71 MB/s Benchmark______Pub8K_Payload-16 2716826 1273 ns/op 6443.95 MB/s Benchmark______Pub8K_Payload-16 2707764 1264 ns/op 6492.02 MB/s Benchmark______Pub8K_Payload-16 2808541 1285 ns/op 6385.35 MB/s Benchmark______Pub8K_Payload-16 2789576 1266 ns/op 6482.75 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 611455 5362 ns/op 6113.80 MB/s Benchmark_____Pub32K_Payload-16 585385 5475 ns/op 5987.45 MB/s Benchmark_____Pub32K_Payload-16 501056 6089 ns/op 5383.57 MB/s Benchmark_____Pub32K_Payload-16 661050 5385 ns/op 6088.00 MB/s Benchmark_____Pub32K_Payload-16 574911 5499 ns/op 5962.04 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31927068 96.10 ns/op 114.46 MB/s Benchmark__AuthPub0b_Payload-16 30577904 100.2 ns/op 109.78 MB/s Benchmark__AuthPub0b_Payload-16 31815408 95.25 ns/op 115.48 MB/s Benchmark__AuthPub0b_Payload-16 32253735 96.41 ns/op 114.10 MB/s Benchmark__AuthPub0b_Payload-16 35881521 97.59 ns/op 112.71 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15630265 227.4 ns/op Benchmark_____________PubSub-16 15590982 227.5 ns/op Benchmark_____________PubSub-16 15705007 227.4 ns/op Benchmark_____________PubSub-16 15696296 229.0 ns/op Benchmark_____________PubSub-16 15560126 227.7 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15716523 226.3 ns/op Benchmark_____PubSubTwoConns-16 15681430 225.8 ns/op Benchmark_____PubSubTwoConns-16 15664208 226.3 ns/op Benchmark_____PubSubTwoConns-16 15685028 226.4 ns/op Benchmark_____PubSubTwoConns-16 15605749 225.1 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46148->127.0.0.1:38239: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:52478->127.0.0.1:33367: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42170->127.0.0.1:34441: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:44312->127.0.0.1:40549: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58446->127.0.0.1:41371: 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 14425647 246.7 ns/op Benchmark_____PubTwoQueueSub-16 14297257 247.1 ns/op Benchmark_____PubTwoQueueSub-16 14361324 246.9 ns/op Benchmark_____PubTwoQueueSub-16 14249319 247.0 ns/op Benchmark_____PubTwoQueueSub-16 14230522 247.1 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14187223 247.6 ns/op Benchmark____PubFourQueueSub-16 14265872 247.1 ns/op Benchmark____PubFourQueueSub-16 14419256 247.4 ns/op Benchmark____PubFourQueueSub-16 14315835 248.1 ns/op Benchmark____PubFourQueueSub-16 14233986 247.3 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14430133 247.6 ns/op Benchmark___PubEightQueueSub-16 14329752 247.7 ns/op Benchmark___PubEightQueueSub-16 14264278 247.4 ns/op Benchmark___PubEightQueueSub-16 14223885 248.4 ns/op Benchmark___PubEightQueueSub-16 14456550 247.3 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23439 155123 ns/op Benchmark_PubSub512kTwoConns-16 22959 154229 ns/op Benchmark_PubSub512kTwoConns-16 23169 154705 ns/op Benchmark_PubSub512kTwoConns-16 22952 154942 ns/op Benchmark_PubSub512kTwoConns-16 23305 156093 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15124311 227.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15267310 230.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15293756 230.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15220964 229.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15229264 229.3 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15130698 229.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15077674 229.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15207948 229.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15350529 229.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15156717 230.4 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11229164 322.5 ns/op Benchmark____RoutedPubSub_0b-16 11310610 320.6 ns/op Benchmark____RoutedPubSub_0b-16 11059429 323.0 ns/op Benchmark____RoutedPubSub_0b-16 11122084 324.2 ns/op Benchmark____RoutedPubSub_0b-16 11018612 321.3 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6486418 543.8 ns/op Benchmark____RoutedPubSub_1K-16 6491924 535.8 ns/op Benchmark____RoutedPubSub_1K-16 6663349 543.9 ns/op Benchmark____RoutedPubSub_1K-16 6454092 547.2 ns/op Benchmark____RoutedPubSub_1K-16 6554145 539.8 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84645 42579 ns/op Benchmark__RoutedPubSub_100K-16 84240 43280 ns/op Benchmark__RoutedPubSub_100K-16 84610 42614 ns/op Benchmark__RoutedPubSub_100K-16 86424 43313 ns/op Benchmark__RoutedPubSub_100K-16 84313 43509 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9455013 338.2 ns/op Benchmark____Routed2QueueSub-16 9644472 332.3 ns/op Benchmark____Routed2QueueSub-16 9744270 335.3 ns/op Benchmark____Routed2QueueSub-16 9519141 333.2 ns/op Benchmark____Routed2QueueSub-16 9727632 328.3 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9305209 325.1 ns/op Benchmark____Routed4QueueSub-16 9358056 332.7 ns/op Benchmark____Routed4QueueSub-16 9247066 341.0 ns/op Benchmark____Routed4QueueSub-16 9329180 326.2 ns/op Benchmark____Routed4QueueSub-16 9132547 334.7 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 8927853 339.8 ns/op Benchmark____Routed8QueueSub-16 9125401 338.3 ns/op Benchmark____Routed8QueueSub-16 9201121 335.4 ns/op Benchmark____Routed8QueueSub-16 9137335 342.0 ns/op Benchmark____Routed8QueueSub-16 9252265 341.6 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 10277918 348.9 ns/op Benchmark___Routed16QueueSub-16 8567304 353.5 ns/op Benchmark___Routed16QueueSub-16 10093633 352.9 ns/op Benchmark___Routed16QueueSub-16 8513613 362.9 ns/op Benchmark___Routed16QueueSub-16 8723636 357.1 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6372598 555.7 ns/op Benchmark____________RouteCompressOff-16 6297448 558.4 ns/op Benchmark____________RouteCompressOff-16 6269390 558.2 ns/op Benchmark____________RouteCompressOff-16 6416236 558.6 ns/op Benchmark____________RouteCompressOff-16 6262368 555.2 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6322221 555.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6418258 552.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6292206 557.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6373600 558.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6407362 564.0 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6403552 554.3 ns/op Benchmark_________RouteCompressS2Fast-16 6398498 556.1 ns/op Benchmark_________RouteCompressS2Fast-16 6374978 553.2 ns/op Benchmark_________RouteCompressS2Fast-16 6447861 560.3 ns/op Benchmark_________RouteCompressS2Fast-16 6492640 555.7 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6422088 558.4 ns/op Benchmark_______RouteCompressS2Better-16 6426279 558.0 ns/op Benchmark_______RouteCompressS2Better-16 6611787 551.4 ns/op Benchmark_______RouteCompressS2Better-16 6215918 560.7 ns/op Benchmark_______RouteCompressS2Better-16 6357214 564.7 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6404736 551.0 ns/op Benchmark_________RouteCompressS2Best-16 6277077 560.3 ns/op Benchmark_________RouteCompressS2Best-16 6386780 561.3 ns/op Benchmark_________RouteCompressS2Best-16 6502202 545.3 ns/op Benchmark_________RouteCompressS2Best-16 6444519 555.5 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4665964 767.4 ns/op 324.48 MB/s Benchmark______FanOut_8x1x10-16 4685510 765.5 ns/op 325.29 MB/s Benchmark______FanOut_8x1x10-16 4651632 771.5 ns/op 322.74 MB/s Benchmark______FanOut_8x1x10-16 4676905 770.5 ns/op 323.16 MB/s Benchmark______FanOut_8x1x10-16 4634977 770.9 ns/op 323.02 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 502359 6067 ns/op 382.20 MB/s Benchmark_____FanOut_8x1x100-16 560955 6075 ns/op 381.73 MB/s Benchmark_____FanOut_8x1x100-16 557457 6114 ns/op 379.29 MB/s Benchmark_____FanOut_8x1x100-16 555369 6096 ns/op 380.42 MB/s Benchmark_____FanOut_8x1x100-16 567567 6130 ns/op 378.31 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47566 74247 ns/op 310.03 MB/s Benchmark____FanOut_8x10x100-16 47862 74171 ns/op 310.35 MB/s Benchmark____FanOut_8x10x100-16 48433 74321 ns/op 309.72 MB/s Benchmark____FanOut_8x10x100-16 48478 74709 ns/op 308.12 MB/s Benchmark____FanOut_8x10x100-16 48483 74099 ns/op 310.65 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5989 600939 ns/op 399.41 MB/s Benchmark___FanOut_8x10x1000-16 5739 595090 ns/op 403.33 MB/s Benchmark___FanOut_8x10x1000-16 6069 591642 ns/op 405.68 MB/s Benchmark___FanOut_8x10x1000-16 5883 605577 ns/op 396.35 MB/s Benchmark___FanOut_8x10x1000-16 5826 589752 ns/op 406.98 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5080 711138 ns/op 323.45 MB/s Benchmark___FanOut_8x100x100-16 4963 706276 ns/op 325.68 MB/s Benchmark___FanOut_8x100x100-16 5070 706574 ns/op 325.54 MB/s Benchmark___FanOut_8x100x100-16 5028 717251 ns/op 320.70 MB/s Benchmark___FanOut_8x100x100-16 4952 706753 ns/op 325.46 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 578 6106604 ns/op 393.02 MB/s Benchmark__FanOut_8x100x1000-16 576 6120300 ns/op 392.14 MB/s Benchmark__FanOut_8x100x1000-16 561 6122624 ns/op 391.99 MB/s Benchmark__FanOut_8x100x1000-16 577 6113554 ns/op 392.57 MB/s Benchmark__FanOut_8x100x1000-16 558 6176793 ns/op 388.55 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 537 6707784 ns/op 372.70 MB/s Benchmark__FanOut_8x10x10000-16 540 6742636 ns/op 370.78 MB/s Benchmark__FanOut_8x10x10000-16 530 6899976 ns/op 362.32 MB/s Benchmark__FanOut_8x10x10000-16 517 6662193 ns/op 375.25 MB/s Benchmark__FanOut_8x10x10000-16 535 6704437 ns/op 372.89 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 956 3757585 ns/op 306.05 MB/s Benchmark___FanOut_8x500x100-16 949 3757243 ns/op 306.08 MB/s Benchmark___FanOut_8x500x100-16 949 3751185 ns/op 306.57 MB/s Benchmark___FanOut_8x500x100-16 960 3746624 ns/op 306.95 MB/s Benchmark___FanOut_8x500x100-16 950 3754585 ns/op 306.30 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 361980 9463 ns/op 1547.11 MB/s Benchmark___FanOut_128x1x100-16 366847 9451 ns/op 1549.19 MB/s Benchmark___FanOut_128x1x100-16 367785 9467 ns/op 1546.59 MB/s Benchmark___FanOut_128x1x100-16 363283 9488 ns/op 1543.17 MB/s Benchmark___FanOut_128x1x100-16 355390 9479 ns/op 1544.58 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32763 109602 ns/op 1324.25 MB/s Benchmark__FanOut_128x10x100-16 32696 110213 ns/op 1316.91 MB/s Benchmark__FanOut_128x10x100-16 32774 109888 ns/op 1320.81 MB/s Benchmark__FanOut_128x10x100-16 32408 110184 ns/op 1317.26 MB/s Benchmark__FanOut_128x10x100-16 32614 111261 ns/op 1304.51 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3764 869226 ns/op 1679.82 MB/s Benchmark_FanOut_128x10x1000-16 4220 870926 ns/op 1676.54 MB/s Benchmark_FanOut_128x10x1000-16 4156 874225 ns/op 1670.21 MB/s Benchmark_FanOut_128x10x1000-16 4134 873398 ns/op 1671.79 MB/s Benchmark_FanOut_128x10x1000-16 4069 871780 ns/op 1674.90 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3526 1011261 ns/op 1433.99 MB/s Benchmark_FanOut_128x100x100-16 3447 1013617 ns/op 1430.66 MB/s Benchmark_FanOut_128x100x100-16 3510 1007914 ns/op 1438.75 MB/s Benchmark_FanOut_128x100x100-16 3518 1012972 ns/op 1431.57 MB/s Benchmark_FanOut_128x100x100-16 3460 1015495 ns/op 1428.01 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 388 9406614 ns/op 1552.11 MB/s BenchmarkFanOut_128x100x1000-16 385 9261573 ns/op 1576.42 MB/s BenchmarkFanOut_128x100x1000-16 388 9254170 ns/op 1577.68 MB/s BenchmarkFanOut_128x100x1000-16 385 9338733 ns/op 1563.40 MB/s BenchmarkFanOut_128x100x1000-16 384 9377918 ns/op 1556.86 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 373 9640861 ns/op 1524.77 MB/s BenchmarkFanOut_128x10x10000-16 368 9636622 ns/op 1525.45 MB/s BenchmarkFanOut_128x10x10000-16 373 9587682 ns/op 1533.23 MB/s BenchmarkFanOut_128x10x10000-16 370 9764155 ns/op 1505.52 MB/s BenchmarkFanOut_128x10x10000-16 370 9684395 ns/op 1517.92 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 675 5289538 ns/op 1370.66 MB/s BenchmarkFanOut__128x500x100-16 669 5301542 ns/op 1367.55 MB/s BenchmarkFanOut__128x500x100-16 676 5254655 ns/op 1379.76 MB/s BenchmarkFanOut__128x500x100-16 678 5239543 ns/op 1383.74 MB/s BenchmarkFanOut__128x500x100-16 687 5244210 ns/op 1382.50 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1927 1831238 ns/op 2889.04 MB/s Benchmark_FanOut_512x100x100-16 1936 1826851 ns/op 2895.98 MB/s Benchmark_FanOut_512x100x100-16 1946 1822896 ns/op 2902.26 MB/s Benchmark_FanOut_512x100x100-16 1939 1837531 ns/op 2879.15 MB/s Benchmark_FanOut_512x100x100-16 1934 1841935 ns/op 2872.26 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16665007 ns/op 3180.35 MB/s Benchmark__FanOut_512x100x1k-16 217 16645947 ns/op 3183.99 MB/s Benchmark__FanOut_512x100x1k-16 216 16513423 ns/op 3209.54 MB/s Benchmark__FanOut_512x100x1k-16 216 16830034 ns/op 3149.16 MB/s Benchmark__FanOut_512x100x1k-16 213 16544116 ns/op 3203.59 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2967 1142076 ns/op 9133.40 MB/s Benchmark____FanOut_1kx10x1k-16 3151 1152320 ns/op 9052.20 MB/s Benchmark____FanOut_1kx10x1k-16 3175 1153529 ns/op 9042.72 MB/s Benchmark____FanOut_1kx10x1k-16 3141 1140073 ns/op 9149.44 MB/s Benchmark____FanOut_1kx10x1k-16 2821 1124224 ns/op 9278.44 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2876 1251683 ns/op 8325.62 MB/s Benchmark__FanOut_1kx100x100-16 2809 1263980 ns/op 8244.62 MB/s Benchmark__FanOut_1kx100x100-16 2790 1254658 ns/op 8305.88 MB/s Benchmark__FanOut_1kx100x100-16 2818 1256209 ns/op 8295.62 MB/s Benchmark__FanOut_1kx100x100-16 2749 1252893 ns/op 8317.58 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4398850 783.8 ns/op 317.68 MB/s Benchmark_____RFanOut_8x1x10-16 4511353 774.6 ns/op 321.44 MB/s Benchmark_____RFanOut_8x1x10-16 4449998 781.8 ns/op 318.52 MB/s Benchmark_____RFanOut_8x1x10-16 4449097 764.0 ns/op 325.93 MB/s Benchmark_____RFanOut_8x1x10-16 4596648 775.2 ns/op 321.22 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 538801 6171 ns/op 375.79 MB/s Benchmark____RFanOut_8x1x100-16 540292 5959 ns/op 389.14 MB/s Benchmark____RFanOut_8x1x100-16 547309 6215 ns/op 373.11 MB/s Benchmark____RFanOut_8x1x100-16 528892 5979 ns/op 387.88 MB/s Benchmark____RFanOut_8x1x100-16 529704 6171 ns/op 375.79 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48807 73934 ns/op 311.34 MB/s Benchmark___RFanOut_8x10x100-16 48776 73602 ns/op 312.75 MB/s Benchmark___RFanOut_8x10x100-16 48627 74355 ns/op 309.58 MB/s Benchmark___RFanOut_8x10x100-16 48612 73955 ns/op 311.26 MB/s Benchmark___RFanOut_8x10x100-16 48781 73585 ns/op 312.82 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6074 591179 ns/op 406.00 MB/s Benchmark__RFanOut_8x10x1000-16 5925 586676 ns/op 409.12 MB/s Benchmark__RFanOut_8x10x1000-16 6070 584985 ns/op 410.30 MB/s Benchmark__RFanOut_8x10x1000-16 6006 585010 ns/op 410.28 MB/s Benchmark__RFanOut_8x10x1000-16 6151 594024 ns/op 404.06 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5173 695367 ns/op 330.79 MB/s Benchmark__RFanOut_8x100x100-16 5074 696646 ns/op 330.18 MB/s Benchmark__RFanOut_8x100x100-16 4969 695820 ns/op 330.57 MB/s Benchmark__RFanOut_8x100x100-16 5053 695331 ns/op 330.81 MB/s Benchmark__RFanOut_8x100x100-16 5012 696957 ns/op 330.03 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 590 6004254 ns/op 399.72 MB/s Benchmark_RFanOut_8x100x1000-16 589 6082743 ns/op 394.56 MB/s Benchmark_RFanOut_8x100x1000-16 592 6013730 ns/op 399.09 MB/s Benchmark_RFanOut_8x100x1000-16 592 6036279 ns/op 397.60 MB/s Benchmark_RFanOut_8x100x1000-16 588 6086360 ns/op 394.33 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 537 6568064 ns/op 380.63 MB/s Benchmark_RFanOut_8x10x10000-16 549 6542369 ns/op 382.13 MB/s Benchmark_RFanOut_8x10x10000-16 541 6606988 ns/op 378.39 MB/s Benchmark_RFanOut_8x10x10000-16 543 6636454 ns/op 376.71 MB/s Benchmark_RFanOut_8x10x10000-16 537 6552955 ns/op 381.51 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3231 1138241 ns/op 9164.18 MB/s Benchmark_RFanOut_1kx10x1000-16 3145 1120321 ns/op 9310.76 MB/s Benchmark_RFanOut_1kx10x1000-16 2804 1150027 ns/op 9070.25 MB/s Benchmark_RFanOut_1kx10x1000-16 3171 1131695 ns/op 9217.18 MB/s Benchmark_RFanOut_1kx10x1000-16 2832 1136605 ns/op 9177.36 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7018593 501.9 ns/op 4140.24 MB/s Benchmark_____FanIn_1kx100x1-16 6910220 503.6 ns/op 4126.01 MB/s Benchmark_____FanIn_1kx100x1-16 6955653 505.1 ns/op 4114.04 MB/s Benchmark_____FanIn_1kx100x1-16 6921795 503.1 ns/op 4130.29 MB/s Benchmark_____FanIn_1kx100x1-16 6974456 506.3 ns/op 4104.33 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2615913 1366 ns/op 6019.53 MB/s Benchmark_____FanIn_4kx100x1-16 2677821 1353 ns/op 6077.55 MB/s Benchmark_____FanIn_4kx100x1-16 2630140 1346 ns/op 6108.55 MB/s Benchmark_____FanIn_4kx100x1-16 2638075 1362 ns/op 6035.17 MB/s Benchmark_____FanIn_4kx100x1-16 2589522 1353 ns/op 6077.31 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1712160 2104 ns/op 7802.20 MB/s Benchmark_____FanIn_8kx100x1-16 1683637 2083 ns/op 7878.09 MB/s Benchmark_____FanIn_8kx100x1-16 1730754 2093 ns/op 7842.13 MB/s Benchmark_____FanIn_8kx100x1-16 1714359 2082 ns/op 7884.05 MB/s Benchmark_____FanIn_8kx100x1-16 1670094 2099 ns/op 7818.56 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 871617 4125 ns/op 7950.71 MB/s Benchmark____FanIn_16kx100x1-16 859688 4130 ns/op 7942.34 MB/s Benchmark____FanIn_16kx100x1-16 876046 4148 ns/op 7908.27 MB/s Benchmark____FanIn_16kx100x1-16 864435 4102 ns/op 7996.07 MB/s Benchmark____FanIn_16kx100x1-16 873181 4078 ns/op 8042.59 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 4824831906 vs 11071901700 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52414->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 171690 19853 ns/op 6603.88 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 3457199667 vs 11157120600 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50684->127.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:50632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50004->127.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:49960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50302->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:50382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50242->127.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:49930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50688->127.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:49912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50428->127.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:50552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50588->127.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:50264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49996->127.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:50012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50276->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 171649 20034 ns/op 6544.00 MB/s Benchmark____FanIn_64kx100x1-16 168447 20154 ns/op 6505.22 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 997463810 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49474->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: 124273320 vs 11391721000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52872->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52452->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52544->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: 564080270 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54572->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 244220670 vs 11614574000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56762->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57192->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: 238059440 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58670->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:59334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58592->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5567874 640.3 ns/op 443.56 MB/s Benchmark___BumpPubCount_1x3-16 5557642 641.4 ns/op 442.79 MB/s Benchmark___BumpPubCount_1x3-16 5581490 643.8 ns/op 441.10 MB/s Benchmark___BumpPubCount_1x3-16 5620222 647.4 ns/op 438.70 MB/s Benchmark___BumpPubCount_1x3-16 5524705 637.4 ns/op 445.53 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5273677 679.2 ns/op 418.16 MB/s Benchmark___BumpPubCount_2x3-16 5272134 679.2 ns/op 418.14 MB/s Benchmark___BumpPubCount_2x3-16 5225155 676.2 ns/op 419.98 MB/s Benchmark___BumpPubCount_2x3-16 5245135 676.3 ns/op 419.92 MB/s Benchmark___BumpPubCount_2x3-16 5275570 679.0 ns/op 418.26 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5426516 651.7 ns/op 435.75 MB/s Benchmark___BumpPubCount_5x3-16 5538603 647.3 ns/op 438.78 MB/s Benchmark___BumpPubCount_5x3-16 5500560 648.4 ns/op 438.01 MB/s Benchmark___BumpPubCount_5x3-16 5314752 647.6 ns/op 438.56 MB/s Benchmark___BumpPubCount_5x3-16 5519042 649.8 ns/op 437.05 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5559063 649.5 ns/op 437.28 MB/s Benchmark__BumpPubCount_10x3-16 5534666 647.5 ns/op 438.61 MB/s Benchmark__BumpPubCount_10x3-16 5514429 647.0 ns/op 438.92 MB/s Benchmark__BumpPubCount_10x3-16 5498535 647.5 ns/op 438.59 MB/s Benchmark__BumpPubCount_10x3-16 5548939 650.5 ns/op 436.58 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12032899 278.3 ns/op 3737.33 MB/s Benchmark____GWs_Opt_1kx01x0-16 12925576 277.7 ns/op 3745.44 MB/s Benchmark____GWs_Opt_1kx01x0-16 11938525 279.8 ns/op 3717.55 MB/s Benchmark____GWs_Opt_1kx01x0-16 11483523 283.2 ns/op 3672.15 MB/s Benchmark____GWs_Opt_1kx01x0-16 12634759 271.4 ns/op 3831.51 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10274811 335.5 ns/op 6152.13 MB/s Benchmark____GWs_Opt_2kx01x0-16 10857224 380.1 ns/op 5429.96 MB/s Benchmark____GWs_Opt_2kx01x0-16 10596402 335.5 ns/op 6151.16 MB/s Benchmark____GWs_Opt_2kx01x0-16 10207528 331.0 ns/op 6235.42 MB/s Benchmark____GWs_Opt_2kx01x0-16 10509619 318.5 ns/op 6480.50 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5681380 630.2 ns/op 6524.41 MB/s Benchmark____GWs_Opt_4kx01x0-16 5609226 634.0 ns/op 6485.95 MB/s Benchmark____GWs_Opt_4kx01x0-16 5483194 654.4 ns/op 6283.72 MB/s Benchmark____GWs_Opt_4kx01x0-16 5749804 605.6 ns/op 6790.37 MB/s Benchmark____GWs_Opt_4kx01x0-16 5440490 652.9 ns/op 6297.99 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 31491712 109.5 ns/op 9498.26 MB/s Benchmark____GWs_Opt_1kx10x0-16 20134834 217.9 ns/op 4772.64 MB/s Benchmark____GWs_Opt_1kx10x0-16 30882782 114.6 ns/op 9078.86 MB/s Benchmark____GWs_Opt_1kx10x0-16 30649374 113.4 ns/op 9171.35 MB/s Benchmark____GWs_Opt_1kx10x0-16 26894850 114.4 ns/op 9090.84 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24605420 154.9 ns/op 13327.32 MB/s Benchmark____GWs_Opt_2kx10x0-16 24563026 141.0 ns/op 14643.11 MB/s Benchmark____GWs_Opt_2kx10x0-16 21408234 149.9 ns/op 13767.62 MB/s Benchmark____GWs_Opt_2kx10x0-16 21145449 161.6 ns/op 12772.08 MB/s Benchmark____GWs_Opt_2kx10x0-16 24850966 142.1 ns/op 14525.63 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12234621 289.6 ns/op 14197.60 MB/s Benchmark____GWs_Opt_4kx10x0-16 12313260 290.4 ns/op 14157.83 MB/s Benchmark____GWs_Opt_4kx10x0-16 11587036 297.8 ns/op 13809.96 MB/s Benchmark____GWs_Opt_4kx10x0-16 12284260 1394 ns/op 2949.89 MB/s Benchmark____GWs_Opt_4kx10x0-16 11744774 334.2 ns/op 12304.46 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6403066 558.6 ns/op 5594.77 MB/s Benchmark____GWs_Opt_1kx01x1-16 6440752 554.8 ns/op 5633.08 MB/s Benchmark____GWs_Opt_1kx01x1-16 6378920 554.4 ns/op 5636.74 MB/s Benchmark____GWs_Opt_1kx01x1-16 6366776 553.1 ns/op 5649.61 MB/s Benchmark____GWs_Opt_1kx01x1-16 6455444 549.0 ns/op 5692.49 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4179100 757.0 ns/op 8186.48 MB/s Benchmark____GWs_Opt_2kx01x1-16 4672054 804.7 ns/op 7701.41 MB/s Benchmark____GWs_Opt_2kx01x1-16 4567411 770.0 ns/op 8048.10 MB/s Benchmark____GWs_Opt_2kx01x1-16 4708256 759.6 ns/op 8157.80 MB/s Benchmark____GWs_Opt_2kx01x1-16 4700934 758.3 ns/op 8172.56 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2591665 1370 ns/op 9009.87 MB/s Benchmark____GWs_Opt_4kx01x1-16 2556049 1372 ns/op 8996.27 MB/s Benchmark____GWs_Opt_4kx01x1-16 2252834 1397 ns/op 8835.22 MB/s Benchmark____GWs_Opt_4kx01x1-16 2534458 1403 ns/op 8794.72 MB/s Benchmark____GWs_Opt_4kx01x1-16 2534751 1385 ns/op 8909.89 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6417562 559.5 ns/op 5585.20 MB/s Benchmark____GWs_Opt_1kx10x1-16 6126667 561.4 ns/op 5566.05 MB/s Benchmark____GWs_Opt_1kx10x1-16 6213560 561.3 ns/op 5567.65 MB/s Benchmark____GWs_Opt_1kx10x1-16 6080016 565.6 ns/op 5525.10 MB/s Benchmark____GWs_Opt_1kx10x1-16 6461947 563.8 ns/op 5543.19 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4011394 854.8 ns/op 7249.27 MB/s Benchmark____GWs_Opt_2kx10x1-16 4294507 897.4 ns/op 6905.23 MB/s Benchmark____GWs_Opt_2kx10x1-16 4198051 843.3 ns/op 7348.75 MB/s Benchmark____GWs_Opt_2kx10x1-16 4067522 850.5 ns/op 7285.88 MB/s Benchmark____GWs_Opt_2kx10x1-16 3994104 832.5 ns/op 7444.21 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2481208 1603 ns/op 7700.11 MB/s Benchmark____GWs_Opt_4kx10x1-16 2460121 1583 ns/op 7796.87 MB/s Benchmark____GWs_Opt_4kx10x1-16 2331945 1523 ns/op 8105.53 MB/s Benchmark____GWs_Opt_4kx10x1-16 2333610 1534 ns/op 8044.02 MB/s Benchmark____GWs_Opt_4kx10x1-16 2370316 1582 ns/op 7799.59 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12024933 289.0 ns/op 3598.96 MB/s Benchmark____GWs_Int_1kx01x0-16 12225770 299.0 ns/op 3477.84 MB/s Benchmark____GWs_Int_1kx01x0-16 11531934 285.4 ns/op 3644.44 MB/s Benchmark____GWs_Int_1kx01x0-16 11836662 288.3 ns/op 3607.87 MB/s Benchmark____GWs_Int_1kx01x0-16 12306667 290.2 ns/op 3584.21 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10030839 369.7 ns/op 5582.26 MB/s Benchmark____GWs_Int_2kx01x0-16 9279420 355.3 ns/op 5809.65 MB/s Benchmark____GWs_Int_2kx01x0-16 9965731 361.3 ns/op 5712.08 MB/s Benchmark____GWs_Int_2kx01x0-16 9951711 339.0 ns/op 6087.95 MB/s Benchmark____GWs_Int_2kx01x0-16 9704023 367.0 ns/op 5623.43 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5384545 649.8 ns/op 6328.34 MB/s Benchmark____GWs_Int_4kx01x0-16 5556432 652.6 ns/op 6301.01 MB/s Benchmark____GWs_Int_4kx01x0-16 5771869 649.1 ns/op 6334.86 MB/s Benchmark____GWs_Int_4kx01x0-16 5217271 647.3 ns/op 6352.54 MB/s Benchmark____GWs_Int_4kx01x0-16 5258684 649.9 ns/op 6326.65 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31954453 126.6 ns/op 8216.82 MB/s Benchmark____GWs_Int_1kx10x0-16 31913581 110.4 ns/op 9423.69 MB/s Benchmark____GWs_Int_1kx10x0-16 30269704 110.5 ns/op 9414.42 MB/s Benchmark____GWs_Int_1kx10x0-16 31229056 106.1 ns/op 9800.25 MB/s Benchmark____GWs_Int_1kx10x0-16 27996162 112.6 ns/op 9236.96 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 21086625 147.7 ns/op 13973.18 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:33414->127.0.0.1:36197: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:46426->127.0.0.1:37129: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 25777093 144.7 ns/op 14266.43 MB/s Benchmark____GWs_Int_2kx10x0-16 26075738 141.9 ns/op 14545.72 MB/s Benchmark____GWs_Int_2kx10x0-16 21649702 142.8 ns/op 14449.99 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11608176 325.2 ns/op 12644.28 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:34822->127.0.0.1:38203: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:55280->127.0.0.1:45917: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 10446572 316.1 ns/op 13007.15 MB/s Benchmark____GWs_Int_4kx10x0-16 10592865 289.5 ns/op 14203.71 MB/s Benchmark____GWs_Int_4kx10x0-16 11748190 340.7 ns/op 12070.96 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6479170 565.5 ns/op 5526.33 MB/s Benchmark____GWs_Int_1kx01x1-16 6400184 564.6 ns/op 5534.56 MB/s Benchmark____GWs_Int_1kx01x1-16 6487729 568.8 ns/op 5493.84 MB/s Benchmark____GWs_Int_1kx01x1-16 6605012 566.9 ns/op 5512.67 MB/s Benchmark____GWs_Int_1kx01x1-16 6580010 557.1 ns/op 5609.11 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4525532 776.3 ns/op 7982.33 MB/s Benchmark____GWs_Int_2kx01x1-16 4822843 774.7 ns/op 7999.63 MB/s Benchmark____GWs_Int_2kx01x1-16 4577814 765.3 ns/op 8097.36 MB/s Benchmark____GWs_Int_2kx01x1-16 4597923 779.7 ns/op 7947.95 MB/s Benchmark____GWs_Int_2kx01x1-16 4645144 772.7 ns/op 8019.93 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2627571 1393 ns/op 8858.79 MB/s Benchmark____GWs_Int_4kx01x1-16 2613045 1601 ns/op 7709.04 MB/s Benchmark____GWs_Int_4kx01x1-16 2634903 1377 ns/op 8961.55 MB/s Benchmark____GWs_Int_4kx01x1-16 2563070 1569 ns/op 7867.50 MB/s Benchmark____GWs_Int_4kx01x1-16 2575473 1602 ns/op 7702.76 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6241965 555.3 ns/op 5627.61 MB/s Benchmark____GWs_Int_1kx10x1-16 6147844 556.5 ns/op 5615.34 MB/s Benchmark____GWs_Int_1kx10x1-16 6240794 565.7 ns/op 5523.88 MB/s Benchmark____GWs_Int_1kx10x1-16 6160684 562.6 ns/op 5554.42 MB/s Benchmark____GWs_Int_1kx10x1-16 6269602 563.5 ns/op 5545.25 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4159690 845.1 ns/op 7333.29 MB/s Benchmark____GWs_Int_2kx10x1-16 4196654 844.5 ns/op 7337.65 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:56402->127.0.0.1:44693: i/o timeout bench_test.go:167: Did not receive all bytes: 291595246 vs 8466096340 --- FAIL: Benchmark____GWs_Int_2kx10x1-16 Benchmark____GWs_Int_2kx10x1-16 4149930 840.1 ns/op 7376.76 MB/s Benchmark____GWs_Int_2kx10x1-16 4262186 849.2 ns/op 7297.06 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2283940 1510 ns/op 8174.90 MB/s Benchmark____GWs_Int_4kx10x1-16 2138102 1581 ns/op 7805.26 MB/s Benchmark____GWs_Int_4kx10x1-16 2362797 1663 ns/op 7420.46 MB/s Benchmark____GWs_Int_4kx10x1-16 2500624 1665 ns/op 7412.70 MB/s Benchmark____GWs_Int_4kx10x1-16 2406211 1599 ns/op 7718.91 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8073390 444.2 ns/op 229.64 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7951570 448.1 ns/op 227.61 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7768150 452.1 ns/op 225.61 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8017704 445.6 ns/op 228.90 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8181104 443.0 ns/op 230.24 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 710882 5158 ns/op 34.32 MB/s Benchmark__GWs_Reqs_1SubEach-16 727930 5324 ns/op 33.24 MB/s Benchmark__GWs_Reqs_1SubEach-16 745946 5279 ns/op 33.53 MB/s Benchmark__GWs_Reqs_1SubEach-16 751152 5275 ns/op 33.55 MB/s Benchmark__GWs_Reqs_1SubEach-16 749730 5285 ns/op 33.49 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2326.523s ❌ Non-zero exit code: 1