From 42a683033594289ddc520dffec652967e366e785 Mon Sep 17 00:00:00 2001
From: Aditya Naik
Date: Wed, 22 Apr 2020 16:30:15 -0400
Subject: Added dataflow protocol files

---
 src/main-data.c | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)

(limited to 'src/main-data.c')

diff --git a/src/main-data.c b/src/main-data.c
index f228235..4314e9e 100644
--- a/src/main-data.c
+++ b/src/main-data.c
@@ -16,12 +16,13 @@
 /* Library includes */
 #include <pb_encode.h>
 #include <pb_decode.h>
-#include "handshake.pb.h"
 
 /* Project includes */
+#include "main.h"
 #include "devices.h"
 #include "config.h"
-#include "main.h"
+#include "dataflow.h"
+#include "handshake.pb.h"
 
 /* Private Macros */
 #define device_MDR s2m_MDR_response
@@ -53,6 +54,7 @@ static void MX_USART1_UART_Init(void);
 
 bool decode_subscriptions_callback(pb_istream_t *istream, const pb_field_t *field, void **args);
 hs_status_t handshake(uint32_t i2c_addr);
+dataflow_status_t device_dataflow(uint8_t i2c_addr);
 bool todo_hs_or_not_todo_hs(uint8_t i2c_addr);
 state_t get_state_from_hs_status(uint16_t device_addr, hs_status_t hs_status);
 bool encode_subscription_callback(pb_ostream_t *ostream, const pb_field_t *field, void * const *arg);
@@ -116,7 +118,6 @@ int main(void)
     device_info[dev_idx]->MDR = module_MDR;
     
     /* dataflow */
-
     
 #else /* Slave code*/
     {
@@ -429,6 +430,13 @@ __DEBUG_BLOCK_END:
     return hs_sts;
 }
 
+dataflow_status_t device_dataflow(uint8_t i2c_addr)
+{
+    uint8_t dev_idx = GET_IDX_FROM_ADDR(i2c_addr);
+    dataflow_status_t status;
+    
+}
+
 bool decode_subscriptions_callback(pb_istream_t *istream, const pb_field_t *field, void **args)
 {
     _subscriptions subs;
-- 
cgit v1.2.3