• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
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 // Scheduler task to drive a MetricsService object's uploading.
15 class MetricsReportingScheduler {
16  public:
17   explicit MetricsReportingScheduler(const base::Closure& upload_callback);
18   ~MetricsReportingScheduler();
19 
20   // Starts scheduling uploads. This in a no-op if the scheduler is already
21   // running, so it is safe to call more than once.
22   void Start();
23 
24   // Stops scheduling uploads.
25   void Stop();
26 
27   // Callback from MetricsService when the startup init task has completed.
28   void InitTaskComplete();
29 
30   // Callback from MetricsService when a triggered upload finishes.
31   void UploadFinished(bool server_is_healthy, bool more_logs_remaining);
32 
33   // Callback from MetricsService when a triggered upload is cancelled by the
34   // MetricsService.
35   void UploadCancelled();
36 
37   // Sets the upload interval to a specific value, exposed for unit tests.
38   void SetUploadIntervalForTesting(base::TimeDelta interval);
39 
40  private:
41   // Timer callback indicating it's time for the MetricsService to upload
42   // metrics.
43   void TriggerUpload();
44 
45   // Schedules a future call to TriggerUpload if one isn't already pending.
46   void ScheduleNextUpload();
47 
48   // Increases the upload interval each time it's called, to handle the case
49   // where the server is having issues.
50   void BackOffUploadInterval();
51 
52   // The MetricsService method to call when uploading should happen.
53   const base::Closure upload_callback_;
54 
55   base::OneShotTimer<MetricsReportingScheduler> upload_timer_;
56 
57   // The interval between being told an upload is done and starting the next
58   // upload.
59   base::TimeDelta upload_interval_;
60 
61   // Indicates that the scheduler is running (i.e., that Start has been called
62   // more recently than Stop).
63   bool running_;
64 
65   // Indicates that the last triggered upload hasn't resolved yet.
66   bool callback_pending_;
67 
68   // Whether the InitTaskComplete() callback has been called.
69   bool init_task_complete_;
70 
71   // Whether the initial scheduled upload timer has fired before the init task
72   // has been completed.
73   bool waiting_for_init_task_complete_;
74 
75   DISALLOW_COPY_AND_ASSIGN(MetricsReportingScheduler);
76 };
77 
78 #endif  // COMPONENTS_METRICS_METRICS_REPORTING_SCHEDULER_H_
79