feat: implement fsync(2) and hard link support [link(2)]

[lunaix-os.git] / lunaix-os / kernel / fs / twifs.c

diff --git a/lunaix-os/kernel/fs/twifs.c b/lunaix-os/kernel/fs/twifs.c
index d24b6a0fde64430e7f528d008ec3ada5fd8460ae..e3abe4b4c2a682577effbfd965c06ea15f318a91 100644 (file)
--- a/lunaix-os/kernel/fs/twifs.c
+++ b/lunaix-os/kernel/fs/twifs.c
@@ -15,7 +15,7 @@
 #include <lunaix/mm/cake.h>
 #include <lunaix/mm/valloc.h>
 
 #include <lunaix/mm/cake.h>
 #include <lunaix/mm/valloc.h>
 

-static struct twifs_node fs_root;
+static struct twifs_node* fs_root;

 
 static struct cake_pile* twi_pile;
 
 
 static struct cake_pile* twi_pile;
 


@@ -28,6 +28,21 @@ __twifs_openfile(struct v_inode* inode, struct v_file* file);
 struct twifs_node*
 __twifs_get_node(struct twifs_node* parent, struct hstr* name);
 
 struct twifs_node*
 __twifs_get_node(struct twifs_node* parent, struct hstr* name);
 

+struct v_inode*
+__twifs_create_inode(struct twifs_node* twi_node);
+
+int
+__twifs_iterate_dir(struct v_file* file, struct dir_context* dctx);
+
+int
+__twifs_mount(struct v_superblock* vsb, struct v_dnode* mount_point);
+
+int
+__twifs_mkdir(struct v_inode* inode, struct v_dnode* dnode);
+
+int
+__twifs_rmstuff(struct v_inode* inode);
+

 void
 twifs_init()
 {
 void
 twifs_init()
 {


@@ -36,49 +51,99 @@ twifs_init()
     struct filesystem* twifs = vzalloc(sizeof(struct filesystem));
     twifs->fs_name = HSTR("twifs", 5);
     twifs->mount = __twifs_mount;
     struct filesystem* twifs = vzalloc(sizeof(struct filesystem));
     twifs->fs_name = HSTR("twifs", 5);
     twifs->mount = __twifs_mount;

+    twifs->types = FSTYPE_ROFS;

 
     fsm_register(twifs);
 
 
     fsm_register(twifs);
 

-    memset(&fs_root, 0, sizeof(fs_root));
-    llist_init_head(&fs_root.children);
+    fs_root = twifs_dir_node(NULL, NULL, 0);
+}
+
+struct twifs_node*
+__twifs_new_node(struct twifs_node* parent, const char* name, int name_len)
+{
+    struct twifs_node* node = cake_grab(twi_pile);
+    memset(node, 0, sizeof(*node));

 
 

-    // 预备一些常用的类别
-    twifs_toplevel_node("kernel", 6);
-    twifs_toplevel_node("dev", 3);
-    twifs_toplevel_node("bus", 3);
+    node->name = HSTR(name, name_len);
+    hstr_rehash(&node->name, HSTR_FULL_HASH);
+    llist_init_head(&node->children);
+
+    if (parent) {
+        llist_append(&parent->children, &node->siblings);
+    }
+
+    return node;
+}
+
+int
+twifs_rm_node(struct twifs_node* node)
+{
+    if ((node->itype & VFS_INODE_TYPE_DIR) && !llist_empty(&node->children)) {
+        return ENOTEMPTY;
+    }
+    llist_delete(&node->siblings);
+    vfs_i_free(node->inode);
+    cake_release(twi_pile, node);
+    return 0;

 }
 
 struct twifs_node*
 }
 
 struct twifs_node*

-twifs_child_node(struct twifs_node* parent, const char* name, int name_len)
+twifs_file_node(struct twifs_node* parent, const char* name, int name_len)
+{
+    struct twifs_node* twi_node = __twifs_new_node(parent, name, name_len);
+    twi_node->itype = VFS_INODE_TYPE_FILE;
+
+    struct v_inode* twi_inode = __twifs_create_inode(twi_node);
+    twi_node->inode = twi_inode;
+
+    return twi_node;
+}
+
+struct twifs_node*
+twifs_dir_node(struct twifs_node* parent, const char* name, int name_len)

 {
     struct hstr hname = HSTR(name, name_len);
     hstr_rehash(&hname, HSTR_FULL_HASH);
 {
     struct hstr hname = HSTR(name, name_len);
     hstr_rehash(&hname, HSTR_FULL_HASH);

-

     struct twifs_node* node = __twifs_get_node(parent, &hname);
     if (node) {
         return node;
     }
 
     struct twifs_node* node = __twifs_get_node(parent, &hname);
     if (node) {
         return node;
     }
 

-    node = cake_grab(twi_pile);
-    memset(node, 0, sizeof(*node));
+    struct twifs_node* twi_node = __twifs_new_node(parent, name, name_len);
+    twi_node->itype = VFS_INODE_TYPE_DIR;

 
 

-    node->name = hname;
-    llist_init_head(&node->children);
-    llist_append(&parent->children, &node->siblings);
+    struct v_inode* twi_inode = __twifs_create_inode(twi_node);
+    twi_node->fops.readdir = __twifs_iterate_dir;
+    twi_node->inode = twi_inode;

 
 

-    return node;
+    return twi_node;

 }
 
 struct twifs_node*
 twifs_toplevel_node(const char* name, int name_len)
 {
 }
 
 struct twifs_node*
 twifs_toplevel_node(const char* name, int name_len)
 {

-    return twifs_child_node(&fs_root, name, name_len);
+    return twifs_dir_node(fs_root, name, name_len);

 }
 
 }
 

-void
+int
+__twifs_mkdir(struct v_inode* inode, struct v_dnode* dnode)
+{
+    struct twifs_node* parent_node = (struct twifs_node*)inode->data;
+    if (!(parent_node->itype & VFS_INODE_TYPE_DIR)) {
+        return ENOTDIR;
+    }
+    struct twifs_node* new_node =
+      twifs_dir_node(parent_node, dnode->name.value, dnode->name.len);
+    dnode->inode = new_node->inode;
+
+    return 0;
+}
+
+int

 __twifs_mount(struct v_superblock* vsb, struct v_dnode* mount_point)
 {
 __twifs_mount(struct v_superblock* vsb, struct v_dnode* mount_point)
 {

-    mount_point->inode = __twifs_create_inode(&fs_root);
+    mount_point->inode = fs_root->inode;
+    return 0;

 }
 
 struct v_inode*
 }
 
 struct v_inode*


@@ -91,14 +156,22 @@ __twifs_create_inode(struct twifs_node* twi_node)
                                .lb_usage = 0,
                                .data = twi_node,
                                .mtime = 0,
                                .lb_usage = 0,
                                .data = twi_node,
                                .mtime = 0,

-                               .ref_count = 0 };
+                               .open_count = 0 };

     inode->ops.dir_lookup = __twifs_dirlookup;
     inode->ops.dir_lookup = __twifs_dirlookup;

+    inode->ops.mkdir = __twifs_mkdir;
+    inode->ops.unlink = __twifs_rmstuff;
+    inode->ops.rmdir = __twifs_rmstuff;

     inode->ops.open = __twifs_openfile;
     inode->ops.open = __twifs_openfile;

+
+    return inode;

 }
 
 struct twifs_node*
 __twifs_get_node(struct twifs_node* parent, struct hstr* name)
 {
 }
 
 struct twifs_node*
 __twifs_get_node(struct twifs_node* parent, struct hstr* name)
 {

+    if (!parent)
+        return NULL;
+

     struct twifs_node *pos, *n;
     llist_for_each(pos, n, &parent->children, siblings)
     {
     struct twifs_node *pos, *n;
     llist_for_each(pos, n, &parent->children, siblings)
     {


@@ -109,17 +182,28 @@ __twifs_get_node(struct twifs_node* parent, struct hstr* name)
     return NULL;
 }
 
     return NULL;
 }
 

+int
+__twifs_rmstuff(struct v_inode* inode)
+{
+    struct twifs_node* twi_node = (struct twifs_node*)inode->data;
+    return twifs_rm_node(twi_node);
+}
+

 int
 __twifs_dirlookup(struct v_inode* inode, struct v_dnode* dnode)
 {
     struct twifs_node* twi_node = (struct twifs_node*)inode->data;
 
 int
 __twifs_dirlookup(struct v_inode* inode, struct v_dnode* dnode)
 {
     struct twifs_node* twi_node = (struct twifs_node*)inode->data;
 

+    if (!(twi_node->itype & VFS_INODE_TYPE_DIR)) {
+        return ENOTDIR;
+    }
+

     struct twifs_node* child_node = __twifs_get_node(twi_node, &dnode->name);
     if (child_node) {
     struct twifs_node* child_node = __twifs_get_node(twi_node, &dnode->name);
     if (child_node) {

-        dnode->inode = __twifs_create_inode(child_node);
+        dnode->inode = child_node->inode;

         return 0;
     }
         return 0;
     }

-    return VFS_ENODIR;
+    return ENOENT;

 }
 
 int
 }
 
 int


@@ -133,12 +217,13 @@ __twifs_iterate_dir(struct v_file* file, struct dir_context* dctx)
     {
         if (counter++ >= dctx->index) {
             dctx->index = counter;
     {
         if (counter++ >= dctx->index) {
             dctx->index = counter;

-            dctx->read_complete_callback(dctx, pos->name.value, pos->itype);
+            dctx->read_complete_callback(
+              dctx, pos->name.value, pos->name.len, pos->itype);

             return 0;
         }
     }
 
             return 0;
         }
     }
 

-    return VFS_EENDOFDIR;
+    return 1;

 }
 
 int
 }
 
 int


@@ -146,8 +231,9 @@ __twifs_openfile(struct v_inode* inode, struct v_file* file)
 {
     struct twifs_node* twi_node = (struct twifs_node*)inode->data;
     if (twi_node) {
 {
     struct twifs_node* twi_node = (struct twifs_node*)inode->data;
     if (twi_node) {

+        file->inode = twi_node->inode;

         file->ops = twi_node->fops;
         file->ops = twi_node->fops;

-        return 1;
+        return 0;

     }
     }

-    return 0;
+    return ENOTSUP;

 }
 }