jl777 7 years ago
parent
commit
a7ee96aa15
  1. 8
      iguana/exchanges/LP_nativeDEX.c

8
iguana/exchanges/LP_nativeDEX.c

@ -519,15 +519,11 @@ int32_t LP_mainloop_iter(void *ctx,char *myipaddr,struct LP_peerinfo *mypeer,int
} }
peer->lastpeers = now; peer->lastpeers = now;
} }
if ( peer->diduquery == 0 ) if ( peer->diduquery == 0 || peer->needping != 0 )
{ {
nonz++;
LP_peer_pricesquery(peer); LP_peer_pricesquery(peer);
LP_utxos_sync(peer); LP_utxos_sync(peer);
peer->diduquery = now; peer->diduquery = now;
}
if ( peer->needping != 0 )
{
nonz++; nonz++;
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 ) 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); free(retstr);
@ -535,7 +531,7 @@ int32_t LP_mainloop_iter(void *ctx,char *myipaddr,struct LP_peerinfo *mypeer,int
needpings++; needpings++;
} }
} }
if ( needpings != 0 || (counter % 100000) == 5 ) if ( needpings != 0 || (counter % 10000) == 5 )
{ {
nonz++; nonz++;
printf("needpings.%d send notify\n",needpings); printf("needpings.%d send notify\n",needpings);

Loading…
Cancel
Save