| Index: components/gcm_driver/gcm_stats_recorder_android.cc
 | 
| diff --git a/components/gcm_driver/gcm_stats_recorder_android.cc b/components/gcm_driver/gcm_stats_recorder_android.cc
 | 
| new file mode 100644
 | 
| index 0000000000000000000000000000000000000000..81746e3bc1b9a8913d7a399c59b1aff72fa6ba95
 | 
| --- /dev/null
 | 
| +++ b/components/gcm_driver/gcm_stats_recorder_android.cc
 | 
| @@ -0,0 +1,117 @@
 | 
| +// Copyright 2015 The Chromium Authors. All rights reserved.
 | 
| +// Use of this source code is governed by a BSD-style license that can be
 | 
| +// found in the LICENSE file.
 | 
| +
 | 
| +#include "components/gcm_driver/gcm_stats_recorder_android.h"
 | 
| +
 | 
| +namespace gcm {
 | 
| +
 | 
| +namespace {
 | 
| +
 | 
| +const size_t MAX_LOGGED_ACTIVITY_COUNT = 100;
 | 
| +
 | 
| +const char kSuccess[] = "SUCCESS";
 | 
| +const char kUnknownError[] = "UNKNOWN_ERROR";
 | 
| +
 | 
| +}  // namespace
 | 
| +
 | 
| +GCMStatsRecorderAndroid::GCMStatsRecorderAndroid(Delegate* delegate)
 | 
| +    : delegate_(delegate) {}
 | 
| +
 | 
| +GCMStatsRecorderAndroid::~GCMStatsRecorderAndroid() {}
 | 
| +
 | 
| +void GCMStatsRecorderAndroid::Clear() {
 | 
| +  registration_activities_.clear();
 | 
| +  receiving_activities_.clear();
 | 
| +}
 | 
| +
 | 
| +void GCMStatsRecorderAndroid::CollectActivities(
 | 
| +    RecordedActivities* recorded_activities) const {
 | 
| +  DCHECK(recorded_activities);
 | 
| +
 | 
| +  recorded_activities->registration_activities.insert(
 | 
| +      recorded_activities->registration_activities.begin(),
 | 
| +      registration_activities_.begin(),
 | 
| +      registration_activities_.end());
 | 
| +  recorded_activities->receiving_activities.insert(
 | 
| +      recorded_activities->receiving_activities.begin(),
 | 
| +      receiving_activities_.begin(),
 | 
| +      receiving_activities_.end());
 | 
| +}
 | 
| +
 | 
| +void GCMStatsRecorderAndroid::RecordRegistrationSent(
 | 
| +    const std::string& app_id) {
 | 
| +  if (!is_recording_)
 | 
| +    return;
 | 
| +
 | 
| +  RecordRegistration(app_id, "Registration request sent", "" /* details */);
 | 
| +}
 | 
| +
 | 
| +void GCMStatsRecorderAndroid::RecordRegistrationResponse(
 | 
| +    const std::string& app_id,
 | 
| +    bool success) {
 | 
| +  if (!is_recording_)
 | 
| +    return;
 | 
| +
 | 
| +  RecordRegistration(
 | 
| +      app_id, "Registration response received", success ? kSuccess
 | 
| +                                                        : kUnknownError);
 | 
| +}
 | 
| +
 | 
| +void GCMStatsRecorderAndroid::RecordUnregistrationSent(
 | 
| +    const std::string& app_id) {
 | 
| +  if (!is_recording_)
 | 
| +    return;
 | 
| +
 | 
| +  RecordRegistration(app_id, "Unregistration request sent", "" /* details */);
 | 
| +}
 | 
| +
 | 
| +void GCMStatsRecorderAndroid::RecordUnregistrationResponse(
 | 
| +    const std::string& app_id,
 | 
| +    bool success) {
 | 
| +  if (!is_recording_)
 | 
| +    return;
 | 
| +
 | 
| +  RecordRegistration(
 | 
| +      app_id, "Unregistration response received", success ? kSuccess
 | 
| +                                                          : kUnknownError);
 | 
| +}
 | 
| +
 | 
| +void GCMStatsRecorderAndroid::RecordRegistration(const std::string& app_id,
 | 
| +                                                 const std::string& event,
 | 
| +                                                 const std::string& details) {
 | 
| +  RegistrationActivity activity;
 | 
| +  activity.app_id = app_id;
 | 
| +  activity.event = event;
 | 
| +  activity.details = details;
 | 
| +
 | 
| +  // TODO(peter): Include the |source| (sender id(s)) of the registrations.
 | 
| +
 | 
| +  registration_activities_.push_front(activity);
 | 
| +  if (registration_activities_.size() > MAX_LOGGED_ACTIVITY_COUNT)
 | 
| +    registration_activities_.pop_back();
 | 
| +
 | 
| +  if (delegate_)
 | 
| +    delegate_->OnActivityRecorded();
 | 
| +}
 | 
| +
 | 
| +void GCMStatsRecorderAndroid::RecordDataMessageReceived(
 | 
| +    const std::string& app_id,
 | 
| +    int message_byte_size) {
 | 
| +  if (!is_recording_)
 | 
| +    return;
 | 
| +
 | 
| +  ReceivingActivity activity;
 | 
| +  activity.app_id = app_id;
 | 
| +  activity.message_byte_size = message_byte_size;
 | 
| +  activity.event = "Data msg received";
 | 
| +
 | 
| +  receiving_activities_.push_front(activity);
 | 
| +  if (receiving_activities_.size() > MAX_LOGGED_ACTIVITY_COUNT)
 | 
| +    receiving_activities_.pop_back();
 | 
| +
 | 
| +  if (delegate_)
 | 
| +    delegate_->OnActivityRecorded();
 | 
| +}
 | 
| +
 | 
| +}  // namespace gcm
 | 
| 
 |