Loading cpp/src/scheduler/JobMgr.cpp +4 −6 Original line number Diff line number Diff line Loading @@ -66,16 +66,14 @@ JobMgr::worker_function() { } auto tasks = build_task(job); auto disk_list = res_mgr_->GetDiskResources(); if (!disk_list.empty()) { if (auto disk = disk_list[0].lock()) { // disk resources NEVER be empty. if (auto disk = res_mgr_->GetDiskResources()[0].lock()) { for (auto& task : tasks) { disk->task_table().Put(task); } } } } } std::vector<TaskPtr> JobMgr::build_task(const JobPtr& job) { Loading Loading
cpp/src/scheduler/JobMgr.cpp +4 −6 Original line number Diff line number Diff line Loading @@ -66,16 +66,14 @@ JobMgr::worker_function() { } auto tasks = build_task(job); auto disk_list = res_mgr_->GetDiskResources(); if (!disk_list.empty()) { if (auto disk = disk_list[0].lock()) { // disk resources NEVER be empty. if (auto disk = res_mgr_->GetDiskResources()[0].lock()) { for (auto& task : tasks) { disk->task_table().Put(task); } } } } } std::vector<TaskPtr> JobMgr::build_task(const JobPtr& job) { Loading