Move IndexedDB from WEBKIT_DEPRECATED to dedicated thread

content/browser/indexed_db/indexed_db_internals_ui.cc

 // Copyright (c) 2013 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/indexed_db/indexed_db_internals_ui.h"
 
 #include <algorithm>
 #include <string>
 
 #include "base/bind.h"
@@ skipping 41 matching lines @@
   source->SetDefaultResource(IDR_INDEXED_DB_INTERNALS_HTML);
 
   BrowserContext* browser_context =
       web_ui->GetWebContents()->GetBrowserContext();
   WebUIDataSource::Add(browser_context, source);
 }
 
 IndexedDBInternalsUI::~IndexedDBInternalsUI() {}
 
 void IndexedDBInternalsUI::AddContextFromStoragePartition(
-    ContextList* contexts,
-    std::vector<base::FilePath>* paths,
     StoragePartition* partition) {
   scoped_refptr<IndexedDBContext> context = partition->GetIndexedDBContext();
-  contexts->push_back(context);
-  paths->push_back(partition->GetPath());
+  context->TaskRunner()->PostTask(
+      FROM_HERE,
+      base::Bind(&IndexedDBInternalsUI::GetAllOriginsOnIndexedDBThread,
+                 base::Unretained(this),
+                 context,
+                 partition->GetPath()));
 }
 
 void IndexedDBInternalsUI::GetAllOrigins(const base::ListValue* args) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
 
   BrowserContext* browser_context =
       web_ui()->GetWebContents()->GetBrowserContext();
 
-  scoped_ptr<std::vector<base::FilePath> > paths(
-      new std::vector<base::FilePath>);
-  scoped_ptr<ContextList> contexts(new ContextList);
   BrowserContext::StoragePartitionCallback cb =
-      base::Bind(&AddContextFromStoragePartition, contexts.get(), paths.get());
+      base::Bind(&IndexedDBInternalsUI::AddContextFromStoragePartition,
+                 base::Unretained(this));
   BrowserContext::ForEachStoragePartition(browser_context, cb);
-
-  BrowserThread::PostTask(
-      BrowserThread::WEBKIT_DEPRECATED,
-      FROM_HERE,
-      base::Bind(&IndexedDBInternalsUI::GetAllOriginsOnWebkitThread,
-                 base::Unretained(this),
-                 base::Passed(&contexts),
-                 base::Passed(&paths)));
 }
 
-bool HostNameComparator(const IndexedDBInfo& i, const IndexedDBInfo& j) {
+static bool HostNameComparator(const IndexedDBInfo& i, const IndexedDBInfo& j) {
   return i.origin_.host() < j.origin_.host();
 }
 
-void IndexedDBInternalsUI::GetAllOriginsOnWebkitThread(
-    const scoped_ptr<ContextList> contexts,
-    const scoped_ptr<std::vector<base::FilePath> > context_paths) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED));
-  DCHECK_EQ(contexts->size(), context_paths->size());
+void IndexedDBInternalsUI::GetAllOriginsOnIndexedDBThread(
+    scoped_refptr<IndexedDBContext> context,
+    const base::FilePath& context_path) {
+  DCHECK(context->OnIndexedDBThread());
 
-  std::vector<base::FilePath>::const_iterator path_iter =
-      context_paths->begin();
-  for (ContextList::const_iterator iter = contexts->begin();
-       iter != contexts->end();
-       ++iter, ++path_iter) {
-    IndexedDBContext* context = iter->get();
-    const base::FilePath& context_path = *path_iter;
-
-    scoped_ptr<std::vector<IndexedDBInfo> > info_list(
-        new std::vector<IndexedDBInfo>(context->GetAllOriginsInfo()));
-    std::sort(info_list->begin(), info_list->end(), HostNameComparator);
-    BrowserThread::PostTask(BrowserThread::UI,
-                            FROM_HERE,
-                            base::Bind(&IndexedDBInternalsUI::OnOriginsReady,
-                                       base::Unretained(this),
-                                       base::Passed(&info_list),
-                                       context_path));
-  }
+  scoped_ptr<std::vector<IndexedDBInfo> > info_list(
+      new std::vector<IndexedDBInfo>(context->GetAllOriginsInfo()));
+  std::sort(info_list->begin(), info_list->end(), HostNameComparator);
+  BrowserThread::PostTask(BrowserThread::UI,
+                          FROM_HERE,
+                          base::Bind(&IndexedDBInternalsUI::OnOriginsReady,
+                                     base::Unretained(this),
+                                     base::Passed(&info_list),
+                                     context_path));
 }
 
 void IndexedDBInternalsUI::OnOriginsReady(
     scoped_ptr<std::vector<IndexedDBInfo> > origins,
     const base::FilePath& path) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   base::ListValue urls;
   for (std::vector<IndexedDBInfo>::const_iterator iter = origins->begin();
        iter != origins->end();
        ++iter) {
@@ skipping 39 matching lines @@
 
   scoped_refptr<IndexedDBContextImpl> result_context;
   StoragePartition* result_partition;
   scoped_ptr<ContextList> contexts(new ContextList);
   BrowserContext::StoragePartitionCallback cb = base::Bind(
       &FindContext, partition_path, &result_partition, &result_context);
   BrowserContext::ForEachStoragePartition(browser_context, cb);
   DCHECK(result_partition);
   DCHECK(result_context.get());
 
-  BrowserThread::PostTask(
-      BrowserThread::WEBKIT_DEPRECATED,
+  result_context->TaskRunner()->PostTask(
       FROM_HERE,
-      base::Bind(&IndexedDBInternalsUI::DownloadOriginDataOnWebkitThread,
+      base::Bind(&IndexedDBInternalsUI::DownloadOriginDataOnIndexedDBThread,
                  base::Unretained(this),
                  result_partition->GetPath(),
                  result_context,
                  origin_url));
 }
 
-void IndexedDBInternalsUI::DownloadOriginDataOnWebkitThread(
+void IndexedDBInternalsUI::DownloadOriginDataOnIndexedDBThread(
     const base::FilePath& partition_path,
     const scoped_refptr<IndexedDBContextImpl> context,
     const GURL& origin_url) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::WEBKIT_DEPRECATED));
+  DCHECK(context->OnIndexedDBThread());
 
   if (!context->IsInOriginSet(origin_url))
     return;
 
   context->ForceClose(origin_url);
 
   base::ScopedTempDir temp_dir;
   if (!temp_dir.CreateUniqueTempDir())
     return;
 
@@ skipping 100 matching lines @@
     return;
   }
 
   item->AddObserver(new FileDeleter(temp_path));
   web_ui()->CallJavascriptFunction("indexeddb.onOriginDownloadReady",
                                    base::StringValue(partition_path.value()),
                                    base::StringValue(origin_url.spec()));
 }
 
 }  // namespace content