Browse Source

Test

etomic
jl777 7 years ago
parent
commit
ce0c7cea5a
  1. 5
      iguana/exchanges/LP_nativeDEX.c
  2. 2
      iguana/exchanges/LP_peers.c

5
iguana/exchanges/LP_nativeDEX.c

@ -900,13 +900,14 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,uint16_t mybu
nanomsg_transportname(0,subaddr,myipaddr,mypubport);
nanomsg_transportname(1,bindaddr,myipaddr,mypubport);
nanomsg_transportname2(1,bindaddr2,myipaddr,mypubport);
valid = 0;
if ( (pubsock= nn_socket(AF_SP,NN_PUB)) >= 0 )
{
valid = 0;
if ( nn_bind(pubsock,bindaddr) >= 0 )
valid++;
if ( nn_bind(pubsock,bindaddr2) >= 0 )
valid++;
if ( nn_bind(pubsock,bindaddr2) >= 0 )
valid++;
if ( valid > 0 )
{
timeout = 1;

2
iguana/exchanges/LP_peers.c

@ -102,7 +102,7 @@ struct LP_peerinfo *LP_addpeer(struct LP_peerinfo *mypeer,int32_t mypubsock,char
nn_setsockopt(pushsock,NN_SOL_SOCKET,NN_SNDTIMEO,&timeout,sizeof(timeout));
//maxsize = 2 * 1024 * 1024;
//nn_setsockopt(pushsock,NN_SOL_SOCKET,NN_SNDBUF,&maxsize,sizeof(maxsize));
printf("connected to push.(%s $s) pushsock.%d valid.%d\n",pushaddr,pushsock,valid);
printf("connected to push.(%s %s) pushsock.%d valid.%d\n",pushaddr,pushsock,valid);
peer->connected = (uint32_t)time(NULL);
peer->pushsock = pushsock;
if ( (subsock= nn_socket(AF_SP,NN_SUB)) >= 0 )

Loading…
Cancel
Save