/****************************************************************************** * Copyright © 2014-2017 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" /* To add a new dPoW'ed assetchain with DEX* API support: 1. add to komodo/src: assetchains, dpowassets, fiat-cli 2. add to end of NOTARY_CURRENCIES[] array in fundnotaries (iguana_notary.c) 3. create fiat/ 4. add to m_notary coins/ get gen_acname from where komodod was launched, change RELAY:-1 and port to 7776 and make _7776 variant 5. make coins/basilisk/ 6. launch from a single node with -gen, launch a second node using -addnode= but without -gen 7. from a single node, fundnotaries to get notaries able to dPoW */ void iguana_initQ(queue_t *Q,char *name) { struct stritem *tst,*item; memset(Q,0,sizeof(*Q)); item = calloc(1,sizeof(*item)+100); strcpy(item->str,"hello, world"); strcpy(Q->name,name); queue_enqueue(name,Q,&item->DL); if ( (tst= queue_dequeue(Q)) != 0 ) free(tst); } void iguana_initQs(struct iguana_info *coin) { int32_t i; iguana_initQ(&coin->acceptQ,"acceptQ"); iguana_initQ(&coin->hdrsQ,"hdrsQ"); iguana_initQ(&coin->blocksQ,"blocksQ"); iguana_initQ(&coin->priorityQ,"priorityQ"); iguana_initQ(&coin->possibleQ,"possibleQ"); iguana_initQ(&coin->msgrequestQ,"msgrequestQ"); iguana_initQ(&coin->cacheQ,"cacheQ"); iguana_initQ(&coin->recvQ,"recvQ"); iguana_initQ(&coin->jsonQ,"jsonQ"); iguana_initQ(&coin->finishedQ,"finishedQ"); if ( coin->MAXPEERS > 0 && coin->peers != 0 ) { for (i=0; ipeers->active[i].sendQ,"addrsendQ"); } } void iguana_initpeer(struct iguana_info *coin,struct iguana_peer *addr,uint64_t ipbits) { memset(addr,0,sizeof(*addr)); addr->ipbits = ipbits; addr->usock = -1; expand_ipbits(addr->ipaddr,(uint32_t)addr->ipbits); //addr->pending = (uint32_t)time(NULL); strcpy(addr->symbol,coin->symbol); strcpy(addr->coinname,coin->name); iguana_initQ(&addr->sendQ,"addrsendQ"); } void iguana_initcoin(struct iguana_info *coin,cJSON *argjson) { int32_t i; char dirname[1024]; if ( coin->instance_nonce == 0 ) { sprintf(dirname,"%s/%s",GLOBAL_TMPDIR,coin->symbol), OS_portable_path(dirname); portable_mutex_init(&coin->RTmutex); portable_mutex_init(&coin->kmdmutex); portable_mutex_init(&coin->peers_mutex); portable_mutex_init(&coin->blocks_mutex); portable_mutex_init(&coin->special_mutex); portable_mutex_init(&coin->allcoins_mutex); coin->txfee = 10000; iguana_meminit(&coin->blockMEM,"blockMEM",coin->blockspace,coin->blockspacesize,0); iguana_initQs(coin); coin->bindsock = -1; coin->notarychain = -1; 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->startutc++; printf("start.%u\n",coin->startutc); coin->startmillis = OS_milliseconds(), coin->starttime = tai_now(); coin->avetime = 1 * 100; //coin->R.maxrecvbundles = IGUANA_INITIALBUNDLES; if ( coin->MAXPEERS > 0 && coin->peers != 0 ) { for (i=0; ipeers->active[i].usock = -1; } } } bits256 iguana_genesis(struct supernet_info *myinfo,struct iguana_info *coin,struct iguana_chain *chain) { struct iguana_block *block,*ptr; struct iguana_msgzblock zmsg; bits256 hash2; char str[65],str2[65]; uint8_t buf[8192],blockspace[sizeof(*block)+sizeof(struct iguana_zblock)]; int32_t height,auxback; if ( coin == 0 || chain == 0 ) return(GENESIS_PUBKEY); block = (void *)blockspace; memset(block,0,sizeof(blockspace)); block->RO.allocsize = chain->zcash != 0 ? sizeof(struct iguana_zblock) : sizeof(struct iguana_block); iguana_blocksizecheck("genesis",chain->zcash,block); if ( chain->genesis_hex == 0 ) { printf("no genesis_hex for %s\n",coin->symbol); memset(hash2.bytes,0,sizeof(hash2)); return(hash2); } decode_hex(buf,(int32_t)strlen(chain->genesis_hex)/2,(char *)chain->genesis_hex); hash2 = iguana_calcblockhash(coin->symbol,coin->chain->hashalgo,buf,chain->zcash == 0 ? sizeof(struct iguana_msgblockhdr) : sizeof(struct iguana_msgzblockhdr)); auxback = chain->auxpow, chain->auxpow = 0; iguana_rwblock(myinfo,coin->symbol,coin->chain->zcash,chain->auxpow,chain->hashalgo,0,&hash2,buf,(void *)&zmsg,sizeof(buf)); chain->auxpow = auxback; if ( coin->virtualchain == 0 && coin->MAXPEERS > 1 ) { if ( chain->debug == 0 && memcmp(hash2.bytes,chain->genesis_hashdata,sizeof(hash2)) != 0 ) { bits256_str(str,hash2); printf("genesis mismatch? zcash.%d calculated %s vs %s\n",chain->zcash,str,bits256_str(str2,*(bits256 *)chain->genesis_hashdata)); memcpy(hash2.bytes,chain->genesis_hashdata,sizeof(hash2)); } if ( coin->chain->debug != 0 ) memcpy(hash2.bytes,chain->genesis_hashdata,sizeof(hash2)); } else memcpy(hash2.bytes,chain->genesis_hashdata,sizeof(hash2)); bits256_str(str,hash2); if ( chain->debug != 0 ) printf("genesis.(%s) zcash.%d len.%d hash.%s\n",chain->genesis_hex,chain->zcash,(int32_t)sizeof(zmsg.zH),str); iguana_blockconv(chain->zcash,chain->auxpow,(void *)block,&zmsg,hash2,0); block->RO.txn_count = 1; block->RO.numvouts = 1; if ( chain->zcash != 0 ) block->RO.allocsize = sizeof(struct iguana_zblock); else block->RO.allocsize = (int32_t)sizeof(*block); iguana_gotdata(coin,0,0); if ( (ptr= iguana_blockhashset("genesis0",coin,0,hash2,1)) != 0 ) { iguana_blockcopy(chain->zcash,chain->auxpow,coin,ptr,block); iguana_blocksizecheck("genesis ptr",chain->zcash,ptr); ptr->mainchain = 1; ptr->height = 0; //coin->blocks.RO[0] = block.RO; if ( coin->virtualchain != 0 || (height= iguana_chainextend(myinfo,coin,ptr)) == 0 ) { iguana_blockzcopy(chain->zcash,block,ptr); iguana_blockzcopy(chain->zcash,(void *)&coin->blocks.hwmchain,ptr); printf("size.%d genesis block PoW %f ptr %f\n",block->RO.allocsize,block->PoW,ptr->PoW); 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"); return(hash2); } int32_t iguana_savehdrs(struct iguana_info *coin) { char fname[512],shastr[65],tmpfname[512],tmpfname2[512],str2[65],str[65],oldfname[512]; bits256 sha256all; FILE *fp=0,*fp2=0; struct iguana_bundle *bp; int32_t hdrsi,n,retval = 0; n = coin->blocks.hwmchain.height + 1; sprintf(tmpfname,"%s/%s/hdrs.txt",GLOBAL_TMPDIR,coin->symbol), OS_compatible_path(tmpfname); sprintf(tmpfname2,"%s/%s/hdrs.h",GLOBAL_TMPDIR,coin->symbol), OS_compatible_path(tmpfname); sprintf(oldfname,"%s/%s_oldhdrs.txt",GLOBAL_CONFSDIR,coin->symbol), OS_compatible_path(oldfname); sprintf(fname,"%s/%s_hdrs.txt",GLOBAL_CONFSDIR,coin->symbol), OS_compatible_path(fname); if ( (fp= fopen(tmpfname,"w")) != 0 ) { if ( (fp2= fopen(tmpfname2,"w")) != 0 ) fprintf(fp2,"char *%s_hdrs[][4] = {\n",coin->symbol); fprintf(fp,"%d\n",n); for (hdrsi=0; hdrsibundlescount; hdrsi++) { if ( (bp= coin->bundles[hdrsi]) != 0 && bp->numhashes >= bp->n ) { shastr[0] = 0; if ( bits256_nonz(bp->allhash) == 0 ) { vcalc_sha256(shastr,sha256all.bytes,bp->hashes[0].bytes,sizeof(*bp->hashes) * coin->chain->bundlesize); bp->allhash = sha256all; } else { sha256all = bp->allhash; bits256_str(shastr,bp->allhash); } fprintf(fp,"%d %s %s %s\n",bp->bundleheight,bits256_str(str,bp->hashes[0]),shastr,bits256_str(str2,bp->hashes[1])); if ( fp2 != 0 ) fprintf(fp2,"{ \"%d\", \"%s\", \"%s\", \"%s\"},\n",bp->bundleheight,bits256_str(str,bp->hashes[0]),shastr,bits256_str(str2,bp->hashes[1])); } else { if ( bp != 0 && bits256_nonz(bp->hashes[0]) != 0 ) { fprintf(fp,"%d %s\n",bp->bundleheight,bits256_str(str,bp->hashes[0])); if ( fp2 != 0 ) fprintf(fp2,"{ \"%d\", \"%s\", \"%s\", \"%s\"},\n",bp->bundleheight,bits256_str(str,bp->hashes[0]),"",""); } break; } } //printf("compare hdrs.txt %ld vs (%s) %ld\n",ftell(fp),fname,(long)OS_filesize(fname)); if ( (long)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_renamefile(tmpfname,fname); //OS_copyfile(tmpfname,fname,1); } else fclose(fp); if ( fp2 != 0 ) { fprintf(fp2,"};\n"); fclose(fp2); } } else { printf("iguana_savehdrs: couldnt create.(%s)\n",tmpfname); return(-1); } return(retval); } int32_t iguana_bundleinitmap(struct supernet_info *myinfo,struct iguana_info *coin,struct iguana_bundle *bp,int32_t height,bits256 hash2,bits256 hash1) { char str[65]; struct iguana_block *block; bp->bundleheight = height; if ( bits256_nonz(hash1) != 0 ) { if ( (block= iguana_blockhashset("inithash1",coin,height+1,hash1,1)) != 0 ) { iguana_bundlehashadd(coin,bp,1,block); block->mainchain = 1; } } if ( height == 0 && coin->current == 0 ) coin->current = coin->bundles[0] = bp; if ( (block= iguana_blockfind("parse",coin,hash2)) != 0 ) block->mainchain = 1, block->height = height; if ( iguana_bundleload(myinfo,coin,&bp->ramchain,bp,2) != 0 ) { if ( coin->current != 0 && coin->current->hdrsi+1 == bp->hdrsi ) coin->current = bp; bp->emitfinish = (uint32_t)time(NULL) + 1; //printf("[%d].%p ",bp->hdrsi,bp->ramchain.H.data); return(0); } else { init_hexbytes_noT(str,hash2.bytes,sizeof(hash2)); bp->emitfinish = 0; iguana_blockQ("init",coin,bp,0,hash2,1); //printf("init reqhdrs.%d\n",bp->bundleheight); //queue_enqueue("hdrsQ",&coin->hdrsQ,queueitem(str),1); memset(&hash2,0,sizeof(hash2)); bp->emitfinish = 0; return(-1); } } void iguana_parseline(struct supernet_info *myinfo,struct iguana_info *coin,int32_t iter,FILE *fp) { int32_t j,k,m,c,flag,bundlei,lastheight,missing=0,height = -1; char checkstr[1024],line[1024]; struct iguana_peer *addr; struct iguana_bundle *bp; bits256 allhash,hash2,hash1,zero,lastbundle; if ( coin->FULLNODE == 0 && coin->VALIDATENODE == 0 && iter > 0 ) return; OS_randombytes((uint8_t *)&j,sizeof(j)); if ( j < 0 ) j = -j; srand(j); memset(&zero,0,sizeof(zero)); lastbundle = zero; if ( coin->MAXPEERS > IGUANA_MAXPEERS ) coin->MAXPEERS = IGUANA_MAXPEERS; #ifdef oldway if ( iter == 1 && 0 ) { 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); } } #endif OS_randombytes((void *)&m,sizeof(m)); srand(m); m = flag = 0; allhash = zero; memset(line,0,sizeof(line)); 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 < coin->MAXPEERS/2 ) { if ( 0 && m == 0 && coin->seedipaddr[0] != 0 ) { addr = &coin->peers->active[m++]; iguana_initpeer(coin,addr,(uint32_t)calc_ipbits(coin->seedipaddr)); printf("SEED_IPADDR initpeer.(%s)\n",addr->ipaddr); iguana_launch(coin,"connection",iguana_startconnection,addr,IGUANA_CONNTHREAD); } #ifndef IGUANA_DISABLEPEERS //if ( (rand() % 2) == 0 ) { 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); } //else #endif } iguana_possible_peer(coin,line); } else { lastheight = height = -1; if ( coin->bundlescount > 0 && (bp= coin->bundles[coin->bundlescount - 1]) != 0 ) lastheight = bp->bundleheight, lastbundle = bp->hashes[0]; for (k=height=0; k= '0' && c <= '9' ) height = (height * 10) + (line[k] - '0'); else break; } if ( line[k] == ' ' ) { decode_hex(hash2.bytes,sizeof(hash2),line+k+1); if ( coin->virtualchain != 0 ) printf("%s line.(%s) k.%d (%c)(%c)(%d)\n",coin->symbol,line,k,line[k+63],line[k+64],line[k+65]); if ( height >= 0 && bits256_nonz(hash2) != 0 ) { if ( (bp= iguana_bundlecreate(coin,&bundlei,height,hash2,zero,0)) != 0 ) { //printf("created bundle.%d\n",bp->hdrsi); memset(hash1.bytes,0,sizeof(hash1)); iguana_bundleinitmap(myinfo,coin,bp,height,hash2,hash1); lastbundle = hash2; } } if ( line[k + 65] != 0 && line[k+65] != '\n' && line[k+65] != '\r' ) { //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)); //printf("parseline: k.%d %d height.%d m.%d bundlesize.%d (%s) check.(%s)\n",k,line[k],height,m,coin->chain->bundlesize,&line[k+1+65],checkstr);// + strlen(line+k+1)]); if ( strncmp(checkstr,line+k+1 + 64 + 1,64) == 0 ) { init_hexbytes_noT(checkstr,hash2.bytes,sizeof(hash2)); if ( strlen(line+k+1 + 2*64 + 2) == sizeof(hash1)*2 ) decode_hex(hash1.bytes,sizeof(hash1),line+k+1 + 2*64 + 2); else memset(hash1.bytes,0,sizeof(hash1)); if ( coin->virtualchain != 0 ) memset(hash1.bytes,0,sizeof(hash1)); //char str[65],str2[65]; printf(">>>> %s bundle.%d last.%d got (%s)/(%s) allhash.(%s)\n",coin->symbol,height,lastheight,bits256_str(str,hash1),checkstr,bits256_str(str2,allhash)); if ( (bp= iguana_bundlecreate(coin,&bundlei,height,hash2,allhash,0)) != 0 ) { if ( bits256_cmp(allhash,bp->allhash) != 0 ) { printf("mismatched allhash.[%d]\n",bp->hdrsi); bp->allhash = allhash; } if ( height >= lastheight ) { if ( iguana_bundleinitmap(myinfo,coin,bp,height,hash2,hash1) == 0 ) lastbundle = hash2, lastheight = height; else if ( missing++ > coin->MAXBUNDLES && strcmp("BTCD",coin->symbol) != 0 ) { printf("missing.%d\n",missing); break; } } } } } } } memset(line,0,sizeof(line)); } if ( iter == 1 && bits256_nonz(lastbundle) != 0 ) { printf("%s parseline ht.%d\n",coin->symbol,lastheight); iguana_initfinal(myinfo,coin,lastbundle); } } long iguana_bundlesload(struct supernet_info *myinfo,struct iguana_info *coin) { char fname[1024]; int32_t iter; FILE *fp; long fpos = -1; for (iter=0; iter<2; iter++) { sprintf(fname,"%s/%s_%s.txt",GLOBAL_CONFSDIR,coin->symbol,(iter == 0) ? "hdrs" : "oldhdrs"), OS_compatible_path(fname); if ( (fp= fopen(fname,"r")) != 0 ) { iguana_parseline(myinfo,coin,1,fp); printf("done parsefile.%d (%s) size.%ld\n",iter,fname,fpos); fpos = ftell(fp); fclose(fp); break; } } return(fpos); } void iguana_ramchainpurge(struct iguana_info *coin,struct iguana_bundle *bp,struct iguana_ramchain *ramchain) { iguana_ramchain_free(coin,ramchain,1); } void iguana_bundlepurge(struct iguana_info *coin,struct iguana_bundle *bp) { int32_t i; static const bits256 zero; iguana_ramchainpurge(coin,bp,&bp->ramchain); if ( bp->speculative != 0 ) { for (i=0; in; i++) if ( bp->speculativecache[i] != 0 ) { free(bp->speculativecache[i]); bp->speculativecache[i] = 0; } myfree(bp->speculative,sizeof(*bp->speculative) * bp->numspec); } bp->numspec = 0; bp->speculative = 0; memset(bp->hashes,0,sizeof(bp->hashes)); memset(bp->issued,0,sizeof(bp->issued)); bp->prevbundlehash2 = bp->nextbundlehash2 = bp->allhash = zero; } void iguana_blockpurge(struct iguana_info *coin,struct iguana_block *block) { if ( block->req != 0 ) { printf("purge req inside block\n"); myfree(block->req,block->req->allocsize); } free(block); } void iguana_blockspurge(struct iguana_info *coin) { struct iguana_block *block,*tmp; if ( 1 && coin->blocks.hash != 0 ) { HASH_ITER(hh,coin->blocks.hash,block,tmp) { HASH_DEL(coin->blocks.hash,block); iguana_blockpurge(coin,block); } coin->blocks.hash = 0; } coin->blocks.maxblocks = coin->blocks.initblocks = coin->blocks.hashblocks = coin->blocks.issuedblocks = coin->blocks.recvblocks = coin->blocks.emitblocks = coin->blocks.parsedblocks = coin->blocks.dirty = 0; printf("clear hwmchain\n"); memset(&coin->blocks.hwmchain,0,sizeof(coin->blocks.hwmchain)); } void iguana_coinpurge(struct iguana_info *coin) { int32_t i,saved; struct iguana_bundle *bp; struct iguana_bundlereq *req; struct iguana_blockreq *breq; struct iguana_helper *ptr; struct stritem *hashitem; saved = coin->active, coin->active = 0; coin->started = 0; while ( coin->idletime == 0 && coin->emitbusy > 0 ) { printf("coinpurge.%s waiting for idle %u emitbusy.%d\n",coin->symbol,(uint32_t)time(NULL),coin->emitbusy); sleep(1); } coin->RTgenesis = 0; while ( (ptr= queue_dequeue(&bundlesQ)) != 0 ) myfree(ptr,ptr->allocsize); if ( 1 ) { while ( (hashitem= queue_dequeue(&coin->hdrsQ)) != 0 ) free(hashitem); while ( (breq= queue_dequeue(&coin->blocksQ)) != 0 ) myfree(breq,sizeof(*breq)); while ( (breq= queue_dequeue(&coin->priorityQ)) != 0 ) myfree(breq,sizeof(*breq)); while ( (req= queue_dequeue(&coin->cacheQ)) != 0 ) myfree(req,req->allocsize); while ( (req= queue_dequeue(&coin->recvQ)) != 0 ) { if ( req->blocks != 0 ) myfree(req->blocks,sizeof(*req->blocks) * req->n), req->blocks = 0; if ( req->hashes != 0 ) myfree(req->hashes,sizeof(*req->hashes) * req->n), req->hashes = 0; myfree(req,req->allocsize); } } //iguana_RTramchainfree(coin,coin->current); iguana_RTdataset_free(coin); coin->bundlescount = 0; for (i=0; ibundlescount; i++) if ( (bp= coin->bundles[i]) != 0 ) iguana_bundlepurge(coin,bp); coin->current = coin->lastpending = 0; memset(coin->bundles,0,sizeof(coin->bundles)); iguana_blockspurge(coin); coin->active = saved; } int32_t iguana_isnotarychain(char *symbol) { int32_t i,n,notarychain = -1; char *jsonstr; cJSON *chains; if ( (jsonstr= dpow_notarychains(0,0,0,0)) != 0 ) { if ( (chains= cJSON_Parse(jsonstr)) != 0 ) { if ( (n= cJSON_GetArraySize(chains)) > 0 ) { for (i=0; ipeers == 0 ) { printf("cant start privatechain directly\n"); return(0); }*/ coin->sleeptime = 10000; symbol = coin->symbol; if ( coin->peers != 0 && iguana_peerslotinit(coin,&coin->internaladdr,IGUANA_MAXPEERS,calc_ipbits("127.0.0.1:7777")) < 0 ) { printf("iguana_coinstart: error creating peerslot\n"); return(0); } if ( initialheight < coin->chain->bundlesize*10 ) initialheight = coin->chain->bundlesize*10; if ( coin->longestchain == 0 ) coin->longestchain = 1; memset(&coin->blocks.hwmchain,0,sizeof(coin->blocks.hwmchain)); coin->blocks.hwmchain.height = 0; coin->blocks.hwmchain.RO.allocsize = coin->chain->zcash != 0 ? sizeof(struct iguana_zblock) : sizeof(struct iguana_block); printf("%s MYSERVICES.%llx\n",coin->symbol,(long long)coin->myservices); if ( coin->virtualchain == 0 && coin->peers != 0 ) { if ( myinfo->IAMNOTARY != 0 || (coin->myservices & NODE_NETWORK) != 0 || (coin->FULLNODE > 0 || coin->VALIDATENODE > 0) ) { if ( coin->peers->acceptloop == 0 && coin->peers->localaddr == 0 ) { 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); } } } if ( coin->rpcloop == 0 && strcmp(coin->chain->symbol,"RELAY") != 0 ) { myinfo->argport = coin->chain->rpcport; coin->rpcloop = malloc(sizeof(pthread_t)); if ( OS_thread_create(coin->rpcloop,NULL,(void *)iguana_rpcloop,(void *)myinfo) != 0 ) { free(coin->rpcloop); coin->rpcloop = 0; printf("error launching rpcloop for %s port.%u\n",coin->symbol,coin->chain->rpcport); } } } if ( (coin->notarychain= iguana_isnotarychain(coin->symbol)) >= 0 && coin->FULLNODE == 0 ) { printf("SET %s NOTARYCHAIN.%d\n",coin->symbol,coin->notarychain); return(coin); } //coin->firstblock = coin->blocks.parsedblocks + 1; iguana_genesis(myinfo,coin,coin->chain); int32_t bundlei = -2; static const bits256 zero; iguana_bundlecreate(coin,&bundlei,0,*(bits256 *)coin->chain->genesis_hashdata,zero,1); if ( coin->virtualchain == 0 ) { _iguana_chainlink(myinfo,coin,iguana_blockfind("genesis",coin,*(bits256 *)coin->chain->genesis_hashdata)); if ( coin->blocks.hwmchain.height != 0 || memcmp(coin->blocks.hwmchain.RO.hash2.bytes,coin->chain->genesis_hashdata,sizeof(coin->chain->genesis_hashdata)) != 0 ) { char str[65]; printf("%s genesis values mismatch hwmheight.%d %.15f %.15f %s\n",coin->name,coin->blocks.hwmchain.height,coin->blocks.hwmchain.PoW,coin->blocks.hwmchain.PoW,bits256_str(str,coin->blocks.hwmchain.RO.hash2)); getchar(); } } memset(&lastbundle,0,sizeof(lastbundle)); if ( coin->peers == 0 ) iter = 2; else iter = (coin->peers->numranked > 8); for (; iter<2; iter++) { #ifdef __PNACL__ if ( iter == 0 ) { char **ipaddrs = 0; int32_t j,num; char *BTC_ipaddrs[] = { "5.9.102.210", "130.211.146.81", "176.9.29.76", "108.58.252.82", "148.251.151.48", "74.207.233.193" }; char *BTCD_ipaddrs[] = { "5.9.102.210", "89.248.160.236", "89.248.160.237", "89.248.160.238", "89.248.160.239", "89.248.160.240", "89.248.160.241", "89.248.160.242", "89.248.160.243", "89.248.160.244", "89.248.160.245", "78.47.58.62", "67.212.70.88", "94.102.50.69", "50.179.58.158", "194.135.94.30", "109.236.85.42", "104.236.127.154", "68.45.147.145", "37.59.14.7", "78.47.115.250", "188.40.138.8", "62.75.143.120", "82.241.71.230", "217.23.6.2", "73.28.172.128", "45.55.149.34", "192.0.242.54", "81.181.155.53", "91.66.185.97", "85.25.217.233", "144.76.239.66", "95.80.9.112", "80.162.193.118", "173.65.129.85", "2.26.173.58", "78.14.250.69", "188.226.253.77", "58.107.67.39", "124.191.37.212", "176.226.137.238", "69.145.25.85", "24.168.14.28", "73.201.180.47", "76.188.171.53", "63.247.147.166", "121.108.241.247", "36.74.36.125", "106.186.119.171", "188.166.91.37", "223.134.228.208", "89.248.160.244", "178.33.209.212", "71.53.156.38", "88.198.10.165", "24.117.221.0", "74.14.104.57", "158.69.27.82", "110.174.129.213", "75.130.163.51" }; if ( strcmp(coin->symbol,"BTCD") == 0 ) ipaddrs = BTCD_ipaddrs, num = (int32_t)(sizeof(BTCD_ipaddrs)/sizeof(*BTCD_ipaddrs)); else if ( strcmp(coin->symbol,"BTC") == 0 ) ipaddrs = BTC_ipaddrs, num = (int32_t)(sizeof(BTC_ipaddrs)/sizeof(*BTC_ipaddrs)); if ( ipaddrs != 0 && coin->virtualchain == 0 ) { for (j=0; jsymbol, j == 0 ? "" : "old", (iter == 0) ? "peers" : "hdrs"), OS_compatible_path(fname); #else sprintf(fname,"%s/%s_%s%s.txt",GLOBAL_CONFSDIR,coin->symbol,j==0?"":"old",(iter == 0) ? "peers" : "hdrs"), OS_compatible_path(fname); #endif //sprintf(fname,"confs/%s_%s.txt",coin->symbol,(iter == 0) ? "peers" : "hdrs"); //sprintf(fname,"tmp/%s/%s.txt",coin->symbol,(iter == 0) ? "peers" : "hdrs"); OS_compatible_path(fname); printf("check.(%s)\n",fname); if ( (fp= fopen(fname,"r")) != 0 ) { if ( coin->virtualchain == 0 || iter > 0 ) { printf("parsefile.%d %s\n",iter,fname); iguana_parseline(myinfo,coin,iter,fp); printf("done parsefile.%d (%s) size.%ld\n",iter,fname,fpos); } fpos = ftell(fp); fclose(fp); break; } } } #ifndef IGUANA_DEDICATED_THREADS coin->peers->peersloop = iguana_launch("peersloop",iguana_peersloop,coin,IGUANA_PERMTHREAD); #endif printf("started.%s %p active.%d\n",coin->symbol,coin->started,coin->active); return(coin); }