Lines Matching refs:sqe
514 char* sqe; in uv__iou_init() local
519 sqe = MAP_FAILED; in uv__iou_init()
569 sqe = mmap(0, in uv__iou_init()
576 if (sq == MAP_FAILED || sqe == MAP_FAILED) in uv__iou_init()
600 iou->sqe = sqe; in uv__iou_init()
621 if (sqe != MAP_FAILED) in uv__iou_init()
622 munmap(sqe, sqelen); in uv__iou_init()
631 munmap(iou->sqe, iou->sqelen); in uv__iou_delete()
758 struct uv__io_uring_sqe* sqe; in uv__iou_get_sqe() local
793 sqe = iou->sqe; in uv__iou_get_sqe()
794 sqe = &sqe[slot]; in uv__iou_get_sqe()
795 memset(sqe, 0, sizeof(*sqe)); in uv__iou_get_sqe()
796 sqe->user_data = (uintptr_t) req; in uv__iou_get_sqe()
807 return sqe; in uv__iou_get_sqe()
829 struct uv__io_uring_sqe* sqe; in uv__iou_fs_close() local
854 sqe = uv__iou_get_sqe(iou, loop, req); in uv__iou_fs_close()
855 if (sqe == NULL) in uv__iou_fs_close()
858 sqe->fd = req->file; in uv__iou_fs_close()
859 sqe->opcode = UV__IORING_OP_CLOSE; in uv__iou_fs_close()
868 struct uv__io_uring_sqe* sqe; in uv__iou_fs_ftruncate() local
875 sqe = uv__iou_get_sqe(iou, loop, req); in uv__iou_fs_ftruncate()
876 if (sqe == NULL) in uv__iou_fs_ftruncate()
879 sqe->fd = req->file; in uv__iou_fs_ftruncate()
880 sqe->len = req->off; in uv__iou_fs_ftruncate()
881 sqe->opcode = UV__IORING_OP_FTRUNCATE; in uv__iou_fs_ftruncate()
890 struct uv__io_uring_sqe* sqe; in uv__iou_fs_fsync_or_fdatasync() local
895 sqe = uv__iou_get_sqe(iou, loop, req); in uv__iou_fs_fsync_or_fdatasync()
896 if (sqe == NULL) in uv__iou_fs_fsync_or_fdatasync()
902 sqe->fd = req->file; in uv__iou_fs_fsync_or_fdatasync()
903 sqe->fsync_flags = fsync_flags; in uv__iou_fs_fsync_or_fdatasync()
904 sqe->opcode = UV__IORING_OP_FSYNC; in uv__iou_fs_fsync_or_fdatasync()
913 struct uv__io_uring_sqe* sqe; in uv__iou_fs_link() local
920 sqe = uv__iou_get_sqe(iou, loop, req); in uv__iou_fs_link()
921 if (sqe == NULL) in uv__iou_fs_link()
924 sqe->addr = (uintptr_t) req->path; in uv__iou_fs_link()
925 sqe->fd = AT_FDCWD; in uv__iou_fs_link()
926 sqe->addr2 = (uintptr_t) req->new_path; in uv__iou_fs_link()
927 sqe->len = AT_FDCWD; in uv__iou_fs_link()
928 sqe->opcode = UV__IORING_OP_LINKAT; in uv__iou_fs_link()
937 struct uv__io_uring_sqe* sqe; in uv__iou_fs_mkdir() local
944 sqe = uv__iou_get_sqe(iou, loop, req); in uv__iou_fs_mkdir()
945 if (sqe == NULL) in uv__iou_fs_mkdir()
948 sqe->addr = (uintptr_t) req->path; in uv__iou_fs_mkdir()
949 sqe->fd = AT_FDCWD; in uv__iou_fs_mkdir()
950 sqe->len = req->mode; in uv__iou_fs_mkdir()
951 sqe->opcode = UV__IORING_OP_MKDIRAT; in uv__iou_fs_mkdir()
960 struct uv__io_uring_sqe* sqe; in uv__iou_fs_open() local
965 sqe = uv__iou_get_sqe(iou, loop, req); in uv__iou_fs_open()
966 if (sqe == NULL) in uv__iou_fs_open()
969 sqe->addr = (uintptr_t) req->path; in uv__iou_fs_open()
970 sqe->fd = AT_FDCWD; in uv__iou_fs_open()
971 sqe->len = req->mode; in uv__iou_fs_open()
972 sqe->opcode = UV__IORING_OP_OPENAT; in uv__iou_fs_open()
973 sqe->open_flags = req->flags | O_CLOEXEC; in uv__iou_fs_open()
982 struct uv__io_uring_sqe* sqe; in uv__iou_fs_rename() local
987 sqe = uv__iou_get_sqe(iou, loop, req); in uv__iou_fs_rename()
988 if (sqe == NULL) in uv__iou_fs_rename()
991 sqe->addr = (uintptr_t) req->path; in uv__iou_fs_rename()
992 sqe->fd = AT_FDCWD; in uv__iou_fs_rename()
993 sqe->addr2 = (uintptr_t) req->new_path; in uv__iou_fs_rename()
994 sqe->len = AT_FDCWD; in uv__iou_fs_rename()
995 sqe->opcode = UV__IORING_OP_RENAMEAT; in uv__iou_fs_rename()
1004 struct uv__io_uring_sqe* sqe; in uv__iou_fs_symlink() local
1011 sqe = uv__iou_get_sqe(iou, loop, req); in uv__iou_fs_symlink()
1012 if (sqe == NULL) in uv__iou_fs_symlink()
1015 sqe->addr = (uintptr_t) req->path; in uv__iou_fs_symlink()
1016 sqe->fd = AT_FDCWD; in uv__iou_fs_symlink()
1017 sqe->addr2 = (uintptr_t) req->new_path; in uv__iou_fs_symlink()
1018 sqe->opcode = UV__IORING_OP_SYMLINKAT; in uv__iou_fs_symlink()
1027 struct uv__io_uring_sqe* sqe; in uv__iou_fs_unlink() local
1032 sqe = uv__iou_get_sqe(iou, loop, req); in uv__iou_fs_unlink()
1033 if (sqe == NULL) in uv__iou_fs_unlink()
1036 sqe->addr = (uintptr_t) req->path; in uv__iou_fs_unlink()
1037 sqe->fd = AT_FDCWD; in uv__iou_fs_unlink()
1038 sqe->opcode = UV__IORING_OP_UNLINKAT; in uv__iou_fs_unlink()
1049 struct uv__io_uring_sqe* sqe; in uv__iou_fs_read_or_write() local
1063 sqe = uv__iou_get_sqe(iou, loop, req); in uv__iou_fs_read_or_write()
1064 if (sqe == NULL) in uv__iou_fs_read_or_write()
1067 sqe->addr = (uintptr_t) req->bufs; in uv__iou_fs_read_or_write()
1068 sqe->fd = req->file; in uv__iou_fs_read_or_write()
1069 sqe->len = req->nbufs; in uv__iou_fs_read_or_write()
1070 sqe->off = req->off < 0 ? -1 : req->off; in uv__iou_fs_read_or_write()
1071 sqe->opcode = is_read ? UV__IORING_OP_READV : UV__IORING_OP_WRITEV; in uv__iou_fs_read_or_write()
1083 struct uv__io_uring_sqe* sqe; in uv__iou_fs_statx() local
1093 sqe = uv__iou_get_sqe(iou, loop, req); in uv__iou_fs_statx()
1094 if (sqe == NULL) { in uv__iou_fs_statx()
1101 sqe->addr = (uintptr_t) req->path; in uv__iou_fs_statx()
1102 sqe->addr2 = (uintptr_t) statxbuf; in uv__iou_fs_statx()
1103 sqe->fd = AT_FDCWD; in uv__iou_fs_statx()
1104 sqe->len = 0xFFF; /* STATX_BASIC_STATS + STATX_BTIME */ in uv__iou_fs_statx()
1105 sqe->opcode = UV__IORING_OP_STATX; in uv__iou_fs_statx()
1108 sqe->addr = (uintptr_t) ""; in uv__iou_fs_statx()
1109 sqe->fd = req->file; in uv__iou_fs_statx()
1110 sqe->statx_flags |= 0x1000; /* AT_EMPTY_PATH */ in uv__iou_fs_statx()
1114 sqe->statx_flags |= AT_SYMLINK_NOFOLLOW; in uv__iou_fs_statx()
1251 struct uv__io_uring_sqe* sqe; in uv__epoll_ctl_prep() local
1265 sqe = ctl->sqe; in uv__epoll_ctl_prep()
1266 sqe = &sqe[slot]; in uv__epoll_ctl_prep()
1268 memset(sqe, 0, sizeof(*sqe)); in uv__epoll_ctl_prep()
1269 sqe->addr = (uintptr_t) pe; in uv__epoll_ctl_prep()
1270 sqe->fd = epollfd; in uv__epoll_ctl_prep()
1271 sqe->len = op; in uv__epoll_ctl_prep()
1272 sqe->off = fd; in uv__epoll_ctl_prep()
1273 sqe->opcode = UV__IORING_OP_EPOLL_CTL; in uv__epoll_ctl_prep()
1274 sqe->user_data = op | slot << 2 | (int64_t) fd << 32; in uv__epoll_ctl_prep()
