Dataflow state machine work

1 files changed, 26 insertions, 0 deletions

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);