-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathServer.cpp
58 lines (47 loc) · 1.5 KB
/
Server.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
#include "Server.hpp"
#include "Client.hpp"
#include "cstdio"
#include <sstream>
void Server::SerSocket()
{
this->fd_SerSocket = socket(AF_INET, SOCK_STREAM, 0);
if (this->fd_SerSocket == -1)
throw std::string("Server's socket creation failed");
int en = 1;
if (setsockopt(fd_SerSocket, SOL_SOCKET, SO_REUSEADDR, &en, sizeof(en)) == -1)
throw std::string("setsockopt() failed");
struct sockaddr_in addr;
addr.sin_port = htons(this->port);
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = INADDR_ANY;
if (bind(fd_SerSocket, (struct sockaddr *)&addr, sizeof(addr)) == -1)
throw std::string("Binding server's socket failed");
if (listen(fd_SerSocket, SOMAXCONN) == -1)
throw std::string("Listening to incoming client requests");
struct pollfd fd_poll;
fd_poll.fd = fd_SerSocket;
fd_poll.events = POLLIN;
fd_poll.revents = 0;
fds.push_back(fd_poll);
}
void Server::execution()
{
SerSocket();
std::cout << "creation of server socket is done wainting for inconming client connection" << std::endl;
while (true)
{
if (poll(&fds[0], fds.size(), -1) == -1)
throw std::string("poll() failed");
for (size_t i = 0; i < fds.size(); i++)
{
if (fds[i].revents & POLLIN)
{
if (fds[i].fd == fd_SerSocket)
AcceptClient();
else
ReceiveData(fds[i].fd);
}
}
}
close(fd_SerSocket);
}