Chromium Code Reviews| Index: services/resource_coordinator/memory/coordinator/process_map.cc |
| diff --git a/services/resource_coordinator/memory/coordinator/process_map.cc b/services/resource_coordinator/memory/coordinator/process_map.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..f5968e6aadd530f7e20530db7d084edf5e89443c |
| --- /dev/null |
| +++ b/services/resource_coordinator/memory/coordinator/process_map.cc |
| @@ -0,0 +1,59 @@ |
| +// Copyright 2017 The Chromium Authors. All rights reserved. |
| +// Use of this source code is governed by a BSD-style license that can be |
| +// found in the LICENSE file. |
| + |
| +#include "services/resource_coordinator/memory/coordinator/process_map.h" |
| + |
| +#include "base/process/process_handle.h" |
| +#include "mojo/public/cpp/bindings/binding.h" |
| +#include "services/resource_coordinator/public/interfaces/memory/memory_instrumentation.mojom.h" |
| +#include "services/service_manager/public/cpp/identity.h" |
| +#include "services/service_manager/public/interfaces/service_manager.mojom.h" |
| + |
| +namespace memory_instrumentation { |
| + |
| +ProcessMap::ProcessMap() : binding_(this) {} |
| + |
| +ProcessMap::~ProcessMap() {} |
| + |
| +void ProcessMap::BindRequest( |
| + service_manager::mojom::ServiceManagerListenerRequest request) { |
| + DCHECK(!binding_.is_bound()); |
|
Primiano Tucci (use gerrit)
2017/05/15 03:48:10
pass the connector and early-out if nullptr. This
erikchen
2017/05/15 17:29:15
Done.
|
| + binding_.Bind(std::move(request)); |
| +} |
| + |
| +void ProcessMap::OnInit(std::vector<RunningServiceInfoPtr> instances) { |
| + // This callback should only be called with an empty model. |
| + DCHECK(instances_.empty()); |
| + for (size_t i = 0; i < instances.size(); ++i) { |
| + const service_manager::Identity& identity = instances[i]->identity; |
| + instances_.emplace(identity, instances[i]->pid); |
| + } |
| +} |
| + |
| +void ProcessMap::OnServiceCreated(RunningServiceInfoPtr instance) { |
| + const service_manager::Identity& identity = instance->identity; |
| + // The instance should not already exists |
| + DCHECK(instances_.find(identity) == instances_.end()); |
| + instances_.emplace(identity, instance->pid); |
|
Primiano Tucci (use gerrit)
2017/05/15 03:48:10
i checked and, at least on Mac OS, pid at this poi
erikchen
2017/05/15 17:29:15
I added an early return to check for kNullProcessI
|
| +} |
| + |
| +void ProcessMap::OnServiceStarted(const service_manager::Identity& identity, |
| + uint32_t pid) { |
| + instances_[identity] = pid; |
| +} |
| + |
| +void ProcessMap::OnServiceStopped(const service_manager::Identity& identity) { |
| + DCHECK(instances_.find(identity) != instances_.end()); |
| + instances_.erase(identity); |
| +} |
| + |
| +base::ProcessId ProcessMap::GetProcessId( |
| + service_manager::Identity identity) const { |
| + auto instance = instances_.find(identity); |
| + if (instance == instances_.end()) |
| + return base::kNullProcessId; |
| + return instance->second; |
| +} |
| + |
| +} // namespace memory_instrumentation |