|
@ -1544,6 +1544,11 @@ int32_t dpow_nanomsg_update(struct supernet_info *myinfo) |
|
|
int32_t i,n=0,num=0,size,broadcastflag,firstz = -1; char *retstr; uint32_t crc32,r,m; struct dpow_nanomsghdr *np=0; struct dpow_info *dp; struct dpow_block *bp; struct dex_nanomsghdr *dexp = 0; void *freeptr; |
|
|
int32_t i,n=0,num=0,size,broadcastflag,firstz = -1; char *retstr; uint32_t crc32,r,m; struct dpow_nanomsghdr *np=0; struct dpow_info *dp; struct dpow_block *bp; struct dex_nanomsghdr *dexp = 0; void *freeptr; |
|
|
if ( time(NULL) < myinfo->nanoinit+5 || (myinfo->dpowsock < 0 && myinfo->dexsock < 0 && myinfo->repsock < 0) ) |
|
|
if ( time(NULL) < myinfo->nanoinit+5 || (myinfo->dpowsock < 0 && myinfo->dexsock < 0 && myinfo->repsock < 0) ) |
|
|
return(-1); |
|
|
return(-1); |
|
|
|
|
|
if ( myinfo->IAMNOTARY != 0 && myinfo->numnotaries <= 0 ) |
|
|
|
|
|
{ |
|
|
|
|
|
myinfo->numnotaries = komodo_notaries("KMD",myinfo->notaries,-1); |
|
|
|
|
|
printf("INIT with %d notaries\n",myinfo->numnotaries); |
|
|
|
|
|
} |
|
|
portable_mutex_lock(&myinfo->dpowmutex); |
|
|
portable_mutex_lock(&myinfo->dpowmutex); |
|
|
/*for (i=0; i<100; i++)
|
|
|
/*for (i=0; i<100; i++)
|
|
|
{ |
|
|
{ |
|
|