| 2419 | } |
| 2420 | |
| 2421 | bool DirectSession::RunState::PendingDone() const { |
| 2422 | for (const auto& it : pending_inputs) { |
| 2423 | if (!it.second) return false; |
| 2424 | } |
| 2425 | for (const auto& it : pending_outputs) { |
| 2426 | if (!it.second) return false; |
| 2427 | } |
| 2428 | return true; |
| 2429 | } |
| 2430 | |
| 2431 | void DirectSession::WaitForNotification(RunState* run_state, |
| 2432 | CancellationManager* cm, |