From c5ef8c53a799daf8cfae5292392321e26c3593ce Mon Sep 17 00:00:00 2001
From: Nathan Giddings <nathang567@gmail.com>
Date: Wed, 8 Nov 2023 14:13:03 -0600
Subject: [PATCH] Started separating important structs from kernel.c

---
 include/addressspace.h | 16 ++++++++++++++++
 include/process.h      | 33 +++++++++++++++++++++++++++++++++
 include/sharedobject.h | 20 ++++++++++++++++++++
 src/addressspace.c     | 22 ++++++++++++++++++++++
 src/process.c          | 32 ++++++++++++++++++++++++++++++++
 src/sharedobject.c     | 37 +++++++++++++++++++++++++++++++++++++
 6 files changed, 160 insertions(+)
 create mode 100644 include/addressspace.h
 create mode 100644 include/process.h
 create mode 100644 include/sharedobject.h
 create mode 100644 src/addressspace.c
 create mode 100644 src/process.c
 create mode 100644 src/sharedobject.c

diff --git a/include/addressspace.h b/include/addressspace.h
new file mode 100644
index 0000000..6672556
--- /dev/null
+++ b/include/addressspace.h
@@ -0,0 +1,16 @@
+#ifndef QUARK_ADDRESSSPACE_H
+#define QUARK_ADDRESSSPACE_H
+
+#include "types/physaddr.h"
+
+typedef struct addressspace_t
+{
+    physaddr_t page_table;
+    int refcount;
+} addressspace_t;
+
+addressspace_t *addressspace_construct();
+
+
+
+#endif
\ No newline at end of file
diff --git a/include/process.h b/include/process.h
new file mode 100644
index 0000000..162506c
--- /dev/null
+++ b/include/process.h
@@ -0,0 +1,33 @@
+#ifndef QUARK_PROCESS_H
+#define QUARK_PROCESS_H
+
+#include "types/pid.h"
+#include "types/physaddr.h"
+#include "types/status.h"
+#include "queue.h"
+
+typedef enum process_state_t
+{
+    PROCESS_ACTIVE,
+    PROCESS_REQUESTING,
+    PROCESS_SENDING
+} process_state_t;
+
+typedef struct process_t
+{
+    pid_t pid;
+    int priority;
+    physaddr_t page_table;
+    struct avltree_t *shared_objects;
+    process_state_t state;
+    struct queue_t sending_queue;
+    struct queue_t message_queue;
+    struct message_t *message_buffer;
+    struct process_context_t *ctx;
+} process_t;
+
+process_t *process_construct(pid_t pid, void *entry, void *stack, int priority, physaddr_t address_space);
+
+error_t process_call_func(process_t *process, void *func, void *ret, int argc, ...);
+
+#endif
\ No newline at end of file
diff --git a/include/sharedobject.h b/include/sharedobject.h
new file mode 100644
index 0000000..98bb052
--- /dev/null
+++ b/include/sharedobject.h
@@ -0,0 +1,20 @@
+#ifndef QUARK_SHARED_OBJECT_H
+#define QUARK_SHARED_OBJECT_H
+
+#include "types/physaddr.h"
+#include <stddef.h>
+
+struct shared_object_t
+{
+    physaddr_t phys_addr;
+    size_t size;
+    unsigned long access_flags;
+    unsigned long refcount;
+    struct avltree_t *users;
+};
+
+struct shared_object *create_shared_object(size_t size, unsigned long flags);
+
+void destroy_shared_object(struct shared_object_t *obj);
+
+#endif
\ No newline at end of file
diff --git a/src/addressspace.c b/src/addressspace.c
new file mode 100644
index 0000000..07c731c
--- /dev/null
+++ b/src/addressspace.c
@@ -0,0 +1,22 @@
+#include "addressspace.h"
+#include "heap.h"
+#include "mmgr.h"
+
+addressspace_t *addressspace_construct()
+{
+    addressspace_t *as = kmalloc(sizeof(addressspace_t));
+    if(as == NULL)
+    {
+        return NULL;
+    }
+
+    as->page_table = create_address_space();
+    if(as->page_table == ENOMEM)
+    {
+        kfree(as);
+        return NULL;
+    }
+
+    as->refcount = 0;
+    return as;
+}
\ No newline at end of file
diff --git a/src/process.c b/src/process.c
new file mode 100644
index 0000000..bcb8bdc
--- /dev/null
+++ b/src/process.c
@@ -0,0 +1,32 @@
+#include "process.h"
+#include "heap.h"
+#include "platform/context.h"
+#include "string.h"
+
+process_t *process_construct(pid_t pid, void *entry, void *stack, int priority, physaddr_t address_space)
+{
+    process_t *new_process = (process_t*) kmalloc(sizeof(process_t));
+    if(new_process == NULL) 
+    {
+        return NULL;
+    }
+
+    struct process_context_t *initial_context = kmalloc(sizeof(struct process_context_t));
+    if(initial_context == NULL)
+    {
+        return 0;
+    }
+
+    context_construct(initial_context);
+    set_context_pc(initial_context, entry);
+    set_context_stack(initial_context, stack);
+    new_process->priority = priority;
+    new_process->pid = pid;
+    new_process->page_table = address_space;
+    new_process->state = PROCESS_ACTIVE;
+    new_process->message_buffer = NULL;
+    new_process->ctx = initial_context;
+    queue_construct(&new_process->sending_queue);
+    queue_construct(&new_process->message_queue);
+    return new_process;
+}
\ No newline at end of file
diff --git a/src/sharedobject.c b/src/sharedobject.c
new file mode 100644
index 0000000..ddcb715
--- /dev/null
+++ b/src/sharedobject.c
@@ -0,0 +1,37 @@
+#include "sharedobject.h"
+#include "avltree.h"
+#include "mmgr.h"
+#include "heap.h"
+
+struct shared_object *create_shared_object(size_t size, unsigned long flags)
+{
+    physaddr_t phys_addr = reserve_pages(size);
+    if(phys_addr == NULL)
+    {
+        return NULL;
+    }
+
+    struct shared_object_t *obj = kmalloc(sizeof(struct shared_object_t));
+    if(obj == NULL)
+    {
+        free_pages(phys_addr);
+        return NULL;
+    }
+
+    obj->phys_addr = phys_addr;
+    obj->size = size;
+    obj->access_flags = flags;
+    obj->refcount = 0;
+    obj->users = NULL;
+    return obj;
+}
+
+void destroy_shared_object(struct shared_object_t *obj)
+{
+    if(obj != NULL)
+    {
+        free_pages(obj->phys_addr);
+        avl_clear(obj->users);
+        kfree(obj);
+    }
+}
\ No newline at end of file