You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
253 lines
10 KiB
253 lines
10 KiB
|
|
/******************************************************************************
|
|
* Copyright © 2014-2017 The SuperNET Developers. *
|
|
* *
|
|
* See the AUTHORS, DEVELOPER-AGREEMENT and LICENSE files at *
|
|
* the top-level directory of this distribution for the individual copyright *
|
|
* holder information and the developer policies on copyright and licensing. *
|
|
* *
|
|
* Unless otherwise agreed in a custom licensing agreement, no part of the *
|
|
* SuperNET software, including this file may be copied, modified, propagated *
|
|
* or distributed except according to the terms contained in the LICENSE file *
|
|
* *
|
|
* Removal or modification of this copyright notice is prohibited. *
|
|
* *
|
|
******************************************************************************/
|
|
//
|
|
// LP_peers.c
|
|
// marketmaker
|
|
//
|
|
|
|
struct LP_peerinfo *LP_peerfind(uint32_t ipbits,uint16_t port)
|
|
{
|
|
struct LP_peerinfo *peer=0; uint64_t ip_port;
|
|
ip_port = ((uint64_t)port << 32) | ipbits;
|
|
portable_mutex_lock(&LP_peermutex);
|
|
HASH_FIND(hh,LP_peerinfos,&ip_port,sizeof(ip_port),peer);
|
|
portable_mutex_unlock(&LP_peermutex);
|
|
return(peer);
|
|
}
|
|
|
|
cJSON *LP_peerjson(struct LP_peerinfo *peer)
|
|
{
|
|
cJSON *item = cJSON_CreateObject();
|
|
jaddstr(item,"ipaddr",peer->ipaddr);
|
|
jaddnum(item,"port",peer->port);
|
|
if ( strcmp(peer->ipaddr,LP_myipaddr) == 0 )
|
|
{
|
|
jaddnum(item,"session",LP_sessionid);
|
|
if ( LP_mypeer != 0 )
|
|
jaddnum(item,"numutxos",LP_mypeer->numutxos);
|
|
} else jaddnum(item,"session",peer->sessionid);
|
|
//jaddnum(item,"profit",peer->profitmargin);
|
|
return(item);
|
|
}
|
|
|
|
char *LP_peers()
|
|
{
|
|
struct LP_peerinfo *peer,*tmp; cJSON *peersjson = cJSON_CreateArray();
|
|
HASH_ITER(hh,LP_peerinfos,peer,tmp)
|
|
{
|
|
//if ( peer->errors < LP_MAXPEER_ERRORS )
|
|
jaddi(peersjson,LP_peerjson(peer));
|
|
}
|
|
return(jprint(peersjson,1));
|
|
}
|
|
|
|
struct LP_peerinfo *LP_addpeer(struct LP_peerinfo *mypeer,int32_t mypubsock,char *ipaddr,uint16_t port,uint16_t pushport,uint16_t subport,int32_t numpeers,int32_t numutxos,uint32_t sessionid)
|
|
{
|
|
uint32_t ipbits; int32_t pushsock,subsock,timeout; char checkip[64],pushaddr[64],subaddr[64]; struct LP_peerinfo *peer = 0;
|
|
#ifdef LP_STRICTPEERS
|
|
if ( strncmp("5.9.253",ipaddr,strlen("5.9.253")) != 0 )
|
|
return(0);
|
|
#endif
|
|
ipbits = (uint32_t)calc_ipbits(ipaddr);
|
|
expand_ipbits(checkip,ipbits);
|
|
if ( strcmp(checkip,ipaddr) == 0 )
|
|
{
|
|
if ( (peer= LP_peerfind(ipbits,port)) != 0 )
|
|
{
|
|
/*if ( numpeers > peer->numpeers )
|
|
peer->numpeers = numpeers;
|
|
if ( numutxos > peer->numutxos )
|
|
peer->numutxos = numutxos;
|
|
if ( peer->sessionid == 0 )
|
|
peer->sessionid = sessionid;*/
|
|
}
|
|
else
|
|
{
|
|
peer = calloc(1,sizeof(*peer));
|
|
if ( strcmp(peer->ipaddr,LP_myipaddr) == 0 )
|
|
peer->sessionid = LP_sessionid;
|
|
else peer->sessionid = sessionid;
|
|
peer->pushsock = peer->subsock = pushsock = subsock = -1;
|
|
strcpy(peer->ipaddr,ipaddr);
|
|
if ( pushport != 0 && subport != 0 && (pushsock= nn_socket(AF_SP,NN_PUSH)) >= 0 )
|
|
{
|
|
nanomsg_transportname(0,pushaddr,peer->ipaddr,pushport);
|
|
if ( nn_connect(pushsock,pushaddr) >= 0 )
|
|
{
|
|
timeout = 1;
|
|
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) %d\n",pushaddr,pushsock);
|
|
peer->connected = (uint32_t)time(NULL);
|
|
peer->pushsock = pushsock;
|
|
if ( (subsock= nn_socket(AF_SP,NN_SUB)) >= 0 )
|
|
{
|
|
timeout = 1;
|
|
nn_setsockopt(subsock,NN_SOL_SOCKET,NN_RCVTIMEO,&timeout,sizeof(timeout));
|
|
nn_setsockopt(subsock,NN_SUB,NN_SUB_SUBSCRIBE,"",0);
|
|
nanomsg_transportname(0,subaddr,peer->ipaddr,subport);
|
|
if ( nn_connect(subsock,subaddr) >= 0 )
|
|
{
|
|
peer->subsock = subsock;
|
|
printf("connected to sub.(%s) %d\n",subaddr,peer->subsock);
|
|
} else nn_close(subsock);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
nn_close(pushsock);
|
|
printf("error connecting to push.(%s)\n",pushaddr);
|
|
}
|
|
} else printf("%s pushport.%u subport.%u pushsock.%d\n",ipaddr,pushport,subport,pushsock);
|
|
//peer->profitmargin = profitmargin;
|
|
peer->ipbits = ipbits;
|
|
peer->port = port;
|
|
peer->ip_port = ((uint64_t)port << 32) | ipbits;
|
|
portable_mutex_lock(&LP_peermutex);
|
|
HASH_ADD(hh,LP_peerinfos,ip_port,sizeof(peer->ip_port),peer);
|
|
if ( mypeer != 0 )
|
|
{
|
|
mypeer->numpeers++;
|
|
printf("_LPaddpeer %s -> numpeers.%d mypubsock.%d other.(%d %d)\n",ipaddr,mypeer->numpeers,mypubsock,numpeers,numutxos);
|
|
} else peer->numpeers = 1; // will become mypeer
|
|
portable_mutex_unlock(&LP_peermutex);
|
|
if ( IAMLP != 0 && mypubsock >= 0 )
|
|
{
|
|
struct iguana_info *coin,*ctmp; bits256 zero; char *msg,busaddr[64];
|
|
msg = jprint(LP_peerjson(peer),1);
|
|
memset(zero.bytes,0,sizeof(zero));
|
|
//LP_send(mypubsock,msg,(int32_t)strlen(msg)+1,1);
|
|
LP_broadcast_message(mypubsock,"","",zero,msg);
|
|
if ( 0 )
|
|
{
|
|
HASH_ITER(hh,LP_coins,coin,ctmp)
|
|
{
|
|
if ( coin->bussock >= 0 )
|
|
{
|
|
nanomsg_transportname(0,busaddr,peer->ipaddr,coin->busport);
|
|
nn_connect(coin->bussock,busaddr);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else printf("LP_addpeer: checkip.(%s) vs (%s)\n",checkip,ipaddr);
|
|
return(peer);
|
|
}
|
|
|
|
int32_t LP_coinbus(uint16_t coin_busport)
|
|
{
|
|
struct LP_peerinfo *peer,*tmp; char busaddr[64]; int32_t timeout,bussock = -1;
|
|
return(-1);
|
|
if ( IAMLP != 0 && LP_mypeer != 0 && (bussock= nn_socket(AF_SP,NN_BUS)) >= 0 )
|
|
{
|
|
timeout = 1;
|
|
nn_setsockopt(bussock,NN_SOL_SOCKET,NN_SNDTIMEO,&timeout,sizeof(timeout));
|
|
nn_setsockopt(bussock,NN_SOL_SOCKET,NN_RCVTIMEO,&timeout,sizeof(timeout));
|
|
nanomsg_transportname(0,busaddr,LP_mypeer->ipaddr,coin_busport);
|
|
if ( nn_bind(bussock,busaddr) < 0 )
|
|
{
|
|
printf("error binding to coin_busport.%s\n",busaddr);
|
|
nn_close(bussock);
|
|
}
|
|
else
|
|
{
|
|
HASH_ITER(hh,LP_peerinfos,peer,tmp)
|
|
{
|
|
if ( LP_mypeer->port != peer->port || strcmp(LP_mypeer->ipaddr,peer->ipaddr) != 0 )
|
|
{
|
|
nanomsg_transportname(0,busaddr,peer->ipaddr,coin_busport);
|
|
nn_connect(bussock,busaddr);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return(bussock);
|
|
}
|
|
|
|
int32_t LP_peersparse(struct LP_peerinfo *mypeer,int32_t mypubsock,char *destipaddr,uint16_t destport,char *retstr,uint32_t now)
|
|
{
|
|
struct LP_peerinfo *peer; uint32_t argipbits; char *argipaddr; uint16_t argport,pushport,subport; cJSON *array,*item; int32_t i,n=0;
|
|
if ( (array= cJSON_Parse(retstr)) != 0 )
|
|
{
|
|
if ( (n= cJSON_GetArraySize(array)) > 0 )
|
|
{
|
|
for (i=0; i<n; i++)
|
|
{
|
|
item = jitem(array,i);
|
|
if ( (argipaddr= jstr(item,"ipaddr")) != 0 && (argport= juint(item,"port")) != 0 )
|
|
{
|
|
if ( (pushport= juint(item,"push")) == 0 )
|
|
pushport = argport + 1;
|
|
if ( (subport= juint(item,"sub")) == 0 )
|
|
subport = argport + 2;
|
|
argipbits = (uint32_t)calc_ipbits(argipaddr);
|
|
if ( (peer= LP_peerfind(argipbits,argport)) == 0 )
|
|
{
|
|
peer = LP_addpeer(mypeer,mypubsock,argipaddr,argport,pushport,subport,jint(item,"numpeers"),jint(item,"numutxos"),juint(item,"session"));
|
|
}
|
|
if ( peer != 0 )
|
|
{
|
|
peer->lasttime = now;
|
|
if ( strcmp(argipaddr,destipaddr) == 0 && destport == argport && peer->numpeers != n )
|
|
peer->numpeers = n;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
free_json(array);
|
|
}
|
|
return(n);
|
|
}
|
|
|
|
void LP_peersquery(struct LP_peerinfo *mypeer,int32_t mypubsock,char *destipaddr,uint16_t destport,char *myipaddr,uint16_t myport)
|
|
{
|
|
char *retstr; struct LP_peerinfo *peer,*tmp; uint32_t now,flag = 0;
|
|
peer = LP_peerfind((uint32_t)calc_ipbits(destipaddr),destport);
|
|
if ( (retstr= issue_LP_getpeers(destipaddr,destport,myipaddr,myport,mypeer!=0?mypeer->numpeers:0,mypeer!=0?mypeer->numutxos:0)) != 0 )
|
|
{
|
|
//printf("got.(%s)\n",retstr);
|
|
now = (uint32_t)time(NULL);
|
|
LP_peersparse(mypeer,mypubsock,destipaddr,destport,retstr,now);
|
|
free(retstr);
|
|
if ( IAMLP != 0 )
|
|
{
|
|
HASH_ITER(hh,LP_peerinfos,peer,tmp)
|
|
{
|
|
if ( peer->lasttime != now )
|
|
{
|
|
printf("{%s:%u}.%d ",peer->ipaddr,peer->port,peer->lasttime - now);
|
|
flag++;
|
|
if ( (retstr= issue_LP_notify(destipaddr,destport,peer->ipaddr,peer->port,peer->numpeers,0,peer->sessionid)) != 0 )
|
|
free(retstr);
|
|
}
|
|
}
|
|
if ( flag != 0 )
|
|
printf(" <- missing peers\n");
|
|
}
|
|
}
|
|
}
|
|
|
|
int32_t LP_numpeers()
|
|
{
|
|
struct LP_peerinfo *peer,*tmp; int32_t numpeers = 0;
|
|
HASH_ITER(hh,LP_peerinfos,peer,tmp)
|
|
{
|
|
numpeers++;
|
|
}
|
|
return(numpeers);
|
|
}
|
|
|