Added RefreshPolicies to PolicyService.

chrome/browser/automation/automation_provider_observers.cc

 // 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/automation/automation_provider_observers.h"
 
 #include <deque>
 #include <string>
 #include <vector>
 
@@ skipping 25 matching lines @@
 #include "chrome/browser/history/history_types.h"
 #include "chrome/browser/history/top_sites.h"
 #include "chrome/browser/infobars/infobar_tab_helper.h"
 #include "chrome/browser/metrics/metric_event_duration_details.h"
 #include "chrome/browser/notifications/balloon.h"
 #include "chrome/browser/notifications/balloon_collection.h"
 #include "chrome/browser/notifications/balloon_host.h"
 #include "chrome/browser/notifications/notification.h"
 #include "chrome/browser/notifications/notification_ui_manager.h"
 #include "chrome/browser/password_manager/password_store_change.h"
-#include "chrome/browser/policy/browser_policy_connector.h"
 #include "chrome/browser/profiles/profile.h"
 #include "chrome/browser/renderer_host/chrome_render_message_filter.h"
 #include "chrome/browser/search_engines/template_url_service.h"
 #include "chrome/browser/search_engines/template_url_service_factory.h"
 #include "chrome/browser/sessions/restore_tab_helper.h"
 #include "chrome/browser/sessions/tab_restore_service.h"
 #include "chrome/browser/sessions/tab_restore_service_factory.h"
 #include "chrome/browser/tab_contents/confirm_infobar_delegate.h"
 #include "chrome/browser/tab_contents/thumbnail_generator.h"
 #include "chrome/browser/translate/page_translated_details.h"
@@ skipping 2883 matching lines @@
         AutomationJSONReply(automation_, reply_message_.release())
             .SendSuccess(NULL);
       }
       delete this;
     }
   } else {
     NOTREACHED();
   }
 }
 
-#if defined(ENABLE_CONFIGURATION_POLICY)
-
-PolicyUpdatesObserver::PolicyUpdatesObserver(
-    AutomationProvider* automation,
-    IPC::Message* reply_message,
-    policy::BrowserPolicyConnector* browser_policy_connector)
-    : automation_(automation->AsWeakPtr()),
-      reply_message_(reply_message) {
-  policy::ConfigurationPolicyProvider* providers[] = {
-    browser_policy_connector->GetManagedCloudProvider(),
-    browser_policy_connector->GetManagedPlatformProvider(),
-    browser_policy_connector->GetRecommendedCloudProvider(),
-    browser_policy_connector->GetRecommendedPlatformProvider(),
-  };
-  for (size_t i = 0; i < arraysize(providers); ++i) {
-    if (providers[i]) {
-      registrars_.push_back(new policy::ConfigurationPolicyObserverRegistrar);
-      registrars_.back()->Init(providers[i], this);
-    }
-  }
-  MaybeReply();
-}
-
-PolicyUpdatesObserver::~PolicyUpdatesObserver() {}
-
-// static
-void PolicyUpdatesObserver::PostCallbackAfterPolicyUpdates(
-    const base::Closure& callback) {
-  // Some policies (e.g. URLBlacklist) post tasks to other message loops before
-  // they start enforcing updated policy values; make sure those tasks have
-  // finished after a policy update.
-  // Updates of the URLBlacklist are done on IO, after building the blacklist
-  // on FILE, which is initiated from IO.
-  PostTask(BrowserThread::IO,
-      base::Bind(&PostTask, BrowserThread::FILE,
-          base::Bind(&PostTask, BrowserThread::IO,
-              base::Bind(&PostTask, BrowserThread::UI, callback))));
-}
-
-void PolicyUpdatesObserver::OnUpdatePolicy(
-    policy::ConfigurationPolicyProvider* provider) {
-  std::vector<policy::ConfigurationPolicyObserverRegistrar*>::iterator it;
-  for (it = registrars_.begin(); it != registrars_.end(); ++it) {
-    if ((*it)->provider() == provider) {
-      delete *it;
-      registrars_.erase(it);
-      MaybeReply();
-      return;
-    }
-  }
-}
-
-void PolicyUpdatesObserver::OnProviderGoingAway(
-    policy::ConfigurationPolicyProvider* provider) {
-  STLDeleteElements(&registrars_);
-  if (automation_) {
-    AutomationJSONReply(automation_, reply_message_.release()).SendError(
-        "Policy provider went away.");
-  }
-  delete this;
-}
-
-void PolicyUpdatesObserver::MaybeReply() {
-  if (registrars_.empty()) {
-    PostCallbackAfterPolicyUpdates(
-        base::Bind(&PolicyUpdatesObserver::Reply, base::Owned(this)));
-  }
-}
-
-void PolicyUpdatesObserver::Reply() {
-  if (automation_) {
-    AutomationJSONReply(
-        automation_, reply_message_.release()).SendSuccess(NULL);
-  }
-  // Reply() is only called from MaybeReply(), which makes the callback own
-  // |this|; so |this| will be deleted once this method returns.
-}
-
-// static
-void PolicyUpdatesObserver::PostTask(content::BrowserThread::ID id,
-                                     const base::Closure& callback) {
-  content::BrowserThread::PostTask(id, FROM_HERE, callback);
-}
-
-#endif  // defined(ENABLE_CONFIGURATION_POLICY)
-
 ExtensionPopupObserver::ExtensionPopupObserver(
     AutomationProvider* automation,
     IPC::Message* reply_message,
     const std::string& extension_id)
     : automation_(automation->AsWeakPtr()),
       reply_message_(reply_message),
       extension_id_(extension_id) {
   registrar_.Add(this, chrome::NOTIFICATION_EXTENSION_HOST_DID_STOP_LOADING,
                  content::NotificationService::AllSources());
 }
@@ skipping 11 matching lines @@
   }
 
   ExtensionHost* host = content::Details<ExtensionHost>(details).ptr();
   if (host->extension_id() == extension_id_ &&
       host->extension_host_type() == chrome::VIEW_TYPE_EXTENSION_POPUP) {
     AutomationJSONReply(automation_, reply_message_.release())
         .SendSuccess(NULL);
     delete this;
   }
 }