AppCache: Use a dedicated thread for the disk cache.

webkit/tools/test_shell/simple_appcache_system.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/tools/test_shell/simple_appcache_system.h"
 
 #include "base/callback.h"
 #include "base/lock.h"
 #include "base/task.h"
 #include "base/waitable_event.h"
@@ skipping 313 matching lines @@
   if (db_thread_.IsRunning()) {
     // We pump a task thru the db thread to ensure any tasks previously
     // scheduled on that thread have been performed prior to return.
     base::WaitableEvent event(false, false);
     db_thread_.message_loop()->PostTask(FROM_HERE,
         NewRunnableFunction(&SignalEvent, &event));
     event.Wait();
   }
 }
 
-void SimpleAppCacheSystem::InitOnUIThread(
-    const FilePath& cache_directory) {
+void SimpleAppCacheSystem::InitOnUIThread(const FilePath& cache_directory) {
   DCHECK(!ui_message_loop_);
-  // TODO(michaeln): provide a cache_thread message loop
-  AppCacheThread::Init(DB_THREAD_ID, IO_THREAD_ID, NULL);
+  AppCacheThread::Init(DB_THREAD_ID, IO_THREAD_ID);
   ui_message_loop_ = MessageLoop::current();
   cache_directory_ = cache_directory;
 }
 
 void SimpleAppCacheSystem::InitOnIOThread(URLRequestContext* request_context) {
   if (!is_initailized_on_ui_thread())
     return;
 
   DCHECK(!io_message_loop_);
   io_message_loop_ = MessageLoop::current();
   io_message_loop_->AddDestructionObserver(this);
 
   if (!db_thread_.IsRunning())
     db_thread_.Start();
 
   // Recreate and initialize per each IO thread.
   service_ = new appcache::AppCacheService();
   backend_impl_ = new appcache::AppCacheBackendImpl();
-  service_->Initialize(cache_directory_);
+  service_->Initialize(cache_directory_,
+                       SimpleResourceLoaderBridge::GetCacheThread());
   service_->set_request_context(request_context);
   backend_impl_->Initialize(service_, frontend_proxy_.get(), kSingleProcessId);
 
   AppCacheInterceptor::EnsureRegistered();
 }
 
 WebApplicationCacheHost* SimpleAppCacheSystem::CreateCacheHostForWebKit(
     WebApplicationCacheHostClient* client) {
   if (!is_initailized_on_ui_thread())
     return NULL;
@@ skipping 31 matching lines @@
 
   delete backend_impl_;
   delete service_;
   backend_impl_ = NULL;
   service_ = NULL;
   io_message_loop_ = NULL;
 
   // Just in case the main thread is waiting on it.
   backend_proxy_->SignalEvent();
 }