|
|
@ -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); |
|
|
|