Lines Matching refs:req
92 if (req == NULL) \
94 UV_REQ_INIT(req, UV_FS); \
95 req->fs_type = UV_FS_ ## subtype; \
96 req->result = 0; \
97 req->ptr = NULL; \
98 req->loop = loop; \
99 req->path = NULL; \
100 req->new_path = NULL; \
101 req->bufs = NULL; \
102 req->cb = cb; \
110 req->path = path; \
112 req->path = uv__strdup(path); \
113 if (req->path == NULL) \
122 req->path = path; \
123 req->new_path = new_path; \
129 req->path = uv__malloc(path_len + new_path_len); \
130 if (req->path == NULL) \
132 req->new_path = req->path + path_len; \
133 memcpy((void*) req->path, path, path_len); \
134 memcpy((void*) req->new_path, new_path, new_path_len); \
142 uv__req_register(loop, req); \
144 &req->work_req, \
151 uv__fs_work(&req->work_req); \
152 return req->result; \
170 static ssize_t uv__fs_fsync(uv_fs_t* req) { in uv__fs_fsync() argument
182 r = fcntl(req->file, F_FULLFSYNC); in uv__fs_fsync()
184 r = fcntl(req->file, 85 /* F_BARRIERFSYNC */); /* fsync + barrier */ in uv__fs_fsync()
186 r = fsync(req->file); in uv__fs_fsync()
189 return fsync(req->file); in uv__fs_fsync()
194 static ssize_t uv__fs_fdatasync(uv_fs_t* req) { in uv__fs_fdatasync() argument
196 return fdatasync(req->file); in uv__fs_fdatasync()
199 return uv__fs_fsync(req); in uv__fs_fdatasync()
201 return fsync(req->file); in uv__fs_fdatasync()
236 static ssize_t uv__fs_futime(uv_fs_t* req) { in uv__fs_futime() argument
242 ts[0] = uv__fs_to_timespec(req->atime); in uv__fs_futime()
243 ts[1] = uv__fs_to_timespec(req->mtime); in uv__fs_futime()
244 return futimens(req->file, ts); in uv__fs_futime()
252 tv[0] = uv__fs_to_timeval(req->atime); in uv__fs_futime()
253 tv[1] = uv__fs_to_timeval(req->mtime); in uv__fs_futime()
255 return futimesat(req->file, NULL, tv); in uv__fs_futime()
257 return futimes(req->file, tv); in uv__fs_futime()
264 atr.att_mtime = req->mtime; in uv__fs_futime()
265 atr.att_atime = req->atime; in uv__fs_futime()
266 return __fchattr(req->file, &atr, sizeof(atr)); in uv__fs_futime()
274 static ssize_t uv__fs_mkdtemp(uv_fs_t* req) { in uv__fs_mkdtemp() argument
275 return mkdtemp((char*) req->path) ? 0 : -1; in uv__fs_mkdtemp()
298 static int uv__fs_mkstemp(uv_fs_t* req) { in uv__fs_mkstemp() argument
309 path = (char*) req->path; in uv__fs_mkstemp()
345 if (req->cb != NULL) in uv__fs_mkstemp()
346 uv_rwlock_rdlock(&req->loop->cloexec_lock); in uv__fs_mkstemp()
360 if (req->cb != NULL) in uv__fs_mkstemp()
361 uv_rwlock_rdunlock(&req->loop->cloexec_lock); in uv__fs_mkstemp()
370 static ssize_t uv__fs_open(uv_fs_t* req) { in uv__fs_open() argument
372 return open(req->path, req->flags | O_CLOEXEC, req->mode); in uv__fs_open()
376 if (req->cb != NULL) in uv__fs_open()
377 uv_rwlock_rdlock(&req->loop->cloexec_lock); in uv__fs_open()
379 r = open(req->path, req->flags, req->mode); in uv__fs_open()
391 if (req->cb != NULL) in uv__fs_open()
392 uv_rwlock_rdunlock(&req->loop->cloexec_lock); in uv__fs_open()
508 static ssize_t uv__fs_read(uv_fs_t* req) { in uv__fs_read() argument
516 fd = req->file; in uv__fs_read()
517 off = req->off; in uv__fs_read()
518 bufs = (const struct iovec*) req->bufs; in uv__fs_read()
519 nbufs = req->nbufs; in uv__fs_read()
551 if (req->cb != NULL) in uv__fs_read()
552 if (req->bufs != req->bufsml) in uv__fs_read()
553 uv__free(req->bufs); in uv__fs_read()
555 req->bufs = NULL; in uv__fs_read()
556 req->nbufs = 0; in uv__fs_read()
572 static ssize_t uv__fs_scandir(uv_fs_t* req) { in uv__fs_scandir() argument
577 n = scandir(req->path, &dents, uv__fs_scandir_filter, uv__fs_scandir_sort); in uv__fs_scandir()
580 req->nbufs = 0; in uv__fs_scandir()
592 req->ptr = dents; in uv__fs_scandir()
597 static int uv__fs_opendir(uv_fs_t* req) { in uv__fs_opendir() argument
604 dir->dir = opendir(req->path); in uv__fs_opendir()
608 req->ptr = dir; in uv__fs_opendir()
613 req->ptr = NULL; in uv__fs_opendir()
617 static int uv__fs_readdir(uv_fs_t* req) { in uv__fs_readdir() argument
624 dir = req->ptr; in uv__fs_readdir()
663 static int uv__fs_closedir(uv_fs_t* req) { in uv__fs_closedir() argument
666 dir = req->ptr; in uv__fs_closedir()
673 uv__free(req->ptr); in uv__fs_closedir()
674 req->ptr = NULL; in uv__fs_closedir()
678 static int uv__fs_statfs(uv_fs_t* req) { in uv__fs_statfs() argument
687 if (0 != statvfs(req->path, &buf)) in uv__fs_statfs()
691 if (0 != statfs(req->path, &buf)) in uv__fs_statfs()
717 req->ptr = stat_fs; in uv__fs_statfs()
732 static ssize_t uv__fs_readlink(uv_fs_t* req) { in uv__fs_readlink() argument
738 maxlen = uv__fs_pathmax_size(req->path); in uv__fs_readlink()
743 ret = uv__lstat(req->path, &st); in uv__fs_readlink()
756 maxlen = uv__fs_pathmax_size(req->path); in uv__fs_readlink()
767 len = os390_readlink(req->path, buf, maxlen); in uv__fs_readlink()
769 len = readlink(req->path, buf, maxlen); in uv__fs_readlink()
786 req->ptr = buf; in uv__fs_readlink()
791 static ssize_t uv__fs_realpath(uv_fs_t* req) { in uv__fs_realpath() argument
796 tmp = realpath(req->path, NULL); in uv__fs_realpath()
810 len = uv__fs_pathmax_size(req->path); in uv__fs_realpath()
818 if (realpath(req->path, buf) == NULL) { in uv__fs_realpath()
824 req->ptr = buf; in uv__fs_realpath()
829 static ssize_t uv__fs_sendfile_emul(uv_fs_t* req) { in uv__fs_sendfile_emul() argument
843 len = req->bufsml[0].len; in uv__fs_sendfile_emul()
844 in_fd = req->flags; in uv__fs_sendfile_emul()
845 out_fd = req->file; in uv__fs_sendfile_emul()
846 offset = req->off; in uv__fs_sendfile_emul()
937 req->off = offset; in uv__fs_sendfile_emul()
1027 static ssize_t uv__fs_sendfile(uv_fs_t* req) { in uv__fs_sendfile() argument
1031 in_fd = req->flags; in uv__fs_sendfile()
1032 out_fd = req->file; in uv__fs_sendfile()
1041 off = req->off; in uv__fs_sendfile()
1042 len = req->bufsml[0].len; in uv__fs_sendfile()
1057 if (r != -1 || off > req->off) { in uv__fs_sendfile()
1058 r = off - req->off; in uv__fs_sendfile()
1059 req->off = off; in uv__fs_sendfile()
1068 return uv__fs_sendfile_emul(req); in uv__fs_sendfile()
1087 off = req->off; in uv__fs_sendfile()
1088 r = uv__fs_copy_file_range(in_fd, &off, out_fd, NULL, req->bufsml[0].len, 0); in uv__fs_sendfile()
1090 r = off - req->off; in uv__fs_sendfile()
1091 req->off = off; in uv__fs_sendfile()
1096 r = sendfile(in_fd, out_fd, req->off, req->bufsml[0].len, NULL, &len, 0); in uv__fs_sendfile()
1100 len = req->bufsml[0].len; in uv__fs_sendfile()
1101 r = sendfile(in_fd, out_fd, req->off, &len, NULL, 0); in uv__fs_sendfile()
1112 req->off += len; in uv__fs_sendfile()
1121 return uv__fs_sendfile_emul(req); in uv__fs_sendfile()
1131 return uv__fs_sendfile_emul(req); in uv__fs_sendfile()
1136 static ssize_t uv__fs_utime(uv_fs_t* req) { in uv__fs_utime() argument
1142 ts[0] = uv__fs_to_timespec(req->atime); in uv__fs_utime()
1143 ts[1] = uv__fs_to_timespec(req->mtime); in uv__fs_utime()
1144 return utimensat(AT_FDCWD, req->path, ts, 0); in uv__fs_utime()
1151 tv[0] = uv__fs_to_timeval(req->atime); in uv__fs_utime()
1152 tv[1] = uv__fs_to_timeval(req->mtime); in uv__fs_utime()
1153 return utimes(req->path, tv); in uv__fs_utime()
1157 buf.actime = req->atime; in uv__fs_utime()
1158 buf.modtime = req->mtime; in uv__fs_utime()
1159 return utime(req->path, &buf); in uv__fs_utime()
1165 atr.att_mtime = req->mtime; in uv__fs_utime()
1166 atr.att_atime = req->atime; in uv__fs_utime()
1167 return __lchattr((char*) req->path, &atr, sizeof(atr)); in uv__fs_utime()
1175 static ssize_t uv__fs_lutime(uv_fs_t* req) { in uv__fs_lutime() argument
1183 ts[0] = uv__fs_to_timespec(req->atime); in uv__fs_lutime()
1184 ts[1] = uv__fs_to_timespec(req->mtime); in uv__fs_lutime()
1185 return utimensat(AT_FDCWD, req->path, ts, AT_SYMLINK_NOFOLLOW); in uv__fs_lutime()
1191 tv[0] = uv__fs_to_timeval(req->atime); in uv__fs_lutime()
1192 tv[1] = uv__fs_to_timeval(req->mtime); in uv__fs_lutime()
1193 return lutimes(req->path, tv); in uv__fs_lutime()
1201 static ssize_t uv__fs_write(uv_fs_t* req) { in uv__fs_write() argument
1208 fd = req->file; in uv__fs_write()
1209 off = req->off; in uv__fs_write()
1210 bufs = (const struct iovec*) req->bufs; in uv__fs_write()
1211 nbufs = req->nbufs; in uv__fs_write()
1230 static ssize_t uv__fs_copyfile(uv_fs_t* req) { in uv__fs_copyfile() argument
1249 srcfd = uv_fs_open(NULL, &fs_req, req->path, O_RDONLY, 0, NULL); in uv__fs_copyfile()
1263 if (req->flags & UV_FS_COPYFILE_EXCL) in uv__fs_copyfile()
1269 req->new_path, in uv__fs_copyfile()
1282 if ((req->flags & UV_FS_COPYFILE_EXCL) == 0) { in uv__fs_copyfile()
1362 if (req->flags & UV_FS_COPYFILE_FICLONE || in uv__fs_copyfile()
1363 req->flags & UV_FS_COPYFILE_FICLONE_FORCE) { in uv__fs_copyfile()
1370 if (req->flags & UV_FS_COPYFILE_FICLONE_FORCE) { in uv__fs_copyfile()
1376 if (req->flags & UV_FS_COPYFILE_FICLONE_FORCE) { in uv__fs_copyfile()
1424 uv_fs_unlink(NULL, &fs_req, req->new_path, NULL); in uv__fs_copyfile()
1637 static ssize_t uv__fs_write_all(uv_fs_t* req) { in uv__fs_write_all() argument
1645 nbufs = req->nbufs; in uv__fs_write_all()
1646 bufs = req->bufs; in uv__fs_write_all()
1650 req->nbufs = nbufs; in uv__fs_write_all()
1651 if (req->nbufs > iovmax) in uv__fs_write_all()
1652 req->nbufs = iovmax; in uv__fs_write_all()
1655 result = uv__fs_write(req); in uv__fs_write_all()
1664 if (req->off >= 0) in uv__fs_write_all()
1665 req->off += result; in uv__fs_write_all()
1667 req->nbufs = uv__fs_buf_offset(req->bufs, result); in uv__fs_write_all()
1668 req->bufs += req->nbufs; in uv__fs_write_all()
1669 nbufs -= req->nbufs; in uv__fs_write_all()
1673 if (bufs != req->bufsml) in uv__fs_write_all()
1676 req->bufs = NULL; in uv__fs_write_all()
1677 req->nbufs = 0; in uv__fs_write_all()
1685 uv_fs_t* req; in uv__fs_work() local
1688 req = container_of(w, uv_fs_t, work_req); in uv__fs_work()
1689 retry_on_eintr = !(req->fs_type == UV_FS_CLOSE || in uv__fs_work()
1690 req->fs_type == UV_FS_READ); in uv__fs_work()
1700 switch (req->fs_type) { in uv__fs_work()
1701 X(ACCESS, access(req->path, req->flags)); in uv__fs_work()
1702 X(CHMOD, chmod(req->path, req->mode)); in uv__fs_work()
1703 X(CHOWN, chown(req->path, req->uid, req->gid)); in uv__fs_work()
1704 X(CLOSE, uv__fs_close(req->file)); in uv__fs_work()
1705 X(COPYFILE, uv__fs_copyfile(req)); in uv__fs_work()
1706 X(FCHMOD, fchmod(req->file, req->mode)); in uv__fs_work()
1707 X(FCHOWN, fchown(req->file, req->uid, req->gid)); in uv__fs_work()
1708 X(LCHOWN, lchown(req->path, req->uid, req->gid)); in uv__fs_work()
1709 X(FDATASYNC, uv__fs_fdatasync(req)); in uv__fs_work()
1710 X(FSTAT, uv__fs_fstat(req->file, &req->statbuf)); in uv__fs_work()
1711 X(FSYNC, uv__fs_fsync(req)); in uv__fs_work()
1712 X(FTRUNCATE, ftruncate(req->file, req->off)); in uv__fs_work()
1713 X(FUTIME, uv__fs_futime(req)); in uv__fs_work()
1714 X(LUTIME, uv__fs_lutime(req)); in uv__fs_work()
1715 X(LSTAT, uv__fs_lstat(req->path, &req->statbuf)); in uv__fs_work()
1716 X(LINK, link(req->path, req->new_path)); in uv__fs_work()
1717 X(MKDIR, mkdir(req->path, req->mode)); in uv__fs_work()
1718 X(MKDTEMP, uv__fs_mkdtemp(req)); in uv__fs_work()
1719 X(MKSTEMP, uv__fs_mkstemp(req)); in uv__fs_work()
1720 X(OPEN, uv__fs_open(req)); in uv__fs_work()
1721 X(READ, uv__fs_read(req)); in uv__fs_work()
1722 X(SCANDIR, uv__fs_scandir(req)); in uv__fs_work()
1723 X(OPENDIR, uv__fs_opendir(req)); in uv__fs_work()
1724 X(READDIR, uv__fs_readdir(req)); in uv__fs_work()
1725 X(CLOSEDIR, uv__fs_closedir(req)); in uv__fs_work()
1726 X(READLINK, uv__fs_readlink(req)); in uv__fs_work()
1727 X(REALPATH, uv__fs_realpath(req)); in uv__fs_work()
1728 X(RENAME, rename(req->path, req->new_path)); in uv__fs_work()
1729 X(RMDIR, rmdir(req->path)); in uv__fs_work()
1730 X(SENDFILE, uv__fs_sendfile(req)); in uv__fs_work()
1731 X(STAT, uv__fs_stat(req->path, &req->statbuf)); in uv__fs_work()
1732 X(STATFS, uv__fs_statfs(req)); in uv__fs_work()
1733 X(SYMLINK, symlink(req->path, req->new_path)); in uv__fs_work()
1734 X(UNLINK, unlink(req->path)); in uv__fs_work()
1735 X(UTIME, uv__fs_utime(req)); in uv__fs_work()
1736 X(WRITE, uv__fs_write_all(req)); in uv__fs_work()
1743 req->result = UV__ERR(errno); in uv__fs_work()
1745 req->result = r; in uv__fs_work()
1747 if (r == 0 && (req->fs_type == UV_FS_STAT || in uv__fs_work()
1748 req->fs_type == UV_FS_FSTAT || in uv__fs_work()
1749 req->fs_type == UV_FS_LSTAT)) { in uv__fs_work()
1750 req->ptr = &req->statbuf; in uv__fs_work()
1756 uv_fs_t* req; in uv__fs_done() local
1758 req = container_of(w, uv_fs_t, work_req); in uv__fs_done()
1759 uv__req_unregister(req->loop, req); in uv__fs_done()
1762 assert(req->result == 0); in uv__fs_done()
1763 req->result = UV_ECANCELED; in uv__fs_done()
1766 req->cb(req); in uv__fs_done()
1770 void uv__fs_post(uv_loop_t* loop, uv_fs_t* req) { in uv__fs_post() argument
1771 uv__req_register(loop, req); in uv__fs_post()
1773 &req->work_req, in uv__fs_post()
1781 uv_fs_t* req, in uv_fs_access() argument
1787 req->flags = flags; in uv_fs_access()
1793 uv_fs_t* req, in uv_fs_chmod() argument
1799 req->mode = mode; in uv_fs_chmod()
1805 uv_fs_t* req, in uv_fs_chown() argument
1812 req->uid = uid; in uv_fs_chown()
1813 req->gid = gid; in uv_fs_chown()
1818 int uv_fs_close(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb) { in uv_fs_close() argument
1820 req->file = file; in uv_fs_close()
1822 if (uv__iou_fs_close(loop, req)) in uv_fs_close()
1829 uv_fs_t* req, in uv_fs_fchmod() argument
1834 req->file = file; in uv_fs_fchmod()
1835 req->mode = mode; in uv_fs_fchmod()
1841 uv_fs_t* req, in uv_fs_fchown() argument
1847 req->file = file; in uv_fs_fchown()
1848 req->uid = uid; in uv_fs_fchown()
1849 req->gid = gid; in uv_fs_fchown()
1855 uv_fs_t* req, in uv_fs_lchown() argument
1862 req->uid = uid; in uv_fs_lchown()
1863 req->gid = gid; in uv_fs_lchown()
1868 int uv_fs_fdatasync(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb) { in uv_fs_fdatasync() argument
1870 req->file = file; in uv_fs_fdatasync()
1872 if (uv__iou_fs_fsync_or_fdatasync(loop, req, /* IORING_FSYNC_DATASYNC */ 1)) in uv_fs_fdatasync()
1878 int uv_fs_fstat(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb) { in uv_fs_fstat() argument
1880 req->file = file; in uv_fs_fstat()
1882 if (uv__iou_fs_statx(loop, req, /* is_fstat */ 1, /* is_lstat */ 0)) in uv_fs_fstat()
1888 int uv_fs_fsync(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb) { in uv_fs_fsync() argument
1890 req->file = file; in uv_fs_fsync()
1892 if (uv__iou_fs_fsync_or_fdatasync(loop, req, /* no flags */ 0)) in uv_fs_fsync()
1899 uv_fs_t* req, in uv_fs_ftruncate() argument
1904 req->file = file; in uv_fs_ftruncate()
1905 req->off = off; in uv_fs_ftruncate()
1911 uv_fs_t* req, in uv_fs_futime() argument
1917 req->file = file; in uv_fs_futime()
1918 req->atime = atime; in uv_fs_futime()
1919 req->mtime = mtime; in uv_fs_futime()
1924 uv_fs_t* req, in uv_fs_lutime() argument
1931 req->atime = atime; in uv_fs_lutime()
1932 req->mtime = mtime; in uv_fs_lutime()
1937 int uv_fs_lstat(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb) { in uv_fs_lstat() argument
1941 if (uv__iou_fs_statx(loop, req, /* is_fstat */ 0, /* is_lstat */ 1)) in uv_fs_lstat()
1948 uv_fs_t* req, in uv_fs_link() argument
1955 if (uv__iou_fs_link(loop, req)) in uv_fs_link()
1962 uv_fs_t* req, in uv_fs_mkdir() argument
1968 req->mode = mode; in uv_fs_mkdir()
1970 if (uv__iou_fs_mkdir(loop, req)) in uv_fs_mkdir()
1977 uv_fs_t* req, in uv_fs_mkdtemp() argument
1981 req->path = uv__strdup(tpl); in uv_fs_mkdtemp()
1982 if (req->path == NULL) in uv_fs_mkdtemp()
1989 uv_fs_t* req, in uv_fs_mkstemp() argument
1993 req->path = uv__strdup(tpl); in uv_fs_mkstemp()
1994 if (req->path == NULL) in uv_fs_mkstemp()
2001 uv_fs_t* req, in uv_fs_open() argument
2008 req->flags = flags; in uv_fs_open()
2009 req->mode = mode; in uv_fs_open()
2011 if (uv__iou_fs_open(loop, req)) in uv_fs_open()
2017 int uv_fs_read(uv_loop_t* loop, uv_fs_t* req, in uv_fs_read() argument
2028 req->off = off; in uv_fs_read()
2029 req->file = file; in uv_fs_read()
2030 req->bufs = (uv_buf_t*) bufs; /* Safe, doesn't mutate |bufs| */ in uv_fs_read()
2031 req->nbufs = nbufs; in uv_fs_read()
2036 req->bufs = req->bufsml; in uv_fs_read()
2037 if (nbufs > ARRAY_SIZE(req->bufsml)) in uv_fs_read()
2038 req->bufs = uv__malloc(nbufs * sizeof(*bufs)); in uv_fs_read()
2040 if (req->bufs == NULL) in uv_fs_read()
2043 memcpy(req->bufs, bufs, nbufs * sizeof(*bufs)); in uv_fs_read()
2045 if (uv__iou_fs_read_or_write(loop, req, /* is_read */ 1)) in uv_fs_read()
2054 uv_fs_t* req, in uv_fs_scandir() argument
2060 req->flags = flags; in uv_fs_scandir()
2065 uv_fs_t* req, in uv_fs_opendir() argument
2074 uv_fs_t* req, in uv_fs_readdir() argument
2082 req->ptr = dir; in uv_fs_readdir()
2087 uv_fs_t* req, in uv_fs_closedir() argument
2095 req->ptr = dir; in uv_fs_closedir()
2100 uv_fs_t* req, in uv_fs_readlink() argument
2110 uv_fs_t* req, in uv_fs_realpath() argument
2120 uv_fs_t* req, in uv_fs_rename() argument
2127 if (uv__iou_fs_rename(loop, req)) in uv_fs_rename()
2133 int uv_fs_rmdir(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb) { in uv_fs_rmdir() argument
2141 uv_fs_t* req, in uv_fs_sendfile() argument
2148 req->flags = in_fd; /* hack */ in uv_fs_sendfile()
2149 req->file = out_fd; in uv_fs_sendfile()
2150 req->off = off; in uv_fs_sendfile()
2151 req->bufsml[0].len = len; in uv_fs_sendfile()
2156 int uv_fs_stat(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb) { in uv_fs_stat() argument
2160 if (uv__iou_fs_statx(loop, req, /* is_fstat */ 0, /* is_lstat */ 0)) in uv_fs_stat()
2167 uv_fs_t* req, in uv_fs_symlink() argument
2174 req->flags = flags; in uv_fs_symlink()
2176 if (uv__iou_fs_symlink(loop, req)) in uv_fs_symlink()
2182 int uv_fs_unlink(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb) { in uv_fs_unlink() argument
2186 if (uv__iou_fs_unlink(loop, req)) in uv_fs_unlink()
2193 uv_fs_t* req, in uv_fs_utime() argument
2200 req->atime = atime; in uv_fs_utime()
2201 req->mtime = mtime; in uv_fs_utime()
2207 uv_fs_t* req, in uv_fs_write() argument
2218 req->file = file; in uv_fs_write()
2220 req->nbufs = nbufs; in uv_fs_write()
2221 req->bufs = req->bufsml; in uv_fs_write()
2222 if (nbufs > ARRAY_SIZE(req->bufsml)) in uv_fs_write()
2223 req->bufs = uv__malloc(nbufs * sizeof(*bufs)); in uv_fs_write()
2225 if (req->bufs == NULL) in uv_fs_write()
2228 memcpy(req->bufs, bufs, nbufs * sizeof(*bufs)); in uv_fs_write()
2230 req->off = off; in uv_fs_write()
2233 if (uv__iou_fs_read_or_write(loop, req, /* is_read */ 0)) in uv_fs_write()
2240 void uv_fs_req_cleanup(uv_fs_t* req) { in uv_fs_req_cleanup() argument
2241 if (req == NULL) in uv_fs_req_cleanup()
2249 if (req->path != NULL && in uv_fs_req_cleanup()
2250 (req->cb != NULL || in uv_fs_req_cleanup()
2251 req->fs_type == UV_FS_MKDTEMP || req->fs_type == UV_FS_MKSTEMP)) in uv_fs_req_cleanup()
2252 uv__free((void*) req->path); /* Memory is shared with req->new_path. */ in uv_fs_req_cleanup()
2254 req->path = NULL; in uv_fs_req_cleanup()
2255 req->new_path = NULL; in uv_fs_req_cleanup()
2257 if (req->fs_type == UV_FS_READDIR && req->ptr != NULL) in uv_fs_req_cleanup()
2258 uv__fs_readdir_cleanup(req); in uv_fs_req_cleanup()
2260 if (req->fs_type == UV_FS_SCANDIR && req->ptr != NULL) in uv_fs_req_cleanup()
2261 uv__fs_scandir_cleanup(req); in uv_fs_req_cleanup()
2263 if (req->bufs != req->bufsml) in uv_fs_req_cleanup()
2264 uv__free(req->bufs); in uv_fs_req_cleanup()
2265 req->bufs = NULL; in uv_fs_req_cleanup()
2267 if (req->fs_type != UV_FS_OPENDIR && req->ptr != &req->statbuf) in uv_fs_req_cleanup()
2268 uv__free(req->ptr); in uv_fs_req_cleanup()
2269 req->ptr = NULL; in uv_fs_req_cleanup()
2274 uv_fs_t* req, in uv_fs_copyfile() argument
2288 req->flags = flags; in uv_fs_copyfile()
2294 uv_fs_t* req, in uv_fs_statfs() argument
2302 int uv_fs_get_system_error(const uv_fs_t* req) { in uv_fs_get_system_error() argument
2303 return -req->result; in uv_fs_get_system_error()
