Merge pull request #429 from jl777/spvdex

Spvdex

iguana/exchanges/LP_nativeDEX.c

@@ -926,12 +926,12 @@ int32_t LP_reserved_msg(int32_t priority,char *base,char *rel,bits256 pubkey,cha
         Reserved_msgs[priority][num_Reserved_msgs[priority]++] = msg;
         n = num_Reserved_msgs[priority];
     } else LP_broadcast_message(LP_mypubsock,base,rel,pubkey,msg);
-    portable_mutex_unlock(&LP_reservedmutex);
     if ( num_Reserved_msgs[priority] > max_Reserved_msgs[priority] )
     {
         max_Reserved_msgs[priority] = num_Reserved_msgs[priority];
         printf("New priority.%d max_Reserved_msgs.%d\n",priority,max_Reserved_msgs[priority]);
     }
+    portable_mutex_unlock(&LP_reservedmutex);
     return(n);
 }
 

iguana/exchanges/LP_signatures.c

@@ -685,11 +685,10 @@ void LP_query(void *ctx,char *myipaddr,int32_t mypubsock,char *method,struct LP_
     memset(&zero,0,sizeof(zero));
     portable_mutex_lock(&LP_reservedmutex);
     if ( num_Reserved_msgs[1] < sizeof(Reserved_msgs[1])/sizeof(*Reserved_msgs[1])-2 )
-    {
         Reserved_msgs[1][num_Reserved_msgs[1]++] = msg;
-        //Reserved_msgs[num_Reserved_msgs++] = msg2;
-    }
-    LP_broadcast_message(LP_mypubsock,qp->srccoin,qp->destcoin,zero,msg2);
+    if ( num_Reserved_msgs[0] < sizeof(Reserved_msgs[0])/sizeof(*Reserved_msgs[0])-2 )
+        Reserved_msgs[0][num_Reserved_msgs[0]++] = msg2;
+    //LP_broadcast_message(LP_mypubsock,qp->srccoin,qp->destcoin,zero,msg2);
     portable_mutex_unlock(&LP_reservedmutex);
 }
 

iguana/exchanges/stats.c

@@ -780,7 +780,7 @@ void stats_rpcloop(void *args)
             printf("error launching rpc handler on port %d\n",port);
             // yes, small leak per command
         }
-        if ( IAMLP != 0 && ipbits != localhostbits )
+        if ( 0 && IAMLP != 0 && ipbits != localhostbits )
         {
             close(bindsock);
             bindsock = iguana_socket(1,"0.0.0.0",port);