test

iguana/iguana_bundles.c

@@ -828,13 +828,15 @@ int32_t iguana_bundlefinalize(struct iguana_info *coin,struct iguana_bundle *bp,
             return(0);
         }
         bp->emitfinish = 1;
-        iguana_bundletweak(coin,bp);
+        sleep(3); // make sure new incoming packet didnt overwrite
-        //sleep(3); // just in case data isnt totally sync'ed to HDD
+        if ( iguana_bundleready(coin,bp) == bp->n )
+        {
             coin->emitbusy++;
             if ( iguana_bundlesaveHT(coin,mem,memB,bp,(uint32_t)time(NULL)) == 0 )
             {
                 //fprintf(stderr,"emitQ done coin.%p bp.[%d] ht.%d\n",coin,bp->hdrsi,bp->bundleheight);
                 bp->emitfinish = (uint32_t)time(NULL) + 1;
+                iguana_bundletweak(coin,bp);
                 coin->numemitted++;
             }
             else
@@ -843,6 +845,7 @@ int32_t iguana_bundlefinalize(struct iguana_info *coin,struct iguana_bundle *bp,
                 bp->emitfinish = 0;
             }
             coin->emitbusy--;
+        } else printf("interloper! [%d] save interupted\n",bp->hdrsi);
     }
     return(1);
 }

iguana/iguana_recv.c

@@ -1085,7 +1085,7 @@ int32_t iguana_reqblocks(struct iguana_info *coin)
             {
                 hdrsi0 = (coin->blocks.hwmchain.height) / coin->chain->bundlesize;
                 bundlei0 = (coin->blocks.hwmchain.height) % coin->chain->bundlesize;
-                if ( (block= iguana_bundleblock(coin,&hash2,coin->bundles[hdrsi0],bundlei0)) == 0 )
+                if ( coin->bundles[hdrsi0] != 0 && (block= iguana_bundleblock(coin,&hash2,coin->bundles[hdrsi0],bundlei0)) != 0 )
                     next = block->hh.next; //, next/block->mainchain = 1;
             }
         }