test

iguana/iguana_recv.c

@@ -394,7 +394,7 @@ void iguana_bundlespeculate(struct iguana_info *coin,struct iguana_bundle *bp,in
 
 int32_t iguana_bundleiters(struct iguana_info *coin,struct iguana_bundle *bp,int32_t timelimit)
 {
-    int32_t i,n,range,better,issued,valid,pend,max,counter = 0; uint32_t now; struct iguana_block *block; double endmillis,width;
+    int32_t i,n,range,starti,better,issued,valid,pend,max,counter = 0; uint32_t now; struct iguana_block *block; double endmillis,width;
     coin->numbundlesQ--;
     //printf("BUNDLEITERS.%d\n",bp->hdrsi);
     if ( bp->numhashes < bp->n && bp->bundleheight < coin->longestchain-coin->chain->bundlesize )
@@ -420,9 +420,8 @@ int32_t iguana_bundleiters(struct iguana_info *coin,struct iguana_bundle *bp,int
     }
     if ( (range= coin->peers.numranked) > IGUANA_MAXBUNDLES )
         range = IGUANA_MAXBUNDLES;
-    if ( 1 && coin->current != 0 )
-    {
-        if ( bp->rank != 0 && bp->rank <= coin->current->hdrsi + range )
+    starti = coin->current == 0 ? 0 : coin->current->hdrsi;
+    if ( bp->hdrsi < starti + range )
     {
         for (i=0; i<bp->n; i++)
         {
@@ -434,8 +433,12 @@ int32_t iguana_bundleiters(struct iguana_info *coin,struct iguana_bundle *bp,int
             }
         }
     }
-        //printf("initial requests for hdrs.%d\n",bp->hdrsi);
+    else
+    {
+        iguana_bundleQ(coin,bp,counter == 0 ? bp->n*5 : bp->n*2);
+        return(0);
     }
+        //printf("initial requests for hdrs.%d\n",bp->hdrsi);
     pend = queue_size(&coin->priorityQ) + queue_size(&coin->blocksQ);
     for (i=0; i<IGUANA_MAXPEERS; i++)
         pend += coin->peers.active[i].pendblocks;