From fad2841f0aebf5b29a48292ba334620c67fdb50d Mon Sep 17 00:00:00 2001 From: jl777 Date: Tue, 20 Jun 2017 11:34:20 +0300 Subject: [PATCH] test --- iguana/exchanges/LP_nativeDEX.c | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/iguana/exchanges/LP_nativeDEX.c b/iguana/exchanges/LP_nativeDEX.c index 10b06b80d..1743f8e42 100644 --- a/iguana/exchanges/LP_nativeDEX.c +++ b/iguana/exchanges/LP_nativeDEX.c @@ -156,14 +156,17 @@ char *LP_process_message(char *typestr,char *myipaddr,int32_t pubsock,double pro int32_t LP_pullsock_check(char **retstrp,char *myipaddr,int32_t pubsock,int32_t pullsock,double profitmargin) { - void *ptr; int32_t recvlen,nonz = 0; + void *ptr; int32_t recvlen=-1,nonz = 0; *retstrp = 0; - while ( pullsock >= 0 && (recvlen= nn_recv(pullsock,&ptr,NN_MSG,0)) >= 0 ) + while ( pullsock >= 0 ) { - if ( IAMLP == 0 ) - printf("pullsock.%d recv.%d (%s)\n",pullsock,recvlen,(char *)ptr); - nonz++; - *retstrp = LP_process_message("PULL",myipaddr,pubsock,profitmargin,ptr,recvlen,pullsock); + if ( (recvlen= nn_recv(pullsock,&ptr,NN_MSG,0)) >= 0 ) + { + if ( IAMLP == 0 ) + printf("pullsock.%d recv.%d (%s)\n",pullsock,recvlen,(char *)ptr); + nonz++; + *retstrp = LP_process_message("PULL",myipaddr,pubsock,profitmargin,ptr,recvlen,pullsock); + } else printf("pullsock.%d recvlen.%d\n",pullsock,recvlen); } return(nonz); }