Index: net/disk_cache/cache_creator.cc |
diff --git a/net/disk_cache/cache_creator.cc b/net/disk_cache/cache_creator.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..718fc0dcf827eb0234e1caef4fd80b7ff1fff22c |
--- /dev/null |
+++ b/net/disk_cache/cache_creator.cc |
@@ -0,0 +1,116 @@ |
+// Copyright (c) 2012 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 "base/file_util.h" |
+#include "base/metrics/field_trial.h" |
+#include "base/stringprintf.h" |
+#include "net/base/net_errors.h" |
+#include "net/disk_cache/backend_impl.h" |
+#include "net/disk_cache/cache_util.h" |
+#include "net/disk_cache/mem_backend_impl.h" |
+#include "net/disk_cache/simple/simple_backend_impl.h" |
+ |
+namespace disk_cache { |
+ |
+CacheCreator::CacheCreator( |
+ const base::FilePath& path, bool force, int max_bytes, |
+ net::CacheType type, uint32 flags, |
+ base::MessageLoopProxy* thread, net::NetLog* net_log, |
+ disk_cache::Backend** backend, |
+ const net::CompletionCallback& callback) |
+ : path_(path), |
+ force_(force), |
+ retry_(false), |
+ max_bytes_(max_bytes), |
+ type_(type), |
+ flags_(flags), |
+ thread_(thread), |
+ backend_(backend), |
+ callback_(callback), |
+ created_cache_(NULL), |
+ net_log_(net_log) { |
+ } |
+ |
+CacheCreator::~CacheCreator() { |
+} |
+ |
+int CacheCreator::Run() { |
+ // TODO(pasko): The two caches should never coexist on disk. Each individual |
+ // cache backend should fail to initialize if it observes the index that does |
+ // not belong to it. |
+ if (base::FieldTrialList::FindFullName("SimpleCacheTrial") == "Yes") { |
+ // TODO(gavinp,pasko): While simple backend development proceeds, we're only |
+ // testing it against net::DISK_CACHE. Turn it on for more cache types as |
+ // appropriate. |
+ if (type_ == net::DISK_CACHE) { |
+ VLOG(1) << "Using the Simple Cache Backend."; |
+ return disk_cache::SimpleBackendImpl::CreateBackend( |
+ path_, max_bytes_, type_, disk_cache::kNone, thread_, net_log_, |
+ backend_, base::Bind(&CacheCreator::OnIOComplete, |
+ base::Unretained(this))); |
+ } |
+ } |
+ disk_cache::BackendImpl* new_cache = |
+ new disk_cache::BackendImpl(path_, thread_, net_log_); |
+ created_cache_ = new_cache; |
+ new_cache->SetMaxSize(max_bytes_); |
+ new_cache->SetType(type_); |
+ new_cache->SetFlags(flags_); |
+ int rv = new_cache->Init( |
+ base::Bind(&CacheCreator::OnIOComplete, base::Unretained(this))); |
+ DCHECK_EQ(net::ERR_IO_PENDING, rv); |
+ return rv; |
+} |
+ |
+void CacheCreator::DoCallback(int result) { |
+ DCHECK_NE(net::ERR_IO_PENDING, result); |
+ if (result == net::OK) { |
+ *backend_ = created_cache_; |
+ } else { |
+ LOG(ERROR) << "Unable to create cache"; |
+ *backend_ = NULL; |
+ delete created_cache_; |
+ } |
+ callback_.Run(result); |
+ delete this; |
+} |
+ |
+// If the initialization of the cache fails, and |force| is true, we will |
+// discard the whole cache and create a new one. |
+void CacheCreator::OnIOComplete(int result) { |
+ if (result == net::OK || !force_ || retry_) |
+ return DoCallback(result); |
+ |
+ // This is a failure and we are supposed to try again, so delete the object, |
+ // delete all the files, and try again. |
+ retry_ = true; |
+ delete created_cache_; |
+ created_cache_ = NULL; |
+ if (!disk_cache::DelayedCacheCleanup(path_)) |
+ return DoCallback(result); |
+ |
+ // The worker thread will start deleting files soon, but the original folder |
+ // is not there anymore... let's create a new set of files. |
+ int rv = Run(); |
+ DCHECK_EQ(net::ERR_IO_PENDING, rv); |
+} |
+ |
+int CreateCacheBackend(net::CacheType type, const base::FilePath& path, |
+ int max_bytes, |
+ bool force, base::MessageLoopProxy* thread, |
+ net::NetLog* net_log, Backend** backend, |
+ const net::CompletionCallback& callback) { |
+ DCHECK(!callback.is_null()); |
+ if (type == net::MEMORY_CACHE) { |
+ *backend = disk_cache::MemBackendImpl::CreateBackend(max_bytes, net_log); |
+ return *backend ? net::OK : net::ERR_FAILED; |
+ } |
+ DCHECK(thread); |
+ CacheCreator* creator = new CacheCreator(path, force, max_bytes, type, kNone, |
+ thread, net_log, backend, callback); |
+ return creator->Run(); |
+} |
+ |
+ |
+} // namespace disk_cache |