Method StarRunGraphHandler

tensorflow/contrib/star/star_worker_service.cc:83–93

}

void StarWorkerService::StarRunGraphHandler(StarServerTag* tag) {
  Schedule([this, tag]() {
    worker_->StarRunGraphAsync(&(tag->star_graph_request_),
                               &(tag->star_graph_response_),
                               [this, tag](const Status& s) {
      auto step_id = tag->star_graph_request_.step_id_;
      tag->ProcessDone(s);
      worker_->Cleanup(step_id);
    });
  });
}

void StarWorkerService::GetStatusHandler(StarServerTag* tag) {
  Schedule([this, tag]() {