jl777 7 years ago
parent
commit
bbcf8414a7
  1. 67
      iguana/exchanges/LP_nativeDEX.c

67
iguana/exchanges/LP_nativeDEX.c

@ -616,17 +616,6 @@ int32_t LP_mainloop_iter(void *ctx,char *myipaddr,struct LP_peerinfo *mypeer,int
needpings++; needpings++;
} }
} }
if ( needpings != 0 || (counter % 10000) == 5 )
{
nonz++;
//printf("needpings.%d send notify\n",needpings);
LP_notify_pubkeys(ctx,pubsock);
}
if ( (counter % 6000) == 10 )
{
nonz++;
LP_privkey_updates(ctx,pubsock,0);
}
HASH_ITER(hh,LP_coins,coin,ctmp) // firstrefht,firstscanht,lastscanht HASH_ITER(hh,LP_coins,coin,ctmp) // firstrefht,firstscanht,lastscanht
{ {
if ( coin->addr_listunspent_requested != 0 ) if ( coin->addr_listunspent_requested != 0 )
@ -647,15 +636,6 @@ int32_t LP_mainloop_iter(void *ctx,char *myipaddr,struct LP_peerinfo *mypeer,int
coin->lastgetinfo = (uint32_t)time(NULL); coin->lastgetinfo = (uint32_t)time(NULL);
} }
} }
if ( (counter % 100000) == 90000 )
{
if ( (retstr= basilisk_swapentry(0,0)) != 0 )
{
//printf("SWAPS.(%s)\n",retstr);
nonz++;
free(retstr);
}
}
counter++; counter++;
return(nonz); return(nonz);
} }
@ -722,6 +702,38 @@ void LP_initpeers(int32_t pubsock,struct LP_peerinfo *mypeer,char *myipaddr,uint
} }
} }
void LP_pubkeysloop(void *ctx)
{
sleep(10);
while ( 1 )
{
LP_notify_pubkeys(ctx,LP_mypubsock);
sleep(60);
}
}
void LP_privkeysloop(void *ctx)
{
sleep(20);
while ( 1 )
{
LP_privkey_updates(ctx,LP_mypubsock,0);
sleep(60);
}
}
void LP_swapsloop(void *ignore)
{
char *retstr;
sleep(50);
while ( 1 )
{
if ( (retstr= basilisk_swapentry(0,0)) != 0 )
free(retstr);
sleep(600);
}
}
void LP_reserved_msgs(void *ignore) void LP_reserved_msgs(void *ignore)
{ {
bits256 zero; int32_t flag; struct nn_pollfd pfd; bits256 zero; int32_t flag; struct nn_pollfd pfd;
@ -939,6 +951,21 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,uint16_t mybu
printf("error launching LP_coinsloop for port.%u\n",myport); printf("error launching LP_coinsloop for port.%u\n",myport);
exit(-1); exit(-1);
} }
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)LP_pubkeysloop,(void *)&myipaddr) != 0 )
{
printf("error launching LP_pubkeysloop for ctx.%p\n",ctx);
exit(-1);
}
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)LP_privkeysloop,(void *)&myipaddr) != 0 )
{
printf("error launching LP_privkeysloop for ctx.%p\n",ctx);
exit(-1);
}
if ( OS_thread_create(malloc(sizeof(pthread_t)),NULL,(void *)LP_swapsloop,(void *)&myipaddr) != 0 )
{
printf("error launching LP_swapsloop for port.%u\n",myport);
exit(-1);
}
//if ( (retstr= basilisk_swapentry(0,0)) != 0 ) //if ( (retstr= basilisk_swapentry(0,0)) != 0 )
// free(retstr); // free(retstr);
int32_t nonz; int32_t nonz;

Loading…
Cancel
Save