Method Produce

tensorflow/core/kernels/hash_ops/tensible_variable_ops.cc:135–157

}

void TensorProducerImpl::Produce(const TensorGenerator::Consumer& consumer) {
  TensorProducerContext* ctx = new TensorProducerContext;
  ctx->frame.reset(new TensorProducerCallFrame);
  ctx->f_opts.reset(new FunctionLibraryRuntime::Options);
  ctx->step_container.reset(new ScopedStepContainer(
      ctx->f_opts->step_id, [this](const string& name) {
    lib_->device()->resource_manager()->Cleanup(name).IgnoreError();
  }));
  ctx->f_opts->step_container = ctx->step_container.get();
  ctx->f_opts->runner = &runner_;
  ctx->cancellation_manager.reset(new CancellationManager);
  ctx->f_opts->cancellation_manager = ctx->cancellation_manager.get();
  CancellationManager c_mgr;
  ctx->f_opts->cancellation_manager = &c_mgr;

  Ref();
  lib_->Run(*ctx->f_opts, f_handle_, ctx->frame.get(),
  [this, ctx, consumer] (const Status& st) {
    consumer(st, ctx->frame->GetRet());
    delete ctx;
    Unref();
  });
}

}  // namespace