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

Backlog scan scanned event

Browse source
This commit is contained in:
Piotr Wójcik 2024-10-13 16:56:29 +02:00
commit 7ae7c8a420
3 changed files with 7 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

1
nano/lib/stats_enums.hpp
View file

@ -419,6 +419,7 @@ enum class detail
activate_failed, activate_failed,
activate_skip, activate_skip,
activate_full, activate_full,
scanned,
// active // active
insert, insert,

7
nano/node/backlog_scan.cpp
View file

@ -128,12 +128,15 @@ void nano::backlog_scan::activate (secure::transaction const & transaction, nano
auto const maybe_conf_info = ledger.store.confirmation_height.get (transaction, account); auto const maybe_conf_info = ledger.store.confirmation_height.get (transaction, account);
auto const conf_info = maybe_conf_info.value_or (nano::confirmation_height_info{}); auto const conf_info = maybe_conf_info.value_or (nano::confirmation_height_info{});
activated_info info{ account, account_info, conf_info };
stats.inc (nano::stat::type::backlog_scan, nano::stat::detail::scanned);
scanned.notify (transaction, info);
// If conf info is empty then it means then it means nothing is confirmed yet // If conf info is empty then it means then it means nothing is confirmed yet
if (conf_info.height < account_info.block_count) if (conf_info.height < account_info.block_count)
{ {
stats.inc (nano::stat::type::backlog_scan, nano::stat::detail::activated); stats.inc (nano::stat::type::backlog_scan, nano::stat::detail::activated);
activated_info info{ account, account_info, conf_info };
activated.notify (transaction, info); activated.notify (transaction, info);
} }
} }

1
nano/node/backlog_scan.hpp
View file

@ -55,6 +55,7 @@ public:
*/ */
using callback_t = nano::observer_set<nano::secure::transaction const &, activated_info const &>; using callback_t = nano::observer_set<nano::secure::transaction const &, activated_info const &>;
callback_t activated; callback_t activated;
callback_t scanned;
private: // Dependencies private: // Dependencies
backlog_scan_config const & config; backlog_scan_config const & config;