Make MediaFileUtil run on thread pool.

webkit/fileapi/file_system_context.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 "webkit/fileapi/file_system_context.h"
 
 #include "base/bind.h"
 #include "base/file_util.h"
 #include "base/stl_util.h"
 #include "base/single_thread_task_runner.h"
 #include "googleurl/src/gurl.h"
 #include "webkit/fileapi/file_system_file_util.h"
 #include "webkit/fileapi/file_system_operation_interface.h"
 #include "webkit/fileapi/file_system_options.h"
 #include "webkit/fileapi/file_system_quota_client.h"
+#include "webkit/fileapi/file_system_task_runners.h"
 #include "webkit/fileapi/file_system_url.h"
 #include "webkit/fileapi/file_system_util.h"
 #include "webkit/fileapi/isolated_mount_point_provider.h"
 #include "webkit/fileapi/sandbox_mount_point_provider.h"
 #include "webkit/quota/quota_manager.h"
 #include "webkit/quota/special_storage_policy.h"
 
 #if defined(OS_CHROMEOS)
 #include "webkit/chromeos/fileapi/cros_mount_point_provider.h"
 #endif
@@ skipping 14 matching lines @@
     const FileSystemContext::OpenFileSystemCallback& callback,
     const GURL& filesystem_root,
     const std::string& filesystem_name,
     base::PlatformFileError error) {
   callback.Run(error, filesystem_name, filesystem_root);
 }
 
 }  // anonymous namespace
 
 FileSystemContext::FileSystemContext(
-    base::SequencedTaskRunner* file_task_runner,
-    base::SingleThreadTaskRunner* io_task_runner,
+    scoped_ptr<FileSystemTaskRunners> task_runners,
     quota::SpecialStoragePolicy* special_storage_policy,
     quota::QuotaManagerProxy* quota_manager_proxy,
     const FilePath& profile_path,
     const FileSystemOptions& options)
-    : file_task_runner_(file_task_runner),
-      io_task_runner_(io_task_runner),
+    : task_runners_(task_runners.Pass()),
       quota_manager_proxy_(quota_manager_proxy),
       sandbox_provider_(
           new SandboxMountPointProvider(
-              file_task_runner,
+              task_runners_->file_task_runner(),
               profile_path,
               options)),
       isolated_provider_(new IsolatedMountPointProvider(profile_path)) {
+  DCHECK(task_runners_.get());
+
   if (quota_manager_proxy) {
     quota_manager_proxy->RegisterClient(CreateQuotaClient(
             this, options.is_incognito()));
   }
 #if defined(OS_CHROMEOS)
   external_provider_.reset(
       new chromeos::CrosMountPointProvider(special_storage_policy));
 #endif
 }
 
 bool FileSystemContext::DeleteDataForOriginOnFileThread(
     const GURL& origin_url) {
-  DCHECK(file_task_runner_->RunsTasksOnCurrentThread());
+  DCHECK(task_runners_->file_task_runner()->RunsTasksOnCurrentThread());
   DCHECK(sandbox_provider());
 
   // Delete temporary and persistent data.
   return
       (sandbox_provider()->DeleteOriginDataOnFileThread(
           this, quota_manager_proxy(), origin_url, kFileSystemTypeTemporary) ==
        base::PLATFORM_FILE_OK) &&
       (sandbox_provider()->DeleteOriginDataOnFileThread(
           this, quota_manager_proxy(), origin_url, kFileSystemTypePersistent) ==
        base::PLATFORM_FILE_OK);
@@ skipping 113 matching lines @@
     FileSystemType type,
     FileSystemMountPointProvider* provider) {
   DCHECK(provider);
   DCHECK(provider_map_.find(type) == provider_map_.end());
   provider_map_[type] = provider;
 }
 
 FileSystemContext::~FileSystemContext() {}
 
 void FileSystemContext::DeleteOnCorrectThread() const {
-  if (!io_task_runner_->RunsTasksOnCurrentThread() &&
-      io_task_runner_->DeleteSoon(FROM_HERE, this)) {
+  if (!task_runners_->io_task_runner()->RunsTasksOnCurrentThread() &&
+      task_runners_->io_task_runner()->DeleteSoon(FROM_HERE, this)) {
     return;
   }
   STLDeleteContainerPairSecondPointers(provider_map_.begin(),
                                        provider_map_.end());
   delete this;
 }
 
 }  // namespace fileapi