From a326077dbee98da75e4940a9dfbc9af3a7883360 Mon Sep 17 00:00:00 2001 From: jl777 Date: Tue, 20 Jun 2017 11:36:55 +0300 Subject: [PATCH] Test --- iguana/exchanges/LP_network.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/iguana/exchanges/LP_network.c b/iguana/exchanges/LP_network.c index 8dfdd478f..3ec9983dd 100644 --- a/iguana/exchanges/LP_network.c +++ b/iguana/exchanges/LP_network.c @@ -424,13 +424,13 @@ int32_t LP_initpublicaddr(uint16_t *mypullportp,char *publicaddr,char *myipaddr, nn_setsockopt(pullsock,NN_SOL_SOCKET,NN_RCVBUF,&maxsize,sizeof(maxsize)); if ( LP_canbind == 0 ) { + if ( nntype == NN_SUB ) + nn_setsockopt(pullsock,NN_SUB,NN_SUB_SUBSCRIBE,"",0); if ( nn_connect(pullsock,connectaddr) < 0 ) { printf("bind to %s error for %s: %s\n",connectaddr,publicaddr,nn_strerror(nn_errno())); exit(-1); - } else printf("nntype.%d NN_SUB.%d connect to %s\n",nntype,NN_SUB,connectaddr); - if ( nntype == NN_SUB ) - nn_setsockopt(pullsock,NN_SUB,NN_SUB_SUBSCRIBE,"",0); + } else printf("nntype.%d NN_SUB.%d connect to %s pullsock.%d\n",nntype,NN_SUB,connectaddr,pullsock); while ( 0 ) { int32_t size; void *buf;