Lines Matching refs:cmd
33 static void uring_cmd_set_ring_ent(struct io_uring_cmd *cmd, in uring_cmd_set_ring_ent() argument
37 io_uring_cmd_to_pdu(cmd, struct fuse_uring_pdu); in uring_cmd_set_ring_ent()
42 static struct fuse_ring_ent *uring_cmd_to_ring_ent(struct io_uring_cmd *cmd) in uring_cmd_to_ring_ent() argument
45 io_uring_cmd_to_pdu(cmd, struct fuse_uring_pdu); in uring_cmd_to_ring_ent()
329 struct io_uring_cmd *cmd; in fuse_uring_entry_teardown() local
334 cmd = ent->cmd; in fuse_uring_entry_teardown()
335 ent->cmd = NULL; in fuse_uring_entry_teardown()
353 if (cmd) in fuse_uring_entry_teardown()
354 io_uring_cmd_done(cmd, -ENOTCONN, 0, IO_URING_F_UNLOCKED); in fuse_uring_entry_teardown()
498 static void fuse_uring_cancel(struct io_uring_cmd *cmd, in fuse_uring_cancel() argument
501 struct fuse_ring_ent *ent = uring_cmd_to_ring_ent(cmd); in fuse_uring_cancel()
515 ent->cmd = NULL; in fuse_uring_cancel()
521 io_uring_cmd_done(cmd, -ENOTCONN, 0, issue_flags); in fuse_uring_cancel()
525 static void fuse_uring_prepare_cancel(struct io_uring_cmd *cmd, int issue_flags, in fuse_uring_prepare_cancel() argument
528 uring_cmd_set_ring_ent(cmd, ring_ent); in fuse_uring_prepare_cancel()
529 io_uring_cmd_mark_cancelable(cmd, issue_flags); in fuse_uring_prepare_cancel()
723 struct io_uring_cmd *cmd; in fuse_uring_send_next_to_ring() local
730 cmd = ent->cmd; in fuse_uring_send_next_to_ring()
731 ent->cmd = NULL; in fuse_uring_send_next_to_ring()
736 io_uring_cmd_done(cmd, 0, 0, issue_flags); in fuse_uring_send_next_to_ring()
746 WARN_ON_ONCE(!ent->cmd); in fuse_uring_ent_avail()
874 static int fuse_uring_commit_fetch(struct io_uring_cmd *cmd, int issue_flags, in fuse_uring_commit_fetch() argument
877 const struct fuse_uring_cmd_req *cmd_req = io_uring_sqe_cmd(cmd->sqe); in fuse_uring_commit_fetch()
931 ent->cmd = cmd; in fuse_uring_commit_fetch()
935 fuse_uring_prepare_cancel(cmd, issue_flags, ent); in fuse_uring_commit_fetch()
977 struct io_uring_cmd *cmd, in fuse_uring_do_register() argument
985 fuse_uring_prepare_cancel(cmd, issue_flags, ent); in fuse_uring_do_register()
988 ent->cmd = cmd; in fuse_uring_do_register()
1030 fuse_uring_create_ring_ent(struct io_uring_cmd *cmd, in fuse_uring_create_ring_ent() argument
1039 err = fuse_uring_get_iovec_from_sqe(cmd->sqe, iov); in fuse_uring_create_ring_ent()
1078 static int fuse_uring_register(struct io_uring_cmd *cmd, in fuse_uring_register() argument
1081 const struct fuse_uring_cmd_req *cmd_req = io_uring_sqe_cmd(cmd->sqe); in fuse_uring_register()
1112 ent = fuse_uring_create_ring_ent(cmd, queue); in fuse_uring_register()
1116 fuse_uring_do_register(ent, cmd, issue_flags); in fuse_uring_register()
1125 int fuse_uring_cmd(struct io_uring_cmd *cmd, unsigned int issue_flags) in fuse_uring_cmd() argument
1129 u32 cmd_op = cmd->cmd_op; in fuse_uring_cmd()
1133 fuse_uring_cancel(cmd, issue_flags); in fuse_uring_cmd()
1141 fud = fuse_get_dev(cmd->file); in fuse_uring_cmd()
1168 err = fuse_uring_register(cmd, issue_flags, fc); in fuse_uring_cmd()
1178 err = fuse_uring_commit_fetch(cmd, issue_flags, fc); in fuse_uring_cmd()
1192 static void fuse_uring_send(struct fuse_ring_ent *ent, struct io_uring_cmd *cmd, in fuse_uring_send() argument
1200 ent->cmd = NULL; in fuse_uring_send()
1203 io_uring_cmd_done(cmd, ret, 0, issue_flags); in fuse_uring_send()
1211 static void fuse_uring_send_in_task(struct io_uring_cmd *cmd, in fuse_uring_send_in_task() argument
1214 struct fuse_ring_ent *ent = uring_cmd_to_ring_ent(cmd); in fuse_uring_send_in_task()
1228 fuse_uring_send(ent, cmd, err, issue_flags); in fuse_uring_send_in_task()
1251 struct io_uring_cmd *cmd = ent->cmd; in fuse_uring_dispatch_ent() local
1253 uring_cmd_set_ring_ent(cmd, ent); in fuse_uring_dispatch_ent()
1254 io_uring_cmd_complete_in_task(cmd, fuse_uring_send_in_task); in fuse_uring_dispatch_ent()