Searched refs:coordinator_ (Results 1 – 2 of 2) sorted by relevance
175 coordinator_.get(), &queue_runner)); in Run()179 TF_RETURN_IF_ERROR(coordinator_->RegisterRunner(std::move(queue_runner))); in Run()180 TF_RETURN_IF_ERROR(coordinator_->GetStatus()); in Run()193 TF_RETURN_IF_ERROR(coordinator_->ExportCostGraph(&queue_costs)); in Run()288 if (this->coordinator_) { in CloseSession()289 this->coordinator_->RequestStop().IgnoreError(); in CloseSession()291 while (!this->coordinator_->AllRunnersStopped()) { in CloseSession()298 this->coordinator_.reset(); in CloseSession()366 coordinator_.reset(new Coordinator()); in ResetSession()
76 std::unique_ptr<Coordinator> coordinator_; variable