diff --git a/modules/net/dap_chain_net.c b/modules/net/dap_chain_net.c index ef56ed93cc3fbcf6ba5dd6f425ae030d0525ab9c..467ce31008b6e190b5d5226d3a8fe78415568c51 100644 --- a/modules/net/dap_chain_net.c +++ b/modules/net/dap_chain_net.c @@ -1065,6 +1065,9 @@ void dap_chain_net_delete( dap_chain_net_t * a_net ) */ int dap_chain_net_init() { + dap_stream_ch_chain_init(); + dap_stream_ch_chain_net_init(); + dap_chain_node_client_init(); dap_chain_node_cli_cmd_item_create ("net", s_cli_net, "Network commands", "net list [chains -n <chain net name>]" diff --git a/modules/net/dap_chain_node_client.c b/modules/net/dap_chain_node_client.c index 46a0b193dd0cc599bee5e50561cc85dd53002d20..111f7fd5ab4b7d39508055e081e71e2315b5f446 100644 --- a/modules/net/dap_chain_node_client.c +++ b/modules/net/dap_chain_node_client.c @@ -271,6 +271,7 @@ static void s_stage_connected_callback(dap_client_t *a_client, void *a_arg) for(size_t i = 0; i < l_channels_count; i++) { if(dap_chain_node_client_set_callbacks(a_client, l_client_internal->active_channels[i]) == -1) { log_it(L_WARNING, "No ch_chain channel, can't init notify callback for pkt type CH_CHAIN"); + return; } } } diff --git a/modules/net/srv/dap_chain_net_srv.c b/modules/net/srv/dap_chain_net_srv.c index 3b0ed4b3657700c2e8bdc0ff28a551d4e87304b5..5206e305e18b7e83014b1641840bda9553b6ac05 100644 --- a/modules/net/srv/dap_chain_net_srv.c +++ b/modules/net/srv/dap_chain_net_srv.c @@ -60,6 +60,7 @@ #include "dap_chain_net_srv.h" #include "dap_chain_net_srv_order.h" #include "dap_chain_net_srv_stream_session.h" +#include "dap_stream_ch_chain_net_srv.h" #ifdef DAP_MODULES_DYNAMIC #include "dap_modules_dynamic_cdb.h" #endif @@ -90,9 +91,9 @@ static void s_load_all(void); * @brief dap_chain_net_srv_init * @return */ -int dap_chain_net_srv_init(dap_config_t * a_cfg) -{ - UNUSED(a_cfg); +int dap_chain_net_srv_init() +{ + dap_stream_ch_chain_net_srv_init(); m_uid = NULL; m_uid_count = 0; if( dap_chain_net_srv_order_init() != 0 ) diff --git a/modules/net/srv/include/dap_chain_net_srv.h b/modules/net/srv/include/dap_chain_net_srv.h index cb018bdcfb09528a8347529df2cbb9781bf35ead..2fc2a3bea2b2da1a8ed3f488b22a9845be7a8338 100755 --- a/modules/net/srv/include/dap_chain_net_srv.h +++ b/modules/net/srv/include/dap_chain_net_srv.h @@ -84,7 +84,7 @@ typedef struct dap_chain_net_srv typedef void (*dap_chain_net_srv_callback_new_t)(dap_chain_net_srv_t *, dap_config_t *); -int dap_chain_net_srv_init(dap_config_t * a_cfg); +int dap_chain_net_srv_init(); void dap_chain_net_srv_deinit(void); dap_chain_net_srv_t* dap_chain_net_srv_add(dap_chain_net_srv_uid_t a_uid,dap_chain_net_srv_callback_data_t a_callback_requested, dap_chain_net_srv_callback_data_t a_callback_response_success,