From ebe26896b083c92492fb2255eca03ced8984553b Mon Sep 17 00:00:00 2001
From: Roman Khlopkov <roman.khlopkov@demlabs.net>
Date: Thu, 30 Mar 2023 22:20:54 +0300
Subject: [PATCH] [*] Pipelines fix
---
dap-sdk | 2 +-
modules/net/dap_chain_node_client.c | 3 ++-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/dap-sdk b/dap-sdk
index 15126aeba8..1e3d551340 160000
--- a/dap-sdk
+++ b/dap-sdk
@@ -1 +1 @@
-Subproject commit 15126aeba885a838db3984ceff83f72e213fbbca
+Subproject commit 1e3d551340e2279465762dbfffd226b90b5d6726
diff --git a/modules/net/dap_chain_node_client.c b/modules/net/dap_chain_node_client.c
index ef4db89a63..ccb7c9d18f 100644
--- a/modules/net/dap_chain_node_client.c
+++ b/modules/net/dap_chain_node_client.c
@@ -499,7 +499,8 @@ static void s_ch_chain_callback_notify_packet_out(dap_stream_ch_chain_t* a_ch_ch
log_it(L_DEBUG, "In: State node %s."NODE_ADDR_FP_STR" %s", l_net->pub.name, NODE_ADDR_FP_ARGS(l_node_addr),
a_pkt_type == DAP_STREAM_CH_CHAIN_PKT_TYPE_TIMEOUT ? "is timeout for sync" : "stream closed");
l_node_client->state = NODE_CLIENT_STATE_ERROR;
- dap_timerfd_reset_unsafe(l_node_client->sync_timer);
+ if (l_node_client->sync_timer)
+ dap_timerfd_reset_unsafe(l_node_client->sync_timer);
bool l_have_waiting = dap_chain_net_sync_unlock(l_net, l_node_client);
if (!l_have_waiting) {
if (dap_chain_net_get_target_state(l_net) == NET_STATE_ONLINE)
--
GitLab