Skip to content
Snippets Groups Projects
Commit 3cc7e03a authored by Roman Khlopkov's avatar Roman Khlopkov 🔜
Browse files

[*] ESBOCS consensus part bugfixes

parent 19e0266d
No related branches found
No related tags found
No related merge requests found
Pipeline #28021 passed with stage
in 9 minutes and 29 seconds
...@@ -1725,11 +1725,10 @@ static void s_session_packet_in(void *a_arg, dap_chain_node_addr_t *a_sender_nod ...@@ -1725,11 +1725,10 @@ static void s_session_packet_in(void *a_arg, dap_chain_node_addr_t *a_sender_nod
s_session_sync_queue_add(l_session, l_message, a_data_size); s_session_sync_queue_add(l_session, l_message, a_data_size);
goto session_unlock; goto session_unlock;
} }
} else if (l_message->hdr.round_id != l_session->cur_round.id || } else if (l_message->hdr.round_id != l_session->cur_round.id) {
l_message->hdr.attempt_num < l_session->cur_round.attempt_num) {
// round check // round check
debug_if(l_cs_debug, L_MSG, "net:%s, chain:%s, round:%"DAP_UINT64_FORMAT_U", attempt:%hhu." debug_if(l_cs_debug, L_MSG, "net:%s, chain:%s, round:%"DAP_UINT64_FORMAT_U", attempt:%hhu."
" Message rejected: round or attempt in message does not match", " Message rejected: round number doesn't match",
l_session->chain->net_name, l_session->chain->name, l_session->chain->net_name, l_session->chain->name,
l_session->cur_round.id, l_session->cur_round.attempt_num); l_session->cur_round.id, l_session->cur_round.attempt_num);
goto session_unlock; goto session_unlock;
...@@ -1745,6 +1744,7 @@ static void s_session_packet_in(void *a_arg, dap_chain_node_addr_t *a_sender_nod ...@@ -1745,6 +1744,7 @@ static void s_session_packet_in(void *a_arg, dap_chain_node_addr_t *a_sender_nod
l_session->cur_round.id, l_message->hdr.attempt_num); l_session->cur_round.id, l_message->hdr.attempt_num);
goto session_unlock; goto session_unlock;
} }
dap_chain_addr_fill_from_sign(&l_signing_addr, l_sign, l_session->chain->net_id);
// check messages chain // check messages chain
dap_chain_esbocs_message_item_t *l_chain_message, *l_chain_message_tmp; dap_chain_esbocs_message_item_t *l_chain_message, *l_chain_message_tmp;
HASH_ITER(hh, l_round->message_items, l_chain_message, l_chain_message_tmp) { HASH_ITER(hh, l_round->message_items, l_chain_message, l_chain_message_tmp) {
...@@ -1770,7 +1770,6 @@ static void s_session_packet_in(void *a_arg, dap_chain_node_addr_t *a_sender_nod ...@@ -1770,7 +1770,6 @@ static void s_session_packet_in(void *a_arg, dap_chain_node_addr_t *a_sender_nod
} }
} }
} }
dap_chain_addr_fill_from_sign(&l_signing_addr, l_sign, l_session->chain->net_id);
s_message_chain_add(l_session, l_message, a_data_size, a_data_hash, &l_signing_addr); s_message_chain_add(l_session, l_message, a_data_size, a_data_hash, &l_signing_addr);
} else } else
dap_chain_addr_fill_from_sign(&l_signing_addr, l_sign, l_session->chain->net_id); dap_chain_addr_fill_from_sign(&l_signing_addr, l_sign, l_session->chain->net_id);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment