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

Periodic pending search (#1268)

Browse source
This commit is contained in:
SergiySW 2018-10-07 19:26:10 +03:00 • committed by Roy Keene
commit b3c7124be7
2 changed files with 13 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

11
rai/node/node.cpp
View file

@ -19,6 +19,7 @@ std::chrono::seconds constexpr rai::node::period;
std::chrono::seconds constexpr rai::node::cutoff;
std::chrono::seconds constexpr rai::node::syn_cookie_cutoff;
std::chrono::minutes constexpr rai::node::backup_interval;
std::chrono::seconds constexpr rai::node::search_pending_interval;
int constexpr rai::port_mapping::mapping_timeout;
int constexpr rai::port_mapping::check_timeout;
unsigned constexpr rai::active_transactions::announce_interval_ms;
@ -2193,6 +2194,7 @@ void rai::node::start ()
ongoing_rep_crawl ();
bootstrap.start ();
backup_wallet ();
search_pending ();
online_reps.recalculate_stake ();
port_mapping.start ();
add_initial_peers ();
@ -2370,6 +2372,15 @@ void rai::node::backup_wallet ()
});
}
void rai::node::search_pending ()
{
wallets.search_pending_all ();
auto this_l (shared ());
alarm.add (std::chrono::steady_clock::now () + search_pending_interval, [this_l]() {
this_l->search_pending ();
});
}
int rai::node::price (rai::uint128_t const & balance_a, int amount_a)
{
assert (balance_a >= amount_a * rai::Gxrb_ratio);

2
rai/node/node.hpp
View file

@ -588,6 +588,7 @@ public:
void ongoing_bootstrap ();
void ongoing_store_flush ();
void backup_wallet ();
void search_pending ();
int price (rai::uint128_t const &, int);
void work_generate_blocking (rai::block &);
uint64_t work_generate_blocking (rai::uint256_union const &);
@ -630,6 +631,7 @@ public:
static std::chrono::seconds constexpr cutoff = period * 5;
static std::chrono::seconds constexpr syn_cookie_cutoff = std::chrono::seconds (5);
static std::chrono::minutes constexpr backup_interval = std::chrono::minutes (5);
static std::chrono::seconds constexpr search_pending_interval = (rai::rai_network == rai::rai_networks::rai_test_network) ? std::chrono::seconds (1) : std::chrono::seconds (5 * 60);
};
class thread_runner
{