From 349cef56144fd8ffc8eabc0d75b5d9b382561a5a Mon Sep 17 00:00:00 2001 From: jewelcodes Date: Fri, 6 Sep 2024 10:07:55 -0400 Subject: [PATCH] ipc: socket creation with socket() --- src/include/kernel/socket.h | 4 +-- src/ipc/sockinit.c | 52 +++++++++++++++++++++++++++++++++++++ 2 files changed, 54 insertions(+), 2 deletions(-) create mode 100644 src/ipc/sockinit.c diff --git a/src/include/kernel/socket.h b/src/include/kernel/socket.h index 31f25d2..20a8b45 100644 --- a/src/include/kernel/socket.h +++ b/src/include/kernel/socket.h @@ -39,8 +39,8 @@ struct sockaddr_un { /* socket-specific I/O descriptor (see io.h) */ typedef struct { - struct sockaddr socket; - int backlog; + struct sockaddr address; + int type, protocol, backlog; int inboundCount, outboundCount; void **inbound, **outbound; } SocketDescriptor; diff --git a/src/ipc/sockinit.c b/src/ipc/sockinit.c new file mode 100644 index 0000000..3c5936e --- /dev/null +++ b/src/ipc/sockinit.c @@ -0,0 +1,52 @@ +/* + * lux - a lightweight unix-like operating system + * Omar Elghoul, 2024 + * + * Core Microkernel + */ + +/* Socket Initialization Functions */ +/* socket(), bind(), and close() for sockets are implemented here */ + +/* I tried my best to follow The Base Specification Issue 8 */ + +#include +#include +#include +#include +#include + +/* socket(): opens a communication socket + * params: t - calling thread, NULL for kernel threads + * params: domain - socket domain/family + * params: type - type of socket (connection, datagram, etc) + * params: protocol - protocol implementing "type" on "domain", zero for default + * returns: positive socket descriptor on success, negative error code on fail + */ + +int socket(Thread *t, int domain, int type, int protocol) { + Process *p; + if(t) p = getProcess(t->pid); + else p = getProcess(getPid()); + + if(!p) return -ESRCH; + if(p->iodCount == MAX_IO_DESCRIPTORS) return -EMFILE; + + IODescriptor *iod = NULL; // open I/O descriptor + int sd = openIO(p, (void **) &iod); + if(sd < 0 || !iod) return sd; + + iod->type = IO_SOCKET; + iod->data = calloc(1, sizeof(SocketDescriptor)); + if(!iod->data) { + closeIO(p, iod); + } + + // set up the socket family for now + SocketDescriptor *sock = (SocketDescriptor *)iod->data; + sock->address.sa_family = domain; + sock->type = type; + sock->protocol = protocol; + + return sd; +}