> ROOT_DIR=/tmp/go-bench-away-job-40ea5260-17df-49e0-ac03-b2827c34ae41-3832153752 > OUTPUT_FILE=/tmp/go-bench-away-job-40ea5260-17df-49e0-ac03-b2827c34ae41-3832153752/results.txt > SHA_FILE=/tmp/go-bench-away-job-40ea5260-17df-49e0-ac03-b2827c34ae41-3832153752/sha.txt > GO_VERSION_FILE=/tmp/go-bench-away-job-40ea5260-17df-49e0-ac03-b2827c34ae41-3832153752/go_version.txt > GIT_REMOTE=https://github.com/nats-io/nats-server.git > GIT_REF=v2.12.3 > TESTS_DIR=test > BENCHMARKS_FILTER=Benchmark.* > BENCHMARK_REPETITIONS=5 > BENCHMARK_MIN_RUN_TIME=3s > MAX_RUN_TIME=4h0m0s > GO=/usr/local/go1.25.4/bin/go > GIT=/usr/bin/git Cloning https://github.com/nats-io/nats-server.git ref: v2.12.3 to /tmp/go-bench-away-job-40ea5260-17df-49e0-ac03-b2827c34ae41-3832153752/source.git SHA of v2.12.3: 067a55d46c77bc692f17a80dc21d5687d22408d1 Go runtime: go version go1.26.0 linux/amd64 AR='ar' CC='gcc' CGO_CFLAGS='-O2 -g' CGO_CPPFLAGS='' CGO_CXXFLAGS='-O2 -g' CGO_ENABLED='0' CGO_FFLAGS='-O2 -g' CGO_LDFLAGS='-O2 -g' CXX='g++' GCCGO='gccgo' GO111MODULE='' GOAMD64='v1' GOARCH='amd64' GOAUTH='netrc' GOBIN='' GOCACHE='/home/gauge-gba/.cache/go-build' GOCACHEPROG='' GODEBUG='' GOENV='/home/gauge-gba/.config/go/env' GOEXE='' GOEXPERIMENT='' GOFIPS140='off' GOFLAGS='' GOGCCFLAGS='-fPIC -m64 -fno-caret-diagnostics -Qunused-arguments -Wl,--no-gc-sections -fmessage-length=0 -ffile-prefix-map=/tmp/go-build3710324920=/tmp/go-build -gno-record-gcc-switches' GOHOSTARCH='amd64' GOHOSTOS='linux' GOINSECURE='' GOMOD='/tmp/go-bench-away-job-40ea5260-17df-49e0-ac03-b2827c34ae41-3832153752/source.git/go.mod' GOMODCACHE='/home/gauge-gba/go/pkg/mod' GONOPROXY='' GONOSUMDB='' GOOS='linux' GOPATH='/home/gauge-gba/go' GOPRIVATE='' GOPROXY='https://proxy.golang.org,direct' GOROOT='/usr/local/go1.25.4' GOSUMDB='sum.golang.org' GOTELEMETRY='local' GOTELEMETRYDIR='/home/gauge-gba/.config/go/telemetry' GOTMPDIR='' GOTOOLCHAIN='auto' GOTOOLDIR='/usr/local/go1.25.4/pkg/tool/linux_amd64' GOVCS='' GOVERSION='go1.26.0' GOWORK='' PKG_CONFIG='pkg-config' Running benchmarks with filter 'Benchmark.*' (5 repetitions, 3s min runtime, timeout in 4h0m0s) goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 57373821 62.84 ns/op 175.05 MB/s Benchmark______Pub0b_Payload-16 53937762 62.77 ns/op 175.24 MB/s Benchmark______Pub0b_Payload-16 49782568 62.51 ns/op 175.98 MB/s Benchmark______Pub0b_Payload-16 54186566 62.83 ns/op 175.09 MB/s Benchmark______Pub0b_Payload-16 53564140 62.75 ns/op 175.29 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 52968244 63.42 ns/op 299.61 MB/s Benchmark______Pub8b_Payload-16 52979448 63.16 ns/op 300.81 MB/s Benchmark______Pub8b_Payload-16 55469358 63.32 ns/op 300.08 MB/s Benchmark______Pub8b_Payload-16 52250048 63.59 ns/op 298.77 MB/s Benchmark______Pub8b_Payload-16 52971952 63.35 ns/op 299.91 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 49823000 68.41 ns/op 643.15 MB/s Benchmark_____Pub32b_Payload-16 44244498 68.50 ns/op 642.36 MB/s Benchmark_____Pub32b_Payload-16 44174599 68.27 ns/op 644.50 MB/s Benchmark_____Pub32b_Payload-16 52531274 69.10 ns/op 636.73 MB/s Benchmark_____Pub32b_Payload-16 45766894 71.20 ns/op 617.96 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 42749192 78.74 ns/op 1790.75 MB/s Benchmark____Pub128B_Payload-16 42686661 79.82 ns/op 1766.43 MB/s Benchmark____Pub128B_Payload-16 43322119 78.19 ns/op 1803.32 MB/s Benchmark____Pub128B_Payload-16 45962062 79.66 ns/op 1770.00 MB/s Benchmark____Pub128B_Payload-16 46224939 80.21 ns/op 1757.92 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 38031321 86.70 ns/op 3102.69 MB/s Benchmark____Pub256B_Payload-16 41693866 87.39 ns/op 3078.33 MB/s Benchmark____Pub256B_Payload-16 42062431 87.96 ns/op 3058.08 MB/s Benchmark____Pub256B_Payload-16 38935468 85.74 ns/op 3137.45 MB/s Benchmark____Pub256B_Payload-16 34493001 88.12 ns/op 3052.53 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 27140806 138.2 ns/op 7512.10 MB/s Benchmark______Pub1K_Payload-16 26785671 130.6 ns/op 7949.02 MB/s Benchmark______Pub1K_Payload-16 24167761 127.6 ns/op 8135.72 MB/s Benchmark______Pub1K_Payload-16 23747199 135.1 ns/op 7682.07 MB/s Benchmark______Pub1K_Payload-16 28794195 134.2 ns/op 7733.94 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5689736 643.5 ns/op 6387.34 MB/s Benchmark______Pub4K_Payload-16 5494791 624.0 ns/op 6586.19 MB/s Benchmark______Pub4K_Payload-16 5706435 627.4 ns/op 6550.85 MB/s Benchmark______Pub4K_Payload-16 5507626 620.7 ns/op 6621.50 MB/s Benchmark______Pub4K_Payload-16 5407567 629.6 ns/op 6528.13 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2784740 1293 ns/op 6348.22 MB/s Benchmark______Pub8K_Payload-16 2785434 1291 ns/op 6354.10 MB/s Benchmark______Pub8K_Payload-16 2741029 1283 ns/op 6395.73 MB/s Benchmark______Pub8K_Payload-16 2687364 1280 ns/op 6411.12 MB/s Benchmark______Pub8K_Payload-16 2679464 1282 ns/op 6400.33 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 660806 5508 ns/op 5951.36 MB/s Benchmark_____Pub32K_Payload-16 588201 5404 ns/op 6066.17 MB/s Benchmark_____Pub32K_Payload-16 645597 5546 ns/op 5911.45 MB/s Benchmark_____Pub32K_Payload-16 652947 5472 ns/op 5990.52 MB/s Benchmark_____Pub32K_Payload-16 583362 5456 ns/op 6008.87 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 35196969 87.11 ns/op 126.28 MB/s Benchmark__AuthPub0b_Payload-16 37425924 84.56 ns/op 130.09 MB/s Benchmark__AuthPub0b_Payload-16 40495107 84.59 ns/op 130.03 MB/s Benchmark__AuthPub0b_Payload-16 40245442 84.26 ns/op 130.55 MB/s Benchmark__AuthPub0b_Payload-16 40282689 84.90 ns/op 129.57 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 17031968 207.6 ns/op Benchmark_____________PubSub-16 17047396 208.1 ns/op Benchmark_____________PubSub-16 17039919 208.1 ns/op Benchmark_____________PubSub-16 17049258 206.5 ns/op Benchmark_____________PubSub-16 17085243 207.4 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 17063259 206.7 ns/op Benchmark_____PubSubTwoConns-16 17006138 205.9 ns/op Benchmark_____PubSubTwoConns-16 17013123 207.0 ns/op Benchmark_____PubSubTwoConns-16 17184183 206.3 ns/op Benchmark_____PubSubTwoConns-16 16970113 207.5 ns/op Benchmark__PubServiceImports bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:52546->127.0.0.1:37939: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:33024->127.0.0.1:35925: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:43906->127.0.0.1:46179: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:40694->127.0.0.1:33959: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:355: Received error on FLUSH write: write tcp 127.0.0.1:36062->127.0.0.1:34523: 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 15818716 225.7 ns/op Benchmark_____PubTwoQueueSub-16 15825954 225.7 ns/op Benchmark_____PubTwoQueueSub-16 15751239 225.5 ns/op Benchmark_____PubTwoQueueSub-16 15740258 226.1 ns/op Benchmark_____PubTwoQueueSub-16 15815157 225.4 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15773457 226.5 ns/op Benchmark____PubFourQueueSub-16 15670400 225.7 ns/op Benchmark____PubFourQueueSub-16 15817818 225.7 ns/op Benchmark____PubFourQueueSub-16 15927922 226.3 ns/op Benchmark____PubFourQueueSub-16 15717015 225.6 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15830570 224.0 ns/op Benchmark___PubEightQueueSub-16 15803329 226.3 ns/op Benchmark___PubEightQueueSub-16 15613263 226.4 ns/op Benchmark___PubEightQueueSub-16 15688255 225.4 ns/op Benchmark___PubEightQueueSub-16 15530362 225.0 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23631 155452 ns/op Benchmark_PubSub512kTwoConns-16 23404 156351 ns/op Benchmark_PubSub512kTwoConns-16 23167 155041 ns/op Benchmark_PubSub512kTwoConns-16 23020 156450 ns/op Benchmark_PubSub512kTwoConns-16 23016 153146 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16604274 210.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 16609588 209.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 16707460 210.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 16394400 210.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 16727650 210.1 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16626206 208.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 16829732 210.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 16577083 210.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 16683182 210.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 16751242 210.6 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 12340794 280.6 ns/op Benchmark____RoutedPubSub_0b-16 12689700 284.8 ns/op Benchmark____RoutedPubSub_0b-16 12358455 282.5 ns/op Benchmark____RoutedPubSub_0b-16 12730587 281.5 ns/op Benchmark____RoutedPubSub_0b-16 12191349 286.6 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6742813 510.0 ns/op Benchmark____RoutedPubSub_1K-16 6651200 517.1 ns/op Benchmark____RoutedPubSub_1K-16 6729949 525.2 ns/op Benchmark____RoutedPubSub_1K-16 6774712 511.3 ns/op Benchmark____RoutedPubSub_1K-16 6767125 518.2 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 87152 42111 ns/op Benchmark__RoutedPubSub_100K-16 82737 42193 ns/op Benchmark__RoutedPubSub_100K-16 85190 42197 ns/op Benchmark__RoutedPubSub_100K-16 84169 44371 ns/op Benchmark__RoutedPubSub_100K-16 74716 46009 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 10517464 338.2 ns/op Benchmark____Routed2QueueSub-16 10400989 343.1 ns/op Benchmark____Routed2QueueSub-16 8962123 340.3 ns/op Benchmark____Routed2QueueSub-16 10593957 348.7 ns/op Benchmark____Routed2QueueSub-16 10510360 334.2 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 10574810 343.4 ns/op Benchmark____Routed4QueueSub-16 8609949 355.2 ns/op Benchmark____Routed4QueueSub-16 10438402 346.3 ns/op Benchmark____Routed4QueueSub-16 10280752 343.5 ns/op Benchmark____Routed4QueueSub-16 10408840 345.7 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 10298510 350.4 ns/op Benchmark____Routed8QueueSub-16 8492007 375.4 ns/op Benchmark____Routed8QueueSub-16 10226671 343.7 ns/op Benchmark____Routed8QueueSub-16 10270372 356.9 ns/op Benchmark____Routed8QueueSub-16 10252381 346.3 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 9518877 374.1 ns/op Benchmark___Routed16QueueSub-16 8068096 373.2 ns/op Benchmark___Routed16QueueSub-16 8280630 375.1 ns/op Benchmark___Routed16QueueSub-16 7982197 379.3 ns/op Benchmark___Routed16QueueSub-16 7958638 378.4 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 7146687 462.1 ns/op Benchmark____________RouteCompressOff-16 6799509 469.8 ns/op Benchmark____________RouteCompressOff-16 7268232 462.4 ns/op Benchmark____________RouteCompressOff-16 7162737 463.8 ns/op Benchmark____________RouteCompressOff-16 6944751 470.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 7152426 466.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 7015653 467.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6827570 471.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6939068 465.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6891164 471.6 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6953540 457.4 ns/op Benchmark_________RouteCompressS2Fast-16 7462736 465.3 ns/op Benchmark_________RouteCompressS2Fast-16 7008428 466.7 ns/op Benchmark_________RouteCompressS2Fast-16 7079895 458.7 ns/op Benchmark_________RouteCompressS2Fast-16 6566328 474.4 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6703530 470.7 ns/op Benchmark_______RouteCompressS2Better-16 6828178 466.4 ns/op Benchmark_______RouteCompressS2Better-16 7360416 461.0 ns/op Benchmark_______RouteCompressS2Better-16 7277050 458.0 ns/op Benchmark_______RouteCompressS2Better-16 7059110 470.4 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 7067220 458.8 ns/op Benchmark_________RouteCompressS2Best-16 7420155 458.4 ns/op Benchmark_________RouteCompressS2Best-16 6965185 467.9 ns/op Benchmark_________RouteCompressS2Best-16 6801517 465.4 ns/op Benchmark_________RouteCompressS2Best-16 6898412 471.0 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5128585 698.6 ns/op 356.44 MB/s Benchmark______FanOut_8x1x10-16 5158256 691.0 ns/op 360.37 MB/s Benchmark______FanOut_8x1x10-16 5171874 690.6 ns/op 360.57 MB/s Benchmark______FanOut_8x1x10-16 5211415 690.7 ns/op 360.50 MB/s Benchmark______FanOut_8x1x10-16 5177568 689.7 ns/op 361.04 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 608739 5368 ns/op 432.01 MB/s Benchmark_____FanOut_8x1x100-16 625596 5363 ns/op 432.40 MB/s Benchmark_____FanOut_8x1x100-16 650925 5378 ns/op 431.21 MB/s Benchmark_____FanOut_8x1x100-16 631614 5397 ns/op 429.67 MB/s Benchmark_____FanOut_8x1x100-16 618397 5353 ns/op 433.21 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 52792 68031 ns/op 338.36 MB/s Benchmark____FanOut_8x10x100-16 52514 67871 ns/op 339.16 MB/s Benchmark____FanOut_8x10x100-16 52827 67926 ns/op 338.89 MB/s Benchmark____FanOut_8x10x100-16 52664 68012 ns/op 338.45 MB/s Benchmark____FanOut_8x10x100-16 52858 67893 ns/op 339.05 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6471 537053 ns/op 446.92 MB/s Benchmark___FanOut_8x10x1000-16 6376 535703 ns/op 448.04 MB/s Benchmark___FanOut_8x10x1000-16 6632 527328 ns/op 455.16 MB/s Benchmark___FanOut_8x10x1000-16 6512 530254 ns/op 452.65 MB/s Benchmark___FanOut_8x10x1000-16 6900 531679 ns/op 451.44 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5696 631538 ns/op 364.22 MB/s Benchmark___FanOut_8x100x100-16 5616 633299 ns/op 363.21 MB/s Benchmark___FanOut_8x100x100-16 5503 632270 ns/op 363.80 MB/s Benchmark___FanOut_8x100x100-16 5493 631736 ns/op 364.11 MB/s Benchmark___FanOut_8x100x100-16 5559 632092 ns/op 363.90 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 646 5614817 ns/op 427.44 MB/s Benchmark__FanOut_8x100x1000-16 640 5565811 ns/op 431.21 MB/s Benchmark__FanOut_8x100x1000-16 634 5506178 ns/op 435.88 MB/s Benchmark__FanOut_8x100x1000-16 663 5493297 ns/op 436.90 MB/s Benchmark__FanOut_8x100x1000-16 640 5509500 ns/op 435.61 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 609 5849624 ns/op 427.38 MB/s Benchmark__FanOut_8x10x10000-16 609 5914683 ns/op 422.68 MB/s Benchmark__FanOut_8x10x10000-16 626 5844882 ns/op 427.73 MB/s Benchmark__FanOut_8x10x10000-16 603 5871666 ns/op 425.78 MB/s Benchmark__FanOut_8x10x10000-16 615 5909180 ns/op 423.07 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1048 3408245 ns/op 337.42 MB/s Benchmark___FanOut_8x500x100-16 1053 3414270 ns/op 336.83 MB/s Benchmark___FanOut_8x500x100-16 1048 3400456 ns/op 338.20 MB/s Benchmark___FanOut_8x500x100-16 1040 3390812 ns/op 339.16 MB/s Benchmark___FanOut_8x500x100-16 1052 3397472 ns/op 338.49 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 377719 8956 ns/op 1634.83 MB/s Benchmark___FanOut_128x1x100-16 375938 8975 ns/op 1631.35 MB/s Benchmark___FanOut_128x1x100-16 384855 8909 ns/op 1643.37 MB/s Benchmark___FanOut_128x1x100-16 389358 8899 ns/op 1645.21 MB/s Benchmark___FanOut_128x1x100-16 374156 8877 ns/op 1649.38 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 34713 102662 ns/op 1413.78 MB/s Benchmark__FanOut_128x10x100-16 35119 102880 ns/op 1410.79 MB/s Benchmark__FanOut_128x10x100-16 35040 102396 ns/op 1417.45 MB/s Benchmark__FanOut_128x10x100-16 35011 102762 ns/op 1412.41 MB/s Benchmark__FanOut_128x10x100-16 34755 102721 ns/op 1412.97 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4345 795004 ns/op 1836.65 MB/s Benchmark_FanOut_128x10x1000-16 4075 796251 ns/op 1833.77 MB/s Benchmark_FanOut_128x10x1000-16 4184 797027 ns/op 1831.98 MB/s Benchmark_FanOut_128x10x1000-16 4551 798705 ns/op 1828.14 MB/s Benchmark_FanOut_128x10x1000-16 4398 792002 ns/op 1843.61 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3727 942890 ns/op 1537.97 MB/s Benchmark_FanOut_128x100x100-16 3746 946270 ns/op 1532.48 MB/s Benchmark_FanOut_128x100x100-16 3702 941980 ns/op 1539.46 MB/s Benchmark_FanOut_128x100x100-16 3712 947332 ns/op 1530.76 MB/s Benchmark_FanOut_128x100x100-16 3741 943927 ns/op 1536.29 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 411 8560868 ns/op 1705.45 MB/s BenchmarkFanOut_128x100x1000-16 421 8491286 ns/op 1719.43 MB/s BenchmarkFanOut_128x100x1000-16 422 8509073 ns/op 1715.83 MB/s BenchmarkFanOut_128x100x1000-16 420 8521718 ns/op 1713.29 MB/s BenchmarkFanOut_128x100x1000-16 428 8446557 ns/op 1728.53 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 403 8828965 ns/op 1664.99 MB/s BenchmarkFanOut_128x10x10000-16 404 8886814 ns/op 1654.15 MB/s BenchmarkFanOut_128x10x10000-16 404 8822107 ns/op 1666.28 MB/s BenchmarkFanOut_128x10x10000-16 409 8902181 ns/op 1651.30 MB/s BenchmarkFanOut_128x10x10000-16 403 8875861 ns/op 1656.19 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 716 4979629 ns/op 1455.96 MB/s BenchmarkFanOut__128x500x100-16 711 4990351 ns/op 1452.83 MB/s BenchmarkFanOut__128x500x100-16 709 4988057 ns/op 1453.50 MB/s BenchmarkFanOut__128x500x100-16 720 4982839 ns/op 1455.02 MB/s BenchmarkFanOut__128x500x100-16 700 4995463 ns/op 1451.35 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 2000 1774986 ns/op 2980.60 MB/s Benchmark_FanOut_512x100x100-16 2002 1781802 ns/op 2969.20 MB/s Benchmark_FanOut_512x100x100-16 2004 1783430 ns/op 2966.49 MB/s Benchmark_FanOut_512x100x100-16 1988 1786348 ns/op 2961.64 MB/s Benchmark_FanOut_512x100x100-16 1999 1790002 ns/op 2955.60 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 220 16000369 ns/op 3312.46 MB/s Benchmark__FanOut_512x100x1k-16 223 16105501 ns/op 3290.83 MB/s Benchmark__FanOut_512x100x1k-16 222 16033782 ns/op 3305.55 MB/s Benchmark__FanOut_512x100x1k-16 223 16159540 ns/op 3279.83 MB/s Benchmark__FanOut_512x100x1k-16 223 16087626 ns/op 3294.49 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3404 1140295 ns/op 9147.66 MB/s Benchmark____FanOut_1kx10x1k-16 3094 1113301 ns/op 9369.47 MB/s Benchmark____FanOut_1kx10x1k-16 3286 1114526 ns/op 9359.17 MB/s Benchmark____FanOut_1kx10x1k-16 3182 1101888 ns/op 9466.52 MB/s Benchmark____FanOut_1kx10x1k-16 3073 1096965 ns/op 9509.00 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2922 1188691 ns/op 8766.82 MB/s Benchmark__FanOut_1kx100x100-16 2906 1194558 ns/op 8723.76 MB/s Benchmark__FanOut_1kx100x100-16 2982 1198391 ns/op 8695.86 MB/s Benchmark__FanOut_1kx100x100-16 2894 1194837 ns/op 8721.72 MB/s Benchmark__FanOut_1kx100x100-16 2966 1191084 ns/op 8749.21 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4659346 738.2 ns/op 337.31 MB/s Benchmark_____RFanOut_8x1x10-16 4563740 740.5 ns/op 336.27 MB/s Benchmark_____RFanOut_8x1x10-16 4588849 758.5 ns/op 328.26 MB/s Benchmark_____RFanOut_8x1x10-16 4665016 735.1 ns/op 338.72 MB/s Benchmark_____RFanOut_8x1x10-16 4620330 738.9 ns/op 337.01 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 620508 5372 ns/op 431.70 MB/s Benchmark____RFanOut_8x1x100-16 608960 5394 ns/op 429.89 MB/s Benchmark____RFanOut_8x1x100-16 588379 5398 ns/op 429.62 MB/s Benchmark____RFanOut_8x1x100-16 611143 5426 ns/op 427.37 MB/s Benchmark____RFanOut_8x1x100-16 603094 5392 ns/op 430.04 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 52875 67739 ns/op 339.82 MB/s Benchmark___RFanOut_8x10x100-16 52851 67715 ns/op 339.94 MB/s Benchmark___RFanOut_8x10x100-16 52966 67675 ns/op 340.14 MB/s Benchmark___RFanOut_8x10x100-16 52830 67781 ns/op 339.61 MB/s Benchmark___RFanOut_8x10x100-16 52443 67887 ns/op 339.08 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6354 534533 ns/op 449.03 MB/s Benchmark__RFanOut_8x10x1000-16 6621 537290 ns/op 446.72 MB/s Benchmark__RFanOut_8x10x1000-16 6588 534813 ns/op 448.79 MB/s Benchmark__RFanOut_8x10x1000-16 6163 535755 ns/op 448.00 MB/s Benchmark__RFanOut_8x10x1000-16 6723 532554 ns/op 450.69 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5503 634523 ns/op 362.51 MB/s Benchmark__RFanOut_8x100x100-16 5503 635056 ns/op 362.20 MB/s Benchmark__RFanOut_8x100x100-16 5484 644392 ns/op 356.95 MB/s Benchmark__RFanOut_8x100x100-16 5563 634619 ns/op 362.45 MB/s Benchmark__RFanOut_8x100x100-16 5534 635989 ns/op 361.67 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 646 5558160 ns/op 431.80 MB/s Benchmark_RFanOut_8x100x1000-16 644 5528847 ns/op 434.09 MB/s Benchmark_RFanOut_8x100x1000-16 632 5464604 ns/op 439.19 MB/s Benchmark_RFanOut_8x100x1000-16 660 5511215 ns/op 435.48 MB/s Benchmark_RFanOut_8x100x1000-16 642 5505341 ns/op 435.94 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 616 5808342 ns/op 430.42 MB/s Benchmark_RFanOut_8x10x10000-16 607 5835235 ns/op 428.44 MB/s Benchmark_RFanOut_8x10x10000-16 624 5908736 ns/op 423.11 MB/s Benchmark_RFanOut_8x10x10000-16 600 5885785 ns/op 424.76 MB/s Benchmark_RFanOut_8x10x10000-16 616 5786886 ns/op 432.01 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3230 1110520 ns/op 9392.93 MB/s Benchmark_RFanOut_1kx10x1000-16 3442 1094503 ns/op 9530.39 MB/s Benchmark_RFanOut_1kx10x1000-16 3476 1110151 ns/op 9396.05 MB/s Benchmark_RFanOut_1kx10x1000-16 2989 1118916 ns/op 9322.45 MB/s Benchmark_RFanOut_1kx10x1000-16 3175 1098104 ns/op 9499.14 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7333732 486.5 ns/op 4271.29 MB/s Benchmark_____FanIn_1kx100x1-16 7157558 485.3 ns/op 4282.25 MB/s Benchmark_____FanIn_1kx100x1-16 7216336 485.5 ns/op 4280.13 MB/s Benchmark_____FanIn_1kx100x1-16 7153728 486.9 ns/op 4267.77 MB/s Benchmark_____FanIn_1kx100x1-16 7140174 485.2 ns/op 4282.79 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2703517 1314 ns/op 6255.65 MB/s Benchmark_____FanIn_4kx100x1-16 2748121 1332 ns/op 6174.82 MB/s Benchmark_____FanIn_4kx100x1-16 2712243 1353 ns/op 6074.70 MB/s Benchmark_____FanIn_4kx100x1-16 2662809 1320 ns/op 6230.93 MB/s Benchmark_____FanIn_4kx100x1-16 2686954 1349 ns/op 6094.58 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1722639 2083 ns/op 7878.69 MB/s Benchmark_____FanIn_8kx100x1-16 1719018 2101 ns/op 7813.51 MB/s Benchmark_____FanIn_8kx100x1-16 1711708 2107 ns/op 7789.94 MB/s Benchmark_____FanIn_8kx100x1-16 1686850 2082 ns/op 7884.03 MB/s Benchmark_____FanIn_8kx100x1-16 1714495 2099 ns/op 7821.17 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 871873 4128 ns/op 7945.28 MB/s Benchmark____FanIn_16kx100x1-16 842071 4190 ns/op 7828.71 MB/s Benchmark____FanIn_16kx100x1-16 870864 4144 ns/op 7914.23 MB/s Benchmark____FanIn_16kx100x1-16 866588 4111 ns/op 7978.43 MB/s Benchmark____FanIn_16kx100x1-16 881661 4141 ns/op 7921.51 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 163708 19514 ns/op 6718.45 MB/s Benchmark____FanIn_64kx100x1-16 167551 19653 ns/op 6670.90 MB/s Benchmark____FanIn_64kx100x1-16 168110 19906 ns/op 6586.21 MB/s Benchmark____FanIn_64kx100x1-16 168356 19854 ns/op 6603.55 MB/s Benchmark____FanIn_64kx100x1-16 171892 19944 ns/op 6573.53 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 769629390 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:59556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58930->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:58864->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 111819770 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:32808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:60782->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:33144->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: 984879170 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:34280->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: 187196520 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: 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:1100: Received error on PUB write: write tcp 127.0.0.1:36784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:36890->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: 123093510 vs 1310900000 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38550->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:38132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1100: Received error on PUB write: write tcp 127.0.0.1:37946->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 6007953 592.0 ns/op 479.70 MB/s Benchmark___BumpPubCount_1x3-16 6041390 591.3 ns/op 480.28 MB/s Benchmark___BumpPubCount_1x3-16 5988806 592.4 ns/op 479.40 MB/s Benchmark___BumpPubCount_1x3-16 6036124 595.1 ns/op 477.23 MB/s Benchmark___BumpPubCount_1x3-16 6056145 594.8 ns/op 477.43 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5736331 627.2 ns/op 452.82 MB/s Benchmark___BumpPubCount_2x3-16 5696407 627.2 ns/op 452.78 MB/s Benchmark___BumpPubCount_2x3-16 5634921 629.2 ns/op 451.34 MB/s Benchmark___BumpPubCount_2x3-16 5639271 627.1 ns/op 452.88 MB/s Benchmark___BumpPubCount_2x3-16 5683101 634.5 ns/op 447.62 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5873889 611.9 ns/op 464.13 MB/s Benchmark___BumpPubCount_5x3-16 5430231 616.4 ns/op 460.71 MB/s Benchmark___BumpPubCount_5x3-16 5817427 612.1 ns/op 463.97 MB/s Benchmark___BumpPubCount_5x3-16 5854836 612.9 ns/op 463.41 MB/s Benchmark___BumpPubCount_5x3-16 5857287 613.6 ns/op 462.85 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5897618 609.5 ns/op 465.93 MB/s Benchmark__BumpPubCount_10x3-16 5873829 609.0 ns/op 466.36 MB/s Benchmark__BumpPubCount_10x3-16 5907477 607.5 ns/op 467.51 MB/s Benchmark__BumpPubCount_10x3-16 5942293 609.1 ns/op 466.29 MB/s Benchmark__BumpPubCount_10x3-16 5912174 606.0 ns/op 468.62 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11335867 264.9 ns/op 3926.68 MB/s Benchmark____GWs_Opt_1kx01x0-16 12871395 268.7 ns/op 3869.92 MB/s Benchmark____GWs_Opt_1kx01x0-16 12804703 262.8 ns/op 3957.14 MB/s Benchmark____GWs_Opt_1kx01x0-16 13233589 262.9 ns/op 3955.85 MB/s Benchmark____GWs_Opt_1kx01x0-16 12884905 270.8 ns/op 3840.63 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 11263110 327.5 ns/op 6301.83 MB/s Benchmark____GWs_Opt_2kx01x0-16 9106461 338.4 ns/op 6099.63 MB/s Benchmark____GWs_Opt_2kx01x0-16 11294430 319.0 ns/op 6469.89 MB/s Benchmark____GWs_Opt_2kx01x0-16 10732246 316.6 ns/op 6518.99 MB/s Benchmark____GWs_Opt_2kx01x0-16 10308536 321.8 ns/op 6414.32 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 6011416 614.6 ns/op 6690.33 MB/s Benchmark____GWs_Opt_4kx01x0-16 6019171 597.5 ns/op 6882.53 MB/s Benchmark____GWs_Opt_4kx01x0-16 6145434 603.5 ns/op 6813.61 MB/s Benchmark____GWs_Opt_4kx01x0-16 6011954 605.4 ns/op 6791.81 MB/s Benchmark____GWs_Opt_4kx01x0-16 5875868 600.9 ns/op 6842.67 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28806272 108.9 ns/op 9551.71 MB/s Benchmark____GWs_Opt_1kx10x0-16 31831878 114.4 ns/op 9091.10 MB/s Benchmark____GWs_Opt_1kx10x0-16 30456574 108.7 ns/op 9568.44 MB/s Benchmark____GWs_Opt_1kx10x0-16 28055509 109.8 ns/op 9471.60 MB/s Benchmark____GWs_Opt_1kx10x0-16 33740094 114.0 ns/op 9119.47 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24480405 139.9 ns/op 14750.92 MB/s Benchmark____GWs_Opt_2kx10x0-16 19077070 159.4 ns/op 12950.33 MB/s Benchmark____GWs_Opt_2kx10x0-16 25115377 141.2 ns/op 14621.72 MB/s Benchmark____GWs_Opt_2kx10x0-16 24533228 142.0 ns/op 14534.39 MB/s Benchmark____GWs_Opt_2kx10x0-16 25636239 155.9 ns/op 13241.76 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 8832957 371.5 ns/op 11068.37 MB/s Benchmark____GWs_Opt_4kx10x0-16 12648985 289.1 ns/op 14225.66 MB/s Benchmark____GWs_Opt_4kx10x0-16 12907569 293.9 ns/op 13991.66 MB/s Benchmark____GWs_Opt_4kx10x0-16 8126013 370.4 ns/op 11100.98 MB/s Benchmark____GWs_Opt_4kx10x0-16 12404646 320.2 ns/op 12841.73 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6271713 564.7 ns/op 5533.52 MB/s Benchmark____GWs_Opt_1kx01x1-16 6314419 567.8 ns/op 5503.90 MB/s Benchmark____GWs_Opt_1kx01x1-16 6129711 1003 ns/op 3114.44 MB/s Benchmark____GWs_Opt_1kx01x1-16 6311326 569.0 ns/op 5491.86 MB/s Benchmark____GWs_Opt_1kx01x1-16 6316484 569.8 ns/op 5484.14 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4620902 806.5 ns/op 7683.64 MB/s Benchmark____GWs_Opt_2kx01x1-16 4552305 811.7 ns/op 7634.76 MB/s Benchmark____GWs_Opt_2kx01x1-16 4378328 818.4 ns/op 7571.67 MB/s Benchmark____GWs_Opt_2kx01x1-16 4534192 952.7 ns/op 6504.54 MB/s Benchmark____GWs_Opt_2kx01x1-16 4174666 947.7 ns/op 6538.87 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2560917 1484 ns/op 8318.83 MB/s Benchmark____GWs_Opt_4kx01x1-16 2490853 1527 ns/op 8080.96 MB/s Benchmark____GWs_Opt_4kx01x1-16 2520384 1414 ns/op 8726.34 MB/s Benchmark____GWs_Opt_4kx01x1-16 2478733 1444 ns/op 8546.07 MB/s Benchmark____GWs_Opt_4kx01x1-16 2574834 1398 ns/op 8826.74 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 5861512 579.7 ns/op 5390.65 MB/s Benchmark____GWs_Opt_1kx10x1-16 5827233 578.2 ns/op 5404.78 MB/s Benchmark____GWs_Opt_1kx10x1-16 5934985 574.9 ns/op 5435.51 MB/s Benchmark____GWs_Opt_1kx10x1-16 6153002 568.4 ns/op 5497.92 MB/s Benchmark____GWs_Opt_1kx10x1-16 5917546 572.5 ns/op 5458.17 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4089030 875.4 ns/op 7079.43 MB/s Benchmark____GWs_Opt_2kx10x1-16 4006639 872.7 ns/op 7100.90 MB/s Benchmark____GWs_Opt_2kx10x1-16 3961353 875.5 ns/op 7078.03 MB/s Benchmark____GWs_Opt_2kx10x1-16 4033555 875.3 ns/op 7080.26 MB/s Benchmark____GWs_Opt_2kx10x1-16 3977037 865.1 ns/op 7163.43 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2198520 1543 ns/op 7998.41 MB/s Benchmark____GWs_Opt_4kx10x1-16 2342517 1617 ns/op 7630.11 MB/s Benchmark____GWs_Opt_4kx10x1-16 2327050 1524 ns/op 8098.32 MB/s Benchmark____GWs_Opt_4kx10x1-16 2239612 1545 ns/op 7985.45 MB/s Benchmark____GWs_Opt_4kx10x1-16 2377287 1540 ns/op 8014.56 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12474111 288.2 ns/op 3608.63 MB/s Benchmark____GWs_Int_1kx01x0-16 12687492 288.3 ns/op 3607.17 MB/s Benchmark____GWs_Int_1kx01x0-16 12460114 283.9 ns/op 3663.11 MB/s Benchmark____GWs_Int_1kx01x0-16 12845797 296.8 ns/op 3504.39 MB/s Benchmark____GWs_Int_1kx01x0-16 12229132 282.6 ns/op 3680.65 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10186258 337.5 ns/op 6114.71 MB/s Benchmark____GWs_Int_2kx01x0-16 9734236 349.5 ns/op 5904.83 MB/s Benchmark____GWs_Int_2kx01x0-16 10169694 347.5 ns/op 5939.95 MB/s Benchmark____GWs_Int_2kx01x0-16 8786082 347.8 ns/op 5935.11 MB/s Benchmark____GWs_Int_2kx01x0-16 9654519 352.9 ns/op 5848.41 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5774376 631.8 ns/op 6508.87 MB/s Benchmark____GWs_Int_4kx01x0-16 5796000 647.9 ns/op 6346.71 MB/s Benchmark____GWs_Int_4kx01x0-16 5871816 612.0 ns/op 6718.46 MB/s Benchmark____GWs_Int_4kx01x0-16 5466536 632.5 ns/op 6500.94 MB/s Benchmark____GWs_Int_4kx01x0-16 5109522 620.6 ns/op 6625.54 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31854218 117.4 ns/op 8861.12 MB/s Benchmark____GWs_Int_1kx10x0-16 32151265 110.7 ns/op 9392.58 MB/s Benchmark____GWs_Int_1kx10x0-16 30760531 109.6 ns/op 9487.29 MB/s Benchmark____GWs_Int_1kx10x0-16 27635349 113.0 ns/op 9202.84 MB/s Benchmark____GWs_Int_1kx10x0-16 31956183 111.3 ns/op 9348.01 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 23533460 145.5 ns/op 14183.11 MB/s Benchmark____GWs_Int_2kx10x0-16 26731021 139.7 ns/op 14770.39 MB/s Benchmark____GWs_Int_2kx10x0-16 25570100 137.4 ns/op 15018.18 MB/s Benchmark____GWs_Int_2kx10x0-16 26503916 139.3 ns/op 14813.47 MB/s Benchmark____GWs_Int_2kx10x0-16 25995572 143.1 ns/op 14422.83 MB/s Benchmark____GWs_Int_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:47040->127.0.0.1:43671: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1259: Received error on PUB write: write tcp 127.0.0.1:36308->127.0.0.1:40437: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 13308548 275.2 ns/op 14941.17 MB/s Benchmark____GWs_Int_4kx10x0-16 12650461 284.6 ns/op 14447.35 MB/s Benchmark____GWs_Int_4kx10x0-16 13000754 299.1 ns/op 13746.55 MB/s Benchmark____GWs_Int_4kx10x0-16 13202667 303.7 ns/op 13538.16 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6352004 578.1 ns/op 5405.64 MB/s Benchmark____GWs_Int_1kx01x1-16 6261312 585.7 ns/op 5335.20 MB/s Benchmark____GWs_Int_1kx01x1-16 6463242 580.5 ns/op 5383.31 MB/s Benchmark____GWs_Int_1kx01x1-16 6107041 574.8 ns/op 5436.88 MB/s Benchmark____GWs_Int_1kx01x1-16 6186127 576.8 ns/op 5417.73 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4491669 801.5 ns/op 7732.03 MB/s Benchmark____GWs_Int_2kx01x1-16 4074258 800.2 ns/op 7744.28 MB/s Benchmark____GWs_Int_2kx01x1-16 4556293 805.1 ns/op 7697.10 MB/s Benchmark____GWs_Int_2kx01x1-16 4495825 804.8 ns/op 7699.65 MB/s Benchmark____GWs_Int_2kx01x1-16 4108581 805.8 ns/op 7690.21 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2563563 1397 ns/op 8834.53 MB/s Benchmark____GWs_Int_4kx01x1-16 2556280 1399 ns/op 8819.46 MB/s Benchmark____GWs_Int_4kx01x1-16 2560027 1409 ns/op 8758.83 MB/s Benchmark____GWs_Int_4kx01x1-16 2597619 1591 ns/op 7757.51 MB/s Benchmark____GWs_Int_4kx01x1-16 2267113 1413 ns/op 8734.54 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 5986351 601.6 ns/op 5194.34 MB/s Benchmark____GWs_Int_1kx10x1-16 5798235 579.4 ns/op 5393.81 MB/s Benchmark____GWs_Int_1kx10x1-16 5880604 581.7 ns/op 5372.61 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:48826->127.0.0.1:40371: use of closed network connection --- FAIL: Benchmark____GWs_Int_1kx10x1-16 Benchmark____GWs_Int_1kx10x1-16 5804900 575.2 ns/op 5432.89 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4022388 874.0 ns/op 7090.33 MB/s Benchmark____GWs_Int_2kx10x1-16 4012737 869.6 ns/op 7126.01 MB/s Benchmark____GWs_Int_2kx10x1-16 4052288 875.4 ns/op 7079.38 MB/s Benchmark____GWs_Int_2kx10x1-16 4013121 872.9 ns/op 7099.43 MB/s Benchmark____GWs_Int_2kx10x1-16 4014219 875.5 ns/op 7078.46 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2311176 1543 ns/op 7998.74 MB/s Benchmark____GWs_Int_4kx10x1-16 2316579 1577 ns/op 7827.85 MB/s Benchmark____GWs_Int_4kx10x1-16 2319650 1545 ns/op 7989.34 MB/s Benchmark____GWs_Int_4kx10x1-16 2281018 1538 ns/op 8021.84 MB/s Benchmark____GWs_Int_4kx10x1-16 2279316 1631 ns/op 7567.41 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8053585 470.2 ns/op 216.95 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7849111 446.3 ns/op 228.52 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8211910 437.1 ns/op 233.38 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7919547 445.3 ns/op 229.05 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8409337 448.5 ns/op 227.45 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 771906 4744 ns/op 37.31 MB/s Benchmark__GWs_Reqs_1SubEach-16 799206 4987 ns/op 35.49 MB/s Benchmark__GWs_Reqs_1SubEach-16 781478 5020 ns/op 35.26 MB/s Benchmark__GWs_Reqs_1SubEach-16 822879 5008 ns/op 35.34 MB/s Benchmark__GWs_Reqs_1SubEach-16 808470 4920 ns/op 35.97 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2134.435s ❌ Non-zero exit code: 1