Browse Source

Test

etomic
jl777 8 years ago
parent
commit
e9c3536f80
  1. 8
      iguana/exchanges/LP_network.c

8
iguana/exchanges/LP_network.c

@ -64,9 +64,9 @@ int32_t LP_send(int32_t sock,char *msg,int32_t freeflag)
//portable_mutex_unlock(&LP_networkmutex);
usleep(1000);
}
printf("error LP_send sock.%d, pipeline timeout.(%s) %s\n",sock,msg,nn_strerror(nn_errno()));
if ( (sentbytes= nn_send(sock,msg,len,0)) != len )
printf("LP_send sent %d instead of %d\n",sentbytes,len);
printf("error LP_send sock.%d, i.%d timeout.(%s) %s\n",sock,i,msg,nn_strerror(nn_errno()));
//if ( (sentbytes= nn_send(sock,msg,len,0)) != len )
// printf("LP_send sent %d instead of %d\n",sentbytes,len);
if ( freeflag != 0 )
free(msg);
return(-1);
@ -339,7 +339,7 @@ char *LP_psock(char *myipaddr,int32_t ispaired)
jaddnum(retjson,"ispaired",ispaired);
jaddstr(retjson,"publicaddr",pushaddr);
jaddnum(retjson,"publicport",pushport);
printf("i.%d publicaddr.(%s) for %s\n",i,pushaddr,subaddr);
printf("i.%d publicaddr.(%s) for %s, pullsock.%d pubsock.%d\n",i,pushaddr,subaddr,pullsock,pubsock);
break;
} else printf("bind error on %s or %s\n",pushaddr,subaddr);
if ( pullsock >= 0 )

Loading…
Cancel
Save