ipc: socket initialization and limits

src/include/kernel/socket.h

@@ -12,6 +12,9 @@
 #include <kernel/sched.h>
 #include <sys/types.h>
 
+/* system-wide limit */
+#define MAX_SOCKETS             (1 << 20)   // little over a million
+
 /* socket family/domain - only Unix sockets will be implemented in the kernel */
 #define AF_UNIX                 1
 #define AF_LOCAL                AF_UNIX
@@ -45,6 +48,8 @@ typedef struct {
     void **inbound, **outbound;
 } SocketDescriptor;
 
+void socketInit();
+
 /* socket system calls */
 int socket(Thread *, int, int, int);
 int connect(Thread *, int, const struct sockaddr *, socklen_t);

src/ipc/sockinit.c

@@ -12,10 +12,32 @@
 
 #include <errno.h>
 #include <stdlib.h>
+#include <kernel/logger.h>
 #include <kernel/socket.h>
 #include <kernel/io.h>
 #include <kernel/sched.h>
 
+/* array of system-wide open sockets */
+static SocketDescriptor *sockets;
+static int socketCount;
+
+/* socketInit(): initializes the socket subsystem
+ * params: none
+ * returns: nothing
+ */
+
+void socketInit() {
+    sockets = calloc(sizeof(SocketDescriptor *), MAX_SOCKETS);
+    if(!sockets) {
+        KERROR("failed to allocate memory for socket subsystem\n");
+        while(1);
+    }
+
+    socketCount = 0;
+
+    KDEBUG("max %d sockets, %d per process\n", MAX_SOCKETS, MAX_IO_DESCRIPTORS);
+}
+
 /* socket(): opens a communication socket
  * params: t - calling thread, NULL for kernel threads
  * params: domain - socket domain/family

src/main.c

@@ -7,6 +7,7 @@
 
 #include <stdlib.h>
 #include <kernel/logger.h>
+#include <kernel/socket.h>
 #include <kernel/sched.h>
 #include <kernel/modules.h>
 #include <platform/platform.h>
@@ -50,15 +51,21 @@ void *kernelThread(void *args) {
     }
 
     setLumenPID(pid);
-    idleThread(args);
+    return idleThread(args);
 }
 
 // the true kernel entry point is called after platform-specific initialization
 // platform-specific code is in platform/[PLATFORM]/main.c
 
 int main(int argc, char **argv) {
+    /* the platform-specific main() function must initialize some basic form of
+     * output for debugging, physical and virtual memory, and multiprocessing; the
+     * boot process will continue here in a more platform-independent fashion */
+
+    socketInit();       // sockets
     schedInit();        // scheduler
 
+    // number of kernel threads = number of CPU cores
     kthreadCreate(&kernelThread, NULL);
 
     for(int i = 1; i < platformCountCPU(); i++) {