Test

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
+#endif*/
-        n++;
+        if ( ++n > 0 )
-        if ( n > 0 )
             break;
     }
     portable_mutex_unlock(&LP_reservedmutex);