GitHub Viewer
#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