Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(98)

Side by Side Diff: google_apis/gcm/monitoring/gcm_stats_recorder.h

Issue 261573002: Add checkin activity recording to gcm recorder. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: resolve conflicts. Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « google_apis/gcm/gcm_client_impl.cc ('k') | google_apis/gcm/monitoring/gcm_stats_recorder.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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
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
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_
OLDNEW
« no previous file with comments | « google_apis/gcm/gcm_client_impl.cc ('k') | google_apis/gcm/monitoring/gcm_stats_recorder.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698