| 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 #include "chrome/browser/policy/async_policy_provider.h" | 5 #include "chrome/browser/policy/async_policy_provider.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
| 9 #include "base/location.h" | 9 #include "base/location.h" |
| 10 #include "base/message_loop/message_loop.h" | 10 #include "base/message_loop/message_loop.h" |
| 11 #include "base/message_loop/message_loop_proxy.h" | 11 #include "base/message_loop/message_loop_proxy.h" |
| 12 #include "base/sequenced_task_runner.h" | 12 #include "base/sequenced_task_runner.h" |
| 13 #include "chrome/browser/policy/async_policy_loader.h" | 13 #include "chrome/browser/policy/async_policy_loader.h" |
| 14 #include "chrome/browser/policy/policy_bundle.h" | 14 #include "chrome/browser/policy/policy_bundle.h" |
| 15 #include "chrome/browser/policy/policy_domain_descriptor.h" | 15 #include "chrome/browser/policy/policy_domain_descriptor.h" |
| 16 | 16 |
| 17 namespace policy { | 17 namespace policy { |
| 18 | 18 |
| 19 AsyncPolicyProvider::AsyncPolicyProvider(scoped_ptr<AsyncPolicyLoader> loader) | 19 AsyncPolicyProvider::AsyncPolicyProvider(scoped_ptr<AsyncPolicyLoader> loader) |
| 20 : loader_(loader.release()), | 20 : loader_(loader.release()), |
| 21 weak_factory_(this) { | 21 weak_factory_(this) { |
| 22 // Make an immediate synchronous load on startup. | |
| 23 OnLoaderReloaded(loader_->InitialLoad()); | |
| 24 } | 22 } |
| 25 | 23 |
| 26 AsyncPolicyProvider::~AsyncPolicyProvider() { | 24 AsyncPolicyProvider::~AsyncPolicyProvider() { |
| 27 DCHECK(CalledOnValidThread()); | 25 DCHECK(CalledOnValidThread()); |
| 28 // Shutdown() must have been called before. | 26 // Shutdown() must have been called before. |
| 29 DCHECK(!loader_); | 27 DCHECK(!loader_); |
| 30 } | 28 } |
| 31 | 29 |
| 30 void AsyncPolicyProvider::InitialLoad() { |
| 31 OnLoaderReloaded(loader_->InitialLoad()); |
| 32 } |
| 33 |
| 32 void AsyncPolicyProvider::Init() { | 34 void AsyncPolicyProvider::Init() { |
| 33 DCHECK(CalledOnValidThread()); | 35 DCHECK(CalledOnValidThread()); |
| 34 ConfigurationPolicyProvider::Init(); | 36 ConfigurationPolicyProvider::Init(); |
| 35 | 37 |
| 36 if (!loader_) | 38 if (!loader_) |
| 37 return; | 39 return; |
| 38 | 40 |
| 39 AsyncPolicyLoader::UpdateCallback callback = | 41 AsyncPolicyLoader::UpdateCallback callback = |
| 40 base::Bind(&AsyncPolicyProvider::LoaderUpdateCallback, | 42 base::Bind(&AsyncPolicyProvider::LoaderUpdateCallback, |
| 41 base::MessageLoopProxy::current(), | 43 base::MessageLoopProxy::current(), |
| (...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 82 return; | 84 return; |
| 83 refresh_callback_.Reset( | 85 refresh_callback_.Reset( |
| 84 base::Bind(&AsyncPolicyProvider::ReloadAfterRefreshSync, | 86 base::Bind(&AsyncPolicyProvider::ReloadAfterRefreshSync, |
| 85 weak_factory_.GetWeakPtr())); | 87 weak_factory_.GetWeakPtr())); |
| 86 loader_->task_runner()->PostTaskAndReply( | 88 loader_->task_runner()->PostTaskAndReply( |
| 87 FROM_HERE, | 89 FROM_HERE, |
| 88 base::Bind(base::DoNothing), | 90 base::Bind(base::DoNothing), |
| 89 refresh_callback_.callback()); | 91 refresh_callback_.callback()); |
| 90 } | 92 } |
| 91 | 93 |
| 94 void AsyncPolicyProvider::InitialRegisterPolicyDomain( |
| 95 scoped_refptr<const PolicyDomainDescriptor> descriptor) { |
| 96 if (loader_) |
| 97 loader_->InitialRegisterPolicyDomain(descriptor); |
| 98 } |
| 99 |
| 92 void AsyncPolicyProvider::RegisterPolicyDomain( | 100 void AsyncPolicyProvider::RegisterPolicyDomain( |
| 93 scoped_refptr<const PolicyDomainDescriptor> descriptor) { | 101 scoped_refptr<const PolicyDomainDescriptor> descriptor) { |
| 94 if (loader_) { | 102 if (loader_) { |
| 95 loader_->task_runner()->PostTask( | 103 loader_->task_runner()->PostTask( |
| 96 FROM_HERE, | 104 FROM_HERE, |
| 97 base::Bind(&AsyncPolicyLoader::RegisterPolicyDomain, | 105 base::Bind(&AsyncPolicyLoader::RegisterPolicyDomain, |
| 98 base::Unretained(loader_), | 106 base::Unretained(loader_), |
| 99 descriptor)); | 107 descriptor)); |
| 100 } | 108 } |
| 101 } | 109 } |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 133 scoped_refptr<base::MessageLoopProxy> loop, | 141 scoped_refptr<base::MessageLoopProxy> loop, |
| 134 base::WeakPtr<AsyncPolicyProvider> weak_this, | 142 base::WeakPtr<AsyncPolicyProvider> weak_this, |
| 135 scoped_ptr<PolicyBundle> bundle) { | 143 scoped_ptr<PolicyBundle> bundle) { |
| 136 loop->PostTask(FROM_HERE, | 144 loop->PostTask(FROM_HERE, |
| 137 base::Bind(&AsyncPolicyProvider::OnLoaderReloaded, | 145 base::Bind(&AsyncPolicyProvider::OnLoaderReloaded, |
| 138 weak_this, | 146 weak_this, |
| 139 base::Passed(&bundle))); | 147 base::Passed(&bundle))); |
| 140 } | 148 } |
| 141 | 149 |
| 142 } // namespace policy | 150 } // namespace policy |
| OLD | NEW |