Skip to content
Snippets Groups Projects

Compare revisions

Changes are shown as if the source revision was being merged into the target revision. Learn more about comparing revisions.

Source

Select target project
No results found

Target

Select target project
  • cellframe/cellframe-sdk
  • MIKA83/cellframe-sdk
2 results
Show changes
Commits on Source (6)
Subproject commit 70cffb96e4be3972625268f3d4f972bb337a87a3
Subproject commit 9e7565c9417bad979e90b83ccd537aecfe7c07f9
......@@ -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);
......
......@@ -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;
}
......