Loading cpp/src/scheduler/BuildMgr.cpp +2 −5 Original line number Diff line number Diff line Loading @@ -15,11 +15,8 @@ // specific language governing permissions and limitations // under the License. #include "BuildMgr.h" #include "scheduler/BuildMgr.h" namespace milvus { namespace scheduler { } // namespace scheduler namespace scheduler {} // namespace scheduler } // namespace milvus cpp/src/scheduler/TaskTable.cpp +2 −4 Original line number Diff line number Diff line Loading @@ -16,9 +16,9 @@ // under the License. #include "scheduler/TaskTable.h" #include "scheduler/SchedInst.h" #include "Utils.h" #include "event/TaskTableUpdatedEvent.h" #include "scheduler/SchedInst.h" #include "utils/Log.h" #include <ctime> Loading Loading @@ -167,13 +167,11 @@ TaskTable::PickToLoad(uint64_t limit) { } if (table_[j]->task->path().Current() == "cpu") { if (table_[j]->task->Type() == TaskType::BuildIndexTask && BuildMgrInst::GetInstance()->numoftasks() < 1) { if (table_[j]->task->Type() == TaskType::BuildIndexTask && BuildMgrInst::GetInstance()->numoftasks() < 1) { return std::vector<uint64_t>(); } } if (table_[j]->state == TaskTableItemState::LOADED) { ++count; if (count > 2) Loading Loading
cpp/src/scheduler/BuildMgr.cpp +2 −5 Original line number Diff line number Diff line Loading @@ -15,11 +15,8 @@ // specific language governing permissions and limitations // under the License. #include "BuildMgr.h" #include "scheduler/BuildMgr.h" namespace milvus { namespace scheduler { } // namespace scheduler namespace scheduler {} // namespace scheduler } // namespace milvus
cpp/src/scheduler/TaskTable.cpp +2 −4 Original line number Diff line number Diff line Loading @@ -16,9 +16,9 @@ // under the License. #include "scheduler/TaskTable.h" #include "scheduler/SchedInst.h" #include "Utils.h" #include "event/TaskTableUpdatedEvent.h" #include "scheduler/SchedInst.h" #include "utils/Log.h" #include <ctime> Loading Loading @@ -167,13 +167,11 @@ TaskTable::PickToLoad(uint64_t limit) { } if (table_[j]->task->path().Current() == "cpu") { if (table_[j]->task->Type() == TaskType::BuildIndexTask && BuildMgrInst::GetInstance()->numoftasks() < 1) { if (table_[j]->task->Type() == TaskType::BuildIndexTask && BuildMgrInst::GetInstance()->numoftasks() < 1) { return std::vector<uint64_t>(); } } if (table_[j]->state == TaskTableItemState::LOADED) { ++count; if (count > 2) Loading