Chromium Code Reviews| Index: base/debug/trace_event_impl.cc |
| diff --git a/base/debug/trace_event_impl.cc b/base/debug/trace_event_impl.cc |
| index 07679d1131250fb101401191d02434dc6e59e8b8..5abe48e430bb72e6982f59fe54c0f1cf1d408ca4 100644 |
| --- a/base/debug/trace_event_impl.cc |
| +++ b/base/debug/trace_event_impl.cc |
| @@ -10,7 +10,6 @@ |
| #include "base/debug/leak_annotations.h" |
| #include "base/debug/trace_event.h" |
| #include "base/format_macros.h" |
| -#include "base/lazy_instance.h" |
| #include "base/memory/singleton.h" |
| #include "base/process_util.h" |
| #include "base/stl_util.h" |
| @@ -20,6 +19,7 @@ |
| #include "base/sys_info.h" |
| #include "base/third_party/dynamic_annotations/dynamic_annotations.h" |
| #include "base/threading/platform_thread.h" |
| +#include "base/threading/thread_id_name_manager.h" |
| #include "base/threading/thread_local.h" |
| #include "base/time.h" |
| #include "base/utf_string_conversions.h" |
| @@ -65,9 +65,11 @@ const int g_category_categories_exhausted = 1; |
| const int g_category_metadata = 2; |
| int g_category_index = 3; // skip initial 3 categories |
| -// The most-recently captured name of the current thread |
| -LazyInstance<ThreadLocalPointer<const char> >::Leaky |
| - g_current_thread_name = LAZY_INSTANCE_INITIALIZER; |
| +// The name of the current thread. This is used to decide if the current |
| +// thread name has changed. We combine all the seen thread names into the |
| +// output name for the thread. |
| +base::InternedString g_current_thread_interned_name = |
|
jar (doing other things)
2013/01/14 19:27:57
I was expecting such a thing to be in TLS, and it'
dsinclair
2013/01/14 22:26:09
Thanks for pointing that out, lost the ThreadLocal
|
| + base::kDefaultInternedString; |
| } // namespace |
| @@ -635,31 +637,35 @@ void TraceLog::AddTraceEvent(char phase, |
| return; |
| int thread_id = static_cast<int>(PlatformThread::CurrentId()); |
| + ThreadIdNameManager* manager = ThreadIdNameManager::GetInstance(); |
| + InternedString interned_name = manager->GetInternedName(thread_id); |
| - const char* new_name = PlatformThread::GetName(); |
| // Check if the thread name has been set or changed since the previous |
| // call (if any), but don't bother if the new name is empty. Note this will |
| // not detect a thread name change within the same char* buffer address: we |
| // favor common case performance over corner case correctness. |
| - if (new_name != g_current_thread_name.Get().Get() && |
| - new_name && *new_name) { |
| - g_current_thread_name.Get().Set(new_name); |
| - base::hash_map<int, std::string>::iterator existing_name = |
| - thread_names_.find(thread_id); |
| - if (existing_name == thread_names_.end()) { |
| - // This is a new thread id, and a new name. |
| - thread_names_[thread_id] = new_name; |
| - } else { |
| - // This is a thread id that we've seen before, but potentially with a |
| - // new name. |
| - std::vector<base::StringPiece> existing_names; |
| - Tokenize(existing_name->second, ",", &existing_names); |
| - bool found = std::find(existing_names.begin(), |
| - existing_names.end(), |
| - new_name) != existing_names.end(); |
| - if (!found) { |
| - existing_name->second.push_back(','); |
| - existing_name->second.append(new_name); |
| + if (interned_name != g_current_thread_interned_name) { |
|
jar (doing other things)
2013/01/14 19:27:57
How does this work without racing access to the gl
dsinclair
2013/01/14 22:26:09
Moved the storage to a thread local. There is an A
jar (doing other things)
2013/01/17 23:18:39
Shouldn't there be a test that would break if we d
dsinclair
2013/01/21 19:14:18
I'm not exactly sure how to write that test. Any s
|
| + const char* new_name = manager->GetInternedStringValue(interned_name); |
| + if (new_name && *new_name) { |
| + g_current_thread_interned_name = interned_name; |
| + |
| + base::hash_map<int, std::string>::iterator existing_name = |
| + thread_names_.find(thread_id); |
| + if (existing_name == thread_names_.end()) { |
| + // This is a new thread id, and a new name. |
| + thread_names_[thread_id] = new_name; |
| + } else { |
| + // This is a thread id that we've seen before, but potentially with a |
| + // new name. |
| + std::vector<base::StringPiece> existing_names; |
| + Tokenize(existing_name->second, ",", &existing_names); |
| + bool found = std::find(existing_names.begin(), |
| + existing_names.end(), |
| + new_name) != existing_names.end(); |
| + if (!found) { |
| + existing_name->second.push_back(','); |
| + existing_name->second.append(new_name); |
| + } |
| } |
| } |
| } |