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

Creating votes doesn't need a write transaction anymore as votes are periodically flushed in the background.

Browse source
This commit is contained in:
clemahieu 2018-04-03 12:22:09 -05:00
commit e0578043a2
1 changed files with 6 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

15
rai/node/node.cpp
View file

@ -1457,7 +1457,7 @@ online_reps (*this)
observers.blocks.add ([this](std::shared_ptr<rai::block> block_a, rai::process_return const & result_a) {
if (this->block_arrival.recent (block_a->hash ()))
{
rai::transaction transaction (store.environment, nullptr, true);
rai::transaction transaction (store.environment, nullptr, false);
active.start (transaction, block_a);
}
});
@ -2899,12 +2899,9 @@ void rai::election::compute_rep_votes (MDB_txn * transaction_a)
void rai::election::broadcast_winner ()
{
{
rai::transaction transaction (node.store.environment, nullptr, true);
compute_rep_votes (transaction);
}
rai::transaction transaction_a (node.store.environment, nullptr, false);
node.network.republish_block (transaction_a, last_winner);
rai::transaction transaction (node.store.environment, nullptr, false);
compute_rep_votes (transaction);
node.network.republish_block (transaction, last_winner);
}
rai::uint128_t rai::election::quorum_threshold (MDB_txn * transaction_a, rai::ledger & ledger_a)
@ -2987,7 +2984,7 @@ bool rai::election::vote (std::shared_ptr<rai::vote> vote_a)
{
assert (!rai::validate_message (vote_a->account, vote_a->hash (), vote_a->signature));
// see republish_vote documentation for an explanation of these rules
rai::transaction transaction (node.store.environment, nullptr, true);
rai::transaction transaction (node.store.environment, nullptr, false);
auto replay (false);
auto supply (node.ledger.supply (transaction));
auto weight (node.ledger.weight (transaction, vote_a->account));
@ -3041,7 +3038,7 @@ bool rai::election::vote (std::shared_ptr<rai::vote> vote_a)
void rai::active_transactions::announce_votes ()
{
std::vector<rai::block_hash> inactive;
rai::transaction transaction (node.store.environment, nullptr, true);
rai::transaction transaction (node.store.environment, nullptr, false);
std::lock_guard<std::mutex> lock (mutex);
{