Method ReadTableMetaAsync

src/sdk/table_impl.cc:1940–1978

}

void TableImpl::ReadTableMetaAsync(ErrorCode* ret_err, int32_t retry_times, bool zk_access) {
  std::string meta_server = cluster_->RootTableAddr(zk_access);
  if (meta_server.empty() && !zk_access) {
    meta_server = cluster_->RootTableAddr(true);
  }
  if (meta_server.empty()) {
    VLOG(10) << "root is empty";

    MutexLock lock(&table_meta_mutex_);
    CHECK(table_meta_updating_);
    if (retry_times >= FLAGS_tera_sdk_meta_read_retry_times) {
      ret_err->SetFailed(ErrorCode::kSystem);
      table_meta_updating_ = false;
      table_meta_cond_.Signal();
    } else {
      int64_t retry_interval =
          static_cast<int64_t>(pow(FLAGS_tera_sdk_delay_send_internal, retry_times) * 1000);
      ThreadPool::Task retry_task =
          std::bind(&TableImpl::ReadTableMetaAsync, this, ret_err, retry_times + 1, true);
      thread_pool_->DelayTask(retry_interval, retry_task);
    }
    return;
  }

  tabletnode::TabletNodeClient tabletnode_client_async(thread_pool_, meta_server);
  ReadTabletRequest* request = new ReadTabletRequest;
  ReadTabletResponse* response = new ReadTabletResponse;
  request->set_sequence_id(last_sequence_id_++);
  request->set_tablet_name(FLAGS_tera_master_meta_table_name);
  RowReaderInfo* row_info = request->add_row_info_list();
  MakeMetaTableKey(name_, row_info->mutable_key());

  access_builder_->BuildInternalGroupRequest(request);

  std::function<void(ReadTabletRequest*, ReadTabletResponse*, bool, int)> done =
      std::bind(&TableImpl::ReadTableMetaCallBackWrapper,
                std::weak_ptr<TableImpl>(shared_from_this()), ret_err, retry_times, _1, _2, _3, _4);
  tabletnode_client_async.ReadTablet(request, response, done);
}

void TableImpl::ReadTableMetaCallBackWrapper(std::weak_ptr<TableImpl> weak_ptr_table,
                                             ErrorCode* ret_err, int32_t retry_times,