| Index: chrome/browser/sync/engine/update_applicator.cc
|
| ===================================================================
|
| --- chrome/browser/sync/engine/update_applicator.cc (revision 30625)
|
| +++ chrome/browser/sync/engine/update_applicator.cc (working copy)
|
| @@ -15,10 +15,13 @@
|
|
|
| namespace browser_sync {
|
|
|
| -UpdateApplicator::UpdateApplicator(SyncerSession* session,
|
| - const vi64iter& begin,
|
| - const vi64iter& end)
|
| - : session_(session), begin_(begin), end_(end), pointer_(begin),
|
| +UpdateApplicator::UpdateApplicator(ConflictResolver* resolver,
|
| + const UpdateIterator& begin,
|
| + const UpdateIterator& end)
|
| + : resolver_(resolver),
|
| + begin_(begin),
|
| + end_(end),
|
| + pointer_(begin),
|
| progress_(false) {
|
| size_t item_count = end - begin;
|
| LOG(INFO) << "UpdateApplicator created for " << item_count << " items.";
|
| @@ -45,7 +48,7 @@
|
| }
|
| syncable::MutableEntry entry(trans, syncable::GET_BY_HANDLE, *pointer_);
|
| UpdateAttemptResponse updateResponse =
|
| - SyncerUtil::AttemptToUpdateEntry(trans, &entry, session_);
|
| + SyncerUtil::AttemptToUpdateEntry(trans, &entry, resolver_);
|
| switch (updateResponse) {
|
| case SUCCESS:
|
| --end_;
|
| @@ -76,25 +79,25 @@
|
| begin_ == end_;
|
| }
|
|
|
| -void UpdateApplicator::SaveProgressIntoSessionState() {
|
| +void UpdateApplicator::SaveProgressIntoSessionState(SyncerSession* session) {
|
| DCHECK(begin_ == end_ || ((pointer_ == end_) && !progress_))
|
| << "SaveProgress called before updates exhausted.";
|
|
|
| vector<syncable::Id>::const_iterator i;
|
| for (i = conflicting_ids_.begin(); i != conflicting_ids_.end(); ++i) {
|
| - session_->EraseBlockedItem(*i);
|
| - session_->AddCommitConflict(*i);
|
| - session_->AddAppliedUpdate(CONFLICT, *i);
|
| + session->EraseBlockedItem(*i);
|
| + session->AddCommitConflict(*i);
|
| + session->AddAppliedUpdate(CONFLICT, *i);
|
| }
|
| for (i = blocked_ids_.begin(); i != blocked_ids_.end(); ++i) {
|
| - session_->AddBlockedItem(*i);
|
| - session_->EraseCommitConflict(*i);
|
| - session_->AddAppliedUpdate(BLOCKED, *i);
|
| + session->AddBlockedItem(*i);
|
| + session->EraseCommitConflict(*i);
|
| + session->AddAppliedUpdate(BLOCKED, *i);
|
| }
|
| for (i = successful_ids_.begin(); i != successful_ids_.end(); ++i) {
|
| - session_->EraseCommitConflict(*i);
|
| - session_->EraseBlockedItem(*i);
|
| - session_->AddAppliedUpdate(SUCCESS, *i);
|
| + session->EraseCommitConflict(*i);
|
| + session->EraseBlockedItem(*i);
|
| + session->AddAppliedUpdate(SUCCESS, *i);
|
| }
|
| }
|
|
|
|
|