| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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_POLICY_ASYNCHRONOUS_POLICY_LOADER_H_ | 5 #ifndef CHROME_BROWSER_POLICY_ASYNCHRONOUS_POLICY_LOADER_H_ |
| 6 #define CHROME_BROWSER_POLICY_ASYNCHRONOUS_POLICY_LOADER_H_ | 6 #define CHROME_BROWSER_POLICY_ASYNCHRONOUS_POLICY_LOADER_H_ |
| 7 #pragma once | 7 #pragma once |
| 8 | 8 |
| 9 #include "base/callback.h" | 9 #include "base/callback.h" |
| 10 #include "base/memory/ref_counted.h" | 10 #include "base/memory/ref_counted.h" |
| 11 #include "base/memory/scoped_ptr.h" | 11 #include "base/memory/scoped_ptr.h" |
| 12 #include "base/memory/weak_ptr.h" | 12 #include "base/memory/weak_ptr.h" |
| 13 #include "base/time.h" | 13 #include "base/time.h" |
| 14 #include "chrome/browser/policy/asynchronous_policy_provider.h" | 14 #include "chrome/browser/policy/asynchronous_policy_provider.h" |
| 15 #include "chrome/browser/policy/configuration_policy_provider.h" | |
| 16 #include "chrome/browser/policy/policy_map.h" | |
| 17 | 15 |
| 18 class MessageLoop; | 16 class MessageLoop; |
| 19 | 17 |
| 20 namespace policy { | 18 namespace policy { |
| 21 | 19 |
| 20 class PolicyBundle; |
| 21 class PolicyMap; |
| 22 |
| 22 // Used by the implementation of asynchronous policy provider to manage the | 23 // Used by the implementation of asynchronous policy provider to manage the |
| 23 // tasks on the FILE thread that do the heavy lifting of loading policies. | 24 // tasks on the FILE thread that do the heavy lifting of loading policies. |
| 24 class AsynchronousPolicyLoader | 25 class AsynchronousPolicyLoader |
| 25 : public base::RefCountedThreadSafe<AsynchronousPolicyLoader> { | 26 : public base::RefCountedThreadSafe<AsynchronousPolicyLoader> { |
| 26 public: | 27 public: |
| 28 // The type of the callback passed to Init(). |
| 29 typedef base::Callback<void(scoped_ptr<PolicyBundle>)> UpdateCallback; |
| 30 |
| 27 AsynchronousPolicyLoader(AsynchronousPolicyProvider::Delegate* delegate, | 31 AsynchronousPolicyLoader(AsynchronousPolicyProvider::Delegate* delegate, |
| 28 int reload_interval_minutes); | 32 int reload_interval_minutes); |
| 29 | 33 |
| 30 // Triggers initial policy load, and installs |callback| as the callback to | 34 // Triggers initial policy load, and installs |callback| as the callback to |
| 31 // invoke on policy updates. | 35 // invoke on policy updates. |callback| takes ownership of the passed |
| 32 virtual void Init(const base::Closure& callback); | 36 // PolicyBundle, which contains all the policies that were loaded. |
| 37 virtual void Init(const UpdateCallback& callback); |
| 33 | 38 |
| 34 // Reloads policy, sending notification of changes if necessary. Must be | 39 // Reloads policy, sending notification of changes if necessary. Must be |
| 35 // called on the FILE thread. When |force| is true, the loader should do an | 40 // called on the FILE thread. When |force| is true, the loader should do an |
| 36 // immediate full reload. | 41 // immediate full reload. |
| 37 virtual void Reload(bool force); | 42 virtual void Reload(bool force); |
| 38 | 43 |
| 39 // Stops any pending reload tasks. Updates callbacks won't be performed | 44 // Stops any pending reload tasks. Updates callbacks won't be performed |
| 40 // anymore once the loader is stopped. | 45 // anymore once the loader is stopped. |
| 41 virtual void Stop(); | 46 virtual void Stop(); |
| 42 | 47 |
| 43 const PolicyMap& policy() const { return policy_; } | |
| 44 | |
| 45 protected: | 48 protected: |
| 46 // AsynchronousPolicyLoader objects should only be deleted by | 49 // AsynchronousPolicyLoader objects should only be deleted by |
| 47 // RefCountedThreadSafe. | 50 // RefCountedThreadSafe. |
| 48 friend class base::RefCountedThreadSafe<AsynchronousPolicyLoader>; | 51 friend class base::RefCountedThreadSafe<AsynchronousPolicyLoader>; |
| 49 virtual ~AsynchronousPolicyLoader(); | 52 virtual ~AsynchronousPolicyLoader(); |
| 50 | 53 |
| 51 // Schedules a call to UpdatePolicy on |origin_loop_|. Takes ownership of | 54 // Schedules a call to UpdatePolicy on |origin_loop_|. Takes ownership of |
| 52 // |new_policy|. | 55 // |new_policy|. |
| 53 void PostUpdatePolicyTask(PolicyMap* new_policy); | 56 void PostUpdatePolicyTask(PolicyMap* new_policy); |
| 54 | 57 |
| (...skipping 20 matching lines...) Expand all Loading... |
| 75 // Invoked from the reload task on the FILE thread. | 78 // Invoked from the reload task on the FILE thread. |
| 76 void ReloadFromTask(); | 79 void ReloadFromTask(); |
| 77 | 80 |
| 78 private: | 81 private: |
| 79 friend class AsynchronousPolicyLoaderTest; | 82 friend class AsynchronousPolicyLoaderTest; |
| 80 | 83 |
| 81 // Finishes loader initialization after the threading system has been fully | 84 // Finishes loader initialization after the threading system has been fully |
| 82 // intialized. | 85 // intialized. |
| 83 void InitAfterFileThreadAvailable(); | 86 void InitAfterFileThreadAvailable(); |
| 84 | 87 |
| 85 // Replaces the existing policy to value map with a new one, sending | 88 // Invokes the |update_callback_| with a new PolicyBundle that maps |
| 86 // notification to the observers if there is a policy change. Must be called | 89 // the chrome namespace to |policy|. Must be called on |origin_loop_| so that |
| 87 // on |origin_loop_| so that it's safe to call back into the provider, which | 90 // it's safe to invoke |update_callback_|. |
| 88 // is not thread-safe. Takes ownership of |new_policy|. | 91 void UpdatePolicy(scoped_ptr<PolicyMap> policy); |
| 89 void UpdatePolicy(PolicyMap* new_policy); | |
| 90 | 92 |
| 91 // Provides the low-level mechanics for loading policy. | 93 // Provides the low-level mechanics for loading policy. |
| 92 scoped_ptr<AsynchronousPolicyProvider::Delegate> delegate_; | 94 scoped_ptr<AsynchronousPolicyProvider::Delegate> delegate_; |
| 93 | 95 |
| 94 // Current policy. | |
| 95 PolicyMap policy_; | |
| 96 | |
| 97 // Used to create and invalidate WeakPtrs on the FILE thread. These are only | 96 // Used to create and invalidate WeakPtrs on the FILE thread. These are only |
| 98 // used to post reload tasks that can be cancelled. | 97 // used to post reload tasks that can be cancelled. |
| 99 base::WeakPtrFactory<AsynchronousPolicyLoader> weak_ptr_factory_; | 98 base::WeakPtrFactory<AsynchronousPolicyLoader> weak_ptr_factory_; |
| 100 | 99 |
| 101 // The interval at which a policy reload will be triggered as a fallback. | 100 // The interval at which a policy reload will be triggered as a fallback. |
| 102 const base::TimeDelta reload_interval_; | 101 const base::TimeDelta reload_interval_; |
| 103 | 102 |
| 104 // The message loop on which this object was constructed. Recorded so that | 103 // The message loop on which this object was constructed. Recorded so that |
| 105 // it's possible to call back into the non thread safe provider to fire the | 104 // it's possible to call back into the non thread safe provider to fire the |
| 106 // notification. | 105 // notification. |
| 107 MessageLoop* origin_loop_; | 106 MessageLoop* origin_loop_; |
| 108 | 107 |
| 109 // True if Stop has been called. | 108 // True if Stop has been called. |
| 110 bool stopped_; | 109 bool stopped_; |
| 111 | 110 |
| 112 // Callback to invoke on policy updates. | 111 // Callback to invoke on policy updates. |
| 113 base::Closure updates_callback_; | 112 UpdateCallback update_callback_; |
| 114 | 113 |
| 115 DISALLOW_COPY_AND_ASSIGN(AsynchronousPolicyLoader); | 114 DISALLOW_COPY_AND_ASSIGN(AsynchronousPolicyLoader); |
| 116 }; | 115 }; |
| 117 | 116 |
| 118 } // namespace policy | 117 } // namespace policy |
| 119 | 118 |
| 120 #endif // CHROME_BROWSER_POLICY_ASYNCHRONOUS_POLICY_LOADER_H_ | 119 #endif // CHROME_BROWSER_POLICY_ASYNCHRONOUS_POLICY_LOADER_H_ |
| OLD | NEW |