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 50339926 71.49 ns/op 153.87 MB/s Benchmark______Pub0b_Payload-16 47498047 71.84 ns/op 153.12 MB/s Benchmark______Pub0b_Payload-16 49637504 71.45 ns/op 153.94 MB/s Benchmark______Pub0b_Payload-16 50312360 71.72 ns/op 153.37 MB/s Benchmark______Pub0b_Payload-16 44483527 71.80 ns/op 153.21 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 40259128 75.24 ns/op 252.52 MB/s Benchmark______Pub8b_Payload-16 47348748 74.50 ns/op 255.04 MB/s Benchmark______Pub8b_Payload-16 46777953 72.40 ns/op 262.44 MB/s Benchmark______Pub8b_Payload-16 47068671 72.20 ns/op 263.14 MB/s Benchmark______Pub8b_Payload-16 46999366 73.19 ns/op 259.60 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 42093978 76.09 ns/op 578.23 MB/s Benchmark_____Pub32b_Payload-16 44730228 76.19 ns/op 577.49 MB/s Benchmark_____Pub32b_Payload-16 44628890 76.13 ns/op 577.98 MB/s Benchmark_____Pub32b_Payload-16 38786108 79.62 ns/op 552.61 MB/s Benchmark_____Pub32b_Payload-16 44922211 76.96 ns/op 571.70 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 42246106 87.53 ns/op 1610.83 MB/s Benchmark____Pub128B_Payload-16 34864004 88.30 ns/op 1596.87 MB/s Benchmark____Pub128B_Payload-16 40162486 85.51 ns/op 1648.89 MB/s Benchmark____Pub128B_Payload-16 35012226 86.58 ns/op 1628.58 MB/s Benchmark____Pub128B_Payload-16 38893153 86.00 ns/op 1639.59 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 37247472 105.5 ns/op 2549.14 MB/s Benchmark____Pub256B_Payload-16 31824247 98.44 ns/op 2732.49 MB/s Benchmark____Pub256B_Payload-16 36714920 93.64 ns/op 2872.78 MB/s Benchmark____Pub256B_Payload-16 34833100 94.69 ns/op 2840.70 MB/s Benchmark____Pub256B_Payload-16 36373838 93.87 ns/op 2865.67 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25351482 136.5 ns/op 7606.34 MB/s Benchmark______Pub1K_Payload-16 24908167 148.6 ns/op 6986.50 MB/s Benchmark______Pub1K_Payload-16 22317208 141.6 ns/op 7329.08 MB/s Benchmark______Pub1K_Payload-16 22425226 159.9 ns/op 6492.12 MB/s Benchmark______Pub1K_Payload-16 23659915 150.5 ns/op 6897.58 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5696808 621.7 ns/op 6610.93 MB/s Benchmark______Pub4K_Payload-16 5774052 625.7 ns/op 6568.91 MB/s Benchmark______Pub4K_Payload-16 5646878 619.9 ns/op 6630.01 MB/s Benchmark______Pub4K_Payload-16 5646099 618.4 ns/op 6646.50 MB/s Benchmark______Pub4K_Payload-16 5615304 625.0 ns/op 6575.77 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2792506 1274 ns/op 6439.52 MB/s Benchmark______Pub8K_Payload-16 2728118 1285 ns/op 6388.14 MB/s Benchmark______Pub8K_Payload-16 2635195 1275 ns/op 6437.71 MB/s Benchmark______Pub8K_Payload-16 2805081 1288 ns/op 6370.61 MB/s Benchmark______Pub8K_Payload-16 2791454 1275 ns/op 6433.74 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 641108 5493 ns/op 5968.04 MB/s Benchmark_____Pub32K_Payload-16 653126 5600 ns/op 5854.43 MB/s Benchmark_____Pub32K_Payload-16 638602 5546 ns/op 5911.14 MB/s Benchmark_____Pub32K_Payload-16 663450 7412 ns/op 4422.83 MB/s Benchmark_____Pub32K_Payload-16 660428 5465 ns/op 5998.26 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31350217 97.50 ns/op 112.82 MB/s Benchmark__AuthPub0b_Payload-16 35317369 96.96 ns/op 113.45 MB/s Benchmark__AuthPub0b_Payload-16 34923304 99.04 ns/op 111.07 MB/s Benchmark__AuthPub0b_Payload-16 35281741 97.49 ns/op 112.83 MB/s Benchmark__AuthPub0b_Payload-16 35112489 97.41 ns/op 112.92 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15368000 229.0 ns/op Benchmark_____________PubSub-16 15539404 229.5 ns/op Benchmark_____________PubSub-16 15187951 229.1 ns/op Benchmark_____________PubSub-16 15394254 228.5 ns/op Benchmark_____________PubSub-16 15500228 231.6 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15697448 227.3 ns/op Benchmark_____PubSubTwoConns-16 15436363 226.5 ns/op Benchmark_____PubSubTwoConns-16 15456716 227.8 ns/op Benchmark_____PubSubTwoConns-16 15681967 227.7 ns/op Benchmark_____PubSubTwoConns-16 15670214 227.9 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34758->127.0.0.1:39745: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58414->127.0.0.1:41209: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:38286->127.0.0.1:43631: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:52846->127.0.0.1:40585: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:53682->127.0.0.1:33705: 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 14286322 247.7 ns/op Benchmark_____PubTwoQueueSub-16 14353580 248.9 ns/op Benchmark_____PubTwoQueueSub-16 14351086 248.0 ns/op Benchmark_____PubTwoQueueSub-16 14274969 248.4 ns/op Benchmark_____PubTwoQueueSub-16 14420804 247.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14288168 247.7 ns/op Benchmark____PubFourQueueSub-16 14309359 247.5 ns/op Benchmark____PubFourQueueSub-16 14395508 246.9 ns/op Benchmark____PubFourQueueSub-16 14517861 247.9 ns/op Benchmark____PubFourQueueSub-16 14219959 247.2 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14091956 247.9 ns/op Benchmark___PubEightQueueSub-16 14356208 248.6 ns/op Benchmark___PubEightQueueSub-16 14168948 247.9 ns/op Benchmark___PubEightQueueSub-16 14327806 249.1 ns/op Benchmark___PubEightQueueSub-16 14397007 250.0 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23169 154089 ns/op Benchmark_PubSub512kTwoConns-16 23194 155908 ns/op Benchmark_PubSub512kTwoConns-16 23251 155227 ns/op Benchmark_PubSub512kTwoConns-16 23210 155822 ns/op Benchmark_PubSub512kTwoConns-16 23092 156366 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14981017 230.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 14879600 231.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15055274 231.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15237348 231.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15130807 231.2 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15049569 232.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15052534 231.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15073780 230.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15173726 231.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15205294 232.0 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10944160 314.3 ns/op Benchmark____RoutedPubSub_0b-16 11181435 313.7 ns/op Benchmark____RoutedPubSub_0b-16 11329197 317.1 ns/op Benchmark____RoutedPubSub_0b-16 11423292 318.5 ns/op Benchmark____RoutedPubSub_0b-16 11259685 313.6 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6494406 534.3 ns/op Benchmark____RoutedPubSub_1K-16 6604045 542.9 ns/op Benchmark____RoutedPubSub_1K-16 6504756 538.9 ns/op Benchmark____RoutedPubSub_1K-16 6555303 534.1 ns/op Benchmark____RoutedPubSub_1K-16 6544536 538.6 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84052 42061 ns/op Benchmark__RoutedPubSub_100K-16 82461 43115 ns/op Benchmark__RoutedPubSub_100K-16 83703 42394 ns/op Benchmark__RoutedPubSub_100K-16 83236 41467 ns/op Benchmark__RoutedPubSub_100K-16 84882 44286 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9890523 318.3 ns/op Benchmark____Routed2QueueSub-16 9462642 325.7 ns/op Benchmark____Routed2QueueSub-16 9744758 323.0 ns/op Benchmark____Routed2QueueSub-16 9680172 325.9 ns/op Benchmark____Routed2QueueSub-16 9578486 324.1 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9653817 322.1 ns/op Benchmark____Routed4QueueSub-16 9635542 324.8 ns/op Benchmark____Routed4QueueSub-16 9690954 318.2 ns/op Benchmark____Routed4QueueSub-16 9359445 321.0 ns/op Benchmark____Routed4QueueSub-16 9501786 321.4 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9262074 329.9 ns/op Benchmark____Routed8QueueSub-16 9251761 330.8 ns/op Benchmark____Routed8QueueSub-16 9235609 335.8 ns/op Benchmark____Routed8QueueSub-16 11059446 321.5 ns/op Benchmark____Routed8QueueSub-16 9530000 323.6 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8967416 345.0 ns/op Benchmark___Routed16QueueSub-16 8916332 348.9 ns/op Benchmark___Routed16QueueSub-16 8891307 350.1 ns/op Benchmark___Routed16QueueSub-16 8867247 346.4 ns/op Benchmark___Routed16QueueSub-16 8712649 349.7 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6337530 558.2 ns/op Benchmark____________RouteCompressOff-16 6251698 544.6 ns/op Benchmark____________RouteCompressOff-16 6439442 544.7 ns/op Benchmark____________RouteCompressOff-16 6466459 552.6 ns/op Benchmark____________RouteCompressOff-16 6492692 558.0 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6233209 558.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6473922 554.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6397142 552.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6395550 553.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6421905 557.6 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6472117 552.3 ns/op Benchmark_________RouteCompressS2Fast-16 6538044 556.7 ns/op Benchmark_________RouteCompressS2Fast-16 6378709 558.5 ns/op Benchmark_________RouteCompressS2Fast-16 6484231 547.8 ns/op Benchmark_________RouteCompressS2Fast-16 6247507 556.8 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6482598 551.7 ns/op Benchmark_______RouteCompressS2Better-16 6302670 544.5 ns/op Benchmark_______RouteCompressS2Better-16 6434712 554.4 ns/op Benchmark_______RouteCompressS2Better-16 6362451 545.3 ns/op Benchmark_______RouteCompressS2Better-16 6399735 550.0 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6350245 540.7 ns/op Benchmark_________RouteCompressS2Best-16 6493142 551.9 ns/op Benchmark_________RouteCompressS2Best-16 6461318 551.0 ns/op Benchmark_________RouteCompressS2Best-16 6440169 550.5 ns/op Benchmark_________RouteCompressS2Best-16 6454832 548.0 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4626296 774.0 ns/op 321.72 MB/s Benchmark______FanOut_8x1x10-16 4624454 769.6 ns/op 323.56 MB/s Benchmark______FanOut_8x1x10-16 4677392 769.8 ns/op 323.46 MB/s Benchmark______FanOut_8x1x10-16 4683021 771.4 ns/op 322.80 MB/s Benchmark______FanOut_8x1x10-16 4667791 770.9 ns/op 323.01 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 524056 6108 ns/op 379.65 MB/s Benchmark_____FanOut_8x1x100-16 534147 6177 ns/op 375.41 MB/s Benchmark_____FanOut_8x1x100-16 554412 6131 ns/op 378.24 MB/s Benchmark_____FanOut_8x1x100-16 516505 6103 ns/op 379.98 MB/s Benchmark_____FanOut_8x1x100-16 546084 6210 ns/op 373.42 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 46946 77497 ns/op 297.03 MB/s Benchmark____FanOut_8x10x100-16 46732 76587 ns/op 300.56 MB/s Benchmark____FanOut_8x10x100-16 46868 76643 ns/op 300.34 MB/s Benchmark____FanOut_8x10x100-16 47143 76686 ns/op 300.17 MB/s Benchmark____FanOut_8x10x100-16 46879 76629 ns/op 300.40 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5810 624004 ns/op 384.64 MB/s Benchmark___FanOut_8x10x1000-16 5766 631536 ns/op 380.06 MB/s Benchmark___FanOut_8x10x1000-16 5722 633441 ns/op 378.91 MB/s Benchmark___FanOut_8x10x1000-16 5548 622734 ns/op 385.43 MB/s Benchmark___FanOut_8x10x1000-16 5794 629100 ns/op 381.53 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4855 728545 ns/op 315.72 MB/s Benchmark___FanOut_8x100x100-16 4911 731497 ns/op 314.45 MB/s Benchmark___FanOut_8x100x100-16 4864 728445 ns/op 315.77 MB/s Benchmark___FanOut_8x100x100-16 4833 729273 ns/op 315.41 MB/s Benchmark___FanOut_8x100x100-16 4837 727555 ns/op 316.15 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 546 6496897 ns/op 369.41 MB/s Benchmark__FanOut_8x100x1000-16 540 6534486 ns/op 367.29 MB/s Benchmark__FanOut_8x100x1000-16 540 6537924 ns/op 367.09 MB/s Benchmark__FanOut_8x100x1000-16 537 6620491 ns/op 362.51 MB/s Benchmark__FanOut_8x100x1000-16 546 6503761 ns/op 369.02 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 516 6936149 ns/op 360.43 MB/s Benchmark__FanOut_8x10x10000-16 507 6891102 ns/op 362.79 MB/s Benchmark__FanOut_8x10x10000-16 519 7025545 ns/op 355.85 MB/s Benchmark__FanOut_8x10x10000-16 514 7022962 ns/op 355.98 MB/s Benchmark__FanOut_8x10x10000-16 498 6920388 ns/op 361.25 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 926 3869696 ns/op 297.19 MB/s Benchmark___FanOut_8x500x100-16 922 3852381 ns/op 298.52 MB/s Benchmark___FanOut_8x500x100-16 927 3846883 ns/op 298.95 MB/s Benchmark___FanOut_8x500x100-16 912 3850778 ns/op 298.65 MB/s Benchmark___FanOut_8x500x100-16 922 3844200 ns/op 299.16 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 359428 9576 ns/op 1528.94 MB/s Benchmark___FanOut_128x1x100-16 366207 9539 ns/op 1534.88 MB/s Benchmark___FanOut_128x1x100-16 354608 9583 ns/op 1527.83 MB/s Benchmark___FanOut_128x1x100-16 352255 9550 ns/op 1533.06 MB/s Benchmark___FanOut_128x1x100-16 358780 9528 ns/op 1536.58 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32043 111822 ns/op 1297.96 MB/s Benchmark__FanOut_128x10x100-16 32257 111334 ns/op 1303.65 MB/s Benchmark__FanOut_128x10x100-16 31874 112431 ns/op 1290.93 MB/s Benchmark__FanOut_128x10x100-16 31822 112358 ns/op 1291.77 MB/s Benchmark__FanOut_128x10x100-16 32012 112723 ns/op 1287.59 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3708 898732 ns/op 1624.67 MB/s Benchmark_FanOut_128x10x1000-16 3936 918091 ns/op 1590.41 MB/s Benchmark_FanOut_128x10x1000-16 3900 901935 ns/op 1618.90 MB/s Benchmark_FanOut_128x10x1000-16 3772 909919 ns/op 1604.69 MB/s Benchmark_FanOut_128x10x1000-16 3932 908167 ns/op 1607.79 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3440 1030680 ns/op 1406.97 MB/s Benchmark_FanOut_128x100x100-16 3402 1031859 ns/op 1405.37 MB/s Benchmark_FanOut_128x100x100-16 3459 1038417 ns/op 1396.49 MB/s Benchmark_FanOut_128x100x100-16 3430 1035231 ns/op 1400.79 MB/s Benchmark_FanOut_128x100x100-16 3418 1033250 ns/op 1403.48 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 373 9469409 ns/op 1541.82 MB/s BenchmarkFanOut_128x100x1000-16 369 9572428 ns/op 1525.23 MB/s BenchmarkFanOut_128x100x1000-16 376 9593467 ns/op 1521.88 MB/s BenchmarkFanOut_128x100x1000-16 373 9588879 ns/op 1522.61 MB/s BenchmarkFanOut_128x100x1000-16 372 9537010 ns/op 1530.89 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 363 9893953 ns/op 1485.77 MB/s BenchmarkFanOut_128x10x10000-16 367 9881687 ns/op 1487.61 MB/s BenchmarkFanOut_128x10x10000-16 364 9973931 ns/op 1473.86 MB/s BenchmarkFanOut_128x10x10000-16 368 9792649 ns/op 1501.14 MB/s BenchmarkFanOut_128x10x10000-16 367 9776199 ns/op 1503.67 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 673 5362761 ns/op 1351.94 MB/s BenchmarkFanOut__128x500x100-16 669 5374036 ns/op 1349.11 MB/s BenchmarkFanOut__128x500x100-16 662 5323626 ns/op 1361.88 MB/s BenchmarkFanOut__128x500x100-16 663 5347578 ns/op 1355.78 MB/s BenchmarkFanOut__128x500x100-16 654 5346089 ns/op 1356.16 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1927 1854800 ns/op 2852.34 MB/s Benchmark_FanOut_512x100x100-16 1887 1856948 ns/op 2849.04 MB/s Benchmark_FanOut_512x100x100-16 1897 1869355 ns/op 2830.13 MB/s Benchmark_FanOut_512x100x100-16 1903 1879395 ns/op 2815.01 MB/s Benchmark_FanOut_512x100x100-16 1912 1880547 ns/op 2813.29 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 211 16945093 ns/op 3127.78 MB/s Benchmark__FanOut_512x100x1k-16 208 16886143 ns/op 3138.70 MB/s Benchmark__FanOut_512x100x1k-16 212 17065185 ns/op 3105.77 MB/s Benchmark__FanOut_512x100x1k-16 211 17082336 ns/op 3102.65 MB/s Benchmark__FanOut_512x100x1k-16 208 17109910 ns/op 3097.65 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3060 1166293 ns/op 8943.76 MB/s Benchmark____FanOut_1kx10x1k-16 3103 1180146 ns/op 8838.77 MB/s Benchmark____FanOut_1kx10x1k-16 2989 1162807 ns/op 8970.56 MB/s Benchmark____FanOut_1kx10x1k-16 2968 1148551 ns/op 9081.91 MB/s Benchmark____FanOut_1kx10x1k-16 3034 1158709 ns/op 9002.30 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2780 1290797 ns/op 8073.34 MB/s Benchmark__FanOut_1kx100x100-16 2728 1277026 ns/op 8160.40 MB/s Benchmark__FanOut_1kx100x100-16 2774 1278132 ns/op 8153.33 MB/s Benchmark__FanOut_1kx100x100-16 2702 1276128 ns/op 8166.14 MB/s Benchmark__FanOut_1kx100x100-16 2754 1279672 ns/op 8143.53 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4420208 773.2 ns/op 322.03 MB/s Benchmark_____RFanOut_8x1x10-16 4448762 779.9 ns/op 319.28 MB/s Benchmark_____RFanOut_8x1x10-16 4490488 767.8 ns/op 324.30 MB/s Benchmark_____RFanOut_8x1x10-16 4531533 808.5 ns/op 307.99 MB/s Benchmark_____RFanOut_8x1x10-16 4462611 780.3 ns/op 319.13 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 503814 6294 ns/op 368.47 MB/s Benchmark____RFanOut_8x1x100-16 545608 6252 ns/op 370.90 MB/s Benchmark____RFanOut_8x1x100-16 542977 6204 ns/op 373.82 MB/s Benchmark____RFanOut_8x1x100-16 552639 6197 ns/op 374.19 MB/s Benchmark____RFanOut_8x1x100-16 522746 6273 ns/op 369.66 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46545 78100 ns/op 294.74 MB/s Benchmark___RFanOut_8x10x100-16 46572 76379 ns/op 301.38 MB/s Benchmark___RFanOut_8x10x100-16 47182 76827 ns/op 299.62 MB/s Benchmark___RFanOut_8x10x100-16 46190 76489 ns/op 300.95 MB/s Benchmark___RFanOut_8x10x100-16 46730 77550 ns/op 296.83 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5408 624762 ns/op 384.18 MB/s Benchmark__RFanOut_8x10x1000-16 5619 626315 ns/op 383.22 MB/s Benchmark__RFanOut_8x10x1000-16 5484 634161 ns/op 378.48 MB/s Benchmark__RFanOut_8x10x1000-16 5719 648246 ns/op 370.26 MB/s Benchmark__RFanOut_8x10x1000-16 5684 633993 ns/op 378.58 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4988 740779 ns/op 310.51 MB/s Benchmark__RFanOut_8x100x100-16 4887 730880 ns/op 314.72 MB/s Benchmark__RFanOut_8x100x100-16 4898 730389 ns/op 314.93 MB/s Benchmark__RFanOut_8x100x100-16 4891 723056 ns/op 318.12 MB/s Benchmark__RFanOut_8x100x100-16 4824 723998 ns/op 317.71 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 529 6497806 ns/op 369.36 MB/s Benchmark_RFanOut_8x100x1000-16 553 6523691 ns/op 367.89 MB/s Benchmark_RFanOut_8x100x1000-16 548 6448778 ns/op 372.17 MB/s Benchmark_RFanOut_8x100x1000-16 550 6530937 ns/op 367.48 MB/s Benchmark_RFanOut_8x100x1000-16 534 6580729 ns/op 364.70 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 508 6978670 ns/op 358.24 MB/s Benchmark_RFanOut_8x10x10000-16 520 6961849 ns/op 359.10 MB/s Benchmark_RFanOut_8x10x10000-16 517 7046587 ns/op 354.78 MB/s Benchmark_RFanOut_8x10x10000-16 501 6914438 ns/op 361.57 MB/s Benchmark_RFanOut_8x10x10000-16 513 6946991 ns/op 359.87 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3099 1175760 ns/op 8871.74 MB/s Benchmark_RFanOut_1kx10x1000-16 3014 1179082 ns/op 8846.74 MB/s Benchmark_RFanOut_1kx10x1000-16 3012 1175336 ns/op 8874.94 MB/s Benchmark_RFanOut_1kx10x1000-16 2881 1179072 ns/op 8846.82 MB/s Benchmark_RFanOut_1kx10x1000-16 3013 1174312 ns/op 8882.68 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6992023 503.7 ns/op 4125.75 MB/s Benchmark_____FanIn_1kx100x1-16 6908572 505.1 ns/op 4113.72 MB/s Benchmark_____FanIn_1kx100x1-16 6906303 504.4 ns/op 4119.90 MB/s Benchmark_____FanIn_1kx100x1-16 6899461 505.7 ns/op 4108.82 MB/s Benchmark_____FanIn_1kx100x1-16 6990870 507.0 ns/op 4098.58 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2634895 1369 ns/op 6006.87 MB/s Benchmark_____FanIn_4kx100x1-16 2639499 1357 ns/op 6059.00 MB/s Benchmark_____FanIn_4kx100x1-16 2606068 1359 ns/op 6051.67 MB/s Benchmark_____FanIn_4kx100x1-16 2646379 1372 ns/op 5990.92 MB/s Benchmark_____FanIn_4kx100x1-16 2617960 1362 ns/op 6036.97 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1698478 2123 ns/op 7731.07 MB/s Benchmark_____FanIn_8kx100x1-16 1677218 2121 ns/op 7738.52 MB/s Benchmark_____FanIn_8kx100x1-16 1720480 2150 ns/op 7635.06 MB/s Benchmark_____FanIn_8kx100x1-16 1678898 2122 ns/op 7733.36 MB/s Benchmark_____FanIn_8kx100x1-16 1700352 2121 ns/op 7737.32 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 868896 4176 ns/op 7854.22 MB/s Benchmark____FanIn_16kx100x1-16 863372 4127 ns/op 7947.48 MB/s Benchmark____FanIn_16kx100x1-16 863990 4171 ns/op 7864.33 MB/s Benchmark____FanIn_16kx100x1-16 869022 4186 ns/op 7836.57 MB/s Benchmark____FanIn_16kx100x1-16 870768 4158 ns/op 7887.71 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 164941 19974 ns/op 6563.86 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 5527822278 vs 11327558400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46050->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 165372 19905 ns/op 6586.61 MB/s Benchmark____FanIn_64kx100x1-16 171378 19904 ns/op 6586.95 MB/s Benchmark____FanIn_64kx100x1-16 170620 19883 ns/op 6593.87 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 136857960 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50914->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: 187589790 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:53078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:52266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52996->127.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:52390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:52656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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: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:53000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:52778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52236->127.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:52878->127.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:52888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:52424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52300->127.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:52906->127.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:52402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52334->127.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:52270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:53100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52836->127.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:52596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52912->127.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:52296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52746->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 316320170 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54262->127.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:54606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:53970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54390->127.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:54700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54762->127.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: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:54126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54650->127.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:54488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54098->127.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:54014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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: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:54698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54058->127.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: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:54150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:54838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54112->127.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:54404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54312->127.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: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:54810->127.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:54498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54206->127.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:53978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54380->127.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:54644->127.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:54524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54344->127.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: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:54186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54782->127.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:54676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:54304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54134->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: 237010720 vs 11483484000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56816->127.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:56716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57384->127.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:57134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56998->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:56694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56982->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: 308585860 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59342->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58538->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58950->127.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:59398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58746->127.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:58850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58544->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:58938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59220->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5501499 645.8 ns/op 439.79 MB/s Benchmark___BumpPubCount_1x3-16 5507690 642.0 ns/op 442.39 MB/s Benchmark___BumpPubCount_1x3-16 5603004 640.1 ns/op 443.70 MB/s Benchmark___BumpPubCount_1x3-16 5524758 646.6 ns/op 439.23 MB/s Benchmark___BumpPubCount_1x3-16 5634538 641.8 ns/op 442.51 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5311195 675.8 ns/op 420.25 MB/s Benchmark___BumpPubCount_2x3-16 5310400 673.3 ns/op 421.79 MB/s Benchmark___BumpPubCount_2x3-16 5168199 675.1 ns/op 420.66 MB/s Benchmark___BumpPubCount_2x3-16 5259364 674.5 ns/op 421.05 MB/s Benchmark___BumpPubCount_2x3-16 5313910 679.3 ns/op 418.11 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5553018 644.8 ns/op 440.44 MB/s Benchmark___BumpPubCount_5x3-16 5554610 646.9 ns/op 439.05 MB/s Benchmark___BumpPubCount_5x3-16 5234392 643.8 ns/op 441.10 MB/s Benchmark___BumpPubCount_5x3-16 5501787 647.4 ns/op 438.66 MB/s Benchmark___BumpPubCount_5x3-16 5258964 643.6 ns/op 441.26 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5539345 648.6 ns/op 437.89 MB/s Benchmark__BumpPubCount_10x3-16 5566346 646.5 ns/op 439.26 MB/s Benchmark__BumpPubCount_10x3-16 5571314 652.5 ns/op 435.23 MB/s Benchmark__BumpPubCount_10x3-16 5542362 645.5 ns/op 439.97 MB/s Benchmark__BumpPubCount_10x3-16 5536651 643.6 ns/op 441.29 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12380720 270.8 ns/op 3840.49 MB/s Benchmark____GWs_Opt_1kx01x0-16 12496114 277.1 ns/op 3753.50 MB/s Benchmark____GWs_Opt_1kx01x0-16 12182634 288.6 ns/op 3603.53 MB/s Benchmark____GWs_Opt_1kx01x0-16 11600734 280.9 ns/op 3702.63 MB/s Benchmark____GWs_Opt_1kx01x0-16 12798457 273.8 ns/op 3798.09 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9849718 335.0 ns/op 6161.72 MB/s Benchmark____GWs_Opt_2kx01x0-16 10699842 340.4 ns/op 6063.28 MB/s Benchmark____GWs_Opt_2kx01x0-16 9858682 348.1 ns/op 5929.33 MB/s Benchmark____GWs_Opt_2kx01x0-16 10652892 352.3 ns/op 5859.03 MB/s Benchmark____GWs_Opt_2kx01x0-16 10182548 358.4 ns/op 5759.22 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5753691 598.1 ns/op 6875.55 MB/s Benchmark____GWs_Opt_4kx01x0-16 5718033 650.4 ns/op 6322.47 MB/s Benchmark____GWs_Opt_4kx01x0-16 5535040 646.8 ns/op 6357.78 MB/s Benchmark____GWs_Opt_4kx01x0-16 5641759 631.8 ns/op 6507.98 MB/s Benchmark____GWs_Opt_4kx01x0-16 5641618 726.6 ns/op 5659.25 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28928874 115.2 ns/op 9031.52 MB/s Benchmark____GWs_Opt_1kx10x0-16 29337883 110.7 ns/op 9392.95 MB/s Benchmark____GWs_Opt_1kx10x0-16 30367358 113.0 ns/op 9202.40 MB/s Benchmark____GWs_Opt_1kx10x0-16 31268370 109.2 ns/op 9528.16 MB/s Benchmark____GWs_Opt_1kx10x0-16 30995662 108.7 ns/op 9571.48 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25039610 141.4 ns/op 14597.97 MB/s Benchmark____GWs_Opt_2kx10x0-16 22297449 154.0 ns/op 13402.55 MB/s Benchmark____GWs_Opt_2kx10x0-16 23534078 139.7 ns/op 14769.27 MB/s Benchmark____GWs_Opt_2kx10x0-16 24191331 147.9 ns/op 13955.57 MB/s Benchmark____GWs_Opt_2kx10x0-16 23878731 147.5 ns/op 13994.84 MB/s Benchmark____GWs_Opt_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:45024->127.0.0.1:45277: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:41618->127.0.0.1:36929: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 13127859 332.9 ns/op 12350.96 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:58304->127.0.0.1:40127: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:36732->127.0.0.1:43177: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 13224472 293.6 ns/op 14007.01 MB/s Benchmark____GWs_Opt_4kx10x0-16 12962641 310.9 ns/op 13224.85 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6597955 556.0 ns/op 5620.93 MB/s Benchmark____GWs_Opt_1kx01x1-16 6356049 551.7 ns/op 5664.55 MB/s Benchmark____GWs_Opt_1kx01x1-16 6381900 543.0 ns/op 5754.89 MB/s Benchmark____GWs_Opt_1kx01x1-16 6690856 547.1 ns/op 5712.13 MB/s Benchmark____GWs_Opt_1kx01x1-16 6588676 549.7 ns/op 5684.50 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4676377 768.0 ns/op 8068.60 MB/s Benchmark____GWs_Opt_2kx01x1-16 4793426 754.7 ns/op 8210.91 MB/s Benchmark____GWs_Opt_2kx01x1-16 4770996 748.4 ns/op 8280.51 MB/s Benchmark____GWs_Opt_2kx01x1-16 4617909 1251 ns/op 4955.37 MB/s Benchmark____GWs_Opt_2kx01x1-16 4692627 767.4 ns/op 8075.54 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2588478 1367 ns/op 9025.12 MB/s Benchmark____GWs_Opt_4kx01x1-16 2544021 1360 ns/op 9072.81 MB/s Benchmark____GWs_Opt_4kx01x1-16 2599622 1371 ns/op 9004.35 MB/s Benchmark____GWs_Opt_4kx01x1-16 2619428 1371 ns/op 9003.53 MB/s Benchmark____GWs_Opt_4kx01x1-16 2600002 1389 ns/op 8887.79 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6483008 556.0 ns/op 5620.82 MB/s Benchmark____GWs_Opt_1kx10x1-16 6239540 580.9 ns/op 5379.54 MB/s Benchmark____GWs_Opt_1kx10x1-16 6226856 558.4 ns/op 5596.58 MB/s Benchmark____GWs_Opt_1kx10x1-16 6011803 557.2 ns/op 5608.72 MB/s Benchmark____GWs_Opt_1kx10x1-16 6295791 557.9 ns/op 5601.24 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 3966348 845.5 ns/op 7329.82 MB/s Benchmark____GWs_Opt_2kx10x1-16 4106282 844.0 ns/op 7342.25 MB/s Benchmark____GWs_Opt_2kx10x1-16 4050284 865.4 ns/op 7160.67 MB/s Benchmark____GWs_Opt_2kx10x1-16 4251475 839.9 ns/op 7378.23 MB/s Benchmark____GWs_Opt_2kx10x1-16 4104363 841.2 ns/op 7367.08 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2262489 1485 ns/op 8307.71 MB/s Benchmark____GWs_Opt_4kx10x1-16 2355630 1542 ns/op 8005.33 MB/s Benchmark____GWs_Opt_4kx10x1-16 2388914 1521 ns/op 8113.53 MB/s Benchmark____GWs_Opt_4kx10x1-16 2334608 1553 ns/op 7948.46 MB/s Benchmark____GWs_Opt_4kx10x1-16 2339272 1410 ns/op 8749.68 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12413750 285.9 ns/op 3637.89 MB/s Benchmark____GWs_Int_1kx01x0-16 11522973 300.0 ns/op 3466.20 MB/s Benchmark____GWs_Int_1kx01x0-16 12289299 282.1 ns/op 3687.07 MB/s Benchmark____GWs_Int_1kx01x0-16 12069993 283.2 ns/op 3672.29 MB/s Benchmark____GWs_Int_1kx01x0-16 12647658 295.5 ns/op 3519.21 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 8397580 372.4 ns/op 5541.96 MB/s Benchmark____GWs_Int_2kx01x0-16 10003806 370.0 ns/op 5577.65 MB/s Benchmark____GWs_Int_2kx01x0-16 9921720 372.0 ns/op 5548.37 MB/s Benchmark____GWs_Int_2kx01x0-16 9581541 368.1 ns/op 5607.58 MB/s Benchmark____GWs_Int_2kx01x0-16 9977622 365.5 ns/op 5647.62 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5735410 647.9 ns/op 6346.78 MB/s Benchmark____GWs_Int_4kx01x0-16 5194960 640.3 ns/op 6422.12 MB/s Benchmark____GWs_Int_4kx01x0-16 5708600 634.4 ns/op 6481.82 MB/s Benchmark____GWs_Int_4kx01x0-16 4914343 639.1 ns/op 6434.42 MB/s Benchmark____GWs_Int_4kx01x0-16 5786056 635.6 ns/op 6469.36 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31945256 116.8 ns/op 8901.35 MB/s Benchmark____GWs_Int_1kx10x0-16 31671482 111.8 ns/op 9299.46 MB/s Benchmark____GWs_Int_1kx10x0-16 31685725 112.1 ns/op 9277.39 MB/s Benchmark____GWs_Int_1kx10x0-16 30065223 109.7 ns/op 9476.12 MB/s Benchmark____GWs_Int_1kx10x0-16 31202790 112.3 ns/op 9258.23 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 23307685 174.6 ns/op 11821.07 MB/s Benchmark____GWs_Int_2kx10x0-16 23334033 159.2 ns/op 12967.38 MB/s Benchmark____GWs_Int_2kx10x0-16 22792765 143.2 ns/op 14413.73 MB/s Benchmark____GWs_Int_2kx10x0-16 25393228 161.1 ns/op 12814.83 MB/s Benchmark____GWs_Int_2kx10x0-16 25855959 142.1 ns/op 14529.04 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11538248 317.0 ns/op 12971.67 MB/s Benchmark____GWs_Int_4kx10x0-16 1000000 26192 ns/op 156.99 MB/s Benchmark____GWs_Int_4kx10x0-16 12980356 315.7 ns/op 13026.29 MB/s Benchmark____GWs_Int_4kx10x0-16 13092428 280.3 ns/op 14669.94 MB/s Benchmark____GWs_Int_4kx10x0-16 13171178 276.0 ns/op 14899.42 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6515956 557.5 ns/op 5605.60 MB/s Benchmark____GWs_Int_1kx01x1-16 6296598 550.6 ns/op 5675.21 MB/s Benchmark____GWs_Int_1kx01x1-16 6617457 557.8 ns/op 5602.52 MB/s Benchmark____GWs_Int_1kx01x1-16 6353755 552.1 ns/op 5659.78 MB/s Benchmark____GWs_Int_1kx01x1-16 6613069 553.9 ns/op 5641.38 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4746260 773.5 ns/op 8011.87 MB/s Benchmark____GWs_Int_2kx01x1-16 4639203 765.4 ns/op 8096.48 MB/s Benchmark____GWs_Int_2kx01x1-16 4619085 767.5 ns/op 8074.06 MB/s Benchmark____GWs_Int_2kx01x1-16 4144456 755.3 ns/op 8205.18 MB/s Benchmark____GWs_Int_2kx01x1-16 4627873 808.9 ns/op 7660.89 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2618041 1358 ns/op 9085.88 MB/s Benchmark____GWs_Int_4kx01x1-16 2527172 1724 ns/op 7159.62 MB/s Benchmark____GWs_Int_4kx01x1-16 2666476 1380 ns/op 8939.86 MB/s Benchmark____GWs_Int_4kx01x1-16 2578404 1517 ns/op 8136.71 MB/s Benchmark____GWs_Int_4kx01x1-16 2671947 1372 ns/op 8992.65 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6205005 561.8 ns/op 5562.80 MB/s Benchmark____GWs_Int_1kx10x1-16 6157065 565.6 ns/op 5525.56 MB/s Benchmark____GWs_Int_1kx10x1-16 6339769 562.8 ns/op 5552.81 MB/s Benchmark____GWs_Int_1kx10x1-16 6096522 568.8 ns/op 5493.71 MB/s Benchmark____GWs_Int_1kx10x1-16 6286851 555.6 ns/op 5624.15 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4166148 870.5 ns/op 7118.88 MB/s Benchmark____GWs_Int_2kx10x1-16 4354581 846.2 ns/op 7323.16 MB/s Benchmark____GWs_Int_2kx10x1-16 4085925 849.2 ns/op 7297.84 MB/s Benchmark____GWs_Int_2kx10x1-16 3982348 842.1 ns/op 7359.22 MB/s Benchmark____GWs_Int_2kx10x1-16 4196569 846.9 ns/op 7317.19 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2306796 1548 ns/op 7970.89 MB/s Benchmark____GWs_Int_4kx10x1-16 2306672 1476 ns/op 8359.87 MB/s Benchmark____GWs_Int_4kx10x1-16 2445487 1539 ns/op 8016.81 MB/s Benchmark____GWs_Int_4kx10x1-16 2376898 1519 ns/op 8122.45 MB/s Benchmark____GWs_Int_4kx10x1-16 2395747 1544 ns/op 7994.17 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8314317 438.7 ns/op 232.51 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8413956 442.6 ns/op 230.48 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8110660 435.5 ns/op 234.23 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8360094 438.6 ns/op 232.58 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8158227 435.2 ns/op 234.37 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 609932 5038 ns/op 35.13 MB/s Benchmark__GWs_Reqs_1SubEach-16 802396 5222 ns/op 33.90 MB/s Benchmark__GWs_Reqs_1SubEach-16 764556 5221 ns/op 33.90 MB/s Benchmark__GWs_Reqs_1SubEach-16 781995 5295 ns/op 33.43 MB/s Benchmark__GWs_Reqs_1SubEach-16 724812 5229 ns/op 33.85 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2141.790s