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

Method FindMultiTask

src/tablet/tablet_impl.cc:4029–4043  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

4027}
4028
4029std::shared_ptr<::fedb::api::TaskInfo> TabletImpl::FindMultiTask(
4030 const ::fedb::api::TaskInfo& task_info) {
4031 auto iter = task_map_.find(task_info.op_id());
4032 if (iter == task_map_.end()) {
4033 return std::shared_ptr<::fedb::api::TaskInfo>();
4034 }
4035 for (auto& task : iter->second) {
4036 if (task->op_id() == task_info.op_id() &&
4037 task->task_type() == task_info.task_type() &&
4038 task->task_id() == task_info.task_id()) {
4039 return task;
4040 }
4041 }
4042 return std::shared_ptr<::fedb::api::TaskInfo>();
4043}
4044
4045void TabletImpl::GcTable(uint32_t tid, uint32_t pid, bool execute_once) {
4046 std::shared_ptr<Table> table = GetTable(tid, pid);

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected