diff --git a/iguana/exchanges/LP_nativeDEX.c b/iguana/exchanges/LP_nativeDEX.c index 2874b4679..0be040be1 100644 --- a/iguana/exchanges/LP_nativeDEX.c +++ b/iguana/exchanges/LP_nativeDEX.c @@ -699,21 +699,24 @@ void LP_initpeers(int32_t pubsock,struct LP_peerinfo *mypeer,char *myipaddr,uint int32_t LP_reserved_msgs() { - bits256 zero; struct nn_pollfd pfd; int32_t n = 0; + 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 ) + if ( 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]); LP_broadcast_message(LP_mypubsock,"","",zero,Reserved_msgs[num_Reserved_msgs]); Reserved_msgs[num_Reserved_msgs] = 0; n++; +#ifdef __APPLE__ + usleep(5000); +#endif } portable_mutex_unlock(&LP_reservedmutex); return(n);