initial socket interface

Author: arihant2math

Cargo.lock

@@ -22,6 +22,7 @@ ringbuf = { version = "0.4.8", default-features = false, features = ["alloc"] }
 bitflags = "2.9.1"
 futures = { version = "0.3.31", default-features = false, features = ["alloc", "async-await"] }
 rand = { version = "0.9.2", default-features = false, features = ["small_rng"] }
+smoltcp = { version = "0.12.0", default-features = false, features = ["alloc", "medium-ethernet", "medium-ip", "proto-ipv4", "proto-ipv6", "socket-tcp", "socket-udp"] }
 
 [features]
 default = ["smp"]

Cargo.toml

@@ -138,6 +138,9 @@ pub enum KernelError {
     #[error("Operation not supported")]
     NotSupported,
 
+    #[error("Address family not supported")]
+    AddressFamilyNotSupported,
+
     #[error("Device probe failed: {0}")]
     Probe(#[from] ProbeError),
 
@@ -180,6 +183,9 @@ pub enum KernelError {
     #[error("Operation timed out")]
     TimedOut,
 
+    #[error("Not a socket")]
+    NotASocket,
+
     #[error("{0}")]
     Other(&'static str),
 }

libkernel/src/error.rs

@@ -71,6 +71,10 @@ use crate::{
         threading::{futex::sys_futex, sys_set_robust_list, sys_set_tid_address},
     },
     sched::{current::current_task, sys_sched_yield},
+    socket::syscalls::{
+        accept::sys_accept, bind::sys_bind, connect::sys_connect, listen::sys_listen,
+        shutdown::sys_shutdown, socket::sys_socket,
+    },
 };
 use alloc::boxed::Box;
 use libkernel::{
@@ -356,7 +360,12 @@ pub async fn handle_syscall() {
         0xb1 => sys_getegid().map_err(|e| match e {}),
         0xb2 => sys_gettid().map_err(|e| match e {}),
         0xb3 => sys_sysinfo(TUA::from_value(arg1 as _)).await,
-        0xc6 => Err(KernelError::NotSupported),
+        0xc6 => sys_socket(arg1 as _, arg2 as _, arg3 as _).await,
+        0xc8 => sys_bind(arg1.into(), UA::from_value(arg2 as _), arg3 as _).await,
+        0xc9 => sys_listen(arg1.into(), arg2 as _).await,
+        0xca => sys_accept(arg1.into()).await,
+        0xcb => sys_connect(arg1.into(), UA::from_value(arg2 as _), arg3 as _).await,
+        0xd2 => sys_shutdown(arg1.into(), arg2 as _).await,
         0xd6 => sys_brk(VA::from_value(arg1 as _))
             .await
             .map_err(|e| match e {}),

src/arch/arm64/exceptions/syscall.rs

@@ -137,4 +137,12 @@ pub trait FileOps: Send + Sync {
     ) -> Result<usize> {
         Err(KernelError::InvalidValue)
     }
+
+    fn is_socket(&self) -> bool {
+        false
+    }
+
+    fn as_socket(&mut self) -> Option<&mut dyn crate::socket::SocketOps> {
+        None
+    }
 }

src/fs/fops.rs

@@ -44,6 +44,7 @@ mod kernel;
 mod memory;
 mod process;
 mod sched;
+mod socket;
 mod sync;
 
 #[panic_handler]