Шрифт:
После открытия
/dev/poll
программа должна инициализировать массив структур pollfd
(тех же, которые используются функцией poll
, но в этом случае поле revents
не используется). Затем массив передается ядру вызовом write
(структура записывается непосредственно в /dev/poll
). После этого программа может вызывать ioctl DP_POLL
и ждать событий. При вызове ioctl
передается следующая структура:
struct dvpoll {
struct pollfd* dp_fds;
int dp_nfds;
int dp_timeout;
};
Поле
dp_fds
указывает на буфер, используемый для хранения массива структур pollfd
, возвращаемых вызовом ioctl
. Поле dp_nfds
задает размер буфера. Вызов ioctl
блокируется до появления интересующих программу событий на любом из опрашиваемых дескрипторов, или до прохождения dp_timeout
миллисекунд. При нулевом значении тайм-аута функция ioctl
возвращается немедленно (то есть данный способ может использоваться для реализации неблокируемых сокетов). Тайм-аут, равный -1, означает неопределенно долгое ожидание. Измененный код функции
str_cli
, переписанной из листинга 6.2 с использованием /dev/poll
, приведен в листинге 14.7. Листинг 14.7. Функция str_cli, использующая /dev/poll
//advio/str_cli_poll03.c
1 #include "unp.h"
2 #include <sys/devpoll.h>
3 void
4 str_cli(FILE *fp, int sockfd)
5 {
6 int stdineof;
7 char buf[MAXLINE];
8 int n;
9 int wfd;
10 struct pollfd pollfd[2];
11 struct dvpoll dopoll;
12 int i;
13 int result;
14 wfd = Open("/dev/poll", O_RDWR, 0);
15 pollfd[0].fd = fileno(fp);
16 pollfd[0].events = POLLIN;
17 pollfd[0].revents = 0;
18 pollfd[1].fd = sockfd;
19 pollfd[1].events = POLLIN;
20 pollfd[1].revents = 0;
21 Write(wfd, pollfd, sizeof(struct pollfd) * 2);
22 stdineof = 0;
23 for (;;) {
24 /* блокирование до готовности сокета */
25 dopoll.dp_timeout = -1;
26 dopoll.dp_nfds = 2;
27 dopoll.dp_fds = pollfd;
28 result = Ioctl(wfd, DP_POLL, &dopoll);
29 /* цикл по готовым дескрипторам */
30 for (i = 0; i < result; i++) {
31 if (dopoll.dp_fds[i].fd == sockfd) {
32 /* сокет готов к чтению */
33 if ((n = Read(sockfd, buf, MAXLINE)) == 0) {
34 if (stdineof == 1)
35 return; /* нормальное завершение */
36 else
37 err_quit("str_cli: server terminated prematurely");
38 }
39 Write(fileno(stdout), buf, n);
40 } else {
41 /* дескриптор готов к чтению */
42 if ((n = Read(fileno(fp), buf, MAXLINE)) == 0) {
43 stdineof = 1;
44 Shutdown(sockfd, SHUT_WR); /* отправка FIN */
45 continue;
46 }