Let IndexedDBContextImpl create its own task runner

content/browser/indexed_db/indexed_db_quota_client.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/indexed_db/indexed_db_quota_client.h"
 
 #include <stdint.h>
 
 #include <vector>
 
@@ skipping 66 matching lines @@
                                           const GetUsageCallback& callback) {
   DCHECK(!callback.is_null());
   DCHECK(indexed_db_context_.get());
 
   // IndexedDB is in the temp namespace for now.
   if (type != storage::kStorageTypeTemporary) {
     callback.Run(0);
     return;
   }
 
-  // No task runner means unit test; no cleanup necessary.
-  if (!indexed_db_context_->TaskRunner()) {
-    callback.Run(0);
-    return;
-  }
-
   base::PostTaskAndReplyWithResult(
       indexed_db_context_->TaskRunner(), FROM_HERE,
       base::Bind(&GetOriginUsageOnIndexedDBThread,
                  base::RetainedRef(indexed_db_context_), origin_url),
       callback);
 }
 
 void IndexedDBQuotaClient::GetOriginsForType(
     storage::StorageType type,
     const GetOriginsCallback& callback) {
   DCHECK(!callback.is_null());
   DCHECK(indexed_db_context_.get());
 
   // All databases are in the temp namespace for now.
   if (type != storage::kStorageTypeTemporary) {
     callback.Run(std::set<GURL>());
     return;
   }
 
-  // No task runner means unit test; no cleanup necessary.
-  if (!indexed_db_context_->TaskRunner()) {
-    callback.Run(std::set<GURL>());
-    return;
-  }
-
   std::set<GURL>* origins_to_return = new std::set<GURL>();
   indexed_db_context_->TaskRunner()->PostTaskAndReply(
       FROM_HERE,
       base::BindOnce(&GetAllOriginsOnIndexedDBThread,
                      base::RetainedRef(indexed_db_context_),
                      base::Unretained(origins_to_return)),
       base::BindOnce(&DidGetOrigins, callback, base::Owned(origins_to_return)));
 }
 
 void IndexedDBQuotaClient::GetOriginsForHost(
     storage::StorageType type,
     const std::string& host,
     const GetOriginsCallback& callback) {
   DCHECK(!callback.is_null());
   DCHECK(indexed_db_context_.get());
 
   // All databases are in the temp namespace for now.
   if (type != storage::kStorageTypeTemporary) {
     callback.Run(std::set<GURL>());
     return;
   }
 
-  // No task runner means unit test; no cleanup necessary.
-  if (!indexed_db_context_->TaskRunner()) {
-    callback.Run(std::set<GURL>());
-    return;
-  }
-
   std::set<GURL>* origins_to_return = new std::set<GURL>();
   indexed_db_context_->TaskRunner()->PostTaskAndReply(
       FROM_HERE,
       base::BindOnce(&GetOriginsForHostOnIndexedDBThread,
                      base::RetainedRef(indexed_db_context_), host,
                      base::Unretained(origins_to_return)),
       base::BindOnce(&DidGetOrigins, callback, base::Owned(origins_to_return)));
 }
 
 void IndexedDBQuotaClient::DeleteOriginData(const GURL& origin,
                                             storage::StorageType type,
                                             const DeletionCallback& callback) {
   if (type != storage::kStorageTypeTemporary) {
     callback.Run(storage::kQuotaErrorNotSupported);
     return;
   }
 
-  // No task runner means unit test; no cleanup necessary.
-  if (!indexed_db_context_->TaskRunner()) {
-    callback.Run(storage::kQuotaStatusOk);
-    return;
-  }
-
   base::PostTaskAndReplyWithResult(
       indexed_db_context_->TaskRunner(), FROM_HERE,
       base::Bind(&DeleteOriginDataOnIndexedDBThread,
                  base::RetainedRef(indexed_db_context_), origin),
       callback);
 }
 
 bool IndexedDBQuotaClient::DoesSupport(storage::StorageType type) const {
   return type == storage::kStorageTypeTemporary;
 }
 
 }  // namespace content