From a0c42948db62b398a86bddd172d3c9faae4d35db Mon Sep 17 00:00:00 2001 From: jl777 Date: Fri, 2 Mar 2018 13:01:51 +0200 Subject: [PATCH] Fix --- iguana/exchanges/LP_nativeDEX.c | 4 ++-- iguana/exchanges/LP_network.c | 7 ++++++- 2 files changed, 8 insertions(+), 3 deletions(-) diff --git a/iguana/exchanges/LP_nativeDEX.c b/iguana/exchanges/LP_nativeDEX.c index 87b481dee..83a88ef15 100644 --- a/iguana/exchanges/LP_nativeDEX.c +++ b/iguana/exchanges/LP_nativeDEX.c @@ -334,7 +334,7 @@ char *LP_process_message(void *ctx,char *typestr,char *myipaddr,int32_t pubsock, } else { - LP_queuecommand(0,jsonstr,pubsock,0); + LP_queuecommand(0,jsonstr,pubsock,0,0); //if ( (retstr= LP_command_process(ctx,myipaddr,pubsock,argjson,&((uint8_t *)ptr)[len],recvlen - len)) != 0 ) //{ //} @@ -417,7 +417,7 @@ int32_t LP_sock_check(char *typestr,void *ctx,char *myipaddr,int32_t pubsock,int //printf("self broadcast.(%s)\n",Broadcaststr); str = Broadcaststr; Broadcaststr = 0; - LP_queuecommand(0,str,pubsock,0); + LP_queuecommand(0,str,pubsock,0,0); /*if ( (argjson= cJSON_Parse(str)) != 0 ) { //portable_mutex_lock(&LP_commandmutex); diff --git a/iguana/exchanges/LP_network.c b/iguana/exchanges/LP_network.c index 48a436706..44498aba2 100644 --- a/iguana/exchanges/LP_network.c +++ b/iguana/exchanges/LP_network.c @@ -449,6 +449,11 @@ void LP_commandQ_loop(void *ctx) //printf("processed.(%s)\n",retstr); if ( ptr->responsesock >= 0 ) { + /*if ( ptr->queueid != 0 ) + { + retjson = cJSON_CreateObject(); + + }*/ if ( (size= nn_send(ptr->responsesock,retstr,(int32_t)strlen(retstr)+1,0)) <= 0 ) printf("error sending result\n"); } @@ -568,7 +573,7 @@ void LP_psockloop(void *_ptr) { sendsock = ptr->sendsock; break; - } else LP_queuecommand(0,(char *)buf,ptr->publicsock,0); + } else LP_queuecommand(0,(char *)buf,ptr->publicsock,0,0); } if ( buf != 0 ) {