diff --git a/iguana/iguana_bundles.c b/iguana/iguana_bundles.c index 44ddfd337..d755bc278 100755 --- a/iguana/iguana_bundles.c +++ b/iguana/iguana_bundles.c @@ -1029,10 +1029,11 @@ int32_t iguana_bundlefinalize(struct supernet_info *myinfo,struct iguana_info *c if ( coin->firstRTheight == 0 && iguana_bundleready(myinfo,coin,bp,0) == bp->n ) { printf(">>>>>>>>>>>>>> EMIT.[%3d] %s | 1st.%-3d h.%-3d c.%-3d s.[%3d] maxB.%d NET.(h%d b%d) %ld:%02ld\n",bp->hdrsi,coin->symbol,coin->current!=0?coin->current->hdrsi:-1,coin->current!=0?coin->current->numhashes:-1,coin->current!=0?coin->current->numcached:-1,coin->current!=0?coin->current->numsaved:-1,coin->MAXBUNDLES,HDRnet,queue_size(&coin->priorityQ),(time(NULL)-coin->startutc)/60,(time(NULL)-coin->startutc)%60); - if ( queue_size(&coin->priorityQ) > 20000 ) + if ( queue_size(&coin->priorityQ) > 10000 ) { while ( (breq= queue_dequeue(&coin->priorityQ,0)) != 0 ) myfree(breq,sizeof(*breq)); + printf("cleared priorityQ\n"); } if ( bp->emitfinish != 0 ) { @@ -1558,5 +1559,11 @@ void iguana_bundlestats(struct supernet_info *myinfo,struct iguana_info *coin,ch iguana_setmaxbundles(coin); strcpy(coin->statusstr,str); coin->estsize = estsize; + if ( queue_size(&coin->priorityQ) > 10000 ) + { + while ( (breq= queue_dequeue(&coin->priorityQ,0)) != 0 ) + myfree(breq,sizeof(*breq)); + printf("cleared priorityQ\n"); + } }