Lines Matching refs:target_ctx

69 static inline bool io_msg_need_remote(struct io_ring_ctx *target_ctx)  in io_msg_need_remote()  argument
71 return target_ctx->task_complete; in io_msg_need_remote()
120 static int io_msg_data_remote(struct io_ring_ctx *target_ctx, in io_msg_data_remote() argument
126 target = io_msg_get_kiocb(target_ctx); in io_msg_data_remote()
133 return io_msg_remote_post(target_ctx, target, msg->len, flags, in io_msg_data_remote()
137 static int __io_msg_ring_data(struct io_ring_ctx *target_ctx, in __io_msg_ring_data() argument
147 if (target_ctx->flags & IORING_SETUP_R_DISABLED) in __io_msg_ring_data()
150 if (io_msg_need_remote(target_ctx)) in __io_msg_ring_data()
151 return io_msg_data_remote(target_ctx, msg); in __io_msg_ring_data()
157 if (target_ctx->flags & IORING_SETUP_IOPOLL) { in __io_msg_ring_data()
158 if (unlikely(io_lock_external_ctx(target_ctx, issue_flags))) in __io_msg_ring_data()
161 if (io_post_aux_cqe(target_ctx, msg->user_data, msg->len, flags)) in __io_msg_ring_data()
163 if (target_ctx->flags & IORING_SETUP_IOPOLL) in __io_msg_ring_data()
164 io_double_unlock_ctx(target_ctx); in __io_msg_ring_data()
170 struct io_ring_ctx *target_ctx = req->file->private_data; in io_msg_ring_data() local
173 return __io_msg_ring_data(target_ctx, msg, issue_flags); in io_msg_ring_data()
198 struct io_ring_ctx *target_ctx = req->file->private_data; in io_msg_install_complete() local
203 if (unlikely(io_lock_external_ctx(target_ctx, issue_flags))) in io_msg_install_complete()
206 ret = __io_fixed_fd_install(target_ctx, src_file, msg->dst_fd); in io_msg_install_complete()
221 if (!io_post_aux_cqe(target_ctx, msg->user_data, ret, 0)) in io_msg_install_complete()
224 io_double_unlock_ctx(target_ctx); in io_msg_install_complete()
259 struct io_ring_ctx *target_ctx = req->file->private_data; in io_msg_send_fd() local
265 if (target_ctx == ctx) in io_msg_send_fd()
267 if (target_ctx->flags & IORING_SETUP_R_DISABLED) in io_msg_send_fd()
275 if (io_msg_need_remote(target_ctx)) in io_msg_send_fd()