MCPcopy Create free account
hub / github.com/4paradigm/OpenMLDB / CreateUpdateTableInfoTask

Method CreateUpdateTableInfoTask

src/nameserver/name_server_impl.cc:7260–7272  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

7258}
7259
7260std::shared_ptr<Task> NameServerImpl::CreateUpdateTableInfoTask(const std::string& src_endpoint,
7261 const std::string& name, const std::string& db,
7262 uint32_t pid, const std::string& des_endpoint,
7263 uint64_t op_index, ::fedb::api::OPType op_type) {
7264 std::shared_ptr<Task> task = std::make_shared<Task>("", std::make_shared<::fedb::api::TaskInfo>());
7265 task->task_info_->set_op_id(op_index);
7266 task->task_info_->set_op_type(op_type);
7267 task->task_info_->set_task_type(::fedb::api::TaskType::kUpdateTableInfo);
7268 task->task_info_->set_status(::fedb::api::TaskStatus::kInited);
7269 task->fun_ = boost::bind(&NameServerImpl::UpdateTableInfo, this, src_endpoint, name, db, pid, des_endpoint,
7270 task->task_info_);
7271 return task;
7272}
7273
7274void NameServerImpl::CheckBinlogSyncProgress(const std::string& name, const std::string& db, uint32_t pid,
7275 const std::string& follower, uint64_t offset_delta,

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected