| OLD | NEW |
| 1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2006-2008 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/stats_table.h" | 5 #include "base/stats_table.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "base/platform_thread.h" | 8 #include "base/platform_thread.h" |
| 9 #include "base/process_util.h" | 9 #include "base/process_util.h" |
| 10 #include "base/shared_memory.h" | 10 #include "base/shared_memory.h" |
| (...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 105 int size; | 105 int size; |
| 106 int max_counters; | 106 int max_counters; |
| 107 int max_threads; | 107 int max_threads; |
| 108 }; | 108 }; |
| 109 | 109 |
| 110 // Construct a new StatsTablePrivate based on expected size parameters, or | 110 // Construct a new StatsTablePrivate based on expected size parameters, or |
| 111 // return NULL on failure. | 111 // return NULL on failure. |
| 112 static StatsTablePrivate* New(const std::wstring& name, int size, | 112 static StatsTablePrivate* New(const std::wstring& name, int size, |
| 113 int max_threads, int max_counters); | 113 int max_threads, int max_counters); |
| 114 | 114 |
| 115 SharedMemory* shared_memory() { return &shared_memory_; } | 115 base::SharedMemory* shared_memory() { return &shared_memory_; } |
| 116 | 116 |
| 117 // Accessors for our header pointers | 117 // Accessors for our header pointers |
| 118 TableHeader* table_header() const { return table_header_; } | 118 TableHeader* table_header() const { return table_header_; } |
| 119 int version() const { return table_header_->version; } | 119 int version() const { return table_header_->version; } |
| 120 int size() const { return table_header_->size; } | 120 int size() const { return table_header_->size; } |
| 121 int max_counters() const { return table_header_->max_counters; } | 121 int max_counters() const { return table_header_->max_counters; } |
| 122 int max_threads() const { return table_header_->max_threads; } | 122 int max_threads() const { return table_header_->max_threads; } |
| 123 | 123 |
| 124 // Accessors for our tables | 124 // Accessors for our tables |
| 125 wchar_t* thread_name(int slot_id) const { | 125 wchar_t* thread_name(int slot_id) const { |
| (...skipping 19 matching lines...) Expand all Loading... |
| 145 StatsTablePrivate() {} | 145 StatsTablePrivate() {} |
| 146 | 146 |
| 147 // Initializes the table on first access. Sets header values | 147 // Initializes the table on first access. Sets header values |
| 148 // appropriately and zeroes all counters. | 148 // appropriately and zeroes all counters. |
| 149 void InitializeTable(void* memory, int size, int max_counters, | 149 void InitializeTable(void* memory, int size, int max_counters, |
| 150 int max_threads); | 150 int max_threads); |
| 151 | 151 |
| 152 // Initializes our in-memory pointers into a pre-created StatsTable. | 152 // Initializes our in-memory pointers into a pre-created StatsTable. |
| 153 void ComputeMappedPointers(void* memory); | 153 void ComputeMappedPointers(void* memory); |
| 154 | 154 |
| 155 SharedMemory shared_memory_; | 155 base::SharedMemory shared_memory_; |
| 156 TableHeader* table_header_; | 156 TableHeader* table_header_; |
| 157 wchar_t* thread_names_table_; | 157 wchar_t* thread_names_table_; |
| 158 int* thread_tid_table_; | 158 int* thread_tid_table_; |
| 159 int* thread_pid_table_; | 159 int* thread_pid_table_; |
| 160 wchar_t* counter_names_table_; | 160 wchar_t* counter_names_table_; |
| 161 int* data_table_; | 161 int* data_table_; |
| 162 }; | 162 }; |
| 163 | 163 |
| 164 // static | 164 // static |
| 165 StatsTablePrivate* StatsTablePrivate::New(const std::wstring& name, | 165 StatsTablePrivate* StatsTablePrivate::New(const std::wstring& name, |
| (...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 282 global_table_ = NULL; | 282 global_table_ = NULL; |
| 283 } | 283 } |
| 284 | 284 |
| 285 int StatsTable::RegisterThread(const std::wstring& name) { | 285 int StatsTable::RegisterThread(const std::wstring& name) { |
| 286 int slot = 0; | 286 int slot = 0; |
| 287 | 287 |
| 288 // Registering a thread requires that we lock the shared memory | 288 // Registering a thread requires that we lock the shared memory |
| 289 // so that two threads don't grab the same slot. Fortunately, | 289 // so that two threads don't grab the same slot. Fortunately, |
| 290 // thread creation shouldn't happen in inner loops. | 290 // thread creation shouldn't happen in inner loops. |
| 291 { | 291 { |
| 292 SharedMemoryAutoLock lock(impl_->shared_memory()); | 292 base::SharedMemoryAutoLock lock(impl_->shared_memory()); |
| 293 slot = FindEmptyThread(); | 293 slot = FindEmptyThread(); |
| 294 if (!slot) { | 294 if (!slot) { |
| 295 return 0; | 295 return 0; |
| 296 } | 296 } |
| 297 | 297 |
| 298 DCHECK(impl_); | 298 DCHECK(impl_); |
| 299 | 299 |
| 300 // We have space, so consume a column in the table. | 300 // We have space, so consume a column in the table. |
| 301 std::wstring thread_name = name; | 301 std::wstring thread_name = name; |
| 302 if (name.empty()) | 302 if (name.empty()) |
| 303 thread_name = kUnknownName; | 303 thread_name = kUnknownName; |
| 304 base::wcslcpy(impl_->thread_name(slot), thread_name.c_str(), | 304 base::wcslcpy(impl_->thread_name(slot), thread_name.c_str(), |
| 305 kMaxThreadNameLength); | 305 kMaxThreadNameLength); |
| 306 *(impl_->thread_tid(slot)) = PlatformThread::CurrentId(); | 306 *(impl_->thread_tid(slot)) = PlatformThread::CurrentId(); |
| 307 *(impl_->thread_pid(slot)) = process_util::GetCurrentProcId(); | 307 *(impl_->thread_pid(slot)) = base::GetCurrentProcId(); |
| 308 } | 308 } |
| 309 | 309 |
| 310 // Set our thread local storage. | 310 // Set our thread local storage. |
| 311 StatsTableTLSData* data = new StatsTableTLSData; | 311 StatsTableTLSData* data = new StatsTableTLSData; |
| 312 data->table = this; | 312 data->table = this; |
| 313 data->slot = slot; | 313 data->slot = slot; |
| 314 tls_index_.Set(data); | 314 tls_index_.Set(data); |
| 315 return slot; | 315 return slot; |
| 316 } | 316 } |
| 317 | 317 |
| (...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 447 int StatsTable::AddCounter(const std::wstring& name) { | 447 int StatsTable::AddCounter(const std::wstring& name) { |
| 448 DCHECK(impl_); | 448 DCHECK(impl_); |
| 449 | 449 |
| 450 if (!impl_) | 450 if (!impl_) |
| 451 return 0; | 451 return 0; |
| 452 | 452 |
| 453 int counter_id = 0; | 453 int counter_id = 0; |
| 454 { | 454 { |
| 455 // To add a counter to the shared memory, we need the | 455 // To add a counter to the shared memory, we need the |
| 456 // shared memory lock. | 456 // shared memory lock. |
| 457 SharedMemoryAutoLock lock(impl_->shared_memory()); | 457 base::SharedMemoryAutoLock lock(impl_->shared_memory()); |
| 458 | 458 |
| 459 // We have space, so create a new counter. | 459 // We have space, so create a new counter. |
| 460 counter_id = FindCounterOrEmptyRow(name); | 460 counter_id = FindCounterOrEmptyRow(name); |
| 461 if (!counter_id) | 461 if (!counter_id) |
| 462 return 0; | 462 return 0; |
| 463 | 463 |
| 464 std::wstring counter_name = name; | 464 std::wstring counter_name = name; |
| 465 if (name.empty()) | 465 if (name.empty()) |
| 466 counter_name = kUnknownName; | 466 counter_name = kUnknownName; |
| 467 base::wcslcpy(impl_->counter_name(counter_id), counter_name.c_str(), | 467 base::wcslcpy(impl_->counter_name(counter_id), counter_name.c_str(), |
| (...skipping 81 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 549 return NULL; | 549 return NULL; |
| 550 | 550 |
| 551 // Find the counter id for the counter. | 551 // Find the counter id for the counter. |
| 552 std::wstring str_name(name); | 552 std::wstring str_name(name); |
| 553 int counter = table->FindCounter(str_name); | 553 int counter = table->FindCounter(str_name); |
| 554 | 554 |
| 555 // Now we can find the location in the table. | 555 // Now we can find the location in the table. |
| 556 return table->GetLocation(counter, slot); | 556 return table->GetLocation(counter, slot); |
| 557 } | 557 } |
| 558 | 558 |
| OLD | NEW |