Merge pull request #4 from SidoShiro/command-queue

Command queue

Author: itectori

CMakeLists.txt

@@ -8,7 +8,7 @@ project(DistributedMalloc)
 find_package(MPI REQUIRED)
 
 # Vars with files for compilation
-set(SRCS src/main/main.c src/utils/utils.c src/cli/cli.c src/network/message.c src/network/block.c include/block.h)
+set(SRCS src/main/main.c src/utils/utils.c src/cli/cli.c src/network/message.c src/network/block.c include/block.h src/utils/command_queue.c)
 include_directories("include/")
 include_directories(SYSTEM ${MPI_INCLUDE_PATH})
 

doc/user_commands.dot

@@ -0,0 +1,11 @@
+digraph User_Command_Queue {
+
+  Command_1 [shape=box]
+  Command_2 [shape=box]
+  Command_3 [shape=box]
+  Leader    [shape=diamond]
+
+  Command_1 -> Command_2 -> Command_3;
+  User -> Command_1;
+  Command_3 -> Leader;
+}

include/command_queue.h

@@ -0,0 +1,60 @@
+#ifndef DISTRIBUTEDMALLOC_COMMAND_QUEUE_H
+#define DISTRIBUTEDMALLOC_COMMAND_QUEUE_H
+
+#include <stdlib.h>
+
+enum user_command {
+    MALLOC, // Data => Size
+    FREE, // Data => Address
+    WRITE, // Data => Address; Data size; Data
+    READ, // Data => Address; Data size
+    DUMP, // Data => Address
+    SNAP,
+    DNET,
+    KILL, // Data => id
+    REVIVE, // Data => id
+    NONE
+};
+
+struct command_queue {
+    enum user_command command;
+    struct command_queue *next;
+    void *data; // Contain the structure depending of the command
+};
+
+// Delete first command queue, return head
+struct command_queue *pop_command(struct command_queue *head);
+
+// Push command in queue, return head, can have head=NULL for init queue
+struct command_queue *push_command(struct command_queue *head, struct command_queue *new_elt);
+
+// Get command queue data, you should known how to cast it
+void *peek_command(struct command_queue *head);
+
+// Get user command enum of the first of the queue
+enum user_command peek_user_command(struct command_queue *head);
+
+struct data_write {
+    size_t address;
+    size_t size;
+    void *data;
+};
+
+struct data_read {
+    size_t address;
+    size_t size;
+};
+
+struct data_id {
+    unsigned short id;
+};
+
+struct data_address {
+    size_t address;
+};
+
+struct data_size {
+    size_t size;
+};
+
+#endif /* !DISTRIBUTEDMALLOC_COMMAND_QUEUE_H */

src/utils/command_queue.c

@@ -0,0 +1,47 @@
+#include "command_queue.h"
+
+// Delete first command queue, return head
+struct command_queue *pop_command(struct command_queue *head) {
+    struct command_queue *new_head = NULL;
+    if (!head)
+        return NULL;
+    else if (!head->next) {
+        if (head->data)
+            free(head->data);
+        free(head);
+        return NULL;
+    } else {
+        new_head = head->next;
+        if (head->data)
+            free(head->data);
+        free(head);
+        return new_head;
+    }
+}
+
+// Push command in queue, return head, can have head=NULL for init queue
+struct command_queue *push_command(struct command_queue *head, struct command_queue *new_elt) {
+    if (!head) {
+        return new_elt;
+    }
+    struct command_queue *iter = head;
+    while (iter->next) {
+        iter = iter->next;
+    }
+    iter->next = new_elt;
+    return head;
+}
+
+// Get command queue data, you should known how to cast it
+void *peek_command(struct command_queue *head) {
+    if (head)
+        return head->data;
+    return NULL;
+}
+
+// Get user command enum of the first of the queue
+enum user_command peek_user_command(struct command_queue *head) {
+    if (head)
+        return head->command;
+    return NONE;
+}