|
|
@ -1217,6 +1217,8 @@ int32_t iguana_processrecvQ(struct iguana_info *coin,int32_t *newhwmp) // single |
|
|
|
*newhwmp = 0; |
|
|
|
while ( coin->active != 0 && (req= queue_dequeue(&coin->recvQ,0)) != 0 ) |
|
|
|
{ |
|
|
|
if ( (flag % 100) == 50 ) |
|
|
|
iguana_reqblocks(coin); |
|
|
|
flag++; |
|
|
|
//fprintf(stderr,"flag.%d %s recvQ.%p type.%c n.%d\n",flag,req->addr != 0 ? req->addr->ipaddr : "0",req,req->type,req->n);
|
|
|
|
if ( req->type == 'B' ) // one block with all txdata
|
|
|
@ -1252,6 +1254,7 @@ int32_t iguana_processrecvQ(struct iguana_info *coin,int32_t *newhwmp) // single |
|
|
|
if ( flag >= IGUANA_BUNDLELOOP ) |
|
|
|
break; |
|
|
|
} |
|
|
|
iguana_reqblocks(coin); |
|
|
|
return(flag); |
|
|
|
} |
|
|
|
|
|
|
|