| 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 |