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 49888966 72.21 ns/op 152.34 MB/s Benchmark______Pub0b_Payload-16 47547961 72.06 ns/op 152.66 MB/s Benchmark______Pub0b_Payload-16 47630989 72.21 ns/op 152.33 MB/s Benchmark______Pub0b_Payload-16 47623488 72.37 ns/op 152.00 MB/s Benchmark______Pub0b_Payload-16 47222613 72.52 ns/op 151.69 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 43363206 73.83 ns/op 257.33 MB/s Benchmark______Pub8b_Payload-16 47100564 75.40 ns/op 251.98 MB/s Benchmark______Pub8b_Payload-16 48693118 72.46 ns/op 262.21 MB/s Benchmark______Pub8b_Payload-16 46909578 75.03 ns/op 253.25 MB/s Benchmark______Pub8b_Payload-16 49580154 77.08 ns/op 246.49 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44314092 76.91 ns/op 572.13 MB/s Benchmark_____Pub32b_Payload-16 45497967 76.51 ns/op 575.08 MB/s Benchmark_____Pub32b_Payload-16 44412639 76.91 ns/op 572.08 MB/s Benchmark_____Pub32b_Payload-16 38513238 77.97 ns/op 564.33 MB/s Benchmark_____Pub32b_Payload-16 44884638 77.07 ns/op 570.94 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39542413 87.37 ns/op 1613.87 MB/s Benchmark____Pub128B_Payload-16 39212839 87.80 ns/op 1606.00 MB/s Benchmark____Pub128B_Payload-16 41664760 86.64 ns/op 1627.34 MB/s Benchmark____Pub128B_Payload-16 38868776 86.29 ns/op 1633.97 MB/s Benchmark____Pub128B_Payload-16 35056392 86.18 ns/op 1636.04 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35294630 94.53 ns/op 2845.77 MB/s Benchmark____Pub256B_Payload-16 37282082 95.66 ns/op 2812.14 MB/s Benchmark____Pub256B_Payload-16 35581830 98.43 ns/op 2732.95 MB/s Benchmark____Pub256B_Payload-16 35246763 97.79 ns/op 2750.93 MB/s Benchmark____Pub256B_Payload-16 36386552 111.1 ns/op 2421.09 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 20333410 150.0 ns/op 6921.69 MB/s Benchmark______Pub1K_Payload-16 24258700 140.8 ns/op 7373.54 MB/s Benchmark______Pub1K_Payload-16 24473116 136.0 ns/op 7633.26 MB/s Benchmark______Pub1K_Payload-16 23465986 141.4 ns/op 7342.03 MB/s Benchmark______Pub1K_Payload-16 23944170 135.8 ns/op 7645.36 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5672152 625.2 ns/op 6574.10 MB/s Benchmark______Pub4K_Payload-16 5651444 626.6 ns/op 6559.37 MB/s Benchmark______Pub4K_Payload-16 5685639 618.9 ns/op 6641.12 MB/s Benchmark______Pub4K_Payload-16 5426274 624.3 ns/op 6583.46 MB/s Benchmark______Pub4K_Payload-16 5535520 626.2 ns/op 6563.92 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2760596 1284 ns/op 6392.15 MB/s Benchmark______Pub8K_Payload-16 2757004 1283 ns/op 6397.71 MB/s Benchmark______Pub8K_Payload-16 2761743 1276 ns/op 6431.63 MB/s Benchmark______Pub8K_Payload-16 2842566 1272 ns/op 6451.47 MB/s Benchmark______Pub8K_Payload-16 2808324 1283 ns/op 6397.69 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 563169 5454 ns/op 6010.72 MB/s Benchmark_____Pub32K_Payload-16 657724 5533 ns/op 5924.70 MB/s Benchmark_____Pub32K_Payload-16 648064 5479 ns/op 5983.18 MB/s Benchmark_____Pub32K_Payload-16 574586 5475 ns/op 5987.31 MB/s Benchmark_____Pub32K_Payload-16 480897 8834 ns/op 3710.86 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32918161 92.85 ns/op 118.47 MB/s Benchmark__AuthPub0b_Payload-16 35831299 93.73 ns/op 117.36 MB/s Benchmark__AuthPub0b_Payload-16 36837255 92.53 ns/op 118.88 MB/s Benchmark__AuthPub0b_Payload-16 36715106 93.99 ns/op 117.03 MB/s Benchmark__AuthPub0b_Payload-16 35366265 92.31 ns/op 119.16 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15563304 226.9 ns/op Benchmark_____________PubSub-16 15615681 226.8 ns/op Benchmark_____________PubSub-16 15528247 227.7 ns/op Benchmark_____________PubSub-16 15580431 227.3 ns/op Benchmark_____________PubSub-16 15617348 227.4 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15852411 226.5 ns/op Benchmark_____PubSubTwoConns-16 15638592 226.5 ns/op Benchmark_____PubSubTwoConns-16 15633620 225.8 ns/op Benchmark_____PubSubTwoConns-16 15641332 225.5 ns/op Benchmark_____PubSubTwoConns-16 15728760 227.0 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34396->127.0.0.1:39233: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:35400->127.0.0.1:34543: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40396->127.0.0.1:40363: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59374->127.0.0.1:33881: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:45806->127.0.0.1:34367: 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 14441992 245.4 ns/op Benchmark_____PubTwoQueueSub-16 14391860 246.6 ns/op Benchmark_____PubTwoQueueSub-16 14274466 246.3 ns/op Benchmark_____PubTwoQueueSub-16 14294590 245.6 ns/op Benchmark_____PubTwoQueueSub-16 14391847 246.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14246750 245.8 ns/op Benchmark____PubFourQueueSub-16 14317784 246.3 ns/op Benchmark____PubFourQueueSub-16 14428988 246.5 ns/op Benchmark____PubFourQueueSub-16 14461011 246.4 ns/op Benchmark____PubFourQueueSub-16 14561712 247.1 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14457955 246.7 ns/op Benchmark___PubEightQueueSub-16 14545838 246.9 ns/op Benchmark___PubEightQueueSub-16 14566771 247.0 ns/op Benchmark___PubEightQueueSub-16 14463972 246.1 ns/op Benchmark___PubEightQueueSub-16 14211896 246.9 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23198 155473 ns/op Benchmark_PubSub512kTwoConns-16 23053 155470 ns/op Benchmark_PubSub512kTwoConns-16 23236 155209 ns/op Benchmark_PubSub512kTwoConns-16 22966 155813 ns/op Benchmark_PubSub512kTwoConns-16 23150 156473 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15171542 230.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15109956 229.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15150828 228.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15045822 228.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15274033 229.6 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15550196 228.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15156236 229.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 14672743 229.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15301558 228.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15291834 228.7 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11087856 314.4 ns/op Benchmark____RoutedPubSub_0b-16 11400567 311.2 ns/op Benchmark____RoutedPubSub_0b-16 11232818 309.8 ns/op Benchmark____RoutedPubSub_0b-16 11314779 314.7 ns/op Benchmark____RoutedPubSub_0b-16 10807849 312.0 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6721934 534.1 ns/op Benchmark____RoutedPubSub_1K-16 6545605 542.3 ns/op Benchmark____RoutedPubSub_1K-16 6652698 540.7 ns/op Benchmark____RoutedPubSub_1K-16 6634345 534.9 ns/op Benchmark____RoutedPubSub_1K-16 6486763 539.2 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 87391 41531 ns/op Benchmark__RoutedPubSub_100K-16 83178 43500 ns/op Benchmark__RoutedPubSub_100K-16 84002 42512 ns/op Benchmark__RoutedPubSub_100K-16 83787 42348 ns/op Benchmark__RoutedPubSub_100K-16 86416 41631 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9575178 320.0 ns/op Benchmark____Routed2QueueSub-16 9668287 319.9 ns/op Benchmark____Routed2QueueSub-16 9723718 319.7 ns/op Benchmark____Routed2QueueSub-16 9574754 315.6 ns/op Benchmark____Routed2QueueSub-16 9571861 318.8 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9602788 328.1 ns/op Benchmark____Routed4QueueSub-16 9497948 325.1 ns/op Benchmark____Routed4QueueSub-16 9621058 327.8 ns/op Benchmark____Routed4QueueSub-16 9755449 328.7 ns/op Benchmark____Routed4QueueSub-16 9601858 325.5 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9336684 335.1 ns/op Benchmark____Routed8QueueSub-16 9358987 330.0 ns/op Benchmark____Routed8QueueSub-16 9091225 337.9 ns/op Benchmark____Routed8QueueSub-16 9068133 337.2 ns/op Benchmark____Routed8QueueSub-16 9389860 328.8 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8683816 349.8 ns/op Benchmark___Routed16QueueSub-16 8619325 349.6 ns/op Benchmark___Routed16QueueSub-16 8600701 353.8 ns/op Benchmark___Routed16QueueSub-16 8775236 346.0 ns/op Benchmark___Routed16QueueSub-16 8708162 344.5 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6287556 556.3 ns/op Benchmark____________RouteCompressOff-16 6409382 554.1 ns/op Benchmark____________RouteCompressOff-16 6328516 552.3 ns/op Benchmark____________RouteCompressOff-16 6324277 548.0 ns/op Benchmark____________RouteCompressOff-16 6437913 551.4 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6333549 551.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6550944 467.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6231202 564.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6302174 562.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6341840 587.7 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6349762 563.9 ns/op Benchmark_________RouteCompressS2Fast-16 6308008 556.3 ns/op Benchmark_________RouteCompressS2Fast-16 6378189 554.0 ns/op Benchmark_________RouteCompressS2Fast-16 6279120 559.6 ns/op Benchmark_________RouteCompressS2Fast-16 6258771 556.2 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6320845 564.8 ns/op Benchmark_______RouteCompressS2Better-16 6442179 563.4 ns/op Benchmark_______RouteCompressS2Better-16 6323694 551.4 ns/op Benchmark_______RouteCompressS2Better-16 6348034 564.9 ns/op Benchmark_______RouteCompressS2Better-16 6296413 559.6 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6302340 559.9 ns/op Benchmark_________RouteCompressS2Best-16 6239754 554.1 ns/op Benchmark_________RouteCompressS2Best-16 6324548 558.7 ns/op Benchmark_________RouteCompressS2Best-16 6539769 552.5 ns/op Benchmark_________RouteCompressS2Best-16 6285597 559.9 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4652659 773.7 ns/op 321.84 MB/s Benchmark______FanOut_8x1x10-16 4684197 769.2 ns/op 323.69 MB/s Benchmark______FanOut_8x1x10-16 4642342 776.1 ns/op 320.83 MB/s Benchmark______FanOut_8x1x10-16 4658949 766.3 ns/op 324.92 MB/s Benchmark______FanOut_8x1x10-16 4660584 767.0 ns/op 324.65 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 538766 6223 ns/op 372.67 MB/s Benchmark_____FanOut_8x1x100-16 548464 6143 ns/op 377.53 MB/s Benchmark_____FanOut_8x1x100-16 561622 6104 ns/op 379.93 MB/s Benchmark_____FanOut_8x1x100-16 539979 6167 ns/op 376.03 MB/s Benchmark_____FanOut_8x1x100-16 532324 6202 ns/op 373.89 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47229 75617 ns/op 304.41 MB/s Benchmark____FanOut_8x10x100-16 47185 75799 ns/op 303.69 MB/s Benchmark____FanOut_8x10x100-16 47023 75804 ns/op 303.66 MB/s Benchmark____FanOut_8x10x100-16 47478 75801 ns/op 303.68 MB/s Benchmark____FanOut_8x10x100-16 47340 75530 ns/op 304.77 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5665 611621 ns/op 392.43 MB/s Benchmark___FanOut_8x10x1000-16 5554 609688 ns/op 393.68 MB/s Benchmark___FanOut_8x10x1000-16 5886 612150 ns/op 392.09 MB/s Benchmark___FanOut_8x10x1000-16 5797 610495 ns/op 393.15 MB/s Benchmark___FanOut_8x10x1000-16 5956 609923 ns/op 393.52 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4924 721418 ns/op 318.84 MB/s Benchmark___FanOut_8x100x100-16 5005 723072 ns/op 318.11 MB/s Benchmark___FanOut_8x100x100-16 4885 726061 ns/op 316.80 MB/s Benchmark___FanOut_8x100x100-16 4878 721350 ns/op 318.87 MB/s Benchmark___FanOut_8x100x100-16 4879 718380 ns/op 320.19 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 567 6358649 ns/op 377.44 MB/s Benchmark__FanOut_8x100x1000-16 565 6379766 ns/op 376.19 MB/s Benchmark__FanOut_8x100x1000-16 566 6337384 ns/op 378.71 MB/s Benchmark__FanOut_8x100x1000-16 560 6348464 ns/op 378.05 MB/s Benchmark__FanOut_8x100x1000-16 544 6325697 ns/op 379.41 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 517 6908769 ns/op 361.86 MB/s Benchmark__FanOut_8x10x10000-16 502 6838622 ns/op 365.57 MB/s Benchmark__FanOut_8x10x10000-16 520 6933073 ns/op 360.59 MB/s Benchmark__FanOut_8x10x10000-16 517 6910730 ns/op 361.76 MB/s Benchmark__FanOut_8x10x10000-16 512 6959817 ns/op 359.21 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 928 3829516 ns/op 300.30 MB/s Benchmark___FanOut_8x500x100-16 931 3805913 ns/op 302.17 MB/s Benchmark___FanOut_8x500x100-16 937 3827286 ns/op 300.48 MB/s Benchmark___FanOut_8x500x100-16 925 3813369 ns/op 301.58 MB/s Benchmark___FanOut_8x500x100-16 924 3813736 ns/op 301.55 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 360646 9624 ns/op 1521.35 MB/s Benchmark___FanOut_128x1x100-16 354018 9597 ns/op 1525.64 MB/s Benchmark___FanOut_128x1x100-16 347793 9535 ns/op 1535.45 MB/s Benchmark___FanOut_128x1x100-16 343713 9580 ns/op 1528.36 MB/s Benchmark___FanOut_128x1x100-16 357038 9583 ns/op 1527.83 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32206 112094 ns/op 1294.82 MB/s Benchmark__FanOut_128x10x100-16 32438 110591 ns/op 1312.41 MB/s Benchmark__FanOut_128x10x100-16 32077 110960 ns/op 1308.04 MB/s Benchmark__FanOut_128x10x100-16 32295 111665 ns/op 1299.79 MB/s Benchmark__FanOut_128x10x100-16 32247 111060 ns/op 1306.87 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3934 901273 ns/op 1620.09 MB/s Benchmark_FanOut_128x10x1000-16 3780 901044 ns/op 1620.50 MB/s Benchmark_FanOut_128x10x1000-16 3974 904152 ns/op 1614.93 MB/s Benchmark_FanOut_128x10x1000-16 3964 882390 ns/op 1654.76 MB/s Benchmark_FanOut_128x10x1000-16 4189 889566 ns/op 1641.41 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3471 1028903 ns/op 1409.41 MB/s Benchmark_FanOut_128x100x100-16 3439 1024082 ns/op 1416.04 MB/s Benchmark_FanOut_128x100x100-16 3436 1024214 ns/op 1415.86 MB/s Benchmark_FanOut_128x100x100-16 3428 1024961 ns/op 1414.83 MB/s Benchmark_FanOut_128x100x100-16 3439 1024305 ns/op 1415.73 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 385 9437818 ns/op 1546.98 MB/s BenchmarkFanOut_128x100x1000-16 375 9420532 ns/op 1549.82 MB/s BenchmarkFanOut_128x100x1000-16 370 9505464 ns/op 1535.97 MB/s BenchmarkFanOut_128x100x1000-16 373 9509893 ns/op 1535.26 MB/s BenchmarkFanOut_128x100x1000-16 376 9567051 ns/op 1526.09 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 362 9705252 ns/op 1514.66 MB/s BenchmarkFanOut_128x10x10000-16 368 9965870 ns/op 1475.05 MB/s BenchmarkFanOut_128x10x10000-16 363 9864375 ns/op 1490.23 MB/s BenchmarkFanOut_128x10x10000-16 367 9872879 ns/op 1488.94 MB/s BenchmarkFanOut_128x10x10000-16 363 9756358 ns/op 1506.72 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 658 5367113 ns/op 1350.85 MB/s BenchmarkFanOut__128x500x100-16 660 5348777 ns/op 1355.48 MB/s BenchmarkFanOut__128x500x100-16 658 5360270 ns/op 1352.57 MB/s BenchmarkFanOut__128x500x100-16 663 5358917 ns/op 1352.91 MB/s BenchmarkFanOut__128x500x100-16 664 5374953 ns/op 1348.88 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1927 1838819 ns/op 2877.13 MB/s Benchmark_FanOut_512x100x100-16 1930 1849813 ns/op 2860.03 MB/s Benchmark_FanOut_512x100x100-16 1898 1872201 ns/op 2825.83 MB/s Benchmark_FanOut_512x100x100-16 1924 1871628 ns/op 2826.70 MB/s Benchmark_FanOut_512x100x100-16 1926 1871035 ns/op 2827.59 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 16953927 ns/op 3126.15 MB/s Benchmark__FanOut_512x100x1k-16 211 16985860 ns/op 3120.27 MB/s Benchmark__FanOut_512x100x1k-16 212 16894829 ns/op 3137.09 MB/s Benchmark__FanOut_512x100x1k-16 212 16952362 ns/op 3126.44 MB/s Benchmark__FanOut_512x100x1k-16 211 17073992 ns/op 3104.17 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3200 1157850 ns/op 9008.97 MB/s Benchmark____FanOut_1kx10x1k-16 2995 1146340 ns/op 9099.43 MB/s Benchmark____FanOut_1kx10x1k-16 3159 1155725 ns/op 9025.54 MB/s Benchmark____FanOut_1kx10x1k-16 2852 1141865 ns/op 9135.09 MB/s Benchmark____FanOut_1kx10x1k-16 3019 1164234 ns/op 8959.57 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2769 1283833 ns/op 8117.13 MB/s Benchmark__FanOut_1kx100x100-16 2812 1272297 ns/op 8190.73 MB/s Benchmark__FanOut_1kx100x100-16 2770 1278915 ns/op 8148.34 MB/s Benchmark__FanOut_1kx100x100-16 2702 1286233 ns/op 8101.98 MB/s Benchmark__FanOut_1kx100x100-16 2712 1273157 ns/op 8185.20 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4512523 781.8 ns/op 318.49 MB/s Benchmark_____RFanOut_8x1x10-16 4376252 775.5 ns/op 321.07 MB/s Benchmark_____RFanOut_8x1x10-16 4508887 786.0 ns/op 316.81 MB/s Benchmark_____RFanOut_8x1x10-16 4462712 786.1 ns/op 316.77 MB/s Benchmark_____RFanOut_8x1x10-16 4485414 781.4 ns/op 318.65 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 555429 6206 ns/op 373.66 MB/s Benchmark____RFanOut_8x1x100-16 509817 6205 ns/op 373.73 MB/s Benchmark____RFanOut_8x1x100-16 523713 6248 ns/op 371.13 MB/s Benchmark____RFanOut_8x1x100-16 543634 6192 ns/op 374.54 MB/s Benchmark____RFanOut_8x1x100-16 541344 6246 ns/op 371.28 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46623 75430 ns/op 305.17 MB/s Benchmark___RFanOut_8x10x100-16 46992 76986 ns/op 299.00 MB/s Benchmark___RFanOut_8x10x100-16 47563 75847 ns/op 303.49 MB/s Benchmark___RFanOut_8x10x100-16 46659 77187 ns/op 298.23 MB/s Benchmark___RFanOut_8x10x100-16 45882 76025 ns/op 302.78 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5524 614789 ns/op 390.41 MB/s Benchmark__RFanOut_8x10x1000-16 5884 627536 ns/op 382.48 MB/s Benchmark__RFanOut_8x10x1000-16 5875 620477 ns/op 386.83 MB/s Benchmark__RFanOut_8x10x1000-16 5761 622889 ns/op 385.33 MB/s Benchmark__RFanOut_8x10x1000-16 5512 610990 ns/op 392.84 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4898 710304 ns/op 323.83 MB/s Benchmark__RFanOut_8x100x100-16 4957 713020 ns/op 322.60 MB/s Benchmark__RFanOut_8x100x100-16 4908 716114 ns/op 321.20 MB/s Benchmark__RFanOut_8x100x100-16 4909 711599 ns/op 323.24 MB/s Benchmark__RFanOut_8x100x100-16 4951 712313 ns/op 322.92 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 553 6295026 ns/op 381.26 MB/s Benchmark_RFanOut_8x100x1000-16 570 6395845 ns/op 375.25 MB/s Benchmark_RFanOut_8x100x1000-16 564 6570970 ns/op 365.25 MB/s Benchmark_RFanOut_8x100x1000-16 558 6266242 ns/op 383.01 MB/s Benchmark_RFanOut_8x100x1000-16 556 6457505 ns/op 371.66 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 513 6796445 ns/op 367.84 MB/s Benchmark_RFanOut_8x10x10000-16 531 6747061 ns/op 370.53 MB/s Benchmark_RFanOut_8x10x10000-16 530 6905384 ns/op 362.04 MB/s Benchmark_RFanOut_8x10x10000-16 534 6835281 ns/op 365.75 MB/s Benchmark_RFanOut_8x10x10000-16 529 6809267 ns/op 367.15 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3069 1166166 ns/op 8944.73 MB/s Benchmark_RFanOut_1kx10x1000-16 2883 1159437 ns/op 8996.64 MB/s Benchmark_RFanOut_1kx10x1000-16 3086 1161939 ns/op 8977.27 MB/s Benchmark_RFanOut_1kx10x1000-16 2752 1175104 ns/op 8876.69 MB/s Benchmark_RFanOut_1kx10x1000-16 3025 1158668 ns/op 9002.61 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6980676 506.4 ns/op 4103.54 MB/s Benchmark_____FanIn_1kx100x1-16 6960826 508.4 ns/op 4087.71 MB/s Benchmark_____FanIn_1kx100x1-16 6898422 507.6 ns/op 4093.38 MB/s Benchmark_____FanIn_1kx100x1-16 6878508 507.7 ns/op 4092.64 MB/s Benchmark_____FanIn_1kx100x1-16 6883224 507.0 ns/op 4098.47 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2604684 1377 ns/op 5972.55 MB/s Benchmark_____FanIn_4kx100x1-16 2604956 1354 ns/op 6074.20 MB/s Benchmark_____FanIn_4kx100x1-16 2569099 1373 ns/op 5988.10 MB/s Benchmark_____FanIn_4kx100x1-16 2662512 1378 ns/op 5968.77 MB/s Benchmark_____FanIn_4kx100x1-16 2668720 1373 ns/op 5988.33 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1695476 2112 ns/op 7771.77 MB/s Benchmark_____FanIn_8kx100x1-16 1686223 2120 ns/op 7742.80 MB/s Benchmark_____FanIn_8kx100x1-16 1676528 2103 ns/op 7805.95 MB/s Benchmark_____FanIn_8kx100x1-16 1742161 2115 ns/op 7759.49 MB/s Benchmark_____FanIn_8kx100x1-16 1724352 2124 ns/op 7728.51 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 859838 4138 ns/op 7925.77 MB/s Benchmark____FanIn_16kx100x1-16 859924 4086 ns/op 8027.91 MB/s Benchmark____FanIn_16kx100x1-16 873831 4148 ns/op 7908.04 MB/s Benchmark____FanIn_16kx100x1-16 855424 4154 ns/op 7895.10 MB/s Benchmark____FanIn_16kx100x1-16 872488 4235 ns/op 7744.25 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 154952 19963 ns/op 6567.37 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 2504845683 vs 11556993900 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54052->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54600->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54110->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54536->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 162356 19696 ns/op 6656.29 MB/s Benchmark____FanIn_64kx100x1-16 175176 19940 ns/op 6575.04 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 4985305650 vs 11163675900 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52928->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 379243370 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54654->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 217085040 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56612->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:56354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56688->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: 288266910 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58594->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:58580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58664->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: 223246270 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60046->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59606->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59662->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60116->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60376->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:59812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59706->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: 118112090 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33866->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33708->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5497629 648.0 ns/op 438.30 MB/s Benchmark___BumpPubCount_1x3-16 5473317 645.9 ns/op 439.70 MB/s Benchmark___BumpPubCount_1x3-16 5551975 647.0 ns/op 438.98 MB/s Benchmark___BumpPubCount_1x3-16 5542740 648.5 ns/op 437.93 MB/s Benchmark___BumpPubCount_1x3-16 5580225 642.6 ns/op 441.98 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5274051 682.7 ns/op 415.98 MB/s Benchmark___BumpPubCount_2x3-16 5266524 682.3 ns/op 416.26 MB/s Benchmark___BumpPubCount_2x3-16 5248209 682.5 ns/op 416.12 MB/s Benchmark___BumpPubCount_2x3-16 5208230 682.0 ns/op 416.44 MB/s Benchmark___BumpPubCount_2x3-16 5195907 681.5 ns/op 416.74 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5476554 650.8 ns/op 436.38 MB/s Benchmark___BumpPubCount_5x3-16 5498239 648.2 ns/op 438.14 MB/s Benchmark___BumpPubCount_5x3-16 5452152 649.0 ns/op 437.61 MB/s Benchmark___BumpPubCount_5x3-16 5460642 650.4 ns/op 436.65 MB/s Benchmark___BumpPubCount_5x3-16 5506568 653.6 ns/op 434.54 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5502592 650.4 ns/op 436.65 MB/s Benchmark__BumpPubCount_10x3-16 5503848 650.6 ns/op 436.49 MB/s Benchmark__BumpPubCount_10x3-16 5500111 650.1 ns/op 436.85 MB/s Benchmark__BumpPubCount_10x3-16 5506200 650.1 ns/op 436.83 MB/s Benchmark__BumpPubCount_10x3-16 5548405 650.6 ns/op 436.50 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12040453 276.0 ns/op 3767.99 MB/s Benchmark____GWs_Opt_1kx01x0-16 12438660 279.3 ns/op 3723.40 MB/s Benchmark____GWs_Opt_1kx01x0-16 12096921 278.2 ns/op 3738.34 MB/s Benchmark____GWs_Opt_1kx01x0-16 12475725 282.1 ns/op 3686.43 MB/s Benchmark____GWs_Opt_1kx01x0-16 12347764 280.1 ns/op 3712.79 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10602284 330.7 ns/op 6241.44 MB/s Benchmark____GWs_Opt_2kx01x0-16 10687587 333.0 ns/op 6198.96 MB/s Benchmark____GWs_Opt_2kx01x0-16 10816906 344.7 ns/op 5987.18 MB/s Benchmark____GWs_Opt_2kx01x0-16 10371208 358.5 ns/op 5758.12 MB/s Benchmark____GWs_Opt_2kx01x0-16 10455322 346.6 ns/op 5955.51 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5587632 693.5 ns/op 5929.56 MB/s Benchmark____GWs_Opt_4kx01x0-16 5422545 644.9 ns/op 6375.82 MB/s Benchmark____GWs_Opt_4kx01x0-16 5387682 653.2 ns/op 6295.26 MB/s Benchmark____GWs_Opt_4kx01x0-16 5515070 637.7 ns/op 6447.90 MB/s Benchmark____GWs_Opt_4kx01x0-16 5726560 649.0 ns/op 6336.12 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28283190 113.5 ns/op 9160.89 MB/s Benchmark____GWs_Opt_1kx10x0-16 31074403 111.1 ns/op 9362.33 MB/s Benchmark____GWs_Opt_1kx10x0-16 30292200 107.6 ns/op 9668.71 MB/s Benchmark____GWs_Opt_1kx10x0-16 20493592 161.3 ns/op 6446.89 MB/s Benchmark____GWs_Opt_1kx10x0-16 31146973 112.9 ns/op 9212.91 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 18126975 172.4 ns/op 11974.32 MB/s Benchmark____GWs_Opt_2kx10x0-16 25027536 174.4 ns/op 11836.40 MB/s Benchmark____GWs_Opt_2kx10x0-16 23554102 148.9 ns/op 13861.19 MB/s Benchmark____GWs_Opt_2kx10x0-16 23919237 154.3 ns/op 13374.31 MB/s Benchmark____GWs_Opt_2kx10x0-16 25420662 147.6 ns/op 13987.63 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11788428 298.1 ns/op 13793.66 MB/s Benchmark____GWs_Opt_4kx10x0-16 12970358 318.8 ns/op 12900.23 MB/s Benchmark____GWs_Opt_4kx10x0-16 11335934 324.4 ns/op 12674.39 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:36096->127.0.0.1:35347: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 11751666 347.4 ns/op 11835.21 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6348807 557.7 ns/op 5603.47 MB/s Benchmark____GWs_Opt_1kx01x1-16 6595023 558.6 ns/op 5594.71 MB/s Benchmark____GWs_Opt_1kx01x1-16 6219342 555.2 ns/op 5628.15 MB/s Benchmark____GWs_Opt_1kx01x1-16 6452421 563.3 ns/op 5547.87 MB/s Benchmark____GWs_Opt_1kx01x1-16 6442788 550.0 ns/op 5681.69 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4629512 778.9 ns/op 7955.73 MB/s Benchmark____GWs_Opt_2kx01x1-16 4716278 766.5 ns/op 8084.92 MB/s Benchmark____GWs_Opt_2kx01x1-16 4754542 766.9 ns/op 8080.75 MB/s Benchmark____GWs_Opt_2kx01x1-16 4757086 919.2 ns/op 6741.61 MB/s Benchmark____GWs_Opt_2kx01x1-16 4551828 771.0 ns/op 8037.35 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2599356 1474 ns/op 8374.26 MB/s Benchmark____GWs_Opt_4kx01x1-16 2576032 1537 ns/op 8030.36 MB/s Benchmark____GWs_Opt_4kx01x1-16 2582580 1384 ns/op 8917.09 MB/s Benchmark____GWs_Opt_4kx01x1-16 2514874 1399 ns/op 8820.04 MB/s Benchmark____GWs_Opt_4kx01x1-16 2645626 1394 ns/op 8854.12 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6455384 555.9 ns/op 5621.73 MB/s Benchmark____GWs_Opt_1kx10x1-16 6091387 570.6 ns/op 5476.49 MB/s Benchmark____GWs_Opt_1kx10x1-16 6457702 562.1 ns/op 5559.45 MB/s Benchmark____GWs_Opt_1kx10x1-16 6461149 559.2 ns/op 5588.21 MB/s Benchmark____GWs_Opt_1kx10x1-16 6113290 551.1 ns/op 5670.76 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4120441 849.0 ns/op 7299.45 MB/s Benchmark____GWs_Opt_2kx10x1-16 4164163 859.8 ns/op 7207.58 MB/s Benchmark____GWs_Opt_2kx10x1-16 4410435 864.6 ns/op 7167.88 MB/s Benchmark____GWs_Opt_2kx10x1-16 4109532 859.3 ns/op 7211.80 MB/s Benchmark____GWs_Opt_2kx10x1-16 4256166 848.7 ns/op 7301.67 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2437081 1530 ns/op 8065.59 MB/s Benchmark____GWs_Opt_4kx10x1-16 2337204 1419 ns/op 8694.38 MB/s Benchmark____GWs_Opt_4kx10x1-16 2390880 1530 ns/op 8064.80 MB/s Benchmark____GWs_Opt_4kx10x1-16 2350840 1530 ns/op 8064.31 MB/s Benchmark____GWs_Opt_4kx10x1-16 2312631 1560 ns/op 7909.99 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12302818 286.2 ns/op 3633.47 MB/s Benchmark____GWs_Int_1kx01x0-16 11426306 287.0 ns/op 3623.98 MB/s Benchmark____GWs_Int_1kx01x0-16 11742116 283.7 ns/op 3665.30 MB/s Benchmark____GWs_Int_1kx01x0-16 12174548 292.2 ns/op 3559.00 MB/s Benchmark____GWs_Int_1kx01x0-16 12313432 294.8 ns/op 3528.05 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10157403 373.8 ns/op 5521.55 MB/s Benchmark____GWs_Int_2kx01x0-16 10239608 361.7 ns/op 5705.90 MB/s Benchmark____GWs_Int_2kx01x0-16 9638947 360.5 ns/op 5725.27 MB/s Benchmark____GWs_Int_2kx01x0-16 10520640 368.5 ns/op 5601.32 MB/s Benchmark____GWs_Int_2kx01x0-16 9228313 365.2 ns/op 5651.17 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5498869 668.5 ns/op 6150.78 MB/s Benchmark____GWs_Int_4kx01x0-16 5508710 666.1 ns/op 6173.60 MB/s Benchmark____GWs_Int_4kx01x0-16 5413232 650.9 ns/op 6317.73 MB/s Benchmark____GWs_Int_4kx01x0-16 5199537 645.2 ns/op 6372.98 MB/s Benchmark____GWs_Int_4kx01x0-16 5625356 648.8 ns/op 6337.49 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32455245 118.8 ns/op 8756.68 MB/s Benchmark____GWs_Int_1kx10x0-16 31650824 111.5 ns/op 9327.86 MB/s Benchmark____GWs_Int_1kx10x0-16 31355316 113.6 ns/op 9153.80 MB/s Benchmark____GWs_Int_1kx10x0-16 32465799 113.4 ns/op 9174.34 MB/s Benchmark____GWs_Int_1kx10x0-16 31909525 110.8 ns/op 9384.45 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25744758 138.9 ns/op 14856.50 MB/s Benchmark____GWs_Int_2kx10x0-16 24924366 176.0 ns/op 11724.18 MB/s Benchmark____GWs_Int_2kx10x0-16 25842097 150.7 ns/op 13693.73 MB/s Benchmark____GWs_Int_2kx10x0-16 26258172 144.8 ns/op 14257.08 MB/s Benchmark____GWs_Int_2kx10x0-16 25410697 141.8 ns/op 14558.58 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 10141368 358.7 ns/op 11465.16 MB/s Benchmark____GWs_Int_4kx10x0-16 13020604 342.1 ns/op 12018.71 MB/s Benchmark____GWs_Int_4kx10x0-16 12456277 310.7 ns/op 13234.42 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:53772->127.0.0.1:45747: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 11515000 321.5 ns/op 12788.62 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6291110 560.3 ns/op 5577.42 MB/s Benchmark____GWs_Int_1kx01x1-16 6465216 561.6 ns/op 5564.74 MB/s Benchmark____GWs_Int_1kx01x1-16 6546030 558.5 ns/op 5594.87 MB/s Benchmark____GWs_Int_1kx01x1-16 6631178 564.5 ns/op 5535.48 MB/s Benchmark____GWs_Int_1kx01x1-16 6428904 564.5 ns/op 5536.13 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4465392 776.9 ns/op 7976.84 MB/s Benchmark____GWs_Int_2kx01x1-16 4607322 767.0 ns/op 8079.01 MB/s Benchmark____GWs_Int_2kx01x1-16 4608938 773.8 ns/op 8008.06 MB/s Benchmark____GWs_Int_2kx01x1-16 4820028 850.8 ns/op 7283.58 MB/s Benchmark____GWs_Int_2kx01x1-16 4532619 776.4 ns/op 7981.78 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2614725 1388 ns/op 8891.58 MB/s Benchmark____GWs_Int_4kx01x1-16 2578532 1476 ns/op 8358.97 MB/s Benchmark____GWs_Int_4kx01x1-16 2425986 1373 ns/op 8988.89 MB/s Benchmark____GWs_Int_4kx01x1-16 2599623 1403 ns/op 8798.64 MB/s Benchmark____GWs_Int_4kx01x1-16 2595481 1412 ns/op 8742.87 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6201110 564.2 ns/op 5538.40 MB/s Benchmark____GWs_Int_1kx10x1-16 6220923 562.6 ns/op 5554.18 MB/s Benchmark____GWs_Int_1kx10x1-16 6216165 563.5 ns/op 5545.52 MB/s Benchmark____GWs_Int_1kx10x1-16 6301076 565.2 ns/op 5528.69 MB/s Benchmark____GWs_Int_1kx10x1-16 6103320 562.3 ns/op 5557.55 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4077625 873.2 ns/op 7096.73 MB/s Benchmark____GWs_Int_2kx10x1-16 4127607 850.2 ns/op 7288.75 MB/s Benchmark____GWs_Int_2kx10x1-16 4156827 851.8 ns/op 7275.25 MB/s Benchmark____GWs_Int_2kx10x1-16 4139822 859.4 ns/op 7211.01 MB/s Benchmark____GWs_Int_2kx10x1-16 4098541 860.0 ns/op 7206.22 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2335807 1520 ns/op 8120.06 MB/s Benchmark____GWs_Int_4kx10x1-16 2339016 1639 ns/op 7527.65 MB/s Benchmark____GWs_Int_4kx10x1-16 2387565 1514 ns/op 8151.85 MB/s Benchmark____GWs_Int_4kx10x1-16 2170479 1492 ns/op 8269.06 MB/s Benchmark____GWs_Int_4kx10x1-16 2328794 1648 ns/op 7488.86 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8053342 440.0 ns/op 231.81 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8278920 430.9 ns/op 236.69 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8313987 436.4 ns/op 233.74 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8263791 446.7 ns/op 228.33 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7990717 438.0 ns/op 232.88 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 715820 5147 ns/op 34.39 MB/s Benchmark__GWs_Reqs_1SubEach-16 755372 5412 ns/op 32.71 MB/s Benchmark__GWs_Reqs_1SubEach-16 730063 5222 ns/op 33.89 MB/s Benchmark__GWs_Reqs_1SubEach-16 729886 5283 ns/op 33.51 MB/s Benchmark__GWs_Reqs_1SubEach-16 691562 5296 ns/op 33.42 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2054.911s