> ROOT_DIR=/tmp/go-bench-away-job-ddda111a-6a7a-4079-bd0b-fea4d54629bd-1345828883 > OUTPUT_FILE=/tmp/go-bench-away-job-ddda111a-6a7a-4079-bd0b-fea4d54629bd-1345828883/results.txt > SHA_FILE=/tmp/go-bench-away-job-ddda111a-6a7a-4079-bd0b-fea4d54629bd-1345828883/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-ddda111a-6a7a-4079-bd0b-fea4d54629bd-1345828883/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-ddda111a-6a7a-4079-bd0b-fea4d54629bd-1345828883/source.git SHA of main: 0a6cc9e061a63b36628afb1744bdefab176f25f5 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-build1049220839=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-ddda111a-6a7a-4079-bd0b-fea4d54629bd-1345828883/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 48701211 73.76 ns/op 149.13 MB/s Benchmark______Pub0b_Payload-16 46050732 74.11 ns/op 148.43 MB/s Benchmark______Pub0b_Payload-16 46044938 74.12 ns/op 148.40 MB/s Benchmark______Pub0b_Payload-16 46137673 74.29 ns/op 148.06 MB/s Benchmark______Pub0b_Payload-16 46306008 74.09 ns/op 148.46 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45484890 75.02 ns/op 253.26 MB/s Benchmark______Pub8b_Payload-16 45143899 74.63 ns/op 254.59 MB/s Benchmark______Pub8b_Payload-16 48350101 76.21 ns/op 249.30 MB/s Benchmark______Pub8b_Payload-16 44879382 74.95 ns/op 253.51 MB/s Benchmark______Pub8b_Payload-16 45695730 74.67 ns/op 254.45 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43307187 80.02 ns/op 549.89 MB/s Benchmark_____Pub32b_Payload-16 42978493 79.23 ns/op 555.34 MB/s Benchmark_____Pub32b_Payload-16 42918280 79.39 ns/op 554.25 MB/s Benchmark_____Pub32b_Payload-16 43187173 79.05 ns/op 556.60 MB/s Benchmark_____Pub32b_Payload-16 43140007 78.81 ns/op 558.29 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 34233052 88.24 ns/op 1597.91 MB/s Benchmark____Pub128B_Payload-16 40312044 88.21 ns/op 1598.38 MB/s Benchmark____Pub128B_Payload-16 33852064 89.80 ns/op 1570.17 MB/s Benchmark____Pub128B_Payload-16 38750725 91.21 ns/op 1545.92 MB/s Benchmark____Pub128B_Payload-16 40336278 95.15 ns/op 1481.81 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 34472221 107.5 ns/op 2503.45 MB/s Benchmark____Pub256B_Payload-16 31554090 96.32 ns/op 2792.71 MB/s Benchmark____Pub256B_Payload-16 37310635 96.36 ns/op 2791.76 MB/s Benchmark____Pub256B_Payload-16 35700212 96.61 ns/op 2784.27 MB/s Benchmark____Pub256B_Payload-16 35340988 95.98 ns/op 2802.65 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 21313186 141.2 ns/op 7351.13 MB/s Benchmark______Pub1K_Payload-16 22087171 143.4 ns/op 7239.68 MB/s Benchmark______Pub1K_Payload-16 23913394 142.2 ns/op 7302.00 MB/s Benchmark______Pub1K_Payload-16 26490734 148.6 ns/op 6983.41 MB/s Benchmark______Pub1K_Payload-16 23949670 140.1 ns/op 7410.88 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5700288 620.9 ns/op 6619.11 MB/s Benchmark______Pub4K_Payload-16 5741468 617.7 ns/op 6653.66 MB/s Benchmark______Pub4K_Payload-16 5592440 620.9 ns/op 6618.95 MB/s Benchmark______Pub4K_Payload-16 5664451 631.1 ns/op 6512.94 MB/s Benchmark______Pub4K_Payload-16 5643267 666.5 ns/op 6166.79 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2781525 1287 ns/op 6377.67 MB/s Benchmark______Pub8K_Payload-16 2781672 1278 ns/op 6420.51 MB/s Benchmark______Pub8K_Payload-16 2685386 1274 ns/op 6438.96 MB/s Benchmark______Pub8K_Payload-16 2736613 1278 ns/op 6420.12 MB/s Benchmark______Pub8K_Payload-16 2750406 1271 ns/op 6454.62 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 550999 5447 ns/op 6018.98 MB/s Benchmark_____Pub32K_Payload-16 667404 5543 ns/op 5913.92 MB/s Benchmark_____Pub32K_Payload-16 557264 5545 ns/op 5911.87 MB/s Benchmark_____Pub32K_Payload-16 654668 5404 ns/op 6066.08 MB/s Benchmark_____Pub32K_Payload-16 556334 5396 ns/op 6075.47 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31857172 95.40 ns/op 115.30 MB/s Benchmark__AuthPub0b_Payload-16 35618678 95.84 ns/op 114.77 MB/s Benchmark__AuthPub0b_Payload-16 31728626 95.88 ns/op 114.73 MB/s Benchmark__AuthPub0b_Payload-16 35843854 95.48 ns/op 115.21 MB/s Benchmark__AuthPub0b_Payload-16 35579056 95.73 ns/op 114.90 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15436743 229.7 ns/op Benchmark_____________PubSub-16 15446138 229.8 ns/op Benchmark_____________PubSub-16 15392314 229.3 ns/op Benchmark_____________PubSub-16 15312583 229.3 ns/op Benchmark_____________PubSub-16 15198940 229.9 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15662178 228.5 ns/op Benchmark_____PubSubTwoConns-16 15249609 227.8 ns/op Benchmark_____PubSubTwoConns-16 15712941 227.8 ns/op Benchmark_____PubSubTwoConns-16 15461044 227.7 ns/op Benchmark_____PubSubTwoConns-16 15615651 228.3 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57184->127.0.0.1:38153: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42868->127.0.0.1:36953: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:47954->127.0.0.1:37791: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41392->127.0.0.1:35087: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:60746->127.0.0.1:35543: 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 14307187 246.7 ns/op Benchmark_____PubTwoQueueSub-16 14208876 246.2 ns/op Benchmark_____PubTwoQueueSub-16 14392317 247.0 ns/op Benchmark_____PubTwoQueueSub-16 14461824 246.6 ns/op Benchmark_____PubTwoQueueSub-16 14484440 246.9 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14279419 247.6 ns/op Benchmark____PubFourQueueSub-16 14430901 246.7 ns/op Benchmark____PubFourQueueSub-16 14338435 247.3 ns/op Benchmark____PubFourQueueSub-16 14222090 246.1 ns/op Benchmark____PubFourQueueSub-16 14298907 246.7 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14291937 246.8 ns/op Benchmark___PubEightQueueSub-16 14360277 247.6 ns/op Benchmark___PubEightQueueSub-16 14449938 247.3 ns/op Benchmark___PubEightQueueSub-16 14453006 247.2 ns/op Benchmark___PubEightQueueSub-16 14314381 247.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 21768 155140 ns/op Benchmark_PubSub512kTwoConns-16 23104 155963 ns/op Benchmark_PubSub512kTwoConns-16 23073 155869 ns/op Benchmark_PubSub512kTwoConns-16 23104 155842 ns/op Benchmark_PubSub512kTwoConns-16 23208 155592 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15075088 231.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15116148 232.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 14989425 231.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15152700 231.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15261718 232.5 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15021133 232.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15110262 232.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15045129 231.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15033307 231.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 14961337 232.7 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11368998 308.9 ns/op Benchmark____RoutedPubSub_0b-16 11632213 319.9 ns/op Benchmark____RoutedPubSub_0b-16 11581437 318.8 ns/op Benchmark____RoutedPubSub_0b-16 11280848 319.4 ns/op Benchmark____RoutedPubSub_0b-16 11410750 310.9 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6767301 536.3 ns/op Benchmark____RoutedPubSub_1K-16 6647942 538.4 ns/op Benchmark____RoutedPubSub_1K-16 6696786 531.3 ns/op Benchmark____RoutedPubSub_1K-16 6571344 507.6 ns/op Benchmark____RoutedPubSub_1K-16 6550167 545.4 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 83895 41918 ns/op Benchmark__RoutedPubSub_100K-16 84613 43135 ns/op Benchmark__RoutedPubSub_100K-16 85776 41930 ns/op Benchmark__RoutedPubSub_100K-16 83660 43389 ns/op Benchmark__RoutedPubSub_100K-16 83108 42925 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9895148 324.7 ns/op Benchmark____Routed2QueueSub-16 9660886 326.2 ns/op Benchmark____Routed2QueueSub-16 9560715 318.8 ns/op Benchmark____Routed2QueueSub-16 9871177 315.2 ns/op Benchmark____Routed2QueueSub-16 9857077 316.2 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9523500 325.0 ns/op Benchmark____Routed4QueueSub-16 9783537 312.9 ns/op Benchmark____Routed4QueueSub-16 9424578 320.0 ns/op Benchmark____Routed4QueueSub-16 9719286 324.5 ns/op Benchmark____Routed4QueueSub-16 9431232 321.0 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9604761 324.1 ns/op Benchmark____Routed8QueueSub-16 9270756 327.4 ns/op Benchmark____Routed8QueueSub-16 11067811 321.3 ns/op Benchmark____Routed8QueueSub-16 9195358 331.1 ns/op Benchmark____Routed8QueueSub-16 9465051 327.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8748564 345.8 ns/op Benchmark___Routed16QueueSub-16 8932107 350.5 ns/op Benchmark___Routed16QueueSub-16 8772980 343.9 ns/op Benchmark___Routed16QueueSub-16 8945640 354.0 ns/op Benchmark___Routed16QueueSub-16 10429158 347.5 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6424734 545.9 ns/op Benchmark____________RouteCompressOff-16 6588062 551.8 ns/op Benchmark____________RouteCompressOff-16 6473476 548.5 ns/op Benchmark____________RouteCompressOff-16 6481993 551.5 ns/op Benchmark____________RouteCompressOff-16 6460957 543.1 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6371041 552.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6442202 553.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6596431 543.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6419664 555.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6343503 552.0 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6523989 552.1 ns/op Benchmark_________RouteCompressS2Fast-16 6367053 548.1 ns/op Benchmark_________RouteCompressS2Fast-16 6455481 548.5 ns/op Benchmark_________RouteCompressS2Fast-16 6538608 548.0 ns/op Benchmark_________RouteCompressS2Fast-16 6492618 550.9 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6555447 551.4 ns/op Benchmark_______RouteCompressS2Better-16 6553796 552.0 ns/op Benchmark_______RouteCompressS2Better-16 6533055 547.7 ns/op Benchmark_______RouteCompressS2Better-16 6585147 551.3 ns/op Benchmark_______RouteCompressS2Better-16 6586252 547.8 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6510495 545.9 ns/op Benchmark_________RouteCompressS2Best-16 6373510 548.1 ns/op Benchmark_________RouteCompressS2Best-16 6542473 550.2 ns/op Benchmark_________RouteCompressS2Best-16 6416414 549.7 ns/op Benchmark_________RouteCompressS2Best-16 6546433 543.3 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4722278 765.4 ns/op 325.33 MB/s Benchmark______FanOut_8x1x10-16 4610654 761.8 ns/op 326.85 MB/s Benchmark______FanOut_8x1x10-16 4594468 762.1 ns/op 326.75 MB/s Benchmark______FanOut_8x1x10-16 4652293 761.5 ns/op 326.98 MB/s Benchmark______FanOut_8x1x10-16 4692640 761.8 ns/op 326.84 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 553466 6071 ns/op 381.98 MB/s Benchmark_____FanOut_8x1x100-16 545701 6069 ns/op 382.10 MB/s Benchmark_____FanOut_8x1x100-16 527349 6003 ns/op 386.32 MB/s Benchmark_____FanOut_8x1x100-16 546206 6011 ns/op 385.77 MB/s Benchmark_____FanOut_8x1x100-16 548235 6042 ns/op 383.83 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47947 73876 ns/op 311.59 MB/s Benchmark____FanOut_8x10x100-16 47894 74617 ns/op 308.49 MB/s Benchmark____FanOut_8x10x100-16 47779 74129 ns/op 310.53 MB/s Benchmark____FanOut_8x10x100-16 47816 74340 ns/op 309.64 MB/s Benchmark____FanOut_8x10x100-16 48586 74378 ns/op 309.49 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5980 589095 ns/op 407.44 MB/s Benchmark___FanOut_8x10x1000-16 6006 590678 ns/op 406.34 MB/s Benchmark___FanOut_8x10x1000-16 5751 589323 ns/op 407.28 MB/s Benchmark___FanOut_8x10x1000-16 6032 596009 ns/op 402.71 MB/s Benchmark___FanOut_8x10x1000-16 5896 601336 ns/op 399.14 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5013 699954 ns/op 328.62 MB/s Benchmark___FanOut_8x100x100-16 5052 699435 ns/op 328.86 MB/s Benchmark___FanOut_8x100x100-16 5024 698230 ns/op 329.43 MB/s Benchmark___FanOut_8x100x100-16 5107 701176 ns/op 328.05 MB/s Benchmark___FanOut_8x100x100-16 5028 709185 ns/op 324.34 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 589 6062889 ns/op 395.85 MB/s Benchmark__FanOut_8x100x1000-16 586 6068413 ns/op 395.49 MB/s Benchmark__FanOut_8x100x1000-16 568 6196136 ns/op 387.34 MB/s Benchmark__FanOut_8x100x1000-16 590 6113045 ns/op 392.61 MB/s Benchmark__FanOut_8x100x1000-16 585 6218908 ns/op 385.92 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 550 6662946 ns/op 375.21 MB/s Benchmark__FanOut_8x10x10000-16 531 6830370 ns/op 366.02 MB/s Benchmark__FanOut_8x10x10000-16 540 6763424 ns/op 369.64 MB/s Benchmark__FanOut_8x10x10000-16 544 6711364 ns/op 372.51 MB/s Benchmark__FanOut_8x10x10000-16 535 6724275 ns/op 371.79 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 960 3749781 ns/op 306.69 MB/s Benchmark___FanOut_8x500x100-16 949 3779374 ns/op 304.29 MB/s Benchmark___FanOut_8x500x100-16 948 3719791 ns/op 309.16 MB/s Benchmark___FanOut_8x500x100-16 958 3715340 ns/op 309.53 MB/s Benchmark___FanOut_8x500x100-16 950 3731671 ns/op 308.18 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 362450 9416 ns/op 1554.83 MB/s Benchmark___FanOut_128x1x100-16 366448 9377 ns/op 1561.31 MB/s Benchmark___FanOut_128x1x100-16 370575 9400 ns/op 1557.58 MB/s Benchmark___FanOut_128x1x100-16 369614 9433 ns/op 1552.13 MB/s Benchmark___FanOut_128x1x100-16 354892 9445 ns/op 1550.14 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32872 110925 ns/op 1308.45 MB/s Benchmark__FanOut_128x10x100-16 32726 109465 ns/op 1325.91 MB/s Benchmark__FanOut_128x10x100-16 32893 109706 ns/op 1323.00 MB/s Benchmark__FanOut_128x10x100-16 32913 109102 ns/op 1330.33 MB/s Benchmark__FanOut_128x10x100-16 32682 110072 ns/op 1318.60 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4064 859889 ns/op 1698.06 MB/s Benchmark_FanOut_128x10x1000-16 4017 874324 ns/op 1670.02 MB/s Benchmark_FanOut_128x10x1000-16 4035 860820 ns/op 1696.22 MB/s Benchmark_FanOut_128x10x1000-16 4074 858074 ns/op 1701.65 MB/s Benchmark_FanOut_128x10x1000-16 4239 861110 ns/op 1695.65 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3591 1001002 ns/op 1448.69 MB/s Benchmark_FanOut_128x100x100-16 3555 998785 ns/op 1451.90 MB/s Benchmark_FanOut_128x100x100-16 3547 997147 ns/op 1454.29 MB/s Benchmark_FanOut_128x100x100-16 3492 1002563 ns/op 1446.43 MB/s Benchmark_FanOut_128x100x100-16 3541 1000939 ns/op 1448.78 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 388 9074252 ns/op 1608.96 MB/s BenchmarkFanOut_128x100x1000-16 385 9200132 ns/op 1586.95 MB/s BenchmarkFanOut_128x100x1000-16 384 9269141 ns/op 1575.13 MB/s BenchmarkFanOut_128x100x1000-16 382 9125912 ns/op 1599.86 MB/s BenchmarkFanOut_128x100x1000-16 396 9078184 ns/op 1608.27 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 376 9508337 ns/op 1546.03 MB/s BenchmarkFanOut_128x10x10000-16 379 9534255 ns/op 1541.82 MB/s BenchmarkFanOut_128x10x10000-16 374 9540873 ns/op 1540.75 MB/s BenchmarkFanOut_128x10x10000-16 374 9501534 ns/op 1547.13 MB/s BenchmarkFanOut_128x10x10000-16 380 9561902 ns/op 1537.37 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 675 5221129 ns/op 1388.62 MB/s BenchmarkFanOut__128x500x100-16 682 5256162 ns/op 1379.36 MB/s BenchmarkFanOut__128x500x100-16 691 5214205 ns/op 1390.46 MB/s BenchmarkFanOut__128x500x100-16 680 5210685 ns/op 1391.40 MB/s BenchmarkFanOut__128x500x100-16 685 5233390 ns/op 1385.36 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1938 1838958 ns/op 2876.91 MB/s Benchmark_FanOut_512x100x100-16 1933 1822529 ns/op 2902.85 MB/s Benchmark_FanOut_512x100x100-16 1941 1817984 ns/op 2910.11 MB/s Benchmark_FanOut_512x100x100-16 2007 1818944 ns/op 2908.57 MB/s Benchmark_FanOut_512x100x100-16 1971 1827105 ns/op 2895.58 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 217 16478327 ns/op 3216.38 MB/s Benchmark__FanOut_512x100x1k-16 216 16616394 ns/op 3189.65 MB/s Benchmark__FanOut_512x100x1k-16 217 16406454 ns/op 3230.47 MB/s Benchmark__FanOut_512x100x1k-16 217 16758581 ns/op 3162.59 MB/s Benchmark__FanOut_512x100x1k-16 216 16537124 ns/op 3204.94 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2992 1125685 ns/op 9266.39 MB/s Benchmark____FanOut_1kx10x1k-16 3174 1131047 ns/op 9222.46 MB/s Benchmark____FanOut_1kx10x1k-16 3358 1147589 ns/op 9089.52 MB/s Benchmark____FanOut_1kx10x1k-16 2845 1161096 ns/op 8983.79 MB/s Benchmark____FanOut_1kx10x1k-16 2868 1157824 ns/op 9009.17 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2818 1243319 ns/op 8381.63 MB/s Benchmark__FanOut_1kx100x100-16 2760 1258041 ns/op 8283.54 MB/s Benchmark__FanOut_1kx100x100-16 2828 1247572 ns/op 8353.06 MB/s Benchmark__FanOut_1kx100x100-16 2761 1247350 ns/op 8354.54 MB/s Benchmark__FanOut_1kx100x100-16 2820 1246596 ns/op 8359.59 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4389820 783.1 ns/op 317.97 MB/s Benchmark_____RFanOut_8x1x10-16 4345575 776.8 ns/op 320.55 MB/s Benchmark_____RFanOut_8x1x10-16 4490371 776.9 ns/op 320.53 MB/s Benchmark_____RFanOut_8x1x10-16 4427196 774.2 ns/op 321.62 MB/s Benchmark_____RFanOut_8x1x10-16 4362637 769.4 ns/op 323.61 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 499515 6064 ns/op 382.41 MB/s Benchmark____RFanOut_8x1x100-16 519763 6083 ns/op 381.24 MB/s Benchmark____RFanOut_8x1x100-16 542442 6290 ns/op 368.65 MB/s Benchmark____RFanOut_8x1x100-16 547441 6332 ns/op 366.24 MB/s Benchmark____RFanOut_8x1x100-16 531079 6065 ns/op 382.35 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48314 74411 ns/op 309.35 MB/s Benchmark___RFanOut_8x10x100-16 48219 74083 ns/op 310.72 MB/s Benchmark___RFanOut_8x10x100-16 48356 74282 ns/op 309.89 MB/s Benchmark___RFanOut_8x10x100-16 48226 74088 ns/op 310.70 MB/s Benchmark___RFanOut_8x10x100-16 48056 74284 ns/op 309.88 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5802 596011 ns/op 402.71 MB/s Benchmark__RFanOut_8x10x1000-16 6151 591498 ns/op 405.78 MB/s Benchmark__RFanOut_8x10x1000-16 5853 599528 ns/op 400.35 MB/s Benchmark__RFanOut_8x10x1000-16 5947 605434 ns/op 396.44 MB/s Benchmark__RFanOut_8x10x1000-16 5533 596784 ns/op 402.19 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5062 701310 ns/op 327.98 MB/s Benchmark__RFanOut_8x100x100-16 4934 705732 ns/op 325.93 MB/s Benchmark__RFanOut_8x100x100-16 4959 703579 ns/op 326.93 MB/s Benchmark__RFanOut_8x100x100-16 4850 704067 ns/op 326.70 MB/s Benchmark__RFanOut_8x100x100-16 4962 701751 ns/op 327.78 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 572 6163863 ns/op 389.37 MB/s Benchmark_RFanOut_8x100x1000-16 583 6098348 ns/op 393.55 MB/s Benchmark_RFanOut_8x100x1000-16 583 6136747 ns/op 391.09 MB/s Benchmark_RFanOut_8x100x1000-16 574 6076546 ns/op 394.96 MB/s Benchmark_RFanOut_8x100x1000-16 574 6130693 ns/op 391.48 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 535 6671258 ns/op 374.74 MB/s Benchmark_RFanOut_8x10x10000-16 531 6682134 ns/op 374.13 MB/s Benchmark_RFanOut_8x10x10000-16 530 6726447 ns/op 371.67 MB/s Benchmark_RFanOut_8x10x10000-16 528 6928026 ns/op 360.86 MB/s Benchmark_RFanOut_8x10x10000-16 531 6682867 ns/op 374.09 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3051 1140012 ns/op 9149.94 MB/s Benchmark_RFanOut_1kx10x1000-16 3063 1142932 ns/op 9126.56 MB/s Benchmark_RFanOut_1kx10x1000-16 2787 1152679 ns/op 9049.39 MB/s Benchmark_RFanOut_1kx10x1000-16 2985 1155803 ns/op 9024.93 MB/s Benchmark_RFanOut_1kx10x1000-16 2935 1142904 ns/op 9126.78 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6979998 503.1 ns/op 4130.15 MB/s Benchmark_____FanIn_1kx100x1-16 6970959 504.0 ns/op 4123.40 MB/s Benchmark_____FanIn_1kx100x1-16 6970016 502.8 ns/op 4132.48 MB/s Benchmark_____FanIn_1kx100x1-16 6986978 506.4 ns/op 4103.63 MB/s Benchmark_____FanIn_1kx100x1-16 6900378 503.8 ns/op 4124.47 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2660584 1363 ns/op 6031.16 MB/s Benchmark_____FanIn_4kx100x1-16 2620822 1353 ns/op 6074.85 MB/s Benchmark_____FanIn_4kx100x1-16 2600499 1362 ns/op 6035.61 MB/s Benchmark_____FanIn_4kx100x1-16 2607802 1388 ns/op 5923.96 MB/s Benchmark_____FanIn_4kx100x1-16 2609558 1357 ns/op 6060.15 MB/s Benchmark_____FanIn_8kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 90058176 vs 8208000000 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:54676->127.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:53964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54704->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark_____FanIn_8kx100x1-16 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:54594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54304->127.0.0.1:5222: write: broken pipe 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: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:54178->127.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:54118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54538->127.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:54038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54282->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54478->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54360->127.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: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54290->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54696->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54230->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54352->127.0.0.1:5222: write: broken pipe 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:53934->127.0.0.1:5222: write: broken pipe 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: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: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: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54196->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54640->127.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:54632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54168->127.0.0.1:5222: write: broken pipe 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:54060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54710->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54394->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54172->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54078->127.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:54788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54324->127.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: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:54444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54564->127.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:54136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54052->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54706->127.0.0.1:5222: write: connection reset by peer Benchmark_____FanIn_8kx100x1-16 1721426 2116 ns/op 7757.67 MB/s Benchmark_____FanIn_8kx100x1-16 1712269 2085 ns/op 7871.86 MB/s Benchmark_____FanIn_8kx100x1-16 1681760 2111 ns/op 7775.13 MB/s Benchmark_____FanIn_8kx100x1-16 1715275 2139 ns/op 7674.21 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 870237 4143 ns/op 7916.67 MB/s Benchmark____FanIn_16kx100x1-16 863300 4123 ns/op 7954.59 MB/s Benchmark____FanIn_16kx100x1-16 872680 4101 ns/op 7998.29 MB/s Benchmark____FanIn_16kx100x1-16 861327 4119 ns/op 7963.84 MB/s Benchmark____FanIn_16kx100x1-16 881118 4132 ns/op 7938.79 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 3407444940 vs 10672028400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36242->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:36434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36652->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 165258 20103 ns/op 6521.77 MB/s Benchmark____FanIn_64kx100x1-16 169106 19807 ns/op 6619.04 MB/s Benchmark____FanIn_64kx100x1-16 169780 19932 ns/op 6577.62 MB/s Benchmark____FanIn_64kx100x1-16 167504 19752 ns/op 6637.57 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 937817860 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48830->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: 201747510 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50270->127.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: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: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:50416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50820->127.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:50280->127.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:51092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:50956->127.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:50882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50844->127.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:50548->127.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:50910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50472->127.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 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:50592->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50422->127.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:51000->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50386->127.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:50710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50376->127.0.0.1:5222: write: connection reset by peer 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:51106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51100->127.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:50972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:50536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50716->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51108->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: 115359200 vs 1310900000 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:52568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52830->127.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:52372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52728->127.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: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: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:52590->127.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:52294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52356->127.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:52174->127.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: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:52494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52542->127.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:52672->127.0.0.1:5222: write: connection reset by peer 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:52408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52190->127.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:52080->127.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:52746->127.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:52544->127.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:52298->127.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:52698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52230->127.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:52552->127.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: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:52722->127.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:52810->127.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:52218->127.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:52730->127.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:52412->127.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:52578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52070->127.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:52038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52832->127.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:52444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52462->127.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:52312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52482->127.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:52624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52596->127.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: 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:52708->127.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:52136->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52328->127.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:52660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52688->127.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:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 99366220 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54030->127.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: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:54500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54366->127.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:53878->127.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:54066->127.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:54660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54504->127.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:54328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53934->127.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:54438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54596->127.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:54256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54238->127.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:53994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54318->127.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:54654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54290->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54228->127.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:53904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54120->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 617827170 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56024->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56264->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56200->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5615160 638.6 ns/op 444.71 MB/s Benchmark___BumpPubCount_1x3-16 5576158 640.9 ns/op 443.13 MB/s Benchmark___BumpPubCount_1x3-16 5561139 642.4 ns/op 442.06 MB/s Benchmark___BumpPubCount_1x3-16 5522347 642.5 ns/op 442.05 MB/s Benchmark___BumpPubCount_1x3-16 5579061 640.3 ns/op 443.55 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5354823 669.3 ns/op 424.35 MB/s Benchmark___BumpPubCount_2x3-16 5361466 679.3 ns/op 418.09 MB/s Benchmark___BumpPubCount_2x3-16 5309218 675.0 ns/op 420.76 MB/s Benchmark___BumpPubCount_2x3-16 5309118 670.0 ns/op 423.90 MB/s Benchmark___BumpPubCount_2x3-16 5348241 668.1 ns/op 425.11 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5611641 641.4 ns/op 442.75 MB/s Benchmark___BumpPubCount_5x3-16 5523679 640.5 ns/op 443.44 MB/s Benchmark___BumpPubCount_5x3-16 5338364 638.8 ns/op 444.60 MB/s Benchmark___BumpPubCount_5x3-16 5387330 638.5 ns/op 444.78 MB/s Benchmark___BumpPubCount_5x3-16 5345662 638.7 ns/op 444.66 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5567197 642.6 ns/op 441.98 MB/s Benchmark__BumpPubCount_10x3-16 5592153 643.7 ns/op 441.22 MB/s Benchmark__BumpPubCount_10x3-16 5584342 641.2 ns/op 442.92 MB/s Benchmark__BumpPubCount_10x3-16 5604724 640.1 ns/op 443.70 MB/s Benchmark__BumpPubCount_10x3-16 5571952 636.2 ns/op 446.37 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11748951 282.0 ns/op 3688.34 MB/s Benchmark____GWs_Opt_1kx01x0-16 12260113 283.5 ns/op 3668.56 MB/s Benchmark____GWs_Opt_1kx01x0-16 12243982 277.7 ns/op 3745.45 MB/s Benchmark____GWs_Opt_1kx01x0-16 12472987 272.9 ns/op 3810.95 MB/s Benchmark____GWs_Opt_1kx01x0-16 12702208 286.8 ns/op 3626.53 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10269021 343.8 ns/op 6003.60 MB/s Benchmark____GWs_Opt_2kx01x0-16 9022396 394.0 ns/op 5239.05 MB/s Benchmark____GWs_Opt_2kx01x0-16 9381699 351.2 ns/op 5877.22 MB/s Benchmark____GWs_Opt_2kx01x0-16 10601798 333.3 ns/op 6192.49 MB/s Benchmark____GWs_Opt_2kx01x0-16 9930638 335.9 ns/op 6144.72 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5735443 626.7 ns/op 6561.31 MB/s Benchmark____GWs_Opt_4kx01x0-16 5592819 611.6 ns/op 6722.92 MB/s Benchmark____GWs_Opt_4kx01x0-16 5760652 626.7 ns/op 6561.42 MB/s Benchmark____GWs_Opt_4kx01x0-16 5688952 641.4 ns/op 6410.70 MB/s Benchmark____GWs_Opt_4kx01x0-16 5857338 630.0 ns/op 6527.01 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 27190225 113.0 ns/op 9207.20 MB/s Benchmark____GWs_Opt_1kx10x0-16 28226983 114.5 ns/op 9080.37 MB/s Benchmark____GWs_Opt_1kx10x0-16 29910363 111.3 ns/op 9347.48 MB/s Benchmark____GWs_Opt_1kx10x0-16 24123586 145.0 ns/op 7170.71 MB/s Benchmark____GWs_Opt_1kx10x0-16 30524983 112.9 ns/op 9215.41 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24748815 141.0 ns/op 14641.57 MB/s Benchmark____GWs_Opt_2kx10x0-16 23845346 161.7 ns/op 12763.37 MB/s Benchmark____GWs_Opt_2kx10x0-16 21254407 151.8 ns/op 13596.63 MB/s Benchmark____GWs_Opt_2kx10x0-16 24253057 143.6 ns/op 14373.01 MB/s Benchmark____GWs_Opt_2kx10x0-16 24933110 153.3 ns/op 13463.63 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 10111506 359.3 ns/op 11446.02 MB/s Benchmark____GWs_Opt_4kx10x0-16 12572124 292.4 ns/op 14063.60 MB/s Benchmark____GWs_Opt_4kx10x0-16 10540929 328.2 ns/op 12527.68 MB/s Benchmark____GWs_Opt_4kx10x0-16 10276675 313.1 ns/op 13131.41 MB/s Benchmark____GWs_Opt_4kx10x0-16 12770404 285.4 ns/op 14405.94 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6633331 551.1 ns/op 5670.99 MB/s Benchmark____GWs_Opt_1kx01x1-16 6790465 554.7 ns/op 5633.18 MB/s Benchmark____GWs_Opt_1kx01x1-16 6583333 543.4 ns/op 5750.80 MB/s Benchmark____GWs_Opt_1kx01x1-16 6623055 554.5 ns/op 5635.72 MB/s Benchmark____GWs_Opt_1kx01x1-16 6664598 547.1 ns/op 5712.10 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4766066 831.8 ns/op 7449.71 MB/s Benchmark____GWs_Opt_2kx01x1-16 4710493 754.2 ns/op 8216.54 MB/s Benchmark____GWs_Opt_2kx01x1-16 4535331 750.7 ns/op 8254.72 MB/s Benchmark____GWs_Opt_2kx01x1-16 4669642 766.2 ns/op 8087.50 MB/s Benchmark____GWs_Opt_2kx01x1-16 4702646 756.5 ns/op 8191.72 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2635287 1373 ns/op 8991.35 MB/s Benchmark____GWs_Opt_4kx01x1-16 2637632 1346 ns/op 9167.81 MB/s Benchmark____GWs_Opt_4kx01x1-16 2585006 2243 ns/op 5502.88 MB/s Benchmark____GWs_Opt_4kx01x1-16 2660580 1453 ns/op 8490.79 MB/s Benchmark____GWs_Opt_4kx01x1-16 2649922 1753 ns/op 7040.78 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6595278 546.6 ns/op 5717.46 MB/s Benchmark____GWs_Opt_1kx10x1-16 6478542 555.4 ns/op 5626.22 MB/s Benchmark____GWs_Opt_1kx10x1-16 6325918 539.4 ns/op 5793.66 MB/s Benchmark____GWs_Opt_1kx10x1-16 6589574 542.7 ns/op 5757.87 MB/s Benchmark____GWs_Opt_1kx10x1-16 6523083 540.6 ns/op 5780.42 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4338210 785.0 ns/op 7894.64 MB/s Benchmark____GWs_Opt_2kx10x1-16 4272775 837.7 ns/op 7397.68 MB/s Benchmark____GWs_Opt_2kx10x1-16 4257481 829.2 ns/op 7473.16 MB/s Benchmark____GWs_Opt_2kx10x1-16 4804737 791.5 ns/op 7828.96 MB/s Benchmark____GWs_Opt_2kx10x1-16 4708219 751.5 ns/op 8246.28 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2330204 1525 ns/op 8091.89 MB/s Benchmark____GWs_Opt_4kx10x1-16 2365422 1506 ns/op 8194.07 MB/s Benchmark____GWs_Opt_4kx10x1-16 2370937 1545 ns/op 7988.33 MB/s Benchmark____GWs_Opt_4kx10x1-16 2304014 1497 ns/op 8242.61 MB/s Benchmark____GWs_Opt_4kx10x1-16 2561640 1416 ns/op 8715.44 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12514953 295.3 ns/op 3521.51 MB/s Benchmark____GWs_Int_1kx01x0-16 12421564 288.8 ns/op 3601.43 MB/s Benchmark____GWs_Int_1kx01x0-16 12328633 292.7 ns/op 3552.62 MB/s Benchmark____GWs_Int_1kx01x0-16 11856940 294.4 ns/op 3532.17 MB/s Benchmark____GWs_Int_1kx01x0-16 12617680 299.1 ns/op 3476.62 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10233012 334.8 ns/op 6164.15 MB/s Benchmark____GWs_Int_2kx01x0-16 10109749 380.0 ns/op 5431.37 MB/s Benchmark____GWs_Int_2kx01x0-16 10148451 356.0 ns/op 5797.37 MB/s Benchmark____GWs_Int_2kx01x0-16 10019248 351.7 ns/op 5869.15 MB/s Benchmark____GWs_Int_2kx01x0-16 10630326 350.8 ns/op 5883.61 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5614100 632.9 ns/op 6497.15 MB/s Benchmark____GWs_Int_4kx01x0-16 5500305 630.6 ns/op 6520.36 MB/s Benchmark____GWs_Int_4kx01x0-16 5591805 622.2 ns/op 6608.95 MB/s Benchmark____GWs_Int_4kx01x0-16 5680194 637.8 ns/op 6447.64 MB/s Benchmark____GWs_Int_4kx01x0-16 5776812 636.2 ns/op 6463.70 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32087402 110.5 ns/op 9410.64 MB/s Benchmark____GWs_Int_1kx10x0-16 32005287 110.3 ns/op 9431.53 MB/s Benchmark____GWs_Int_1kx10x0-16 31194458 117.5 ns/op 8853.44 MB/s Benchmark____GWs_Int_1kx10x0-16 29868752 106.9 ns/op 9730.00 MB/s Benchmark____GWs_Int_1kx10x0-16 31491348 114.3 ns/op 9102.61 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25121583 143.3 ns/op 14402.52 MB/s Benchmark____GWs_Int_2kx10x0-16 25580730 160.1 ns/op 12895.95 MB/s Benchmark____GWs_Int_2kx10x0-16 21699872 155.1 ns/op 13305.37 MB/s Benchmark____GWs_Int_2kx10x0-16 25537756 145.1 ns/op 14222.41 MB/s Benchmark____GWs_Int_2kx10x0-16 25937106 167.4 ns/op 12329.37 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 10969285 280.9 ns/op 14636.58 MB/s Benchmark____GWs_Int_4kx10x0-16 13037734 311.9 ns/op 13181.88 MB/s Benchmark____GWs_Int_4kx10x0-16 12450596 284.4 ns/op 14457.23 MB/s Benchmark____GWs_Int_4kx10x0-16 12497313 291.3 ns/op 14116.18 MB/s Benchmark____GWs_Int_4kx10x0-16 9264976 385.3 ns/op 10671.03 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6459529 560.7 ns/op 5573.76 MB/s Benchmark____GWs_Int_1kx01x1-16 6520726 563.6 ns/op 5544.33 MB/s Benchmark____GWs_Int_1kx01x1-16 6449624 564.2 ns/op 5538.73 MB/s Benchmark____GWs_Int_1kx01x1-16 6419791 553.6 ns/op 5644.45 MB/s Benchmark____GWs_Int_1kx01x1-16 6445798 557.4 ns/op 5606.63 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4696492 775.7 ns/op 7988.96 MB/s Benchmark____GWs_Int_2kx01x1-16 4726970 767.2 ns/op 8077.12 MB/s Benchmark____GWs_Int_2kx01x1-16 4653855 763.5 ns/op 8116.71 MB/s Benchmark____GWs_Int_2kx01x1-16 4749535 926.2 ns/op 6690.90 MB/s Benchmark____GWs_Int_2kx01x1-16 4729246 769.5 ns/op 8052.89 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2622079 1370 ns/op 9007.12 MB/s Benchmark____GWs_Int_4kx01x1-16 2664013 1373 ns/op 8990.60 MB/s Benchmark____GWs_Int_4kx01x1-16 2207244 1373 ns/op 8987.13 MB/s Benchmark____GWs_Int_4kx01x1-16 2650766 1536 ns/op 8033.96 MB/s Benchmark____GWs_Int_4kx01x1-16 2459359 1357 ns/op 9096.22 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6559762 547.9 ns/op 5703.45 MB/s Benchmark____GWs_Int_1kx10x1-16 6586287 554.5 ns/op 5636.13 MB/s Benchmark____GWs_Int_1kx10x1-16 6442021 555.0 ns/op 5630.48 MB/s Benchmark____GWs_Int_1kx10x1-16 6467504 555.3 ns/op 5627.42 MB/s Benchmark____GWs_Int_1kx10x1-16 6095052 550.2 ns/op 5680.17 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4269708 899.3 ns/op 6890.80 MB/s Benchmark____GWs_Int_2kx10x1-16 4074235 818.4 ns/op 7571.73 MB/s Benchmark____GWs_Int_2kx10x1-16 4102741 840.7 ns/op 7371.07 MB/s Benchmark____GWs_Int_2kx10x1-16 4371824 839.3 ns/op 7383.41 MB/s Benchmark____GWs_Int_2kx10x1-16 4223971 819.1 ns/op 7565.77 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2153634 1502 ns/op 8215.65 MB/s Benchmark____GWs_Int_4kx10x1-16 2383858 1499 ns/op 8233.64 MB/s Benchmark____GWs_Int_4kx10x1-16 2255149 1519 ns/op 8125.97 MB/s Benchmark____GWs_Int_4kx10x1-16 2389192 1506 ns/op 8194.53 MB/s Benchmark____GWs_Int_4kx10x1-16 2488167 1526 ns/op 8084.56 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8163646 440.3 ns/op 231.67 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8008483 440.2 ns/op 231.72 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8562951 432.6 ns/op 235.78 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7845144 440.6 ns/op 231.52 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8398641 436.3 ns/op 233.77 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 614502 5015 ns/op 35.29 MB/s Benchmark__GWs_Reqs_1SubEach-16 801333 5217 ns/op 33.93 MB/s Benchmark__GWs_Reqs_1SubEach-16 735848 5301 ns/op 33.39 MB/s Benchmark__GWs_Reqs_1SubEach-16 744417 5218 ns/op 33.92 MB/s Benchmark__GWs_Reqs_1SubEach-16 720206 5251 ns/op 33.71 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2065.570s ❌ Non-zero exit code: 1