added IPC syscalls

kernel/syscall/skeleton.cc

@@ -4,6 +4,7 @@
 #include "../debug/output.h"
 #include "../device/textstream.h"
 #include "../interrupt/guard.h"
+#include "../memory/page.h"
 #include "../sync/semaphore.h"
 #include "../thread/scheduler.h"
 #include "../memory/pageframealloc.h"
@@ -283,5 +284,107 @@ namespace Syscall {
       }
       return 0; 
     }
+
+
+bool copy_from_phys(Vault& vault, uintptr_t phys_ptr, void* virt_ptr, size_t size) {
+	Thread* current_thread = vault.scheduler.active();
+	
+	size_t offset = Page::offset(phys_ptr); 
+	size_t total_size = size + offset;
+  four_lvl_paging_t* search_table = vault.scheduler.active()->paging_tree;
+
+	void* page_ptr = getFreeVirtSpace(search_table, total_size); // page aligned pointer 
+	if (page_ptr == nullptr) {
+		return false;
+	}
+	
+	uintptr_t virt_addr = (uintptr_t)(page_ptr) + offset;
+  for(uint8_t i =0; i<size/4096; i++){
+    setMapping(virt_addr, (void*)phys_ptr, vault.scheduler.active()->paging_tree);
+  }
+
+	memcpy(virt_ptr, (void*)(virt_addr), size);
+	PageFrameAllocator::free((uintptr_t)(page_ptr));
+	
+	return true;
+}
+
+
+
+bool send(Vault& v, int pid, const void* sbuffer, size_t ssize, void* rbuffer, size_t rsize) {
+	Thread* current_thread = v.scheduler.active();
+	Thread* target_thread = v.thread_list[pid];
+
+	uintptr_t sbuffer_ptr = (uintptr_t) target_thread->paging_tree;
+
+    // Erstelle Nachichtenobjekt
+	IpcStruct msg = {sbuffer_ptr, ssize, current_thread->id, false, nullptr};
+	
+	target_thread->ipc_queue.enqueue(msg);
+	target_thread->ipc_sem.v(v);
+
+	while (true) {
+		current_thread->ipc_sem.p(v);
+		if (msg.is_answer) {
+			break;
+		}
+		DBG_VERBOSE << "" << endl;
+	}
+
+	// Kopiere Antwort
+	if (!copy_from_phys(v, msg.ptr, rbuffer, rsize)) {
+		return false;
+	}
+
+	return true;
+}
+
+int receive(Vault& v, void* buffer, size_t size) {
+
+	// DBG_VERBOSE << "Receive syscall for thread " << dec << v.scheduler.active()->id << endl;
+	Thread* thread = v.scheduler.active();
+
+	// Warte auf Nachricht
+	if (thread->ipc_queue.is_empty()) {
+		thread->ipc_sem.p(v);
+	}
+	
+	IpcStruct* ipc = thread->ipc_queue.first();
+	if (ipc == nullptr) return -1;
+	
+	// Buffer holen
+	if (!copy_from_phys(v, ipc->ptr, buffer, size)) {
+		return -3;
+	}
+	
+	return ipc->pid;
+}
+
+bool reply(Vault& v, const void* buffer, size_t size) {
+
+  Thread* current_thread = v.scheduler.active();
+  IpcStruct* ipc = current_thread->ipc_queue.dequeue();
+
+  // if (!ipc || ipc->pid < 0 || static_cast<size_t>(ipc->pid) >= v.thread_count) return false;
+
+  Thread* other_thread = v.thread_list[ipc->pid];
+  if (other_thread == nullptr) return false;
+
+  uintptr_t phys_ptr =  (uintptr_t) current_thread->paging_tree;
+
+  ipc->ptr = phys_ptr;
+  ipc->size = size;
+  ipc->pid = current_thread->id;
+  ipc->is_answer = true;
+
+  // Sender aufwecken
+  other_thread->ipc_sem.v(v);
+
+  return true;
+}
+
+
+
+
   }  // namespace Skeleton
 }  // namespace Syscall