OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 COMPONENTS_METRICS_PROFILER_TRACKING_SYNCHRONIZER_H_ | 5 #ifndef COMPONENTS_METRICS_PROFILER_TRACKING_SYNCHRONIZER_H_ |
6 #define COMPONENTS_METRICS_PROFILER_TRACKING_SYNCHRONIZER_H_ | 6 #define COMPONENTS_METRICS_PROFILER_TRACKING_SYNCHRONIZER_H_ |
7 | 7 |
8 #include <map> | 8 #include <map> |
9 #include <string> | 9 #include <string> |
10 #include <vector> | 10 #include <vector> |
11 | 11 |
12 #include "base/basictypes.h" | 12 #include "base/basictypes.h" |
13 #include "base/lazy_instance.h" | 13 #include "base/lazy_instance.h" |
14 #include "base/memory/ref_counted.h" | 14 #include "base/memory/ref_counted.h" |
15 #include "base/memory/weak_ptr.h" | 15 #include "base/memory/weak_ptr.h" |
| 16 #include "base/time/time.h" |
| 17 #include "components/metrics/proto/chrome_user_metrics_extension.pb.h" |
16 #include "content/public/browser/profiler_subscriber.h" | 18 #include "content/public/browser/profiler_subscriber.h" |
17 | 19 |
18 // This class maintains state that is used to upload profiler data from the | 20 // This class maintains state that is used to upload profiler data from the |
19 // various processes, into the browser process. Such transactions are usually | 21 // various processes, into the browser process. Such transactions are usually |
20 // instigated by the browser. In general, a process will respond by gathering | 22 // instigated by the browser. In general, a process will respond by gathering |
21 // profiler data, and transmitting the pickled profiler data. We collect the | 23 // profiler data, and transmitting the pickled profiler data. We collect the |
22 // data in asynchronous mode that doesn't block the UI thread. | 24 // data in asynchronous mode that doesn't block the UI thread. |
23 // | 25 // |
24 // To assure that all the processes have responded, a counter is maintained | 26 // To assure that all the processes have responded, a counter is maintained |
25 // to indicate the number of pending (not yet responsive) processes. We tag | 27 // to indicate the number of pending (not yet responsive) processes. We tag |
(...skipping 18 matching lines...) Expand all Loading... |
44 // already completed, and will not need this instance any further. | 46 // already completed, and will not need this instance any further. |
45 TrackingSynchronizer(); | 47 TrackingSynchronizer(); |
46 | 48 |
47 // Contact all processes, and get them to upload to the browser any/all | 49 // Contact all processes, and get them to upload to the browser any/all |
48 // changes to profiler data. It calls |callback_object|'s SetData method with | 50 // changes to profiler data. It calls |callback_object|'s SetData method with |
49 // the data received from each sub-process. | 51 // the data received from each sub-process. |
50 // This method is accessible on UI thread. | 52 // This method is accessible on UI thread. |
51 static void FetchProfilerDataAsynchronously( | 53 static void FetchProfilerDataAsynchronously( |
52 const base::WeakPtr<TrackingSynchronizerObserver>& callback_object); | 54 const base::WeakPtr<TrackingSynchronizerObserver>& callback_object); |
53 | 55 |
| 56 // Called when a profiling phase completes. |profiling_event| is the event |
| 57 // associated with completing the phase and starting a new one. |
| 58 static void OnProfilingPhaseCompletion( |
| 59 ProfilerEventProto::ProfilerEvent profiling_event); |
| 60 |
54 // ------------------------------------------------------ | 61 // ------------------------------------------------------ |
55 // ProfilerSubscriber methods for browser child processes | 62 // ProfilerSubscriber methods for browser child processes |
56 // ------------------------------------------------------ | 63 // ------------------------------------------------------ |
57 | 64 |
58 // Update the number of pending processes for the given |sequence_number|. | 65 // Update the number of pending processes for the given |sequence_number|. |
59 // This is called on UI thread. | 66 // This is called on UI thread. |
60 void OnPendingProcesses(int sequence_number, | 67 void OnPendingProcesses(int sequence_number, |
61 int pending_processes, | 68 int pending_processes, |
62 bool end) override; | 69 bool end) override; |
63 | 70 |
(...skipping 13 matching lines...) Expand all Loading... |
77 const tracked_objects::ProcessDataSnapshot& profiler_data, | 84 const tracked_objects::ProcessDataSnapshot& profiler_data, |
78 int process_type) override; | 85 int process_type) override; |
79 | 86 |
80 // Establish a new sequence_number_, and use it to notify all the processes of | 87 // Establish a new sequence_number_, and use it to notify all the processes of |
81 // the need to supply, to the browser, their tracking data. It also registers | 88 // the need to supply, to the browser, their tracking data. It also registers |
82 // |callback_object| in |outstanding_requests_| map. Return the | 89 // |callback_object| in |outstanding_requests_| map. Return the |
83 // sequence_number_ that was used. This method is accessible on UI thread. | 90 // sequence_number_ that was used. This method is accessible on UI thread. |
84 int RegisterAndNotifyAllProcesses( | 91 int RegisterAndNotifyAllProcesses( |
85 const base::WeakPtr<TrackingSynchronizerObserver>& callback_object); | 92 const base::WeakPtr<TrackingSynchronizerObserver>& callback_object); |
86 | 93 |
| 94 // Notifies all processes of a completion profiling phase. |profiling_event| |
| 95 // is the event that caused the phase change. |
| 96 void NotifyAllProcessesOfProfilingPhaseCompletion( |
| 97 ProfilerEventProto::ProfilerEvent profiling_event); |
| 98 |
87 // It finds the RequestContext for the given |sequence_number| and notifies | 99 // It finds the RequestContext for the given |sequence_number| and notifies |
88 // the RequestContext's |callback_object_| about the |value|. This is called | 100 // the RequestContext's |callback_object_| about the |value|. This is called |
89 // whenever we receive profiler data from processes. It also records that we | 101 // whenever we receive profiler data from processes. It also records that we |
90 // are waiting for one less profiler data from a process for the given | 102 // are waiting for one less profiler data from a process for the given |
91 // sequence number. If we have received a response from all renderers and | 103 // sequence number. If we have received a response from all renderers and |
92 // browser processes, then it calls RequestContext's DeleteIfAllDone to delete | 104 // browser processes, then it calls RequestContext's DeleteIfAllDone to delete |
93 // the entry for sequence_number. This method is accessible on UI thread. | 105 // the entry for sequence_number. This method is accessible on UI thread. |
94 void DecrementPendingProcessesAndSendData( | 106 void DecrementPendingProcessesAndSendData( |
95 int sequence_number, | 107 int sequence_number, |
96 const tracked_objects::ProcessDataSnapshot& profiler_data, | 108 const tracked_objects::ProcessDataSnapshot& profiler_data, |
97 int process_type); | 109 int process_type); |
98 | 110 |
99 // Get a new sequence number to be sent to processes from browser process. | 111 // Get a new sequence number to be sent to processes from browser process. |
100 // This method is accessible on UI thread. | 112 // This method is accessible on UI thread. |
101 int GetNextAvailableSequenceNumber(); | 113 int GetNextAvailableSequenceNumber(); |
102 | 114 |
103 // We don't track the actual processes that are contacted for an update, only | 115 // We don't track the actual processes that are contacted for an update, only |
104 // the count of the number of processes, and we can sometimes time-out and | 116 // the count of the number of processes, and we can sometimes time-out and |
105 // give up on a "slow to respond" process. We use a sequence_number to be | 117 // give up on a "slow to respond" process. We use a sequence_number to be |
106 // sure a response from a process is associated with the current round of | 118 // sure a response from a process is associated with the current round of |
107 // requests. All sequence numbers used are non-negative. | 119 // requests. All sequence numbers used are non-negative. |
108 // last_used_sequence_number_ is the most recently used number (used to avoid | 120 // last_used_sequence_number_ is the most recently used number (used to avoid |
109 // reuse for a long time). | 121 // reuse for a long time). |
110 int last_used_sequence_number_; | 122 int last_used_sequence_number_; |
111 | 123 |
| 124 // Sequence of events associated with already completed profiling phases. The |
| 125 // index in the vector is the phase number. The current phase is not included. |
| 126 std::vector<ProfilerEventProto::ProfilerEvent> |
| 127 phase_completion_events_sequence_; |
| 128 |
| 129 // Time of the profiling start. Used to calculate times of phase change |
| 130 // moments relative to this value. |
| 131 const base::TimeTicks start_time_; |
| 132 |
| 133 // Times of starts of all profiling phases, including the current phase. The |
| 134 // index in the vector is the phase number. |
| 135 std::vector<base::TimeTicks> phase_start_times_; |
| 136 |
112 DISALLOW_COPY_AND_ASSIGN(TrackingSynchronizer); | 137 DISALLOW_COPY_AND_ASSIGN(TrackingSynchronizer); |
113 }; | 138 }; |
114 | 139 |
115 } // namespace metrics | 140 } // namespace metrics |
116 | 141 |
117 #endif // COMPONENTS_METRICS_PROFILER_TRACKING_SYNCHRONIZER_H_ | 142 #endif // COMPONENTS_METRICS_PROFILER_TRACKING_SYNCHRONIZER_H_ |
OLD | NEW |