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 49357861 72.70 ns/op 151.31 MB/s Benchmark______Pub0b_Payload-16 46883012 72.70 ns/op 151.30 MB/s Benchmark______Pub0b_Payload-16 49452031 74.39 ns/op 147.88 MB/s Benchmark______Pub0b_Payload-16 46645294 72.90 ns/op 150.88 MB/s Benchmark______Pub0b_Payload-16 46088828 72.58 ns/op 151.55 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46374789 74.43 ns/op 255.26 MB/s Benchmark______Pub8b_Payload-16 46133701 73.42 ns/op 258.79 MB/s Benchmark______Pub8b_Payload-16 46484754 73.29 ns/op 259.24 MB/s Benchmark______Pub8b_Payload-16 46333954 73.37 ns/op 258.96 MB/s Benchmark______Pub8b_Payload-16 45348163 73.32 ns/op 259.14 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 46043626 78.04 ns/op 563.82 MB/s Benchmark_____Pub32b_Payload-16 43638488 78.09 ns/op 563.46 MB/s Benchmark_____Pub32b_Payload-16 41325793 77.80 ns/op 565.58 MB/s Benchmark_____Pub32b_Payload-16 43522826 77.74 ns/op 565.98 MB/s Benchmark_____Pub32b_Payload-16 43524607 78.02 ns/op 563.98 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 34334683 88.64 ns/op 1590.67 MB/s Benchmark____Pub128B_Payload-16 35253970 88.19 ns/op 1598.74 MB/s Benchmark____Pub128B_Payload-16 37954743 87.34 ns/op 1614.31 MB/s Benchmark____Pub128B_Payload-16 39052208 88.55 ns/op 1592.38 MB/s Benchmark____Pub128B_Payload-16 34232562 88.96 ns/op 1584.98 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 32093016 95.87 ns/op 2805.93 MB/s Benchmark____Pub256B_Payload-16 31817370 95.44 ns/op 2818.46 MB/s Benchmark____Pub256B_Payload-16 37307210 101.9 ns/op 2640.57 MB/s Benchmark____Pub256B_Payload-16 34994074 95.58 ns/op 2814.31 MB/s Benchmark____Pub256B_Payload-16 37453904 96.47 ns/op 2788.50 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23073008 142.8 ns/op 7271.02 MB/s Benchmark______Pub1K_Payload-16 24439555 159.8 ns/op 6494.17 MB/s Benchmark______Pub1K_Payload-16 23863532 146.7 ns/op 7076.24 MB/s Benchmark______Pub1K_Payload-16 23136522 147.4 ns/op 7042.40 MB/s Benchmark______Pub1K_Payload-16 26402214 138.8 ns/op 7478.75 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5677390 621.1 ns/op 6617.41 MB/s Benchmark______Pub4K_Payload-16 5361579 615.3 ns/op 6679.98 MB/s Benchmark______Pub4K_Payload-16 5555270 628.6 ns/op 6538.28 MB/s Benchmark______Pub4K_Payload-16 5587353 617.4 ns/op 6657.42 MB/s Benchmark______Pub4K_Payload-16 5367636 620.0 ns/op 6628.62 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2784488 1278 ns/op 6421.58 MB/s Benchmark______Pub8K_Payload-16 2725430 1289 ns/op 6365.00 MB/s Benchmark______Pub8K_Payload-16 2770700 1282 ns/op 6399.88 MB/s Benchmark______Pub8K_Payload-16 2735666 1293 ns/op 6344.76 MB/s Benchmark______Pub8K_Payload-16 2715004 1278 ns/op 6419.72 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 652609 5374 ns/op 6100.50 MB/s Benchmark_____Pub32K_Payload-16 649986 5537 ns/op 5920.46 MB/s Benchmark_____Pub32K_Payload-16 419770 16247 ns/op 2017.85 MB/s Benchmark_____Pub32K_Payload-16 655238 5475 ns/op 5987.29 MB/s Benchmark_____Pub32K_Payload-16 653456 5434 ns/op 6033.07 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32048113 94.42 ns/op 116.51 MB/s Benchmark__AuthPub0b_Payload-16 32315335 94.64 ns/op 116.22 MB/s Benchmark__AuthPub0b_Payload-16 36148165 94.81 ns/op 116.02 MB/s Benchmark__AuthPub0b_Payload-16 36126729 94.38 ns/op 116.55 MB/s Benchmark__AuthPub0b_Payload-16 35942584 94.78 ns/op 116.06 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15414784 229.6 ns/op Benchmark_____________PubSub-16 15232886 229.8 ns/op Benchmark_____________PubSub-16 15363246 229.6 ns/op Benchmark_____________PubSub-16 15422812 229.8 ns/op Benchmark_____________PubSub-16 15445166 230.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15594914 228.0 ns/op Benchmark_____PubSubTwoConns-16 15446593 227.6 ns/op Benchmark_____PubSubTwoConns-16 15507092 227.9 ns/op Benchmark_____PubSubTwoConns-16 15607239 228.2 ns/op Benchmark_____PubSubTwoConns-16 15473406 227.9 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:35446->127.0.0.1:42135: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51342->127.0.0.1:45411: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:54398->127.0.0.1:33425: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:37932->127.0.0.1:46523: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40756->127.0.0.1:36979: 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 14077129 249.9 ns/op Benchmark_____PubTwoQueueSub-16 14183737 250.1 ns/op Benchmark_____PubTwoQueueSub-16 14009892 250.0 ns/op Benchmark_____PubTwoQueueSub-16 14135414 250.5 ns/op Benchmark_____PubTwoQueueSub-16 14179622 250.8 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14037853 250.9 ns/op Benchmark____PubFourQueueSub-16 14024838 251.3 ns/op Benchmark____PubFourQueueSub-16 14032011 250.5 ns/op Benchmark____PubFourQueueSub-16 14227405 250.3 ns/op Benchmark____PubFourQueueSub-16 14321169 251.7 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14136978 251.1 ns/op Benchmark___PubEightQueueSub-16 14299300 250.7 ns/op Benchmark___PubEightQueueSub-16 14248966 250.4 ns/op Benchmark___PubEightQueueSub-16 14239376 250.7 ns/op Benchmark___PubEightQueueSub-16 14291557 250.9 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23269 154932 ns/op Benchmark_PubSub512kTwoConns-16 23070 156070 ns/op Benchmark_PubSub512kTwoConns-16 22983 155283 ns/op Benchmark_PubSub512kTwoConns-16 23410 155650 ns/op Benchmark_PubSub512kTwoConns-16 23391 155456 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14998021 230.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15083572 232.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 14845434 233.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15027855 231.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 14998486 231.6 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15009316 231.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15022088 232.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 14911747 232.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 14971140 232.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15042721 233.0 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11789695 312.2 ns/op Benchmark____RoutedPubSub_0b-16 11230791 313.5 ns/op Benchmark____RoutedPubSub_0b-16 11424355 314.9 ns/op Benchmark____RoutedPubSub_0b-16 11220319 313.0 ns/op Benchmark____RoutedPubSub_0b-16 11490295 317.6 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6537852 539.0 ns/op Benchmark____RoutedPubSub_1K-16 6721006 535.0 ns/op Benchmark____RoutedPubSub_1K-16 6679045 539.2 ns/op Benchmark____RoutedPubSub_1K-16 6639823 532.7 ns/op Benchmark____RoutedPubSub_1K-16 6616767 538.6 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84294 42178 ns/op Benchmark__RoutedPubSub_100K-16 80526 41290 ns/op Benchmark__RoutedPubSub_100K-16 84518 42636 ns/op Benchmark__RoutedPubSub_100K-16 84848 43199 ns/op Benchmark__RoutedPubSub_100K-16 84036 47882 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9610254 313.7 ns/op Benchmark____Routed2QueueSub-16 9951529 321.5 ns/op Benchmark____Routed2QueueSub-16 10037952 323.2 ns/op Benchmark____Routed2QueueSub-16 9748454 318.1 ns/op Benchmark____Routed2QueueSub-16 9773751 320.5 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9547902 331.4 ns/op Benchmark____Routed4QueueSub-16 9595687 320.6 ns/op Benchmark____Routed4QueueSub-16 9589896 317.9 ns/op Benchmark____Routed4QueueSub-16 9566419 322.9 ns/op Benchmark____Routed4QueueSub-16 9346112 324.4 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9240136 335.8 ns/op Benchmark____Routed8QueueSub-16 9267841 324.8 ns/op Benchmark____Routed8QueueSub-16 9233882 336.0 ns/op Benchmark____Routed8QueueSub-16 9141670 341.4 ns/op Benchmark____Routed8QueueSub-16 11089928 323.9 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8679084 352.5 ns/op Benchmark___Routed16QueueSub-16 10457131 347.1 ns/op Benchmark___Routed16QueueSub-16 8909866 352.1 ns/op Benchmark___Routed16QueueSub-16 8762066 349.1 ns/op Benchmark___Routed16QueueSub-16 8948817 352.0 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6378067 542.7 ns/op Benchmark____________RouteCompressOff-16 6513627 550.1 ns/op Benchmark____________RouteCompressOff-16 6572080 543.2 ns/op Benchmark____________RouteCompressOff-16 6373598 548.4 ns/op Benchmark____________RouteCompressOff-16 6361062 547.0 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6448296 552.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6282817 549.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6465482 539.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6391518 551.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6506178 550.6 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6389679 550.0 ns/op Benchmark_________RouteCompressS2Fast-16 6071437 547.3 ns/op Benchmark_________RouteCompressS2Fast-16 6429537 548.0 ns/op Benchmark_________RouteCompressS2Fast-16 6382237 551.4 ns/op Benchmark_________RouteCompressS2Fast-16 6521301 554.3 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6593061 546.8 ns/op Benchmark_______RouteCompressS2Better-16 6435397 538.2 ns/op Benchmark_______RouteCompressS2Better-16 6403935 552.0 ns/op Benchmark_______RouteCompressS2Better-16 6367765 542.2 ns/op Benchmark_______RouteCompressS2Better-16 6348847 545.9 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6363730 547.8 ns/op Benchmark_________RouteCompressS2Best-16 6517526 537.5 ns/op Benchmark_________RouteCompressS2Best-16 6389284 542.0 ns/op Benchmark_________RouteCompressS2Best-16 6594073 518.1 ns/op Benchmark_________RouteCompressS2Best-16 6449460 545.9 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4660066 774.6 ns/op 321.45 MB/s Benchmark______FanOut_8x1x10-16 4683528 768.9 ns/op 323.84 MB/s Benchmark______FanOut_8x1x10-16 4658320 771.6 ns/op 322.71 MB/s Benchmark______FanOut_8x1x10-16 4626830 767.7 ns/op 324.37 MB/s Benchmark______FanOut_8x1x10-16 4639453 781.1 ns/op 318.77 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 553574 6059 ns/op 382.71 MB/s Benchmark_____FanOut_8x1x100-16 545853 6179 ns/op 375.29 MB/s Benchmark_____FanOut_8x1x100-16 564020 6103 ns/op 379.98 MB/s Benchmark_____FanOut_8x1x100-16 537667 6148 ns/op 377.17 MB/s Benchmark_____FanOut_8x1x100-16 574246 6174 ns/op 375.63 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48154 75100 ns/op 306.51 MB/s Benchmark____FanOut_8x10x100-16 47547 74557 ns/op 308.74 MB/s Benchmark____FanOut_8x10x100-16 48195 74631 ns/op 308.44 MB/s Benchmark____FanOut_8x10x100-16 47030 76293 ns/op 301.72 MB/s Benchmark____FanOut_8x10x100-16 48117 74876 ns/op 307.43 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6000 596447 ns/op 402.41 MB/s Benchmark___FanOut_8x10x1000-16 5857 604577 ns/op 397.00 MB/s Benchmark___FanOut_8x10x1000-16 5894 594753 ns/op 403.56 MB/s Benchmark___FanOut_8x10x1000-16 5955 595739 ns/op 402.89 MB/s Benchmark___FanOut_8x10x1000-16 5895 612681 ns/op 391.75 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4995 709649 ns/op 324.13 MB/s Benchmark___FanOut_8x100x100-16 4978 713800 ns/op 322.25 MB/s Benchmark___FanOut_8x100x100-16 5073 705126 ns/op 326.21 MB/s Benchmark___FanOut_8x100x100-16 4966 710145 ns/op 323.90 MB/s Benchmark___FanOut_8x100x100-16 4948 707507 ns/op 325.11 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 568 6216619 ns/op 386.07 MB/s Benchmark__FanOut_8x100x1000-16 568 6235213 ns/op 384.91 MB/s Benchmark__FanOut_8x100x1000-16 573 6315074 ns/op 380.05 MB/s Benchmark__FanOut_8x100x1000-16 540 6164354 ns/op 389.34 MB/s Benchmark__FanOut_8x100x1000-16 555 6292403 ns/op 381.42 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 535 6643918 ns/op 376.29 MB/s Benchmark__FanOut_8x10x10000-16 517 6899950 ns/op 362.32 MB/s Benchmark__FanOut_8x10x10000-16 534 6710227 ns/op 372.57 MB/s Benchmark__FanOut_8x10x10000-16 513 6682068 ns/op 374.14 MB/s Benchmark__FanOut_8x10x10000-16 524 6744316 ns/op 370.69 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 952 3743615 ns/op 307.19 MB/s Benchmark___FanOut_8x500x100-16 951 3794985 ns/op 303.04 MB/s Benchmark___FanOut_8x500x100-16 950 3749207 ns/op 306.74 MB/s Benchmark___FanOut_8x500x100-16 950 3822679 ns/op 300.84 MB/s Benchmark___FanOut_8x500x100-16 934 3748021 ns/op 306.83 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 376472 9410 ns/op 1555.98 MB/s Benchmark___FanOut_128x1x100-16 375084 9415 ns/op 1555.04 MB/s Benchmark___FanOut_128x1x100-16 365496 9522 ns/op 1537.65 MB/s Benchmark___FanOut_128x1x100-16 369715 9421 ns/op 1554.10 MB/s Benchmark___FanOut_128x1x100-16 360434 9429 ns/op 1552.74 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32691 109320 ns/op 1327.67 MB/s Benchmark__FanOut_128x10x100-16 32746 109876 ns/op 1320.96 MB/s Benchmark__FanOut_128x10x100-16 32822 110496 ns/op 1313.54 MB/s Benchmark__FanOut_128x10x100-16 32358 109019 ns/op 1331.34 MB/s Benchmark__FanOut_128x10x100-16 32760 110791 ns/op 1310.05 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3949 865393 ns/op 1687.26 MB/s Benchmark_FanOut_128x10x1000-16 4009 863379 ns/op 1691.19 MB/s Benchmark_FanOut_128x10x1000-16 4143 872361 ns/op 1673.78 MB/s Benchmark_FanOut_128x10x1000-16 4081 865296 ns/op 1687.45 MB/s Benchmark_FanOut_128x10x1000-16 4152 865173 ns/op 1687.69 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3525 1009058 ns/op 1437.12 MB/s Benchmark_FanOut_128x100x100-16 3565 1005852 ns/op 1441.70 MB/s Benchmark_FanOut_128x100x100-16 3488 1014210 ns/op 1429.82 MB/s Benchmark_FanOut_128x100x100-16 3495 1008877 ns/op 1437.38 MB/s Benchmark_FanOut_128x100x100-16 3486 1008292 ns/op 1438.21 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 394 9419896 ns/op 1549.93 MB/s BenchmarkFanOut_128x100x1000-16 381 9258581 ns/op 1576.93 MB/s BenchmarkFanOut_128x100x1000-16 384 9181089 ns/op 1590.24 MB/s BenchmarkFanOut_128x100x1000-16 380 9208595 ns/op 1585.49 MB/s BenchmarkFanOut_128x100x1000-16 385 9422926 ns/op 1549.43 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 370 9589345 ns/op 1532.97 MB/s BenchmarkFanOut_128x10x10000-16 375 9699356 ns/op 1515.58 MB/s BenchmarkFanOut_128x10x10000-16 372 9637899 ns/op 1525.24 MB/s BenchmarkFanOut_128x10x10000-16 373 9729744 ns/op 1510.85 MB/s BenchmarkFanOut_128x10x10000-16 378 9517220 ns/op 1544.58 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 668 5285621 ns/op 1371.67 MB/s BenchmarkFanOut__128x500x100-16 675 5252565 ns/op 1380.30 MB/s BenchmarkFanOut__128x500x100-16 672 5240648 ns/op 1383.44 MB/s BenchmarkFanOut__128x500x100-16 682 5234508 ns/op 1385.07 MB/s BenchmarkFanOut__128x500x100-16 679 5260466 ns/op 1378.23 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1963 1827808 ns/op 2894.46 MB/s Benchmark_FanOut_512x100x100-16 1964 1848490 ns/op 2862.08 MB/s Benchmark_FanOut_512x100x100-16 1915 1843005 ns/op 2870.60 MB/s Benchmark_FanOut_512x100x100-16 1992 1838924 ns/op 2876.97 MB/s Benchmark_FanOut_512x100x100-16 1921 1823932 ns/op 2900.62 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 216 16779742 ns/op 3158.60 MB/s Benchmark__FanOut_512x100x1k-16 216 16674559 ns/op 3178.53 MB/s Benchmark__FanOut_512x100x1k-16 217 16579585 ns/op 3196.73 MB/s Benchmark__FanOut_512x100x1k-16 218 16649747 ns/op 3183.26 MB/s Benchmark__FanOut_512x100x1k-16 214 16483959 ns/op 3215.28 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2998 1157435 ns/op 9012.20 MB/s Benchmark____FanOut_1kx10x1k-16 3022 1145231 ns/op 9108.24 MB/s Benchmark____FanOut_1kx10x1k-16 3232 1131838 ns/op 9216.02 MB/s Benchmark____FanOut_1kx10x1k-16 3038 1156066 ns/op 9022.88 MB/s Benchmark____FanOut_1kx10x1k-16 3266 1155746 ns/op 9025.37 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2893 1248985 ns/op 8343.61 MB/s Benchmark__FanOut_1kx100x100-16 2814 1262356 ns/op 8255.23 MB/s Benchmark__FanOut_1kx100x100-16 2782 1252501 ns/op 8320.19 MB/s Benchmark__FanOut_1kx100x100-16 2829 1262460 ns/op 8254.55 MB/s Benchmark__FanOut_1kx100x100-16 2793 1258799 ns/op 8278.56 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4483327 765.5 ns/op 325.29 MB/s Benchmark_____RFanOut_8x1x10-16 4406294 822.7 ns/op 302.66 MB/s Benchmark_____RFanOut_8x1x10-16 4560680 784.9 ns/op 317.23 MB/s Benchmark_____RFanOut_8x1x10-16 4395753 762.9 ns/op 326.39 MB/s Benchmark_____RFanOut_8x1x10-16 4569613 788.2 ns/op 315.91 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 521962 6278 ns/op 369.36 MB/s Benchmark____RFanOut_8x1x100-16 545946 6308 ns/op 367.61 MB/s Benchmark____RFanOut_8x1x100-16 513086 6093 ns/op 380.60 MB/s Benchmark____RFanOut_8x1x100-16 500938 6100 ns/op 380.17 MB/s Benchmark____RFanOut_8x1x100-16 538540 6084 ns/op 381.18 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48170 74839 ns/op 307.58 MB/s Benchmark___RFanOut_8x10x100-16 48166 75137 ns/op 306.36 MB/s Benchmark___RFanOut_8x10x100-16 47764 75097 ns/op 306.52 MB/s Benchmark___RFanOut_8x10x100-16 47896 75056 ns/op 306.69 MB/s Benchmark___RFanOut_8x10x100-16 47850 74783 ns/op 307.81 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5984 597144 ns/op 401.95 MB/s Benchmark__RFanOut_8x10x1000-16 5804 598487 ns/op 401.04 MB/s Benchmark__RFanOut_8x10x1000-16 5822 603195 ns/op 397.91 MB/s Benchmark__RFanOut_8x10x1000-16 5797 595322 ns/op 403.18 MB/s Benchmark__RFanOut_8x10x1000-16 5566 600035 ns/op 400.01 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5068 706190 ns/op 325.72 MB/s Benchmark__RFanOut_8x100x100-16 4986 706455 ns/op 325.60 MB/s Benchmark__RFanOut_8x100x100-16 4962 704742 ns/op 326.39 MB/s Benchmark__RFanOut_8x100x100-16 4898 705649 ns/op 325.97 MB/s Benchmark__RFanOut_8x100x100-16 5026 708212 ns/op 324.79 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 579 6110742 ns/op 392.75 MB/s Benchmark_RFanOut_8x100x1000-16 580 6203255 ns/op 386.90 MB/s Benchmark_RFanOut_8x100x1000-16 578 6185573 ns/op 388.00 MB/s Benchmark_RFanOut_8x100x1000-16 576 6158531 ns/op 389.71 MB/s Benchmark_RFanOut_8x100x1000-16 570 6271001 ns/op 382.72 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 512 6731093 ns/op 371.41 MB/s Benchmark_RFanOut_8x10x10000-16 522 6692780 ns/op 373.54 MB/s Benchmark_RFanOut_8x10x10000-16 520 6690051 ns/op 373.69 MB/s Benchmark_RFanOut_8x10x10000-16 538 6829803 ns/op 366.05 MB/s Benchmark_RFanOut_8x10x10000-16 522 6728810 ns/op 371.54 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2935 1152390 ns/op 9051.66 MB/s Benchmark_RFanOut_1kx10x1000-16 3036 1162081 ns/op 8976.17 MB/s Benchmark_RFanOut_1kx10x1000-16 3040 1136069 ns/op 9181.70 MB/s Benchmark_RFanOut_1kx10x1000-16 2901 1161282 ns/op 8982.35 MB/s Benchmark_RFanOut_1kx10x1000-16 3012 1149561 ns/op 9073.93 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6977564 502.8 ns/op 4132.80 MB/s Benchmark_____FanIn_1kx100x1-16 6955420 503.1 ns/op 4130.74 MB/s Benchmark_____FanIn_1kx100x1-16 6930096 501.7 ns/op 4141.76 MB/s Benchmark_____FanIn_1kx100x1-16 7005362 504.0 ns/op 4122.75 MB/s Benchmark_____FanIn_1kx100x1-16 7038798 505.9 ns/op 4107.45 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2652970 1371 ns/op 5995.62 MB/s Benchmark_____FanIn_4kx100x1-16 2677795 1366 ns/op 6020.64 MB/s Benchmark_____FanIn_4kx100x1-16 2672270 1352 ns/op 6083.25 MB/s Benchmark_____FanIn_4kx100x1-16 2605790 1340 ns/op 6135.55 MB/s Benchmark_____FanIn_4kx100x1-16 2669464 1367 ns/op 6015.38 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1694781 2125 ns/op 7723.10 MB/s Benchmark_____FanIn_8kx100x1-16 1698872 2101 ns/op 7810.79 MB/s Benchmark_____FanIn_8kx100x1-16 1745098 2110 ns/op 7779.68 MB/s Benchmark_____FanIn_8kx100x1-16 1712931 2128 ns/op 7713.29 MB/s Benchmark_____FanIn_8kx100x1-16 1720016 2103 ns/op 7804.53 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 879810 4274 ns/op 7674.33 MB/s Benchmark____FanIn_16kx100x1-16 871606 4162 ns/op 7881.31 MB/s Benchmark____FanIn_16kx100x1-16 873307 4150 ns/op 7903.71 MB/s Benchmark____FanIn_16kx100x1-16 884965 4092 ns/op 8015.90 MB/s Benchmark____FanIn_16kx100x1-16 870640 4139 ns/op 7924.17 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 169387 19750 ns/op 6638.08 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 4341444084 vs 11248894800 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37542->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:38278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38260->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 164662 19798 ns/op 6622.20 MB/s Benchmark____FanIn_64kx100x1-16 167445 20115 ns/op 6517.58 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 3553300365 vs 11255450100 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59522->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59450->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:58792->127.0.0.1:5222: write: connection reset by peer Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 457766280 vs 11352394000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34152->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33666->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:33680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33550->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: 319859600 vs 11299958000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36446->127.0.0.1:5222: write: connection reset by peer bench_test.go: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:36738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36236->127.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:36510->127.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:36444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35876->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35958->127.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: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:36392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36724->127.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:36662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36138->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36578->127.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 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36010->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: 622415320 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38218->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38594->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:38336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38006->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: 346733050 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39662->127.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:40138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39542->127.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:39680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40344->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: 639719200 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41576->127.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:41626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41822->127.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: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:41640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41734->127.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:41742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41726->127.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:41408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41872->127.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:41616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41958->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5527402 644.3 ns/op 440.76 MB/s Benchmark___BumpPubCount_1x3-16 5526860 643.5 ns/op 441.35 MB/s Benchmark___BumpPubCount_1x3-16 5489509 644.0 ns/op 441.00 MB/s Benchmark___BumpPubCount_1x3-16 5549144 651.5 ns/op 435.89 MB/s Benchmark___BumpPubCount_1x3-16 5511255 642.7 ns/op 441.89 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5285905 675.5 ns/op 420.43 MB/s Benchmark___BumpPubCount_2x3-16 5308946 675.9 ns/op 420.20 MB/s Benchmark___BumpPubCount_2x3-16 5252092 674.2 ns/op 421.27 MB/s Benchmark___BumpPubCount_2x3-16 5283972 671.2 ns/op 423.12 MB/s Benchmark___BumpPubCount_2x3-16 5285401 676.9 ns/op 419.59 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5503976 644.7 ns/op 440.54 MB/s Benchmark___BumpPubCount_5x3-16 5516217 642.4 ns/op 442.10 MB/s Benchmark___BumpPubCount_5x3-16 5575975 644.4 ns/op 440.73 MB/s Benchmark___BumpPubCount_5x3-16 5521149 645.8 ns/op 439.78 MB/s Benchmark___BumpPubCount_5x3-16 5330084 644.1 ns/op 440.89 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5535470 644.4 ns/op 440.70 MB/s Benchmark__BumpPubCount_10x3-16 5579155 641.9 ns/op 442.43 MB/s Benchmark__BumpPubCount_10x3-16 5568643 646.0 ns/op 439.63 MB/s Benchmark__BumpPubCount_10x3-16 5568266 643.3 ns/op 441.46 MB/s Benchmark__BumpPubCount_10x3-16 5608093 651.4 ns/op 436.01 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11895384 270.6 ns/op 3843.72 MB/s Benchmark____GWs_Opt_1kx01x0-16 13131204 276.2 ns/op 3765.27 MB/s Benchmark____GWs_Opt_1kx01x0-16 12541744 285.1 ns/op 3647.60 MB/s Benchmark____GWs_Opt_1kx01x0-16 13119640 277.5 ns/op 3747.92 MB/s Benchmark____GWs_Opt_1kx01x0-16 12808245 269.6 ns/op 3857.02 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10779933 353.0 ns/op 5847.42 MB/s Benchmark____GWs_Opt_2kx01x0-16 9370236 327.7 ns/op 6299.33 MB/s Benchmark____GWs_Opt_2kx01x0-16 10361104 339.3 ns/op 6083.90 MB/s Benchmark____GWs_Opt_2kx01x0-16 9816967 354.2 ns/op 5826.99 MB/s Benchmark____GWs_Opt_2kx01x0-16 10958536 325.6 ns/op 6338.33 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5503135 639.0 ns/op 6435.15 MB/s Benchmark____GWs_Opt_4kx01x0-16 5594706 631.6 ns/op 6510.51 MB/s Benchmark____GWs_Opt_4kx01x0-16 5663034 625.9 ns/op 6569.96 MB/s Benchmark____GWs_Opt_4kx01x0-16 5612956 757.3 ns/op 5429.89 MB/s Benchmark____GWs_Opt_4kx01x0-16 5287204 633.0 ns/op 6496.30 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28014753 109.9 ns/op 9463.55 MB/s Benchmark____GWs_Opt_1kx10x0-16 30515959 115.2 ns/op 9030.03 MB/s Benchmark____GWs_Opt_1kx10x0-16 26839130 118.6 ns/op 8768.81 MB/s Benchmark____GWs_Opt_1kx10x0-16 28348990 112.4 ns/op 9252.93 MB/s Benchmark____GWs_Opt_1kx10x0-16 31938849 112.0 ns/op 9286.27 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25892820 156.0 ns/op 13230.55 MB/s Benchmark____GWs_Opt_2kx10x0-16 23787902 142.7 ns/op 14465.78 MB/s Benchmark____GWs_Opt_2kx10x0-16 23075283 140.2 ns/op 14724.90 MB/s Benchmark____GWs_Opt_2kx10x0-16 21733695 146.7 ns/op 14066.47 MB/s Benchmark____GWs_Opt_2kx10x0-16 25715336 152.3 ns/op 13555.05 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 13321818 329.0 ns/op 12497.55 MB/s Benchmark____GWs_Opt_4kx10x0-16 12661872 331.0 ns/op 12423.94 MB/s Benchmark____GWs_Opt_4kx10x0-16 12455251 331.8 ns/op 12393.03 MB/s Benchmark____GWs_Opt_4kx10x0-16 11663734 284.7 ns/op 14444.98 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:40976->127.0.0.1:33605: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:36712->127.0.0.1:44687: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6583333 546.6 ns/op 5717.31 MB/s Benchmark____GWs_Opt_1kx01x1-16 6556334 549.7 ns/op 5685.43 MB/s Benchmark____GWs_Opt_1kx01x1-16 6703668 548.8 ns/op 5694.40 MB/s Benchmark____GWs_Opt_1kx01x1-16 6450693 545.1 ns/op 5732.50 MB/s Benchmark____GWs_Opt_1kx01x1-16 6568933 546.8 ns/op 5715.33 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4746752 750.7 ns/op 8254.62 MB/s Benchmark____GWs_Opt_2kx01x1-16 4367109 753.9 ns/op 8220.31 MB/s Benchmark____GWs_Opt_2kx01x1-16 4819621 768.1 ns/op 8067.57 MB/s Benchmark____GWs_Opt_2kx01x1-16 4836204 750.1 ns/op 8261.17 MB/s Benchmark____GWs_Opt_2kx01x1-16 4555759 765.2 ns/op 8098.62 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2620632 1459 ns/op 8457.14 MB/s Benchmark____GWs_Opt_4kx01x1-16 2593912 1360 ns/op 9076.33 MB/s Benchmark____GWs_Opt_4kx01x1-16 2360967 1365 ns/op 9038.34 MB/s Benchmark____GWs_Opt_4kx01x1-16 2621641 1711 ns/op 7212.16 MB/s Benchmark____GWs_Opt_4kx01x1-16 2629478 1396 ns/op 8842.48 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6265947 556.7 ns/op 5613.72 MB/s Benchmark____GWs_Opt_1kx10x1-16 6556242 553.3 ns/op 5648.42 MB/s Benchmark____GWs_Opt_1kx10x1-16 6169634 561.4 ns/op 5566.70 MB/s Benchmark____GWs_Opt_1kx10x1-16 6647600 548.3 ns/op 5698.98 MB/s Benchmark____GWs_Opt_1kx10x1-16 6472021 551.8 ns/op 5663.62 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4116452 845.4 ns/op 7329.92 MB/s Benchmark____GWs_Opt_2kx10x1-16 4264375 849.2 ns/op 7297.21 MB/s Benchmark____GWs_Opt_2kx10x1-16 4494621 891.0 ns/op 6955.00 MB/s Benchmark____GWs_Opt_2kx10x1-16 4215979 902.9 ns/op 6863.16 MB/s Benchmark____GWs_Opt_2kx10x1-16 4299250 826.3 ns/op 7499.67 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2265501 1505 ns/op 8202.51 MB/s Benchmark____GWs_Opt_4kx10x1-16 2324320 1823 ns/op 6767.83 MB/s Benchmark____GWs_Opt_4kx10x1-16 2375683 1564 ns/op 7892.29 MB/s Benchmark____GWs_Opt_4kx10x1-16 2318488 1546 ns/op 7982.41 MB/s Benchmark____GWs_Opt_4kx10x1-16 2543515 1706 ns/op 7235.83 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12469890 293.6 ns/op 3542.10 MB/s Benchmark____GWs_Int_1kx01x0-16 12282852 279.6 ns/op 3719.94 MB/s Benchmark____GWs_Int_1kx01x0-16 12592446 285.9 ns/op 3637.38 MB/s Benchmark____GWs_Int_1kx01x0-16 12312321 287.0 ns/op 3623.72 MB/s Benchmark____GWs_Int_1kx01x0-16 12943207 279.3 ns/op 3723.29 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10181998 347.4 ns/op 5941.10 MB/s Benchmark____GWs_Int_2kx01x0-16 10128010 337.6 ns/op 6113.47 MB/s Benchmark____GWs_Int_2kx01x0-16 10181815 367.4 ns/op 5617.53 MB/s Benchmark____GWs_Int_2kx01x0-16 10360990 335.7 ns/op 6148.46 MB/s Benchmark____GWs_Int_2kx01x0-16 9647244 354.2 ns/op 5826.59 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5651468 648.9 ns/op 6336.57 MB/s Benchmark____GWs_Int_4kx01x0-16 5479328 637.1 ns/op 6454.46 MB/s Benchmark____GWs_Int_4kx01x0-16 5754996 648.0 ns/op 6346.15 MB/s Benchmark____GWs_Int_4kx01x0-16 5269344 888.4 ns/op 4628.67 MB/s Benchmark____GWs_Int_4kx01x0-16 5493538 638.1 ns/op 6444.46 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31745214 111.7 ns/op 9307.93 MB/s Benchmark____GWs_Int_1kx10x0-16 31553512 112.6 ns/op 9238.40 MB/s Benchmark____GWs_Int_1kx10x0-16 30815582 113.2 ns/op 9187.84 MB/s Benchmark____GWs_Int_1kx10x0-16 32239444 111.9 ns/op 9293.91 MB/s Benchmark____GWs_Int_1kx10x0-16 29386880 116.2 ns/op 8951.69 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25560992 152.4 ns/op 13543.90 MB/s Benchmark____GWs_Int_2kx10x0-16 25625355 140.7 ns/op 14664.98 MB/s Benchmark____GWs_Int_2kx10x0-16 23913858 180.0 ns/op 11463.90 MB/s Benchmark____GWs_Int_2kx10x0-16 25415797 150.3 ns/op 13732.94 MB/s Benchmark____GWs_Int_2kx10x0-16 25929660 146.3 ns/op 14111.16 MB/s Benchmark____GWs_Int_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:48412->127.0.0.1:44685: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:58878->127.0.0.1:40575: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12010710 309.2 ns/op 13299.46 MB/s Benchmark____GWs_Int_4kx10x0-16 12009558 319.2 ns/op 12883.15 MB/s Benchmark____GWs_Int_4kx10x0-16 7213309 419.1 ns/op 9810.74 MB/s Benchmark____GWs_Int_4kx10x0-16 10674748 302.0 ns/op 13613.78 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6452832 550.2 ns/op 5679.37 MB/s Benchmark____GWs_Int_1kx01x1-16 6673933 553.3 ns/op 5647.78 MB/s Benchmark____GWs_Int_1kx01x1-16 6544819 550.2 ns/op 5679.91 MB/s Benchmark____GWs_Int_1kx01x1-16 6621956 561.5 ns/op 5565.18 MB/s Benchmark____GWs_Int_1kx01x1-16 6381978 555.8 ns/op 5622.72 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4607612 759.5 ns/op 8159.48 MB/s Benchmark____GWs_Int_2kx01x1-16 4680247 848.0 ns/op 7308.10 MB/s Benchmark____GWs_Int_2kx01x1-16 4689954 761.5 ns/op 8137.87 MB/s Benchmark____GWs_Int_2kx01x1-16 4747352 757.6 ns/op 8180.07 MB/s Benchmark____GWs_Int_2kx01x1-16 4702974 760.3 ns/op 8151.02 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2334400 1380 ns/op 8945.94 MB/s Benchmark____GWs_Int_4kx01x1-16 2594496 1357 ns/op 9095.31 MB/s Benchmark____GWs_Int_4kx01x1-16 2640015 1495 ns/op 8253.34 MB/s Benchmark____GWs_Int_4kx01x1-16 2622820 1360 ns/op 9076.30 MB/s Benchmark____GWs_Int_4kx01x1-16 2639770 1367 ns/op 9030.80 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6670554 549.5 ns/op 5686.83 MB/s Benchmark____GWs_Int_1kx10x1-16 6532819 564.6 ns/op 5534.66 MB/s Benchmark____GWs_Int_1kx10x1-16 6452637 544.2 ns/op 5742.31 MB/s Benchmark____GWs_Int_1kx10x1-16 6604684 555.9 ns/op 5621.28 MB/s Benchmark____GWs_Int_1kx10x1-16 6541654 553.6 ns/op 5644.60 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4415521 830.0 ns/op 7465.88 MB/s Benchmark____GWs_Int_2kx10x1-16 4194590 879.8 ns/op 7043.89 MB/s Benchmark____GWs_Int_2kx10x1-16 4233037 832.5 ns/op 7443.80 MB/s Benchmark____GWs_Int_2kx10x1-16 4085908 836.9 ns/op 7404.72 MB/s Benchmark____GWs_Int_2kx10x1-16 4164692 834.4 ns/op 7427.07 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2389759 1533 ns/op 8051.69 MB/s Benchmark____GWs_Int_4kx10x1-16 2438502 1519 ns/op 8125.57 MB/s Benchmark____GWs_Int_4kx10x1-16 2357221 1704 ns/op 7240.31 MB/s Benchmark____GWs_Int_4kx10x1-16 2294271 1494 ns/op 8258.27 MB/s Benchmark____GWs_Int_4kx10x1-16 2332144 1484 ns/op 8316.18 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 7880870 439.5 ns/op 232.09 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8432599 427.4 ns/op 238.63 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7783576 433.8 ns/op 235.14 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8237452 434.6 ns/op 234.68 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8293592 429.3 ns/op 237.57 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 630270 5063 ns/op 34.96 MB/s Benchmark__GWs_Reqs_1SubEach-16 825740 5226 ns/op 33.87 MB/s Benchmark__GWs_Reqs_1SubEach-16 732692 5245 ns/op 33.75 MB/s Benchmark__GWs_Reqs_1SubEach-16 756682 5408 ns/op 32.73 MB/s Benchmark__GWs_Reqs_1SubEach-16 740664 5248 ns/op 33.73 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2152.123s