Peerplays_Blockchain/peerplays_migrated
1
0
Fork 0
Code Issues 35 Pull requests 4 Projects Releases 20 Packages Wiki Activity Actions

split notifications (notify_changed_objects) in three signals: new_objects, changed_objects, removed_objects

Browse source
This commit is contained in:
elmato 2017-02-10 08:25:39 +00:00
parent 823beb7fe5
commit 02b2672a39
2 changed files with 16 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
libraries/chain/db_block.cpp
View file

@ -549,17 +549,19 @@ void database::notify_changed_objects()
if( _undo_db.enabled() ) if( _undo_db.enabled() )
{ {
const auto& head_undo = _undo_db.head(); const auto& head_undo = _undo_db.head();
vector<object_id_type> new_ids; new_ids.reserve(head_undo.new_ids.size());
for( const auto& item : head_undo.new_ids ) new_ids.push_back(item);
vector<object_id_type> changed_ids; changed_ids.reserve(head_undo.old_values.size()); vector<object_id_type> changed_ids; changed_ids.reserve(head_undo.old_values.size());
for( const auto& item : head_undo.old_values ) changed_ids.push_back(item.first); for( const auto& item : head_undo.old_values ) changed_ids.push_back(item.first);
for( const auto& item : head_undo.new_ids ) changed_ids.push_back(item);
vector<const object*> removed; vector<const object*> removed; removed.reserve( head_undo.removed.size() );
removed.reserve( head_undo.removed.size() ); for( const auto& item : head_undo.removed ) removed.emplace_back( item.second.get() );
for( const auto& item : head_undo.removed )
{ new_objects(new_ids);
changed_ids.push_back( item.first );
removed.emplace_back( item.second.get() );
}
changed_objects(changed_ids); changed_objects(changed_ids);
removed_objects(removed);
} }
} FC_CAPTURE_AND_RETHROW() } } FC_CAPTURE_AND_RETHROW() }

6
libraries/chain/include/graphene/chain/database.hpp
View file

@ -189,6 +189,12 @@ namespace graphene { namespace chain {
*/ */
fc::signal<void(const signed_transaction&)> on_pending_transaction; fc::signal<void(const signed_transaction&)> on_pending_transaction;
/**
* Emitted After a block has been applied and committed. The callback
* should not yield and should execute quickly.
*/
fc::signal<void(const vector<object_id_type>&)> new_objects;
/** /**
* Emitted After a block has been applied and committed. The callback * Emitted After a block has been applied and committed. The callback
* should not yield and should execute quickly. * should not yield and should execute quickly.