[*] Callbakcs for stream channel

dap_stream_ch_chain_net.c

@@ -26,12 +26,24 @@
 #include <errno.h>
 #include <string.h>
 #include "dap_common.h"
-
+#include "dap_stream.h"
+#include "dap_stream_ch.h"
 #include "dap_stream_ch_chain_net.h"
+#include "dap_stream_ch_proc.h"
+
 
-#define LOG_TAG "stream_ch_chain_net"
+#define LOG_TAG "dap_stream_ch_chain_net"
 
+typedef struct dap_stream_ch_chain_net {
+    pthread_mutex_t mutex;
+} dap_stream_ch_chain_net_t;
 
+#define DAP_STREAM_CH_CHAIN_NET(a) ((dap_stream_ch_chain_net_t *) ((a)->internal) )
+
+static void s_stream_ch_new(dap_stream_ch_t* ch , void* arg);
+static void s_stream_ch_delete(dap_stream_ch_t* ch , void* arg);
+static void s_stream_ch_packet_in(dap_stream_ch_t* ch , void* arg);
+static void s_stream_ch_packet_out(dap_stream_ch_t* ch , void* arg);
 
 /**
  * @brief dap_stream_ch_chain_net_init
@@ -40,9 +52,58 @@
 int dap_stream_ch_chain_net_init()
 {
     log_it(L_NOTICE,"Chain network channel initialized");
+    dap_stream_ch_proc_add('N',s_stream_ch_new,s_stream_ch_delete,s_stream_ch_packet_in,s_stream_ch_packet_out);
+
     return 0;
 }
 
+/**
+ * @brief dap_stream_ch_chain_deinit
+ */
 void dap_stream_ch_chain_net_deinit()
 {
+
+}
+
+/**
+ * @brief s_stream_ch_new
+ * @param a_ch
+ * @param arg
+ */
+void s_stream_ch_new(dap_stream_ch_t* a_ch , void* arg)
+{
+    a_ch->internal=DAP_NEW_Z(dap_stream_ch_chain_net_t);
+    dap_stream_ch_chain_net_t * l_ch_chain_net = DAP_STREAM_CH_CHAIN_NET(a_ch);
+    pthread_mutex_init( &l_ch_chain_net->mutex,NULL);
+}
+
+
+/**
+ * @brief s_stream_ch_delete
+ * @param ch
+ * @param arg
+ */
+void s_stream_ch_delete(dap_stream_ch_t* ch , void* arg)
+{
+
+}
+
+/**
+ * @brief s_stream_ch_packet_in
+ * @param ch
+ * @param arg
+ */
+void s_stream_ch_packet_in(dap_stream_ch_t* ch , void* arg)
+{
+
+}
+
+/**
+ * @brief s_stream_ch_packet_out
+ * @param ch
+ * @param arg
+ */
+void s_stream_ch_packet_out(dap_stream_ch_t* ch , void* arg)
+{
+
 }