test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-08 06:49:26 +08:00
Code Issues Actions 14 Packages Projects Releases Wiki Activity

fix clang format

Browse Source 
Former-commit-id: 375685f93f0b9f0c28b93e3fe717c544cd3f2fb6
This commit is contained in:
Yu Kun 2019-10-15 17:12:05 +08:00
parent 72ead4e35a
commit 102ec91fb4
2 changed files with 12 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/scheduler/action/PushTaskToNeighbour.cpp
View File

@ -209,9 +209,9 @@ Action::SpecifiedResourceLabelTaskScheduler(ResourceMgrWPtr res_mgr, ResourcePtr
} else {
auto next_res_name = task->path().Next();
auto next_res = res_mgr.lock()->GetResource(next_res_name);
// if (event->task_table_item_->Move()) {
// next_res->task_table().Put(task);
// }
// if (event->task_table_item_->Move()) {
// next_res->task_table().Put(task);
// }
event->task_table_item_->Move();
next_res->task_table().Put(task);
}

17
core/src/scheduler/resource/Resource.cpp
View File

@ -125,14 +125,15 @@ Resource::pick_task_execute() {
if (task_table_.Execute(index)) {
return task_table_.Get(index);
}
// if (task_table_[index]->task->label()->Type() == TaskLabelType::SPECIFIED_RESOURCE) {
// if (task_table_.Get(index)->task->path().Current() == task_table_.Get(index)->task->path().Last() &&
// task_table_.Get(index)->task->path().Last() == name()) {
// if (task_table_.Execute(index)) {
// return task_table_.Get(index);
// }
// }
// }
// if (task_table_[index]->task->label()->Type() == TaskLabelType::SPECIFIED_RESOURCE) {
// if (task_table_.Get(index)->task->path().Current() == task_table_.Get(index)->task->path().Last()
// &&
// task_table_.Get(index)->task->path().Last() == name()) {
// if (task_table_.Execute(index)) {
// return task_table_.Get(index);
// }
// }
// }
// else try next
}
return nullptr;