Method CommitReaders

src/sdk/table_impl.cc:1123–1156

}

void TableImpl::CommitReaders(const std::string& server_addr,
                              std::vector<RowReaderImpl*>& reader_list) {
  std::vector<int64_t>* reader_id_list = new std::vector<int64_t>;
  tabletnode::TabletNodeClient tabletnode_client_async(thread_pool_, server_addr);
  ReadTabletRequest* request = new ReadTabletRequest;
  ReadTabletResponse* response = new ReadTabletResponse;
  request->set_sequence_id(last_sequence_id_++);
  request->set_tablet_name(name_);

  access_builder_->BuildRequest(request);

  for (uint32_t i = 0; i < reader_list.size(); ++i) {
    RowReaderImpl* row_reader = reader_list[i];
    RowReaderInfo* row_reader_info = request->add_row_info_list();
    if (!request->has_client_timeout_ms() ||
        (request->has_client_timeout_ms() &&
         request->client_timeout_ms() > row_reader->TimeOut())) {
      request->set_client_timeout_ms(row_reader->TimeOut());
    }
    request->set_snapshot_id(row_reader->GetSnapshot());
    row_reader->ToProtoBuf(row_reader_info);
    // row_reader_info->CopyFrom(row_reader->GetRowReaderInfo());
    reader_id_list->push_back(row_reader->GetId());
    row_reader->AddCommitTimes();
    row_reader->DecRef();
  }
  VLOG(20) << "commit " << reader_list.size() << " reads to " << server_addr
           << "timeout:" << request->client_timeout_ms();
  request->set_timestamp(get_micros());
  std::function<void(ReadTabletRequest*, ReadTabletResponse*, bool, int)> done =
      std::bind(&TableImpl::ReaderCallBackWrapper, std::weak_ptr<TableImpl>(shared_from_this()),
                reader_id_list, _1, _2, _3, _4);
  tabletnode_client_async.ReadTablet(request, response, done);
}
void TableImpl::ReaderCallBackWrapper(std::weak_ptr<TableImpl> weak_ptr_table,
                                      std::vector<int64_t>* reader_id_list,
                                      ReadTabletRequest* request, ReadTabletResponse* response,