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.
92 lines
4.0 KiB
92 lines
4.0 KiB
9 years ago
|
/******************************************************************************
|
||
|
|
* Copyright © 2014-2015 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. *
|
||
|
|
* *
|
||
|
|
******************************************************************************/
|
||
|
|
|
||
|
|
#ifndef INCLUDED_SUPERNET_H
|
||
|
|
#define INCLUDED_SUPERNET_H
|
||
|
|
|
||
|
|
#include "../crypto777/OS_portable.h"
|
||
|
|
#include "../includes/cJSON.h"
|
||
|
|
#include "../includes/nanomsg/nn.h"
|
||
|
|
|
||
|
|
#define SUPERNET_PORT 7778
|
||
|
|
#define SUPERNET_NETWORKTIMEOUT 10000
|
||
|
|
#define SUPERNET_POLLTIMEOUT 1
|
||
|
|
#define SUPERNET_APIUSLEEP (SUPERNET_POLLTIMEOUT * 10000)
|
||
|
|
#define SUPERNET_MAXAGENTS 64
|
||
|
|
#define NXT_TOKEN_LEN 160
|
||
|
|
#define nn_errstr() nn_strerror(nn_errno())
|
||
|
|
|
||
|
|
/*#define LB_OFFSET 1
|
||
|
|
#define PUBGLOBALS_OFFSET 2
|
||
|
|
#define PUBRELAYS_OFFSET 3
|
||
|
|
|
||
|
|
|
||
|
|
#define MAX_SERVERNAME 128
|
||
|
|
struct relayargs
|
||
|
|
{
|
||
|
|
char name[16],endpoint[MAX_SERVERNAME];
|
||
|
|
int32_t sock,type,bindflag,sendtimeout,recvtimeout;
|
||
|
|
};
|
||
|
|
struct relay_info { int32_t sock,num,mytype,desttype; struct endpoint connections[1 << CONNECTION_NUMBITS]; };*/
|
||
|
|
|
||
|
|
#define CONNECTION_NUMBITS 10
|
||
|
|
struct endpoint { queue_t nnrecvQ; int32_t nnsock,nnind; uint64_t ipbits:32,port:16,transport:2,nn:4,directind:CONNECTION_NUMBITS; };
|
||
|
|
|
||
|
|
struct direct_connection { char handler[16]; struct endpoint epbits; int32_t sock; };
|
||
|
|
|
||
|
|
struct supernet_msghdr { uint8_t type,serlen[3]; char command[16]; uint8_t hdrdata[44]; uint8_t data[]; };
|
||
|
|
|
||
|
|
struct supernet_agent
|
||
|
|
{
|
||
|
|
struct queueitem DL; queue_t recvQ; uint64_t totalrecv,totalsent;
|
||
|
|
int32_t (*recvfunc)(void *myinfo,struct supernet_agent *,struct supernet_msghdr *msg,uint8_t *data,int32_t datalen);
|
||
|
|
cJSON *networks;
|
||
|
|
char name[9],ipaddr[64],reppoint[64],pubpoint[64]; int32_t reqsock,repsock,pubsock,subsock;
|
||
|
|
uint32_t ipbits,dead; int32_t num,sock; uint16_t port,pubport,repport;
|
||
|
|
};
|
||
|
|
|
||
|
|
struct supernet_info
|
||
|
|
{
|
||
|
|
char ipaddr[64],transport[8]; int32_t APISLEEP; int32_t iamrelay; uint64_t my64bits; uint64_t ipbits;
|
||
|
|
int32_t Debuglevel,readyflag,dead,POLLTIMEOUT;
|
||
|
|
//int32_t pullsock,subclient,lbclient,lbserver,servicesock,pubglobal,pubrelays,numservers;
|
||
|
|
bits256 privkey,pubkey;
|
||
|
|
uint16_t port,serviceport,acceptport;
|
||
|
|
struct nn_pollfd pfd[SUPERNET_MAXAGENTS]; //struct relay_info active;
|
||
|
|
struct supernet_agent agents[SUPERNET_MAXAGENTS]; queue_t acceptQ; int32_t numagents;
|
||
|
|
};
|
||
|
|
|
||
|
|
struct supernet_endpoint
|
||
|
|
{
|
||
|
|
char name[64]; struct endpoint ep;
|
||
|
|
int32_t (*nnrecvfunc)(struct supernet_info *,struct supernet_endpoint *,int32_t ind,uint8_t *msg,int32_t nnlen);
|
||
|
|
queue_t nnrecvQ;
|
||
|
|
int32_t nnsock,num; struct endpoint eps[];
|
||
|
|
};
|
||
|
|
|
||
|
|
void expand_epbits(char *endpoint,struct endpoint epbits);
|
||
|
|
struct endpoint calc_epbits(char *transport,uint32_t ipbits,uint16_t port,int32_t type);
|
||
|
|
|
||
|
|
void SuperNET_init();
|
||
|
|
char *SuperNET_JSON(struct supernet_info *myinfo,cJSON *json,char *remoteaddr);
|
||
|
|
|
||
|
|
char *pangea_parser(struct supernet_info *myinfo,char *method,cJSON *json,char *remoteaddr);
|
||
|
|
char *ramchain_parser(struct supernet_info *myinfo,char *method,cJSON *json,char *remoteaddr);
|
||
|
|
char *iguana_parser(struct supernet_info *myinfo,char *method,cJSON *json,char *remoteaddr);
|
||
|
|
char *InstantDEX_parser(struct supernet_info *myinfo,char *method,cJSON *json,char *remoteaddr);
|
||
|
|
|
||
|
|
#endif
|
||
|
|
|