Как использовать функцию poll C для просмотра именованных каналов в Linux?

Question

Я пытаюсь написать программу, в которой я должен наблюдать за окончанием именованных каналов, используя функцию poll. У меня есть цикл for для проверки каждой трубы всякий раз, когда опрос возвращает>0, и я знаю, что когда труба закрывается из процедуры на другом конце, я получу POLLHUP или POLLIN | POLLHUP в поле месторасположения структуры pollfd.

Мой вопрос: когда одна труба действительно закрывается и возвращает мне POLLHUP, что произойдет в следующем цикле? Будет ли он возвращать POLLHUP снова и снова в следующем и любом последующем цикле или функция poll будет игнорировать его после первого POLLHUP?

Answer 1

Минимальный пример

Источник ниже. Использование:

sudo mknod poll0.tmp p
sudo mknod poll1.tmp p
sudo chmod 666 poll*.tmp
./poll.out

На другой оболочке:

printf a > poll0.tmp
printf b > poll1.tmp

Выход:

loop
POLLIN i=0 n=1 buf=a
loop
POLLHUP i=0
loop
POLLIN i=1 n=1 buf=b
POLLHUP i=1
loop

Итак, обратите внимание, как poll ждет чтения без зацикливания.

Пример кулера:

(while true; do date; sleep 1; done) > poll0.tmp &
(while true; do date; sleep 2; done) > poll1.tmp &

0 пишется каждую секунду, и 1 каждые две секунды, что показывает, как poll() имеет дело с обоими входами одновременно, не останавливая друг друга.

Источник:

#define _XOPEN_SOURCE 700
#include <fcntl.h> /* creat, O_CREAT */
#include <poll.h> /* poll */
#include <stdio.h> /* printf, puts, snprintf */
#include <stdlib.h> /* EXIT_FAILURE, EXIT_SUCCESS */
#include <unistd.h> /* read */

int main(void) {
    enum { N = 2 };
    char buf[1024], path[1024];
    int fd, i, n;
    short revents;
    struct pollfd pfds[N];

    for (i = 0; i < N; ++i) {
        snprintf(path, sizeof(path), "poll%d.tmp", i);
        /* O_NONBLOCK is required or else the open blocks
         * until the other side of the pipe opens. */
        fd = open(path, O_RDONLY | O_NONBLOCK);
        if (fd == -1) {
            perror("open");
            exit(EXIT_FAILURE);
        }
        pfds[i].fd = fd;
        /* Only events in this mask will be listened to.
         * However, there are also some events that are unmaskable,
         * notably POLLHUP when pipe closes! */
        pfds[i].events = POLLIN;
    }
    while (1) {
        puts("loop");
        i = poll(pfds, N, -1);
        if (i == -1) {
            perror("poll");
            exit(EXIT_FAILURE);
        }
        for (i = 0; i < N; ++i) {
            revents = pfds[i].revents;
            if (revents & POLLIN) {
                n = read(pfds[i].fd, buf, sizeof(buf));
                printf("POLLIN i=%d n=%d buf=%.*s\n", i, n, n, buf);
            }
            if (revents & POLLHUP) {
                printf("POLLHUP i=%d\n", i);

                /* This happens when the other side closed.
                 * This event is only cleared when we close the reader. */

                /* poll won't set POLLHUP anymore once all fds are closed.
                 * Any futher polls on this will give the POLLNVAL event instead. */
                close(pfds[i].fd);

                /* negative fds are ignored. So if we negate an FD,
                 * we can both turn if off for a while, and turn it on
                 * later on by re-nagating it. */
                pfds[i].fd *= -1;
            }
        }
    }
}

Компилировать с:

gcc -o poll.out -std=c99 poll.c

Проверено в Ubuntu 14.04.

GitHub вверх по течению.

Чтобы ответить на оригинальный вопрос:

когда один канал действительно закроется и вернет мне POLLHUP, что произойдет в следующем цикле? Будет ли он возвращать POLLHUP снова и снова в следующем и любом последующем цикле или функция poll будет игнорировать его после первого POLLHUP?

Удалить строки:

close(pfds[i].fd);
pfds[i].fd *= -1;

и вы увидите, что он зацикливается навсегда POLLHUP,

Удалить только:

close(pfds[i].fd);

и вы получите POLLNVAL вместо этого, поскольку он пытается использовать закрытый сокет fd: Linux, обрабатывает POLLERR POLLHUP POLLNVAL

Answer 2

Он будет продолжать устанавливать POLLHUP в посту.
Также см. http://linux.die.net/man/3/poll для справки.