OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 #ifndef BASE_PROFILER_STACK_SAMPLING_PROFILER_H_ | 5 #ifndef BASE_PROFILER_STACK_SAMPLING_PROFILER_H_ |
6 #define BASE_PROFILER_STACK_SAMPLING_PROFILER_H_ | 6 #define BASE_PROFILER_STACK_SAMPLING_PROFILER_H_ |
7 | 7 |
8 #include <string> | 8 #include <string> |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
11 #include "base/base_export.h" | 11 #include "base/base_export.h" |
12 #include "base/callback.h" | 12 #include "base/callback.h" |
13 #include "base/files/file_path.h" | 13 #include "base/files/file_path.h" |
14 #include "base/memory/scoped_ptr.h" | 14 #include "base/memory/scoped_ptr.h" |
15 #include "base/strings/string16.h" | 15 #include "base/strings/string16.h" |
16 #include "base/threading/platform_thread.h" | 16 #include "base/threading/platform_thread.h" |
17 #include "base/time/time.h" | 17 #include "base/time/time.h" |
18 | 18 |
19 namespace base { | 19 namespace base { |
20 | 20 |
21 // StackSamplingProfiler periodically stops a thread to sample its stack, for | 21 // StackSamplingProfiler periodically stops a thread to sample its stack, for |
22 // the purpose of collecting information about which code paths are | 22 // the purpose of collecting information about which code paths are |
23 // executing. This information is used in aggregate by UMA to identify hot | 23 // executing. This information is used in aggregate by UMA to identify hot |
24 // and/or janky code paths. | 24 // and/or janky code paths. |
25 // | 25 // |
26 // Sample StackStackSamplingProfiler usage: | 26 // Sample StackSamplingProfiler usage: |
27 // | 27 // |
28 // // Create and customize params as desired. | 28 // // Create and customize params as desired. |
29 // base::StackStackSamplingProfiler::SamplingParams params; | 29 // base::StackStackSamplingProfiler::SamplingParams params; |
30 // // Any thread's ID may be passed as the target. | 30 // // Any thread's ID may be passed as the target. |
31 // base::StackSamplingProfiler profiler(base::PlatformThread::CurrentId()), | 31 // base::StackSamplingProfiler profiler(base::PlatformThread::CurrentId()), |
32 // params); | 32 // params); |
33 // | 33 // |
34 // // To process the profiles within Chrome rather than via UMA, set a custom | 34 // // To process the profiles within Chrome rather than via UMA, set a custom |
35 // // completed callback: | 35 // // completed callback: |
36 // base::Callback<void(const std::vector<Profile>&)> | 36 // base::StackStackSamplingProfiler::CompletedCallback |
37 // thread_safe_callback = ...; | 37 // thread_safe_callback = ...; |
38 // profiler.SetCustomCompletedCallback(thread_safe_callback); | 38 // profiler.SetCustomCompletedCallback(thread_safe_callback); |
39 // | 39 // |
40 // profiler.Start(); | 40 // profiler.Start(); |
41 // // ... work being done on the target thread here ... | 41 // // ... work being done on the target thread here ... |
42 // profiler.Stop(); // optional, stops collection before complete per params | 42 // profiler.Stop(); // optional, stops collection before complete per params |
43 // | 43 // |
| 44 // The default SamplingParams causes stacks to be recorded in a single burst at |
| 45 // a 10Hz interval for a total of 30 seconds. All of these parameters may be |
| 46 // altered as desired. |
| 47 // |
44 // When all profiles are complete or the profiler is stopped, if the custom | 48 // When all profiles are complete or the profiler is stopped, if the custom |
45 // completed callback was set it will be called from the profiler thread with | 49 // completed callback was set it is called from the profiler thread with the |
46 // the completed profiles. If no callback was set, the profiles are stored | 50 // completed profiles. A profile is considered complete if all requested samples |
47 // internally and retrieved for UMA through | 51 // were recorded for the profile (i.e. it was not stopped prematurely). If no |
48 // GetPendingProfiles(). GetPendingProfiles() should never be called by other | 52 // callback was set, the completed profiles are stored internally and retrieved |
49 // code; to retrieve profiles for in-process processing, set a completed | 53 // for UMA through GetPendingProfiles(). GetPendingProfiles() should never be |
50 // callback. | 54 // called by other code; to retrieve profiles for in-process processing, set a |
| 55 // completed callback. |
| 56 // |
| 57 // The results of the profiling are passed to the completed callback and consist |
| 58 // of a vector of Profiles. Each Profile corresponds to a burst as specified in |
| 59 // SamplingParams and contains a set of Samples and Modules. One Sample |
| 60 // corresponds to a single recorded stack, and the Modules record those modules |
| 61 // associated with the recorded stack frames. |
51 class BASE_EXPORT StackSamplingProfiler { | 62 class BASE_EXPORT StackSamplingProfiler { |
52 public: | 63 public: |
53 // Module represents the module (DLL or exe) corresponding to a stack frame. | 64 // Module represents the module (DLL or exe) corresponding to a stack frame. |
54 struct Module { | 65 struct Module { |
55 Module(); | 66 Module(); |
56 ~Module(); | 67 ~Module(); |
57 | 68 |
58 // Points to the base address of the module. | 69 // Points to the base address of the module. |
59 const void* base_address; | 70 const void* base_address; |
60 // An opaque binary string that uniquely identifies a particular program | 71 // An opaque binary string that uniquely identifies a particular program |
61 // version with high probability. This is parsed from headers of the loaded | 72 // version with high probability. This is parsed from headers of the loaded |
62 // module. | 73 // module. |
63 // For binaries generated by GNU tools: | 74 // For binaries generated by GNU tools: |
64 // Contents of the .note.gnu.build-id field. | 75 // Contents of the .note.gnu.build-id field. |
65 // On Windows: | 76 // On Windows: |
66 // GUID + AGE in the debug image headers of a module. | 77 // GUID + AGE in the debug image headers of a module. |
67 std::string id; | 78 std::string id; |
68 // The filename of the module. | 79 // The filename of the module. |
69 FilePath filename; | 80 FilePath filename; |
70 }; | 81 }; |
71 | 82 |
72 // Frame represents an individual sampled stack frame with module information. | 83 // Frame represents an individual sampled stack frame with module information. |
73 struct Frame { | 84 struct Frame { |
74 Frame(); | 85 Frame(const void* instruction_pointer, size_t module_index); |
75 ~Frame(); | 86 ~Frame(); |
76 | 87 |
77 // The sampled instruction pointer within the function. | 88 // The sampled instruction pointer within the function. |
78 const void* instruction_pointer; | 89 const void* instruction_pointer; |
79 // Index of the module in the array of modules. We don't represent module | 90 // Index of the module in Profile::modules. We don't represent module state |
80 // state directly here to save space. | 91 // directly here to save space. |
81 int module_index; | 92 size_t module_index; |
| 93 |
| 94 // Identifies a unknown module. |
| 95 static const size_t kUnknownModuleIndex = static_cast<size_t>(-1); |
82 }; | 96 }; |
83 | 97 |
84 // Sample represents a set of stack frames. | 98 // Sample represents a set of stack frames. |
85 using Sample = std::vector<Frame>; | 99 using Sample = std::vector<Frame>; |
86 | 100 |
87 // Profile represents a set of samples. | 101 // Profile represents a set of samples. |
88 struct BASE_EXPORT Profile { | 102 struct BASE_EXPORT Profile { |
89 Profile(); | 103 Profile(); |
90 ~Profile(); | 104 ~Profile(); |
91 | 105 |
92 std::vector<Module> modules; | 106 std::vector<Module> modules; |
93 std::vector<Sample> samples; | 107 std::vector<Sample> samples; |
94 // Duration of this profile. | 108 // Duration of this profile. |
95 TimeDelta profile_duration; | 109 TimeDelta profile_duration; |
96 // Time between samples. | 110 // Time between samples. |
97 TimeDelta sampling_period; | 111 TimeDelta sampling_period; |
98 // True if sample ordering is important and should be preserved if and when | 112 // True if sample ordering is important and should be preserved if and when |
99 // this profile is compressed and processed. | 113 // this profile is compressed and processed. |
100 bool preserve_sample_ordering; | 114 bool preserve_sample_ordering; |
101 }; | 115 }; |
102 | 116 |
103 // NativeStackSampler abstracts the native implementation required to record a | 117 // NativeStackSampler abstracts the native implementation required to record a |
104 // stack sample for a given thread. | 118 // stack sample for a given thread. |
105 class NativeStackSampler { | 119 class NativeStackSampler { |
106 public: | 120 public: |
107 virtual ~NativeStackSampler(); | 121 virtual ~NativeStackSampler(); |
108 | 122 |
109 // Create a stack sampler that records samples for |thread_handle|. Returns | 123 // Creates a stack sampler that records samples for |thread_handle|. Returns |
110 // null if this platform does not support stack sampling. | 124 // null if this platform does not support stack sampling. |
111 static scoped_ptr<NativeStackSampler> Create(PlatformThreadId thread_id); | 125 static scoped_ptr<NativeStackSampler> Create(PlatformThreadId thread_id); |
112 | 126 |
113 // Notify the sampler that we're starting to record a new profile. This | 127 // Notifies the sampler that we're starting to record a new profile. This |
114 // function is called on the SamplingThread. | 128 // function is called on the thread used for sampling. |
115 virtual void ProfileRecordingStarting(Profile* profile) = 0; | 129 virtual void ProfileRecordingStarting(Profile* profile) = 0; |
116 | 130 |
117 // Record a stack sample. This function is called on the SamplingThread. | 131 // Records a stack sample. This function is called on the thread used for |
| 132 // sampling. |
118 virtual void RecordStackSample(Sample* sample) = 0; | 133 virtual void RecordStackSample(Sample* sample) = 0; |
119 | 134 |
120 // Notify the sampler that we've stopped recording the current profile. This | 135 // Notifies the sampler that we've stopped recording the current |
121 // function is called on the SamplingThread. | 136 // profile. This function is called on the thread used for sampling. |
122 virtual void ProfileRecordingStopped() = 0; | 137 virtual void ProfileRecordingStopped() = 0; |
123 | 138 |
124 protected: | 139 protected: |
125 NativeStackSampler(); | 140 NativeStackSampler(); |
126 | 141 |
127 private: | 142 private: |
128 DISALLOW_COPY_AND_ASSIGN(NativeStackSampler); | 143 DISALLOW_COPY_AND_ASSIGN(NativeStackSampler); |
129 }; | 144 }; |
130 | 145 |
131 // Represents parameters that configure the sampling. | 146 // Represents parameters that configure the sampling. |
132 struct BASE_EXPORT SamplingParams { | 147 struct BASE_EXPORT SamplingParams { |
133 SamplingParams(); | 148 SamplingParams(); |
134 | 149 |
135 // Time to delay before first samples are taken. Defaults to 0. | 150 // Time to delay before first samples are taken. Defaults to 0. |
136 TimeDelta initial_delay; | 151 TimeDelta initial_delay; |
137 // Number of sampling bursts to perform. Defaults to 1. | 152 // Number of sampling bursts to perform. Defaults to 1. |
138 int bursts; | 153 int bursts; |
139 // Interval between sampling bursts. This is the desired duration from the | 154 // Interval between sampling bursts. This is the desired duration from the |
140 // start of one burst to the start of the next burst. Defaults to 10s. | 155 // start of one burst to the start of the next burst. Defaults to 10s. |
141 TimeDelta burst_interval; | 156 TimeDelta burst_interval; |
142 // Number of samples to record per burst. Defaults to 300. | 157 // Number of samples to record per burst. Defaults to 300. |
143 int samples_per_burst; | 158 int samples_per_burst; |
144 // Interval between samples during a sampling burst. This is the desired | 159 // Interval between samples during a sampling burst. This is the desired |
145 // duration from the start of one burst to the start of the next | 160 // duration from the start of one sample to the start of the next |
146 // burst. Defaults to 100ms. | 161 // sample. Defaults to 100ms. |
147 TimeDelta sampling_interval; | 162 TimeDelta sampling_interval; |
148 // True if sample ordering is important and should be preserved if and when | 163 // True if sample ordering is important and should be preserved if and when |
149 // this profile is compressed and processed. Defaults to false. | 164 // this profile is compressed and processed. Defaults to false. |
150 bool preserve_sample_ordering; | 165 bool preserve_sample_ordering; |
151 }; | 166 }; |
152 | 167 |
| 168 using CompletedCallback = Callback<void(const std::vector<Profile>&)>; |
| 169 |
153 StackSamplingProfiler(PlatformThreadId thread_id, | 170 StackSamplingProfiler(PlatformThreadId thread_id, |
154 const SamplingParams& params); | 171 const SamplingParams& params); |
155 ~StackSamplingProfiler(); | 172 ~StackSamplingProfiler(); |
156 | 173 |
157 // Initializes the profiler and starts sampling. | 174 // Initializes the profiler and starts sampling. |
158 void Start(); | 175 void Start(); |
| 176 |
159 // Stops the profiler and any ongoing sampling. Calling this function is | 177 // Stops the profiler and any ongoing sampling. Calling this function is |
160 // optional; if not invoked profiling will terminate when all the profiling | 178 // optional; if not invoked profiling terminates when all the profiling bursts |
161 // bursts specified in the SamplingParams are completed. | 179 // specified in the SamplingParams are completed. |
162 void Stop(); | 180 void Stop(); |
163 | 181 |
164 // Gets the pending profiles into *|profiles| and clears the internal | 182 // Moves all pending profiles from internal storage to |profiles|. This |
165 // storage. This function is thread safe. | 183 // function is thread safe. |
166 // | 184 // |
167 // ***This is intended for use only by UMA.*** Callers who want to process the | 185 // ***This is intended for use only by UMA.*** Callers who want to process the |
168 // collected profiles should use SetCustomCompletedCallback. | 186 // collected profiles should use SetCustomCompletedCallback. |
169 static void GetPendingProfiles(std::vector<Profile>* profiles); | 187 static void GetPendingProfiles(std::vector<Profile>* profiles); |
170 | 188 |
171 // By default, collected profiles are stored internally and can be retrieved | 189 // By default, collected profiles are stored internally and can be retrieved |
172 // by GetPendingProfiles. If a callback is provided via this function, | 190 // by GetPendingProfiles. If a callback is provided via this function, |
173 // however, it will be called with the collected profiles instead. Note that | 191 // however, it is called with the collected profiles instead. Note that the |
174 // this call to the callback occurs *on the profiler thread*. | 192 // call to the callback occurs *on the profiler thread*. |
175 void SetCustomCompletedCallback( | 193 void set_custom_completed_callback(CompletedCallback callback) { |
176 Callback<void(const std::vector<Profile>&)> callback); | 194 custom_completed_callback_ = callback; |
| 195 } |
177 | 196 |
178 private: | 197 private: |
| 198 // SamplingThread is a separate thread used to suspend and sample stacks from |
| 199 // the target thread. |
179 class SamplingThread; | 200 class SamplingThread; |
180 struct SamplingThreadDeleter { | 201 struct SamplingThreadDeleter { |
181 void operator() (SamplingThread* thread) const; | 202 void operator() (SamplingThread* thread) const; |
182 }; | 203 }; |
183 | 204 |
184 // The thread whose stack will be sampled. | 205 // The thread whose stack will be sampled. |
185 PlatformThreadId thread_id_; | 206 PlatformThreadId thread_id_; |
186 | 207 |
187 const SamplingParams params_; | 208 const SamplingParams params_; |
188 | 209 |
189 scoped_ptr<SamplingThread, SamplingThreadDeleter> sampling_thread_; | 210 scoped_ptr<SamplingThread, SamplingThreadDeleter> sampling_thread_; |
190 scoped_ptr<NativeStackSampler> native_sampler_; | 211 scoped_ptr<NativeStackSampler> native_sampler_; |
191 | 212 |
192 Callback<void(const std::vector<Profile>&)> custom_completed_callback_; | 213 CompletedCallback custom_completed_callback_; |
193 | 214 |
194 DISALLOW_COPY_AND_ASSIGN(StackSamplingProfiler); | 215 DISALLOW_COPY_AND_ASSIGN(StackSamplingProfiler); |
195 }; | 216 }; |
196 | 217 |
197 // Defined to allow equality check of Samples. | 218 // Defined to allow equality check of Samples. |
198 BASE_EXPORT bool operator==(const StackSamplingProfiler::Frame& a, | 219 BASE_EXPORT bool operator==(const StackSamplingProfiler::Frame& a, |
199 const StackSamplingProfiler::Frame& b); | 220 const StackSamplingProfiler::Frame& b); |
200 // Defined to allow ordering of Samples. | 221 // Defined to allow ordering of Samples. |
201 BASE_EXPORT bool operator<(const StackSamplingProfiler::Frame& a, | 222 BASE_EXPORT bool operator<(const StackSamplingProfiler::Frame& a, |
202 const StackSamplingProfiler::Frame& b); | 223 const StackSamplingProfiler::Frame& b); |
203 | 224 |
204 } // namespace base | 225 } // namespace base |
205 | 226 |
206 #endif // BASE_PROFILER_STACK_SAMPLING_PROFILER_H_ | 227 #endif // BASE_PROFILER_STACK_SAMPLING_PROFILER_H_ |
| 228 |
OLD | NEW |