From b76564872bd531b479039b0f7a9bb6f7775df931 Mon Sep 17 00:00:00 2001 From: groot Date: Tue, 13 Aug 2019 15:28:27 +0800 Subject: [PATCH] MS-343 implement ResourceMgr Former-commit-id: dce8588474e29e3da9fa68189306cee58a570c2b --- cpp/src/scheduler/ResourceMgr.cpp | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/cpp/src/scheduler/ResourceMgr.cpp b/cpp/src/scheduler/ResourceMgr.cpp index faf422b8..d033bd92 100644 --- a/cpp/src/scheduler/ResourceMgr.cpp +++ b/cpp/src/scheduler/ResourceMgr.cpp @@ -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; +} + } } } -- GitLab