poll()

Направлять ввод/вывод на различные файловые дескрипторы

Прототип:

#include <sys/poll.h>
int poll( struct pollfd *fds,
nfds_t nfds,
int timeout );

Аргументы:

fds
Массив элементов struct pollfd, который определяет интересующие файловые дескрипторы.
nfds
Количество элементов в массиве fds.
timeout
Предельное время ожидания в миллисекундах.

Библиотека:

libc

Описание:

Функция poll () предоставляет приложениям механизм мультиплексирования операций ввода/вывода над набором файловых дескрипторов.

Аргумент fds - это массив из структур struct pollfd.

Функция poll() проверяет каждый член массива файловых дескрипторов fds на предмет наличия событий, указанных в events. Количество структур struct pollfd в массиве fds определяется аргументом nfds. Членами массива являются структуры struct pollfd, внутри которых fd указывает на дескриптор открытого файла, а аргументы events и revents представляют собой битовые маски, построенные с помощью комбинации (операция ИЛИ) следующих флагов событий:

POLLERR
Произошла ошибка на устройстве. Этот флаг действителен только в битовой маске revents и игнорируется в events.
POLLHUP
Устройство было отключено. Это событие и POLLOUT являются взаимоисключающими; устройство не является доступным для записи, если до этого произошло его отключение. Однако это событие совместимо с POLLIN, POLLRDNORM, POLLRDBAND или POLLPRI. Если удаленный сокет закрыт, poll() возвращает событие POLLIN, а не POLLHUP. Этот флаг действителен только в битовой маске revents и игнорируется в events.
POLLIN
Данные могут быть прочитаны без блокировки, кроме данных с высоким приоритетом. Это эквивалент POLLRDNORM | POLLRDBAND.
POLLNVAL
Указано недопустимое значение файлового дескриптора. Этот флаг действителен только для члена revents и игнорируется в events.
POLLOUT
Обычные данные можно записывать без блокировки.
POLLPRI
Данные с высоким приоритетом можно читать без блокировки.
POLLRDBAND
Приоритетные данные можно читать без блокировки.
POLLRDNORM
Обычные данные можно читать без блокировки.
POLLWRBAND
Приоритетные данные могут быть записаны.
POLLWRNORM
Эквивалент POLLOUT.

Значение и семантика обычных, приоритетных и высокоприоритетных данных зависят от файла и устройства.

Если значение fd меньше, чем 0, события events игнорируются, а для revents устанавливается значение 0 в этой записи при возврате из poll().

В каждой структуре struct pollfd poll() очищает элемент revents, за исключением тех случаев, когда приложение запрашивало отчет об условии, задав один из битов events, перечисленных выше, функция poll() устанавливает соответствующий бит в revents, если запрошенное условие истинно. Кроме того, функция poll() устанавливает флаг POLLHUP, POLLERR и POLLNVAL в revents, если условие истинно, даже если приложение не установило соответствующий бит в events.

Если ни одно из определенных событий не происходит ни в одном из выбранных файловых дескрипторов, функция poll() выдерживает timeout миллисекунд, чтобы событие произошло в любом из них. Если значение timeout равно 0, poll() возвращается немедленно. Если значение timeout равно -1, poll() блокируется до тех пор, пока не произойдет запрошенное событие или пока вызов не будет прерван.

Флаг O_NONBLOCK не влияет на функцию poll().

Функция poll() позволяет опрашивать обычные файлы, терминальные и псевдотерминальные устройства, FIFO и каналы.

Обычные файлы обычно имеют статус TRUE на чтение и запись.

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

Возвращаемое значение:

>0
Общее количество выбранных файловых дескрипторов.
0
Истекло время ожидания вызова, но не один дескриптор файлов не выбран.
-1
Возникла ошибка. Код ошибки записан в errno.

Коды ошибок:

EAGAIN
Не удалось выделить внутренние структуры данных, но последующий запрос может быть успешным.
EINTR
Получен сигнал во время выполнения poll().
EFAULT
Аргумент fds указывает на несуществующую часть адресного пространства вызывающего процесса.

Примеры:

#include <sys/socket.h>
#include <netinet/in.h>
#include <sys/poll.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <stdio.h>
#include <pthread.h>
#include <fcntl.h>
#include <errno.h>
#include <string.h>
struct sockaddr_in sad;
void * client( void *arg )
{
int s;
const char *p = "Some data\n";
if ( (s = socket( AF_INET, SOCK_STREAM, 0 )) == -1 )
{
perror( "socket" );
return (NULL);
}
if ( connect( s, (struct sockaddr *)&sad, sizeof( sad ) ) == -1 )
{
perror("connect");
return (NULL);
}
write( s, p, strlen( p ) );
close( s );
return (NULL);
}
int main( void )
{
struct pollfd fds;
int s = -1, s2 = -1, done_accept = 0, oflags, ret;
char buf[100];
if ( (s = socket( AF_INET, SOCK_STREAM, 0 )) == -1 )
{
perror( "socket" );
return (1);
}
sad.sin_family = AF_INET;
sad.sin_len = sizeof( sad );
sad.sin_addr.s_addr = inet_addr( "127.0.0.1" );
sad.sin_port = htons( 1234 );
fds.fd = s;
fds.events = POLLRDNORM;
oflags = fcntl( s, F_GETFL );
oflags |= O_NONBLOCK;
fcntl( s, F_SETFL, oflags );
if ( bind( s, (struct sockaddr *)&sad, sizeof( sad ) ) == -1 )
{
perror( "bind" );
return (1);
}
listen( s, 5 );
if ( (ret = pthread_create( NULL, NULL, client, NULL )) != EOK )
{
fprintf( stderr, "pthread_create: %s\n", strerror( ret ) );
return (1);
}
for ( ; ; )
{
if ( (ret = poll( &fds, 1, -1 )) == -1 )
{
perror( "poll" );
break;
} else
if ( ret != 1 || (fds.revents & POLLRDNORM) == 0 )
{
break;
}
if ( done_accept )
{
if ( (ret = read( s2, buf, sizeof( buf ) )) <= 0 )
{
break;
}
printf( "%s", buf );
} else {
if ( (s2 = accept( s, NULL, 0 )) == -1 )
{
perror( "accept" );
break;
}
fds.fd = s2;
done_accept = 1;
}
}
close( s );
close( s2 );
return (0);
}

Классификация:

POSIX 1003.1 XSI

Точка остановки потока
Да
Обработчик прерываний
Нет
Обработчик сигналов
Нет
В потоке
Да

Предостережения:

Не все менеджеры поддерживают POLLPRI, POLLPRI, POLLERR и POLLHUP.

Тематические ссылки:

struct pollfd, read(), select(), write()




Предыдущий раздел: Описание API системной библиотеки