Add support for loading user cloud policy on desktop.

chrome/browser/policy/config_dir_policy_loader.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/policy/config_dir_policy_loader.h"
 
 #include <algorithm>
 #include <set>
 #include <string>
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/file_util.h"
 #include "base/json/json_file_value_serializer.h"
 #include "base/logging.h"
+#include "base/message_loop.h"
 #include "base/platform_file.h"
 #include "base/stl_util.h"
 #include "chrome/browser/policy/policy_bundle.h"
+#include "content/public/browser/browser_thread.h"
 
 namespace policy {
 
 namespace {
 
 // Subdirectories that contain the mandatory and recommended policies.
 const FilePath::CharType kMandatoryConfigDir[] = FILE_PATH_LITERAL("managed");
 const FilePath::CharType kRecommendedConfigDir[] =
     FILE_PATH_LITERAL("recommended");
 
 }  // namespace
 
 ConfigDirPolicyLoader::ConfigDirPolicyLoader(const FilePath& config_dir,
                                              PolicyScope scope)
     : config_dir_(config_dir),
       scope_(scope) {}
 
 ConfigDirPolicyLoader::~ConfigDirPolicyLoader() {}
 
 void ConfigDirPolicyLoader::InitOnFile() {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::FILE));
+  // Some unit tests create a File thread that shares a MessageLoop with the
+  // UI thread, and this causes DCHECKs because IO operations aren't allowed on
+  // that thread. So if this is running in the context of one of those tests,
+  // just exit.
+  if (!MessageLoop::current()->IsType(MessageLoop::TYPE_IO))
+    return;
   base::files::FilePathWatcher::Callback callback =
       base::Bind(&ConfigDirPolicyLoader::OnFileUpdated, base::Unretained(this));
   mandatory_watcher_.Watch(config_dir_.Append(kMandatoryConfigDir), callback);
   recommended_watcher_.Watch(config_dir_.Append(kRecommendedConfigDir),
                              callback);
 }
 
 scoped_ptr<PolicyBundle> ConfigDirPolicyLoader::Load() {
   scoped_ptr<PolicyBundle> bundle(new PolicyBundle());
   LoadFromPath(config_dir_.Append(kMandatoryConfigDir),
@@ skipping 133 matching lines @@
     }
   }
 }
 
 void ConfigDirPolicyLoader::OnFileUpdated(const FilePath& path, bool error) {
   if (!error)
     Reload(false);
 }
 
 }  // namespace policy