OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "components/browser_watcher/postmortem_report_collector.h" | 5 #include "components/browser_watcher/postmortem_report_collector.h" |
6 | 6 |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 | 8 |
9 #include <memory> | 9 #include <memory> |
10 #include <set> | 10 #include <set> |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
49 using testing::_; | 49 using testing::_; |
50 using testing::Return; | 50 using testing::Return; |
51 using testing::SetArgPointee; | 51 using testing::SetArgPointee; |
52 | 52 |
53 namespace { | 53 namespace { |
54 | 54 |
55 const char kProductName[] = "TestProduct"; | 55 const char kProductName[] = "TestProduct"; |
56 const char kVersionNumber[] = "TestVersionNumber"; | 56 const char kVersionNumber[] = "TestVersionNumber"; |
57 const char kChannelName[] = "TestChannel"; | 57 const char kChannelName[] = "TestChannel"; |
58 | 58 |
| 59 // The tracker creates some data entries internally. |
| 60 const size_t kInternalProcessDatums = 1; |
| 61 |
59 void ContainsKeyValue( | 62 void ContainsKeyValue( |
60 const google::protobuf::Map<std::string, TypedValue>& data, | 63 const google::protobuf::Map<std::string, TypedValue>& data, |
61 const std::string& key, | 64 const std::string& key, |
62 const std::string& value) { | 65 const std::string& value) { |
63 auto it = data.find(key); | 66 auto it = data.find(key); |
64 ASSERT_TRUE(it != data.end()); | 67 ASSERT_TRUE(it != data.end()); |
65 EXPECT_EQ(TypedValue::kStringValue, it->second.value_case()); | 68 EXPECT_EQ(TypedValue::kStringValue, it->second.value_case()); |
66 EXPECT_EQ(value, it->second.string_value()); | 69 EXPECT_EQ(value, it->second.string_value()); |
67 } | 70 } |
68 | 71 |
(...skipping 502 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
571 StabilityReport report; | 574 StabilityReport report; |
572 ASSERT_EQ(SUCCESS, collector.CollectOneReport(debug_file_path(), &report)); | 575 ASSERT_EQ(SUCCESS, collector.CollectOneReport(debug_file_path(), &report)); |
573 | 576 |
574 // Validate the report's log content. | 577 // Validate the report's log content. |
575 ASSERT_EQ(2, report.log_messages_size()); | 578 ASSERT_EQ(2, report.log_messages_size()); |
576 ASSERT_EQ("hello world", report.log_messages(0)); | 579 ASSERT_EQ("hello world", report.log_messages(0)); |
577 ASSERT_EQ("foo bar", report.log_messages(1)); | 580 ASSERT_EQ("foo bar", report.log_messages(1)); |
578 } | 581 } |
579 | 582 |
580 TEST_F(PostmortemReportCollectorCollectionFromGlobalTrackerTest, | 583 TEST_F(PostmortemReportCollectorCollectionFromGlobalTrackerTest, |
581 GlobalUserDataCollection) { | 584 ProcessUserDataCollection) { |
582 const char string1[] = "foo"; | 585 const char string1[] = "foo"; |
583 const char string2[] = "bar"; | 586 const char string2[] = "bar"; |
584 | 587 |
585 // Record some global user data. | 588 // Record some process user data. |
586 GlobalActivityTracker::CreateWithFile(debug_file_path(), kMemorySize, 0ULL, | 589 GlobalActivityTracker::CreateWithFile(debug_file_path(), kMemorySize, 0ULL, |
587 "", 3); | 590 "", 3); |
588 ActivityUserData& global_data = GlobalActivityTracker::Get()->global_data(); | 591 ActivityUserData& process_data = GlobalActivityTracker::Get()->process_data(); |
589 global_data.Set("raw", "foo", 3); | 592 ActivityUserData::Snapshot snapshot; |
590 global_data.SetString("string", "bar"); | 593 ASSERT_TRUE(process_data.CreateSnapshot(&snapshot)); |
591 global_data.SetChar("char", '9'); | 594 ASSERT_EQ(kInternalProcessDatums, snapshot.size()); |
592 global_data.SetInt("int", -9999); | 595 process_data.Set("raw", "foo", 3); |
593 global_data.SetUint("uint", 9999); | 596 process_data.SetString("string", "bar"); |
594 global_data.SetBool("bool", true); | 597 process_data.SetChar("char", '9'); |
595 global_data.SetReference("ref", string1, strlen(string1)); | 598 process_data.SetInt("int", -9999); |
596 global_data.SetStringReference("sref", string2); | 599 process_data.SetUint("uint", 9999); |
| 600 process_data.SetBool("bool", true); |
| 601 process_data.SetReference("ref", string1, strlen(string1)); |
| 602 process_data.SetStringReference("sref", string2); |
597 | 603 |
598 // Collect the stability report. | 604 // Collect the stability report. |
599 PostmortemReportCollector collector(kProductName, kVersionNumber, | 605 PostmortemReportCollector collector(kProductName, kVersionNumber, |
600 kChannelName, nullptr); | 606 kChannelName, nullptr); |
601 StabilityReport report; | 607 StabilityReport report; |
602 ASSERT_EQ(SUCCESS, collector.CollectOneReport(debug_file_path(), &report)); | 608 ASSERT_EQ(SUCCESS, collector.CollectOneReport(debug_file_path(), &report)); |
603 | 609 |
604 // Validate the report's user data. | 610 // Validate the report's user data. |
605 const auto& collected_data = report.global_data(); | 611 const auto& collected_data = report.global_data(); |
606 ASSERT_EQ(12U, collected_data.size()); | 612 ASSERT_EQ(kInternalProcessDatums + 12U, collected_data.size()); |
607 | 613 |
608 ASSERT_TRUE(base::ContainsKey(collected_data, "raw")); | 614 ASSERT_TRUE(base::ContainsKey(collected_data, "raw")); |
609 EXPECT_EQ(TypedValue::kBytesValue, collected_data.at("raw").value_case()); | 615 EXPECT_EQ(TypedValue::kBytesValue, collected_data.at("raw").value_case()); |
610 EXPECT_EQ("foo", collected_data.at("raw").bytes_value()); | 616 EXPECT_EQ("foo", collected_data.at("raw").bytes_value()); |
611 | 617 |
612 ASSERT_TRUE(base::ContainsKey(collected_data, "string")); | 618 ASSERT_TRUE(base::ContainsKey(collected_data, "string")); |
613 EXPECT_EQ(TypedValue::kStringValue, collected_data.at("string").value_case()); | 619 EXPECT_EQ(TypedValue::kStringValue, collected_data.at("string").value_case()); |
614 EXPECT_EQ("bar", collected_data.at("string").string_value()); | 620 EXPECT_EQ("bar", collected_data.at("string").string_value()); |
615 | 621 |
616 ASSERT_TRUE(base::ContainsKey(collected_data, "char")); | 622 ASSERT_TRUE(base::ContainsKey(collected_data, "char")); |
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
652 ContainsKeyValue(collected_data, kStabilityReporterPlatform, "Win64"); | 658 ContainsKeyValue(collected_data, kStabilityReporterPlatform, "Win64"); |
653 #endif | 659 #endif |
654 ContainsKeyValue(collected_data, kStabilityReporterVersion, kVersionNumber); | 660 ContainsKeyValue(collected_data, kStabilityReporterVersion, kVersionNumber); |
655 } | 661 } |
656 | 662 |
657 TEST_F(PostmortemReportCollectorCollectionFromGlobalTrackerTest, | 663 TEST_F(PostmortemReportCollectorCollectionFromGlobalTrackerTest, |
658 FieldTrialCollection) { | 664 FieldTrialCollection) { |
659 // Record some data. | 665 // Record some data. |
660 GlobalActivityTracker::CreateWithFile(debug_file_path(), kMemorySize, 0ULL, | 666 GlobalActivityTracker::CreateWithFile(debug_file_path(), kMemorySize, 0ULL, |
661 "", 3); | 667 "", 3); |
662 ActivityUserData& global_data = GlobalActivityTracker::Get()->global_data(); | 668 ActivityUserData& process_data = GlobalActivityTracker::Get()->process_data(); |
663 global_data.SetString("string", "bar"); | 669 process_data.SetString("string", "bar"); |
664 global_data.SetString("FieldTrial.string", "bar"); | 670 process_data.SetString("FieldTrial.string", "bar"); |
665 global_data.SetString("FieldTrial.foo", "bar"); | 671 process_data.SetString("FieldTrial.foo", "bar"); |
666 | 672 |
667 // Collect the stability report. | 673 // Collect the stability report. |
668 PostmortemReportCollector collector(kProductName, kVersionNumber, | 674 PostmortemReportCollector collector(kProductName, kVersionNumber, |
669 kChannelName, nullptr); | 675 kChannelName, nullptr); |
670 StabilityReport report; | 676 StabilityReport report; |
671 ASSERT_EQ(SUCCESS, collector.CollectOneReport(debug_file_path(), &report)); | 677 ASSERT_EQ(SUCCESS, collector.CollectOneReport(debug_file_path(), &report)); |
672 | 678 |
673 // Validate the report's experiment and global data. | 679 // Validate the report's experiment and global data. |
674 ASSERT_EQ(2, report.field_trials_size()); | 680 ASSERT_EQ(2, report.field_trials_size()); |
675 EXPECT_NE(0U, report.field_trials(0).name_id()); | 681 EXPECT_NE(0U, report.field_trials(0).name_id()); |
676 EXPECT_NE(0U, report.field_trials(0).group_id()); | 682 EXPECT_NE(0U, report.field_trials(0).group_id()); |
677 EXPECT_NE(0U, report.field_trials(1).name_id()); | 683 EXPECT_NE(0U, report.field_trials(1).name_id()); |
678 EXPECT_EQ(report.field_trials(0).group_id(), | 684 EXPECT_EQ(report.field_trials(0).group_id(), |
679 report.field_trials(1).group_id()); | 685 report.field_trials(1).group_id()); |
680 | 686 |
681 // Expect 5 key/value pairs (including product details). | 687 // Expect 5 key/value pairs (including product details). |
682 const auto& collected_data = report.global_data(); | 688 const auto& collected_data = report.global_data(); |
683 EXPECT_EQ(5U, collected_data.size()); | 689 EXPECT_EQ(kInternalProcessDatums + 5U, collected_data.size()); |
684 EXPECT_TRUE(base::ContainsKey(collected_data, "string")); | 690 EXPECT_TRUE(base::ContainsKey(collected_data, "string")); |
685 } | 691 } |
686 | 692 |
687 TEST_F(PostmortemReportCollectorCollectionFromGlobalTrackerTest, | 693 TEST_F(PostmortemReportCollectorCollectionFromGlobalTrackerTest, |
688 ModuleCollection) { | 694 ModuleCollection) { |
689 // Record some module information. | 695 // Record some module information. |
690 GlobalActivityTracker::CreateWithFile(debug_file_path(), kMemorySize, 0ULL, | 696 GlobalActivityTracker::CreateWithFile(debug_file_path(), kMemorySize, 0ULL, |
691 "", 3); | 697 "", 3); |
692 | 698 |
693 base::debug::GlobalActivityTracker::ModuleInfo module_info = {}; | 699 base::debug::GlobalActivityTracker::ModuleInfo module_info = {}; |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
728 EXPECT_EQ("", collected_module.version()); | 734 EXPECT_EQ("", collected_module.version()); |
729 EXPECT_EQ(0LL, collected_module.shrink_down_delta()); | 735 EXPECT_EQ(0LL, collected_module.shrink_down_delta()); |
730 EXPECT_EQ(!module_info.is_loaded, collected_module.is_unloaded()); | 736 EXPECT_EQ(!module_info.is_loaded, collected_module.is_unloaded()); |
731 } | 737 } |
732 | 738 |
733 TEST_F(PostmortemReportCollectorCollectionFromGlobalTrackerTest, | 739 TEST_F(PostmortemReportCollectorCollectionFromGlobalTrackerTest, |
734 SystemStateTest) { | 740 SystemStateTest) { |
735 // Setup. | 741 // Setup. |
736 GlobalActivityTracker::CreateWithFile(debug_file_path(), kMemorySize, 0ULL, | 742 GlobalActivityTracker::CreateWithFile(debug_file_path(), kMemorySize, 0ULL, |
737 "", 3); | 743 "", 3); |
738 ActivityUserData& global_data = GlobalActivityTracker::Get()->global_data(); | 744 ActivityUserData& process_data = GlobalActivityTracker::Get()->process_data(); |
739 global_data.SetInt(kStabilityStartTimestamp, 12345LL); | 745 process_data.SetInt(kStabilityStartTimestamp, 12345LL); |
740 | 746 |
741 // Collect. | 747 // Collect. |
742 MockSystemSessionAnalyzer analyzer; | 748 MockSystemSessionAnalyzer analyzer; |
743 EXPECT_CALL(analyzer, | 749 EXPECT_CALL(analyzer, |
744 IsSessionUnclean(base::Time::FromInternalValue(12345LL))) | 750 IsSessionUnclean(base::Time::FromInternalValue(12345LL))) |
745 .Times(1) | 751 .Times(1) |
746 .WillOnce(Return(SystemSessionAnalyzer::CLEAN)); | 752 .WillOnce(Return(SystemSessionAnalyzer::CLEAN)); |
747 PostmortemReportCollector collector(kProductName, kVersionNumber, | 753 PostmortemReportCollector collector(kProductName, kVersionNumber, |
748 kChannelName, &analyzer); | 754 kChannelName, &analyzer); |
749 StabilityReport report; | 755 StabilityReport report; |
750 ASSERT_EQ(SUCCESS, collector.CollectOneReport(debug_file_path(), &report)); | 756 ASSERT_EQ(SUCCESS, collector.CollectOneReport(debug_file_path(), &report)); |
751 | 757 |
752 // Validate the report. | 758 // Validate the report. |
753 ASSERT_EQ(SystemState::CLEAN, report.system_state().session_state()); | 759 ASSERT_EQ(SystemState::CLEAN, report.system_state().session_state()); |
754 } | 760 } |
755 | 761 |
756 } // namespace browser_watcher | 762 } // namespace browser_watcher |
OLD | NEW |