OLD | NEW |
| (Empty) |
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 | |
3 // found in the LICENSE file. | |
4 | |
5 #include "chrome/browser/policy/cloud_policy_provider.h" | |
6 | |
7 #include "base/memory/scoped_ptr.h" | |
8 #include "chrome/browser/policy/browser_policy_connector.h" | |
9 #include "chrome/browser/policy/policy_bundle.h" | |
10 #include "chrome/browser/policy/policy_map.h" | |
11 | |
12 namespace policy { | |
13 | |
14 CloudPolicyProvider::CloudPolicyProvider(BrowserPolicyConnector* connector) | |
15 : browser_policy_connector_(connector), | |
16 initialization_complete_(false) { | |
17 for (size_t i = 0; i < CACHE_SIZE; ++i) | |
18 caches_[i] = NULL; | |
19 } | |
20 | |
21 CloudPolicyProvider::~CloudPolicyProvider() {} | |
22 | |
23 void CloudPolicyProvider::SetUserPolicyCache(CloudPolicyCacheBase* cache) { | |
24 DCHECK(!caches_[CACHE_USER]); | |
25 caches_[CACHE_USER] = cache; | |
26 cache->AddObserver(this); | |
27 Merge(); | |
28 } | |
29 | |
30 #if defined(OS_CHROMEOS) | |
31 void CloudPolicyProvider::SetDevicePolicyCache(CloudPolicyCacheBase* cache) { | |
32 DCHECK(caches_[CACHE_DEVICE] == NULL); | |
33 caches_[CACHE_DEVICE] = cache; | |
34 cache->AddObserver(this); | |
35 Merge(); | |
36 } | |
37 #endif | |
38 | |
39 void CloudPolicyProvider::Shutdown() { | |
40 for (size_t i = 0; i < CACHE_SIZE; ++i) { | |
41 if (caches_[i]) { | |
42 caches_[i]->RemoveObserver(this); | |
43 caches_[i] = NULL; | |
44 } | |
45 } | |
46 ConfigurationPolicyProvider::Shutdown(); | |
47 } | |
48 | |
49 bool CloudPolicyProvider::IsInitializationComplete() const { | |
50 return initialization_complete_; | |
51 } | |
52 | |
53 void CloudPolicyProvider::RefreshPolicies() { | |
54 for (size_t i = 0; i < CACHE_SIZE; ++i) { | |
55 if (caches_[i]) | |
56 pending_updates_.insert(caches_[i]); | |
57 } | |
58 if (pending_updates_.empty()) | |
59 Merge(); | |
60 else | |
61 browser_policy_connector_->FetchCloudPolicy(); | |
62 } | |
63 | |
64 void CloudPolicyProvider::OnCacheUpdate(CloudPolicyCacheBase* cache) { | |
65 pending_updates_.erase(cache); | |
66 if (pending_updates_.empty()) | |
67 Merge(); | |
68 } | |
69 | |
70 void CloudPolicyProvider::Merge() { | |
71 // Re-check whether all caches are ready. | |
72 if (!initialization_complete_) { | |
73 initialization_complete_ = true; | |
74 for (size_t i = 0; i < CACHE_SIZE; ++i) { | |
75 if (caches_[i] == NULL || !caches_[i]->IsReady()) { | |
76 initialization_complete_ = false; | |
77 break; | |
78 } | |
79 } | |
80 } | |
81 | |
82 PolicyMap combined; | |
83 for (size_t i = 0; i < CACHE_SIZE; ++i) { | |
84 if (caches_[i] && caches_[i]->IsReady()) | |
85 combined.MergeFrom(*caches_[i]->policy()); | |
86 } | |
87 | |
88 scoped_ptr<PolicyBundle> bundle(new PolicyBundle()); | |
89 bundle->Get(POLICY_DOMAIN_CHROME, std::string()).Swap(&combined); | |
90 UpdatePolicy(bundle.Pass()); | |
91 } | |
92 | |
93 } // namespace policy | |
OLD | NEW |