Server.h

#ifndef SERVER_H
#define SERVER_H


#include <assert.h>
#include <errno.h>
#include <fcntl.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/epoll.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <unistd.h>
#include <netdb.h>
#include <strings.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <signal.h>
#include <pthread.h>
#include <iostream>

#define TRUE 		1
#define FALSE 		0
#define EPOLL_QUEUE_LEN	64000
#define BUFLEN		1024
#define SERVER_PORT	7000
#define NUM_WORKERS 10

typedef struct thrdParams
{
    int fd;
    int epoll_fd;
    int fd_new;
    int fd_server;
    int eventIndex;
    int worker_fds[NUM_WORKERS];
    int thrdNumber;

} thrdParams;


extern void readSocket(int fd);
extern void *readSocket(void *param);
extern void* UpdateConsole(void *param);
extern void* worker(void *param);
extern void* acceptConnections(void *param);
extern int numClients;
extern int numClientsInThread[NUM_WORKERS];

class Server

{

public:
    explicit Server(int);
    void startServer();

    static struct epoll_event events[EPOLL_QUEUE_LEN], event;
    static struct epoll_event worker_events[NUM_WORKERS][EPOLL_QUEUE_LEN];
    static struct epoll_event worker_event[NUM_WORKERS];

private:
    int fd_server;
    int num_fds;
    int epoll_fd;
    int worker_fds[NUM_WORKERS];
    int arg;
    int fd_new;
    int port;
    struct sockaddr_in addr, remote_addr;
    socklen_t addr_size;
    pthread_t readThread, updateConsoleThrd;
    thrdParams *acceptThrdParams;
    thrdParams *workerParams[NUM_WORKERS];

    void SystemFatal (const char* message);

};

#endif // SERVER_H