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

Avoid long held transactions during backlog population

Browse source
This commit is contained in:
Piotr Wójcik 2024-08-23 10:12:40 +02:00
commit 92df37bc05
1 changed files with 12 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

17
nano/node/backlog_population.cpp
View file

@ -95,19 +95,26 @@ void nano::backlog_population::populate_backlog (nano::unique_lock<nano::mutex>
{
auto transaction = ledger.tx_begin_read ();
auto count = 0u;
auto i = ledger.store.account.begin (transaction, next);
auto it = ledger.store.account.begin (transaction, next);
auto const end = ledger.store.account.end ();
for (; i != end && count < chunk_size; ++i, ++count, ++total)
auto should_refresh = [&transaction] () {
auto cutoff = std::chrono::steady_clock::now () - 100ms; // TODO: Make this configurable
return transaction.timestamp () < cutoff;
};
for (size_t count = 0; it != end && count < chunk_size && !should_refresh (); ++it, ++count, ++total)
{
stats.inc (nano::stat::type::backlog, nano::stat::detail::total);
auto const & account = i->first;
auto const & account_info = i->second;
auto const & account = it->first;
auto const & account_info = it->second;
activate (transaction, account, account_info);
next = account.number () + 1;
}
done = ledger.store.account.begin (transaction, next) == end;
}