lukechilds
/
SuperNET
mirror of https://github.com/lukechilds/SuperNET.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
137 Commits
31 Branches
0 Tags
196 MiB
 
 
 
 
 
 
Tree: 21ea06c78c
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from '21ea06c78c'
${ noResults }
SuperNET/iguana/iguana_init.c

364 lines
15 KiB
Raw Blame History

/******************************************************************************
* Copyright © 2014-2015 The SuperNET Developers. *
* *
* See the AUTHORS, DEVELOPER-AGREEMENT and LICENSE files at *
* the top-level directory of this distribution for the individual copyright *
* holder information and the developer policies on copyright and licensing. *
* *
* Unless otherwise agreed in a custom licensing agreement, no part of the *
* SuperNET software, including this file may be copied, modified, propagated *
* or distributed except according to the terms contained in the LICENSE file *
* *
* Removal or modification of this copyright notice is prohibited. *
* *
******************************************************************************/
#include "iguana777.h"
void iguana_initQ(queue_t *Q,char *name)
{
char *tst,*str = "need to init each Q when single threaded";
queue_enqueue(name,Q,queueitem(str),1);
if ( (tst= queue_dequeue(Q,1)) != 0 )
free_queueitem(tst);
}
void iguana_initQs(struct iguana_info *coin)
{
int32_t i;
iguana_initQ(&coin->acceptQ,"acceptQ");
iguana_initQ(&coin->bundlesQ,"bundlesQ");
iguana_initQ(&coin->hdrsQ,"hdrsQ");
iguana_initQ(&coin->blocksQ,"blocksQ");
iguana_initQ(&coin->priorityQ,"priorityQ");
iguana_initQ(&coin->possibleQ,"possibleQ");
iguana_initQ(&coin->cacheQ,"cacheQ");
iguana_initQ(&coin->TerminateQ,"TerminateQ");
for (i=0; i<IGUANA_MAXPEERS; i++)
iguana_initQ(&coin->peers.active[i].sendQ,"addrsendQ");
}
void iguana_initpeer(struct iguana_info *coin,struct iguana_peer *addr,uint32_t ipbits)
{
memset(addr,0,sizeof(*addr));
addr->ipbits = ipbits;
addr->usock = -1;
expand_ipbits(addr->ipaddr,addr->ipbits);
//addr->pending = (uint32_t)time(NULL);
strcpy(addr->symbol,coin->symbol);
strcpy(addr->coinstr,coin->name);
iguana_initQ(&addr->sendQ,"addrsendQ");
}
void iguana_initcoin(struct iguana_info *coin)
{
int32_t i;
portable_mutex_init(&coin->peers_mutex);
portable_mutex_init(&coin->blocks_mutex);
iguana_meminit(&coin->blockMEM,"blockMEM",coin->blockspace,sizeof(coin->blockspace),0);
iguana_initQs(coin);
OS_randombytes((unsigned char *)&coin->instance_nonce,sizeof(coin->instance_nonce));
coin->startutc = (uint32_t)time(NULL);
while ( time(NULL) == coin->startutc )
usleep(1);
coin->startmillis = OS_milliseconds(), coin->starttime = tai_now(coin->startmillis);
coin->avetime = 1 * 100;
//coin->R.maxrecvbundles = IGUANA_INITIALBUNDLES;
for (i=0; i<IGUANA_MAXPEERS; i++)
coin->peers.active[i].usock = -1;
// validate blocks!!
//for (i=0; i<IGUANA_NUMAPPENDS; i++)
// vupdate_sha256(coin->latest.lhashes[i].bytes,&coin->latest.states[i],0,0);
}
bits256 iguana_genesis(struct iguana_info *coin,struct iguana_chain *chain)
{
struct iguana_block block,*ptr; struct iguana_msgblock msg; bits256 hash2; char str[65]; uint8_t buf[1024]; int32_t height;
decode_hex(buf,(int32_t)strlen(chain->genesis_hex)/2,(char *)chain->genesis_hex);
hash2 = bits256_doublesha256(0,buf,sizeof(struct iguana_msgblockhdr));
iguana_rwblock(0,&hash2,buf,&msg);
if ( memcmp(hash2.bytes,chain->genesis_hashdata,sizeof(hash2)) != 0 )
{
bits256_str(str,hash2);
printf("genesis mismatch? calculated %s vs %s\n",str,(char *)chain->genesis_hex);
memset(hash2.bytes,0,sizeof(hash2));
return(hash2);
}
bits256_str(str,hash2);
printf("genesis.(%s) len.%d hash.%s\n",chain->genesis_hex,(int32_t)sizeof(msg.H),str);
iguana_blockconv(&block,&msg,hash2,0);
//coin->latest.dep.numtxids =
block.RO.numvouts = 1;
iguana_gotdata(coin,0,0);
if ( (ptr= iguana_blockhashset(coin,0,hash2,1)) != 0 )
{
ptr->mainchain = 1;
iguana_blockcopy(coin,ptr,&block);
coin->blocks.RO[0] = block.RO;
if ( (height= iguana_chainextend(coin,ptr)) == 0 )
{
block = *ptr;
coin->blocks.recvblocks = coin->blocks.issuedblocks = 1;
}
else printf("genesis block doesnt validate for %s ht.%d\n",coin->symbol,height);
} else printf("couldnt hashset genesis\n");
if ( coin->blocks.hwmchain.height != 0 || fabs(coin->blocks.hwmchain.PoW - block.PoW) > SMALLVAL || memcmp(coin->blocks.hwmchain.RO.hash2.bytes,hash2.bytes,sizeof(hash2)) != 0 )
{
printf("%s genesis values mismatch hwmheight.%d %.15f %.15f %s\n",coin->name,coin->blocks.hwmchain.height,coin->blocks.hwmchain.PoW,block.PoW,bits256_str(str,coin->blocks.hwmchain.RO.hash2));
getchar();
}
int32_t bundlei = -2;
static bits256 zero;
iguana_bundlecreate(coin,&bundlei,0,hash2,zero,1);
return(hash2);
}
int32_t iguana_savehdrs(struct iguana_info *coin)
{
int32_t height,iter,i,n,retval = 0; char fname[512],shastr[65],tmpfname[512],str[65],oldfname[512];
bits256 hash2,sha256all,*hashes; FILE *fp; struct sha256_vstate shastate;
n = coin->blocks.hwmchain.height + 1;
hashes = mycalloc('h',coin->chain->bundlesize,sizeof(*hashes));
if ( 0 )
{
printf("start savehdrs calc\n");
vupdate_sha256(sha256all.bytes,&shastate,0,0);
for (i=0; i<n; i++)
{
hash2 = iguana_blockhash(coin,i);
if ( bits256_nonz(hash2) == 0 )
{
printf("iguana_savehdrs null hash at %d\n",i);
return(-1);
}
vupdate_sha256(sha256all.bytes,&shastate,(void *)hash2.bytes,sizeof(hash2));
}
printf("finished calc\n");
}
sprintf(oldfname,"confs/%s_oldhdrs.txt",coin->symbol), OS_compatible_path(oldfname);
sprintf(tmpfname,"tmp/%s/hdrs.txt",coin->symbol), OS_compatible_path(tmpfname);
sprintf(fname,"confs/%s_hdrs.txt",coin->symbol), OS_compatible_path(fname);
if ( (fp= fopen(tmpfname,"w")) != 0 )
{
if ( 0 )
{
fprintf(fp,"%d %s\n",n,bits256_str(str,sha256all));
for (i=0; i<n; i++)
{
hash2 = iguana_blockhash(coin,i);
fprintf(fp,"%d %s\n",i,bits256_str(str,hash2));
}
printf("finished saving\n");
}
else
{
fprintf(fp,"%d\n",n);
for (height=0; height<=n; height+=coin->chain->bundlesize)
{
for (i=0; i<coin->chain->bundlesize; i++)
{
hashes[i] = iguana_blockhash(coin,height+i);
if ( bits256_str(str,hashes[i]) == 0 )
break;
}
if ( i == coin->chain->bundlesize )
{
struct iguana_bundle *bp;
vcalc_sha256(shastr,sha256all.bytes,hashes[0].bytes,sizeof(*hashes) * coin->chain->bundlesize);
if ( (bp= coin->bundles[height/coin->chain->bundlesize]) != 0 )
bp->allhash = sha256all;
}
else shastr[0] = 0;
for (iter=0; iter<1; iter++)
{
hash2 = iguana_blockhash(coin,height+iter);
if ( bits256_nonz(hash2) > 0 )
{
char str[65];
bits256_str(str,hash2);
if ( iter == 0 )
fprintf(fp,"%d %s %s\n",height+iter,str,shastr);
else fprintf(fp,"%d %s\n",height+iter,str);
retval = height+iter;
}
if ( coin->chain->hasheaders != 0 )
break;
}
}
}
//printf("new hdrs.txt %ld vs (%s) %ld\n",ftell(fp),fname,(long)iguana_filesize(fname));
if ( ftell(fp) > OS_filesize(fname) )
{
printf("new hdrs.txt %ld vs (%s) %ld\n",ftell(fp),fname,(long)OS_filesize(fname));
fclose(fp);
OS_renamefile(fname,oldfname);
OS_copyfile(tmpfname,fname,1);
} else fclose(fp);
}
myfree(hashes,coin->chain->bundlesize * sizeof(*hashes));
return(retval);
}
void iguana_parseline(struct iguana_info *coin,int32_t iter,FILE *fp)
{
int32_t j,k,m,c,height,flag,bundlei,bundleheight = -1; char checkstr[1024],line[1024];
struct iguana_peer *addr; struct iguana_bundle *bp; bits256 allhash,hash2,zero;
struct iguana_block *block;
if ( iter == 1 )
{
int32_t i; FILE *fp; char fname[512]; struct iguana_blockRO blockRO;
sprintf(fname,"blocks.%s",coin->symbol), OS_compatible_path(fname);
if ( (fp= fopen(fname,"rb")) != 0 )
{
for (i=0; i<100000000; i++)
{
if ( fread(&blockRO,1,sizeof(blockRO),fp) != sizeof(blockRO) )
break;
if ( i > (coin->blocks.maxbits - 1000) )
iguana_recvalloc(coin,i + 100000);
coin->blocks.RO[i] = blockRO;
char str[65];
if ( bits256_nonz(blockRO.hash2) > 0 )
printf("init.%d %s\n",i,bits256_str(str,blockRO.hash2));
}
fclose(fp);
printf("validate.%d blocks that were read in\n",i);
}
}
m = flag = 0;
memset(&zero,0,sizeof(zero));
allhash = zero;
while ( fgets(line,sizeof(line),fp) > 0 )
{
j = (int32_t)strlen(line) - 1;
line[j] = 0;
//printf("parse line.(%s) maxpeers.%d\n",line,coin->MAXPEERS);
if ( iter == 0 )
{
if ( m < (2*coin->MAXPEERS)/3 )//&& m < 77.7 )
{
if ( m == 0 )
{
addr = &coin->peers.active[m++];
iguana_initpeer(coin,addr,(uint32_t)calc_ipbits("127.0.0.1"));
printf("call initpeer.(%s)\n",addr->ipaddr);
iguana_launch(coin,"connection",iguana_startconnection,addr,IGUANA_CONNTHREAD);
}
#ifndef IGUANA_DISABLEPEERS
addr = &coin->peers.active[m++];
iguana_initpeer(coin,addr,(uint32_t)calc_ipbits(line));
printf("call initpeer.(%s)\n",addr->ipaddr);
iguana_launch(coin,"connection",iguana_startconnection,addr,IGUANA_CONNTHREAD);
#endif
}
}
else
{
for (k=height=0; k<j-1; k++)
{
if ( (c= line[k]) == ' ' )
break;
else if ( c >= '0' && c <= '9' )
height = (height * 10) + (line[k] - '0');
else break;
}
//printf("parseline: k.%d %d height.%d m.%d bundlesize.%d (%s)\n",k,line[k],height,m,coin->chain->bundlesize,&line[k+1+65]);// + strlen(line+k+1)]);
if ( line[k] == ' ' )
{
decode_hex(hash2.bytes,sizeof(hash2),line+k+1);
if ( line[k+1 + 65] != 0 )
{
if ( height > (coin->blocks.maxbits - 1000) )
iguana_recvalloc(coin,height + 100000);
decode_hex(allhash.bytes,sizeof(allhash),line+k+1 + 64 + 1);
init_hexbytes_noT(checkstr,allhash.bytes,sizeof(allhash));
if ( strcmp(checkstr,line+k+1 + 64 + 1) == 0 )
{
init_hexbytes_noT(checkstr,hash2.bytes,sizeof(hash2));
//char str[65],str2[65]; printf(">>>> bundle.%d got (%s)/(%s) allhash.(%s)\n",height,bits256_str(str,hash2),checkstr,bits256_str(str2,allhash));
if ( (bp= iguana_bundlecreate(coin,&bundlei,height,hash2,allhash,0)) != 0 )
{
bp->bundleheight = height;
if ( (block= iguana_blockfind(coin,hash2)) != 0 )
block->mainchain = 1, block->height = height;
if ( iguana_bundleload(coin,bp) != 0 )
{
bp->emitfinish = (uint32_t)time(NULL) + 1;
//printf("LOADED bundle.%d\n",bp->bundleheight);
}
else
{
char str[65];
init_hexbytes_noT(str,hash2.bytes,sizeof(hash2));
bp->emitfinish = 0;
iguana_blockQ(coin,bp,0,hash2,1);
queue_enqueue("hdrsQ",&coin->hdrsQ,queueitem(str),1);
}
}
}
}
init_hexbytes_noT(checkstr,hash2.bytes,sizeof(hash2));
if ( strncmp(checkstr,line+k+1,64) == 0 )
{
if ( (height % coin->chain->bundlesize) == 1 )
{
if ( (bp= coin->bundles[height/coin->chain->bundlesize]) != 0 )
{
if ( iguana_bundlehash2add(coin,0,bp,1,hash2) == 0 )
{
//printf("add bundle.%d:%d (%s)\n",bundleheight,bp->hdrsi,bits256_str(str,hash2));
if ( (block= iguana_blockfind(coin,hash2)) != 0 )
block->mainchain = 1, block->height = bundleheight+1;
}
}
}
}
}
}
}
}
struct iguana_info *iguana_startcoin(struct iguana_info *coin,int32_t initialheight,int32_t mapflags)
{
FILE *fp; char fname[512],*symbol; int32_t iter;
coin->sleeptime = 10000;
symbol = coin->symbol;
if ( initialheight < coin->chain->bundlesize*10 )
initialheight = coin->chain->bundlesize*10;
iguana_recvalloc(coin,initialheight);
coin->longestchain = 1;
coin->blocks.hwmchain.height = 0;
if ( (coin->myservices & NODE_NETWORK) != 0 )
{
printf("MYSERVICES.%llx\n",(long long)coin->myservices);
coin->peers.acceptloop = malloc(sizeof(pthread_t));
if ( OS_thread_create(coin->peers.acceptloop,NULL,(void *)iguana_acceptloop,(void *)coin) != 0 )
{
free(coin->peers.acceptloop);
coin->peers.acceptloop = 0;
printf("error launching accept thread for port.%u\n",coin->chain->portp2p);
}
}
coin->firstblock = coin->blocks.parsedblocks + 1;
iguana_genesis(coin,coin->chain);
for (iter=0; iter<2; iter++)
{
sprintf(fname,"confs/%s_%s.txt",coin->symbol,(iter == 0) ? "peers" : "hdrs");
OS_compatible_path(fname);
printf("parsefile.%d %s\n",iter,fname);
if ( (fp= fopen(fname,"r")) != 0 )
{
iguana_parseline(coin,iter,fp);
fclose(fp);
}
printf("done parsefile.%d\n",iter);
}
#ifndef IGUANA_DEDICATED_THREADS
coin->peers.peersloop = iguana_launch("peersloop",iguana_peersloop,coin,IGUANA_PERMTHREAD);
#endif
if ( 0 && (coin->MAXBUNDLES= coin->bundlescount / 4) < _IGUANA_MAXBUNDLES )
coin->MAXBUNDLES = _IGUANA_MAXBUNDLES;
printf("started.%s\n",coin->symbol);
return(coin);
}