diff --git a/nano/node/vote_processor.cpp b/nano/node/vote_processor.cpp index 654c126b94..d62186b0e8 100644 --- a/nano/node/vote_processor.cpp +++ b/nano/node/vote_processor.cpp @@ -238,11 +238,6 @@ bool nano::vote_processor::empty () const return votes.empty (); } -bool nano::vote_processor::half_full () const -{ - return size () >= max_votes / 2; -} - void nano::vote_processor::calculate_weights () { nano::unique_lock lock{ mutex }; diff --git a/nano/node/vote_processor.hpp b/nano/node/vote_processor.hpp index be5e356f19..35e14e61d1 100644 --- a/nano/node/vote_processor.hpp +++ b/nano/node/vote_processor.hpp @@ -52,13 +52,12 @@ class vote_processor final bool vote (std::shared_ptr const &, std::shared_ptr const &); /** Note: node.active.mutex lock is required */ nano::vote_code vote_blocking (std::shared_ptr const &, std::shared_ptr const &, bool = false); - void verify_votes (std::deque, std::shared_ptr>> const &); + /** Function blocks until either the current queue size (a established flush boundary as it'll continue to increase) * is processed or the queue is empty (end condition or cutoff's guard, as it is positioned ahead) */ void flush (); std::size_t size () const; bool empty () const; - bool half_full () const; void calculate_weights (); std::atomic total_processed{ 0 }; @@ -76,6 +75,7 @@ class vote_processor final private: void run (); + void verify_votes (std::deque, std::shared_ptr>> const &); private: // Higher number means higher priority