Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(238)

Unified Diff: net/disk_cache/simple/simple_entry_impl.cc

Issue 22859060: Fix race condition for non-open/create operations happening after a doom. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Rebase Created 7 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/disk_cache/simple/simple_entry_impl.h ('k') | net/disk_cache/simple/simple_entry_operation.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: net/disk_cache/simple/simple_entry_impl.cc
diff --git a/net/disk_cache/simple/simple_entry_impl.cc b/net/disk_cache/simple/simple_entry_impl.cc
index cfc2689622b7b4495aaafc278584f8131c590237..d270098c34d7841633f1444e5a07fd47830b6237 100644
--- a/net/disk_cache/simple/simple_entry_impl.cc
+++ b/net/disk_cache/simple/simple_entry_impl.cc
@@ -15,6 +15,7 @@
#include "base/logging.h"
#include "base/message_loop/message_loop_proxy.h"
#include "base/task_runner.h"
+#include "base/task_runner_util.h"
#include "base/time/time.h"
#include "net/base/io_buffer.h"
#include "net/base/net_errors.h"
@@ -264,12 +265,8 @@ int SimpleEntryImpl::DoomEntry(const CompletionCallback& callback) {
net_log_.AddEvent(net::NetLog::TYPE_SIMPLE_CACHE_ENTRY_DOOM_BEGIN);
MarkAsDoomed();
- scoped_ptr<int> result(new int());
- Closure task = base::Bind(&SimpleSynchronousEntry::DoomEntry, path_, key_,
- entry_hash_, result.get());
- Closure reply = base::Bind(&CallCompletionCallback,
- callback, base::Passed(&result));
- worker_pool_->PostTaskAndReply(FROM_HERE, task, reply);
+ pending_operations_.push(SimpleEntryOperation::DoomOperation(this, callback));
+ RunNextOperationIfNeeded();
return net::ERR_IO_PENDING;
}
@@ -587,6 +584,9 @@ void SimpleEntryImpl::RunNextOperationIfNeeded() {
operation->callback(),
operation->truncate());
break;
+ case SimpleEntryOperation::TYPE_DOOM:
+ DoomEntryInternal(operation->callback());
+ break;
default:
NOTREACHED();
}
@@ -613,7 +613,8 @@ void SimpleEntryImpl::OpenEntryInternal(bool have_index,
net::NetLog::TYPE_SIMPLE_CACHE_ENTRY_OPEN_END,
CreateNetLogSimpleEntryCreationCallback(this, net::OK));
return;
- } else if (state_ == STATE_FAILURE) {
+ }
+ if (state_ == STATE_FAILURE) {
if (!callback.is_null()) {
MessageLoopProxy::current()->PostTask(FROM_HERE, base::Bind(
callback, net::ERR_FAILED));
@@ -743,7 +744,6 @@ void SimpleEntryImpl::CloseInternal() {
}
}
} else {
- synchronous_entry_ = NULL;
CloseOperationComplete();
}
}
@@ -901,6 +901,15 @@ void SimpleEntryImpl::WriteDataInternal(int stream_index,
worker_pool_->PostTaskAndReply(FROM_HERE, task, reply);
}
+void SimpleEntryImpl::DoomEntryInternal(const CompletionCallback& callback) {
+ PostTaskAndReplyWithResult(
+ worker_pool_, FROM_HERE,
+ base::Bind(&SimpleSynchronousEntry::DoomEntry, path_, key_, entry_hash_),
+ base::Bind(&SimpleEntryImpl::DoomOperationComplete, this, callback,
+ state_));
+ state_ = STATE_IO_PENDING;
+}
+
void SimpleEntryImpl::CreationOperationComplete(
const CompletionCallback& completion_callback,
const base::TimeTicks& start_time,
@@ -1073,6 +1082,15 @@ void SimpleEntryImpl::WriteOperationComplete(
stream_index, completion_callback, *entry_stat, result.Pass());
}
+void SimpleEntryImpl::DoomOperationComplete(const CompletionCallback& callback,
+ State state_to_restore,
+ int result) {
+ state_ = state_to_restore;
+ if (!callback.is_null())
+ callback.Run(result);
+ RunNextOperationIfNeeded();
+}
+
void SimpleEntryImpl::ChecksumOperationComplete(
int orig_result,
int stream_index,
« no previous file with comments | « net/disk_cache/simple/simple_entry_impl.h ('k') | net/disk_cache/simple/simple_entry_operation.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698