| Index: sync/engine/non_blocking_type_commit_contribution.cc
|
| diff --git a/sync/engine/non_blocking_type_commit_contribution.cc b/sync/engine/non_blocking_type_commit_contribution.cc
|
| index d4506b33e3b5dfc8829184eeed45f22d1dc27388..5e845c8eefaad20ac74d230dc443fef628b74859 100644
|
| --- a/sync/engine/non_blocking_type_commit_contribution.cc
|
| +++ b/sync/engine/non_blocking_type_commit_contribution.cc
|
| @@ -19,12 +19,10 @@ namespace syncer_v2 {
|
| NonBlockingTypeCommitContribution::NonBlockingTypeCommitContribution(
|
| const sync_pb::DataTypeContext& context,
|
| const google::protobuf::RepeatedPtrField<sync_pb::SyncEntity>& entities,
|
| - const std::vector<int64_t>& sequence_numbers,
|
| ModelTypeWorker* worker)
|
| : worker_(worker),
|
| context_(context),
|
| entities_(entities),
|
| - sequence_numbers_(sequence_numbers),
|
| cleaned_up_(false) {}
|
|
|
| NonBlockingTypeCommitContribution::~NonBlockingTypeCommitContribution() {
|
| @@ -54,7 +52,7 @@ syncer::SyncerError NonBlockingTypeCommitContribution::ProcessCommitResponse(
|
|
|
| CommitResponseDataList response_list;
|
|
|
| - for (size_t i = 0; i < sequence_numbers_.size(); ++i) {
|
| + for (int i = 0; i < entities_.size(); ++i) {
|
| const sync_pb::CommitResponse_EntryResponse& entry_response =
|
| commit_response.entryresponse(entries_start_index_ + i);
|
|
|
| @@ -76,7 +74,6 @@ syncer::SyncerError NonBlockingTypeCommitContribution::ProcessCommitResponse(
|
| response_data.id = entry_response.id_string();
|
| response_data.client_tag_hash =
|
| entities_.Get(i).client_defined_unique_tag();
|
| - response_data.sequence_number = sequence_numbers_[i];
|
| response_data.response_version = entry_response.version();
|
| response_list.push_back(response_data);
|
| break;
|
| @@ -95,7 +92,7 @@ syncer::SyncerError NonBlockingTypeCommitContribution::ProcessCommitResponse(
|
|
|
| // Send whatever successful responses we did get back to our parent.
|
| // It's the schedulers job to handle the failures.
|
| - worker_->OnCommitResponse(response_list);
|
| + worker_->OnCommitResponse(&response_list);
|
|
|
| // Let the scheduler know about the failures.
|
| if (unknown_error) {
|
| @@ -118,7 +115,7 @@ void NonBlockingTypeCommitContribution::CleanUp() {
|
| }
|
|
|
| size_t NonBlockingTypeCommitContribution::GetNumEntries() const {
|
| - return sequence_numbers_.size();
|
| + return entities_.size();
|
| }
|
|
|
| } // namespace syncer_v2
|
|
|