Commit 3bcb9770 authored by Maks Orlovich's avatar Maks Orlovich Committed by Commit Bot

SimpleCache: pass result to EntryOperationComplete by value.

This lets me change how it's actually passed to op-specific Complete
callbacks freely, which I want to do, but is easier to review as a
separate change, plus moving a unique_ptr to int feels a bit... silly.

Change-Id: If8a3f445779477c4388daf060608fe64858507ec
Reviewed-on: https://chromium-review.googlesource.com/902522Reviewed-by: default avatarHelen Li <xunjieli@chromium.org>
Commit-Queue: Maks Orlovich <morlovich@chromium.org>
Cr-Commit-Position: refs/heads/master@{#534684}
parent 6ada544c
...@@ -1339,12 +1339,11 @@ void SimpleEntryImpl::CreationOperationComplete( ...@@ -1339,12 +1339,11 @@ void SimpleEntryImpl::CreationOperationComplete(
void SimpleEntryImpl::EntryOperationComplete( void SimpleEntryImpl::EntryOperationComplete(
const CompletionCallback& completion_callback, const CompletionCallback& completion_callback,
const SimpleEntryStat& entry_stat, const SimpleEntryStat& entry_stat,
std::unique_ptr<int> result) { int result) {
DCHECK(io_thread_checker_.CalledOnValidThread()); DCHECK(io_thread_checker_.CalledOnValidThread());
DCHECK(synchronous_entry_); DCHECK(synchronous_entry_);
DCHECK_EQ(STATE_IO_PENDING, state_); DCHECK_EQ(STATE_IO_PENDING, state_);
DCHECK(result); if (result < 0) {
if (*result < 0) {
state_ = STATE_FAILURE; state_ = STATE_FAILURE;
MarkAsDoomed(DOOM_COMPLETED); MarkAsDoomed(DOOM_COMPLETED);
} else { } else {
...@@ -1354,7 +1353,7 @@ void SimpleEntryImpl::EntryOperationComplete( ...@@ -1354,7 +1353,7 @@ void SimpleEntryImpl::EntryOperationComplete(
if (!completion_callback.is_null()) { if (!completion_callback.is_null()) {
base::ThreadTaskRunnerHandle::Get()->PostTask( base::ThreadTaskRunnerHandle::Get()->PostTask(
FROM_HERE, base::Bind(completion_callback, *result)); FROM_HERE, base::Bind(completion_callback, result));
} }
RunNextOperationIfNeeded(); RunNextOperationIfNeeded();
} }
...@@ -1401,7 +1400,7 @@ void SimpleEntryImpl::ReadOperationComplete( ...@@ -1401,7 +1400,7 @@ void SimpleEntryImpl::ReadOperationComplete(
CreateNetLogReadWriteCompleteCallback(*result)); CreateNetLogReadWriteCompleteCallback(*result));
} }
EntryOperationComplete(completion_callback, *entry_stat, std::move(result)); EntryOperationComplete(completion_callback, *entry_stat, *result);
} }
void SimpleEntryImpl::WriteOperationComplete( void SimpleEntryImpl::WriteOperationComplete(
...@@ -1423,7 +1422,7 @@ void SimpleEntryImpl::WriteOperationComplete( ...@@ -1423,7 +1422,7 @@ void SimpleEntryImpl::WriteOperationComplete(
crc32s_end_offset_[stream_index] = 0; crc32s_end_offset_[stream_index] = 0;
} }
EntryOperationComplete(completion_callback, *entry_stat, std::move(result)); EntryOperationComplete(completion_callback, *entry_stat, *result);
} }
void SimpleEntryImpl::ReadSparseOperationComplete( void SimpleEntryImpl::ReadSparseOperationComplete(
...@@ -1441,7 +1440,7 @@ void SimpleEntryImpl::ReadSparseOperationComplete( ...@@ -1441,7 +1440,7 @@ void SimpleEntryImpl::ReadSparseOperationComplete(
SimpleEntryStat entry_stat(*last_used, last_modified_, data_size_, SimpleEntryStat entry_stat(*last_used, last_modified_, data_size_,
sparse_data_size_); sparse_data_size_);
EntryOperationComplete(completion_callback, entry_stat, std::move(result)); EntryOperationComplete(completion_callback, entry_stat, *result);
} }
void SimpleEntryImpl::WriteSparseOperationComplete( void SimpleEntryImpl::WriteSparseOperationComplete(
...@@ -1457,7 +1456,7 @@ void SimpleEntryImpl::WriteSparseOperationComplete( ...@@ -1457,7 +1456,7 @@ void SimpleEntryImpl::WriteSparseOperationComplete(
CreateNetLogReadWriteCompleteCallback(*result)); CreateNetLogReadWriteCompleteCallback(*result));
} }
EntryOperationComplete(completion_callback, *entry_stat, std::move(result)); EntryOperationComplete(completion_callback, *entry_stat, *result);
} }
void SimpleEntryImpl::GetAvailableRangeOperationComplete( void SimpleEntryImpl::GetAvailableRangeOperationComplete(
...@@ -1469,7 +1468,7 @@ void SimpleEntryImpl::GetAvailableRangeOperationComplete( ...@@ -1469,7 +1468,7 @@ void SimpleEntryImpl::GetAvailableRangeOperationComplete(
SimpleEntryStat entry_stat(last_used_, last_modified_, data_size_, SimpleEntryStat entry_stat(last_used_, last_modified_, data_size_,
sparse_data_size_); sparse_data_size_);
EntryOperationComplete(completion_callback, entry_stat, std::move(result)); EntryOperationComplete(completion_callback, entry_stat, *result);
} }
void SimpleEntryImpl::DoomOperationComplete( void SimpleEntryImpl::DoomOperationComplete(
......
...@@ -271,7 +271,7 @@ class NET_EXPORT_PRIVATE SimpleEntryImpl : public Entry, ...@@ -271,7 +271,7 @@ class NET_EXPORT_PRIVATE SimpleEntryImpl : public Entry,
// |completion_callback| after updating state and dooming on errors. // |completion_callback| after updating state and dooming on errors.
void EntryOperationComplete(const CompletionCallback& completion_callback, void EntryOperationComplete(const CompletionCallback& completion_callback,
const SimpleEntryStat& entry_stat, const SimpleEntryStat& entry_stat,
std::unique_ptr<int> result); int result);
// Called after an asynchronous read. Updates |crc32s_| if possible. // Called after an asynchronous read. Updates |crc32s_| if possible.
void ReadOperationComplete( void ReadOperationComplete(
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment