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

adding spam to detect bugs

Browse source
This commit is contained in:
Daniel Larimer 2015-07-30 16:45:14 -04:00
parent 8b0a22d849
commit 1b260ab37a
2 changed files with 17 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
libraries/app/api.cpp
View file

@ -708,6 +708,7 @@ namespace graphene { namespace app {
result.push_back( aobj->owner );
break;
} case impl_account_statistics_object_type:{
elog( "stats object" );
const auto& aobj = dynamic_cast<const account_statistics_object*>(obj);
assert( aobj != nullptr );
result.push_back( aobj->owner );
@ -801,6 +802,7 @@ namespace graphene { namespace app {
map< pair<asset_id_type, asset_id_type>, vector<variant> > market_broadcast_queue;
for(auto id : ids)
{
edump((id)(_account_subscriptions.size()));
if(_subscriptions.find(id) != _subscriptions.end())
my_objects.push_back(id);
@ -811,6 +813,7 @@ namespace graphene { namespace app {
if( obj )
{
vector<account_id_type> relevant = get_relevant_accounts( obj );
edump(("relevant accounts")(relevant)(obj->id));
for( const auto& r : relevant )
{
auto sub = _account_subscriptions.find(r);
@ -818,6 +821,8 @@ namespace graphene { namespace app {
broadcast_queue[r].emplace_back(obj->to_variant());
}
}
else
elog( "unable to find object ${id}", ("id",id) );
}
if( _market_subscriptions.size() )
@ -842,12 +847,20 @@ namespace graphene { namespace app {
/// if a connection hangs then this could get backed up and result in
/// a failure to exit cleanly.
_broadcast_changes_complete = fc::async([=](){
for( const auto& item : broadcast_queue )
edump((item.second));
for( const auto& item : broadcast_queue )
{
edump( (item) );
auto sub = _account_subscriptions.find(item.first);
if( sub != _account_subscriptions.end() )
sub->second( fc::variant(item.second ) );
try {
auto sub = _account_subscriptions.find(item.first);
if( sub != _account_subscriptions.end() )
sub->second( fc::variant(item.second ) );
} catch ( const fc::exception& e )
{
edump((e.to_detail_string()));
}
}
for( const auto& item : market_broadcast_queue )
{

2
libraries/fc

@ -1 +1 @@
Subproject commit 088dadd12481e75829b83c098f3bc36b7e296ca0
Subproject commit d11b48a015e0c339cc20f739ef1f8a5b3c57b913