Merge pull request #7 from SidoShiro/dev

Dev into Master

Author: SidoShiro

CMakeLists.txt

@@ -8,7 +8,8 @@ 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)
+set(SRCS src/main/main.c src/utils/utils.c src/cli/cli.c src/network/message.c src/network/block.c src/network/node.c src/utils/command_queue.c src/graph/graph.c)
+
 include_directories("include/")
 include_directories(SYSTEM ${MPI_INCLUDE_PATH})
 

README.md

@@ -11,24 +11,18 @@ mkdir build
 cd build
 cmake ..
 make
-./dmalloc [DOTFILE]
+mpirun --hostfile ../hostfile dmalloc [DOTFILE]
 ```
 
 In project directory:
 
 ```sh
 cmake .
 make
-./dmalloc [DOTFILE]
+mpirun --hostfile hostfile dmalloc [DOTFILE]
 ```
 
 
-dmalloc usage :
-
-```sh
-./dmalloc [DOTFILE]
-```
-
 # Tooltips
 
 * How to display a graph
@@ -88,4 +82,17 @@ dmalloc usage :
 | kill `id`                         | kill node refered by `id`                               |
 | revive `id`                       | revive `id`                                             |
 
+## Node Life Cycles
+
+### Node Leader Elections
+
+![Graph leader election](doc/node_election.png)
+
+### Node Leader Cycle
+
+![Graph leader cycle](doc/node_leader_proc.png)
+
+### Node Cycle
+
+![Graph leader election](doc/node_proc.png)
 

doc/node_election.png

@@ -0,0 +1,15 @@
+digraph Leader {
+  is_now_leader -> Send_LEADER_to_USER -> Idle;
+  Idle -> Idle;
+  Idle -> USER_WRITE;
+  Idle -> USER_READ;
+  Idle -> USER_SNAP;
+  Idle -> USER_MALLOC;
+  Idle -> USER_FREE;
+  Idle -> USER_DUMP;
+  USER_DUMP -> USER_READ;
+  Idle -> USER_KILL;
+  Idle -> USER_REVIVE;
+  USER_WRITE -> Send_WRITE -> Recv_OK_write -> Send_WRITE_DATA;
+  USER_READ -> Send_READ -> Recv_OK_read -> Recv_READ_DATA;
+}

doc/node_leader.dot

@@ -0,0 +1,51 @@
+digraph NodeProcess {
+  Idle -> Idle;
+  Idle -> Recv_WRITE;
+  Recv_WRITE -> id_op_is_id_op_write;
+  id_op_is_id_op_write -> Send_OK_write;
+  Send_OK_write -> Recv_WRITE_DATA;
+  Recv_WRITE_DATA -> id_op_is_id_op_write;
+  id_op_is_id_op_write -> Idle;
+  Recv_WRITE -> id_op_is_not_id_op_write;
+  id_op_is_not_id_op_write -> Send_WRITE;
+  Send_WRITE -> Recv_OK_write;
+  Recv_OK_write -> Send_OK_write;
+  Recv_WRITE_DATA -> id_op_is_not_id_op_write;
+  id_op_is_not_id_op_write -> Send_WRITE_DATA;
+  Send_WRITE_DATA -> Idle;
+  Idle -> Recv_READ;
+  Recv_READ -> id_op_is_id_op_read;
+  id_op_is_id_op_read -> Send_OK_read;
+  Send_OK_read -> Send_READ_DATA;
+  Send_READ_DATA -> Idle;
+  Recv_READ -> id_op_is_not_id_op_read;
+  id_op_is_not_id_op_read -> Send_READ;
+  Send_READ -> Recv_OK_read;
+  Recv_OK_read -> Recv_READ_DATA;
+  Recv_READ_DATA -> Send_OK_read;
+  Idle -> Recv_DIE;
+  Recv_DIE -> id_op_is_id_op_die;
+  id_op_is_id_op_die -> DIE;
+  Recv_DIE -> id_op_is_not_id_op_die;
+  id_op_is_not_id_op_die -> Send_DIE;
+  Send_DIE -> Idle;
+  Idle -> Recv_REVIVE;
+  Recv_REVIVE -> id_op_is_id_op_revive;
+  id_op_is_id_op_revive -> Send_WARNING;
+  Send_WARNING -> Idle;
+  Recv_REVIVE -> id_op_is_not_id_op_revive;
+  id_op_is_not_id_op_revive -> Send_REVIVE;
+  Send_REVIVE -> Idle;
+  DIE -> Recv_REVIVE_on_dead;
+  Recv_REVIVE_on_dead -> Idle;
+  Idle -> Recv_SNAP;
+  Recv_SNAP -> id_op_is_id_op_snap;
+  id_op_is_id_op_snap -> Send_OK_snap;
+  Recv_SNAP -> id_op_is_not_id_op_snap;
+  id_op_is_not_id_op_snap -> Send_SNAP;
+  Send_SNAP -> Recv_OK_snap;
+  Recv_OK_snap -> Recv_SNAP_DATA;
+  Recv_SNAP_DATA -> Send_OK_snap;
+  Send_OK_snap -> Send_SNAP_DATA;
+  Send_SNAP_DATA -> Idle;
+}

doc/node_leader_proc.png

@@ -0,0 +1,4 @@
+digraph NodeStart {
+  NodeInit -> Send_LEADER;
+  Send_LEADER -> Recv_LEADER;
+}

doc/node_proc.png

@@ -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;
+}

doc/node_process.dot

@@ -0,0 +1 @@
+localhost slots=25