Browse Source

test

release/v0.1
jl777 9 years ago
parent
commit
fbb51f7f12
  1. 11
      iguana/iguana_bundles.c
  2. 6
      iguana/iguana_recv.c
  3. 2
      iguana/main.c

11
iguana/iguana_bundles.c

@ -929,13 +929,16 @@ void iguana_bundlestats(struct iguana_info *coin,char *str,int32_t lag)
{
if ( bp->hdrsi >= starti && bp->hdrsi < lasti )
capacity = iguana_bundlemissings(coin,bp,capacity,lag);
for (j=0; j<bp->n; j++)
if ( coin->enableCACHE != 0 )
{
if ( bp->speculativecache[j] != 0 )
for (j=0; j<bp->n; j++)
{
if ( (block= iguana_blockhashset(coin,-1,bp->speculative[j],1)) != 0 && block->processed == 0 )
iguana_cacheprocess(coin,bp,j);
if ( bp->speculativecache[j] != 0 )
{
if ( (block= iguana_blockhashset(coin,-1,bp->speculative[j],1)) != 0 && block->processed == 0 )
iguana_cacheprocess(coin,bp,j);
numcached++;
}
}
}
}

6
iguana/iguana_recv.c

@ -1217,8 +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);
//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
@ -1254,7 +1254,7 @@ int32_t iguana_processrecvQ(struct iguana_info *coin,int32_t *newhwmp) // single
if ( flag >= IGUANA_BUNDLELOOP )
break;
}
iguana_reqblocks(coin);
//iguana_reqblocks(coin);
return(flag);
}

2
iguana/main.c

@ -360,7 +360,7 @@ void mainloop(struct supernet_info *myinfo)
printf("main active.%d started.%p\n",coin->active,coin->started);
iguana_bundlestats(coin,str,IGUANA_DEFAULTLAG);
printf("done main active.%d started.%p\n",coin->active,coin->started);
//iguana_reqblocks(coin);
iguana_reqblocks(coin);
coin->RTramchain_busy = 1;
if ( iguana_realtime_update(coin) > 0 )
flag++;

Loading…
Cancel
Save