Method ScanMetaTableAsync

src/sdk/table_impl.cc:1587–1623

}

void TableImpl::ScanMetaTableAsync(const std::string& key_start, const std::string& key_end,
                                   const std::string& expand_key_end, bool zk_access) {
  meta_mutex_.AssertHeld();
  CHECK(expand_key_end == "" || expand_key_end >= key_end);

  std::string meta_addr = cluster_->RootTableAddr(zk_access);
  if (meta_addr.empty() && !zk_access) {
    meta_addr = cluster_->RootTableAddr(true);
  }

  if (meta_addr.empty()) {
    VLOG(6) << "root is empty";

    ThreadPool::Task retry_task = std::bind(&TableImpl::ScanMetaTableAsyncInLock, this, key_start,
                                            key_end, expand_key_end, true);
    thread_pool_->DelayTask(FLAGS_tera_sdk_update_meta_internal, retry_task);
    return;
  }

  VLOG(6) << "root: " << meta_addr;
  tabletnode::TabletNodeClient tabletnode_client_async(thread_pool_, meta_addr);
  ScanTabletRequest* request = new ScanTabletRequest;
  ScanTabletResponse* response = new ScanTabletResponse;
  request->set_sequence_id(last_sequence_id_++);
  request->set_table_name(FLAGS_tera_master_meta_table_name);
  MetaTableScanRange(name_, key_start, expand_key_end, request->mutable_start(),
                     request->mutable_end());
  request->set_buffer_limit(FLAGS_tera_sdk_update_meta_buffer_limit);
  request->set_round_down(true);

  access_builder_->BuildInternalGroupRequest(request);

  std::function<void(ScanTabletRequest*, ScanTabletResponse*, bool, int)> done = std::bind(
      &TableImpl::ScanMetaTableCallBackWrapper, std::weak_ptr<TableImpl>(shared_from_this()),
      key_start, key_end, expand_key_end, get_micros(), _1, _2, _3, _4);
  tabletnode_client_async.ScanTablet(request, response, done);
}

void TableImpl::ScanMetaTableCallBackWrapper(std::weak_ptr<TableImpl> weak_ptr_table,
                                             std::string key_start, std::string key_end,