From 464ca0e2f3cc569512c3b8331a9d8c6145b7f926 Mon Sep 17 00:00:00 2001
From: "Constantin P." <papizh.konstantin@demlabs.net>
Date: Mon, 9 Sep 2024 16:53:43 +0700
Subject: [PATCH] round manipulations bound to single proc thread
---
dap-sdk | 2 +-
modules/consensus/esbocs/dap_chain_cs_esbocs.c | 6 ++++--
2 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/dap-sdk b/dap-sdk
index 70cffb96e4..9e7565c941 160000
--- a/dap-sdk
+++ b/dap-sdk
@@ -1 +1 @@
-Subproject commit 70cffb96e4be3972625268f3d4f972bb337a87a3
+Subproject commit 9e7565c9417bad979e90b83ccd537aecfe7c07f9
diff --git a/modules/consensus/esbocs/dap_chain_cs_esbocs.c b/modules/consensus/esbocs/dap_chain_cs_esbocs.c
index eaa405cd7f..355c1907c0 100644
--- a/modules/consensus/esbocs/dap_chain_cs_esbocs.c
+++ b/modules/consensus/esbocs/dap_chain_cs_esbocs.c
@@ -2191,7 +2191,8 @@ static bool s_stream_ch_packet_in(dap_stream_ch_t *a_ch, void *a_arg)
l_args->session = l_session;
l_args->message_size = l_message_size;
memcpy(l_args->message, l_message, l_message_size);
- dap_proc_thread_callback_add(NULL, s_process_incoming_message, l_args);
+ dap_proc_thread_t *l_thread = DAP_PROC_THREAD(dap_context_current());
+ dap_proc_thread_callback_add(l_thread, s_process_incoming_message, l_args);
return true;
}
@@ -2752,7 +2753,8 @@ static void s_message_send(dap_chain_esbocs_session_t *a_session, uint8_t a_mess
l_args->session = a_session;
l_args->message_size = l_message_size + l_sign_size;
memcpy(l_args->message, l_message, l_message_size + l_sign_size);
- dap_proc_thread_callback_add(NULL, s_process_incoming_message, l_args);
+ dap_proc_thread_t *l_thread = DAP_PROC_THREAD(dap_context_current());
+ dap_proc_thread_callback_add(l_thread, s_process_incoming_message, l_args);
}
}
DAP_DELETE(l_message);
--
GitLab