OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 GOOGLE_APIS_GCM_GCM_STATS_RECORDER_H_ | 5 #ifndef GOOGLE_APIS_GCM_GCM_STATS_RECORDER_H_ |
6 #define GOOGLE_APIS_GCM_GCM_STATS_RECORDER_H_ | 6 #define GOOGLE_APIS_GCM_GCM_STATS_RECORDER_H_ |
7 | 7 |
8 #include <deque> | 8 #include <deque> |
9 #include <string> | 9 #include <string> |
10 #include <vector> | 10 #include <vector> |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
42 std::string event; // A short description of the event. | 42 std::string event; // A short description of the event. |
43 std::string details; // Any additional detail about the event. | 43 std::string details; // Any additional detail about the event. |
44 }; | 44 }; |
45 | 45 |
46 // Contains relevant data of a connection activity. | 46 // Contains relevant data of a connection activity. |
47 struct GCM_EXPORT ConnectionActivity : Activity { | 47 struct GCM_EXPORT ConnectionActivity : Activity { |
48 ConnectionActivity(); | 48 ConnectionActivity(); |
49 virtual ~ConnectionActivity(); | 49 virtual ~ConnectionActivity(); |
50 }; | 50 }; |
51 | 51 |
| 52 // Contains relevant data of a check-in activity. |
| 53 struct GCM_EXPORT CheckinActivity : Activity { |
| 54 CheckinActivity(); |
| 55 virtual ~CheckinActivity(); |
| 56 }; |
| 57 |
52 // Contains relevant data of a registration/unregistration step. | 58 // Contains relevant data of a registration/unregistration step. |
53 struct GCM_EXPORT RegistrationActivity : Activity { | 59 struct GCM_EXPORT RegistrationActivity : Activity { |
54 RegistrationActivity(); | 60 RegistrationActivity(); |
55 virtual ~RegistrationActivity(); | 61 virtual ~RegistrationActivity(); |
56 | 62 |
57 std::string app_id; | 63 std::string app_id; |
58 std::string sender_ids; // Comma separated sender ids. | 64 std::string sender_ids; // Comma separated sender ids. |
59 }; | 65 }; |
60 | 66 |
61 // Contains relevant data of a message receiving event. | 67 // Contains relevant data of a message receiving event. |
(...skipping 13 matching lines...) Expand all Loading... |
75 | 81 |
76 std::string app_id; | 82 std::string app_id; |
77 std::string receiver_id; | 83 std::string receiver_id; |
78 std::string message_id; | 84 std::string message_id; |
79 }; | 85 }; |
80 | 86 |
81 struct GCM_EXPORT RecordedActivities { | 87 struct GCM_EXPORT RecordedActivities { |
82 RecordedActivities(); | 88 RecordedActivities(); |
83 virtual ~RecordedActivities(); | 89 virtual ~RecordedActivities(); |
84 | 90 |
| 91 std::vector<GCMStatsRecorder::CheckinActivity> checkin_activities; |
85 std::vector<GCMStatsRecorder::ConnectionActivity> connection_activities; | 92 std::vector<GCMStatsRecorder::ConnectionActivity> connection_activities; |
86 std::vector<GCMStatsRecorder::RegistrationActivity> registration_activities; | 93 std::vector<GCMStatsRecorder::RegistrationActivity> registration_activities; |
87 std::vector<GCMStatsRecorder::ReceivingActivity> receiving_activities; | 94 std::vector<GCMStatsRecorder::ReceivingActivity> receiving_activities; |
88 std::vector<GCMStatsRecorder::SendingActivity> sending_activities; | 95 std::vector<GCMStatsRecorder::SendingActivity> sending_activities; |
89 }; | 96 }; |
90 | 97 |
91 GCMStatsRecorder(); | 98 GCMStatsRecorder(); |
92 virtual ~GCMStatsRecorder(); | 99 virtual ~GCMStatsRecorder(); |
93 | 100 |
94 // Indicates whether the recorder is currently recording activities or not. | 101 // Indicates whether the recorder is currently recording activities or not. |
95 bool is_recording() const { | 102 bool is_recording() const { |
96 return is_recording_; | 103 return is_recording_; |
97 } | 104 } |
98 | 105 |
99 // Turns recording on/off. | 106 // Turns recording on/off. |
100 void SetRecording(bool recording); | 107 void SetRecording(bool recording); |
101 | 108 |
102 // Clear all recorded activities. | 109 // Clear all recorded activities. |
103 void Clear(); | 110 void Clear(); |
104 | 111 |
105 // All RecordXXXX methods below will record one activity. It will be inserted | 112 // All RecordXXXX methods below will record one activity. It will be inserted |
106 // to the front of a queue so that entries in the queue had reverse | 113 // to the front of a queue so that entries in the queue had reverse |
107 // chronological order. | 114 // chronological order. |
108 | 115 |
| 116 // Records that a check-in has been initiated. |
| 117 void RecordCheckinInitiated(uint64 android_id); |
| 118 |
| 119 // Records that a check-in has been delayed due to backoff. |
| 120 void RecordCheckinDelayedDueToBackoff(int64 delay_msec); |
| 121 |
| 122 // Records that a check-in request has succeeded. |
| 123 void RecordCheckinSuccess(); |
| 124 |
| 125 // Records that a check-in request has failed. If a retry will be tempted then |
| 126 // will_retry should be true. |
| 127 void RecordCheckinFailure(std::string status, bool will_retry); |
| 128 |
109 // Records that a connection to MCS has been initiated. | 129 // Records that a connection to MCS has been initiated. |
110 void RecordConnectionInitiated(const std::string& host); | 130 void RecordConnectionInitiated(const std::string& host); |
111 | 131 |
112 // Records that a connection has been delayed due to backoff. | 132 // Records that a connection has been delayed due to backoff. |
113 void RecordConnectionDelayedDueToBackoff(int64 delay_msec); | 133 void RecordConnectionDelayedDueToBackoff(int64 delay_msec); |
114 | 134 |
115 // Records that connection has been successfully established. | 135 // Records that connection has been successfully established. |
116 void RecordConnectionSuccess(); | 136 void RecordConnectionSuccess(); |
117 | 137 |
118 // Records that connection has failed with a network error code. | 138 // Records that connection has failed with a network error code. |
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
175 int byte_size, | 195 int byte_size, |
176 int ttl); | 196 int ttl); |
177 // Records that a 'send error' message was received. | 197 // Records that a 'send error' message was received. |
178 void RecordIncomingSendError(const std::string& app_id, | 198 void RecordIncomingSendError(const std::string& app_id, |
179 const std::string& receiver_id, | 199 const std::string& receiver_id, |
180 const std::string& message_id); | 200 const std::string& message_id); |
181 | 201 |
182 // Collect all recorded activities into the struct. | 202 // Collect all recorded activities into the struct. |
183 void CollectActivities(RecordedActivities* recorder_activities) const; | 203 void CollectActivities(RecordedActivities* recorder_activities) const; |
184 | 204 |
| 205 const std::deque<CheckinActivity>& checkin_activities() const { |
| 206 return checkin_activities_; |
| 207 } |
185 const std::deque<ConnectionActivity>& connection_activities() const { | 208 const std::deque<ConnectionActivity>& connection_activities() const { |
186 return connection_activities_; | 209 return connection_activities_; |
187 } | 210 } |
188 const std::deque<RegistrationActivity>& registration_activities() const { | 211 const std::deque<RegistrationActivity>& registration_activities() const { |
189 return registration_activities_; | 212 return registration_activities_; |
190 } | 213 } |
191 const std::deque<ReceivingActivity>& receiving_activities() const { | 214 const std::deque<ReceivingActivity>& receiving_activities() const { |
192 return receiving_activities_; | 215 return receiving_activities_; |
193 } | 216 } |
194 const std::deque<SendingActivity>& sending_activities() const { | 217 const std::deque<SendingActivity>& sending_activities() const { |
195 return sending_activities_; | 218 return sending_activities_; |
196 } | 219 } |
197 | 220 |
198 protected: | 221 protected: |
| 222 void RecordCheckin(const std::string& event, |
| 223 const std::string& details); |
199 void RecordConnection(const std::string& event, | 224 void RecordConnection(const std::string& event, |
200 const std::string& details); | 225 const std::string& details); |
201 void RecordRegistration(const std::string& app_id, | 226 void RecordRegistration(const std::string& app_id, |
202 const std::string& sender_id, | 227 const std::string& sender_id, |
203 const std::string& event, | 228 const std::string& event, |
204 const std::string& details); | 229 const std::string& details); |
205 void RecordReceiving(const std::string& app_id, | 230 void RecordReceiving(const std::string& app_id, |
206 const std::string& from, | 231 const std::string& from, |
207 int message_byte_size, | 232 int message_byte_size, |
208 const std::string& event, | 233 const std::string& event, |
209 const std::string& details); | 234 const std::string& details); |
210 void RecordSending(const std::string& app_id, | 235 void RecordSending(const std::string& app_id, |
211 const std::string& receiver_id, | 236 const std::string& receiver_id, |
212 const std::string& message_id, | 237 const std::string& message_id, |
213 const std::string& event, | 238 const std::string& event, |
214 const std::string& details); | 239 const std::string& details); |
215 | 240 |
216 bool is_recording_; | 241 bool is_recording_; |
217 | 242 |
| 243 std::deque<CheckinActivity> checkin_activities_; |
218 std::deque<ConnectionActivity> connection_activities_; | 244 std::deque<ConnectionActivity> connection_activities_; |
219 std::deque<RegistrationActivity> registration_activities_; | 245 std::deque<RegistrationActivity> registration_activities_; |
220 std::deque<ReceivingActivity> receiving_activities_; | 246 std::deque<ReceivingActivity> receiving_activities_; |
221 std::deque<SendingActivity> sending_activities_; | 247 std::deque<SendingActivity> sending_activities_; |
222 | 248 |
223 DISALLOW_COPY_AND_ASSIGN(GCMStatsRecorder); | 249 DISALLOW_COPY_AND_ASSIGN(GCMStatsRecorder); |
224 }; | 250 }; |
225 | 251 |
226 } // namespace gcm | 252 } // namespace gcm |
227 | 253 |
228 #endif // GOOGLE_APIS_GCM_GCM_STATS_RECORDER_H_ | 254 #endif // GOOGLE_APIS_GCM_GCM_STATS_RECORDER_H_ |
OLD | NEW |