Chromium Code Reviews| Index: base/trace_event/memory_dump_manager.cc |
| diff --git a/base/trace_event/memory_dump_manager.cc b/base/trace_event/memory_dump_manager.cc |
| index bafd121af1e461cc246c3664d6b269079c9b752d..f66a7f908b452d63434bd3be75e59e6d87cdd8ce 100644 |
| --- a/base/trace_event/memory_dump_manager.cc |
| +++ b/base/trace_event/memory_dump_manager.cc |
| @@ -93,8 +93,7 @@ void MemoryDumpManager::SetInstanceForTesting(MemoryDumpManager* instance) { |
| } |
| MemoryDumpManager::MemoryDumpManager() |
| - : did_unregister_dump_provider_(false), |
| - delegate_(nullptr), |
| + : delegate_(nullptr), |
| memory_tracing_enabled_(0), |
| tracing_process_id_(kInvalidTracingProcessId), |
| system_allocator_pool_name_(nullptr), |
| @@ -152,7 +151,13 @@ void MemoryDumpManager::RegisterDumpProvider( |
| const scoped_refptr<SingleThreadTaskRunner>& task_runner) { |
| MemoryDumpProviderInfo mdp_info(mdp, task_runner); |
| AutoLock lock(lock_); |
| - dump_providers_.insert(mdp_info); |
| + auto iter_new = dump_providers_.insert(mdp_info); |
| + |
| + // If there was a previous entry, replace it with the new one. |
|
Primiano Tucci (use gerrit)
2015/08/24 09:31:19
Please add a comment here:
// This is to deal with
Ruud van Asseldonk
2015/08/24 10:08:37
Done.
|
| + if (!iter_new.second) { |
| + dump_providers_.erase(iter_new.first); |
| + dump_providers_.insert(mdp_info); |
| + } |
| } |
| void MemoryDumpManager::RegisterDumpProvider(MemoryDumpProvider* mdp) { |
| @@ -183,8 +188,7 @@ void MemoryDumpManager::UnregisterDumpProvider(MemoryDumpProvider* mdp) { |
| << "The MemoryDumpProvider attempted to unregister itself in a racy way. " |
| << "Please file a crbug."; |
| - dump_providers_.erase(mdp_iter); |
| - did_unregister_dump_provider_ = true; |
| + mdp_iter->unregistered = true; |
| } |
| void MemoryDumpManager::RequestGlobalDump(MemoryDumpType dump_type, |
| @@ -228,7 +232,6 @@ void MemoryDumpManager::CreateProcessDump(const MemoryDumpRequestArgs& args, |
| scoped_ptr<ProcessMemoryDumpAsyncState> pmd_async_state; |
| { |
| AutoLock lock(lock_); |
| - did_unregister_dump_provider_ = false; |
| pmd_async_state.reset(new ProcessMemoryDumpAsyncState( |
| args, dump_providers_.begin(), session_state_, callback)); |
| } |
| @@ -268,18 +271,10 @@ void MemoryDumpManager::ContinueAsyncProcessDump( |
| bool skip_dump = false; |
| { |
| AutoLock lock(lock_); |
| - // In the unlikely event that a dump provider was unregistered while |
| - // dumping, abort the dump, as that would make |next_dump_provider| invalid. |
| - // Registration, on the other hand, is safe as per std::set<> contract. |
| - if (did_unregister_dump_provider_) { |
| - return AbortDumpLocked(pmd_async_state->callback, |
| - pmd_async_state->task_runner, |
| - pmd_async_state->req_args.dump_guid); |
| - } |
| - auto* mdp_info = &*pmd_async_state->next_dump_provider; |
| + auto mdp_info = pmd_async_state->next_dump_provider; |
| mdp = mdp_info->dump_provider; |
| - if (mdp_info->disabled) { |
| + if (mdp_info->disabled || mdp_info->unregistered) { |
| skip_dump = true; |
| } else if (mdp_info->task_runner && |
| !mdp_info->task_runner->BelongsToCurrentThread()) { |
| @@ -318,12 +313,7 @@ void MemoryDumpManager::ContinueAsyncProcessDump( |
| { |
| AutoLock lock(lock_); |
| - if (did_unregister_dump_provider_) { |
| - return AbortDumpLocked(pmd_async_state->callback, |
| - pmd_async_state->task_runner, |
| - pmd_async_state->req_args.dump_guid); |
| - } |
| - auto* mdp_info = &*pmd_async_state->next_dump_provider; |
| + auto mdp_info = pmd_async_state->next_dump_provider; |
| if (dump_successful) { |
| mdp_info->consecutive_failures = 0; |
| } else if (!skip_dump) { |
| @@ -334,6 +324,10 @@ void MemoryDumpManager::ContinueAsyncProcessDump( |
| } |
| ++pmd_async_state->next_dump_provider; |
| finalize = pmd_async_state->next_dump_provider == dump_providers_.end(); |
| + |
| + if (mdp_info->unregistered) { |
|
Primiano Tucci (use gerrit)
2015/08/24 09:31:19
tip: you can omit the braces for single line ifs i
Ruud van Asseldonk
2015/08/24 10:08:37
Done.
|
| + dump_providers_.erase(mdp_info); |
| + } |
| } |
| if (!skip_dump && !dump_successful) { |
| @@ -454,8 +448,8 @@ MemoryDumpManager::MemoryDumpProviderInfo::MemoryDumpProviderInfo( |
| : dump_provider(dump_provider), |
| task_runner(task_runner), |
| consecutive_failures(0), |
| - disabled(false) { |
| -} |
| + disabled(false), |
| + unregistered(false) {} |
| MemoryDumpManager::MemoryDumpProviderInfo::~MemoryDumpProviderInfo() { |
| } |