feat(cpu): handle pcb from module CPU

tomasanchez · Apr 23, 2022 · 60cf776 · 60cf776
1 parent 9e28760
commit 60cf776
Show file tree

Hide file tree

Showing 2 changed files with 63 additions and 0 deletions.
diff --git a/cpu/include/server/pcb_controller.h b/cpu/include/server/pcb_controller.h
@@ -0,0 +1,27 @@
+/**
+ * @file pcb_controller.h
+ * @author Tomás Sánchez <tosanchez@frba.utn.edu.ar>
+ * @brief
+ * @version 0.1
+ * @date 04-23-2022
+ *
+ * @copyright Copyright (c) 2022
+ *
+ */
+
+#pragma once
+
+#include "pcb.h"
+#include "server.h"
+
+// ============================================================================================================
+//                                   ***** Public Functions  *****
+// ============================================================================================================
+
+/**
+ * @brief Receivesa a PCB stream.
+ *
+ * @param fd the file descriptor
+ * @return a new PCB instance
+ */
+pcb_t *receive_pcb(int fd);
diff --git a/cpu/src/server/pcb_controller.c b/cpu/src/server/pcb_controller.c
@@ -0,0 +1,36 @@
+/**
+ * @file pcb_controller.c
+ * @author Tomás Sánchez <tosanchez@frba.utn.edu.ar>
+ * @brief
+ * @version 0.1
+ * @date 04-23-2022
+ *
+ * @copyright Copyright (c) 2022
+ *
+ */
+#include <stdlib.h>
+#include "pcb_controller.h"
+#include "log.h"
+
+// ============================================================================================================
+//                                   ***** Definitions  *****
+// ============================================================================================================
+
+#define LOG_PCB(pcb)                                                                                                             \
+	{                                                                                                                            \
+		LOG_INFO("PCB= [id: %d, size: %lu, estimation: %d, program_counter: %d]", pcb->id, pcb->size, pcb->estimation, pcb->pc); \
+	}
+
+// ============================================================================================================
+//                                   ***** Public Functions  *****
+// ============================================================================================================
+
+pcb_t *receive_pcb(int fd)
+{
+	ssize_t recv_bytes = -1;
+
+	pcb_t *pcb = NULL;
+	pcb = pcb_from_stream(servidor_recibir_stream(fd, &recv_bytes));
+	LOG_PCB(pcb);
+	return pcb;
+}