From e36fc955be3cf2f5a05148720868c057df13faa8 Mon Sep 17 00:00:00 2001
From: Dmitriy Gerasimov <dmitry.gerasimov@demlabs.net>
Date: Thu, 19 Aug 2021 16:21:05 +0700
Subject: [PATCH] [*] Add check and fix
---
CMakeLists.txt | 2 +-
modules/net/dap_chain_net.c | 4 +++-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/CMakeLists.txt b/CMakeLists.txt
index e359e42e86..fbecb5ed93 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -2,7 +2,7 @@ project(cellframe-sdk C)
cmake_minimum_required(VERSION 3.0)
set(CMAKE_C_STANDARD 11)
-set(CELLFRAME_SDK_NATIVE_VERSION "2.9-27")
+set(CELLFRAME_SDK_NATIVE_VERSION "2.9-28")
add_definitions ("-DCELLFRAME_SDK_VERSION=\"${CELLFRAME_SDK_NATIVE_VERSION}\"")
set(DAPSDK_MODULES "")
message("Cellframe modules: ${CELLFRAME_MODULES}")
diff --git a/modules/net/dap_chain_net.c b/modules/net/dap_chain_net.c
index 8e9ee6717d..6dfd45a8ef 100644
--- a/modules/net/dap_chain_net.c
+++ b/modules/net/dap_chain_net.c
@@ -392,7 +392,9 @@ static void s_chain_callback_notify(void * a_arg, dap_chain_t *a_chain, dap_chai
pthread_rwlock_rdlock(&PVT(l_net)->rwlock);
for (dap_list_t *l_tmp = PVT(l_net)->links; l_tmp; l_tmp = dap_list_next(l_tmp)) {
dap_chain_node_client_t *l_node_client = (dap_chain_node_client_t *)l_tmp->data;
- dap_stream_ch_chain_pkt_write_mt( dap_client_get_stream_worker( l_node_client->client), l_node_client->ch_chain_uuid, DAP_STREAM_CH_CHAIN_PKT_TYPE_CHAIN,
+ dap_worker_t * l_worker = dap_client_get_stream_worker( l_node_client->client);
+ if(l_worker)
+ dap_stream_ch_chain_pkt_write_mt(l_worker, l_node_client->ch_chain_uuid, DAP_STREAM_CH_CHAIN_PKT_TYPE_CHAIN,
l_net->pub.id.uint64, a_chain->id.uint64, a_id.uint64, a_atom, a_atom_size);
}
pthread_rwlock_unlock(&PVT(l_net)->rwlock);
--
GitLab