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

Moving pulling counting to a more reliable location.

Browse source
This commit is contained in:
clemahieu 2017-08-08 20:31:20 -05:00
commit 92857507e6
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
rai/node/bootstrap.cpp
View file

@ -440,10 +440,12 @@ void rai::frontier_req_client::next (MDB_txn * transaction_a)
rai::bulk_pull_client::bulk_pull_client (std::shared_ptr <rai::bootstrap_client> connection_a) :
connection (connection_a)
{
++connection->attempt->pulling;
}
rai::bulk_pull_client::~bulk_pull_client ()
{
--connection->attempt->pulling;
}
void rai::bulk_pull_client::request (rai::pull_info const & pull_a)
@ -551,7 +553,6 @@ void rai::bulk_pull_client::received_type ()
if (expected == pull.end)
{
pull = rai::pull_info ();
--connection->attempt->pulling;
connection->work ();
}
else
@ -892,9 +893,8 @@ void rai::bootstrap_client::work ()
// There are more things to pull
auto pull (attempt->pulls.front ());
attempt->pulls.pop_front ();
++attempt->pulling;
lock.unlock ();
auto pull_client (std::make_shared <rai::bulk_pull_client> (shared_from_this ()));
lock.unlock ();
pull_client->request (pull);
}
else