ab0bc2c4c0
+ added EPOLLERR and EPOLLHUP handling + fix root substitution for default "/" location (temp or permanent ?) + tested siege a little, seems good
71 lines
1.8 KiB
C++
71 lines
1.8 KiB
C++
|
|
#include "Webserv.hpp"
|
|
|
|
#define MAX_EVENTS 42 // arbitrary
|
|
#define TIMEOUT 3000
|
|
|
|
void Webserv::run()
|
|
{
|
|
std::cerr << "Server started\n";
|
|
struct epoll_event events[MAX_EVENTS];
|
|
int nfds;
|
|
int i;
|
|
int count_loop = 0;
|
|
std::vector<listen_socket>::iterator it_socket;
|
|
|
|
g_run = true;
|
|
while (g_run)
|
|
{
|
|
std::cerr << ++count_loop << "----loop epoll()\n";
|
|
nfds = ::epoll_wait(_epfd, events, MAX_EVENTS, TIMEOUT);
|
|
if (nfds == -1)
|
|
{
|
|
std::perror("err epoll_wait()");
|
|
if (errno == EINTR)
|
|
g_run = false;
|
|
else
|
|
throw std::runtime_error("Epoll wait");
|
|
}
|
|
else if (nfds == 0 && !_clients.empty())
|
|
_timeout();
|
|
i = 0;
|
|
while (i < nfds)
|
|
{
|
|
try {
|
|
it_socket = std::find(_listen_sockets.begin(), _listen_sockets.end(), events[i].data.fd);
|
|
if (it_socket != _listen_sockets.end())
|
|
{
|
|
if (events[i].events & EPOLLERR || events[i].events & EPOLLHUP)
|
|
_handle_epoll_error_lsocket(events[i].events, it_socket);
|
|
else if (events[i].events & EPOLLIN)
|
|
_accept_connection(*it_socket);
|
|
}
|
|
else
|
|
{
|
|
if (events[i].events & EPOLLERR || events[i].events & EPOLLHUP)
|
|
_handle_epoll_error_client(events[i].events, events[i].data.fd);
|
|
else if (events[i].events & EPOLLIN)
|
|
_request( &(*std::find(_clients.begin(), _clients.end(), events[i].data.fd)) );
|
|
else if (events[i].events & EPOLLOUT)
|
|
_response( &(*std::find(_clients.begin(), _clients.end(), events[i].data.fd)) );
|
|
}
|
|
++i;
|
|
if (!g_run)
|
|
break;
|
|
}
|
|
catch (const std::bad_alloc& e) {
|
|
std::cerr << e.what() << '\n';
|
|
_close_all_clients();
|
|
/* Swap to free the memory
|
|
From : http://www.uml.org.cn/c%2B%2B/pdf/EffectiveSTL.pdf#page=66 */
|
|
std::vector<Client>().swap(_clients);
|
|
break;
|
|
}
|
|
catch (const std::exception& e) {
|
|
std::cerr << e.what() << '\n';
|
|
++i;
|
|
}
|
|
}
|
|
}
|
|
}
|