while(true)
{
int nfds = epoll_wait(epollfd, events, MAX_EVENTS, -1);
if (nfds == -1)
std::cout << "[ERROR] nfds error" << std::endl;
for (size_t k = 0; k < nfds; ++k)
{
if(events[k].data.fd == sock)
{
listen_res = listen(events[k].data.fd, 1);
if(listen_res = 1)
{
connection = accept(sock, (struct sockaddr*)&from, &len);
if(connection == -1)
continue;
if (setnonblocking(connection) == -1)
std::cout << "[ERROR] setnonblocking()" << std::endl;
ev.events = EPOLLIN | EPOLLRDHUP | EPOLLERR | EPOLLET;
ev.data.fd = connection;
if(epoll_ctl(epollfd, EPOLL_CTL_ADD, connection, &ev) == -1)
std::cout << "[ERROR] epoll_ctl(connection) returned an error " << std::endl;
else
std::cout << "[INFO] New Client's IP: " << inet_ntoa(from.sin_addr) << std::endl;
}
}
else
{
if (events[k].events & (EPOLLRDHUP | EPOLLHUP))
{
std::cout << "Disconnect" << std::endl;
ThreadPool.add(task);
close(events[k].data.fd);
epoll_ctl(epollfd, EPOLL_CTL_DEL, events[k].data.fd, &ev);
}
else if (events[k].events & EPOLLIN)
{
do
{
read(events[k].data.fd, &Packet, sizeof(PacketStructure));
do_work(&Packet);
}while(errno != EAGAIN);
}
}
}
}
После определенного количества посланных пакетов (отправляю части файла размером по 128 байт) этот код перестает принимать пакеты от клиента. Как можно решить проблему?