UnixSocket::write_at(): init

* Implement write_at for unix socket
* Fix Buffer::write_data returning (len - 1) instead of (len)
* Print the slice len in syslog

Signed-off-by: Andy-Python-Programmer <andypythonappdeveloper@gmail.com>

Author: Andy-Python-Programmer

src/aero_kernel/src/fs/ramfs.rs

@@ -199,7 +199,7 @@ impl INodeInterface for LockedRamINode {
                 device.write_at(offset, buffer)
             }
 
-            FileContents::Socket(_) => Err(FileSystemError::NotSupported),
+            FileContents::Socket(e) => e.write_at(offset, buffer),
             FileContents::None => Err(FileSystemError::NotSupported),
         }
     }
@@ -298,7 +298,7 @@ impl INodeInterface for LockedRamINode {
                 device.read_at(offset, buffer)
             }
 
-            FileContents::Socket(_) => Err(FileSystemError::NotSupported),
+            FileContents::Socket(e) => e.read_at(offset, buffer),
             FileContents::None => Err(FileSystemError::NotSupported),
         }
     }

src/aero_kernel/src/socket/unix.rs

@@ -123,8 +123,19 @@ impl INodeInterface for UnixSocket {
         Ok(read)
     }
 
-    fn write_at(&self, _offset: usize, _buffer: &[u8]) -> Result<usize> {
-        unimplemented!()
+    fn write_at(&self, offset: usize, buffer: &[u8]) -> Result<usize> {
+        let inner = self.inner.lock_irq();
+
+        // TODO: Remove the unwrap and return an error instead.
+        let peer = inner
+            .peer
+            .as_ref()
+            .expect("UnixSocket::write_at(): socket not connected!");
+
+        let result = offset + peer.buffer.lock_irq().write_data(buffer);
+        peer.wq.notify_complete();
+
+        Ok(result)
     }
 
     fn metadata(&self) -> Result<Metadata> {

src/aero_kernel/src/utils/buffer.rs

@@ -51,7 +51,7 @@ impl Buffer {
 
     pub fn write_data(&mut self, data: &[u8]) -> usize {
         self.data.extend_from_slice(data);
-        data.len() - 1
+        data.len()
     }
 }
 

src/aero_proc/src/syscall.rs

@@ -119,7 +119,7 @@ pub fn parse(attr: TokenStream, item: TokenStream) -> TokenStream {
                     if let Some(typ) = typ {
                         match typ {
                             ArgType::Array(_) => quote::quote!(.add_argument("<array>")),
-                            ArgType::Slice(_) => quote::quote!(.add_argument("<slice>")),
+                            ArgType::Slice(_) => quote::quote!(.add_argument(alloc::format!("<slice[..{}]>", #ident.len()))),
 
                             ArgType::Pointer(_) => {
                                 quote::quote!(.add_argument(alloc::format!("*{:#x}", #ident as usize)))