Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(702)

Side by Side Diff: chrome/browser/policy/async_policy_provider.cc

Issue 22493010: policy: load JSON schema into domain descriptor at start time. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: add comments and clean up includes Created 7 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698