diff --git a/dap-sdk b/dap-sdk index 70cffb96e4be3972625268f3d4f972bb337a87a3..9e7565c9417bad979e90b83ccd537aecfe7c07f9 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 eaa405cd7fff060fb691a9ac78e475bdc861a140..9d4eeca4ee44ad4c2228e1d0a5727f2b9f86bd86 100644 --- a/modules/consensus/esbocs/dap_chain_cs_esbocs.c +++ b/modules/consensus/esbocs/dap_chain_cs_esbocs.c @@ -2191,7 +2191,7 @@ 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_callback_add(dap_worker_get_current()->proc_queue_input, s_process_incoming_message, l_args); return true; } @@ -2752,7 +2752,7 @@ 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_callback_add(dap_worker_get_current()->proc_queue_input, s_process_incoming_message, l_args); } } DAP_DELETE(l_message); diff --git a/modules/service/voting/dap_chain_net_srv_voting.c b/modules/service/voting/dap_chain_net_srv_voting.c index 7583bc2f1bd431cdeb18f5731eba9e8d42dd6b71..f6ac389d96f0bbacc1b00ceea7df9f3e50ae4729 100644 --- a/modules/service/voting/dap_chain_net_srv_voting.c +++ b/modules/service/voting/dap_chain_net_srv_voting.c @@ -440,10 +440,10 @@ static int s_vote_verificator(dap_ledger_t *a_ledger, dap_chain_tx_item_type_t a dap_list_free(l_tsd_list); // change vote & move it to the end of list l_voting->votes = dap_list_remove_link(l_voting->votes, it); - DAP_DELETE(it->data); l_voting->votes = dap_list_append(l_voting->votes, l_vote_item); char l_vote_hash_str[DAP_HASH_FAST_STR_SIZE]; dap_hash_fast_to_str(&((dap_chain_net_vote_t *)it->data)->vote_hash, l_vote_hash_str, DAP_HASH_FAST_STR_SIZE); + DAP_DELETE(it->data); log_it(L_INFO, "Vote %s of voting %s has been changed", l_vote_hash_str, dap_hash_fast_to_str_static(&l_voting->voting_hash)); return DAP_LEDGER_CHECK_OK; }