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 49715870 71.83 ns/op 153.14 MB/s Benchmark______Pub0b_Payload-16 47348670 71.83 ns/op 153.15 MB/s Benchmark______Pub0b_Payload-16 47805230 72.07 ns/op 152.64 MB/s Benchmark______Pub0b_Payload-16 47531245 72.61 ns/op 151.49 MB/s Benchmark______Pub0b_Payload-16 49969472 71.87 ns/op 153.06 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 43286968 72.87 ns/op 260.72 MB/s Benchmark______Pub8b_Payload-16 46616581 73.02 ns/op 260.21 MB/s Benchmark______Pub8b_Payload-16 46723674 72.64 ns/op 261.58 MB/s Benchmark______Pub8b_Payload-16 46860952 72.48 ns/op 262.14 MB/s Benchmark______Pub8b_Payload-16 46970437 78.62 ns/op 241.66 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43713283 76.32 ns/op 576.48 MB/s Benchmark_____Pub32b_Payload-16 46820904 76.30 ns/op 576.66 MB/s Benchmark_____Pub32b_Payload-16 38983588 77.11 ns/op 570.65 MB/s Benchmark_____Pub32b_Payload-16 44768440 76.60 ns/op 574.44 MB/s Benchmark_____Pub32b_Payload-16 43008091 76.57 ns/op 574.66 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 40098684 92.01 ns/op 1532.47 MB/s Benchmark____Pub128B_Payload-16 41480074 87.12 ns/op 1618.43 MB/s Benchmark____Pub128B_Payload-16 39636102 87.99 ns/op 1602.50 MB/s Benchmark____Pub128B_Payload-16 35018451 86.15 ns/op 1636.59 MB/s Benchmark____Pub128B_Payload-16 39156051 93.22 ns/op 1512.48 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35693768 94.85 ns/op 2836.16 MB/s Benchmark____Pub256B_Payload-16 32340232 94.22 ns/op 2855.04 MB/s Benchmark____Pub256B_Payload-16 35697558 93.86 ns/op 2865.88 MB/s Benchmark____Pub256B_Payload-16 35952492 96.34 ns/op 2792.19 MB/s Benchmark____Pub256B_Payload-16 36081050 94.91 ns/op 2834.17 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23849006 139.9 ns/op 7421.43 MB/s Benchmark______Pub1K_Payload-16 24381348 139.4 ns/op 7447.22 MB/s Benchmark______Pub1K_Payload-16 21919003 140.7 ns/op 7379.96 MB/s Benchmark______Pub1K_Payload-16 24637570 144.5 ns/op 7181.09 MB/s Benchmark______Pub1K_Payload-16 24041698 140.3 ns/op 7398.87 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5286163 628.1 ns/op 6543.17 MB/s Benchmark______Pub4K_Payload-16 5614671 613.1 ns/op 6704.10 MB/s Benchmark______Pub4K_Payload-16 5272173 624.2 ns/op 6584.87 MB/s Benchmark______Pub4K_Payload-16 5752792 621.5 ns/op 6612.84 MB/s Benchmark______Pub4K_Payload-16 5408330 628.1 ns/op 6543.81 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2685700 1275 ns/op 6433.57 MB/s Benchmark______Pub8K_Payload-16 2762356 1274 ns/op 6441.54 MB/s Benchmark______Pub8K_Payload-16 2830675 1284 ns/op 6390.35 MB/s Benchmark______Pub8K_Payload-16 2669836 1279 ns/op 6415.19 MB/s Benchmark______Pub8K_Payload-16 2668576 1282 ns/op 6399.97 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 647070 5349 ns/op 6128.72 MB/s Benchmark_____Pub32K_Payload-16 651164 5354 ns/op 6123.10 MB/s Benchmark_____Pub32K_Payload-16 669421 5491 ns/op 5970.38 MB/s Benchmark_____Pub32K_Payload-16 656656 5427 ns/op 6041.23 MB/s Benchmark_____Pub32K_Payload-16 653587 5414 ns/op 6054.69 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32506672 92.83 ns/op 118.50 MB/s Benchmark__AuthPub0b_Payload-16 36145285 93.18 ns/op 118.05 MB/s Benchmark__AuthPub0b_Payload-16 36455667 93.02 ns/op 118.25 MB/s Benchmark__AuthPub0b_Payload-16 36595573 92.74 ns/op 118.61 MB/s Benchmark__AuthPub0b_Payload-16 36991174 93.99 ns/op 117.04 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15638361 228.1 ns/op Benchmark_____________PubSub-16 15175714 228.4 ns/op Benchmark_____________PubSub-16 15411051 230.9 ns/op Benchmark_____________PubSub-16 15184065 227.6 ns/op Benchmark_____________PubSub-16 15660327 228.2 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15807616 226.6 ns/op Benchmark_____PubSubTwoConns-16 15517002 227.0 ns/op Benchmark_____PubSubTwoConns-16 15426835 227.1 ns/op Benchmark_____PubSubTwoConns-16 15468135 226.4 ns/op Benchmark_____PubSubTwoConns-16 15318374 227.2 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43126->127.0.0.1:46829: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57306->127.0.0.1:36457: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58988->127.0.0.1:35931: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57498->127.0.0.1:32987: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46372->127.0.0.1:39465: 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 14353065 248.0 ns/op Benchmark_____PubTwoQueueSub-16 14415069 247.4 ns/op Benchmark_____PubTwoQueueSub-16 14178244 247.8 ns/op Benchmark_____PubTwoQueueSub-16 14384491 247.9 ns/op Benchmark_____PubTwoQueueSub-16 14419011 248.8 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14350444 247.4 ns/op Benchmark____PubFourQueueSub-16 14295489 247.9 ns/op Benchmark____PubFourQueueSub-16 14184938 250.2 ns/op Benchmark____PubFourQueueSub-16 14224657 250.5 ns/op Benchmark____PubFourQueueSub-16 14255424 248.1 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14262355 247.9 ns/op Benchmark___PubEightQueueSub-16 14216839 248.7 ns/op Benchmark___PubEightQueueSub-16 14369631 248.5 ns/op Benchmark___PubEightQueueSub-16 14132575 248.7 ns/op Benchmark___PubEightQueueSub-16 14282541 248.2 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23154 155641 ns/op Benchmark_PubSub512kTwoConns-16 23101 156258 ns/op Benchmark_PubSub512kTwoConns-16 22934 151651 ns/op Benchmark_PubSub512kTwoConns-16 23214 156844 ns/op Benchmark_PubSub512kTwoConns-16 23220 156592 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15077344 230.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15041575 231.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15132208 230.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15384782 230.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15241968 230.4 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14978719 229.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15116182 233.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 14953498 230.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15234848 231.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15221211 231.1 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11339221 314.3 ns/op Benchmark____RoutedPubSub_0b-16 10985422 314.2 ns/op Benchmark____RoutedPubSub_0b-16 10959992 315.4 ns/op Benchmark____RoutedPubSub_0b-16 11147623 313.2 ns/op Benchmark____RoutedPubSub_0b-16 11148156 312.3 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6968076 547.3 ns/op Benchmark____RoutedPubSub_1K-16 6624400 575.1 ns/op Benchmark____RoutedPubSub_1K-16 6607874 544.1 ns/op Benchmark____RoutedPubSub_1K-16 6607497 639.1 ns/op Benchmark____RoutedPubSub_1K-16 6696002 541.1 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 83403 45187 ns/op Benchmark__RoutedPubSub_100K-16 75644 46725 ns/op Benchmark__RoutedPubSub_100K-16 75475 45656 ns/op Benchmark__RoutedPubSub_100K-16 74516 47663 ns/op Benchmark__RoutedPubSub_100K-16 78062 45752 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9515814 326.0 ns/op Benchmark____Routed2QueueSub-16 9671342 329.9 ns/op Benchmark____Routed2QueueSub-16 9659938 328.7 ns/op Benchmark____Routed2QueueSub-16 9399837 322.9 ns/op Benchmark____Routed2QueueSub-16 9556447 324.8 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 10995067 327.9 ns/op Benchmark____Routed4QueueSub-16 9413370 328.9 ns/op Benchmark____Routed4QueueSub-16 9209210 331.2 ns/op Benchmark____Routed4QueueSub-16 9340251 330.8 ns/op Benchmark____Routed4QueueSub-16 9465984 330.4 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9138374 335.8 ns/op Benchmark____Routed8QueueSub-16 10627605 327.7 ns/op Benchmark____Routed8QueueSub-16 9167922 333.4 ns/op Benchmark____Routed8QueueSub-16 9289018 337.2 ns/op Benchmark____Routed8QueueSub-16 9191574 338.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8569342 352.3 ns/op Benchmark___Routed16QueueSub-16 8574997 359.8 ns/op Benchmark___Routed16QueueSub-16 8590759 365.0 ns/op Benchmark___Routed16QueueSub-16 8525662 353.8 ns/op Benchmark___Routed16QueueSub-16 8652636 360.8 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6485412 556.0 ns/op Benchmark____________RouteCompressOff-16 6412228 556.8 ns/op Benchmark____________RouteCompressOff-16 6379704 550.9 ns/op Benchmark____________RouteCompressOff-16 6442424 548.5 ns/op Benchmark____________RouteCompressOff-16 6264470 548.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6351774 554.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6478929 547.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6229837 550.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6269775 560.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6412633 551.6 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6411747 552.6 ns/op Benchmark_________RouteCompressS2Fast-16 6470260 548.8 ns/op Benchmark_________RouteCompressS2Fast-16 6418116 543.4 ns/op Benchmark_________RouteCompressS2Fast-16 6395834 494.2 ns/op Benchmark_________RouteCompressS2Fast-16 6469624 555.2 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6387976 542.9 ns/op Benchmark_______RouteCompressS2Better-16 6160359 558.2 ns/op Benchmark_______RouteCompressS2Better-16 6500851 552.9 ns/op Benchmark_______RouteCompressS2Better-16 6477430 555.5 ns/op Benchmark_______RouteCompressS2Better-16 6603894 555.6 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6256669 556.8 ns/op Benchmark_________RouteCompressS2Best-16 6375480 556.1 ns/op Benchmark_________RouteCompressS2Best-16 6339536 553.5 ns/op Benchmark_________RouteCompressS2Best-16 6188378 553.8 ns/op Benchmark_________RouteCompressS2Best-16 6397268 552.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4469132 774.4 ns/op 321.55 MB/s Benchmark______FanOut_8x1x10-16 4634522 775.9 ns/op 320.91 MB/s Benchmark______FanOut_8x1x10-16 4631568 774.0 ns/op 321.73 MB/s Benchmark______FanOut_8x1x10-16 4640809 776.9 ns/op 320.49 MB/s Benchmark______FanOut_8x1x10-16 4622548 773.2 ns/op 322.04 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 542110 6234 ns/op 372.01 MB/s Benchmark_____FanOut_8x1x100-16 534325 6240 ns/op 371.61 MB/s Benchmark_____FanOut_8x1x100-16 555512 6190 ns/op 374.67 MB/s Benchmark_____FanOut_8x1x100-16 535068 6296 ns/op 368.32 MB/s Benchmark_____FanOut_8x1x100-16 550015 6255 ns/op 370.72 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 46820 78640 ns/op 292.71 MB/s Benchmark____FanOut_8x10x100-16 46485 77368 ns/op 297.53 MB/s Benchmark____FanOut_8x10x100-16 46485 78925 ns/op 291.66 MB/s Benchmark____FanOut_8x10x100-16 46132 77563 ns/op 296.78 MB/s Benchmark____FanOut_8x10x100-16 46759 77721 ns/op 296.18 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5616 624999 ns/op 384.03 MB/s Benchmark___FanOut_8x10x1000-16 5433 627542 ns/op 382.47 MB/s Benchmark___FanOut_8x10x1000-16 5546 630537 ns/op 380.66 MB/s Benchmark___FanOut_8x10x1000-16 5625 639488 ns/op 375.33 MB/s Benchmark___FanOut_8x10x1000-16 5378 625391 ns/op 383.79 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4825 742865 ns/op 309.64 MB/s Benchmark___FanOut_8x100x100-16 4818 733443 ns/op 313.62 MB/s Benchmark___FanOut_8x100x100-16 4839 736114 ns/op 312.48 MB/s Benchmark___FanOut_8x100x100-16 4857 730699 ns/op 314.79 MB/s Benchmark___FanOut_8x100x100-16 4791 729866 ns/op 315.15 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 546 6513142 ns/op 368.49 MB/s Benchmark__FanOut_8x100x1000-16 542 6476238 ns/op 370.59 MB/s Benchmark__FanOut_8x100x1000-16 546 6545646 ns/op 366.66 MB/s Benchmark__FanOut_8x100x1000-16 536 6429513 ns/op 373.28 MB/s Benchmark__FanOut_8x100x1000-16 548 6495410 ns/op 369.49 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 506 6934025 ns/op 360.54 MB/s Benchmark__FanOut_8x10x10000-16 519 7236424 ns/op 345.48 MB/s Benchmark__FanOut_8x10x10000-16 516 7000114 ns/op 357.14 MB/s Benchmark__FanOut_8x10x10000-16 507 6924567 ns/op 361.04 MB/s Benchmark__FanOut_8x10x10000-16 506 7296214 ns/op 342.65 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 919 3887559 ns/op 295.82 MB/s Benchmark___FanOut_8x500x100-16 925 3867403 ns/op 297.36 MB/s Benchmark___FanOut_8x500x100-16 912 3880922 ns/op 296.33 MB/s Benchmark___FanOut_8x500x100-16 918 3855804 ns/op 298.26 MB/s Benchmark___FanOut_8x500x100-16 924 3860742 ns/op 297.88 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 355318 9667 ns/op 1514.56 MB/s Benchmark___FanOut_128x1x100-16 354680 9663 ns/op 1515.18 MB/s Benchmark___FanOut_128x1x100-16 346006 9713 ns/op 1507.29 MB/s Benchmark___FanOut_128x1x100-16 355185 9709 ns/op 1508.02 MB/s Benchmark___FanOut_128x1x100-16 355088 9692 ns/op 1510.55 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 31441 113048 ns/op 1283.89 MB/s Benchmark__FanOut_128x10x100-16 31630 113253 ns/op 1281.57 MB/s Benchmark__FanOut_128x10x100-16 31868 113358 ns/op 1280.38 MB/s Benchmark__FanOut_128x10x100-16 31749 113147 ns/op 1282.77 MB/s Benchmark__FanOut_128x10x100-16 31672 113108 ns/op 1283.21 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3948 913398 ns/op 1598.58 MB/s Benchmark_FanOut_128x10x1000-16 3828 912850 ns/op 1599.54 MB/s Benchmark_FanOut_128x10x1000-16 3976 903435 ns/op 1616.21 MB/s Benchmark_FanOut_128x10x1000-16 4036 909215 ns/op 1605.94 MB/s Benchmark_FanOut_128x10x1000-16 3886 915370 ns/op 1595.14 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3506 1035815 ns/op 1400.00 MB/s Benchmark_FanOut_128x100x100-16 3361 1041152 ns/op 1392.82 MB/s Benchmark_FanOut_128x100x100-16 3349 1035690 ns/op 1400.17 MB/s Benchmark_FanOut_128x100x100-16 3366 1038847 ns/op 1395.91 MB/s Benchmark_FanOut_128x100x100-16 3415 1033502 ns/op 1403.13 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 376 9752259 ns/op 1497.10 MB/s BenchmarkFanOut_128x100x1000-16 367 9594885 ns/op 1521.66 MB/s BenchmarkFanOut_128x100x1000-16 363 9701668 ns/op 1504.91 MB/s BenchmarkFanOut_128x100x1000-16 369 9732118 ns/op 1500.20 MB/s BenchmarkFanOut_128x100x1000-16 372 9706899 ns/op 1504.10 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 363 9911957 ns/op 1483.07 MB/s BenchmarkFanOut_128x10x10000-16 364 9986755 ns/op 1471.96 MB/s BenchmarkFanOut_128x10x10000-16 362 9973441 ns/op 1473.93 MB/s BenchmarkFanOut_128x10x10000-16 362 10042620 ns/op 1463.78 MB/s BenchmarkFanOut_128x10x10000-16 360 9924062 ns/op 1481.26 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 654 5408129 ns/op 1340.60 MB/s BenchmarkFanOut__128x500x100-16 657 5484515 ns/op 1321.93 MB/s BenchmarkFanOut__128x500x100-16 662 5412715 ns/op 1339.46 MB/s BenchmarkFanOut__128x500x100-16 652 5420302 ns/op 1337.59 MB/s BenchmarkFanOut__128x500x100-16 666 5439003 ns/op 1332.99 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1864 1873051 ns/op 2824.55 MB/s Benchmark_FanOut_512x100x100-16 1912 1852273 ns/op 2856.23 MB/s Benchmark_FanOut_512x100x100-16 1926 1883689 ns/op 2808.60 MB/s Benchmark_FanOut_512x100x100-16 1910 1879502 ns/op 2814.85 MB/s Benchmark_FanOut_512x100x100-16 1905 1878774 ns/op 2815.95 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 210 16956847 ns/op 3125.61 MB/s Benchmark__FanOut_512x100x1k-16 212 16947838 ns/op 3127.27 MB/s Benchmark__FanOut_512x100x1k-16 213 16901910 ns/op 3135.77 MB/s Benchmark__FanOut_512x100x1k-16 212 17101569 ns/op 3099.16 MB/s Benchmark__FanOut_512x100x1k-16 212 16928438 ns/op 3130.86 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3070 1162371 ns/op 8973.93 MB/s Benchmark____FanOut_1kx10x1k-16 2896 1167685 ns/op 8933.09 MB/s Benchmark____FanOut_1kx10x1k-16 3140 1180001 ns/op 8839.85 MB/s Benchmark____FanOut_1kx10x1k-16 3114 1179776 ns/op 8841.54 MB/s Benchmark____FanOut_1kx10x1k-16 3022 1147657 ns/op 9088.99 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2770 1285354 ns/op 8107.52 MB/s Benchmark__FanOut_1kx100x100-16 2734 1279495 ns/op 8144.65 MB/s Benchmark__FanOut_1kx100x100-16 2763 1281015 ns/op 8134.99 MB/s Benchmark__FanOut_1kx100x100-16 2751 1272762 ns/op 8187.74 MB/s Benchmark__FanOut_1kx100x100-16 2742 1278524 ns/op 8150.83 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4403888 805.2 ns/op 309.23 MB/s Benchmark_____RFanOut_8x1x10-16 4416956 806.9 ns/op 308.58 MB/s Benchmark_____RFanOut_8x1x10-16 4479606 791.9 ns/op 314.44 MB/s Benchmark_____RFanOut_8x1x10-16 4482478 790.7 ns/op 314.90 MB/s Benchmark_____RFanOut_8x1x10-16 4487384 793.9 ns/op 313.62 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 538215 6295 ns/op 368.38 MB/s Benchmark____RFanOut_8x1x100-16 523128 6352 ns/op 365.06 MB/s Benchmark____RFanOut_8x1x100-16 516331 6333 ns/op 366.20 MB/s Benchmark____RFanOut_8x1x100-16 500977 6383 ns/op 363.30 MB/s Benchmark____RFanOut_8x1x100-16 503748 6397 ns/op 362.49 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 45523 77819 ns/op 295.80 MB/s Benchmark___RFanOut_8x10x100-16 46125 77522 ns/op 296.93 MB/s Benchmark___RFanOut_8x10x100-16 46340 76926 ns/op 299.24 MB/s Benchmark___RFanOut_8x10x100-16 46572 77558 ns/op 296.80 MB/s Benchmark___RFanOut_8x10x100-16 45984 76973 ns/op 299.05 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5401 645329 ns/op 371.93 MB/s Benchmark__RFanOut_8x10x1000-16 5608 621647 ns/op 386.10 MB/s Benchmark__RFanOut_8x10x1000-16 5548 625080 ns/op 383.98 MB/s Benchmark__RFanOut_8x10x1000-16 5542 633501 ns/op 378.88 MB/s Benchmark__RFanOut_8x10x1000-16 5431 638266 ns/op 376.05 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4818 735283 ns/op 312.83 MB/s Benchmark__RFanOut_8x100x100-16 4782 723469 ns/op 317.94 MB/s Benchmark__RFanOut_8x100x100-16 4840 732786 ns/op 313.90 MB/s Benchmark__RFanOut_8x100x100-16 4810 724331 ns/op 317.56 MB/s Benchmark__RFanOut_8x100x100-16 4809 731451 ns/op 314.47 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 552 6607309 ns/op 363.24 MB/s Benchmark_RFanOut_8x100x1000-16 544 6390854 ns/op 375.54 MB/s Benchmark_RFanOut_8x100x1000-16 547 6439630 ns/op 372.70 MB/s Benchmark_RFanOut_8x100x1000-16 548 6453790 ns/op 371.88 MB/s Benchmark_RFanOut_8x100x1000-16 540 6430063 ns/op 373.25 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 507 7158250 ns/op 349.25 MB/s Benchmark_RFanOut_8x10x10000-16 516 6945908 ns/op 359.93 MB/s Benchmark_RFanOut_8x10x10000-16 506 6889663 ns/op 362.87 MB/s Benchmark_RFanOut_8x10x10000-16 516 7086801 ns/op 352.77 MB/s Benchmark_RFanOut_8x10x10000-16 504 6873914 ns/op 363.70 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3055 1168793 ns/op 8924.62 MB/s Benchmark_RFanOut_1kx10x1000-16 2996 1158002 ns/op 9007.79 MB/s Benchmark_RFanOut_1kx10x1000-16 3066 1172622 ns/op 8895.48 MB/s Benchmark_RFanOut_1kx10x1000-16 3123 1163948 ns/op 8961.77 MB/s Benchmark_RFanOut_1kx10x1000-16 3112 1174180 ns/op 8883.68 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6876817 506.5 ns/op 4102.34 MB/s Benchmark_____FanIn_1kx100x1-16 6899988 506.0 ns/op 4107.09 MB/s Benchmark_____FanIn_1kx100x1-16 6893398 507.9 ns/op 4091.62 MB/s Benchmark_____FanIn_1kx100x1-16 6908575 507.7 ns/op 4093.00 MB/s Benchmark_____FanIn_1kx100x1-16 6914188 506.5 ns/op 4102.43 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2621499 1367 ns/op 6014.43 MB/s Benchmark_____FanIn_4kx100x1-16 2626453 1344 ns/op 6116.99 MB/s Benchmark_____FanIn_4kx100x1-16 2651839 1380 ns/op 5960.12 MB/s Benchmark_____FanIn_4kx100x1-16 2636349 1363 ns/op 6033.67 MB/s Benchmark_____FanIn_4kx100x1-16 2587234 1372 ns/op 5993.06 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1713715 2107 ns/op 7790.11 MB/s Benchmark_____FanIn_8kx100x1-16 1719782 2109 ns/op 7781.88 MB/s Benchmark_____FanIn_8kx100x1-16 1701337 2127 ns/op 7715.30 MB/s Benchmark_____FanIn_8kx100x1-16 1689739 2137 ns/op 7679.73 MB/s Benchmark_____FanIn_8kx100x1-16 1685414 2102 ns/op 7807.47 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 863115 4182 ns/op 7843.39 MB/s Benchmark____FanIn_16kx100x1-16 846854 4161 ns/op 7882.79 MB/s Benchmark____FanIn_16kx100x1-16 844896 4112 ns/op 7976.76 MB/s Benchmark____FanIn_16kx100x1-16 856333 4169 ns/op 7868.05 MB/s Benchmark____FanIn_16kx100x1-16 865879 4144 ns/op 7914.74 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 165512 19838 ns/op 6608.74 MB/s Benchmark____FanIn_64kx100x1-16 168322 19802 ns/op 6620.70 MB/s Benchmark____FanIn_64kx100x1-16 166371 20079 ns/op 6529.29 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7028396001 vs 11085012300 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56222->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56304->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 165141 19836 ns/op 6609.45 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 932312080 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60868->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: 107755980 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34508->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: 440200220 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36326->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:36886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36864->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: 1374347560 vs 11496593000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39680->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: 441773300 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40906->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41308->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:40922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40892->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5544766 646.9 ns/op 438.99 MB/s Benchmark___BumpPubCount_1x3-16 5542045 641.2 ns/op 442.94 MB/s Benchmark___BumpPubCount_1x3-16 5473808 641.7 ns/op 442.61 MB/s Benchmark___BumpPubCount_1x3-16 5525643 641.7 ns/op 442.60 MB/s Benchmark___BumpPubCount_1x3-16 5577672 643.8 ns/op 441.16 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5206202 681.6 ns/op 416.69 MB/s Benchmark___BumpPubCount_2x3-16 5245062 677.9 ns/op 418.94 MB/s Benchmark___BumpPubCount_2x3-16 5271864 681.5 ns/op 416.70 MB/s Benchmark___BumpPubCount_2x3-16 5252713 679.9 ns/op 417.74 MB/s Benchmark___BumpPubCount_2x3-16 5276388 682.6 ns/op 416.04 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5514930 652.5 ns/op 435.24 MB/s Benchmark___BumpPubCount_5x3-16 5522758 650.7 ns/op 436.43 MB/s Benchmark___BumpPubCount_5x3-16 5490769 653.0 ns/op 434.95 MB/s Benchmark___BumpPubCount_5x3-16 5521150 651.6 ns/op 435.88 MB/s Benchmark___BumpPubCount_5x3-16 5355346 651.6 ns/op 435.83 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5525952 649.4 ns/op 437.36 MB/s Benchmark__BumpPubCount_10x3-16 5488465 651.6 ns/op 435.87 MB/s Benchmark__BumpPubCount_10x3-16 5505066 654.3 ns/op 434.06 MB/s Benchmark__BumpPubCount_10x3-16 5477193 653.7 ns/op 434.43 MB/s Benchmark__BumpPubCount_10x3-16 4741365 655.6 ns/op 433.19 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12243648 275.3 ns/op 3777.13 MB/s Benchmark____GWs_Opt_1kx01x0-16 12713037 278.5 ns/op 3733.75 MB/s Benchmark____GWs_Opt_1kx01x0-16 12625778 274.2 ns/op 3793.38 MB/s Benchmark____GWs_Opt_1kx01x0-16 12961521 275.7 ns/op 3772.64 MB/s Benchmark____GWs_Opt_1kx01x0-16 11951410 275.5 ns/op 3775.27 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10712163 345.2 ns/op 5979.22 MB/s Benchmark____GWs_Opt_2kx01x0-16 10290220 343.1 ns/op 6016.36 MB/s Benchmark____GWs_Opt_2kx01x0-16 10415242 346.9 ns/op 5949.08 MB/s Benchmark____GWs_Opt_2kx01x0-16 10162190 329.9 ns/op 6256.78 MB/s Benchmark____GWs_Opt_2kx01x0-16 9653696 339.1 ns/op 6086.85 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5734848 605.9 ns/op 6786.44 MB/s Benchmark____GWs_Opt_4kx01x0-16 5829249 618.7 ns/op 6646.51 MB/s Benchmark____GWs_Opt_4kx01x0-16 5657283 637.6 ns/op 6449.20 MB/s Benchmark____GWs_Opt_4kx01x0-16 5820560 608.8 ns/op 6754.56 MB/s Benchmark____GWs_Opt_4kx01x0-16 6062436 623.6 ns/op 6593.53 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29012226 113.3 ns/op 9179.86 MB/s Benchmark____GWs_Opt_1kx10x0-16 31605585 109.7 ns/op 9480.63 MB/s Benchmark____GWs_Opt_1kx10x0-16 31156515 118.0 ns/op 8812.05 MB/s Benchmark____GWs_Opt_1kx10x0-16 29709247 110.5 ns/op 9415.17 MB/s Benchmark____GWs_Opt_1kx10x0-16 28170224 113.6 ns/op 9155.96 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 21739950 141.8 ns/op 14551.53 MB/s Benchmark____GWs_Opt_2kx10x0-16 25103348 152.7 ns/op 13512.91 MB/s Benchmark____GWs_Opt_2kx10x0-16 25810399 145.2 ns/op 14212.13 MB/s Benchmark____GWs_Opt_2kx10x0-16 20316867 151.8 ns/op 13597.06 MB/s Benchmark____GWs_Opt_2kx10x0-16 23602934 146.8 ns/op 14057.77 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 8415603 390.5 ns/op 10529.04 MB/s Benchmark____GWs_Opt_4kx10x0-16 9265519 325.3 ns/op 12640.48 MB/s Benchmark____GWs_Opt_4kx10x0-16 9371383 340.3 ns/op 12084.92 MB/s Benchmark____GWs_Opt_4kx10x0-16 10551775 349.5 ns/op 11766.44 MB/s Benchmark____GWs_Opt_4kx10x0-16 11944945 296.7 ns/op 13858.13 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6510370 550.0 ns/op 5681.83 MB/s Benchmark____GWs_Opt_1kx01x1-16 6578307 552.2 ns/op 5658.87 MB/s Benchmark____GWs_Opt_1kx01x1-16 6602814 552.9 ns/op 5651.97 MB/s Benchmark____GWs_Opt_1kx01x1-16 6317496 558.3 ns/op 5596.87 MB/s Benchmark____GWs_Opt_1kx01x1-16 6535147 554.6 ns/op 5634.90 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4712164 780.6 ns/op 7939.21 MB/s Benchmark____GWs_Opt_2kx01x1-16 4485729 787.5 ns/op 7869.41 MB/s Benchmark____GWs_Opt_2kx01x1-16 4619077 769.7 ns/op 8051.17 MB/s Benchmark____GWs_Opt_2kx01x1-16 4481474 767.7 ns/op 8072.16 MB/s Benchmark____GWs_Opt_2kx01x1-16 4669783 763.9 ns/op 8112.26 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2651602 1370 ns/op 9008.50 MB/s Benchmark____GWs_Opt_4kx01x1-16 2641422 1382 ns/op 8928.56 MB/s Benchmark____GWs_Opt_4kx01x1-16 2601957 1382 ns/op 8927.55 MB/s Benchmark____GWs_Opt_4kx01x1-16 2655970 1453 ns/op 8495.08 MB/s Benchmark____GWs_Opt_4kx01x1-16 2636557 1387 ns/op 8897.07 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 5869578 559.7 ns/op 5583.57 MB/s Benchmark____GWs_Opt_1kx10x1-16 6102255 561.9 ns/op 5561.84 MB/s Benchmark____GWs_Opt_1kx10x1-16 6067071 575.1 ns/op 5433.97 MB/s Benchmark____GWs_Opt_1kx10x1-16 6269419 579.9 ns/op 5388.53 MB/s Benchmark____GWs_Opt_1kx10x1-16 6014046 566.4 ns/op 5517.56 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4170403 852.9 ns/op 7265.65 MB/s Benchmark____GWs_Opt_2kx10x1-16 3910196 860.6 ns/op 7200.47 MB/s Benchmark____GWs_Opt_2kx10x1-16 4057098 851.0 ns/op 7281.60 MB/s Benchmark____GWs_Opt_2kx10x1-16 4083307 839.2 ns/op 7383.98 MB/s Benchmark____GWs_Opt_2kx10x1-16 4066611 853.9 ns/op 7257.49 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2339529 1543 ns/op 8000.49 MB/s Benchmark____GWs_Opt_4kx10x1-16 2308556 1570 ns/op 7861.38 MB/s Benchmark____GWs_Opt_4kx10x1-16 2276498 1543 ns/op 7998.10 MB/s Benchmark____GWs_Opt_4kx10x1-16 2281837 1507 ns/op 8189.50 MB/s Benchmark____GWs_Opt_4kx10x1-16 2398556 1579 ns/op 7814.36 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12249422 288.2 ns/op 3608.81 MB/s Benchmark____GWs_Int_1kx01x0-16 12160387 299.9 ns/op 3468.33 MB/s Benchmark____GWs_Int_1kx01x0-16 12623839 289.1 ns/op 3597.38 MB/s Benchmark____GWs_Int_1kx01x0-16 12796047 291.7 ns/op 3565.29 MB/s Benchmark____GWs_Int_1kx01x0-16 12666757 300.0 ns/op 3466.53 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9495440 346.7 ns/op 5953.42 MB/s Benchmark____GWs_Int_2kx01x0-16 10265245 365.9 ns/op 5641.01 MB/s Benchmark____GWs_Int_2kx01x0-16 10006874 334.0 ns/op 6180.39 MB/s Benchmark____GWs_Int_2kx01x0-16 10226916 347.0 ns/op 5947.64 MB/s Benchmark____GWs_Int_2kx01x0-16 9278083 349.4 ns/op 5907.28 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5683795 630.3 ns/op 6523.89 MB/s Benchmark____GWs_Int_4kx01x0-16 5707317 624.4 ns/op 6585.63 MB/s Benchmark____GWs_Int_4kx01x0-16 5618450 615.3 ns/op 6682.97 MB/s Benchmark____GWs_Int_4kx01x0-16 5649334 642.8 ns/op 6397.20 MB/s Benchmark____GWs_Int_4kx01x0-16 5728282 631.7 ns/op 6509.52 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30587900 108.6 ns/op 9573.46 MB/s Benchmark____GWs_Int_1kx10x0-16 29846516 112.7 ns/op 9231.05 MB/s Benchmark____GWs_Int_1kx10x0-16 30650854 113.5 ns/op 9164.99 MB/s Benchmark____GWs_Int_1kx10x0-16 27632830 113.6 ns/op 9151.83 MB/s Benchmark____GWs_Int_1kx10x0-16 32143220 110.3 ns/op 9432.65 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25023194 151.9 ns/op 13584.60 MB/s Benchmark____GWs_Int_2kx10x0-16 24740379 150.7 ns/op 13694.18 MB/s Benchmark____GWs_Int_2kx10x0-16 26239657 148.9 ns/op 13865.74 MB/s Benchmark____GWs_Int_2kx10x0-16 26248119 159.3 ns/op 12954.64 MB/s Benchmark____GWs_Int_2kx10x0-16 23234472 138.6 ns/op 14889.63 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13118320 286.9 ns/op 14330.97 MB/s Benchmark____GWs_Int_4kx10x0-16 12993975 285.5 ns/op 14403.40 MB/s Benchmark____GWs_Int_4kx10x0-16 13174987 300.7 ns/op 13676.83 MB/s Benchmark____GWs_Int_4kx10x0-16 12100944 309.4 ns/op 13289.14 MB/s Benchmark____GWs_Int_4kx10x0-16 13077993 302.0 ns/op 13614.14 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 5997577 561.2 ns/op 5568.19 MB/s Benchmark____GWs_Int_1kx01x1-16 6349816 560.5 ns/op 5575.36 MB/s Benchmark____GWs_Int_1kx01x1-16 6297961 569.2 ns/op 5489.90 MB/s Benchmark____GWs_Int_1kx01x1-16 6433836 569.1 ns/op 5490.85 MB/s Benchmark____GWs_Int_1kx01x1-16 6433141 555.9 ns/op 5621.32 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4651094 771.7 ns/op 8030.43 MB/s Benchmark____GWs_Int_2kx01x1-16 4688218 770.7 ns/op 8040.53 MB/s Benchmark____GWs_Int_2kx01x1-16 4665795 754.1 ns/op 8217.80 MB/s Benchmark____GWs_Int_2kx01x1-16 4630147 772.0 ns/op 8026.86 MB/s Benchmark____GWs_Int_2kx01x1-16 4533696 783.0 ns/op 7914.68 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2222936 1477 ns/op 8356.88 MB/s Benchmark____GWs_Int_4kx01x1-16 2241531 1363 ns/op 9053.17 MB/s Benchmark____GWs_Int_4kx01x1-16 2558295 1508 ns/op 8184.72 MB/s Benchmark____GWs_Int_4kx01x1-16 2578635 2345 ns/op 5263.30 MB/s Benchmark____GWs_Int_4kx01x1-16 2319180 1383 ns/op 8924.25 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6688993 566.4 ns/op 5516.94 MB/s Benchmark____GWs_Int_1kx10x1-16 6206158 563.3 ns/op 5547.74 MB/s Benchmark____GWs_Int_1kx10x1-16 6233301 564.2 ns/op 5539.26 MB/s Benchmark____GWs_Int_1kx10x1-16 6206140 566.2 ns/op 5518.99 MB/s Benchmark____GWs_Int_1kx10x1-16 6041097 563.0 ns/op 5550.81 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4092314 853.6 ns/op 7259.87 MB/s Benchmark____GWs_Int_2kx10x1-16 4089393 854.3 ns/op 7254.26 MB/s Benchmark____GWs_Int_2kx10x1-16 3953692 845.5 ns/op 7329.67 MB/s Benchmark____GWs_Int_2kx10x1-16 4156186 849.7 ns/op 7292.79 MB/s Benchmark____GWs_Int_2kx10x1-16 4054933 857.2 ns/op 7229.22 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2426868 1515 ns/op 8146.80 MB/s Benchmark____GWs_Int_4kx10x1-16 2357001 1517 ns/op 8137.48 MB/s Benchmark____GWs_Int_4kx10x1-16 2334586 1552 ns/op 7951.35 MB/s Benchmark____GWs_Int_4kx10x1-16 2247859 1543 ns/op 8000.46 MB/s Benchmark____GWs_Int_4kx10x1-16 2256643 1539 ns/op 8020.23 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8153631 439.0 ns/op 232.36 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8155053 436.1 ns/op 233.89 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7938183 439.3 ns/op 232.20 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8275977 438.7 ns/op 232.52 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8265795 446.5 ns/op 228.46 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 610063 5052 ns/op 35.03 MB/s Benchmark__GWs_Reqs_1SubEach-16 763099 5262 ns/op 33.64 MB/s Benchmark__GWs_Reqs_1SubEach-16 742803 5279 ns/op 33.53 MB/s Benchmark__GWs_Reqs_1SubEach-16 715350 5278 ns/op 33.53 MB/s Benchmark__GWs_Reqs_1SubEach-16 740293 5286 ns/op 33.49 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2070.935s