From 23ad3bd9f69f4e40d3c3d0117c58911a1c16f92c Mon Sep 17 00:00:00 2001 From: jl777 Date: Sun, 22 Oct 2017 17:26:46 +0300 Subject: [PATCH] Test --- iguana/exchanges/LP_nativeDEX.c | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/iguana/exchanges/LP_nativeDEX.c b/iguana/exchanges/LP_nativeDEX.c index aee72a9d0..e81edbd8e 100644 --- a/iguana/exchanges/LP_nativeDEX.c +++ b/iguana/exchanges/LP_nativeDEX.c @@ -675,29 +675,28 @@ void LP_initpeers(int32_t pubsock,struct LP_peerinfo *mypeer,char *myipaddr,uint int32_t LP_reserved_msgs() { - bits256 zero; int32_t n = 0; //struct nn_pollfd pfd; + bits256 zero; int32_t n = 0; struct nn_pollfd pfd; memset(zero.bytes,0,sizeof(zero)); portable_mutex_lock(&LP_reservedmutex); while ( num_Reserved_msgs > 0 ) { - /*memset(&pfd,0,sizeof(pfd)); + memset(&pfd,0,sizeof(pfd)); pfd.fd = LP_mypubsock; pfd.events = NN_POLLOUT; if ( nn_poll(&pfd,1,1) != 1 ) - break;*/ + break; num_Reserved_msgs--; //printf("%d BROADCASTING RESERVED.(%s)\n",num_Reserved_msgs,Reserved_msgs[num_Reserved_msgs]); #ifdef __APPLE__ #endif LP_broadcast_message(LP_mypubsock,"","",zero,Reserved_msgs[num_Reserved_msgs]); Reserved_msgs[num_Reserved_msgs] = 0; -#ifdef __APPLE__ +/*#ifdef __APPLE__ usleep(5000); #else usleep(3000); -#endif - n++; - if ( n > 0 ) +#endif*/ + if ( ++n > 0 ) break; } portable_mutex_unlock(&LP_reservedmutex);