| 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 "base/debug/activity_analyzer.h" | 5 #include "base/debug/activity_analyzer.h" |
| 6 | 6 |
| 7 #include <atomic> | 7 #include <atomic> |
| 8 #include <memory> | 8 #include <memory> |
| 9 | 9 |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| (...skipping 28 matching lines...) Expand all Loading... |
| 39 | 39 |
| 40 private: | 40 private: |
| 41 std::unique_ptr<char[]> mem_segment_; | 41 std::unique_ptr<char[]> mem_segment_; |
| 42 }; | 42 }; |
| 43 | 43 |
| 44 } // namespace | 44 } // namespace |
| 45 | 45 |
| 46 | 46 |
| 47 class ActivityAnalyzerTest : public testing::Test { | 47 class ActivityAnalyzerTest : public testing::Test { |
| 48 public: | 48 public: |
| 49 const int kMemorySize = 1 << 10; // 1MiB | 49 const int kMemorySize = 1 << 20; // 1MiB |
| 50 const int kStackSize = 1 << 10; // 1KiB | 50 const int kStackSize = 1 << 10; // 1KiB |
| 51 | 51 |
| 52 ActivityAnalyzerTest() {} | 52 ActivityAnalyzerTest() {} |
| 53 | 53 |
| 54 ~ActivityAnalyzerTest() override { | 54 ~ActivityAnalyzerTest() override { |
| 55 GlobalActivityTracker* global_tracker = GlobalActivityTracker::Get(); | 55 GlobalActivityTracker* global_tracker = GlobalActivityTracker::Get(); |
| 56 if (global_tracker) { | 56 if (global_tracker) { |
| 57 global_tracker->ReleaseTrackerForCurrentThreadForTesting(); | 57 global_tracker->ReleaseTrackerForCurrentThreadForTesting(); |
| 58 delete global_tracker; | 58 delete global_tracker; |
| 59 } | 59 } |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 91 source_(source), | 91 source_(source), |
| 92 activity_(activity), | 92 activity_(activity), |
| 93 data_(data), | 93 data_(data), |
| 94 ready_(false), | 94 ready_(false), |
| 95 exit_(false), | 95 exit_(false), |
| 96 exit_condition_(&lock_) {} | 96 exit_condition_(&lock_) {} |
| 97 | 97 |
| 98 ~SimpleActivityThread() override {} | 98 ~SimpleActivityThread() override {} |
| 99 | 99 |
| 100 void Run() override { | 100 void Run() override { |
| 101 GlobalActivityTracker::Get() | 101 ThreadActivityTracker::ActivityId id = GlobalActivityTracker::Get() |
| 102 ->GetOrCreateTrackerForCurrentThread() | 102 ->GetOrCreateTrackerForCurrentThread() |
| 103 ->PushActivity(source_, activity_, data_); | 103 ->PushActivity(source_, activity_, data_); |
| 104 | 104 |
| 105 { | 105 { |
| 106 AutoLock auto_lock(lock_); | 106 AutoLock auto_lock(lock_); |
| 107 ready_.store(true, std::memory_order_release); | 107 ready_.store(true, std::memory_order_release); |
| 108 while (!exit_.load(std::memory_order_relaxed)) | 108 while (!exit_.load(std::memory_order_relaxed)) |
| 109 exit_condition_.Wait(); | 109 exit_condition_.Wait(); |
| 110 } | 110 } |
| 111 | 111 |
| 112 GlobalActivityTracker::Get() | 112 GlobalActivityTracker::Get() |
| 113 ->GetOrCreateTrackerForCurrentThread() | 113 ->GetTrackerForCurrentThread() |
| 114 ->PopActivity(); | 114 ->PopActivity(id); |
| 115 } | 115 } |
| 116 | 116 |
| 117 void Exit() { | 117 void Exit() { |
| 118 AutoLock auto_lock(lock_); | 118 AutoLock auto_lock(lock_); |
| 119 exit_.store(true, std::memory_order_relaxed); | 119 exit_.store(true, std::memory_order_relaxed); |
| 120 exit_condition_.Signal(); | 120 exit_condition_.Signal(); |
| 121 } | 121 } |
| 122 | 122 |
| 123 void WaitReady() { | 123 void WaitReady() { |
| 124 SPIN_FOR_1_SECOND_OR_UNTIL_TRUE(ready_.load(std::memory_order_acquire)); | 124 SPIN_FOR_1_SECOND_OR_UNTIL_TRUE(ready_.load(std::memory_order_acquire)); |
| (...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 172 ThreadActivityAnalyzer* ta2 = analyzer.GetFirstAnalyzer(); | 172 ThreadActivityAnalyzer* ta2 = analyzer.GetFirstAnalyzer(); |
| 173 ASSERT_TRUE(ta2); | 173 ASSERT_TRUE(ta2); |
| 174 EXPECT_FALSE(analyzer.GetNextAnalyzer()); | 174 EXPECT_FALSE(analyzer.GetNextAnalyzer()); |
| 175 ThreadActivityAnalyzer::ThreadKey tk2 = ta2->GetThreadKey(); | 175 ThreadActivityAnalyzer::ThreadKey tk2 = ta2->GetThreadKey(); |
| 176 EXPECT_EQ(ta2, analyzer.GetAnalyzerForThread(tk2)); | 176 EXPECT_EQ(ta2, analyzer.GetAnalyzerForThread(tk2)); |
| 177 EXPECT_EQ(tk1, tk2); | 177 EXPECT_EQ(tk1, tk2); |
| 178 } | 178 } |
| 179 | 179 |
| 180 } // namespace debug | 180 } // namespace debug |
| 181 } // namespace base | 181 } // namespace base |
| OLD | NEW |