Test

iguana/exchanges/LP_nativeDEX.c

@@ -1029,7 +1029,7 @@ 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);
+    } //else LP_broadcast_message(LP_mypubsock,base,rel,pubkey,msg);
     if ( num_Reserved_msgs[priority] > max_Reserved_msgs[priority] )
     {
         max_Reserved_msgs[priority] = num_Reserved_msgs[priority];

iguana/exchanges/LP_ordermatch.c

@@ -492,11 +492,12 @@ int32_t LP_connectstartbob(void *ctx,int32_t pubsock,cJSON *argjson,char *base,c
                 jaddstr(retjson,"method","connected");
                 jaddstr(retjson,"pair",pairstr);
                 char str[65]; printf("BOB pubsock.%d binds to %d (%s)\n",pubsock,pair,bits256_str(str,qp->desthash));
-                LP_reserved_msg(1,base,rel,qp->desthash,jprint(retjson,0));
                 bits256 zero;
                 memset(zero.bytes,0,sizeof(zero));
                 LP_reserved_msg(1,base,rel,zero,jprint(retjson,0));
-                LP_reserved_msg(0,base,rel,zero,jprint(retjson,0));
+                //sleep(1);
+                //LP_reserved_msg(1,base,rel,qp->desthash,jprint(retjson,0));
+                //LP_reserved_msg(0,base,rel,zero,jprint(retjson,0));
                 free_json(retjson);
                 retval = 0;
             } else printf("error launching swaploop\n");
@@ -1001,11 +1002,11 @@ int32_t LP_tradecommand(void *ctx,char *myipaddr,int32_t pubsock,cJSON *argjson,
                 msg = jprint(retjson,1);
                 printf("return after queued RESERVED: set swappending.%u accept qprice %.8f, min %.8f\n(%s)\n",Q.timestamp + LP_RESERVETIME,qprice,ask,msg);
                 LP_reserved_msg(1,Q.srccoin,Q.destcoin,Q.desthash,clonestr(msg));
-                //sleep(1);
+                sleep(1);
                 bits256 zero;
                 memset(zero.bytes,0,sizeof(zero));
                 LP_reserved_msg(1,Q.srccoin,Q.destcoin,zero,clonestr(msg));
-                LP_reserved_msg(0,Q.srccoin,Q.destcoin,zero,clonestr(msg));
+                //LP_reserved_msg(0,Q.srccoin,Q.destcoin,zero,clonestr(msg));
                 free(msg);
                 butxo->T.lasttime = (uint32_t)time(NULL);
                 return(retval);

iguana/exchanges/LP_signatures.c

@@ -728,6 +728,7 @@ void LP_query(void *ctx,char *myipaddr,int32_t mypubsock,char *method,struct LP_
     {
         memset(&zero,0,sizeof(zero));
         LP_reserved_msg(1,qp->srccoin,qp->destcoin,qp->desthash,clonestr(msg));
+        sleep(1);
         LP_reserved_msg(1,qp->srccoin,qp->destcoin,zero,clonestr(msg));
         //LP_reserved_msg(0,qp->srccoin,qp->destcoin,zero,clonestr(msg));
         free(msg);