| OLD | NEW |
| (Empty) |
| 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_GCM_DRIVER_GCM_CHANNEL_STATUS_SYNCER_H_ | |
| 6 #define COMPONENTS_GCM_DRIVER_GCM_CHANNEL_STATUS_SYNCER_H_ | |
| 7 | |
| 8 #include "base/compiler_specific.h" | |
| 9 #include "base/macros.h" | |
| 10 #include "base/memory/ref_counted.h" | |
| 11 #include "base/memory/scoped_ptr.h" | |
| 12 #include "base/memory/weak_ptr.h" | |
| 13 #include "base/time/time.h" | |
| 14 | |
| 15 class PrefService; | |
| 16 class PrefRegistrySimple; | |
| 17 | |
| 18 namespace net { | |
| 19 class URLRequestContextGetter; | |
| 20 } | |
| 21 | |
| 22 namespace user_prefs { | |
| 23 class PrefRegistrySyncable; | |
| 24 } | |
| 25 | |
| 26 namespace gcm { | |
| 27 | |
| 28 class GCMChannelStatusRequest; | |
| 29 class GCMDriver; | |
| 30 | |
| 31 // Syncing with the server for GCM channel status that controls if GCM | |
| 32 // functionality should be enabled or disabled. | |
| 33 class GCMChannelStatusSyncer { | |
| 34 public: | |
| 35 static void RegisterPrefs(PrefRegistrySimple* registry); | |
| 36 static void RegisterProfilePrefs(user_prefs::PrefRegistrySyncable* registry); | |
| 37 | |
| 38 GCMChannelStatusSyncer( | |
| 39 GCMDriver* driver, | |
| 40 PrefService* prefs, | |
| 41 const scoped_refptr<net::URLRequestContextGetter>& request_context); | |
| 42 ~GCMChannelStatusSyncer(); | |
| 43 | |
| 44 void EnsureStarted(); | |
| 45 void Stop(); | |
| 46 | |
| 47 bool gcm_enabled() const { return gcm_enabled_; } | |
| 48 | |
| 49 // For testing purpose. | |
| 50 void set_delay_removed_for_testing(bool delay_removed) { | |
| 51 delay_removed_for_testing_ = delay_removed; | |
| 52 } | |
| 53 base::TimeDelta current_request_delay_interval() const { | |
| 54 return current_request_delay_interval_; | |
| 55 } | |
| 56 static int first_time_delay_seconds(); | |
| 57 | |
| 58 private: | |
| 59 // Called when a request is completed. | |
| 60 void OnRequestCompleted(bool enabled, int poll_interval_seconds); | |
| 61 | |
| 62 // Schedules next request to start after appropriate delay. | |
| 63 void ScheduleRequest(); | |
| 64 | |
| 65 // Creates and starts a request immediately. | |
| 66 void StartRequest(); | |
| 67 | |
| 68 // Computes and returns a delay with the fuzzing variation added if needed, | |
| 69 // after which the request could start. | |
| 70 base::TimeDelta GetRequestDelayInterval() const; | |
| 71 | |
| 72 // GCMDriver owns GCMChannelStatusSyncer instance. | |
| 73 GCMDriver* driver_; | |
| 74 PrefService* prefs_; | |
| 75 | |
| 76 scoped_refptr<net::URLRequestContextGetter> request_context_; | |
| 77 scoped_ptr<GCMChannelStatusRequest> request_; | |
| 78 | |
| 79 bool gcm_enabled_; | |
| 80 int poll_interval_seconds_; | |
| 81 base::Time last_check_time_; | |
| 82 | |
| 83 // The flag that indicates if the delay, including fuzzing variation and poll | |
| 84 // interval, is removed for testing purpose. | |
| 85 bool delay_removed_for_testing_; | |
| 86 | |
| 87 // Tracked for testing purpose. | |
| 88 base::TimeDelta current_request_delay_interval_; | |
| 89 | |
| 90 // Used to pass a weak pointer to a task. | |
| 91 base::WeakPtrFactory<GCMChannelStatusSyncer> weak_ptr_factory_; | |
| 92 | |
| 93 DISALLOW_COPY_AND_ASSIGN(GCMChannelStatusSyncer); | |
| 94 }; | |
| 95 | |
| 96 } // namespace gcm | |
| 97 | |
| 98 #endif // COMPONENTS_GCM_DRIVER_GCM_CHANNEL_STATUS_SYNCER_H_ | |
| OLD | NEW |