OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/trace_event_impl.h" | 5 #include "base/debug/trace_event_impl.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/debug/leak_annotations.h" | 10 #include "base/debug/leak_annotations.h" |
11 #include "base/debug/trace_event.h" | 11 #include "base/debug/trace_event.h" |
12 #include "base/format_macros.h" | 12 #include "base/format_macros.h" |
13 #include "base/lazy_instance.h" | |
14 #include "base/memory/singleton.h" | 13 #include "base/memory/singleton.h" |
15 #include "base/process_util.h" | 14 #include "base/process_util.h" |
16 #include "base/stl_util.h" | 15 #include "base/stl_util.h" |
17 #include "base/stringprintf.h" | 16 #include "base/stringprintf.h" |
18 #include "base/string_tokenizer.h" | 17 #include "base/string_tokenizer.h" |
19 #include "base/string_util.h" | 18 #include "base/string_util.h" |
20 #include "base/sys_info.h" | 19 #include "base/sys_info.h" |
21 #include "base/third_party/dynamic_annotations/dynamic_annotations.h" | 20 #include "base/third_party/dynamic_annotations/dynamic_annotations.h" |
22 #include "base/threading/platform_thread.h" | 21 #include "base/threading/platform_thread.h" |
| 22 #include "base/threading/thread_id_name_manager.h" |
23 #include "base/threading/thread_local.h" | 23 #include "base/threading/thread_local.h" |
24 #include "base/time.h" | 24 #include "base/time.h" |
25 #include "base/utf_string_conversions.h" | 25 #include "base/utf_string_conversions.h" |
26 | 26 |
27 #if defined(OS_WIN) | 27 #if defined(OS_WIN) |
28 #include "base/debug/trace_event_win.h" | 28 #include "base/debug/trace_event_win.h" |
29 #endif | 29 #endif |
30 | 30 |
31 class DeleteTraceLogForTesting { | 31 class DeleteTraceLogForTesting { |
32 public: | 32 public: |
(...skipping 25 matching lines...) Expand all Loading... |
58 "tracing categories exhausted; must increase TRACE_EVENT_MAX_CATEGORIES", | 58 "tracing categories exhausted; must increase TRACE_EVENT_MAX_CATEGORIES", |
59 "__metadata", | 59 "__metadata", |
60 }; | 60 }; |
61 // The enabled flag is char instead of bool so that the API can be used from C. | 61 // The enabled flag is char instead of bool so that the API can be used from C. |
62 unsigned char g_category_enabled[TRACE_EVENT_MAX_CATEGORIES] = { 0 }; | 62 unsigned char g_category_enabled[TRACE_EVENT_MAX_CATEGORIES] = { 0 }; |
63 const int g_category_already_shutdown = 0; | 63 const int g_category_already_shutdown = 0; |
64 const int g_category_categories_exhausted = 1; | 64 const int g_category_categories_exhausted = 1; |
65 const int g_category_metadata = 2; | 65 const int g_category_metadata = 2; |
66 int g_category_index = 3; // skip initial 3 categories | 66 int g_category_index = 3; // skip initial 3 categories |
67 | 67 |
68 // The most-recently captured name of the current thread | 68 // The version number for the name of the current thread. |
69 LazyInstance<ThreadLocalPointer<const char> >::Leaky | 69 uint32 g_current_thread_name_version = 0; |
70 g_current_thread_name = LAZY_INSTANCE_INITIALIZER; | |
71 | 70 |
72 } // namespace | 71 } // namespace |
73 | 72 |
74 //////////////////////////////////////////////////////////////////////////////// | 73 //////////////////////////////////////////////////////////////////////////////// |
75 // | 74 // |
76 // TraceEvent | 75 // TraceEvent |
77 // | 76 // |
78 //////////////////////////////////////////////////////////////////////////////// | 77 //////////////////////////////////////////////////////////////////////////////// |
79 | 78 |
80 namespace { | 79 namespace { |
(...skipping 547 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
628 TimeTicks now = TimeTicks::NowFromSystemTraceTime() - time_offset_; | 627 TimeTicks now = TimeTicks::NowFromSystemTraceTime() - time_offset_; |
629 NotificationHelper notifier(this); | 628 NotificationHelper notifier(this); |
630 { | 629 { |
631 AutoLock lock(lock_); | 630 AutoLock lock(lock_); |
632 if (*category_enabled != CATEGORY_ENABLED) | 631 if (*category_enabled != CATEGORY_ENABLED) |
633 return; | 632 return; |
634 if (logged_events_.size() >= kTraceEventBufferSize) | 633 if (logged_events_.size() >= kTraceEventBufferSize) |
635 return; | 634 return; |
636 | 635 |
637 int thread_id = static_cast<int>(PlatformThread::CurrentId()); | 636 int thread_id = static_cast<int>(PlatformThread::CurrentId()); |
| 637 ThreadIdNameManager* manager = ThreadIdNameManager::GetInstance(); |
| 638 const char* new_name = manager->GetNameForId(thread_id); |
| 639 uint32 new_version = manager->GetVersionForId(thread_id); |
638 | 640 |
639 const char* new_name = PlatformThread::GetName(); | |
640 // Check if the thread name has been set or changed since the previous | 641 // Check if the thread name has been set or changed since the previous |
641 // call (if any), but don't bother if the new name is empty. Note this will | 642 // call (if any), but don't bother if the new name is empty. Note this will |
642 // not detect a thread name change within the same char* buffer address: we | 643 // not detect a thread name change within the same char* buffer address: we |
643 // favor common case performance over corner case correctness. | 644 // favor common case performance over corner case correctness. |
644 if (new_name != g_current_thread_name.Get().Get() && | 645 if (new_version != g_current_thread_name_version && |
645 new_name && *new_name) { | 646 new_name && *new_name) { |
646 g_current_thread_name.Get().Set(new_name); | 647 g_current_thread_name_version = new_version; |
| 648 |
647 base::hash_map<int, std::string>::iterator existing_name = | 649 base::hash_map<int, std::string>::iterator existing_name = |
648 thread_names_.find(thread_id); | 650 thread_names_.find(thread_id); |
649 if (existing_name == thread_names_.end()) { | 651 if (existing_name == thread_names_.end()) { |
650 // This is a new thread id, and a new name. | 652 // This is a new thread id, and a new name. |
651 thread_names_[thread_id] = new_name; | 653 thread_names_[thread_id] = new_name; |
652 } else { | 654 } else { |
653 // This is a thread id that we've seen before, but potentially with a | 655 // This is a thread id that we've seen before, but potentially with a |
654 // new name. | 656 // new name. |
655 std::vector<base::StringPiece> existing_names; | 657 std::vector<base::StringPiece> existing_names; |
656 Tokenize(existing_name->second, ",", &existing_names); | 658 Tokenize(existing_name->second, ",", &existing_names); |
(...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
780 unsigned long long pid = static_cast<unsigned long long>(process_id_); | 782 unsigned long long pid = static_cast<unsigned long long>(process_id_); |
781 process_id_hash_ = (offset_basis ^ pid) * fnv_prime; | 783 process_id_hash_ = (offset_basis ^ pid) * fnv_prime; |
782 } | 784 } |
783 | 785 |
784 void TraceLog::SetTimeOffset(TimeDelta offset) { | 786 void TraceLog::SetTimeOffset(TimeDelta offset) { |
785 time_offset_ = offset; | 787 time_offset_ = offset; |
786 } | 788 } |
787 | 789 |
788 } // namespace debug | 790 } // namespace debug |
789 } // namespace base | 791 } // namespace base |
OLD | NEW |