jl777 7 years ago
parent
commit
a0c42948db
  1. 4
      iguana/exchanges/LP_nativeDEX.c
  2. 7
      iguana/exchanges/LP_network.c

4
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);

7
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 )
{

Loading…
Cancel
Save