AppCache: Use a dedicated thread for the disk cache.

webkit/tools/test_shell/simple_resource_loader_bridge.cc

 // Copyright (c) 2006-2008 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.
 //
 // This file contains an implementation of the ResourceLoaderBridge class.
 // The class is implemented using URLRequest, meaning it is a "simple" version
 // that directly issues requests. The more complicated one used in the
 // browser uses IPC.
 //
 // Because URLRequest only provides an asynchronous resource loading API, this
@@ skipping 68 matching lines @@
         accept_all_cookies(false) {}
 
   FilePath cache_path;
   net::HttpCache::Mode cache_mode;
   bool no_proxy;
   bool accept_all_cookies;
 };
 
 TestShellRequestContextParams* g_request_context_params = NULL;
 URLRequestContext* g_request_context = NULL;
+base::Thread* g_cache_thread = NULL;
 
 //-----------------------------------------------------------------------------
 
 class IOThread : public base::Thread {
  public:
   IOThread() : base::Thread("IOThread") {
   }
 
   ~IOThread() {
     // We cannot rely on our base class to stop the thread since we want our
@@ skipping 627 matching lines @@
   g_request_context_params = new TestShellRequestContextParams(
       cache_path, cache_mode, no_proxy);
 }
 
 // static
 void SimpleResourceLoaderBridge::Shutdown() {
   if (g_io_thread) {
     delete g_io_thread;
     g_io_thread = NULL;
 
+    DCHECK(g_cache_thread);
+    delete g_cache_thread;
+    g_cache_thread = NULL;
+
     DCHECK(!g_request_context) << "should have been nulled by thread dtor";
   } else {
     delete g_request_context_params;
     g_request_context_params = NULL;
   }
 }
 
 // static
 void SimpleResourceLoaderBridge::SetCookie(const GURL& url,
                                            const GURL& first_party_for_cookies,
@@ skipping 35 matching lines @@
 
 #if defined(OS_WIN)
   // Use NSS for SSL on Windows.  TODO(wtc): this should eventually be hidden
   // inside DefaultClientSocketFactory::CreateSSLClientSocket.
   net::ClientSocketFactory::SetSSLClientSocketFactory(
       net::SSLClientSocketNSSFactory);
   // We want to be sure to init NSPR on the main thread.
   base::EnsureNSPRInit();
 #endif
 
+  // Create the cache thread. We want the cache thread to outlive the IO thread,
+  // so its lifetime is bonded to the IO thread lifetime.
+  DCHECK(!g_cache_thread);
+  g_cache_thread = new base::Thread("cache");
+  CHECK(g_cache_thread->StartWithOptions(
+      base::Thread::Options(MessageLoop::TYPE_IO, 0)));
+
   g_io_thread = new IOThread();
   base::Thread::Options options;
   options.message_loop_type = MessageLoop::TYPE_IO;
   return g_io_thread->StartWithOptions(options);
 }
 
 // static
 void SimpleResourceLoaderBridge::SetAcceptAllCookies(bool accept_all_cookies) {
   if (g_request_context_params) {
     g_request_context_params->accept_all_cookies = accept_all_cookies;
     DCHECK(!g_request_context);
     DCHECK(!g_io_thread);
   } else {
     g_io_thread->SetAcceptAllCookies(accept_all_cookies);
   }
 }
+
+// static
+scoped_refptr<base::MessageLoopProxy>
+    SimpleResourceLoaderBridge::GetCacheThread() {
+  return g_cache_thread->message_loop_proxy();
+}