| Index: sync/engine/update_applicator.cc
|
| diff --git a/sync/engine/update_applicator.cc b/sync/engine/update_applicator.cc
|
| index 3edf1f84b3469ab3435d3be0440bb225cd4fc931..e8731cecf4c06fe29691447f156d1bb81a8ea848 100644
|
| --- a/sync/engine/update_applicator.cc
|
| +++ b/sync/engine/update_applicator.cc
|
| @@ -19,12 +19,8 @@ namespace syncer {
|
|
|
| using syncable::ID;
|
|
|
| -UpdateApplicator::UpdateApplicator(Cryptographer* cryptographer,
|
| - const ModelSafeRoutingInfo& routes,
|
| - ModelSafeGroup group_filter)
|
| +UpdateApplicator::UpdateApplicator(Cryptographer* cryptographer)
|
| : cryptographer_(cryptographer),
|
| - group_filter_(group_filter),
|
| - routing_info_(routes),
|
| updates_applied_(0),
|
| encryption_conflicts_(0),
|
| hierarchy_conflicts_(0) {
|
| @@ -58,11 +54,6 @@ void UpdateApplicator::AttemptApplications(
|
|
|
| for (std::vector<int64>::iterator i = to_apply.begin();
|
| i != to_apply.end(); ++i) {
|
| - syncable::Entry read_entry(trans, syncable::GET_BY_HANDLE, *i);
|
| - if (SkipUpdate(read_entry)) {
|
| - continue;
|
| - }
|
| -
|
| syncable::MutableEntry entry(trans, syncable::GET_BY_HANDLE, *i);
|
| UpdateAttemptResponse result = AttemptToUpdateEntry(
|
| trans, &entry, cryptographer_);
|
| @@ -103,23 +94,4 @@ void UpdateApplicator::AttemptApplications(
|
| }
|
| }
|
|
|
| -bool UpdateApplicator::SkipUpdate(const syncable::Entry& entry) {
|
| - ModelType type = entry.GetServerModelType();
|
| - ModelSafeGroup g = GetGroupForModelType(type, routing_info_);
|
| - // The set of updates passed to the UpdateApplicator should already
|
| - // be group-filtered.
|
| - if (g != group_filter_) {
|
| - NOTREACHED();
|
| - return true;
|
| - }
|
| - if (g == GROUP_PASSIVE &&
|
| - !routing_info_.count(type) &&
|
| - type != UNSPECIFIED &&
|
| - type != TOP_LEVEL_FOLDER) {
|
| - DVLOG(1) << "Skipping update application, type not permitted.";
|
| - return true;
|
| - }
|
| - return false;
|
| -}
|
| -
|
| } // namespace syncer
|
|
|