| 7258 | } |
| 7259 | |
| 7260 | std::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 | |
| 7274 | void NameServerImpl::CheckBinlogSyncProgress(const std::string& name, const std::string& db, uint32_t pid, |
| 7275 | const std::string& follower, uint64_t offset_delta, |
nothing calls this directly
no outgoing calls
no test coverage detected