src/components/metrics/metrics_reporting_scheduler.h

   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
   3 // found in the LICENSE file.
   4
   5 #ifndef COMPONENTS_METRICS_METRICS_REPORTING_SCHEDULER_H_
   6 #define COMPONENTS_METRICS_METRICS_REPORTING_SCHEDULER_H_
   7
   8 #include "base/basictypes.h"
   9 #include "base/callback.h"
  10 #include "base/memory/weak_ptr.h"
  11 #include "base/time/time.h"
  12 #include "base/timer/timer.h"
  13
  14 namespace metrics {
  15
  16 // Scheduler task to drive a MetricsService object's uploading.
  17 class MetricsReportingScheduler {
  18  public:
  19   explicit MetricsReportingScheduler(const base::Closure& upload_callback);
  20   ~MetricsReportingScheduler();
  21
  22   // Starts scheduling uploads. This in a no-op if the scheduler is already
  23   // running, so it is safe to call more than once.
  24   void Start();
  25
  26   // Stops scheduling uploads.
  27   void Stop();
  28
  29   // Callback from MetricsService when the startup init task has completed.
  30   void InitTaskComplete();
  31
  32   // Callback from MetricsService when a triggered upload finishes.
  33   void UploadFinished(bool server_is_healthy, bool more_logs_remaining);
  34
  35   // Callback from MetricsService when a triggered upload is cancelled by the
  36   // MetricsService.
  37   void UploadCancelled();
  38
  39   // Sets the upload interval to a specific value, exposed for unit tests.
  40   void SetUploadIntervalForTesting(base::TimeDelta interval);
  41
  42  private:
  43   // Timer callback indicating it's time for the MetricsService to upload
  44   // metrics.
  45   void TriggerUpload();
  46
  47   // Schedules a future call to TriggerUpload if one isn't already pending.
  48   void ScheduleNextUpload();
  49
  50   // Increases the upload interval each time it's called, to handle the case
  51   // where the server is having issues.
  52   void BackOffUploadInterval();
  53
  54   // Returns upload interval based on the system and experiment that the user is
  55   // assigned to.
  56   // TODO(gayane): Only for experimenting with upload interval for Android
  57   // (bug: 17391128). Should be removed once the experiments are done.
  58   base::TimeDelta GetStandardUploadInterval();
  59
  60   // The MetricsService method to call when uploading should happen.
  61   const base::Closure upload_callback_;
  62
  63   base::OneShotTimer<MetricsReportingScheduler> upload_timer_;
  64
  65   // The interval between being told an upload is done and starting the next
  66   // upload.
  67   base::TimeDelta upload_interval_;
  68
  69   // The tick count of the last time log upload has been finished and null if no
  70   // upload has been done yet.
  71   base::TimeTicks last_upload_finish_time_;
  72
  73   // Indicates that the scheduler is running (i.e., that Start has been called
  74   // more recently than Stop).
  75   bool running_;
  76
  77   // Indicates that the last triggered upload hasn't resolved yet.
  78   bool callback_pending_;
  79
  80   // Whether the InitTaskComplete() callback has been called.
  81   bool init_task_complete_;
  82
  83   // Whether the initial scheduled upload timer has fired before the init task
  84   // has been completed.
  85   bool waiting_for_init_task_complete_;
  86
  87   DISALLOW_COPY_AND_ASSIGN(MetricsReportingScheduler);
  88 };
  89
  90 }  // namespace metrics
  91
  92 #endif  // COMPONENTS_METRICS_METRICS_REPORTING_SCHEDULER_H_