Create a secondary file thread, FILE_USER_BLOCKING...

chrome/browser/browser_process_impl.cc

 // Copyright (c) 2011 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 "chrome/browser/browser_process_impl.h"
 
 #include <map>
 #include <set>
 #include <vector>
 
@@ skipping 119 matching lines @@
 #endif
 
 BrowserProcessImpl::BrowserProcessImpl(const CommandLine& command_line)
     : created_resource_dispatcher_host_(false),
       created_metrics_service_(false),
       created_io_thread_(false),
       created_file_thread_(false),
       created_db_thread_(false),
       created_process_launcher_thread_(false),
       created_cache_thread_(false),
+      created_appcache_thread_(false),
       created_watchdog_thread_(false),
 #if defined(OS_CHROMEOS)
       created_web_socket_proxy_thread_(false),
 #endif
       created_profile_manager_(false),
       created_local_state_(false),
       created_icon_manager_(false),
       created_devtools_manager_(false),
       created_sidebar_manager_(false),
       created_browser_policy_connector_(false),
@@ skipping 103 matching lines @@
 
   // Stop the watchdog thread before stopping other threads.
   watchdog_thread_.reset();
 
   // Need to stop io_thread_ before resource_dispatcher_host_, since
   // io_thread_ may still deref ResourceDispatcherHost and handle resource
   // request before going away.
   io_thread_.reset();
 
   // The IO thread was the only user of this thread.
+  appcache_thread_.reset();
+
+  // The IO thread was the only user of this thread.
   cache_thread_.reset();
 
   // Stop the process launcher thread after the IO thread, in case the IO thread
   // posted a task to terminate a process on the process launcher thread.
   process_launcher_thread_.reset();
 
   // Clean up state that lives on the file_thread_ before it goes away.
   if (resource_dispatcher_host_.get()) {
     resource_dispatcher_host()->download_file_manager()->Shutdown();
     resource_dispatcher_host()->save_file_manager()->Shutdown();
@@ skipping 158 matching lines @@
   return process_launcher_thread_.get();
 }
 
 base::Thread* BrowserProcessImpl::cache_thread() {
   DCHECK(CalledOnValidThread());
   if (!created_cache_thread_)
     CreateCacheThread();
   return cache_thread_.get();
 }
 
+base::Thread* BrowserProcessImpl::appcache_thread() {
+  DCHECK(CalledOnValidThread());
+  if (!created_appcache_thread_)
+    CreateAppCacheThread();
+  return appcache_thread_.get();
+}
+
+
 WatchDogThread* BrowserProcessImpl::watchdog_thread() {
   DCHECK(CalledOnValidThread());
   if (!created_watchdog_thread_)
     CreateWatchdogThread();
   DCHECK(watchdog_thread_.get() != NULL);
   return watchdog_thread_.get();
 }
 
 #if defined(OS_CHROMEOS)
 base::Thread* BrowserProcessImpl::web_socket_proxy_thread() {
@@ skipping 443 matching lines @@
 
   scoped_ptr<base::Thread> thread(
       new BrowserThread(BrowserThread::CACHE));
   base::Thread::Options options;
   options.message_loop_type = MessageLoop::TYPE_IO;
   if (!thread->StartWithOptions(options))
     return;
   cache_thread_.swap(thread);
 }
 
+void BrowserProcessImpl::CreateAppCacheThread() {
+  DCHECK(!created_appcache_thread_ && !appcache_thread_.get());
+  created_appcache_thread_ = true;
+
+  scoped_ptr<base::Thread> thread(
+      new BrowserThread(BrowserThread::APPCACHE));

[rvargas (doing something else), 2011/10/21 19:46:17]

Just double checking that you don't intend to use async io on this thread.

[michaeln, 2011/10/21 19:52:12]

definitely not right now, i don't anticipate doing so ever, if i eventually do
i'll change the options accordingly

+  if (!thread->Start())
+    return;
+  appcache_thread_.swap(thread);
+}
+
 void BrowserProcessImpl::CreateWatchdogThread() {
   DCHECK(!created_watchdog_thread_ && watchdog_thread_.get() == NULL);
   created_watchdog_thread_ = true;
 
   scoped_ptr<WatchDogThread> thread(new WatchDogThread());
   if (!thread->Start())
     return;
   watchdog_thread_.swap(thread);
 }
 
@@ skipping 242 matching lines @@
 }
 
 void BrowserProcessImpl::OnAutoupdateTimer() {
   if (CanAutorestartForUpdate()) {
     DLOG(WARNING) << "Detected update.  Restarting browser.";
     RestartPersistentInstance();
   }
 }
 
 #endif  // (defined(OS_WIN) || defined(OS_LINUX)) && !defined(OS_CHROMEOS)