| 114 | } |
| 115 | |
| 116 | void SetRunOptions(OpKernelContext* ctx, FunctionLibraryRuntime::Options* opts, |
| 117 | bool always_collect_stats) { |
| 118 | opts->rendezvous = ctx->rendezvous(); |
| 119 | opts->cancellation_manager = ctx->cancellation_manager(); |
| 120 | if (always_collect_stats) { |
| 121 | opts->stats_collector = ctx->stats_collector(); |
| 122 | } |
| 123 | opts->runner = ctx->runner(); |
| 124 | opts->step_container = ctx->step_container(); |
| 125 | } |
| 126 | |
| 127 | class IfOp : public AsyncOpKernel { |
| 128 | public: |
no test coverage detected