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

Side by Side Diff: sync/engine/get_commit_ids_command.cc

Issue 11636006: WIP: The Bookmark Position Megapatch (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Various updates, including switch suffix to unique_client_tag style Created 8 years 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 unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « sync/engine/conflict_resolver.cc ('k') | sync/engine/process_commit_response_command.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "sync/engine/get_commit_ids_command.h" 5 #include "sync/engine/get_commit_ids_command.h"
6 6
7 #include <set> 7 #include <set>
8 #include <utility> 8 #include <utility>
9 #include <vector> 9 #include <vector>
10 10
(...skipping 230 matching lines...) Expand 10 before | Expand all | Expand 10 after
241 if (commit_set_->HaveCommitItem(item_handle)) { 241 if (commit_set_->HaveCommitItem(item_handle)) {
242 // We've already added this item to the commit set, and so must have 242 // We've already added this item to the commit set, and so must have
243 // already added the predecessors as well. 243 // already added the predecessors as well.
244 return true; 244 return true;
245 } 245 }
246 if (!AddItem(ready_unsynced_set, item, result)) 246 if (!AddItem(ready_unsynced_set, item, result))
247 return false; // Item is in conflict. 247 return false; // Item is in conflict.
248 if (item.Get(syncable::IS_DEL)) 248 if (item.Get(syncable::IS_DEL))
249 return true; // Deleted items have no predecessors. 249 return true; // Deleted items have no predecessors.
250 250
251 syncable::Id prev_id = item.Get(syncable::PREV_ID); 251 syncable::Id prev_id = item.GetPredecessorId();
252 while (!prev_id.IsRoot()) { 252 while (!prev_id.IsRoot()) {
253 syncable::Entry prev(trans, syncable::GET_BY_ID, prev_id); 253 syncable::Entry prev(trans, syncable::GET_BY_ID, prev_id);
254 CHECK(prev.good()) << "Bad id when walking predecessors."; 254 CHECK(prev.good()) << "Bad id when walking predecessors.";
255 if (!prev.Get(syncable::IS_UNSYNCED)) 255 if (!prev.Get(syncable::IS_UNSYNCED))
256 break; 256 break;
257 int64 handle = prev.Get(syncable::META_HANDLE); 257 int64 handle = prev.Get(syncable::META_HANDLE);
258 if (commit_set_->HaveCommitItem(handle)) { 258 if (commit_set_->HaveCommitItem(handle)) {
259 // We've already added this item to the commit set, and so must have 259 // We've already added this item to the commit set, and so must have
260 // already added the predecessors as well. 260 // already added the predecessors as well.
261 return true; 261 return true;
262 } 262 }
263 if (!AddItem(ready_unsynced_set, prev, result)) 263 if (!AddItem(ready_unsynced_set, prev, result))
264 return false; // Item is in conflict. 264 return false; // Item is in conflict.
265 prev_id = prev.Get(syncable::PREV_ID); 265 prev_id = prev.GetPredecessorId();
266 } 266 }
267 return true; 267 return true;
268 } 268 }
269 269
270 bool GetCommitIdsCommand::AddPredecessorsThenItem( 270 bool GetCommitIdsCommand::AddPredecessorsThenItem(
271 syncable::BaseTransaction* trans, 271 syncable::BaseTransaction* trans,
272 const ModelSafeRoutingInfo& routes, 272 const ModelSafeRoutingInfo& routes,
273 const std::set<int64>& ready_unsynced_set, 273 const std::set<int64>& ready_unsynced_set,
274 const syncable::Entry& item, 274 const syncable::Entry& item,
275 OrderedCommitSet* result) const { 275 OrderedCommitSet* result) const {
(...skipping 152 matching lines...) Expand 10 before | Expand all | Expand 10 after
428 // delete trees. 428 // delete trees.
429 429
430 // Add moves and creates, and prepend their uncommitted parents. 430 // Add moves and creates, and prepend their uncommitted parents.
431 AddCreatesAndMoves(write_transaction, routes, ready_unsynced_set); 431 AddCreatesAndMoves(write_transaction, routes, ready_unsynced_set);
432 432
433 // Add all deletes. 433 // Add all deletes.
434 AddDeletes(write_transaction, ready_unsynced_set); 434 AddDeletes(write_transaction, ready_unsynced_set);
435 } 435 }
436 436
437 } // namespace syncer 437 } // namespace syncer
OLDNEW
« no previous file with comments | « sync/engine/conflict_resolver.cc ('k') | sync/engine/process_commit_response_command.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698