diff -r 000000000000 -r 5c129dd80d4f CSc/CS.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/CSc/CS.h	Thu Nov 21 14:55:10 2019 +0100
@@ -0,0 +1,155 @@
+#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