test

iguana/iguana777.c

@@ -336,7 +336,7 @@ int32_t iguana_helpertask(FILE *fp,struct OS_memspace *mem,struct OS_memspace *m
             }
             else if ( ptr->type == 'B' )
             {
-                iguana_bundleiters(coin,bp,ptr->timelimit);
+                iguana_bundleiters(coin,mem,memB,bp,ptr->timelimit);
             }
             else if ( ptr->type == 'E' )
             {
@@ -404,7 +404,7 @@ void iguana_helper(void *arg)
         {
             idle = 0;
             if ( ptr->bp != 0 && ptr->coin != 0 )
-                flag += iguana_bundleiters(ptr->coin,ptr->bp,ptr->timelimit);
+                flag += iguana_bundleiters(ptr->coin,&MEM,MEMB,ptr->bp,ptr->timelimit);
             else printf("helper missing param? %p %p %u\n",ptr->coin,ptr->bp,ptr->timelimit);
             myfree(ptr,ptr->allocsize);
             flag++;

iguana/iguana777.h

@@ -733,7 +733,7 @@ int32_t is_bitcoinrpc(char *method,char *remoteaddr);
 char *iguana_bitcoinRPC(struct supernet_info *myinfo,char *method,cJSON *json,char *remoteaddr);
 cJSON *iguana_pubkeyjson(struct iguana_info *coin,char *pubkeystr);
 void iguana_bundleQ(struct iguana_info *coin,struct iguana_bundle *bp,int32_t timelimit);
-int32_t iguana_bundleiters(struct iguana_info *coin,struct iguana_bundle *bp,int32_t timelimit);
+int32_t iguana_bundleiters(struct iguana_info *coin,struct OS_memspace *mem,struct OS_memspace *memB,struct iguana_bundle *bp,int32_t timelimit);
 void ramcoder_test(void *data,int64_t len);
 void iguana_exit();
 int32_t iguana_pendingaccept(struct iguana_info *coin);

iguana/iguana_bundles.c

@@ -704,7 +704,7 @@ int32_t iguana_bundlefinish(struct iguana_info *coin,struct iguana_bundle *bp)
     return(0);
 }
 
-int32_t iguana_bundleiters(struct iguana_info *coin,struct iguana_bundle *bp,int32_t timelimit)
+int32_t iguana_bundleiters(struct iguana_info *coin,struct OS_memspace *mem,struct OS_memspace *memB,struct iguana_bundle *bp,int32_t timelimit)
 {
     int32_t range,starti,lasti,retval=0,max,counter = 0; struct iguana_bundle *currentbp,*lastbp;
     bp->nexttime = (uint32_t)time(NULL) + 1;
@@ -746,7 +746,17 @@ int32_t iguana_bundleiters(struct iguana_info *coin,struct iguana_bundle *bp,int
             bp->emitfinish = 1;
             iguana_bundletweak(coin,bp);
             sleep(1); // just in case data isnt totally sync'ed to HDD
-            iguana_emitQ(coin,bp);
+            if ( 0 )
+                iguana_emitQ(coin,bp);
+            else
+            {
+                if ( iguana_bundlesaveHT(coin,mem,memB,bp,(uint32_t)time(NULL)) == 0 )
+                {
+                    fprintf(stderr,"emitQ coin.%p bp.[%d]\n",coin,bp->bundleheight);
+                    bp->emitfinish = (uint32_t)time(NULL) + 1;
+                    coin->numemitted++;
+                } else bp->emitfinish = 0;
+            }
         }
         retval = 1;
     }