| 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 |