UNIX: разработка сетевых приложений
вернуться

Стивенс Уильям Ричард
Шрифт:

26 char buff[2048];

27 printf("SIGURG received\n");

28 n = Recv(connfd, buff, sizeof(buff) - 1, MSG_OOB);

29 buff[n] = 0; /* завершающий пустой байт */

30 printf("read %d OOB byte\n", n);

31 }

14-20
Принимающий процесс устанавливает размер приемного буфера сокета приемника равным 4096 байт. Этот размер наследуется присоединенным сокетом после установления соединения. Затем процесс вызывает функцию
accept
, задает обработчик для сигнала
SIGURG
и задает владельца сокета. В главном цикле (бесконечном) вызывается функция
pause
.

22-31
Обработчик сигнала вызывает функцию
recv
для считывания внеполосных данных.

Если мы запускаем сначала принимающую программу, а затем программу отправки, то получаем следующий результат выполнения программы отправки:

macosx % tcpsend05 freebsd 5555

wrote 16384 bytes of normal data

wrote 1 byte of OOB data

wrote 1024 bytes of normal data

Как и ожидалось, все данные помещаются в буфер отправки сокета отправителя, и программа завершается. Ниже приведен результат работы принимающей программы:

freebsd4 % tcprecv05 5555

SIGURG received

recv error: Resource temporarily unavailable

Сообщение об ошибке, которое выдает наша функция

err_sys
, соответствует ошибке
EAGAIN
, которая в FreeBSD аналогична ошибке
EWOULDBLOCK
. TCP посылает уведомление об отправке внеполосных данных принимающему TCP, который в результате генерирует сигнал
SIGURG
для принимающего процесса. Но когда вызывается функция
recv
и задается флаг
MSG_OOB
, байт с внеполосными данными не может быть прочитан.

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

ПРИМЕЧАНИЕ

В реализациях, происходящих от Беркли [128, с. 1016-1017], можно отметить две близких проблемы. Во-первых, даже если приемный буфер сокета заполнен, ядро всегда принимает от процесса внеполосные данные для отправки собеседнику. Во-вторых, когда отправитель посылает байт с внеполосными данными, немедленно посылается сегмент TCP, содержащий срочное уведомление. Все обычные проверки вывода TCP (алгоритм Нагла, предотвращение синдрома «глупого окна») при этом блокируются.

Пример: единственность отметки внеполосных данных в TCP

Нашим очередным примером мы иллюстрируем тот факт, что для данного соединения TCP существует всего одна отметка внеполосных данных, и если новые внеполосные данные прибудут прежде, чем принимающий процесс начнет считывать пришедшие ранее внеполосные данные, то предыдущая отметка будет утеряна.

В листинге 24.10 показана посылающая программа, аналогичная программе, приведенной в листинге 24.6. Отличие заключается в том, что сейчас мы добавили еще одну функцию

send
для отправки внеполосных данных и еще одну функцию
write
для записи обычных данных.

Листинг 24.10. Отправка двух байтов внеполосных данных друг за другом

//oob/tcpsend06.c

1 #include "unp.h"

2 int

3 main(int argc, char **argv)

4 {

5 int sockfd;

6 if (argc != 3)

7 err_quit("usage: tcpsend04 <host> <port#>");

8 sockfd = Tcp_connect(argv[1], argv[2]);

9 Write(sockfd, "123", 3);

10 printf("wrote 3 bytes of normal data\n");

11 Send(sockfd, "4", 1, MSG_OOB);

12 printf("wrote 1 byte of OOB data\n");

13 Write(sockfd, "5", 1);

14 printf("wrote 1 byte of normal data\n");

15 Send(sockfd,. "6", 1, MSG_OOB);

16 printf("wrote 1 byte of OOB data\n");

17 Write(sockfd, "7", 1);

18 printf("wrote 1 byte of normal data\n");

19 exit(0);

20 }

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

Принимающая программа идентична программе, приведенной в листинге 24.7, где вызывается функция

sleep
, которая после установления соединения переводит получателя в спящее состояние на 5 с, чтобы позволить данным прибыть на принимающий TCP. Ниже приводится результат выполнения этой программы: