| 741 | } |
| 742 | |
| 743 | void RunHandler::Impl::ScheduleIntraOpClosure(std::function<void()> fn) { |
| 744 | VLOG(3) << "Scheduling intra work for " << tws()->GetTracemeId(); |
| 745 | pool_impl_->run_handler_thread_pool()->AddWorkToQueue(tws(), false, |
| 746 | std::move(fn)); |
| 747 | } |
| 748 | |
| 749 | void RunHandler::Impl::Reset(int64 step_id) { |
| 750 | start_time_us_ = tensorflow::Env::Default()->NowMicros(); |
no test coverage detected