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

Method FindTask

src/nameserver/name_server_impl.cc:5049–5060  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

5047}
5048
5049std::shared_ptr<::fedb::api::TaskInfo> NameServerImpl::FindTask(uint64_t op_id, ::fedb::api::TaskType task_type) {
5050 auto iter = task_map_.find(op_id);
5051 if (iter == task_map_.end()) {
5052 return std::shared_ptr<::fedb::api::TaskInfo>();
5053 }
5054 for (auto& task : iter->second) {
5055 if (task->op_id() == op_id && task->task_type() == task_type) {
5056 return task;
5057 }
5058 }
5059 return std::shared_ptr<::fedb::api::TaskInfo>();
5060}
5061
5062std::shared_ptr<fedb::nameserver::ClusterInfo> NameServerImpl::GetHealthCluster(const std::string& alias) {
5063 auto iter = nsc_.find(alias);

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected