Method CommitSyncWrite

src/benchmark/mark.cc:112–124

}

void Adapter::CommitSyncWrite() {
  if (sync_mutations_.size() == 0) {
    return;
  }
  CHECK_EQ(sync_mutations_.size(), sync_req_sizes_.size());
  int64_t req_time = Now();
  table_->ApplyMutation(sync_mutations_);
  for (size_t i = 0; i < sync_mutations_.size(); i++) {
    WriteCallback(sync_mutations_[i], sync_req_sizes_[i], req_time);
  }
  sync_mutations_.clear();
  sync_req_sizes_.clear();
}

void Adapter::WriteCallback(tera::RowMutation* row_mu, size_t req_size, int64_t req_time) {
  uint32_t latency = (Now() - req_time) / 1000;