AppCache: Use a dedicated thread for the disk cache.

webkit/appcache/appcache_disk_cache.cc

 // Copyright (c) 2010 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/appcache/appcache_disk_cache.h"
 
 #include "base/file_path.h"
 #include "base/logging.h"
 #include "base/string_util.h"
 #include "net/base/net_errors.h"
 
 namespace appcache {
 
 AppCacheDiskCache::AppCacheDiskCache()
     : is_disabled_(false), init_callback_(NULL) {
 }
 
 AppCacheDiskCache::~AppCacheDiskCache() {
   if (create_backend_callback_) {
     create_backend_callback_->Cancel();
     create_backend_callback_.release();
     OnCreateBackendComplete(net::ERR_ABORTED);
   }
 }
 
 int AppCacheDiskCache::InitWithDiskBackend(
     const FilePath& disk_cache_directory, int disk_cache_size, bool force,
-    net::CompletionCallback* callback) {
+    base::MessageLoopProxy* cache_thread, net::CompletionCallback* callback) {
   return Init(net::APP_CACHE, disk_cache_directory,
-              disk_cache_size, force, callback);
+              disk_cache_size, force, cache_thread, callback);
 }
 
 int AppCacheDiskCache::InitWithMemBackend(
     int mem_cache_size, net::CompletionCallback* callback) {
-  return Init(net::MEMORY_CACHE, FilePath(), mem_cache_size, false, callback);
+  return Init(net::MEMORY_CACHE, FilePath(), mem_cache_size, false, NULL,
+              callback);
 }
 
 void AppCacheDiskCache::Disable() {
   if (is_disabled_)
     return;
 
   is_disabled_ = true;
 
   if (create_backend_callback_) {
     create_backend_callback_->Cancel();
@@ skipping 46 matching lines @@
 
   if (!disk_cache_.get())
     return net::ERR_FAILED;
 
   return disk_cache_->DoomEntry(Int64ToString(key), callback);
 }
 
 int AppCacheDiskCache::Init(net::CacheType cache_type,
                             const FilePath& cache_directory,
                             int cache_size, bool force,
+                            base::MessageLoopProxy* cache_thread,
                             net::CompletionCallback* callback) {
   DCHECK(!is_initializing() && !disk_cache_.get());
   is_disabled_ = false;
   create_backend_callback_ = new CreateBackendCallback(
       this, &AppCacheDiskCache::OnCreateBackendComplete);
 
-  // TODO(michaeln): Pass a valid cache_thread here.
   int rv = disk_cache::CreateCacheBackend(
-      cache_type, cache_directory, cache_size, force, NULL,
+      cache_type, cache_directory, cache_size, force, cache_thread,
       &(create_backend_callback_->backend_ptr_), create_backend_callback_);
   if (rv == net::ERR_IO_PENDING)
     init_callback_ = callback;
   else
     OnCreateBackendComplete(rv);
   return rv;
 }
 
 void AppCacheDiskCache::OnCreateBackendComplete(int rv) {
   if (rv == net::OK) {
@@ skipping 27 matching lines @@
         break;
     }
     if (rv != net::ERR_IO_PENDING)
       iter->callback->Run(rv);
   }
   pending_calls_.clear();
 }
 
 }  // namespace appcache