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

Adding vector of observers in client.

Browse source
This commit is contained in:
clemahieu 2014-12-04 18:42:46 -06:00
commit 48ddc09424
2 changed files with 34 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

32
rai/core/core.cpp
View file

@ -860,11 +860,39 @@ service (processor_a)
{
ledger.send_observer = [this] (rai::send_block const & block_a, rai::account const & account_a, rai::amount const & balance_a)
{
if (wallet.find (block_a.hashables.destination) != wallet.end ())
for (auto & i: send_observers)
{
conflicts.start (block_a, true);
i (block_a, account_a, balance_a);
}
};
ledger.receive_observer = [this] (rai::receive_block const & block_a, rai::account const & account_a, rai::amount const & balance_a)
{
for (auto & i: receive_observers)
{
i (block_a, account_a, balance_a);
}
};
ledger.open_observer = [this] (rai::open_block const & block_a, rai::account const & account_a, rai::amount const & balance_a, rai::account const & representative_a)
{
for (auto & i: open_observers)
{
i (block_a, account_a, balance_a, representative_a);
}
};
ledger.change_observer = [this] (rai::change_block const & block_a, rai::account const & account_a, rai::account const & representative_a)
{
for (auto & i: change_observers)
{
i (block_a, account_a, representative_a);
}
};
send_observers.push_back ([this] (rai::send_block const & block_a, rai::account const & account_a, rai::amount const & balance_a)
{
if (wallet.find (block_a.hashables.destination) != wallet.end ())
{
conflicts.start (block_a, true);
}
});
if (!init_a.error ())
{
if (client_lifetime_tracing ())

4
rai/core/core.hpp
View file

@ -688,6 +688,10 @@ namespace rai {
rai::transactions transactions;
rai::peer_container peers;
rai::processor_service & service;
std::vector <std::function <void (rai::send_block const &, rai::account const &, rai::amount const &)>> send_observers;
std::vector <std::function <void (rai::receive_block const &, rai::account const &, rai::amount const &)>> receive_observers;
std::vector <std::function <void (rai::open_block const &, rai::account const &, rai::amount const &, rai::account const &)>> open_observers;
std::vector <std::function <void (rai::change_block const &, rai::account const &, rai::account const &)>> change_observers;
};
class system
{