|
@ -313,7 +313,7 @@ char *LP_psock(char *myipaddr,int32_t ispaired) |
|
|
pullsock = pubsock = -1; |
|
|
pullsock = pubsock = -1; |
|
|
nanomsg_transportname(1,pushaddr,myipaddr,pushport), pushport += 2; |
|
|
nanomsg_transportname(1,pushaddr,myipaddr,pushport), pushport += 2; |
|
|
nanomsg_transportname(1,subaddr,myipaddr,subport), subport += 2; |
|
|
nanomsg_transportname(1,subaddr,myipaddr,subport), subport += 2; |
|
|
if ( (pullsock= nn_socket(AF_SP,ispaired!=0?NN_PAIR:NN_PULL)) >= 0 && (pubsock= nn_socket(AF_SP,ispaired!=0?NN_PAIR:NN_PUB)) >= 0 ) |
|
|
if ( (pullsock= nn_socket(AF_SP,ispaired!=0?NN_PAIR:NN_PULL)) >= 0 && (pubsock= nn_socket(AF_SP,ispaired!=0?NN_PAIR:NN_PAIR)) >= 0 ) |
|
|
{ |
|
|
{ |
|
|
if ( nn_bind(pullsock,pushaddr) >= 0 && nn_bind(pubsock,subaddr) >= 0 ) |
|
|
if ( nn_bind(pullsock,pushaddr) >= 0 && nn_bind(pubsock,subaddr) >= 0 ) |
|
|
{ |
|
|
{ |
|
@ -404,7 +404,8 @@ int32_t LP_initpublicaddr(uint16_t *mypullportp,char *publicaddr,char *myipaddr, |
|
|
nntype = LP_COMMAND_RECVSOCK; |
|
|
nntype = LP_COMMAND_RECVSOCK; |
|
|
else nntype = NN_SUB; |
|
|
else nntype = NN_SUB; |
|
|
} |
|
|
} |
|
|
else nntype = NN_PAIR; |
|
|
//else
|
|
|
|
|
|
nntype = NN_PAIR; |
|
|
if ( LP_canbind != 0 ) |
|
|
if ( LP_canbind != 0 ) |
|
|
{ |
|
|
{ |
|
|
nanomsg_transportname(0,publicaddr,myipaddr,mypullport); |
|
|
nanomsg_transportname(0,publicaddr,myipaddr,mypullport); |
|
|