vfs: pipe

ilobilo · ilobilo · commit 6706bbe4e27a · 2025-12-05T23:13:21.000+04:00
diff --git a/kernel/interfaces/lib/ringbuffer.cppm b/kernel/interfaces/lib/ringbuffer.cppm
diff --git a/kernel/interfaces/lib/semaphore.cppm b/kernel/interfaces/lib/semaphore.cppm
@@ -27,8 +27,9 @@ export namespace lib
         semaphore &operator=(const semaphore &) = delete;
         semaphore &operator=(semaphore &&) = delete;
 
-        void wait();
+        bool wait();
         bool wait_for(std::size_t ms);
         void signal(bool drop = false);
+        void signal_all();
     };
 } // export namespace lib
diff --git a/kernel/interfaces/system/syscall/vfs.cppm b/kernel/interfaces/system/syscall/vfs.cppm
@@ -7,9 +7,9 @@ import std;
 
 export namespace syscall::vfs
 {
+    int openat(int dirfd, const char __user *pathname, int flags, mode_t mode);
     int open(const char __user *pathname, int flags, mode_t mode);
     int creat(const char __user *pathname, mode_t mode);
-    int openat(int dirfd, const char __user *pathname, int flags, mode_t mode);
 
     int close(int fd);
 
@@ -43,4 +43,7 @@ export namespace syscall::vfs
     int dup3(int oldfd, int newfd, int flags);
 
     char *getcwd(char __user *buf, std::size_t size);
+
+    int pipe2(int __user *pipefd, int flags);
+    int pipe(int __user *pipefd);
 } // export namespace syscall::vfs
diff --git a/kernel/interfaces/system/system.cppm b/kernel/interfaces/system/system.cppm
@@ -8,11 +8,11 @@ export import system.chrono;
 export import system.bin;
 export import system.cpu;
 export import system.cpu.local;
-export import system.dev;
 export import system.interrupts;
 export import system.memory;
 export import system.net;
 export import system.pci;
 export import system.scheduler;
 export import system.syscall;
-export import system.vfs;
+export import system.vfs;
+export import system.vfs.dev;
diff --git a/kernel/interfaces/system/vfs/dev.cppm b/kernel/interfaces/system/vfs/dev.cppm
@@ -1,12 +1,12 @@
 // Copyright (C) 2024-2025  ilobilo
 
-export module system.dev;
+export module system.vfs.dev;
 
 import system.vfs;
 import lib;
 import std;
 
-export namespace dev
+export namespace vfs::dev
 {
     inline constexpr std::uint32_t major(dev_t dev)
     {
@@ -33,4 +33,4 @@ export namespace dev
 
     bool register_cdev(std::shared_ptr<vfs::ops> ops, dev_t dev);
     std::shared_ptr<vfs::ops> get_cdev_ops(dev_t dev);
-} // export namespace dev
+} // export namespace vfs::dev
diff --git a/kernel/interfaces/system/vfs/pipe.cppm b/kernel/interfaces/system/vfs/pipe.cppm
@@ -0,0 +1,12 @@
+// Copyright (C) 2024-2025  ilobilo
+
+export module system.vfs.pipe;
+
+import system.vfs;
+import lib;
+import std;
+
+export namespace vfs::pipe
+{
+    std::shared_ptr<vfs::ops> get_ops();
+} // export namespace vfs::pipe
diff --git a/kernel/interfaces/system/vfs/vfs.cppm b/kernel/interfaces/system/vfs/vfs.cppm
@@ -152,9 +152,13 @@ export namespace vfs
             return (errno = ENOTTY, -1);
         }
 
-        virtual std::shared_ptr<vmm::object> map(std::shared_ptr<file> self, bool priv) = 0;
+        virtual std::shared_ptr<vmm::object> map(std::shared_ptr<file> self, bool priv)
+        {
+            lib::unused(self, priv);
+            return nullptr;
+        }
 
-        virtual bool sync() = 0;
+        virtual bool sync() { return true; }
 
         virtual ~ops() = default;
     };
@@ -212,7 +216,7 @@ export namespace vfs
         std::shared_ptr<ops> op;
         stat stat;
 
-        inode(std::shared_ptr<ops> op) : op { op } { }
+        inode(std::shared_ptr<ops> op) : op { op }, stat { } { }
 
         virtual ~inode() = default;
     };
diff --git a/kernel/source/arch/x86_64/system/syscall.cpp b/kernel/source/arch/x86_64/system/syscall.cpp
@@ -45,6 +45,7 @@ namespace x86_64::syscall
         [19] = { "readv", vfs::readv },
         [20] = { "writev", vfs::writev },
         [21] = { "access", vfs::access },
+        [22] = { "pipe", vfs::pipe },
         [23] = { "select", proc::select },
         [32] = { "dup", vfs::dup },
         [33] = { "dup2", vfs::dup2 },
@@ -79,6 +80,7 @@ namespace x86_64::syscall
         [273] = { "set_robust_list", proc::set_robust_list },
         [274] = { "get_robust_list", proc::get_robust_list },
         [292] = { "dup3", vfs::dup3 },
+        [293] = { "pipe2", vfs::pipe2 },
         [295] = { "preadv", vfs::preadv },
         [296] = { "pwritev", vfs::pwritev },
         [302] = { "prlimit", proc::prlimit },
diff --git a/kernel/source/drivers/fs/dev/dev.cpp b/kernel/source/drivers/fs/dev/dev.cpp
@@ -3,8 +3,8 @@
 module drivers.fs.dev;
 
 import drivers.initramfs;
-import system.dev;
 import system.vfs;
+import system.vfs.dev;
 import magic_enum;
 import lib;
 import std;
@@ -62,7 +62,7 @@ namespace fs::dev
                 );
             };
 
-            using namespace ::dev;
+            using namespace vfs::dev;
             create("/dev/null", stat::s_ifchr | 0666, makedev(1, 3));
             create("/dev/zero", stat::s_ifchr | 0666, makedev(1, 5));
             create("/dev/full", stat::s_ifchr | 0666, makedev(1, 7));
diff --git a/kernel/source/drivers/fs/dev/mem.cpp b/kernel/source/drivers/fs/dev/mem.cpp
@@ -4,8 +4,8 @@ module drivers.fs.dev.mem;
 
 import drivers.fs.devtmpfs;
 import system.memory.virt;
-import system.dev;
 import system.vfs;
+import system.vfs.dev;
 import boot;
 import lib;
 import std;
@@ -173,7 +173,7 @@ namespace fs::dev::mem
         lib::initgraph::require { devtmpfs::mounted_stage() },
         lib::initgraph::entail { registered_stage() },
         [] {
-            using namespace ::dev;
+            using namespace vfs::dev;
             register_cdev(null_ops::singleton(), makedev(1, 3));
             register_cdev(zero_ops::singleton(), makedev(1, 5));
             register_cdev(full_ops::singleton(), makedev(1, 7));
diff --git a/kernel/source/drivers/fs/dev/tty.cpp b/kernel/source/drivers/fs/dev/tty.cpp
@@ -6,7 +6,7 @@ import drivers.fs.devtmpfs;
 import system.memory.virt;
 import system.scheduler;
 import system.vfs;
-import system.dev;
+import system.vfs.dev;
 import arch;
 import lib;
 import std;
@@ -93,8 +93,6 @@ namespace fs::dev::tty
         }
     } // namespace
 
-    using namespace ::dev;
-
     std::ssize_t default_ldisc::read(lib::maybe_uspan<std::byte> buffer)
     {
         lib::unused(buffer);
@@ -170,6 +168,8 @@ namespace fs::dev::tty
         test_driver() : driver { "tty-test", 4, 0, ktermios::standard() } { }
     };
 
+    using namespace vfs::dev;
+
     struct ops : vfs::ops
     {
         static std::shared_ptr<ops> singleton()
@@ -180,8 +180,8 @@ namespace fs::dev::tty
 
         bool open(std::shared_ptr<vfs::file> self, int flags) override
         {
-            lib::bug_on(self->private_data != nullptr);
-            lib::bug_on(!self || !self->path.dentry || !self->path.dentry->inode);
+            lib::bug_on(!self || self->private_data != nullptr);
+            lib::bug_on(!self->path.dentry || !self->path.dentry->inode);
 
             const auto rdev = self->path.dentry->inode->stat.st_rdev;
             auto drv = get_driver(major(rdev));
@@ -280,14 +280,6 @@ namespace fs::dev::tty
             lib::unused(file, size);
             return true;
         }
-
-        std::shared_ptr<vmm::object> map(std::shared_ptr<vfs::file> file, bool priv) override
-        {
-            lib::unused(file, priv);
-            return nullptr;
-        }
-
-        bool sync() override { return true; }
     };
 
     struct current_ops : vfs::ops
@@ -300,6 +292,7 @@ namespace fs::dev::tty
 
         bool open(std::shared_ptr<vfs::file> self, int flags) override
         {
+            lib::bug_on(!self || self->private_data != nullptr);
             lib::unused(flags);
 
             const auto proc = sched::proc_for(self->pid);
@@ -353,14 +346,6 @@ namespace fs::dev::tty
             lib::unused(file, size);
             return true;
         }
-
-        std::shared_ptr<vmm::object> map(std::shared_ptr<vfs::file> file, bool priv) override
-        {
-            lib::unused(file, priv);
-            return nullptr;
-        }
-
-        bool sync() override { return true; }
     };
 
     lib::initgraph::stage *registered_stage()
diff --git a/kernel/source/drivers/initramfs.cpp b/kernel/source/drivers/initramfs.cpp
@@ -3,8 +3,8 @@
 module drivers.initramfs;
 
 import drivers.fs.dev;
-import system.dev;
 import system.vfs;
+import system.vfs.dev;
 import magic_enum;
 import boot;
 import lib;
@@ -68,7 +68,7 @@ namespace initramfs
 
                 const auto devmajor = lib::oct2int<time_t>(current->devmajor);
                 const auto devminor = lib::oct2int<time_t>(current->devminor);
-                const dev_t dev = dev::makedev(devmajor, devminor);
+                const dev_t dev = vfs::dev::makedev(devmajor, devminor);
 
                 std::shared_ptr<vfs::inode> inode;
 
diff --git a/kernel/source/lib/semaphore.cpp b/kernel/source/lib/semaphore.cpp
@@ -25,20 +25,21 @@ namespace lib
         return ret;
     }
 
-    void semaphore::wait()
+    bool semaphore::wait()
     {
         const bool ints = arch::int_switch_status(false);
         lock.lock();
 
         auto me = sched::this_thread();
 
+        std::size_t reason = 0;
         if (--signals < 0)
         {
             threads.push_back(me);
             me->prepare_sleep();
             lock.unlock();
 
-            if (sched::yield())
+            if ((reason = sched::yield()))
             {
                 lock.lock();
                 auto it = std::remove(threads.begin(), threads.end(), me);
@@ -47,14 +48,18 @@ namespace lib
                     threads.erase(it);
                     signals++;
                 }
+                else reason = sched::wake_reason::success;
+
                 lock.unlock();
             }
             arch::int_switch(ints);
-            return;
+            return reason == sched::wake_reason::success;
         }
 
         lock.unlock();
         arch::int_switch(ints);
+
+        return reason == sched::wake_reason::success;
     }
 
     bool semaphore::wait_for(std::size_t ms)
@@ -98,4 +103,26 @@ namespace lib
         if (thread)
             thread->wake_up(0);
     }
+
+    void semaphore::signal_all()
+    {
+        const bool ints = arch::int_switch_status(false);
+        lock.lock();
+
+        std::list<sched::thread_base *> temp_threads;
+
+        while (!threads.empty())
+        {
+            bug_on(signals >= 0);
+            temp_threads.push_back(threads.front());
+            threads.pop_front();
+            signals++;
+        }
+
+        lock.unlock();
+        arch::int_switch(ints);
+
+        for (auto &thread : temp_threads)
+            static_cast<sched::thread *>(thread)->wake_up(0);
+    }
 } // namespace lib
diff --git a/kernel/source/system/syscall/vfs.cpp b/kernel/source/system/syscall/vfs.cpp
diff --git a/kernel/source/system/vfs/dev.cpp b/kernel/source/system/vfs/dev.cpp
diff --git a/kernel/source/system/vfs/pipe.cpp b/kernel/source/system/vfs/pipe.cpp
diff --git a/kernel/source/system/vfs/vfs.cpp b/kernel/source/system/vfs/vfs.cpp
