2

Подскажите, как реализовать таймауты соединений при использовании epoll? Требуется определять неактивные соединения и закрывать их.

2 ответа 2

4

Так ведь в man epoll_wait явно прописан timeout в миллисекундах.

Вот им и пользуйтесь. Если epoll_wait() вернул 0, то таймаут истек. В этом случае просматриваете свой вектор epoll_event, по которым делаете опрос и принимаете решение.

Видимо в вашем случае с каждым соединением надо связать структуру данных, что-то вроде

struct connect {
   int sock_fd;
   time_t last; // ???
   ...
};

а в struct epoll_event, массив которых передаете в epoll_wait() использовать поле .data.ptr (заносите туда адрес соответствующей struct connect).

Соответственно, при каждом recv() меняете в нужном блоке last. А при таймауте сравнивает текущее время с каждым last.

Как-то так, если кратко.

6
  • И где-то на 10к сокетов он перестанет возвращать ноль. Но идея в принципе понятна. Я тоже склонялся к похожему решению, но там была идея лишь раз в 10 секунд проверять все соединения, что чточно не будет создавать нежелательной нагрузки, однако мне показали другое решение. Привел его в своем ответе. К сожалению, пока не могу решить, какое решение лучше.
    – mikelsv
    11 июн 2015 в 13:30
  • @mikelsv, ну вам же в любом случае надо пересчитывать передаваемый при очередном вызове в epoll_wait таймут (ведь обычно куча возвратов будет не с нулем). Так что, если очередной пересчитанный таймаут стал нулем, то настало время просмотра вектора events.
    – avp
    11 июн 2015 в 13:44
  • Сейчас нет, epoll_wait() вызывается с бесконечным ожиданием. Теперь же я скорее всего буду вызывать его с интервалом в 10 секунд. Пока не стоит задачи сделать точный таймаут.
    – mikelsv
    11 июн 2015 в 13:53
  • 1
    @mikelsv, если у вас все таймауты одинаковы, то (наверное, такое решение Вы тоже рассматривали) можно все делать за O(1). Используем самоорганизующийся двусвязный список connections. Новые добавляем в конец списка. Обновляемые (мы получаем из epoll_wait сразу адрес элемента списка) перемещаем в конец списка с пересчитанным временем таймаута. Таким образом список всегда будет упорядочен по времени таймаута. При поиске "просроченных" соединений достаточно проверять элементы в голове списка (и сразу удалять их) пока время наступления таймаута меньше текущего. IMHO красиво.
    – avp
    14 июн 2015 в 18:42
  • Я тоже думал о таком красивом решении, но к сожалению концепция сервера такова, что таймауты могут быть разными. Конечно, можно ставить их в список с таймаутом в секунду и перебрасывать в конец списка, но это будет лишняя нагрузка, хотя тоже вроде вариант. Перед решением этой проблемы требуется решить другую: ru.stackoverflow.com/questions/429478 , как сказать епулу передать сокет в обработчик.
    – mikelsv
    14 июн 2015 в 19:26
1

Подобная проблема довольно интересно решена здесь: https://github.com/zeromq/libzmq/blob/master/src/epoll.cpp#L152 и https://github.com/zeromq/libzmq/blob/master/src/poller_base.cpp#L78 .

Если вкратце, то там берется std::multimap и, когда требуется установить таймер, в него записывают время срабатывания и указатель на класс, которому надо сообщить. И перед каждым вызовом epoll_wait() проверяется у кого истек таймер. Довольно интересное и быстрое решение.

2
  • Тут все зависит от интенсивности (частоты) вызовов epoll_wait. / Допустим, вы работаете с большим количеством активных соединений, а значит очень часто вызываете epoll_wait и каждый раз вам придется смотреть (почти всегда безрезультатно), а у кого истек таймаут. На самом деле это очень быстро. А вот обновление каждого таймера вызовет его удаление и последующую вставку в rb-tree (т.е. время порядка log(N)). / В моем ответе обновление -- быстро, просмотр (по таймауту, скажем на практике раз в секунду) время порядка N. / Пока все (отбываю до понедельника)
    – avp
    11 июн 2015 в 13:38
  • В принципе да, проще пробежаться по массиву элементов. Меня тоже смущала работа с динамическим массивом, к тому же пришлось бы переписать его так, чтобы он не дергал malloc() при каждом добавлении таймера.
    – mikelsv
    11 июн 2015 в 13:48

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.