Testing hs

2 files changed, 6 insertions, 5 deletions

diff --git a/src/dataflow.c b/src/dataflow.c
index 6944085..e85124a 100644
--- a/src/dataflow.c
+++ b/src/dataflow.c
@@ -18,8 +18,7 @@
  * |     7 | cmd_routing_ptr   |
  * |     8 | cmd_src_idx_rbuf  |
  * |     9 | cmd_dst_idx_rbuf  |
- *
- *
+ * |-------+-------------------|
  *
  */
 
@@ -156,7 +155,7 @@ int DF_func_rx_cmd(p_stream_t stream, void **args)
 
 int DF_func_tx_data(p_stream_t stream, void **args)
 {
-    
+    /* TODO Do this after MDR is cached after handshake, let's not encode it again here */
 }
 
 int DF_func_tx_cmd(p_stream_t stream, void **args)
diff --git a/src/master_posix.c b/src/master_posix.c
index ec60065..0d6bf82 100644
--- a/src/master_posix.c
+++ b/src/master_posix.c
@@ -111,9 +111,10 @@ void vStartPOSIXMaster(void *pvParams)
 {
     pthread_t handshake_thread, dataflow_thread, routing_thread;
     p_stream_t device_streams[2];
+
+    /* Stream initializations should be handled by the devicetree library once that's set up */
     STREAM_INIT(STDIO, NULL, device_streams[0]);
     STREAM_INIT(STDIO, NULL, device_streams[1]);
-
     /* This is the global stream that is being used by handhsake and dataflow */
     STREAM_INIT(STDIO, NULL, stream);
     
@@ -141,7 +142,8 @@ static void *handshake_func(void * pvArgs)
     printf("Handshake thread started %s", LINE_BREAK);
     for (;;) {
 	for (int dev_idx = 0; dev_idx < BUS_DEVICE_LIMIT-1; dev_idx++) {
-	    /* With the new state machine structure, what is the correct condition 
+	    /* 
+	     * With the new state machine structure, what is the correct condition 
 	     * for performing a handshake?
 	     *
 	     * Answer: Handshake attempts will occur based on user-configured processor devices.