chrome/browser/chromeos/policy/affiliated_invalidation_service_provider_impl.h

   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
   3 // found in the LICENSE file.
   4
   5 #ifndef CHROME_BROWSER_CHROMEOS_POLICY_AFFILIATED_INVALIDATION_SERVICE_PROVIDER_IMPL_H_
   6 #define CHROME_BROWSER_CHROMEOS_POLICY_AFFILIATED_INVALIDATION_SERVICE_PROVIDER_IMPL_H_
   7
   8 #include "base/macros.h"
   9 #include "base/memory/scoped_ptr.h"
  10 #include "base/memory/scoped_vector.h"
  11 #include "base/observer_list.h"
  12 #include "chrome/browser/chromeos/policy/affiliated_invalidation_service_provider.h"
  13 #include "content/public/browser/notification_observer.h"
  14 #include "content/public/browser/notification_registrar.h"
  15
  16 namespace invalidation {
  17 class InvalidationService;
  18 class TiclInvalidationService;
  19 }
  20
  21 namespace policy {
  22
  23 class AffiliatedInvalidationServiceProviderImpl
  24     : public AffiliatedInvalidationServiceProvider,
  25       public content::NotificationObserver {
  26  public:
  27   AffiliatedInvalidationServiceProviderImpl();
  28   ~AffiliatedInvalidationServiceProviderImpl() override;
  29
  30   // content::NotificationObserver:
  31   void Observe(int type,
  32                const content::NotificationSource& source,
  33                const content::NotificationDetails& details) override;
  34
  35   // AffiliatedInvalidationServiceProvider:
  36   void RegisterConsumer(Consumer* consumer) override;
  37   void UnregisterConsumer(Consumer* consumer) override;
  38   void Shutdown() override;
  39
  40   invalidation::TiclInvalidationService*
  41       GetDeviceInvalidationServiceForTest() const;
  42
  43  private:
  44   // Helper that monitors the status of a single |InvalidationService|.
  45   class InvalidationServiceObserver;
  46
  47   // Status updates received from |InvalidationServiceObserver|s.
  48   void OnInvalidationServiceConnected(
  49       invalidation::InvalidationService* invalidation_service);
  50   void OnInvalidationServiceDisconnected(
  51       invalidation::InvalidationService* invalidation_service);
  52
  53   // Checks whether a connected |InvalidationService| affiliated with the
  54   // device's enrollment domain is available. If so, notifies the consumers.
  55   // Otherwise, consumers will be notified once such an invalidation service
  56   // becomes available.
  57   // Further ensures that a device-global invalidation service is running iff
  58   // there is no other connected service available for use and there is at least
  59   // one registered consumer.
  60   void FindConnectedInvalidationService();
  61
  62   // Choose |invalidation_service| as the shared invalidation service and notify
  63   // consumers.
  64   void SetInvalidationService(
  65       invalidation::InvalidationService* invalidation_service);
  66
  67   // Destroy the device-global invalidation service, if any.
  68   void DestroyDeviceInvalidationService();
  69
  70   content::NotificationRegistrar registrar_;
  71
  72   // Device-global invalidation service.
  73   scoped_ptr<invalidation::TiclInvalidationService>
  74       device_invalidation_service_;
  75
  76   // State observer for the device-global invalidation service.
  77   scoped_ptr<InvalidationServiceObserver> device_invalidation_service_observer_;
  78
  79   // State observers for logged-in users' invalidation services.
  80   ScopedVector<InvalidationServiceObserver>
  81       profile_invalidation_service_observers_;
  82
  83   // The invalidation service currently used by consumers. nullptr if there are
  84   // no registered consumers or no connected invalidation service is available
  85   // for use.
  86   invalidation::InvalidationService* invalidation_service_;
  87
  88   ObserverList<Consumer, true> consumers_;
  89   int consumer_count_;
  90
  91   bool is_shut_down_;
  92
  93   DISALLOW_COPY_AND_ASSIGN(AffiliatedInvalidationServiceProviderImpl);
  94 };
  95
  96 }  // namespace policy
  97
  98 #endif  // CHROME_BROWSER_CHROMEOS_POLICY_AFFILIATED_INVALIDATION_SERVICE_PROVIDER_IMPL_H_