test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-11-30 10:59:32 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

MS-343 implement ResourceMgr

Browse Source 
Former-commit-id: f0f04297bb219cfa20e4eba609ff390f84e3a4a3
This commit is contained in:
starlord 2019-08-13 15:28:27 +08:00
parent 549b18f871
commit 3e47b26d9f
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
cpp/src/scheduler/ResourceMgr.cpp
View File

@ -63,15 +63,19 @@ ResourceMgr::EventProcess() {
ResourceWPtr res(resources_[i]);
if (start_up_event_[i]) {
on_start_up_(res);
start_up_event_[i] = false;
}
if (finish_task_event_[i]) {
on_finish_task_(res);
finish_task_event_[i] = false;
}
if (copy_completed_event_[i]) {
on_copy_completed_(res);
copy_completed_event_[i] = false;
}
if (task_table_updated_event_[i]) {
on_task_table_updated_(res);
task_table_updated_event_[i] = false;
}
}
}
@ -100,6 +104,18 @@ ResourceMgr::Stop() {
}
}
std::string
ResourceMgr::Dump() {
std::string str = "ResourceMgr contains " + std::to_string(resources_.size()) + " resources.\n";
for (uint64_t i = 0; i < resources_.size(); ++i) {
str += "Resource No." + std::to_string(i) + ":\n";
str += resources_[i]->Dump();
}
return str;
}
}
}
}