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

Consolidate received_frontier transactions

Browse source
This commit is contained in:
SergiySW 2018-07-28 00:40:36 +03:00 • committed by clemahieu
commit ada4338acd
1 changed files with 5 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

14
rai/node/bootstrap.cpp
View file

@ -273,12 +273,12 @@ void rai::frontier_req_client::received_frontier (boost::system::error_code cons
{
BOOST_LOG (connection->node->log) << boost::str (boost::format ("Received %1% frontiers from %2%") % std::to_string (count) % connection->socket->remote_endpoint ());
}
rai::transaction transaction (connection->node->store.environment, nullptr, false);
if (!account.is_zero ())
{
while (!current.is_zero () && current < account)
{
// We know about an account they don't.
rai::transaction transaction (connection->node->store.environment, nullptr, false);
unsynced (info.head, 0);
next (transaction);
}
@ -286,7 +286,6 @@ void rai::frontier_req_client::received_frontier (boost::system::error_code cons
{
if (account == current)
{
rai::transaction transaction (connection->node->store.environment, nullptr, false);
if (latest == info.head)
{
// In sync
@ -322,14 +321,11 @@ void rai::frontier_req_client::received_frontier (boost::system::error_code cons
}
else
{
while (!current.is_zero ())
{
rai::transaction transaction (connection->node->store.environment, nullptr, false);
while (!current.is_zero ())
{
// We know about an account they don't.
unsynced (info.head, 0);
next (transaction);
}
// We know about an account they don't.
unsynced (info.head, 0);
next (transaction);
}
if (connection->node->config.logging.bulk_pull_logging ())
{