dn724/dncurrency
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Generated vote size histogram (#4751)

Browse source
This commit is contained in:
Piotr Wójcik 2024-10-09 23:35:28 +02:00 • committed by GitHub
commit c22851b107
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

2
nano/lib/stats_enums.hpp
View file

@ -540,6 +540,8 @@ enum class sample
active_election_duration, active_election_duration,
bootstrap_tag_duration, bootstrap_tag_duration,
rep_response_time, rep_response_time,
vote_generator_final_hashes,
vote_generator_hashes,
_last // Must be the last enum _last // Must be the last enum
}; };

10
nano/node/vote_generator.cpp
View file

@ -124,15 +124,12 @@ void nano::vote_generator::process_batch (std::deque<queue_entry_t> & batch)
if (is_final) if (is_final)
{ {
transaction_variant_t transaction_variant{ ledger.tx_begin_write (nano::store::writer::voting_final) }; transaction_variant_t transaction_variant{ ledger.tx_begin_write (nano::store::writer::voting_final) };
verify_batch (transaction_variant, batch); verify_batch (transaction_variant, batch);
// Commit write transaction // Commit write transaction
} }
else else
{ {
transaction_variant_t transaction_variant{ ledger.tx_begin_read () }; transaction_variant_t transaction_variant{ ledger.tx_begin_read () };
verify_batch (transaction_variant, batch); verify_batch (transaction_variant, batch);
} }
@ -208,9 +205,10 @@ void nano::vote_generator::broadcast (nano::unique_lock<nano::mutex> & lock_a)
if (!hashes.empty ()) if (!hashes.empty ())
{ {
lock_a.unlock (); lock_a.unlock ();
vote (hashes, roots, [this] (auto const & vote_a) { vote (hashes, roots, [this] (auto const & generated_vote) {
this->broadcast_action (vote_a); stats.inc (nano::stat::type::vote_generator, nano::stat::detail::generator_broadcasts);
this->stats.inc (nano::stat::type::vote_generator, nano::stat::detail::generator_broadcasts); stats.sample (is_final ? nano::stat::sample::vote_generator_final_hashes : nano::stat::sample::vote_generator_hashes, generated_vote->hashes.size (), { 0, nano::network::confirm_ack_hashes_max });
broadcast_action (generated_vote);
}); });
lock_a.lock (); lock_a.lock ();
} }