Move Indexed DB from dedicated thread to task scheduler

content/browser/storage_partition_impl.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 "content/browser/storage_partition_impl.h"
 
 #include <stddef.h>
 
 #include <set>
 #include <vector>
 
 #include "base/bind.h"
 #include "base/command_line.h"
 #include "base/location.h"
 #include "base/sequenced_task_runner.h"
 #include "base/single_thread_task_runner.h"
 #include "base/strings/utf_string_conversions.h"
+#include "base/task_scheduler/post_task.h"
 #include "content/browser/blob_storage/chrome_blob_storage_context.h"
 #include "content/browser/browser_main_loop.h"
 #include "content/browser/browsing_data/storage_partition_http_cache_data_remover.h"
 #include "content/browser/fileapi/browser_file_system_helper.h"
 #include "content/browser/gpu/shader_cache_factory.h"
 #include "content/browser/notifications/platform_notification_context_impl.h"
 #include "content/common/dom_storage/dom_storage_types.h"
 #include "content/public/browser/browser_context.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/content_browser_client.h"
@@ skipping 438 matching lines @@
       quota_manager_proxy.get(),
       BrowserThread::GetTaskRunnerForThread(BrowserThread::FILE).get());
 
   partition->dom_storage_context_ = new DOMStorageContextWrapper(
       BrowserContext::GetConnectorFor(context),
       in_memory ? base::FilePath() : context->GetPath(),
       relative_partition_path, context->GetSpecialStoragePolicy());
 
   // BrowserMainLoop may not be initialized in unit tests. Tests will
   // need to inject their own task runner into the IndexedDBContext.
-  base::SequencedTaskRunner* idb_task_runner =
+  // TODO(jsbell): This is no longer true, update tests to provide use a
+  // base::test::ScopedTaskEnvironment instead of injecting a test task
+  // runner.
+  scoped_refptr<base::SequencedTaskRunner> idb_task_runner =
       BrowserThread::CurrentlyOn(BrowserThread::UI) &&
               BrowserMainLoop::GetInstance()
-          ? BrowserMainLoop::GetInstance()
-                ->indexed_db_thread()
-                ->task_runner()
-                .get()
-          : NULL;
+          ? base::CreateSequencedTaskRunnerWithTraits({
+                base::MayBlock(), base::WithBaseSyncPrimitives(),
+                base::TaskPriority::USER_VISIBLE,
+                base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN,
+            })
+          : nullptr;
 
   base::FilePath path = in_memory ? base::FilePath() : partition_path;
   partition->indexed_db_context_ =
       new IndexedDBContextImpl(path, context->GetSpecialStoragePolicy(),
                                quota_manager_proxy.get(), idb_task_runner);
 
   partition->cache_storage_context_ = new CacheStorageContextImpl(context);
   partition->cache_storage_context_->Init(path, quota_manager_proxy);
 
   partition->service_worker_context_ = new ServiceWorkerContextWrapper(context);
@@ skipping 487 matching lines @@
   media_url_request_context_ = media_url_request_context;
 }
 
 void StoragePartitionImpl::GetQuotaSettings(
     const storage::OptionalQuotaSettingsCallback& callback) {
   GetContentClient()->browser()->GetQuotaSettings(browser_context_, this,
                                                   callback);
 }
 
 }  // namespace content