| Index: remoting/host/policy_hack/policy_watcher.cc
|
| diff --git a/remoting/host/policy_hack/policy_watcher.cc b/remoting/host/policy_hack/policy_watcher.cc
|
| index d0f59572c31ed2480d409bea355a8b5e68d89515..8e30c241ae98da24b25d1da2d87a6db6c3dabfcd 100644
|
| --- a/remoting/host/policy_hack/policy_watcher.cc
|
| +++ b/remoting/host/policy_hack/policy_watcher.cc
|
| @@ -118,7 +118,6 @@
|
| PolicyWatcher::PolicyWatcher(
|
| scoped_refptr<base::SingleThreadTaskRunner> task_runner)
|
| : task_runner_(task_runner),
|
| - transient_policy_error_retry_counter_(0),
|
| old_policies_(new base::DictionaryValue()),
|
| default_values_(new base::DictionaryValue()),
|
| weak_factory_(this) {
|
| @@ -152,20 +151,16 @@
|
| PolicyWatcher::~PolicyWatcher() {
|
| }
|
|
|
| -void PolicyWatcher::StartWatching(
|
| - const PolicyUpdatedCallback& policy_updated_callback,
|
| - const PolicyErrorCallback& policy_error_callback) {
|
| +void PolicyWatcher::StartWatching(const PolicyCallback& policy_callback) {
|
| if (!OnPolicyWatcherThread()) {
|
| task_runner_->PostTask(FROM_HERE,
|
| base::Bind(&PolicyWatcher::StartWatching,
|
| base::Unretained(this),
|
| - policy_updated_callback,
|
| - policy_error_callback));
|
| + policy_callback));
|
| return;
|
| }
|
|
|
| - policy_updated_callback_ = policy_updated_callback;
|
| - policy_error_callback_ = policy_error_callback;
|
| + policy_callback_ = policy_callback;
|
| StartWatchingInternal();
|
| }
|
|
|
| @@ -179,8 +174,7 @@
|
| void PolicyWatcher::StopWatchingOnPolicyWatcherThread() {
|
| StopWatchingInternal();
|
| weak_factory_.InvalidateWeakPtrs();
|
| - policy_updated_callback_.Reset();
|
| - policy_error_callback_.Reset();
|
| + policy_callback_.Reset();
|
| }
|
|
|
| void PolicyWatcher::ScheduleFallbackReloadTask() {
|
| @@ -208,8 +202,6 @@
|
| void PolicyWatcher::UpdatePolicies(
|
| const base::DictionaryValue* new_policies_raw) {
|
| DCHECK(OnPolicyWatcherThread());
|
| -
|
| - transient_policy_error_retry_counter_ = 0;
|
|
|
| // Use default values for any missing policies.
|
| scoped_ptr<base::DictionaryValue> new_policies =
|
| @@ -234,20 +226,7 @@
|
|
|
| // Notify our client of the changed policies.
|
| if (!changed_policies->empty()) {
|
| - policy_updated_callback_.Run(changed_policies.Pass());
|
| - }
|
| -}
|
| -
|
| -void PolicyWatcher::SignalPolicyError() {
|
| - transient_policy_error_retry_counter_ = 0;
|
| - policy_error_callback_.Run();
|
| -}
|
| -
|
| -void PolicyWatcher::SignalTransientPolicyError() {
|
| - const int kMaxRetryCount = 5;
|
| - transient_policy_error_retry_counter_ += 1;
|
| - if (transient_policy_error_retry_counter_ >= kMaxRetryCount) {
|
| - SignalPolicyError();
|
| + policy_callback_.Run(changed_policies.Pass());
|
| }
|
| }
|
|
|
|
|