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

Log dropped peers if bulk pull logging is active (#741)

Browse source
This commit is contained in:
cryptocode 2018-03-22 18:29:16 +01:00 • committed by Lee Bousfield
commit 3218883123
1 changed files with 17 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

17
rai/node/bootstrap.cpp
View file

@ -1124,6 +1124,11 @@ void rai::bootstrap_attempt::populate_connections ()
// This is ~1.5kilobits/sec.
if (elapsed_sec > bootstrap_minimum_termination_time_sec && blocks_per_sec < bootstrap_minimum_blocks_per_sec)
{
if (node->config.logging.bulk_pull_logging ())
{
BOOST_LOG (node->log) << boost::str (boost::format ("Stopping slow peer %1% (elapsed sec %2%s > %3%s and %4% blocks per second < %5%)") % client->endpoint.address ().to_string () % elapsed_sec % bootstrap_minimum_termination_time_sec % blocks_per_sec % bootstrap_minimum_blocks_per_sec);
}
client->stop (true);
}
}
@ -1138,9 +1143,21 @@ void rai::bootstrap_attempt::populate_connections ()
{
// 4 -> 1, 8 -> 2, 16 -> 4, arbitrary, but seems to work well.
auto drop = (int)roundf (sqrtf ((float)target - 2.0f));
if (node->config.logging.bulk_pull_logging ())
{
BOOST_LOG (node->log) << boost::str (boost::format ("Dropping %1% bulk pull peers, target connections %2%") % drop % target);
}
for (int i = 0; i < drop; i++)
{
auto client = sorted_connections.top ();
if (node->config.logging.bulk_pull_logging ())
{
BOOST_LOG (node->log) << boost::str (boost::format ("Dropping peer with block rate %1%, block count %2% (%3%) ") % client->block_rate () % client->block_count % client->endpoint.address ().to_string ());
}
client->stop (false);
sorted_connections.pop ();
}