jl777 7 years ago
parent
commit
de51ec981d
  1. 2
      iguana/exchanges/LP_nativeDEX.c
  2. 2
      iguana/exchanges/LP_network.c
  3. 6
      iguana/exchanges/LP_peers.c

2
iguana/exchanges/LP_nativeDEX.c

@ -1150,7 +1150,7 @@ int32_t LP_reserved_msg(int32_t priority,char *base,char *rel,bits256 pubkey,cha
if ( (sentbytes= nn_send(pubp->pairsock,msg,(int32_t)strlen(msg)+1,0)) < 0 ) if ( (sentbytes= nn_send(pubp->pairsock,msg,(int32_t)strlen(msg)+1,0)) < 0 )
{ {
pubp->pairsock = -1; pubp->pairsock = -1;
printf("mark cmdchannel closed\n"); printf("mark cmdchannel %d closed sentbytes.%d\n",pubp->pairsock,sentbytes);
} }
else else
{ {

2
iguana/exchanges/LP_network.c

@ -748,7 +748,7 @@ char *issue_LP_psock(char *destip,uint16_t destport,int32_t ispaired,int32_t cmd
sprintf(url,"http://%s:%u/api/stats/psock?ispaired=%d&cmdchannel=%d&pubkey=%s",destip,destport-1,ispaired,cmdchannel,bits256_str(str,G.LP_mypub25519)); sprintf(url,"http://%s:%u/api/stats/psock?ispaired=%d&cmdchannel=%d&pubkey=%s",destip,destport-1,ispaired,cmdchannel,bits256_str(str,G.LP_mypub25519));
//return(LP_issue_curl("psock",destip,destport,url)); //return(LP_issue_curl("psock",destip,destport,url));
retstr = issue_curlt(url,LP_HTTP_TIMEOUT*3); retstr = issue_curlt(url,LP_HTTP_TIMEOUT*3);
printf("issue_LP_psock got (%s) from %s\n",retstr,url); // this is needed?! //printf("issue_LP_psock got (%s) from %s\n",retstr,url); // this is needed?!
return(retstr); return(retstr);
} }

6
iguana/exchanges/LP_peers.c

@ -58,14 +58,16 @@ char *LP_peers()
void LP_cmdchannel(struct LP_peerinfo *peer) void LP_cmdchannel(struct LP_peerinfo *peer)
{ {
char connectaddr[128],publicaddr[128],*retstr; int32_t pubsock; uint16_t cmdport; char *hellostr = "{\"method\":\"hello\"}";
char connectaddr[128],publicaddr[128],*retstr; int32_t pubsock,sentbytes; uint16_t cmdport;
if ( bits256_nonz(G.LP_mypub25519) == 0 || strcmp(G.USERPASS,"1d8b27b21efabcd96571cd56f91a40fb9aa4cc623d273c63bf9223dc6f8cd81f") == 0 ) if ( bits256_nonz(G.LP_mypub25519) == 0 || strcmp(G.USERPASS,"1d8b27b21efabcd96571cd56f91a40fb9aa4cc623d273c63bf9223dc6f8cd81f") == 0 )
return; return;
if ( (cmdport= LP_psock_get(connectaddr,publicaddr,1,1,peer->ipaddr)) != 0 ) if ( (cmdport= LP_psock_get(connectaddr,publicaddr,1,1,peer->ipaddr)) != 0 )
{ {
if ( (retstr= _LP_psock_create(&peer->pairsock,&pubsock,peer->ipaddr,cmdport,cmdport,1,1,G.LP_mypub25519)) != 0 ) if ( (retstr= _LP_psock_create(&peer->pairsock,&pubsock,peer->ipaddr,cmdport,cmdport,1,1,G.LP_mypub25519)) != 0 )
{ {
printf("cmdchannel created %s\n",retstr); sentbytes = nn_send(peer->pairsock,hellostr,(int32_t)strlen(hellostr)+1,0);
printf("cmdchannel %d created %s sent.%d\n",peer->pairsock,retstr,sentbytes);
free(retstr); free(retstr);
} }
} else printf("error getting cmdchannel with %s\n",peer->ipaddr); } else printf("error getting cmdchannel with %s\n",peer->ipaddr);

Loading…
Cancel
Save