From a3120f845c6e2f4cfb7a12810881024a802fc7f4 Mon Sep 17 00:00:00 2001
From: Aditya Naik
Date: Mon, 10 Aug 2020 12:55:36 -0400
Subject: Dataflow state machine work

---
 include/dataflow.h  | 26 ++++++++++++++++++++++++++
 include/handshake.h |  6 +++---
 2 files changed, 29 insertions(+), 3 deletions(-)

(limited to 'include')

diff --git a/include/dataflow.h b/include/dataflow.h
index 2aed40a..665c92d 100644
--- a/include/dataflow.h
+++ b/include/dataflow.h
@@ -1,3 +1,4 @@
+#include "stream.h"
 
 /*
  *
@@ -45,3 +46,28 @@ typedef enum DOC_codes {
     RESERVED       = 0x4,
     DATA           = 0x5
 } DOC_codes_t;
+
+
+
+#define EXPAND_AS_ENUM(a, b) a,
+#define EXPAND_AS_JUMPTABLE(a, b) b,
+#define EXPAND_DF_PROTOTYPES(a, b) int b(p_stream_t, void**);
+
+#define DF_STATE_TABLE(ENTRY)			\
+    ENTRY(DF_IDLE, DF_func_idle)		\
+	ENTRY(DF_RX_DOC, DF_rx_doc)		\
+	ENTRY(DF_RX_DATA, DF_rx_data)		\
+	ENTRY(DF_RX_CMD, DF_rx_cmd)		\
+	ENTRY(DF_TX_DATA, DF_tx_data)		\
+	ENTRY(DF_TX_CMD, DF_tx_cmd)
+
+enum {
+    /* DF_STATE_TABLE(EXPAND_AS_ENUM) */
+    /* NUM_DF_STATES, */
+    DF_STATE_FAIL,
+    DF_STATE_SUCCESS
+};
+
+typedef int (*df_func_t)(p_stream_t, void**);
+
+DF_STATE_TABLE(EXPAND_DF_PROTOTYPES);
diff --git a/include/handshake.h b/include/handshake.h
index a777abb..8ac34ab 100644
--- a/include/handshake.h
+++ b/include/handshake.h
@@ -6,7 +6,7 @@
 
 #define EXPAND_AS_ENUM(a, b) a,
 #define EXPAND_AS_JUMPTABLE(a, b) b,
-#define EXPAND_AS_PROTOTYPES(a, b) hs_status_t b(p_stream_t, void**);
+#define EXPAND_HS_PROTOTYPES(a, b) hs_status_t b(p_stream_t, void**);
 
 typedef hs_status_t (*hs_func_t)(p_stream_t, void**);
 
@@ -18,11 +18,11 @@ typedef hs_status_t (*hs_func_t)(p_stream_t, void**);
 	    
 enum {
     HS_STATE_TABLE(EXPAND_AS_ENUM)
-    NUM_STATES,
+    NUM_HS_STATES,
     HS_STATE_FAIL,
     HS_STATE_SUCCESS,
 };
 
-HS_STATE_TABLE(EXPAND_AS_PROTOTYPES);
+HS_STATE_TABLE(EXPAND_HS_PROTOTYPES);
 
 #endif /* __HANDSHAKE_H */
-- 
cgit v1.2.3