#ifndef _CSH_

#define _CSH_ 1

#include <stdlib.h>

#include <string.h>

#include <stdio.h>

#include <unistd.h>

#include <pthread.h>

#include <signal.h>

#include <errno.h>

#include <time.h>

#include <math.h>

#include <sys/types.h>

#include <sys/socket.h>

#include <netdb.h>

#include <sys/time.h>

#include <openssl/ssl.h>

#include <openssl/bio.h>

#include <openssl/err.h>

#include <sys/wait.h>

#include <sys/select.h>

#include <sys/mman.h>

#include <semaphore.h>

#include <signal.h>

#include <execinfo.h>

#include <libgen.h>

typedef struct DebugS {

	char id[128];

	char msg[256];

} DebugT, *DebugP;

#define DebugA() (DebugP)malloc(sizeof(DebugT))

typedef struct ShareS {

	int conns;

	int msgs;

	int act;

	int mashOpenClientCount;

	int mashOpenSSLClientCount;

	sem_t counterSem;

	sem_t debugSem;

} ShareT, *ShareP;

#define ShareA(v) if((v = mmap(NULL, sizeof(ShareT), PROT_READ|PROT_WRITE, MAP_SHARED|MAP_ANONYMOUS, -1, 0)) < 0) SYSERR("mmap")

typedef struct CSS {

	DebugT debug;

	int debMaxLev;

	int port0;

	int portZ;

	char *text;

	int ttl;

	int mp0;

	int mn;

	int rp0;

	int rn;

   struct timespec pace;

   int pacing;

	int issl;

	int connThreshold;		// connection retry threshhold

	int connTO;					// connection timeout in usecs

	int selTO;					// selection timeout in secs

	char *ceP;					// -->SSL certs path

	char *caP;					//	-->CA  certs path

	ShareP shP;

	char home[128];

} CST, *CSP;

#define CSA(v) if((v = (CSP)malloc(sizeof(CST))) < 0) SYSERR("malloc")

typedef struct HeaderS {

	int ttl;

	int ts;

	int listPort;

} HeaderT, *HeaderP;

typedef struct PayloadS {

	time_t ts;

	char text;

} PayloadT, *PayloadP;

typedef struct ContainerS {

	HeaderT hdr;

	PayloadT payl;

} ContainerT, *ContainerP;

typedef struct DataS {

	DebugT debug;

	ContainerP contP;

	int dataLen;

} DataT, *DataP;

#define DataA(v) if((v = (DataP)malloc(sizeof(DataT))) < 0) SYSERR("malloc")

typedef struct SocketS {

	int remPort;

	int sc;

	SSL *sslP;

} SocketT, *SocketP;

#define SocketA(v) if((v = (SocketP)malloc(sizeof(SocketT))) < 0) SYSERR("malloc")

typedef enum{ring, mash} topology;

typedef struct NodeS {

	DebugT debug;

	topology topo;

	int ssc;

	int locPort;

	int first;

	int last;

	int nodes;

	int nodeIdx;

	int kicker;

	int *forw;

	int closing;

	pthread_t closingThread;

	SocketP cliSides;

	SocketP srvSides;

	DataT data;

	int len;

	int ssl;

	SSL_CTX *ctx;

	struct sigaction *sigactP;

} NodeT, *NodeP;

#define NodeA(v) if((v = (NodeP)malloc(sizeof(NodeT))) < 0) SYSERR("malloc")

typedef enum{client, server} nodeside;

extern void debug_init();

extern char *gpa(struct sockaddr *);

extern void gai(int, struct addrinfo *ai, DebugP);

#define GAI(level, ai) gai(level, ai, deP)

extern void ssl_err(DebugP, char*);

extern void abend(DebugP);

extern void Node(topology, int*, int, int, int, int);

extern void Data(DataP, DebugP);

extern int dttlData(DataP);

extern int ttlData(DataP);

extern int remPortData(DataP);

extern DataP loadData(DataP, int, char*);

extern char *unldData(DataP);

extern char *digest24Data(DataP, char *);

extern int chkData(DataP);

extern void sabotageData(DataP);

extern int tsData(DataP);

extern void back_trace();

extern void pre(char *);

extern void deb(int, DebugP);

extern void err(int, char *, DebugP);

#define DEBID(...) sprintf(deP->id, __VA_ARGS__)

#define LOG(level, ...) sprintf(deP->msg, __VA_ARGS__), deb(level, deP)

#define SYSERR(e) LOG(0, "%s: %s (%d)", e, strerror(errno), errno), abend(deP)

#define SSLERR(e) ssl_err(deP, e)

#define SOFTERR(e) LOG(0, e), fflush(stderr)

#define HARDERR(e) SOFTERR(e), abend(deP);

#define ERR(e) perror(e), exit(EXIT_FAILURE)

#define PACING SIGUSR1

extern CSP csP;

#endif