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 49196804 71.83 ns/op 153.13 MB/s Benchmark______Pub0b_Payload-16 47090700 71.46 ns/op 153.93 MB/s Benchmark______Pub0b_Payload-16 46804581 71.52 ns/op 153.79 MB/s Benchmark______Pub0b_Payload-16 47746190 71.73 ns/op 153.35 MB/s Benchmark______Pub0b_Payload-16 45068616 71.48 ns/op 153.89 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45313437 72.28 ns/op 262.86 MB/s Benchmark______Pub8b_Payload-16 49217265 75.37 ns/op 252.09 MB/s Benchmark______Pub8b_Payload-16 46918767 72.45 ns/op 262.26 MB/s Benchmark______Pub8b_Payload-16 47165353 75.15 ns/op 252.84 MB/s Benchmark______Pub8b_Payload-16 49896388 76.13 ns/op 249.57 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44400244 76.88 ns/op 572.33 MB/s Benchmark_____Pub32b_Payload-16 44354295 77.94 ns/op 564.52 MB/s Benchmark_____Pub32b_Payload-16 46755091 76.83 ns/op 572.68 MB/s Benchmark_____Pub32b_Payload-16 41904830 77.08 ns/op 570.84 MB/s Benchmark_____Pub32b_Payload-16 44191951 77.04 ns/op 571.12 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39494364 87.98 ns/op 1602.73 MB/s Benchmark____Pub128B_Payload-16 39609166 85.99 ns/op 1639.64 MB/s Benchmark____Pub128B_Payload-16 39928516 86.07 ns/op 1638.28 MB/s Benchmark____Pub128B_Payload-16 39056576 85.80 ns/op 1643.37 MB/s Benchmark____Pub128B_Payload-16 34587849 87.16 ns/op 1617.78 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35022633 95.12 ns/op 2828.15 MB/s Benchmark____Pub256B_Payload-16 38721621 96.25 ns/op 2794.70 MB/s Benchmark____Pub256B_Payload-16 36858238 96.10 ns/op 2799.24 MB/s Benchmark____Pub256B_Payload-16 35321514 94.28 ns/op 2853.23 MB/s Benchmark____Pub256B_Payload-16 36168772 94.36 ns/op 2850.90 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24260791 143.4 ns/op 7240.32 MB/s Benchmark______Pub1K_Payload-16 23162565 141.7 ns/op 7323.46 MB/s Benchmark______Pub1K_Payload-16 24550707 148.8 ns/op 6974.45 MB/s Benchmark______Pub1K_Payload-16 25507764 138.8 ns/op 7476.36 MB/s Benchmark______Pub1K_Payload-16 24503894 143.0 ns/op 7256.47 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5693246 636.0 ns/op 6462.23 MB/s Benchmark______Pub4K_Payload-16 5599311 617.5 ns/op 6655.58 MB/s Benchmark______Pub4K_Payload-16 5476632 610.2 ns/op 6735.84 MB/s Benchmark______Pub4K_Payload-16 5558449 611.0 ns/op 6726.28 MB/s Benchmark______Pub4K_Payload-16 5223534 633.7 ns/op 6485.54 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2709117 1284 ns/op 6390.82 MB/s Benchmark______Pub8K_Payload-16 2825736 1273 ns/op 6444.35 MB/s Benchmark______Pub8K_Payload-16 2767632 1276 ns/op 6431.86 MB/s Benchmark______Pub8K_Payload-16 2775354 1282 ns/op 6399.52 MB/s Benchmark______Pub8K_Payload-16 2708143 1279 ns/op 6414.58 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 653239 5478 ns/op 5984.23 MB/s Benchmark_____Pub32K_Payload-16 646789 5489 ns/op 5971.99 MB/s Benchmark_____Pub32K_Payload-16 654066 5491 ns/op 5970.73 MB/s Benchmark_____Pub32K_Payload-16 653343 5466 ns/op 5997.08 MB/s Benchmark_____Pub32K_Payload-16 484178 6485 ns/op 5055.42 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32051794 95.01 ns/op 115.78 MB/s Benchmark__AuthPub0b_Payload-16 36162778 94.61 ns/op 116.27 MB/s Benchmark__AuthPub0b_Payload-16 36227050 94.42 ns/op 116.50 MB/s Benchmark__AuthPub0b_Payload-16 36335544 93.94 ns/op 117.10 MB/s Benchmark__AuthPub0b_Payload-16 36079647 93.94 ns/op 117.09 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15802462 226.1 ns/op Benchmark_____________PubSub-16 15717835 228.9 ns/op Benchmark_____________PubSub-16 15433880 227.6 ns/op Benchmark_____________PubSub-16 15518068 228.4 ns/op Benchmark_____________PubSub-16 15623317 226.6 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15728143 225.4 ns/op Benchmark_____PubSubTwoConns-16 15704120 225.8 ns/op Benchmark_____PubSubTwoConns-16 15738740 224.2 ns/op Benchmark_____PubSubTwoConns-16 15603216 226.6 ns/op Benchmark_____PubSubTwoConns-16 15558723 227.3 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:45378->127.0.0.1:36539: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42658->127.0.0.1:33491: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41136->127.0.0.1:45635: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:54578->127.0.0.1:42865: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49240->127.0.0.1:33253: 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 14217723 246.9 ns/op Benchmark_____PubTwoQueueSub-16 14385070 247.1 ns/op Benchmark_____PubTwoQueueSub-16 14374574 245.9 ns/op Benchmark_____PubTwoQueueSub-16 14420610 246.6 ns/op Benchmark_____PubTwoQueueSub-16 14480274 246.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14319621 245.6 ns/op Benchmark____PubFourQueueSub-16 14273088 245.5 ns/op Benchmark____PubFourQueueSub-16 14460298 246.9 ns/op Benchmark____PubFourQueueSub-16 14371023 245.8 ns/op Benchmark____PubFourQueueSub-16 14460082 246.1 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14521692 245.8 ns/op Benchmark___PubEightQueueSub-16 14341046 247.0 ns/op Benchmark___PubEightQueueSub-16 14390602 246.3 ns/op Benchmark___PubEightQueueSub-16 14373320 245.0 ns/op Benchmark___PubEightQueueSub-16 14536599 246.9 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23168 154982 ns/op Benchmark_PubSub512kTwoConns-16 23461 156785 ns/op Benchmark_PubSub512kTwoConns-16 23260 157445 ns/op Benchmark_PubSub512kTwoConns-16 23065 155785 ns/op Benchmark_PubSub512kTwoConns-16 22992 153479 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15492256 230.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15557544 228.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15285094 227.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15576582 227.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15553252 225.5 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15329320 227.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15372445 228.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15291420 228.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15321031 227.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15487971 228.1 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11928784 307.5 ns/op Benchmark____RoutedPubSub_0b-16 11719354 309.8 ns/op Benchmark____RoutedPubSub_0b-16 11698705 308.2 ns/op Benchmark____RoutedPubSub_0b-16 11244328 311.4 ns/op Benchmark____RoutedPubSub_0b-16 11306280 311.4 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6807906 533.5 ns/op Benchmark____RoutedPubSub_1K-16 6820833 526.8 ns/op Benchmark____RoutedPubSub_1K-16 6799618 539.0 ns/op Benchmark____RoutedPubSub_1K-16 6556657 533.1 ns/op Benchmark____RoutedPubSub_1K-16 6535414 542.2 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 79988 43100 ns/op Benchmark__RoutedPubSub_100K-16 83437 41417 ns/op Benchmark__RoutedPubSub_100K-16 82554 42382 ns/op Benchmark__RoutedPubSub_100K-16 78426 44664 ns/op Benchmark__RoutedPubSub_100K-16 84669 42033 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11397292 318.5 ns/op Benchmark____Routed2QueueSub-16 9519447 317.3 ns/op Benchmark____Routed2QueueSub-16 9685905 323.6 ns/op Benchmark____Routed2QueueSub-16 9767044 326.9 ns/op Benchmark____Routed2QueueSub-16 9758071 315.4 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9711835 320.3 ns/op Benchmark____Routed4QueueSub-16 9479809 323.3 ns/op Benchmark____Routed4QueueSub-16 9309612 328.3 ns/op Benchmark____Routed4QueueSub-16 11214309 316.4 ns/op Benchmark____Routed4QueueSub-16 9435171 330.9 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9054464 332.9 ns/op Benchmark____Routed8QueueSub-16 10962133 329.2 ns/op Benchmark____Routed8QueueSub-16 9361726 330.7 ns/op Benchmark____Routed8QueueSub-16 9200271 326.9 ns/op Benchmark____Routed8QueueSub-16 9433518 325.7 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8554366 353.8 ns/op Benchmark___Routed16QueueSub-16 8853067 348.7 ns/op Benchmark___Routed16QueueSub-16 8628529 355.2 ns/op Benchmark___Routed16QueueSub-16 8913306 348.4 ns/op Benchmark___Routed16QueueSub-16 8640160 347.4 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6361766 554.2 ns/op Benchmark____________RouteCompressOff-16 6469086 553.4 ns/op Benchmark____________RouteCompressOff-16 6564878 544.9 ns/op Benchmark____________RouteCompressOff-16 6444645 550.6 ns/op Benchmark____________RouteCompressOff-16 6503023 546.2 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6345963 549.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6634836 549.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6393303 552.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6408154 544.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6471999 549.0 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6508540 550.0 ns/op Benchmark_________RouteCompressS2Fast-16 6606943 547.1 ns/op Benchmark_________RouteCompressS2Fast-16 6462124 553.3 ns/op Benchmark_________RouteCompressS2Fast-16 6364812 553.2 ns/op Benchmark_________RouteCompressS2Fast-16 6279098 550.4 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6321514 552.8 ns/op Benchmark_______RouteCompressS2Better-16 6529018 549.0 ns/op Benchmark_______RouteCompressS2Better-16 6332745 551.8 ns/op Benchmark_______RouteCompressS2Better-16 6557883 503.2 ns/op Benchmark_______RouteCompressS2Better-16 6447294 546.5 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6440397 557.8 ns/op Benchmark_________RouteCompressS2Best-16 6512247 553.9 ns/op Benchmark_________RouteCompressS2Best-16 6496207 551.3 ns/op Benchmark_________RouteCompressS2Best-16 6499514 545.3 ns/op Benchmark_________RouteCompressS2Best-16 6577401 541.6 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4629967 765.8 ns/op 325.14 MB/s Benchmark______FanOut_8x1x10-16 4674984 770.3 ns/op 323.26 MB/s Benchmark______FanOut_8x1x10-16 4645070 768.7 ns/op 323.94 MB/s Benchmark______FanOut_8x1x10-16 4666588 768.4 ns/op 324.03 MB/s Benchmark______FanOut_8x1x10-16 4601209 766.3 ns/op 324.95 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 551132 6106 ns/op 379.78 MB/s Benchmark_____FanOut_8x1x100-16 559941 6117 ns/op 379.10 MB/s Benchmark_____FanOut_8x1x100-16 527197 6108 ns/op 379.68 MB/s Benchmark_____FanOut_8x1x100-16 564272 6146 ns/op 377.29 MB/s Benchmark_____FanOut_8x1x100-16 565395 6220 ns/op 372.85 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47190 75626 ns/op 304.38 MB/s Benchmark____FanOut_8x10x100-16 47246 76131 ns/op 302.36 MB/s Benchmark____FanOut_8x10x100-16 47479 75660 ns/op 304.24 MB/s Benchmark____FanOut_8x10x100-16 47516 75878 ns/op 303.37 MB/s Benchmark____FanOut_8x10x100-16 47299 75462 ns/op 305.04 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5692 613445 ns/op 391.26 MB/s Benchmark___FanOut_8x10x1000-16 5788 613764 ns/op 391.06 MB/s Benchmark___FanOut_8x10x1000-16 5655 607596 ns/op 395.03 MB/s Benchmark___FanOut_8x10x1000-16 5904 612961 ns/op 391.57 MB/s Benchmark___FanOut_8x10x1000-16 5852 611810 ns/op 392.31 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4874 719290 ns/op 319.79 MB/s Benchmark___FanOut_8x100x100-16 4947 720395 ns/op 319.30 MB/s Benchmark___FanOut_8x100x100-16 4801 724602 ns/op 317.44 MB/s Benchmark___FanOut_8x100x100-16 4916 721929 ns/op 318.62 MB/s Benchmark___FanOut_8x100x100-16 4860 720419 ns/op 319.29 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 573 6317328 ns/op 379.91 MB/s Benchmark__FanOut_8x100x1000-16 566 6293475 ns/op 381.35 MB/s Benchmark__FanOut_8x100x1000-16 548 6351171 ns/op 377.89 MB/s Benchmark__FanOut_8x100x1000-16 560 6323119 ns/op 379.56 MB/s Benchmark__FanOut_8x100x1000-16 552 6392813 ns/op 375.42 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 514 6861611 ns/op 364.35 MB/s Benchmark__FanOut_8x10x10000-16 511 6853208 ns/op 364.80 MB/s Benchmark__FanOut_8x10x10000-16 528 6864181 ns/op 364.21 MB/s Benchmark__FanOut_8x10x10000-16 511 6922121 ns/op 361.16 MB/s Benchmark__FanOut_8x10x10000-16 506 6873517 ns/op 363.72 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 924 3823731 ns/op 300.76 MB/s Benchmark___FanOut_8x500x100-16 928 3873722 ns/op 296.88 MB/s Benchmark___FanOut_8x500x100-16 928 3873335 ns/op 296.91 MB/s Benchmark___FanOut_8x500x100-16 930 3841532 ns/op 299.36 MB/s Benchmark___FanOut_8x500x100-16 934 3817465 ns/op 301.25 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 353068 9504 ns/op 1540.43 MB/s Benchmark___FanOut_128x1x100-16 354474 9566 ns/op 1530.48 MB/s Benchmark___FanOut_128x1x100-16 360360 9663 ns/op 1515.19 MB/s Benchmark___FanOut_128x1x100-16 347860 9545 ns/op 1533.87 MB/s Benchmark___FanOut_128x1x100-16 364476 9569 ns/op 1530.12 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32162 112262 ns/op 1292.88 MB/s Benchmark__FanOut_128x10x100-16 32185 111768 ns/op 1298.59 MB/s Benchmark__FanOut_128x10x100-16 32238 111906 ns/op 1296.99 MB/s Benchmark__FanOut_128x10x100-16 32197 111223 ns/op 1304.96 MB/s Benchmark__FanOut_128x10x100-16 31926 111728 ns/op 1299.06 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4050 889572 ns/op 1641.40 MB/s Benchmark_FanOut_128x10x1000-16 4030 894241 ns/op 1632.83 MB/s Benchmark_FanOut_128x10x1000-16 3886 886237 ns/op 1647.57 MB/s Benchmark_FanOut_128x10x1000-16 4045 878193 ns/op 1662.67 MB/s Benchmark_FanOut_128x10x1000-16 3999 887728 ns/op 1644.81 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3504 1024230 ns/op 1415.83 MB/s Benchmark_FanOut_128x100x100-16 3470 1023295 ns/op 1417.13 MB/s Benchmark_FanOut_128x100x100-16 3439 1022318 ns/op 1418.48 MB/s Benchmark_FanOut_128x100x100-16 3391 1022434 ns/op 1418.32 MB/s Benchmark_FanOut_128x100x100-16 3439 1025586 ns/op 1413.96 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 375 9403811 ns/op 1552.58 MB/s BenchmarkFanOut_128x100x1000-16 370 9462046 ns/op 1543.02 MB/s BenchmarkFanOut_128x100x1000-16 378 9494570 ns/op 1537.74 MB/s BenchmarkFanOut_128x100x1000-16 374 9485474 ns/op 1539.21 MB/s BenchmarkFanOut_128x100x1000-16 376 9660477 ns/op 1511.33 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 369 9759850 ns/op 1506.19 MB/s BenchmarkFanOut_128x10x10000-16 367 9781219 ns/op 1502.89 MB/s BenchmarkFanOut_128x10x10000-16 364 9764477 ns/op 1505.47 MB/s BenchmarkFanOut_128x10x10000-16 363 9894077 ns/op 1485.75 MB/s BenchmarkFanOut_128x10x10000-16 363 9782350 ns/op 1502.72 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 656 5398655 ns/op 1342.95 MB/s BenchmarkFanOut__128x500x100-16 667 5346067 ns/op 1356.16 MB/s BenchmarkFanOut__128x500x100-16 668 5370937 ns/op 1349.88 MB/s BenchmarkFanOut__128x500x100-16 651 5368241 ns/op 1350.56 MB/s BenchmarkFanOut__128x500x100-16 666 5380400 ns/op 1347.51 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1932 1851025 ns/op 2858.16 MB/s Benchmark_FanOut_512x100x100-16 1924 1844459 ns/op 2868.33 MB/s Benchmark_FanOut_512x100x100-16 1940 1854963 ns/op 2852.09 MB/s Benchmark_FanOut_512x100x100-16 1897 1863122 ns/op 2839.60 MB/s Benchmark_FanOut_512x100x100-16 1934 1841258 ns/op 2873.32 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16865766 ns/op 3142.49 MB/s Benchmark__FanOut_512x100x1k-16 212 16778973 ns/op 3158.75 MB/s Benchmark__FanOut_512x100x1k-16 211 17008415 ns/op 3116.14 MB/s Benchmark__FanOut_512x100x1k-16 213 16834006 ns/op 3148.42 MB/s Benchmark__FanOut_512x100x1k-16 212 16864841 ns/op 3142.66 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2919 1159541 ns/op 8995.84 MB/s Benchmark____FanOut_1kx10x1k-16 2912 1148723 ns/op 9080.55 MB/s Benchmark____FanOut_1kx10x1k-16 3084 1151607 ns/op 9057.81 MB/s Benchmark____FanOut_1kx10x1k-16 2883 1148337 ns/op 9083.60 MB/s Benchmark____FanOut_1kx10x1k-16 3194 1174738 ns/op 8879.46 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2778 1276472 ns/op 8163.94 MB/s Benchmark__FanOut_1kx100x100-16 2769 1270500 ns/op 8202.31 MB/s Benchmark__FanOut_1kx100x100-16 2730 1284865 ns/op 8110.61 MB/s Benchmark__FanOut_1kx100x100-16 2702 1276096 ns/op 8166.34 MB/s Benchmark__FanOut_1kx100x100-16 2764 1280283 ns/op 8139.64 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4456855 772.7 ns/op 322.25 MB/s Benchmark_____RFanOut_8x1x10-16 4431466 794.8 ns/op 313.30 MB/s Benchmark_____RFanOut_8x1x10-16 4480426 784.4 ns/op 317.43 MB/s Benchmark_____RFanOut_8x1x10-16 4519506 784.5 ns/op 317.39 MB/s Benchmark_____RFanOut_8x1x10-16 4446898 778.7 ns/op 319.78 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 512749 6200 ns/op 374.03 MB/s Benchmark____RFanOut_8x1x100-16 528324 6175 ns/op 375.53 MB/s Benchmark____RFanOut_8x1x100-16 540236 6244 ns/op 371.39 MB/s Benchmark____RFanOut_8x1x100-16 514161 6302 ns/op 367.99 MB/s Benchmark____RFanOut_8x1x100-16 530392 6147 ns/op 377.26 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47122 75681 ns/op 304.16 MB/s Benchmark___RFanOut_8x10x100-16 47391 76156 ns/op 302.26 MB/s Benchmark___RFanOut_8x10x100-16 47400 75400 ns/op 305.29 MB/s Benchmark___RFanOut_8x10x100-16 47098 77152 ns/op 298.36 MB/s Benchmark___RFanOut_8x10x100-16 47527 75680 ns/op 304.16 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5684 608782 ns/op 394.26 MB/s Benchmark__RFanOut_8x10x1000-16 5838 620158 ns/op 387.03 MB/s Benchmark__RFanOut_8x10x1000-16 5673 608435 ns/op 394.49 MB/s Benchmark__RFanOut_8x10x1000-16 5462 611912 ns/op 392.24 MB/s Benchmark__RFanOut_8x10x1000-16 5590 626139 ns/op 383.33 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4862 711336 ns/op 323.36 MB/s Benchmark__RFanOut_8x100x100-16 4868 720213 ns/op 319.38 MB/s Benchmark__RFanOut_8x100x100-16 4970 713703 ns/op 322.29 MB/s Benchmark__RFanOut_8x100x100-16 4990 710987 ns/op 323.52 MB/s Benchmark__RFanOut_8x100x100-16 4911 713569 ns/op 322.35 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 542 6385520 ns/op 375.85 MB/s Benchmark_RFanOut_8x100x1000-16 554 6408397 ns/op 374.51 MB/s Benchmark_RFanOut_8x100x1000-16 561 6337165 ns/op 378.72 MB/s Benchmark_RFanOut_8x100x1000-16 568 6559684 ns/op 365.87 MB/s Benchmark_RFanOut_8x100x1000-16 558 6436666 ns/op 372.87 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 514 6869423 ns/op 363.93 MB/s Benchmark_RFanOut_8x10x10000-16 518 6902747 ns/op 362.18 MB/s Benchmark_RFanOut_8x10x10000-16 512 6967262 ns/op 358.82 MB/s Benchmark_RFanOut_8x10x10000-16 513 7004730 ns/op 356.90 MB/s Benchmark_RFanOut_8x10x10000-16 526 7020660 ns/op 356.09 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3009 1151594 ns/op 9057.91 MB/s Benchmark_RFanOut_1kx10x1000-16 3081 1182698 ns/op 8819.69 MB/s Benchmark_RFanOut_1kx10x1000-16 3019 1158155 ns/op 9006.60 MB/s Benchmark_RFanOut_1kx10x1000-16 2919 1165228 ns/op 8951.93 MB/s Benchmark_RFanOut_1kx10x1000-16 3076 1154742 ns/op 9033.22 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7013738 505.5 ns/op 4110.89 MB/s Benchmark_____FanIn_1kx100x1-16 6906244 506.0 ns/op 4106.55 MB/s Benchmark_____FanIn_1kx100x1-16 6965202 507.5 ns/op 4094.90 MB/s Benchmark_____FanIn_1kx100x1-16 6932502 505.5 ns/op 4110.89 MB/s Benchmark_____FanIn_1kx100x1-16 6915877 505.0 ns/op 4114.61 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2621562 1363 ns/op 6031.60 MB/s Benchmark_____FanIn_4kx100x1-16 2613386 1384 ns/op 5940.89 MB/s Benchmark_____FanIn_4kx100x1-16 2643106 1386 ns/op 5932.29 MB/s Benchmark_____FanIn_4kx100x1-16 2659818 1373 ns/op 5987.94 MB/s Benchmark_____FanIn_4kx100x1-16 2653352 1364 ns/op 6027.70 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1683634 2132 ns/op 7697.53 MB/s Benchmark_____FanIn_8kx100x1-16 1717446 2123 ns/op 7732.42 MB/s Benchmark_____FanIn_8kx100x1-16 1687731 2121 ns/op 7739.54 MB/s Benchmark_____FanIn_8kx100x1-16 1717747 2102 ns/op 7808.40 MB/s Benchmark_____FanIn_8kx100x1-16 1686428 2092 ns/op 7847.89 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 878881 4197 ns/op 7815.15 MB/s Benchmark____FanIn_16kx100x1-16 867169 4184 ns/op 7839.42 MB/s Benchmark____FanIn_16kx100x1-16 875728 4156 ns/op 7891.26 MB/s Benchmark____FanIn_16kx100x1-16 841653 4168 ns/op 7870.00 MB/s Benchmark____FanIn_16kx100x1-16 851966 4164 ns/op 7876.67 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 166054 19690 ns/op 6658.50 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7816801932 vs 11321003100 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46828->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47406->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:47302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47530->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 157983 19810 ns/op 6618.14 MB/s Benchmark____FanIn_64kx100x1-16 168123 19975 ns/op 6563.38 MB/s Benchmark____FanIn_64kx100x1-16 161668 20006 ns/op 6553.20 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 660824690 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35450->127.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:35766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35750->127.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:35440->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:35804->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: 173300980 vs 11837427000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:37856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38056->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:37920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: 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:1096: Received error on PUB write: write tcp 127.0.0.1:38580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38168->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:38362->127.0.0.1:5222: write: broken pipe bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 711425430 vs 11719446000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41570->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40824->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: 250512990 vs 11758773000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43530->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:44260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44372->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: 2185270300 vs 11352394000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46206->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5481165 646.9 ns/op 439.02 MB/s Benchmark___BumpPubCount_1x3-16 5476986 649.4 ns/op 437.30 MB/s Benchmark___BumpPubCount_1x3-16 5568428 642.3 ns/op 442.19 MB/s Benchmark___BumpPubCount_1x3-16 5510918 650.1 ns/op 436.83 MB/s Benchmark___BumpPubCount_1x3-16 5509207 646.8 ns/op 439.07 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5217070 681.9 ns/op 416.51 MB/s Benchmark___BumpPubCount_2x3-16 5229183 678.8 ns/op 418.41 MB/s Benchmark___BumpPubCount_2x3-16 5253752 682.5 ns/op 416.14 MB/s Benchmark___BumpPubCount_2x3-16 5256112 682.3 ns/op 416.25 MB/s Benchmark___BumpPubCount_2x3-16 5261679 684.6 ns/op 414.87 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5383484 652.2 ns/op 435.46 MB/s Benchmark___BumpPubCount_5x3-16 5356872 649.9 ns/op 436.98 MB/s Benchmark___BumpPubCount_5x3-16 5367505 649.8 ns/op 437.09 MB/s Benchmark___BumpPubCount_5x3-16 5521029 651.1 ns/op 436.22 MB/s Benchmark___BumpPubCount_5x3-16 5101390 652.2 ns/op 435.47 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5507628 650.4 ns/op 436.66 MB/s Benchmark__BumpPubCount_10x3-16 5517518 649.8 ns/op 437.05 MB/s Benchmark__BumpPubCount_10x3-16 5525223 650.5 ns/op 436.58 MB/s Benchmark__BumpPubCount_10x3-16 5512309 651.8 ns/op 435.72 MB/s Benchmark__BumpPubCount_10x3-16 5519385 650.8 ns/op 436.41 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12448131 270.3 ns/op 3847.06 MB/s Benchmark____GWs_Opt_1kx01x0-16 13017532 274.5 ns/op 3789.39 MB/s Benchmark____GWs_Opt_1kx01x0-16 12488960 270.6 ns/op 3843.30 MB/s Benchmark____GWs_Opt_1kx01x0-16 12305737 273.0 ns/op 3809.98 MB/s Benchmark____GWs_Opt_1kx01x0-16 13425918 269.8 ns/op 3854.46 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10848463 344.1 ns/op 5999.00 MB/s Benchmark____GWs_Opt_2kx01x0-16 10197838 342.2 ns/op 6032.36 MB/s Benchmark____GWs_Opt_2kx01x0-16 10418713 350.5 ns/op 5888.75 MB/s Benchmark____GWs_Opt_2kx01x0-16 10543464 329.5 ns/op 6263.91 MB/s Benchmark____GWs_Opt_2kx01x0-16 10321634 342.1 ns/op 6033.42 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5900376 620.6 ns/op 6626.32 MB/s Benchmark____GWs_Opt_4kx01x0-16 5921444 619.7 ns/op 6635.76 MB/s Benchmark____GWs_Opt_4kx01x0-16 5694769 618.1 ns/op 6652.36 MB/s Benchmark____GWs_Opt_4kx01x0-16 5862518 619.7 ns/op 6634.96 MB/s Benchmark____GWs_Opt_4kx01x0-16 5852986 619.3 ns/op 6639.48 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28495642 119.4 ns/op 8707.83 MB/s Benchmark____GWs_Opt_1kx10x0-16 31094558 112.6 ns/op 9236.14 MB/s Benchmark____GWs_Opt_1kx10x0-16 28917848 112.4 ns/op 9254.59 MB/s Benchmark____GWs_Opt_1kx10x0-16 31208010 108.0 ns/op 9631.39 MB/s Benchmark____GWs_Opt_1kx10x0-16 31206022 111.2 ns/op 9355.56 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24290436 149.7 ns/op 13785.15 MB/s Benchmark____GWs_Opt_2kx10x0-16 23578398 143.8 ns/op 14351.44 MB/s Benchmark____GWs_Opt_2kx10x0-16 22117111 141.9 ns/op 14545.39 MB/s Benchmark____GWs_Opt_2kx10x0-16 23685277 141.3 ns/op 14606.11 MB/s Benchmark____GWs_Opt_2kx10x0-16 24361496 157.1 ns/op 13135.20 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12784542 295.2 ns/op 13929.85 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:39178->127.0.0.1:38669: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:58588->127.0.0.1:40009: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 10112097 316.1 ns/op 13007.55 MB/s Benchmark____GWs_Opt_4kx10x0-16 12841186 297.9 ns/op 13802.91 MB/s Benchmark____GWs_Opt_4kx10x0-16 11059087 347.4 ns/op 11836.98 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6424869 554.6 ns/op 5635.08 MB/s Benchmark____GWs_Opt_1kx01x1-16 6528705 587.1 ns/op 5323.13 MB/s Benchmark____GWs_Opt_1kx01x1-16 6192051 553.2 ns/op 5649.05 MB/s Benchmark____GWs_Opt_1kx01x1-16 6460107 554.8 ns/op 5632.74 MB/s Benchmark____GWs_Opt_1kx01x1-16 6438235 555.2 ns/op 5628.98 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4552132 770.4 ns/op 8043.73 MB/s Benchmark____GWs_Opt_2kx01x1-16 4827939 761.2 ns/op 8141.32 MB/s Benchmark____GWs_Opt_2kx01x1-16 4739008 758.8 ns/op 8166.70 MB/s Benchmark____GWs_Opt_2kx01x1-16 4626802 763.2 ns/op 8119.51 MB/s Benchmark____GWs_Opt_2kx01x1-16 4679844 770.7 ns/op 8040.64 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2658472 1559 ns/op 7915.91 MB/s Benchmark____GWs_Opt_4kx01x1-16 2542996 1355 ns/op 9106.25 MB/s Benchmark____GWs_Opt_4kx01x1-16 2566666 1374 ns/op 8980.58 MB/s Benchmark____GWs_Opt_4kx01x1-16 2655176 1396 ns/op 8842.72 MB/s Benchmark____GWs_Opt_4kx01x1-16 2626410 1884 ns/op 6551.46 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6587200 563.6 ns/op 5544.49 MB/s Benchmark____GWs_Opt_1kx10x1-16 6224037 561.4 ns/op 5566.83 MB/s Benchmark____GWs_Opt_1kx10x1-16 6278834 556.3 ns/op 5617.12 MB/s Benchmark____GWs_Opt_1kx10x1-16 6161563 553.8 ns/op 5642.47 MB/s Benchmark____GWs_Opt_1kx10x1-16 6468442 541.4 ns/op 5772.28 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 3890184 847.4 ns/op 7312.54 MB/s Benchmark____GWs_Opt_2kx10x1-16 4078164 855.0 ns/op 7248.13 MB/s Benchmark____GWs_Opt_2kx10x1-16 4229161 848.9 ns/op 7299.94 MB/s Benchmark____GWs_Opt_2kx10x1-16 4056025 853.7 ns/op 7259.40 MB/s Benchmark____GWs_Opt_2kx10x1-16 4098967 853.3 ns/op 7262.70 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2351618 1531 ns/op 8061.17 MB/s Benchmark____GWs_Opt_4kx10x1-16 2426198 1533 ns/op 8050.07 MB/s Benchmark____GWs_Opt_4kx10x1-16 2373073 1528 ns/op 8076.28 MB/s Benchmark____GWs_Opt_4kx10x1-16 2440609 1573 ns/op 7844.21 MB/s Benchmark____GWs_Opt_4kx10x1-16 2373138 1529 ns/op 8071.45 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12733734 285.6 ns/op 3641.02 MB/s Benchmark____GWs_Int_1kx01x0-16 12170304 285.6 ns/op 3641.32 MB/s Benchmark____GWs_Int_1kx01x0-16 12759150 285.9 ns/op 3637.42 MB/s Benchmark____GWs_Int_1kx01x0-16 10496323 289.9 ns/op 3587.63 MB/s Benchmark____GWs_Int_1kx01x0-16 12175111 285.4 ns/op 3644.29 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10051473 356.8 ns/op 5784.35 MB/s Benchmark____GWs_Int_2kx01x0-16 10356069 352.3 ns/op 5858.32 MB/s Benchmark____GWs_Int_2kx01x0-16 9755253 341.2 ns/op 6049.88 MB/s Benchmark____GWs_Int_2kx01x0-16 10209868 339.7 ns/op 6075.95 MB/s Benchmark____GWs_Int_2kx01x0-16 10252620 350.4 ns/op 5890.73 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5898985 703.0 ns/op 5848.90 MB/s Benchmark____GWs_Int_4kx01x0-16 4927016 633.0 ns/op 6495.83 MB/s Benchmark____GWs_Int_4kx01x0-16 5759932 626.7 ns/op 6561.09 MB/s Benchmark____GWs_Int_4kx01x0-16 5768506 686.1 ns/op 5993.04 MB/s Benchmark____GWs_Int_4kx01x0-16 5742558 630.5 ns/op 6521.87 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31331786 110.2 ns/op 9434.94 MB/s Benchmark____GWs_Int_1kx10x0-16 31634533 108.7 ns/op 9565.93 MB/s Benchmark____GWs_Int_1kx10x0-16 31373845 112.9 ns/op 9207.81 MB/s Benchmark____GWs_Int_1kx10x0-16 30742742 118.6 ns/op 8770.19 MB/s Benchmark____GWs_Int_1kx10x0-16 31193422 110.1 ns/op 9449.33 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 21485965 140.9 ns/op 14644.93 MB/s Benchmark____GWs_Int_2kx10x0-16 24363530 145.5 ns/op 14186.10 MB/s Benchmark____GWs_Int_2kx10x0-16 24726781 144.4 ns/op 14288.70 MB/s Benchmark____GWs_Int_2kx10x0-16 26038425 152.7 ns/op 13515.60 MB/s Benchmark____GWs_Int_2kx10x0-16 23214124 138.7 ns/op 14881.98 MB/s Benchmark____GWs_Int_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:49540->127.0.0.1:35639: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:57356->127.0.0.1:41455: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12778432 281.7 ns/op 14596.20 MB/s Benchmark____GWs_Int_4kx10x0-16 12752079 292.5 ns/op 14058.26 MB/s Benchmark____GWs_Int_4kx10x0-16 11429890 285.6 ns/op 14399.96 MB/s Benchmark____GWs_Int_4kx10x0-16 13062502 286.2 ns/op 14370.00 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6405537 567.1 ns/op 5510.53 MB/s Benchmark____GWs_Int_1kx01x1-16 6331575 554.7 ns/op 5633.98 MB/s Benchmark____GWs_Int_1kx01x1-16 6431152 570.8 ns/op 5475.11 MB/s Benchmark____GWs_Int_1kx01x1-16 6382528 695.1 ns/op 4495.72 MB/s Benchmark____GWs_Int_1kx01x1-16 6247575 572.4 ns/op 5459.21 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4645921 781.7 ns/op 7927.28 MB/s Benchmark____GWs_Int_2kx01x1-16 4731469 772.3 ns/op 8024.58 MB/s Benchmark____GWs_Int_2kx01x1-16 4630624 766.9 ns/op 8080.16 MB/s Benchmark____GWs_Int_2kx01x1-16 4638007 766.5 ns/op 8084.57 MB/s Benchmark____GWs_Int_2kx01x1-16 4691250 807.1 ns/op 7678.49 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2610632 1378 ns/op 8957.07 MB/s Benchmark____GWs_Int_4kx01x1-16 2632350 1380 ns/op 8941.67 MB/s Benchmark____GWs_Int_4kx01x1-16 2591185 1376 ns/op 8969.98 MB/s Benchmark____GWs_Int_4kx01x1-16 2621023 1414 ns/op 8729.69 MB/s Benchmark____GWs_Int_4kx01x1-16 2569540 1387 ns/op 8894.63 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6323732 555.1 ns/op 5630.11 MB/s Benchmark____GWs_Int_1kx10x1-16 6524482 555.1 ns/op 5629.51 MB/s Benchmark____GWs_Int_1kx10x1-16 6323881 558.3 ns/op 5597.53 MB/s Benchmark____GWs_Int_1kx10x1-16 6521353 563.4 ns/op 5546.77 MB/s Benchmark____GWs_Int_1kx10x1-16 6593677 555.2 ns/op 5628.99 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 3985378 854.2 ns/op 7254.36 MB/s Benchmark____GWs_Int_2kx10x1-16 4135280 850.4 ns/op 7286.93 MB/s Benchmark____GWs_Int_2kx10x1-16 3976651 833.5 ns/op 7435.05 MB/s Benchmark____GWs_Int_2kx10x1-16 4133394 843.2 ns/op 7349.46 MB/s Benchmark____GWs_Int_2kx10x1-16 4120926 847.9 ns/op 7308.41 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2140890 1583 ns/op 7797.11 MB/s Benchmark____GWs_Int_4kx10x1-16 2364330 1509 ns/op 8179.51 MB/s Benchmark____GWs_Int_4kx10x1-16 2395166 1541 ns/op 8009.87 MB/s Benchmark____GWs_Int_4kx10x1-16 2330878 1520 ns/op 8118.27 MB/s Benchmark____GWs_Int_4kx10x1-16 2215074 1478 ns/op 8348.17 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8019679 432.6 ns/op 235.81 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8179429 427.6 ns/op 238.54 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8178912 431.4 ns/op 236.42 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8157242 436.1 ns/op 233.90 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8264674 438.8 ns/op 232.44 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 612027 5066 ns/op 34.94 MB/s Benchmark__GWs_Reqs_1SubEach-16 769605 5343 ns/op 33.13 MB/s Benchmark__GWs_Reqs_1SubEach-16 727020 5224 ns/op 33.88 MB/s Benchmark__GWs_Reqs_1SubEach-16 732895 5244 ns/op 33.75 MB/s Benchmark__GWs_Reqs_1SubEach-16 735739 5259 ns/op 33.66 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2156.843s