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

Add vote_processor overflow mode (#1365)

Browse source
This commit is contained in:
SergiySW 2018-11-19 20:16:10 +03:00 • committed by Roy Keene
commit f3c9ea72e6
1 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

11
rai/node/node.cpp
View file

@ -888,8 +888,15 @@ void rai::vote_processor::vote (std::shared_ptr<rai::vote> vote_a, rai::endpoint
std::lock_guard<std::mutex> lock (mutex);
if (!stopped)
{
votes.push_back (std::make_pair (vote_a, endpoint_a));
condition.notify_all ();
if (votes.size () < 256 * 1024)
{
votes.push_back (std::make_pair (vote_a, endpoint_a));
condition.notify_all ();
}
else if (node.config.logging.vote_logging ())
{
BOOST_LOG (node.log) << "Votes overflow";
}
}
}