From 59e5da2feef61650a34866f96227bbe756b2ecb2 Mon Sep 17 00:00:00 2001 From: jl777 Date: Fri, 13 Oct 2017 17:58:40 +0300 Subject: [PATCH] Test --- iguana/exchanges/LP_nativeDEX.c | 24 +++++++++++++++++------- 1 file changed, 17 insertions(+), 7 deletions(-) diff --git a/iguana/exchanges/LP_nativeDEX.c b/iguana/exchanges/LP_nativeDEX.c index c0b202599..24a612c22 100644 --- a/iguana/exchanges/LP_nativeDEX.c +++ b/iguana/exchanges/LP_nativeDEX.c @@ -483,6 +483,7 @@ int32_t LP_mainloop_iter(void *ctx,char *myipaddr,struct LP_peerinfo *mypeer,int { if ( strcmp(peer->ipaddr,myipaddr) != 0 ) { + nonz++; LP_peersquery(mypeer,pubsock,peer->ipaddr,peer->port,myipaddr,myport); peer->diduquery = 0; LP_utxos_sync(peer); @@ -491,6 +492,7 @@ int32_t LP_mainloop_iter(void *ctx,char *myipaddr,struct LP_peerinfo *mypeer,int } if ( peer->diduquery == 0 ) { + nonz++; needpings++; LP_peer_pricesquery(peer); LP_utxos_sync(peer); @@ -498,6 +500,7 @@ int32_t LP_mainloop_iter(void *ctx,char *myipaddr,struct LP_peerinfo *mypeer,int } if ( peer->needping != 0 ) { + nonz++; needpings++; if ( (retstr= issue_LP_notify(peer->ipaddr,peer->port,"127.0.0.1",0,numpeers,G.LP_sessionid,G.LP_myrmd160str,G.LP_mypub25519)) != 0 ) free(retstr); @@ -506,15 +509,13 @@ int32_t LP_mainloop_iter(void *ctx,char *myipaddr,struct LP_peerinfo *mypeer,int } if ( needpings != 0 || (counter % 6000) == 5 ) { - //printf("needpings.%d send notify\n",needpings); + nonz++; + printf("needpings.%d send notify\n",needpings); LP_notify_pubkeys(ctx,pubsock); - HASH_ITER(hh,LP_coins,coin,ctmp) - { - LP_smartutxos_push(coin); - } } if ( (counter % 6000) == 10 ) { + nonz++; LP_privkey_updates(ctx,pubsock,0); } HASH_ITER(hh,LP_coins,coin,ctmp) // firstrefht,firstscanht,lastscanht @@ -522,12 +523,18 @@ int32_t LP_mainloop_iter(void *ctx,char *myipaddr,struct LP_peerinfo *mypeer,int memset(&zero,0,sizeof(zero)); if ( coin->inactive != 0 ) continue; + if ( (counter % 6000) == 100 ) + { + LP_smartutxos_push(coin); + nonz++; + } if ( coin->electrum != 0 ) continue; //if ( coin->obooktime == 0 ) // continue; if ( time(NULL) > coin->lastgetinfo+LP_GETINFO_INCR ) { + nonz++; if ( (height= LP_getheight(coin)) > coin->longestchain ) { coin->longestchain = height; @@ -572,6 +579,7 @@ int32_t LP_mainloop_iter(void *ctx,char *myipaddr,struct LP_peerinfo *mypeer,int } if ( j < 100 ) continue; + nonz++; //LP_getestimatedrate(coin); break; } @@ -580,6 +588,7 @@ int32_t LP_mainloop_iter(void *ctx,char *myipaddr,struct LP_peerinfo *mypeer,int if ( (retstr= basilisk_swapentry(0,0)) != 0 ) { //printf("SWAPS.(%s)\n",retstr); + nonz++; free(retstr); } } @@ -816,8 +825,9 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,uint16_t mybu if ( LP_mainloop_iter(ctx,myipaddr,mypeer,pubsock,pushaddr,myport) != 0 ) nonz++; if ( nonz == 0 ) - usleep(50000); - else usleep(5000); + usleep(1000); + else if ( IAMLP == 0 ) + usleep(10000); } }