| 453 | } |
| 454 | |
| 455 | void GraphTask::ReclaimSubgraphTask(void) |
| 456 | { |
| 457 | DevScheduler* scheduler = dev_engine_->GetScheduler(); |
| 458 | |
| 459 | for(SubgraphTask* sub : sub_task_list_) |
| 460 | { |
| 461 | if(sub->GetStatus() == EXEC_STATUS_RUN) |
| 462 | { |
| 463 | XLOG_ERROR() << "cannot reclaim subgraph while it is running\n"; |
| 464 | return; |
| 465 | } |
| 466 | |
| 467 | if(sub->attached) |
| 468 | { |
| 469 | scheduler->PostrunTask(dev_engine_, sub->dev_executor, sub); |
| 470 | } |
| 471 | |
| 472 | sub->Release(); |
| 473 | |
| 474 | delete sub; |
| 475 | } |
| 476 | |
| 477 | sub_task_list_.clear(); |
| 478 | } |
| 479 | |
| 480 | GraphTask::~GraphTask(void) |
| 481 | { |
no test coverage detected