[*] Callbakcs for stream channel

dap_stream_ch_chain_net_srv.c

@@ -23,19 +23,83 @@
 */
 
 #include "dap_common.h"
-
+#include "dap_stream.h"
+#include "dap_stream_ch.h"
 #include "dap_stream_ch_chain_net_srv.h"
+#include "dap_stream_ch_proc.h"
+
+#define LOG_TAG "dap_stream_ch_chain_net_srv"
+
+typedef struct dap_stream_ch_chain_net_srv {
+    pthread_mutex_t mutex;
+} dap_stream_ch_chain_net_srv_t;
 
-#define LOG_TAG "stream_ch_chain_net_srv"
+#define DAP_STREAM_CH_CHAIN_NET_SRV(a) ((dap_stream_ch_chain_net_srv_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
+ * @return
+ */
 int dap_stream_ch_chain_net_srv_init()
 {
     log_it(L_NOTICE,"Chain network services channel initialized");
+    dap_stream_ch_proc_add('S',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_srv_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_srv_t);
+    dap_stream_ch_chain_net_srv_t * l_ch_chain_net_srv = DAP_STREAM_CH_CHAIN_NET_SRV(a_ch);
+    pthread_mutex_init( &l_ch_chain_net_srv->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)
+{
+
+}