| 239 | : AsyncOpKernel(context) {} |
| 240 | |
| 241 | void XRTExecuteOp::ComputeAsync(OpKernelContext* context, DoneCallback done) { |
| 242 | // Schedule onto the default queue, for unbounded concurrency. See b/73520706 |
| 243 | Env::Default()->SchedClosure([this, context, done]() { |
| 244 | OP_REQUIRES_OK_ASYNC(context, DoWork(context), done); |
| 245 | done(); |
| 246 | }); |
| 247 | } |
| 248 | |
| 249 | Status XRTExecuteOp::DoWork(OpKernelContext* context) { |
| 250 | VLOG(1) << "XRTExecuteOp::Compute"; |
nothing calls this directly
no test coverage detected