Lines Matching refs:target_ctx

68 static inline bool io_msg_need_remote(struct io_ring_ctx *target_ctx)  in io_msg_need_remote()  argument
70 return target_ctx->task_complete; in io_msg_need_remote()
96 static int io_msg_data_remote(struct io_ring_ctx *target_ctx, in io_msg_data_remote() argument
109 io_msg_remote_post(target_ctx, target, msg->len, flags, msg->user_data); in io_msg_data_remote()
113 static int __io_msg_ring_data(struct io_ring_ctx *target_ctx, in __io_msg_ring_data() argument
127 if (smp_load_acquire(&target_ctx->flags) & IORING_SETUP_R_DISABLED) in __io_msg_ring_data()
130 if (io_msg_need_remote(target_ctx)) in __io_msg_ring_data()
131 return io_msg_data_remote(target_ctx, msg); in __io_msg_ring_data()
137 if (target_ctx->flags & IORING_SETUP_IOPOLL) { in __io_msg_ring_data()
138 if (unlikely(io_lock_external_ctx(target_ctx, issue_flags))) in __io_msg_ring_data()
141 if (io_post_aux_cqe(target_ctx, msg->user_data, msg->len, flags)) in __io_msg_ring_data()
143 if (target_ctx->flags & IORING_SETUP_IOPOLL) in __io_msg_ring_data()
144 io_double_unlock_ctx(target_ctx); in __io_msg_ring_data()
150 struct io_ring_ctx *target_ctx = req->file->private_data; in io_msg_ring_data() local
153 return __io_msg_ring_data(target_ctx, msg, issue_flags); in io_msg_ring_data()
178 struct io_ring_ctx *target_ctx = req->file->private_data; in io_msg_install_complete() local
183 if (unlikely(io_lock_external_ctx(target_ctx, issue_flags))) in io_msg_install_complete()
186 ret = __io_fixed_fd_install(target_ctx, src_file, msg->dst_fd); in io_msg_install_complete()
201 if (!io_post_aux_cqe(target_ctx, msg->user_data, ret, 0)) in io_msg_install_complete()
204 io_double_unlock_ctx(target_ctx); in io_msg_install_complete()
236 struct io_ring_ctx *target_ctx = req->file->private_data; in io_msg_send_fd() local
242 if (target_ctx == ctx) in io_msg_send_fd()
248 if (smp_load_acquire(&target_ctx->flags) & IORING_SETUP_R_DISABLED) in io_msg_send_fd()
256 if (io_msg_need_remote(target_ctx)) in io_msg_send_fd()