| 2409 | : RunState({}, {}, step_id, devices) {} |
| 2410 | |
| 2411 | DirectSession::RunState::~RunState() { |
| 2412 | if (rendez != nullptr) { |
| 2413 | if (!executors_done.HasBeenNotified()) { |
| 2414 | rendez->StartAbort(errors::Cancelled("PRun cancellation")); |
| 2415 | executors_done.WaitForNotification(); |
| 2416 | } |
| 2417 | rendez->Unref(); |
| 2418 | } |
| 2419 | } |
| 2420 | |
| 2421 | bool DirectSession::RunState::PendingDone() const { |
| 2422 | for (const auto& it : pending_inputs) { |
nothing calls this directly
no test coverage detected