[Sync] Stop accessing BrowserContextKeyedServiceFactory on non-UI thread.

chrome/browser/extensions/api/storage/settings_sync_util.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/extensions/api/storage/settings_sync_util.h"
 
+#include "base/bind.h"
 #include "base/json/json_writer.h"
 #include "base/values.h"
 #include "chrome/browser/extensions/api/storage/sync_value_store_cache.h"
 #include "components/sync/protocol/app_setting_specifics.pb.h"
 #include "components/sync/protocol/extension_setting_specifics.pb.h"
 #include "components/sync/protocol/sync.pb.h"
 #include "content/public/browser/browser_thread.h"
 #include "extensions/browser/api/storage/storage_frontend.h"
 
+using base::WeakPtr;
 using content::BrowserThread;
+using syncer::ModelType;
+using syncer::SyncableService;
 
 namespace extensions {
 
 namespace settings_sync_util {
 
 namespace {
 
 void PopulateExtensionSettingSpecifics(
     const std::string& extension_id,
     const std::string& key,
@@ skipping 10 matching lines @@
 
 void PopulateAppSettingSpecifics(
     const std::string& extension_id,
     const std::string& key,
     const base::Value& value,
     sync_pb::AppSettingSpecifics* specifics) {
   PopulateExtensionSettingSpecifics(
       extension_id, key, value, specifics->mutable_extension_setting());
 }
 
+WeakPtr<SyncableService> GetSyncableService(WeakPtr<SyncValueStoreCache> cache,
+                                            ModelType type) {
+  DCHECK_CURRENTLY_ON(BrowserThread::FILE);
+  return cache.get() ? cache->GetSyncableService(type)->AsWeakPtr()
+                     : WeakPtr<SyncableService>();
+}
+
 }  // namespace
 
-syncer::SyncData CreateData(
-    const std::string& extension_id,
-    const std::string& key,
-    const base::Value& value,
-    syncer::ModelType type) {
+syncer::SyncData CreateData(const std::string& extension_id,
+                            const std::string& key,
+                            const base::Value& value,
+                            ModelType type) {
   sync_pb::EntitySpecifics specifics;
   switch (type) {
     case syncer::EXTENSION_SETTINGS:
       PopulateExtensionSettingSpecifics(
           extension_id,
           key,
           value,
           specifics.mutable_extension_setting());
       break;
 
     case syncer::APP_SETTINGS:
       PopulateAppSettingSpecifics(
           extension_id,
           key,
           value,
           specifics.mutable_app_setting());
       break;
 
     default:
       NOTREACHED();
   }
 
   return syncer::SyncData::CreateLocalData(
       extension_id + "/" + key, key, specifics);
 }
 
-syncer::SyncChange CreateAdd(
-    const std::string& extension_id,
-    const std::string& key,
-    const base::Value& value,
-    syncer::ModelType type) {
+syncer::SyncChange CreateAdd(const std::string& extension_id,
+                             const std::string& key,
+                             const base::Value& value,
+                             ModelType type) {
   return syncer::SyncChange(
       FROM_HERE,
       syncer::SyncChange::ACTION_ADD,
       CreateData(extension_id, key, value, type));
 }
 
-syncer::SyncChange CreateUpdate(
-    const std::string& extension_id,
-    const std::string& key,
-    const base::Value& value,
-    syncer::ModelType type) {
+syncer::SyncChange CreateUpdate(const std::string& extension_id,
+                                const std::string& key,
+                                const base::Value& value,
+                                ModelType type) {
   return syncer::SyncChange(
       FROM_HERE,
       syncer::SyncChange::ACTION_UPDATE,
       CreateData(extension_id, key, value, type));
 }
 
-syncer::SyncChange CreateDelete(
-    const std::string& extension_id,
-    const std::string& key,
-    syncer::ModelType type) {
+syncer::SyncChange CreateDelete(const std::string& extension_id,
+                                const std::string& key,
+                                ModelType type) {
   base::DictionaryValue no_value;
   return syncer::SyncChange(
       FROM_HERE,
       syncer::SyncChange::ACTION_DELETE,
       CreateData(extension_id, key, no_value, type));
 }
 
-syncer::SyncableService* GetSyncableService(content::BrowserContext* context,
-                                            syncer::ModelType type) {
-  DCHECK_CURRENTLY_ON(BrowserThread::FILE);
+syncer::SyncClient::ServiceProvider GetSyncableServiceProvider(
+    content::BrowserContext* context,
+    ModelType type) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
   DCHECK(type == syncer::APP_SETTINGS || type == syncer::EXTENSION_SETTINGS);
   StorageFrontend* frontend = StorageFrontend::Get(context);
   SyncValueStoreCache* sync_cache = static_cast<SyncValueStoreCache*>(
       frontend->GetValueStoreCache(settings_namespace::SYNC));
-  return sync_cache->GetSyncableService(type);
+  // We must rely on our caller to guarantee that sync_cache->AsWeakPtr() is a
+  // valid call right now, and that shutdown has not begun.
+  return base::Bind(&GetSyncableService, sync_cache->AsWeakPtr(), type);
 }
 
 }  // namespace settings_sync_util
 
 }  // namespace extensions