Http cache: Add support for a dedicated cache thread.

net/http/http_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 "net/http/http_cache.h"
 
 #include <algorithm>
 
 #include "base/compiler_specific.h"
 
@@ skipping 183 matching lines @@
 }
 
 //-----------------------------------------------------------------------------
 
 HttpCache::HttpCache(NetworkChangeNotifier* network_change_notifier,
                      HostResolver* host_resolver,
                      ProxyService* proxy_service,
                      SSLConfigService* ssl_config_service,
                      HttpAuthHandlerFactory* http_auth_handler_factory,
                      const FilePath& cache_dir,
+                     MessageLoop* cache_thread,
                      int cache_size)
     : disk_cache_dir_(cache_dir),
+      cache_thread_(cache_thread),
       mode_(NORMAL),
       type_(DISK_CACHE),
       network_layer_(HttpNetworkLayer::CreateFactory(
           network_change_notifier, host_resolver, proxy_service,
           ssl_config_service, http_auth_handler_factory)),
       ALLOW_THIS_IN_INITIALIZER_LIST(task_factory_(this)),
       enable_range_support_(true),
       cache_size_(cache_size) {
 }
 
 HttpCache::HttpCache(HttpNetworkSession* session,
                      const FilePath& cache_dir,
+                     MessageLoop* cache_thread,
                      int cache_size)
     : disk_cache_dir_(cache_dir),
+      cache_thread_(cache_thread),
       mode_(NORMAL),
       type_(DISK_CACHE),
       network_layer_(HttpNetworkLayer::CreateFactory(session)),
       ALLOW_THIS_IN_INITIALIZER_LIST(task_factory_(this)),
       enable_range_support_(true),
       cache_size_(cache_size) {
 }
 
 HttpCache::HttpCache(NetworkChangeNotifier* network_change_notifier,
                      HostResolver* host_resolver,
@@ skipping 52 matching lines @@
     // was an in-memory cache.
     disk_cache_.reset(disk_cache::CreateInMemoryCacheBackend(cache_size_));
   } else if (!disk_cache_dir_.empty()) {
     disk_cache_.reset(disk_cache::CreateCacheBackend(disk_cache_dir_, true,
         cache_size_, type_));
     disk_cache_dir_ = FilePath();  // Reclaim memory.
   }
   return disk_cache_.get();
 }
 
+int HttpCache::GetBackend(disk_cache::Backend** backend,
+                          CompletionCallback* callback) {
+  DCHECK(callback != NULL);
+  *backend = GetBackend();
+  return OK;
+}
+
 int HttpCache::CreateTransaction(scoped_ptr<HttpTransaction>* trans) {
   // Do lazy initialization of disk cache if needed.
   GetBackend();
   trans->reset(new HttpCache::Transaction(this, enable_range_support_));
   return OK;
 }
 
 HttpCache* HttpCache::GetCache() {
   return this;
 }
@@ skipping 600 matching lines @@
         item->NotifyTransaction(ERR_CACHE_RACE, NULL);
         fail_requests = true;
       } else {
         item->NotifyTransaction(result, entry);
       }
     }
   }
 }
 
 }  // namespace net