From 3e47b26d9f20a73970096ca1ffe413fd47c5a3b9 Mon Sep 17 00:00:00 2001 From: starlord Date: Tue, 13 Aug 2019 15:28:27 +0800 Subject: [PATCH] MS-343 implement ResourceMgr Former-commit-id: f0f04297bb219cfa20e4eba609ff390f84e3a4a3 --- 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 faf422b849..d033bd9298 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; +} + } } }