select – Ожидание завершения ввода-вывода¶select – Waiting for I/O completion

/dev/poll объекты опроса¶/dev/poll polling objects

Solaris и его производные имеют /dev/poll. В то время как select() является O(наибольший файловый дескриптор) и poll() является O(количество файловых дескрипторов), /dev/poll является O(активные файловые дескрипторы).

Поведение /dev/poll очень близко к стандартному объекту poll().

devpoll.close()¶

Закрывает файловый дескриптор объекта опроса.

Добавлено в версии 3.4.

devpoll.closed¶

True если объект опроса закрыт.

Добавлено в версии 3.4.

devpoll.fileno()¶

Возвращает номер файлового дескриптора объекта опроса.

Добавлено в версии 3.4.

devpoll.register(fd[, eventmask])¶

Регистрирует файловый дескриптор в объекте опроса. Последующие вызовы метода poll() будут проверять, есть ли у файлового дескриптора ожидающие события ввода-вывода. fd может быть целым числом или объектом с методом fileno(), возвращающим целое число. Файловые объекты реализуют fileno(), поэтому их тоже можно использовать в качестве аргумента.

eventmask – необязательная битовая маска, описывающая тип событий, которые требуется проверять. Константы те же, что и для объекта poll(). Значение по умолчанию представляет собой комбинацию констант POLLIN, POLLPRI и POLLOUT.

Предупреждение

Регистрация уже зарегистрированного файлового дескриптора не является ошибкой, но результат не определен. Правильным действием будет сначала отменить регистрацию или изменить его. Это важное отличие от poll().

devpoll.modify(fd[, eventmask])¶

Этот метод выполняет unregister() с последующим register(). Он (немного) эффективнее, чем делать то же самое явно.

devpoll.unregister(fd)¶

Удаляет файловый дескриптор, отслеживаемый объектом опроса. Как и метод register(), fd может быть целым числом или объектом с методом fileno(), возвращающим целое число.

Попытка удалить файловый дескриптор, который никогда не был зарегистрирован, безопасно игнорируется.

devpoll.poll([timeout])¶

Опрашивает набор зарегистрированных файловых дескрипторов и возвращает возможно пустой список, содержащий кортежи из двух элементов (fd, event) для дескрипторов, у которых есть события или ошибки. fd – это файловый дескриптор, а event – битовая маска с установленными битами для сообщенных событий этого дескриптора: POLLIN – ожидание ввода, POLLOUT – указывает, что в дескриптор можно писать, и так далее. Пустой список означает, что вызов завершился по тайм-ауту и ни у одного файлового дескриптора не было событий. Если указан timeout, он задает время в миллисекундах, в течение которого система будет ждать событий перед возвратом. Если timeout опущен, равен -1 или None, вызов будет блокироваться до появления события для этого объекта poll.

Изменено в версии 3.5: Функция теперь повторяется с пересчитанным тайм-аутом при прерывании сигналом, за исключением случая, когда обработчик сигнала вызывает исключение (см. PEP 475 для обоснования), вместо вызова InterruptedError.

Объекты опроса с триггерами по переднему и уровневому фронту (epoll)¶Edge and level trigger polling (epoll) objects

https://linux.die.net/man/4/epoll

eventmask – это битовая маска, использующая следующие константы:

Константа	Значение
EPOLLIN	Доступен для чтения.
EPOLLOUT	Доступен для записи.
EPOLLPRI	Срочные данные для чтения.
EPOLLERR	На связанном fd произошла ошибка.
EPOLLHUP	На связанном fd произошел разрыв соединения.
EPOLLET	Устанавливает поведение триггера по переднему фронту; по умолчанию – поведение триггера по уровню.
EPOLLONESHOT	Устанавливает однократное поведение. После извлечения одного события файловый дескриптор внутренне отключается.
EPOLLEXCLUSIVE	Пробуждает только один объект epoll при событии на связанном fd. По умолчанию (если этот флаг не установлен) пробуждаются все объекты epoll, ожидающие на этом fd.
EPOLLRDHUP	Потоковый сокет: удаленная сторона закрыла соединение или завершила записывающую половину соединения.
EPOLLRDNORM	Эквивалентно EPOLLIN
EPOLLRDBAND	Полоса приоритетных данных доступна для чтения.
EPOLLWRNORM	Эквивалентно EPOLLOUT.
EPOLLWRBAND	Приоритетные данные могут быть записаны.
EPOLLMSG	Игнорируется.
EPOLLWAKEUP	Предотвращает ожидание во время ожидания событий.

Добавлено в версии 3.6: EPOLLEXCLUSIVE был добавлен. Поддерживается только ядром Linux 4.5 и новее.

Добавлено в версии 3.14: EPOLLWAKEUP был добавлен. Поддерживается только ядром Linux 3.5 и новее.

epoll.close()¶

Закрывает управляющий файловый дескриптор объекта epoll.

epoll.closed¶

True, если объект epoll закрыт.

epoll.fileno()¶

Возвращает номер файлового дескриптора управляющего fd.

epoll.fromfd(fd)¶

Создает объект epoll из заданного файлового дескриптора.

epoll.register(fd[, eventmask])¶

Регистрирует файловый дескриптор fd в объекте epoll.

epoll.modify(fd, eventmask)¶

Изменяет зарегистрированный файловый дескриптор fd.

epoll.unregister(fd)¶

Удаляет зарегистрированный файловый дескриптор из объекта epoll.

Изменено в версии 3.9: Метод больше не игнорирует ошибку EBADF.

epoll.poll(timeout=None, maxevents=-1)¶

Ожидает события. timeout в секундах (float)

Изменено в версии 3.5: Функция теперь повторяется с пересчитанным тайм-аутом при прерывании сигналом, за исключением случая, когда обработчик сигнала вызывает исключение (см. PEP 475 для обоснования), вместо вызова InterruptedError.

Объекты опроса (polling)¶Polling objects

Системный вызов poll(), поддерживаемый в большинстве Unix-систем, обеспечивает лучшую масштабируемость для сетевых серверов, обслуживающих одновременно множество клиентов. poll() масштабируется лучше, поскольку системный вызов требует только перечисления интересующих файловых дескрипторов, тогда как select() строит битовую маску, устанавливает биты для интересующих fd, а затем всю битовую маску нужно снова линейно сканировать. select() имеет сложность O(наибольший файловый дескриптор), тогда как poll() – O(количество файловых дескрипторов).

poll.register(fd[, eventmask])¶

Регистрирует файловый дескриптор в объекте опроса. Последующие вызовы метода poll() будут проверять, есть ли у файлового дескриптора ожидающие события ввода-вывода. fd может быть целым числом или объектом с методом fileno(), возвращающим целое число. Файловые объекты реализуют fileno(), поэтому их тоже можно использовать в качестве аргумента.

eventmask – необязательная битовая маска, описывающая типы событий для проверки. Может быть комбинацией констант POLLIN, POLLPRI и POLLOUT, описанных в таблице ниже. Если не указана, по умолчанию проверяются все три типа событий.

Константа	Значение
POLLIN	Есть данные для чтения.
POLLPRI	Есть срочные данные для чтения.
POLLOUT	Готов к выводу: запись не будет блокироваться.
POLLERR	Ошибка какого-либо рода.
POLLHUP	Разъединение.
POLLRDHUP	Удаленный сокет потока закрыл соединение или завершил запись на своей стороне.
POLLNVAL	Недопустимый запрос: дескриптор не открыт.

Регистрация уже зарегистрированного файлового дескриптора не является ошибкой и имеет тот же эффект, как если бы дескриптор был зарегистрирован ровно один раз.

poll.modify(fd, eventmask)¶

Изменяет уже зарегистрированный fd. Это имеет тот же эффект, что и register(fd, eventmask). Попытка изменить файловый дескриптор, который никогда не был зарегистрирован, приводит к возбуждению исключения OSError с errno ENOENT.

poll.unregister(fd)¶

Удаляет файловый дескриптор, отслеживаемый объектом опроса. Как и метод register(), fd может быть целым числом или объектом с методом fileno(), возвращающим целое число.

Попытка удалить файловый дескриптор, который никогда не был зарегистрирован, приводит к возбуждению исключения KeyError.

poll.poll([timeout])¶

Опрашивает набор зарегистрированных файловых дескрипторов и возвращает, возможно, пустой список, содержащий (fd, event) кортежи из двух элементов для дескрипторов, по которым есть события или ошибки. fd – файловый дескриптор, а event – битовая маска с установленными битами для сообщаемых событий этого дескриптора: POLLIN для ожидания ввода, POLLOUT для указания, что в дескриптор можно писать, и так далее. Пустой список означает, что вызов завершился по таймауту и ни у одного файлового дескриптора не было событий. Если указан timeout, он задает время ожидания в миллисекундах, в течение которого система будет ожидать события перед возвратом. Если timeout опущен, отрицателен или равен None, вызов будет блокироваться до появления события для этого объекта опроса.

Изменено в версии 3.5: Функция теперь повторяется с пересчитанным тайм-аутом при прерывании сигналом, за исключением случая, когда обработчик сигнала вызывает исключение (см. PEP 475 для обоснования), вместо вызова InterruptedError.

Объекты Kqueue¶Kqueue objects

kqueue.close()¶

Закрывает файловый дескриптор управления объекта kqueue.

kqueue.closed¶

True, если объект kqueue закрыт.

kqueue.fileno()¶

Возвращает номер файлового дескриптора управляющего fd.

kqueue.fromfd(fd)¶

Создаёт объект kqueue из заданного файлового дескриптора.

kqueue.control(changelist, max_events[, timeout]) → eventlist¶

Низкоуровневый интерфейс к kevent

• changelist должен быть итерируемым объектом, содержащим объекты kevent, или None

• max_events должен быть 0 или положительным целым числом

• тайм-аут в секундах (можно использовать числа с плавающей точкой); по умолчанию None, что означает бесконечное ожидание

Изменено в версии 3.5: Функция теперь повторяется с пересчитанным тайм-аутом при прерывании сигналом, за исключением случая, когда обработчик сигнала вызывает исключение (см. PEP 475 для обоснования), вместо вызова InterruptedError.

Объекты kevent¶Kevent objects

https://man.freebsd.org/cgi/man.cgi?query=kqueue&sektion=2

kevent.ident¶

Значение, используемое для идентификации события. Интерпретация зависит от фильтра, но обычно это файловый дескриптор. В конструкторе ident может быть либо целым числом, либо объектом с методом fileno(). kevent хранит целое число внутри.

kevent.filter¶

Имя фильтра ядра.

Константа	Значение
KQ_FILTER_READ	Принимает дескриптор и возвращает результат, когда doступны данные для чтения.
KQ_FILTER_WRITE	Принимает дескриптор и возвращает результат, когда doступны данные для записи.
KQ_FILTER_AIO	Запросы AIO.
KQ_FILTER_VNODE	Возвращает результат, когда происходит одно или несколько запрошенных событий, отслеживаемых в fflag.
KQ_FILTER_PROC	Отслеживает события для идентификатора процесса.
KQ_FILTER_NETDEV	Отслеживает события на сетевом устройстве (недоступно в macOS).
KQ_FILTER_SIGNAL	Возвращает результат, когда отслеживаемый сигнал doставляется процессу.
KQ_FILTER_TIMER	Устанавливает произвольный таймер.

kevent.flags¶

Действие фильтра.

Константа	Значение
KQ_EV_ADD	Добавляет или изменяет событие.
KQ_EV_DELETE	Удаляет событие из очереди.
KQ_EV_ENABLE	Разрешает control() возвращать событие.
KQ_EV_DISABLE	Отключает событие.
KQ_EV_ONESHOT	Удаляет событие после первого срабатывания.
KQ_EV_CLEAR	Сбрасывает состояние после извлечения события.
KQ_EV_SYSFLAGS	Внутреннее событие.
KQ_EV_FLAG1	Внутреннее событие.
KQ_EV_EOF	Специфическое для фильтра условие EOF.
KQ_EV_ERROR	Смотрите возвращаемые значения.

kevent.fflags¶

Специфические для фильтра флаги.

KQ_FILTER_READ и KQ_FILTER_WRITE флаги фильтра:

Константа	Значение
KQ_NOTE_LOWAT	Нижний водяной знак буфера сокета.

KQ_FILTER_VNODE флаги фильтра:

Константа	Значение
KQ_NOTE_DELETE	Была вызвана функция unlink().
KQ_NOTE_WRITE	Произошла запись.
KQ_NOTE_EXTEND	Файл был расширен.
KQ_NOTE_ATTRIB	Был изменён атрибут.
KQ_NOTE_LINK	Количество ссылок изменилось.
KQ_NOTE_RENAME	Файл был переименован.
KQ_NOTE_REVOKE	Доступ к файлу был отозван.

KQ_FILTER_PROC флаги фильтра:

Константа	Значение
KQ_NOTE_EXIT	Процесс завершился.
KQ_NOTE_FORK	Процесс вызвал fork().
KQ_NOTE_EXEC	Процесс запустил новый процесс.
KQ_NOTE_PCTRLMASK	Внутренний флаг фильтра.
KQ_NOTE_PDATAMASK	Внутренний флаг фильтра.
KQ_NOTE_TRACK	Отслеживает процесс после вызова fork().
KQ_NOTE_CHILD	Возвращается для дочернего процесса для NOTE_TRACK.
KQ_NOTE_TRACKERR	Не удалось присоединиться к дочернему процессу.

KQ_FILTER_NETDEV флаги фильтра (недоступны в macOS):

Константа	Значение
KQ_NOTE_LINKUP	Соединение активно.
KQ_NOTE_LINKDOWN	Соединение неактивно.
KQ_NOTE_LINKINV	Состояние соединения некорректно.

kevent.data¶

Данные, специфичные для фильтра.

kevent.udata¶

Пользовательское значение.