Method ExecuteAsync

tensorflow/core/distributed_runtime/graph_mgr.cc:427–449

}

void GraphMgr::ExecuteAsync(const string& handle, const int64 step_id,
                            WorkerSession* session, const ExecutorOpts& opts,
                            StepStatsCollector* collector,
                            MutableRunGraphResponseWrapper* response,
                            CancellationManager* cancellation_manager,
                            const NamedTensors& in,
                            std::map<std::string, bool>& is_send_dead,
                            StatusCallback done) {
  RemoteRendezvous *rendezvous = worker_env_->rendezvous_mgr->Find(step_id);
  Status s = rendezvous->Initialize(session);
  if (!s.ok()) {
    done(s);
    rendezvous->Unref();
    return;
  }

  ExecuteAsync(handle, step_id, rendezvous, session, opts, collector,
               response, cancellation_manager, in, is_send_dead,
               [rendezvous, done](const Status &s) {
        rendezvous->Unref();
        done(s);
      });
}

void GraphMgr::ExecuteAsync(const string& handle, const int64 step_id,
                            Rendezvous* rendezvous,