CSNode/Server.cpp at main · elfpipe/CSNode · GitHub

Repository navigation

History

49 lines (44 loc) · 1.39 KB

Raw

#include <unistd.h>

#include <poll.h>

#include <iostream>

#include <strings.h>

#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 << "Icomming call...\n";

CSNode::CSConnection *connection = _this->node->waitForIncomming (_this->node->port);

if (connection) {

// cout << "<message> : " << _this->node->readSentence (connection, '\3') << "\n";

// _this->node->writeSentence (connection, "CLOSE");

_this->node->serverCommand (connection);

_this->node->closeConnection (connection);

cout << "Call completed.\n";

}

if(pfds[1].revents & POLLIN) {

cout << "exitPipe activatet (EXIT)\n";

pthread_exit(0);

}

void Server::endThread() {

write (exitPipe[1], "hej\0", 4);

}

CSNode/Server.cpp at main · elfpipe/CSNode · GitHub

Repository navigation

Expand file tree

Breadcrumbs

Server.cpp

Latest commit

History

Breadcrumbs

Server.cpp

File metadata and controls