1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
// Copyright 2016 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 "components/metrics/child_call_stack_profile_collector.h"
#include <utility>
#include "base/bind.h"
#include "base/bind_helpers.h"
#include "base/logging.h"
#include "base/synchronization/lock.h"
#include "base/threading/thread_task_runner_handle.h"
#include "services/service_manager/public/cpp/interface_provider.h"
namespace metrics {
ChildCallStackProfileCollector::ProfilesState::ProfilesState() = default;
ChildCallStackProfileCollector::ProfilesState::ProfilesState(ProfilesState&&) =
default;
ChildCallStackProfileCollector::ProfilesState::ProfilesState(
const CallStackProfileParams& params,
base::TimeTicks start_timestamp,
base::StackSamplingProfiler::CallStackProfiles profiles)
: params(params),
start_timestamp(start_timestamp),
profiles(std::move(profiles)) {}
ChildCallStackProfileCollector::ProfilesState::~ProfilesState() = default;
// Some versions of GCC need this for push_back to work with std::move.
ChildCallStackProfileCollector::ProfilesState&
ChildCallStackProfileCollector::ProfilesState::operator=(ProfilesState&&) =
default;
ChildCallStackProfileCollector::ChildCallStackProfileCollector() {}
ChildCallStackProfileCollector::~ChildCallStackProfileCollector() {}
base::StackSamplingProfiler::CompletedCallback
ChildCallStackProfileCollector::GetProfilerCallback(
const CallStackProfileParams& params) {
return base::Bind(&ChildCallStackProfileCollector::Collect,
// This class has lazy instance lifetime.
base::Unretained(this), params,
base::TimeTicks::Now());
}
void ChildCallStackProfileCollector::SetParentProfileCollector(
metrics::mojom::CallStackProfileCollectorPtr parent_collector) {
base::AutoLock alock(lock_);
// This function should only invoked once, during the mode of operation when
// retaining profiles after construction.
DCHECK(retain_profiles_);
retain_profiles_ = false;
task_runner_ = base::ThreadTaskRunnerHandle::Get();
parent_collector_ = std::move(parent_collector);
if (parent_collector_) {
for (ProfilesState& state : profiles_) {
parent_collector_->Collect(state.params, state.start_timestamp,
std::move(state.profiles));
}
}
profiles_.clear();
}
void ChildCallStackProfileCollector::Collect(
const CallStackProfileParams& params,
base::TimeTicks start_timestamp,
std::vector<CallStackProfile> profiles) {
base::AutoLock alock(lock_);
if (task_runner_ &&
// The profiler thread does not have a task runner. Attempting to
// invoke Get() on it results in a DCHECK.
(!base::ThreadTaskRunnerHandle::IsSet() ||
base::ThreadTaskRunnerHandle::Get() != task_runner_)) {
// Post back to the thread that owns the the parent interface.
task_runner_->PostTask(FROM_HERE, base::Bind(
&ChildCallStackProfileCollector::Collect,
// This class has lazy instance lifetime.
base::Unretained(this),
params,
start_timestamp,
base::Passed(std::move(profiles))));
return;
}
if (parent_collector_) {
parent_collector_->Collect(params, start_timestamp, std::move(profiles));
} else if (retain_profiles_) {
profiles_.push_back(
ProfilesState(params, start_timestamp, std::move(profiles)));
}
}
} // namespace metrics
|
