servers: moved initialization stub out of main

Author: jewelcodes

src/include/kernel/servers.h

@@ -11,6 +11,7 @@
 
 #include <stdint.h>
 
+#define SERVER_MAX_CONNECTIONS  512
 #define SERVER_MAX_SIZE         0x80000             // max msg size is 512 KiB
 #define SERVER_KERNEL_PATH      "lux:///kernel"     // not a real file, special path
 #define SERVER_LUMEN_PATH       "lux:///lumen"      // likewise not a real file
@@ -65,3 +66,6 @@ typedef struct {
     uint64_t buffer;        // pointer
     uint16_t w, h, pitch, bpp;
 } FramebufferResponse;
+
+void serverInit();
+void serverIdle();

src/main.c

@@ -23,35 +23,7 @@ void *idleThread(void *args) {
 
 void *kernelThread(void *args) {
     // open the kernel socket for server communication
-    struct sockaddr_un addr;
-    addr.sun_family = AF_UNIX;
-    strcpy(addr.sun_path, SERVER_KERNEL_PATH);     // this is a special path and not a true file
-
-    int sd = socket(NULL, AF_UNIX, SOCK_DGRAM | SOCK_NONBLOCK, 0);
-    if(sd < 0) {
-        KERROR("failed to open kernel socket: error code %d\n", -1*sd);
-        while(1) platformHalt();
-    }
-
-    int status = bind(NULL, sd, (const struct sockaddr *)&addr, sizeof(struct sockaddr_un));
-    if(status) {
-        KERROR("failed to bind kernel socket: error code %d\n", -1*status);
-        while(1) platformHalt();
-    }
-
-    status = listen(NULL, sd, 2048);
-    if(status) {
-        KERROR("failed to listen to kernel socket: error code %d\n", -1*status);
-        while(1) platformHalt();
-    }
-
-    KDEBUG("kernel is listening on socket %d: %s\n", sd, addr.sun_path);
-
-    void *buffer = malloc(SERVER_MAX_SIZE);
-    if(!buffer) {
-        KERROR("failed to allocate memory for server buffer\n");
-        while(1) platformHalt();
-    }
+    serverInit();
 
     KDEBUG("attempt to load lumen from ramdisk...\n");
 

src/servers/handle.c

@@ -0,0 +1,63 @@
+/*
+ * lux - a lightweight unix-like operating system
+ * Omar Elghoul, 2024
+ * 
+ * Core Microkernel
+ */
+
+/* Kernel-Server Communication */
+
+#include <stdlib.h>
+#include <string.h>
+#include <platform/platform.h>
+#include <kernel/logger.h>
+#include <kernel/socket.h>
+#include <kernel/servers.h>
+
+static int kernelSocket = 0, lumenSocket = 0;
+static int *connections;           // connected socket descriptors
+static struct sockaddr *connaddr;  // connected socket addresses
+static socklen_t *connlen;         // length of connected socket addresses
+static void *buffer;
+static int connectionCount = 0;
+
+/* serverInit(): initializes the server subsystem
+ * params: none
+ * returns: nothing
+ */
+
+void serverInit() {
+    struct sockaddr_un addr;
+    addr.sun_family = AF_UNIX;
+    strcpy(addr.sun_path, SERVER_KERNEL_PATH);     // this is a special path and not a true file
+
+    kernelSocket = socket(NULL, AF_UNIX, SOCK_DGRAM | SOCK_NONBLOCK, 0);
+    if(kernelSocket < 0) {
+        KERROR("failed to open kernel socket: error code %d\n", -1*kernelSocket);
+        while(1) platformHalt();
+    }
+
+    int status = bind(NULL, kernelSocket, (const struct sockaddr *)&addr, sizeof(struct sockaddr_un));
+    if(status) {
+        KERROR("failed to bind kernel socket: error code %d\n", -1*status);
+        while(1) platformHalt();
+    }
+
+    status = listen(NULL, kernelSocket, SERVER_MAX_CONNECTIONS);
+    if(status) {
+        KERROR("failed to listen to kernel socket: error code %d\n", -1*status);
+        while(1) platformHalt();
+    }
+
+    connections = calloc(SERVER_MAX_CONNECTIONS, sizeof(int));
+    connaddr = calloc(SERVER_MAX_CONNECTIONS, sizeof(struct sockaddr));
+    connlen = calloc(SERVER_MAX_CONNECTIONS, sizeof(socklen_t));
+    buffer = malloc(SERVER_MAX_SIZE);
+
+    if(!connections || !connaddr || !connlen || !buffer) {
+        KERROR("failed to allocate memory for incoming connections\n");
+        while(1) platformHalt();
+    }
+
+    KDEBUG("kernel is listening on socket %d: %s\n", kernelSocket, addr.sun_path);
+}