Framework for exporting system header to user space (#59)

[lunaix-os.git] / lunaix-os / kernel / process / taskfs.c

diff --git a/lunaix-os/kernel/process/taskfs.c b/lunaix-os/kernel/process/taskfs.c
index 28c371346478a5cb83922e35662ccb3246eee4ef..8ab3d65d6555204a31073de63958a3f135de9a72 100644 (file)
--- a/lunaix-os/kernel/process/taskfs.c
+++ b/lunaix-os/kernel/process/taskfs.c
@@ -1,13 +1,15 @@
-#include <lunaix/dirent.h>

 #include <lunaix/fs/taskfs.h>
 #include <lunaix/fs/twimap.h>
 #include <lunaix/fs/taskfs.h>
 #include <lunaix/fs/twimap.h>

+#include <lunaix/fs/api.h>

 #include <lunaix/mm/valloc.h>
 #include <lunaix/process.h>
 #include <lunaix/sched.h>
 
 #include <lunaix/mm/valloc.h>
 #include <lunaix/process.h>
 #include <lunaix/sched.h>
 

-#include <klibc/stdio.h>
+#include <klibc/strfmt.h>

 #include <klibc/string.h>
 
 #include <klibc/string.h>
 

+#include <usr/lunaix/dirent.h>
+

 #define COUNTER_MASK ((1 << 16) - 1)
 
 static struct hbucket* attr_export_table;
 #define COUNTER_MASK ((1 << 16) - 1)
 
 static struct hbucket* attr_export_table;


@@ -51,17 +53,21 @@ taskfs_readdir(struct v_file* file, struct dir_context* dctx)
 {
     struct v_inode* inode = file->inode;
     pid_t pid = inode->id >> 16;
 {
     struct v_inode* inode = file->inode;
     pid_t pid = inode->id >> 16;

-    int counter = 0;
+    unsigned int counter = 0;

 
     if ((inode->id & COUNTER_MASK)) {
         return ENOTDIR;
     }
 
 
     if ((inode->id & COUNTER_MASK)) {
         return ENOTDIR;
     }
 

+    if (fsapi_handle_pseudo_dirent(file, dctx)) {
+        return 1;
+    }
+

     if (pid) {
         struct task_attribute *pos, *n;
         llist_for_each(pos, n, &attributes, siblings)
         {
     if (pid) {
         struct task_attribute *pos, *n;
         llist_for_each(pos, n, &attributes, siblings)
         {

-            if (counter == dctx->index) {
+            if (counter == file->f_pos) {

                 dctx->read_complete_callback(
                   dctx, pos->key_val, VFS_NAME_MAXLEN, DT_FILE);
                 return 1;
                 dctx->read_complete_callback(
                   dctx, pos->key_val, VFS_NAME_MAXLEN, DT_FILE);
                 return 1;


@@ -75,7 +81,7 @@ taskfs_readdir(struct v_file* file, struct dir_context* dctx)
     struct proc_info *root = get_process(pid), *pos, *n;
     llist_for_each(pos, n, &root->tasks, tasks)
     {
     struct proc_info *root = get_process(pid), *pos, *n;
     llist_for_each(pos, n, &root->tasks, tasks)
     {

-        if (counter == dctx->index) {
+        if (counter == file->f_pos) {

             ksnprintf(name, VFS_NAME_MAXLEN, "%d", pos->pid);
             dctx->read_complete_callback(dctx, name, VFS_NAME_MAXLEN, DT_DIR);
             return 1;
             ksnprintf(name, VFS_NAME_MAXLEN, "%d", pos->pid);
             dctx->read_complete_callback(dctx, name, VFS_NAME_MAXLEN, DT_DIR);
             return 1;


@@ -128,12 +134,16 @@ taskfs_dirlookup(struct v_inode* this, struct v_dnode* dnode)
         return ENOENT;
     }
 
         return ENOENT;
     }
 

-    return taskfs_mknod(dnode, pid, 0, VFS_IFDIR);
+    return taskfs_mknod(dnode, pid, 0, F_DIR);

 }
 
 static struct v_file_ops taskfs_file_ops = { .close = default_file_close,
                                              .read = default_file_read,
 }
 
 static struct v_file_ops taskfs_file_ops = { .close = default_file_close,
                                              .read = default_file_read,

+                                             .read_page =
+                                               default_file_read_page,

                                              .write = default_file_write,
                                              .write = default_file_write,

+                                             .write_page =
+                                               default_file_write_page,

                                              .readdir = taskfs_readdir,
                                              .seek = default_file_seek };
 static struct v_inode_ops taskfs_inode_ops = { .dir_lookup = taskfs_dirlookup,
                                              .readdir = taskfs_readdir,
                                              .seek = default_file_seek };
 static struct v_inode_ops taskfs_inode_ops = { .dir_lookup = taskfs_dirlookup,


@@ -160,6 +170,12 @@ taskfs_mount(struct v_superblock* vsb, struct v_dnode* mount_point)
     return taskfs_mknod(mount_point, 0, 0, VFS_IFDIR);
 }
 
     return taskfs_mknod(mount_point, 0, 0, VFS_IFDIR);
 }
 

+int
+taskfs_unmount(struct v_superblock* vsb)
+{
+    return 0;
+}
+

 void
 taskfs_invalidate(pid_t pid)
 {
 void
 taskfs_invalidate(pid_t pid)
 {


@@ -215,12 +231,14 @@ export_task_attr();
 void
 taskfs_init()
 {
 void
 taskfs_init()
 {

-    struct filesystem* taskfs = fsm_new_fs("taskfs", 5);
-    taskfs->mount = taskfs_mount;
-
-    fsm_register(taskfs);
+    struct filesystem* fs;
+    fs = fsapi_fs_declare("taskfs", FSTYPE_PSEUDO);
+    
+    fsapi_fs_set_mntops(fs, taskfs_mount, taskfs_unmount);
+    fsapi_fs_finalise(fs);

 
     attr_export_table = vcalloc(ATTR_TABLE_LEN, sizeof(struct hbucket));
 
     export_task_attr();
 
     attr_export_table = vcalloc(ATTR_TABLE_LEN, sizeof(struct hbucket));
 
     export_task_attr();

-}
\ No newline at end of file
+}
+EXPORT_FILE_SYSTEM(taskfs, taskfs_init);
\ No newline at end of file