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 if (!target_ctx->task_complete) in io_msg_need_remote()
73 return current != target_ctx->submitter_task; in io_msg_need_remote()
96 struct io_ring_ctx *target_ctx = req->file->private_data; in io_msg_tw_complete() local
113 if (target_ctx->flags & IORING_SETUP_IOPOLL) in io_msg_tw_complete()
114 mutex_lock(&target_ctx->uring_lock); in io_msg_tw_complete()
115 if (!io_post_aux_cqe(target_ctx, msg->user_data, msg->len, flags)) in io_msg_tw_complete()
117 if (target_ctx->flags & IORING_SETUP_IOPOLL) in io_msg_tw_complete()
118 mutex_unlock(&target_ctx->uring_lock); in io_msg_tw_complete()
128 struct io_ring_ctx *target_ctx = req->file->private_data; in io_msg_ring_data() local
137 if (target_ctx->flags & IORING_SETUP_R_DISABLED) in io_msg_ring_data()
140 if (io_msg_need_remote(target_ctx)) in io_msg_ring_data()
147 if (target_ctx->flags & IORING_SETUP_IOPOLL) { in io_msg_ring_data()
148 if (unlikely(io_double_lock_ctx(target_ctx, issue_flags))) in io_msg_ring_data()
150 if (io_post_aux_cqe(target_ctx, msg->user_data, msg->len, flags)) in io_msg_ring_data()
152 io_double_unlock_ctx(target_ctx); in io_msg_ring_data()
154 if (io_post_aux_cqe(target_ctx, msg->user_data, msg->len, flags)) in io_msg_ring_data()
180 struct io_ring_ctx *target_ctx = req->file->private_data; in io_msg_install_complete() local
185 if (unlikely(io_double_lock_ctx(target_ctx, issue_flags))) in io_msg_install_complete()
188 ret = __io_fixed_fd_install(target_ctx, src_file, msg->dst_fd); in io_msg_install_complete()
203 if (!io_post_aux_cqe(target_ctx, msg->user_data, ret, 0)) in io_msg_install_complete()
206 io_double_unlock_ctx(target_ctx); in io_msg_install_complete()
225 struct io_ring_ctx *target_ctx = req->file->private_data; in io_msg_send_fd() local
232 if (target_ctx == ctx) in io_msg_send_fd()
234 if (target_ctx->flags & IORING_SETUP_R_DISABLED) in io_msg_send_fd()
244 if (io_msg_need_remote(target_ctx)) in io_msg_send_fd()