|
@ -401,7 +401,7 @@ int32_t LP_initpublicaddr(uint16_t *mypullportp,char *publicaddr,char *myipaddr, |
|
|
{ |
|
|
{ |
|
|
printf("bind to %s error for %s: %s\n",connectaddr,publicaddr,nn_strerror(nn_errno())); |
|
|
printf("bind to %s error for %s: %s\n",connectaddr,publicaddr,nn_strerror(nn_errno())); |
|
|
exit(-1); |
|
|
exit(-1); |
|
|
} |
|
|
} else printf("nntype.%d NN_SUB.%d to %s\n",nntype,NN_SUB,connectaddr); |
|
|
if ( nntype == NN_SUB ) |
|
|
if ( nntype == NN_SUB ) |
|
|
nn_setsockopt(pullsock,NN_SUB,NN_SUB_SUBSCRIBE,"",0); |
|
|
nn_setsockopt(pullsock,NN_SUB,NN_SUB_SUBSCRIBE,"",0); |
|
|
} |
|
|
} |
|
|