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

Running recalculate_stake process and holding reference to node by weak_ptr inside alarm instead of by shared_ptr to prevent circular references and hangs during shutdown.

Browse source
This commit is contained in:
clemahieu 2018-04-02 12:25:24 -05:00
commit e888a66458
1 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

10
rai/node/node.cpp
View file

@ -1927,6 +1927,7 @@ void rai::node::start ()
bootstrap.start ();
backup_wallet ();
active.announce_votes ();
online_reps.recalculate_stake ();
port_mapping.start ();
add_initial_peers ();
observers.started ();
@ -2496,8 +2497,13 @@ void rai::online_reps::recalculate_stake ()
online_stake_total += node.ledger.weight (transaction, it.representative);
}
auto now (std::chrono::steady_clock::now ());
auto node_l (node.shared ());
node.alarm.add (now + std::chrono::minutes (5), [node_l]() { node_l->online_reps.recalculate_stake (); });
std::weak_ptr<rai::node> node_w (node.shared ());
node.alarm.add (now + std::chrono::minutes (5), [node_w]() {
if (auto node_l = node_w.lock ())
{
node_l->online_reps.recalculate_stake ();
}
});
}
rai::uint128_t rai::online_reps::online_stake ()