#include 
#include 
#include 
#include 
#include "CSNode.hpp"
#include "Server.hpp"
Server::Server (CSNode *node) {
    this->node = node;
}
void Server::startThread () {
    pthread_t threadHandle;
    pipe(exitPipe);
    pthread_create (&threadHandle, 0, thread, (void *)this);

}
void *Server::thread(void *dummy) {
    Server *_this = (Server *) dummy;
    struct pollfd pfds[2];
    pfds[0] = {_this->node->bindSocket, POLLIN, 0};
    pfds[1] = {_this->exitPipe[0], POLLIN, 0};

    while (1) {
        if (poll (pfds, 2, 100) < 0) {
            perror("poll");
            pthread_exit(0);
        }
        
        if(pfds[0].revents & POLLIN) {
            cout node->waitForIncomming (_this->node->port);
            if (connection) {
                // cout readSentence (connection, '\3') node->writeSentence (connection, "CLOSE");
                _this->node->serverCommand (connection);
                _this->node->closeConnection (connection);
                cout