chrome/browser/chromeos/policy/status_uploader.h

   1 // Copyright (c) 2015 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 CHROME_BROWSER_CHROMEOS_POLICY_STATUS_UPLOADER_H_
   6 #define CHROME_BROWSER_CHROMEOS_POLICY_STATUS_UPLOADER_H_
   7
   8 #include "base/cancelable_callback.h"
   9 #include "base/memory/ref_counted.h"
  10 #include "base/memory/scoped_ptr.h"
  11 #include "base/memory/weak_ptr.h"
  12 #include "base/time/time.h"
  13 #include "chrome/browser/chromeos/settings/cros_settings.h"
  14 #include "components/policy/core/common/cloud/cloud_policy_constants.h"
  15 #include "policy/proto/device_management_backend.pb.h"
  16
  17 namespace base {
  18 class SequencedTaskRunner;
  19 }
  20
  21 namespace policy {
  22
  23 class CloudPolicyClient;
  24 class DeviceStatusCollector;
  25
  26 // Class responsible for periodically uploading device status from the
  27 // passed DeviceStatusCollector.
  28 class StatusUploader {
  29  public:
  30   // Refresh constants.
  31   static const int64 kDefaultUploadDelayMs;
  32
  33   // Constructor. |client| must be registered and must stay
  34   // valid and registered through the lifetime of this StatusUploader
  35   // object.
  36   StatusUploader(
  37       CloudPolicyClient* client,
  38       scoped_ptr<DeviceStatusCollector> collector,
  39       const scoped_refptr<base::SequencedTaskRunner>& task_runner);
  40
  41   ~StatusUploader();
  42
  43   // Returns the time of the last successful upload, or Time(0) if no upload
  44   // has ever happened.
  45   base::Time last_upload() const { return last_upload_; }
  46
  47  private:
  48   // Callback invoked periodically to upload the device status from the
  49   // DeviceStatusCollector.
  50   void UploadStatus();
  51
  52   // Invoked once a status upload has completed.
  53   void OnUploadCompleted(bool success);
  54
  55   // Helper method that figures out when the next status upload should
  56   // be scheduled.
  57   void ScheduleNextStatusUpload();
  58
  59   // Updates the upload frequency from settings and schedules a new upload
  60   // if appropriate.
  61   void RefreshUploadFrequency();
  62
  63   // CloudPolicyClient used to issue requests to the server.
  64   CloudPolicyClient* client_;
  65
  66   // DeviceStatusCollector that provides status for uploading.
  67   scoped_ptr<DeviceStatusCollector> collector_;
  68
  69   // TaskRunner used for scheduling upload tasks.
  70   const scoped_refptr<base::SequencedTaskRunner> task_runner_;
  71
  72   // How long to wait between status uploads.
  73   base::TimeDelta upload_frequency_;
  74
  75   // Observer to changes in the upload frequency.
  76   scoped_ptr<chromeos::CrosSettings::ObserverSubscription>
  77       upload_frequency_observer_;
  78
  79   // The time the last upload was performed.
  80   base::Time last_upload_;
  81
  82   // Callback invoked via a delay to upload device status.
  83   base::CancelableClosure upload_callback_;
  84
  85   // Note: This should remain the last member so it'll be destroyed and
  86   // invalidate the weak pointers before any other members are destroyed.
  87   base::WeakPtrFactory<StatusUploader> weak_factory_;
  88
  89   DISALLOW_COPY_AND_ASSIGN(StatusUploader);
  90 };
  91
  92 }  // namespace policy
  93
  94 #endif  // CHROME_BROWSER_CHROMEOS_POLICY_STATUS_UPLOADER_H_