From 61a14b3b946fa65a9f10ab28453ad650f64d6bd2 Mon Sep 17 00:00:00 2001 From: jl777 Date: Thu, 21 Sep 2017 21:51:38 +0200 Subject: [PATCH] Test --- iguana/exchanges/LP_ordermatch.c | 13 ++++++------- iguana/exchanges/LP_scan.c | 2 +- 2 files changed, 7 insertions(+), 8 deletions(-) diff --git a/iguana/exchanges/LP_ordermatch.c b/iguana/exchanges/LP_ordermatch.c index 4be94c444..3d3a9bdcf 100644 --- a/iguana/exchanges/LP_ordermatch.c +++ b/iguana/exchanges/LP_ordermatch.c @@ -352,16 +352,16 @@ double LP_query(void *ctx,char *myipaddr,int32_t mypubsock,char *method,struct L jaddstr(reqjson,"method",method); msg = jprint(reqjson,1); printf("QUERY.(%s)\n",msg); - if ( strcmp(method,"connect") == 0 ) + memset(&zero,0,sizeof(zero)); + if ( 0 && strcmp(method,"connect") == 0 ) { sleep(3); - memset(&zero,0,sizeof(zero)); LP_broadcast_message(LP_mypubsock,qp->srccoin,qp->destcoin,zero,msg); } else { memset(&zero,0,sizeof(zero)); - LP_broadcast_message(LP_mypubsock,qp->srccoin,qp->destcoin,zero,msg); + LP_broadcast_message(LP_mypubsock,qp->srccoin,qp->destcoin,qp->srchash,msg); for (i=0; i<30; i++) { if ( (price= LP_pricecache(qp,qp->srccoin,qp->destcoin,qp->txid,qp->vout)) > SMALLVAL ) @@ -744,7 +744,7 @@ int32_t LP_tradecommand(void *ctx,char *myipaddr,int32_t pubsock,cJSON *argjson, if ( butxo == 0 || bits256_nonz(butxo->payment.txid) == 0 || bits256_nonz(butxo->deposit.txid) == 0 || butxo->payment.vout < 0 || butxo->deposit.vout < 0 ) { char str[65]; printf("couldnt find bob utxos for autxo %s/v%d %.8f\n",bits256_str(str,autxo->payment.txid),autxo->payment.vout,dstr(autxo->S.satoshis)); - return(-44); + return(1); } printf("TRADECOMMAND.(%s)\n",jprint(argjson,0)); Q.txid = butxo->payment.txid; @@ -785,10 +785,9 @@ int32_t LP_tradecommand(void *ctx,char *myipaddr,int32_t pubsock,cJSON *argjson, bits256 zero; memset(&zero,0,sizeof(zero)); LP_broadcast_message(pubsock,Q.srccoin,Q.destcoin,zero,msg);//butxo->S.otherpubkey,msg); - printf("return after RESERVED\n"); LP_butxo_swapfields_set(butxo); printf("return after RESERVED\n"); - return(0); + return(2); } } else printf("warning swappending.%u swap.%p\n",butxo->T.swappending,butxo->S.swap); } @@ -800,7 +799,7 @@ int32_t LP_tradecommand(void *ctx,char *myipaddr,int32_t pubsock,cJSON *argjson, // validate SPV alice LP_connectstartbob(ctx,pubsock,butxo,argjson,Q.srccoin,Q.destcoin,qprice,&Q); LP_butxo_swapfields_set(butxo); - return(0); + return(3); } else printf("pend.%u swap %p when connect came in (%s)\n",butxo->T.swappending,butxo->S.swap,jprint(argjson,0)); } diff --git a/iguana/exchanges/LP_scan.c b/iguana/exchanges/LP_scan.c index 019767670..7d2bf6dda 100644 --- a/iguana/exchanges/LP_scan.c +++ b/iguana/exchanges/LP_scan.c @@ -478,7 +478,7 @@ int32_t LP_waitmempool(char *symbol,char *coinaddr,bits256 txid,int32_t duration free(array); } } - if ( time(NULL) < expiration ) + if ( time(NULL) > expiration ) break; usleep(500000); }