From 0ca4561fc11cfca6a9678ee65c26e2a92f03cd29 Mon Sep 17 00:00:00 2001 From: jl777 Date: Sun, 18 Jun 2017 21:30:55 +0300 Subject: [PATCH] test --- iguana/exchanges/LP_nativeDEX.c | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) diff --git a/iguana/exchanges/LP_nativeDEX.c b/iguana/exchanges/LP_nativeDEX.c index 1949357a9..bc6c7a40f 100644 --- a/iguana/exchanges/LP_nativeDEX.c +++ b/iguana/exchanges/LP_nativeDEX.c @@ -344,9 +344,19 @@ void LP_mainloop(char *myipaddr,struct LP_peerinfo *mypeer,uint16_t mypubport,in } } -void nn_tests() +void nn_tests(char *pushaddr) { - nn_socket(AF_SP,NN_BUS); + int32_t sock,n; + if ( (sock= nn_socket(AF_SP,NN_PUSH)) >= 0 ) + { + if ( nn_connect(sock,pushaddr) < 0 ) + printf("connect error %s\n",nn_strerror(nn_errno())); + else + { + n = LP_send(sock,"nn_tests",0); + printf("sent %d bytes\n",n); + } + } } void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,double profitmargin,char *passphrase,int32_t amclient,char *userhome,cJSON *argjson) @@ -387,7 +397,6 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,double profit } else printf("error getting myipaddr\n"); } else printf("error issuing curl\n"); nanomsg_tcpname(pushaddr,myipaddr,mypullport); - nn_tests(); if ( (pullsock= nn_socket(AF_SP,NN_PULL)) >= 0 ) { nanomsg_tcpname(bindaddr,"0.0.0.0",mypullport); @@ -399,6 +408,7 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,double profit //nn_setsockopt(pullsock,NN_SOL_SOCKET,NN_RCVBUF,&maxsize,sizeof(maxsize)); } else printf("bind to %s error for %s: %s\n",bindaddr,pushaddr,nn_strerror(nn_errno())); } + nn_tests(pushaddr); printf("my command address is (%s) pullsock.%d\n",pushaddr,pullsock); if ( IAMLP != 0 ) {