в драйвере устройства linux char, что делает функция poll_queue_pro c? - PullRequest
Новая
       78

в драйвере устройства linux char, что делает функция poll_queue_pro c?

0 голосов
/ 30 апреля 2020

Существует концепция синхронного опроса для нескольких файлов устройств в linux, и я пытаюсь понять, как это работает.
в linux 2.6.23 исходные драйверы / char / random. c, Я вижу следующий код 

static DECLARE_WAIT_QUEUE_HEAD(random_read_wait);
static DECLARE_WAIT_QUEUE_HEAD(random_write_wait);

static unsigned int
random_poll(struct file *file, poll_table * wait)
{
    unsigned int mask;

    poll_wait(file, &random_read_wait, wait);
    poll_wait(file, &random_write_wait, wait);
    mask = 0;
    if (input_pool.entropy_count >= random_read_wakeup_thresh)
        mask |= POLLIN | POLLRDNORM;
    if (input_pool.entropy_count < random_write_wakeup_thresh)
        mask |= POLLOUT | POLLWRNORM;
    return mask;
}

poll_table определен, как указано ниже, в include / linux / poll.h 

typedef void (*poll_queue_proc)(struct file *, wait_queue_head_t *, struct poll_table_struct *);

typedef struct poll_table_struct {
    poll_queue_proc qproc;
} poll_table;

, который я видел в книге (гл.5, Essential Linux Драйверы устройств, Venkateswaran), что «poll_table представляет собой таблицу очередей ожидания, принадлежащих драйверам устройств, которые опрашиваются для данных» но источник говорит, что это просто указатель на функцию. и я не могу найти, что делает эта функция qpro c. Ниже приведена функция poll_wait, определенная в include / linux / poll.h. 

static inline void poll_wait(struct file * filp, wait_queue_head_t * wait_address, poll_table *p)
{
    if (p && wait_address)
        p->qproc(filp, wait_address, p);
}

, и в книге говорится (о примере драйвера char для мыши): "mouse_poll () использует библиотечную функцию, poll_wait (), чтобы добавить очередь ожидания (mouse_wait) в ядро ​​poll_table и go для сна. " поэтому poll_wait может спать, но в приведенной выше функции random_poll () мы видим две последовательные функции poll_wait. Так что random_poll последовательно опрашивает доступность для чтения и записи и отправляет маску приложению? Буду признателен, если кто-нибудь покажет мне пример функции poll_queue_pro c. Я не смог найти его в источнике драйвера linux (он должен появляться только в приложении?).

1 Ответ

0 голосов
/ 30 апреля 2020

drivers/char/random.c:random_poll() вызывается, когда пользовательское пространство вызывает select() (или poll() или epoll_wait() в этом отношении) с файловым дескриптором, ссылающимся на /dev/random.

Эти системные вызовы являются основой мультиплексирование событий . В следующей программе пользовательское пространство открывает несколько источников ввода (скажем, /dev/random и /dev/ttyS4) и вызывает select() на обоих из них , чтобы заблокировать, пока любой из них не получит входные данные для чтения. (Существуют и другие источники событий, кроме ввода, ввод является самым простым.) 

#include <sys/select.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>


#define _SYSE(ret, msg) do {                    \
    if (ret == -1) {                            \
        perror(msg);                            \
        exit(EXIT_FAILURE);                     \
    }                                           \
} while (0)

static int /*bool: EOF detected*/ consume_fd(int fd, const char* msg)
{
    char tmp[64];
    ssize_t nread;

    nread = read(fd, tmp, sizeof(tmp));
    _SYSE(nread, "read");
    if (nread == 0 /*EOF*/)
        return 1;

    printf("%s: consumed %ld bytes\n", msg, nread);
    return 0;
}

int main(void)
{
    int random_fd, tty_fd, nfds = 0;

    random_fd = open("/dev/random", O_RDONLY);
    _SYSE(random_fd, "open random");
    if (random_fd > nfds)
        nfds = random_fd+1;

    tty_fd = open("/dev/ttyS4", O_RDONLY);
    _SYSE(tty_fd, "open tty");
    if (tty_fd > nfds)
        nfds = tty_fd+1;

    while (1) {
        fd_set in_fds;
        int ret;

        FD_ZERO(&in_fds);
        FD_SET(random_fd, &in_fds);
        FD_SET(tty_fd, &in_fds);

        ret = select(nfds, &in_fds, NULL, NULL, NULL);
        _SYSE(ret, "select");

        if (FD_ISSET(random_fd, &in_fds)) {
            int eof_detected = consume_fd(random_fd, "random");
            if (eof_detected) 
                break;
        }
        if (FD_ISSET(tty_fd, &in_fds)) {
            int eof_detected = consume_fd(tty_fd, "tty");
            if (eof_detected) 
                break;
        }
    }
    return 0;
}

Вывод появится, как только появятся случайные числа или в последовательной строке будут данные. (Обратите внимание, что в настоящее время /dev/random не блокирует, а генерирует псевдослучайные числа, поэтому вывод действительно быстрый.)

Когда select() входит в ядро, вызывается random_poll(), и другая, сопоставимая, функция где-то на уровне TTY - просто потому, что select() передает эти файловые дескрипторы в качестве параметров. Предполагается, что эти функции просто помещают вызывающего в poll_table, который находится вне вашей досягаемости (он представляет вызывающую задачу для этой цели).

На втором этапе реализация select() затем приостанавливается звонящий, пока любое из событий не станет правдой. (См. fs/select.c.)

...