| 238 | } |
| 239 | |
| 240 | void MapDefunOp::SetRunOptions(OpKernelContext* ctx, |
| 241 | FunctionLibraryRuntime::Options* opts, |
| 242 | ComputeOptions* compute_opts, |
| 243 | bool always_collect_stats) { |
| 244 | opts->rendezvous = ctx->rendezvous(); |
| 245 | if (always_collect_stats) { |
| 246 | opts->stats_collector = ctx->stats_collector(); |
| 247 | } |
| 248 | if (max_intra_op_parallelism_ >= 1) { |
| 249 | opts->runner = &compute_opts->runner; |
| 250 | } else { |
| 251 | opts->runner = ctx->runner(); |
| 252 | } |
| 253 | } |
| 254 | |
| 255 | Status MapDefunOp::SetupArgs(OpKernelContext* ctx, |
| 256 | ComputeOptions** compute_opts) { |
nothing calls this directly
no test coverage detected