diff --git a/dap-sdk b/dap-sdk index 0c4e700f4976945c8bd2370ca62f4e3f068a20c3..a26a4b0c76a953a7563c664fb2dec74f122c1aa0 160000 --- a/dap-sdk +++ b/dap-sdk @@ -1 +1 @@ -Subproject commit 0c4e700f4976945c8bd2370ca62f4e3f068a20c3 +Subproject commit a26a4b0c76a953a7563c664fb2dec74f122c1aa0 diff --git a/modules/net/dap_chain_node_client.c b/modules/net/dap_chain_node_client.c index ffd7af199ac9f3f24e29980fa8e0abebc140dfe7..2c6de201ba1db22f7d21ab7843a16bb373a3a4a7 100644 --- a/modules/net/dap_chain_node_client.c +++ b/modules/net/dap_chain_node_client.c @@ -156,7 +156,11 @@ static void s_stage_connected_callback(dap_client_t *a_client, void *a_arg) } } } - if(l_node_client->callbacks.connected) + pthread_mutex_lock(&l_node_client->wait_mutex); + l_node_client->state = NODE_CLIENT_STATE_ESTABLISHED; + pthread_cond_signal(&l_node_client->wait_cond); + pthread_mutex_unlock(&l_node_client->wait_mutex); + if (l_node_client->callbacks.connected) l_node_client->callbacks.connected(l_node_client, l_node_client->callbacks_arg); } }