From 6dd71fc18a45a74b324def4e10e5272f35ce0f66 Mon Sep 17 00:00:00 2001 From: jl777 Date: Sat, 12 Mar 2016 23:47:11 -0300 Subject: [PATCH] test --- iguana/iguana_recv.c | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/iguana/iguana_recv.c b/iguana/iguana_recv.c index a6af39d72..250600469 100755 --- a/iguana/iguana_recv.c +++ b/iguana/iguana_recv.c @@ -857,14 +857,16 @@ int32_t iguana_processbundlesQ(struct iguana_info *coin,int32_t *newhwmp) // sin { int32_t flag = 0; struct iguana_bundlereq *req; *newhwmp = 0; - while ( flag < IGUANA_BUNDLELOOP && (req= queue_dequeue(&coin->bundlesQ,0)) != 0 ) + while ( (req= queue_dequeue(&coin->bundlesQ,0)) != 0 ) { - flag++; //fprintf(stderr,"%s bundlesQ.%p type.%c n.%d\n",req->addr != 0 ? req->addr->ipaddr : "0",req,req->type,req->n); //if ( req->type == 'H' ) // continue; if ( req->type == 'B' ) // one block with all txdata + { req = iguana_recvblock(coin,req->addr,req,&req->block,req->numtx,req->datalen,req->recvlen,newhwmp); + flag++; + } else if ( req->type == 'H' ) // blockhdrs (doesnt have txn_count!) { if ( (req= iguana_recvblockhdrs(coin,req,req->blocks,req->n,newhwmp)) != 0 ) @@ -889,6 +891,8 @@ int32_t iguana_processbundlesQ(struct iguana_info *coin,int32_t *newhwmp) // sin //fprintf(stderr,"finished bundlesQ\n"); if ( req != 0 ) myfree(req,req->allocsize), req = 0; + if ( flag >= IGUANA_BUNDLELOOP ) + break; } return(flag); }