OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef CHROME_BROWSER_CHROMEOS_POLICY_AFFILIATED_INVALIDATION_SERVICE_PROVIDER_
H_ | 5 #ifndef CHROME_BROWSER_CHROMEOS_POLICY_AFFILIATED_INVALIDATION_SERVICE_PROVIDER_
IMPL_H_ |
6 #define CHROME_BROWSER_CHROMEOS_POLICY_AFFILIATED_INVALIDATION_SERVICE_PROVIDER_
H_ | 6 #define CHROME_BROWSER_CHROMEOS_POLICY_AFFILIATED_INVALIDATION_SERVICE_PROVIDER_
IMPL_H_ |
7 | 7 |
8 #include "base/macros.h" | 8 #include "base/macros.h" |
9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
10 #include "base/memory/scoped_vector.h" | 10 #include "base/memory/scoped_vector.h" |
11 #include "base/observer_list.h" | 11 #include "base/observer_list.h" |
| 12 #include "chrome/browser/chromeos/policy/affiliated_invalidation_service_provide
r.h" |
12 #include "content/public/browser/notification_observer.h" | 13 #include "content/public/browser/notification_observer.h" |
13 #include "content/public/browser/notification_registrar.h" | 14 #include "content/public/browser/notification_registrar.h" |
14 | 15 |
15 namespace invalidation { | 16 namespace invalidation { |
16 class InvalidationService; | 17 class InvalidationService; |
17 class TiclInvalidationService; | 18 class TiclInvalidationService; |
18 } | 19 } |
19 | 20 |
20 namespace policy { | 21 namespace policy { |
21 | 22 |
22 // This class provides access to an |InvalidationService| that can be used to | 23 class AffiliatedInvalidationServiceProviderImpl |
23 // subscribe to invalidations generated by the device's enrollment domain, e.g. | 24 : public AffiliatedInvalidationServiceProvider, |
24 // policy pushing and remote commands for: | 25 public content::NotificationObserver { |
25 // * the device itself | |
26 // * device-local accounts | |
27 // * other users affiliated with the enrollment domain | |
28 // | |
29 // If an affiliated user with a connected invalidation service is logged in, | |
30 // that invalidation service will be used to conserve server resources. If there | |
31 // are no logged-in users matching these criteria, a device-global | |
32 // |TiclInvalidationService| is spun up. | |
33 // The class monitors the status of the invalidation services and switches | |
34 // between them whenever the service currently in use disconnects or the | |
35 // device-global invalidation service can be replaced with another service that | |
36 // just connected. | |
37 class AffiliatedInvalidationServiceProvider | |
38 : public content::NotificationObserver { | |
39 public: | 26 public: |
40 class Consumer { | 27 AffiliatedInvalidationServiceProviderImpl(); |
41 public: | 28 ~AffiliatedInvalidationServiceProviderImpl() override; |
42 // This method is called when the invalidation service that the consumer | |
43 // should use changes: | |
44 // * If |invalidation_service| is a nullptr, no invalidation service is | |
45 // currently available for use. | |
46 // * Otherwise, |invalidation_service| is the invalidation service that the | |
47 // consumer should use. It is guaranteed to be connected. Any previously | |
48 // provided invalidation services must no longer be used. | |
49 virtual void OnInvalidationServiceSet( | |
50 invalidation::InvalidationService* invalidation_service) = 0; | |
51 | |
52 protected: | |
53 virtual ~Consumer(); | |
54 }; | |
55 | |
56 AffiliatedInvalidationServiceProvider(); | |
57 ~AffiliatedInvalidationServiceProvider() override; | |
58 | 29 |
59 // content::NotificationObserver: | 30 // content::NotificationObserver: |
60 void Observe(int type, | 31 void Observe(int type, |
61 const content::NotificationSource& source, | 32 const content::NotificationSource& source, |
62 const content::NotificationDetails& details) override; | 33 const content::NotificationDetails& details) override; |
63 | 34 |
64 // Indicates that |consumer| is interested in using the shared | 35 // AffiliatedInvalidationServiceProvider: |
65 // |InvalidationService|. The consumer's OnInvalidationServiceSet() method | 36 void RegisterConsumer(Consumer* consumer) override; |
66 // will be called back when a connected invalidation service becomes | 37 void UnregisterConsumer(Consumer* consumer) override; |
67 // available. If an invalidation service is available already, the callback | 38 void Shutdown() override; |
68 // will occur synchronously. The |consumer| must be unregistered before |this| | |
69 // is destroyed. | |
70 void RegisterConsumer(Consumer* consumer); | |
71 | |
72 // Indicates that |consumer| is no longer interested in using the | |
73 // shared |InvalidationService|. | |
74 void UnregisterConsumer(Consumer* consumer); | |
75 | |
76 // Shuts down the provider. Once the provider is shut down, it no longer makes | |
77 // any invalidation service available to consumers, no longer observes any | |
78 // per-profile invalidation services and no longer maintains a device-global | |
79 // invalidation service. | |
80 void Shutdown(); | |
81 | 39 |
82 invalidation::TiclInvalidationService* | 40 invalidation::TiclInvalidationService* |
83 GetDeviceInvalidationServiceForTest() const; | 41 GetDeviceInvalidationServiceForTest() const; |
84 | 42 |
85 private: | 43 private: |
86 // Helper that monitors the status of a single |InvalidationService|. | 44 // Helper that monitors the status of a single |InvalidationService|. |
87 class InvalidationServiceObserver; | 45 class InvalidationServiceObserver; |
88 | 46 |
89 // Status updates received from |InvalidationServiceObserver|s. | 47 // Status updates received from |InvalidationServiceObserver|s. |
90 void OnInvalidationServiceConnected( | 48 void OnInvalidationServiceConnected( |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
125 // The invalidation service currently used by consumers. nullptr if there are | 83 // The invalidation service currently used by consumers. nullptr if there are |
126 // no registered consumers or no connected invalidation service is available | 84 // no registered consumers or no connected invalidation service is available |
127 // for use. | 85 // for use. |
128 invalidation::InvalidationService* invalidation_service_; | 86 invalidation::InvalidationService* invalidation_service_; |
129 | 87 |
130 ObserverList<Consumer, true> consumers_; | 88 ObserverList<Consumer, true> consumers_; |
131 int consumer_count_; | 89 int consumer_count_; |
132 | 90 |
133 bool is_shut_down_; | 91 bool is_shut_down_; |
134 | 92 |
135 DISALLOW_COPY_AND_ASSIGN(AffiliatedInvalidationServiceProvider); | 93 DISALLOW_COPY_AND_ASSIGN(AffiliatedInvalidationServiceProviderImpl); |
136 }; | 94 }; |
137 | 95 |
138 } // namespace policy | 96 } // namespace policy |
139 | 97 |
140 #endif // CHROME_BROWSER_CHROMEOS_POLICY_AFFILIATED_INVALIDATION_SERVICE_PROVID
ER_H_ | 98 #endif // CHROME_BROWSER_CHROMEOS_POLICY_AFFILIATED_INVALIDATION_SERVICE_PROVID
ER_IMPL_H_ |
OLD | NEW |