+ lock_inode(inode);
+
+ if (!check_directory_node(inode)) {
+ errno = ENOTDIR;
+ goto unlock;
+ }
+
+ struct dir_context dctx = (struct dir_context) {
+ .cb_data = dent,
+ .read_complete_callback = __vfs_readdir_callback
+ };
+
+ if ((errno = fd_s->file->ops->readdir(fd_s->file, &dctx)) != 1) {
+ goto unlock;
+ }
+ dent->d_offset++;
+ fd_s->file->f_pos++;
+
+unlock:
+ unlock_inode(inode);
+
+done:
+ return DO_STATUS_OR_RETURN(errno);
+}
+
+__DEFINE_LXSYSCALL3(int, read, int, fd, void*, buf, size_t, count)
+{
+ int errno = 0;
+ struct v_fd* fd_s;
+ if ((errno = vfs_getfd(fd, &fd_s))) {
+ goto done;
+ }
+
+ struct v_file* file = fd_s->file;
+ if (check_directory_node(file->inode)) {
+ errno = EISDIR;
+ goto done;
+ }
+
+ lock_inode(file->inode);
+
+ file->inode->atime = clock_unixtime();
+
+ if (check_seqdev_node(file->inode) || (fd_s->flags & FO_DIRECT)) {
+ errno = file->ops->read(file->inode, buf, count, file->f_pos);
+ } else {
+ errno = pcache_read(file->inode, buf, count, file->f_pos);
+ }
+
+ if (errno > 0) {
+ file->f_pos += errno;
+ unlock_inode(file->inode);
+ return errno;
+ }
+
+ unlock_inode(file->inode);
+
+done:
+ return DO_STATUS(errno);
+}
+
+__DEFINE_LXSYSCALL3(int, write, int, fd, void*, buf, size_t, count)
+{
+ int errno = 0;
+ struct v_fd* fd_s;
+ if ((errno = vfs_getfd(fd, &fd_s))) {
+ goto done;
+ }
+
+ struct v_inode* inode;
+ struct v_file* file = fd_s->file;
+
+ if ((errno = vfs_check_writable(file->dnode))) {
+ goto done;
+ }
+
+ if (check_directory_node(file->inode)) {
+ errno = EISDIR;
+ goto done;
+ }
+
+ inode = file->inode;
+ lock_inode(inode);
+
+ inode->mtime = clock_unixtime();
+ if ((fd_s->flags & O_APPEND)) {
+ file->f_pos = inode->fsize;
+ }
+
+ if (check_seqdev_node(inode) || (fd_s->flags & FO_DIRECT)) {
+ errno = file->ops->write(inode, buf, count, file->f_pos);
+ } else {
+ errno = pcache_write(inode, buf, count, file->f_pos);
+ }
+
+ if (errno > 0) {
+ file->f_pos += errno;
+ inode->fsize = MAX(inode->fsize, file->f_pos);
+
+ unlock_inode(inode);
+ return errno;
+ }
+
+ unlock_inode(inode);
+
+done:
+ return DO_STATUS(errno);
+}
+
+__DEFINE_LXSYSCALL3(int, lseek, int, fd, int, offset, int, options)
+{
+ int errno = 0;
+ struct v_fd* fd_s;
+ if ((errno = vfs_getfd(fd, &fd_s))) {
+ goto done;
+ }
+
+ struct v_file* file = fd_s->file;
+ struct v_inode* inode = file->inode;
+
+ if (!file->ops->seek) {
+ errno = ENOTSUP;
+ goto done;
+ }
+
+ lock_inode(inode);
+
+ int overflow = 0;
+ int fpos = file->f_pos;
+
+ if (vfs_get_dtype(inode->itype) == DT_DIR) {
+ options = (options != FSEEK_END) ? options : FSEEK_SET;
+ }
+
+ switch (options) {
+ case FSEEK_CUR:
+ overflow = sadd_of((int)file->f_pos, offset, &fpos);
+ break;
+ case FSEEK_END:
+ overflow = sadd_of((int)inode->fsize, offset, &fpos);
+ break;
+ case FSEEK_SET:
+ fpos = offset;
+ break;
+ }
+
+ if (overflow) {
+ errno = EOVERFLOW;
+ }
+ else {
+ errno = file->ops->seek(file, fpos);
+ }
+
+ unlock_inode(inode);
+
+done:
+ return DO_STATUS(errno);
+}
+
+int
+vfs_get_path(struct v_dnode* dnode, char* buf, size_t size, int depth)
+{
+ if (!dnode) {
+ return 0;
+ }
+
+ if (depth > 64) {
+ return ENAMETOOLONG;
+ }
+
+ size_t len = 0;
+
+ if (dnode->parent != dnode) {
+ len = vfs_get_path(dnode->parent, buf, size, depth + 1);
+ }
+
+ if (len >= size) {
+ return len;
+ }
+
+ if (!len || buf[len - 1] != VFS_PATH_DELIM) {
+ buf[len++] = VFS_PATH_DELIM;
+ }
+
+ size_t cpy_size = MIN(dnode->name.len, size - len);
+ strncpy(buf + len, dnode->name.value, cpy_size);
+ len += cpy_size;
+
+ return len;
+}
+
+int
+vfs_readlink(struct v_dnode* dnode, char* buf, size_t size)
+{
+ const char* link;
+ struct v_inode* inode = dnode->inode;
+
+ if (!check_symlink_node(inode)) {
+ return EINVAL;
+ }
+
+ if (!inode->ops->read_symlink) {
+ return ENOTSUP;
+ }
+
+ lock_inode(inode);
+
+ int errno = inode->ops->read_symlink(inode, &link);
+ if (errno >= 0) {
+ strncpy(buf, link, MIN(size, (size_t)errno));
+ }
+
+ unlock_inode(inode);
+ return errno;
+}
+
+int
+vfs_get_dtype(int itype)
+{
+ int dtype = DT_FILE;
+ if (check_itype(itype, VFS_IFSYMLINK)) {
+ dtype |= DT_SYMLINK;
+ }
+
+ if (check_itype(itype, VFS_IFDIR)) {
+ dtype |= DT_DIR;
+ return dtype;
+ }
+
+ // TODO other types
+
+ return dtype;
+}
+
+__DEFINE_LXSYSCALL3(int, realpathat, int, fd, char*, buf, size_t, size)
+{
+ int errno;
+ struct v_fd* fd_s;
+ if ((errno = vfs_getfd(fd, &fd_s))) {
+ goto done;
+ }
+
+ struct v_dnode* dnode;
+ errno = vfs_get_path(fd_s->file->dnode, buf, size, 0);
+
+ if (errno >= 0) {
+ return errno;
+ }
+
+done:
+ return DO_STATUS(errno);
+}
+
+__DEFINE_LXSYSCALL3(int, readlink, const char*, path, char*, buf, size_t, size)
+{
+ int errno;
+ struct v_dnode* dnode;
+ if (!(errno = vfs_walk_proc(path, &dnode, NULL, VFS_WALK_NOFOLLOW))) {
+ errno = vfs_readlink(dnode, buf, size);
+ }
+
+ if (errno >= 0) {
+ return errno;
+ }
+
+ return DO_STATUS(errno);
+}
+
+__DEFINE_LXSYSCALL4(
+ int, readlinkat, int, dirfd, const char*, pathname, char*, buf, size_t, size)
+{
+ int errno;
+ struct v_fd* fd_s;
+ if ((errno = vfs_getfd(dirfd, &fd_s))) {
+ goto done;
+ }
+
+ pathname = pathname ? pathname : "";
+
+ struct v_dnode* dnode;
+ if (!(errno = vfs_walk(
+ fd_s->file->dnode, pathname, &dnode, NULL, VFS_WALK_NOFOLLOW))) {
+ errno = vfs_readlink(fd_s->file->dnode, buf, size);
+ }
+
+ if (errno >= 0) {
+ return errno;
+ }
+
+done:
+ return DO_STATUS(errno);
+}
+
+/*
+ NOTE
+ When we perform operation that could affect the layout of
+ directory (i.e., rename, mkdir, rmdir). We must lock the parent dir
+ whenever possible. This will blocking any ongoing path walking to reach
+ it hence avoid any partial state.
+*/
+
+__DEFINE_LXSYSCALL1(int, rmdir, const char*, pathname)
+{
+ int errno;
+ struct v_dnode* dnode;
+ if ((errno = vfs_walk_proc(pathname, &dnode, NULL, 0))) {
+ return DO_STATUS(errno);
+ }
+
+ lock_dnode(dnode);
+
+ if ((errno = vfs_check_writable(dnode))) {
+ goto done;
+ }
+
+ if ((dnode->super_block->fs->types & FSTYPE_ROFS)) {
+ errno = EROFS;
+ goto done;
+ }
+
+ if (dnode->ref_count > 1 || dnode->inode->open_count) {
+ errno = EBUSY;
+ goto done;
+ }
+
+ if (!llist_empty(&dnode->children)) {
+ errno = ENOTEMPTY;
+ goto done;
+ }
+
+ struct v_dnode* parent = dnode->parent;
+
+ if (!parent) {
+ errno = EINVAL;
+ goto done;
+ }
+
+ lock_dnode(parent);
+ lock_inode(parent->inode);
+
+ if (check_directory_node(dnode->inode)) {
+ errno = parent->inode->ops->rmdir(parent->inode, dnode);
+ if (!errno) {
+ vfs_dcache_remove(dnode);
+ }
+ } else {
+ errno = ENOTDIR;
+ }
+
+ unlock_inode(parent->inode);
+ unlock_dnode(parent);
+
+done:
+ unlock_dnode(dnode);
+ return DO_STATUS(errno);
+}
+
+__DEFINE_LXSYSCALL1(int, mkdir, const char*, path)
git://scm.lunaixsky.com / lunaix-os.git / blobdiff