Linux не может заставить eventfd работать вместе с epoll - PullRequest
Новая
       30

Linux не может заставить eventfd работать вместе с epoll

3 голосов
/ 18 марта 2011

Я пишу простой серверный класс на основе epoll. Чтобы проснуться epoll_wait(), я решил использовать eventfd. Говорят, что он лучше подходит для простой передачи событий, и я согласен с этим. Поэтому я создал свое мероприятие и положил на него часы: 

_epollfd = epoll_create1(0);
if (_epollfd == -1) throw ServerError("epoll_create");
_eventfd = eventfd(0, EFD_NONBLOCK);
epoll_event evnt = {0};
evnt.data.fd = _eventfd;
evnt.events = _events;
if (epoll_ctl(_epollfd, EPOLL_CTL_ADD, _eventfd, &evnt) == -1)
    throw ServerError("epoll_ctl(add)");

позже в цикле ожидания сообщения, в отдельном потоке: 

    int count = epoll_wait(_epollfd, evnts, EVENTS, -1);
    if (count == -1)
    {
        if (errno != EINTR)
        {
            perror("epoll_wait");
            return;
        }
    }

    for (int i = 0; i < count; ++i)
    {
        epoll_event & e = evnts[i];
        if (e.data.fd == _serverSock)
            connectionAccepted();
        else if (e.data.fd == _eventfd)
        {
            eventfd_t val;
            eventfd_read(_eventfd, &val);
            return;
        }
    }

и, конечно, код, который останавливает сервер: 

eventfd_write(_eventfd, 1);

По причинам, которые я не могу объяснить, я не смог разбудить epoll_wait(), просто написав на мероприятие. В конце концов, это сработало за несколько сеансов отладки.

Вот мой обходной путь: зная, что EPOLLOUT будет вызывать событие каждый раз, когда fd доступен для записи, я изменил код остановки на 

epoll_event evnt = {0};
evnt.data.fd = _eventfd;
evnt.events = EPOLLOUT;
if (epoll_ctl(_epollfd, EPOLL_CTL_MOD, _eventfd, &evnt) == -1)
    throw ServerError("epoll_ctl(mod)");

Теперь это работает, но так быть не должно.

Я не верю, что это должно быть сложно. Что я сделал не так?

Спасибо

Ответы [ 2 ]

3 голосов
/ 02 сентября 2012

У меня работает.Для справки вот полный код C: он печатает «eventfd_write», «1» и «DING: 1».Протестировано в Linux 2.6.35-30-generic # 56-Ubuntu SMP. 

#include <stdio.h>
#include <errno.h>
#include <sys/epoll.h>
#include <sys/eventfd.h>
#include <pthread.h>
#include <stdlib.h>

int _epollfd, _eventfd;

int init()
{
    _epollfd = epoll_create1(0);
    if (_epollfd == -1) abort();
    _eventfd = eventfd(0, EFD_NONBLOCK);
    struct epoll_event evnt = {0};
    evnt.data.fd = _eventfd;
    evnt.events = EPOLLIN | EPOLLET;
    if (epoll_ctl(_epollfd, EPOLL_CTL_ADD, _eventfd, &evnt) == -1)
        abort();
}

void *subprocess(void *arg)
{
    static const int EVENTS = 20;
    struct epoll_event evnts[EVENTS];
    while (1) {
        int count = epoll_wait(_epollfd, evnts, EVENTS, -1);
        printf("%d\n", count);
        if (count == -1)
        {
            if (errno != EINTR)
            {
                perror("epoll_wait");
                return NULL;
            }
        }

        int i;
        for (i = 0; i < count; ++i)
        {
            struct epoll_event *e = evnts + i;
            if (e->data.fd == _eventfd)
            {
                eventfd_t val;
                eventfd_read(_eventfd, &val);
                printf("DING: %lld\n", (long long)val);
                return NULL;
            }
        }
    }
}

int main()
{
    pthread_t th;
    init();
    if (pthread_create(&th, NULL, subprocess, NULL) != 0)
        abort();
    sleep(2);
    printf("eventfd_write\n");
    eventfd_write(_eventfd, 1);
    sleep(2);
}
1 голос
/ 04 сентября 2012

Если вы используете несколько потоков, вы должны связать свой вызов с eventfd_write в конце каждого потока.Это только один вариант.

...