blob: f921b8a1e5ab1292f45bdb06df1799c50bdfd2cd (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
// Copyright (c) 2012 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chrome/browser/policy/cloud_policy_provider.h"
#include "base/memory/scoped_ptr.h"
#include "chrome/browser/policy/browser_policy_connector.h"
#include "chrome/browser/policy/policy_bundle.h"
#include "chrome/browser/policy/policy_map.h"
namespace policy {
CloudPolicyProvider::CloudPolicyProvider(
BrowserPolicyConnector* browser_policy_connector,
PolicyLevel level)
: browser_policy_connector_(browser_policy_connector),
level_(level),
initialization_complete_(false) {
for (size_t i = 0; i < CACHE_SIZE; ++i)
caches_[i] = NULL;
}
CloudPolicyProvider::~CloudPolicyProvider() {
for (size_t i = 0; i < CACHE_SIZE; ++i) {
if (caches_[i])
caches_[i]->RemoveObserver(this);
}
}
void CloudPolicyProvider::SetUserPolicyCache(CloudPolicyCacheBase* cache) {
DCHECK(!caches_[CACHE_USER]);
caches_[CACHE_USER] = cache;
cache->AddObserver(this);
Merge();
}
#if defined(OS_CHROMEOS)
void CloudPolicyProvider::SetDevicePolicyCache(CloudPolicyCacheBase* cache) {
DCHECK(caches_[CACHE_DEVICE] == NULL);
caches_[CACHE_DEVICE] = cache;
cache->AddObserver(this);
Merge();
}
#endif
bool CloudPolicyProvider::IsInitializationComplete() const {
return initialization_complete_;
}
void CloudPolicyProvider::RefreshPolicies() {
for (size_t i = 0; i < CACHE_SIZE; ++i) {
if (caches_[i])
pending_updates_.insert(caches_[i]);
}
if (pending_updates_.empty())
Merge();
else
browser_policy_connector_->FetchCloudPolicy();
}
void CloudPolicyProvider::OnCacheUpdate(CloudPolicyCacheBase* cache) {
pending_updates_.erase(cache);
if (pending_updates_.empty())
Merge();
}
void CloudPolicyProvider::OnCacheGoingAway(CloudPolicyCacheBase* cache) {
for (size_t i = 0; i < CACHE_SIZE; ++i) {
if (caches_[i] == cache) {
caches_[i] = NULL;
cache->RemoveObserver(this);
pending_updates_.erase(cache);
Merge();
return;
}
}
NOTREACHED();
}
void CloudPolicyProvider::Merge() {
// Re-check whether all caches are ready.
if (!initialization_complete_) {
initialization_complete_ = true;
for (size_t i = 0; i < CACHE_SIZE; ++i) {
if (caches_[i] == NULL || !caches_[i]->IsReady()) {
initialization_complete_ = false;
break;
}
}
}
PolicyMap combined;
for (size_t i = 0; i < CACHE_SIZE; ++i) {
if (caches_[i] && caches_[i]->IsReady())
combined.MergeFrom(*caches_[i]->policy());
}
combined.FilterLevel(level_);
scoped_ptr<PolicyBundle> bundle(new PolicyBundle());
bundle->Get(POLICY_DOMAIN_CHROME, std::string()).Swap(&combined);
UpdatePolicy(bundle.Pass());
}
} // namespace policy
|
