diff --git a/iguana/exchanges/LP_nativeDEX.c b/iguana/exchanges/LP_nativeDEX.c index 6d2fc9368..f8811e832 100644 --- a/iguana/exchanges/LP_nativeDEX.c +++ b/iguana/exchanges/LP_nativeDEX.c @@ -349,7 +349,7 @@ void LP_mainloop(char *myipaddr,struct LP_peerinfo *mypeer,uint16_t mypubport,in void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,double profitmargin,char *passphrase,int32_t amclient,char *userhome,cJSON *argjson) { - char *myipaddr=0; long filesize,n; int32_t timeout,maxsize,pullsock=-1,pubsock=-1; struct LP_peerinfo *mypeer=0; char pushaddr[128],subaddr[128]; + char *myipaddr=0; long filesize,n; int32_t timeout,pullsock=-1,pubsock=-1; struct LP_peerinfo *mypeer=0; char pushaddr[128],subaddr[128]; IAMLP = !amclient; LP_profitratio += profitmargin; OS_randombytes((void *)&n,sizeof(n)); diff --git a/iguana/exchanges/LP_network.c b/iguana/exchanges/LP_network.c index 6b83a356f..b2f820216 100644 --- a/iguana/exchanges/LP_network.c +++ b/iguana/exchanges/LP_network.c @@ -40,7 +40,7 @@ int32_t LP_send(int32_t sock,char *msg,int32_t freeflag) { pfd.fd = sock; pfd.events = NN_POLLOUT; - portable_mutex_lock(&LP_networkmutex); + //portable_mutex_lock(&LP_networkmutex); if ( nn_poll(&pfd,1,1) > 0 ) { if ( (sentbytes= nn_send(sock,msg,len,0)) != len ) @@ -48,10 +48,10 @@ int32_t LP_send(int32_t sock,char *msg,int32_t freeflag) //else printf("SENT.(%s)\n",msg); if ( freeflag != 0 ) free(msg); - portable_mutex_unlock(&LP_networkmutex); + //portable_mutex_unlock(&LP_networkmutex); return(sentbytes); } - portable_mutex_unlock(&LP_networkmutex); + //portable_mutex_unlock(&LP_networkmutex); usleep(1000); } printf("error LP_send sock.%d, pipeline timeout.(%s) %s\n",sock,msg,nn_strerror(nn_errno()));