Lines Matching refs:sqe
540 char* sqe;
544 sqe = MAP_FAILED;
590 sqe = mmap(0,
597 if (sq == MAP_FAILED || sqe == MAP_FAILED)
622 iou->sqe = sqe;
635 iou->sqarray[i] = i; /* Slot -> sqe identity mapping. */
643 if (sqe != MAP_FAILED)
644 munmap(sqe, sqelen);
653 munmap(iou->sqe, iou->sqelen);
792 struct uv__io_uring_sqe* sqe;
810 sqe = iou->sqe;
811 sqe = &sqe[slot];
812 memset(sqe, 0, sizeof(*sqe));
813 sqe->user_data = (uintptr_t) req;
824 return sqe;
846 struct uv__io_uring_sqe* sqe;
871 sqe = uv__iou_get_sqe(iou, loop, req);
872 if (sqe == NULL)
875 sqe->fd = req->file;
876 sqe->opcode = UV__IORING_OP_CLOSE;
887 struct uv__io_uring_sqe* sqe;
892 sqe = uv__iou_get_sqe(iou, loop, req);
893 if (sqe == NULL)
899 sqe->fd = req->file;
900 sqe->fsync_flags = fsync_flags;
901 sqe->opcode = UV__IORING_OP_FSYNC;
910 struct uv__io_uring_sqe* sqe;
918 sqe = uv__iou_get_sqe(iou, loop, req);
919 if (sqe == NULL)
922 sqe->addr = (uintptr_t) req->path;
923 sqe->fd = AT_FDCWD;
924 sqe->addr2 = (uintptr_t) req->new_path;
925 sqe->len = AT_FDCWD;
926 sqe->opcode = UV__IORING_OP_LINKAT;
935 struct uv__io_uring_sqe* sqe;
943 sqe = uv__iou_get_sqe(iou, loop, req);
944 if (sqe == NULL)
947 sqe->addr = (uintptr_t) req->path;
948 sqe->fd = AT_FDCWD;
949 sqe->len = req->mode;
950 sqe->opcode = UV__IORING_OP_MKDIRAT;
959 struct uv__io_uring_sqe* sqe;
964 sqe = uv__iou_get_sqe(iou, loop, req);
965 if (sqe == NULL)
968 sqe->addr = (uintptr_t) req->path;
969 sqe->fd = AT_FDCWD;
970 sqe->len = req->mode;
971 sqe->opcode = UV__IORING_OP_OPENAT;
972 sqe->open_flags = req->flags | O_CLOEXEC;
981 struct uv__io_uring_sqe* sqe;
986 sqe = uv__iou_get_sqe(iou, loop, req);
987 if (sqe == NULL)
990 sqe->addr = (uintptr_t) req->path;
991 sqe->fd = AT_FDCWD;
992 sqe->addr2 = (uintptr_t) req->new_path;
993 sqe->len = AT_FDCWD;
994 sqe->opcode = UV__IORING_OP_RENAMEAT;
1003 struct uv__io_uring_sqe* sqe;
1011 sqe = uv__iou_get_sqe(iou, loop, req);
1012 if (sqe == NULL)
1015 sqe->addr = (uintptr_t) req->path;
1016 sqe->fd = AT_FDCWD;
1017 sqe->addr2 = (uintptr_t) req->new_path;
1018 sqe->opcode = UV__IORING_OP_SYMLINKAT;
1027 struct uv__io_uring_sqe* sqe;
1032 sqe = uv__iou_get_sqe(iou, loop, req);
1033 if (sqe == NULL)
1036 sqe->addr = (uintptr_t) req->path;
1037 sqe->fd = AT_FDCWD;
1038 sqe->opcode = UV__IORING_OP_UNLINKAT;
1049 struct uv__io_uring_sqe* sqe;
1063 sqe = uv__iou_get_sqe(iou, loop, req);
1064 if (sqe == NULL)
1067 sqe->addr = (uintptr_t) req->bufs;
1068 sqe->fd = req->file;
1069 sqe->len = req->nbufs;
1070 sqe->off = req->off < 0 ? -1 : req->off;
1071 sqe->opcode = is_read ? UV__IORING_OP_READV : UV__IORING_OP_WRITEV;
1083 struct uv__io_uring_sqe* sqe;
1093 sqe = uv__iou_get_sqe(iou, loop, req);
1094 if (sqe == NULL) {
1101 sqe->addr = (uintptr_t) req->path;
1102 sqe->addr2 = (uintptr_t) statxbuf;
1103 sqe->fd = AT_FDCWD;
1104 sqe->len = 0xFFF; /* STATX_BASIC_STATS + STATX_BTIME */
1105 sqe->opcode = UV__IORING_OP_STATX;
1108 sqe->addr = (uintptr_t) "";
1109 sqe->fd = req->file;
1110 sqe->statx_flags |= 0x1000; /* AT_EMPTY_PATH */
1114 sqe->statx_flags |= AT_SYMLINK_NOFOLLOW;
1247 struct uv__io_uring_sqe* sqe;
1296 sqe = ctl->sqe;
1297 sqe = &sqe[slot];
1299 memset(sqe, 0, sizeof(*sqe));
1300 sqe->addr = (uintptr_t) pe;
1301 sqe->fd = epollfd;
1302 sqe->len = op;
1303 sqe->off = fd;
1304 sqe->opcode = UV__IORING_OP_EPOLL_CTL;
1305 sqe->user_data = op | slot << 2 | (int64_t) fd << 32;