Method Create

tensorflow/core/common_runtime/executor_test.cc:60–84

Resets executor_ with a new executor based on a graph 'gdef'.

  // Resets executor_ with a new executor based on a graph 'gdef'.
  void Create(std::unique_ptr<const Graph> graph) {
    const int version = graph->versions().producer();
    LocalExecutorParams params;
    params.device = device_.get();
    params.create_kernel = [this, version](const NodeDef& ndef,
                                           OpKernel** kernel) {
      return CreateNonCachedKernel(device_.get(), nullptr, ndef, version,
                                   kernel);
    };
    params.delete_kernel = [](OpKernel* kernel) {
      DeleteNonCachedKernel(kernel);
    };
    rendez_ = NewLocalRendezvous();
    params.rendezvous_factory = [this](const int64, const DeviceMgr*,
                                       Rendezvous** r) {
      *r = rendez_;
      rendez_->Ref();
      return Status::OK();
    };
    delete exec_;
    TF_CHECK_OK(NewLocalExecutor(params, std::move(graph), &exec_));
    runner_ = [this](std::function<void()> fn) { thread_pool_->Schedule(fn); };
    cost_runner_ = [this](std::function<void()> fn, int64 cost)
        { thread_pool_->CostSchedule(fn, cost); };
  }

  Status Run(Rendezvous* rendez) {
    Executor::Args args;