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

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

Листинг 10.4. Функция sctp_strcliecho

1 #include "unp.h"

2 #define SCTP_MAXLINE 800

3 void

4 sctpstr_cli_echoall(FILE *fp, int sock_fd, struct sockaddr to,

5 socklen_t tolen)

6 {

7 struct sockaddr_in peeraddr;

8 struct sctp_sndrcvinfo sri;

9 char sendline[SCTP_MAXLlNE], recvline[SCTP_MAXLINE];

10 socklen_t len;

11 int rd_sz, i, strsz;

12 int msg_flags;

13 bzero(sendline, sizeof(sendline));

14 bzero(&sri, sizeof(sri));

15 while (fgets(sendline, SCTP_MAXLINE - 9, fp) != NULL) {

16 strsz = strlen(sendline);

17 if (sendline[strsz-1] == '\n') {

18 sendline[strsz-1] = '\0';

19 strsz--;

20 }

21 for (i=0; i<SERV_MAX_SCTP_STRM; i++) {

22 snprintf(sendline + strsz, sizeof(sendline) - strsz,

23 ".msg %d", i);

24 Sctp_sendmsg(sock_fd, sendline, sizeof(sendline),

25 to, tolen, 0, 0, i, 0, 0);

26 }

27 for (i =0; i < SERV_MAX_SCTP_STRM; i++) {

28 len = sizeof(peeraddr);

29 rd_sz = Sctp_recvmsg(sock_fd, recvline, sizeof(recvline),

30 (SA*)&peeraddr, &len, &sri, &msg_flags);

31 printf("From str:%d seq:%d (assoc:0x%x)",

32 sri.sinfo_stream, sri.sinfo_ssn,

33 (u_int)sri, sinfo_assoc_id);

34 printf("%.*s\n", rd_sz, recvline);

35 }

36 }

37 }

Инициализация структур данных и ожидание ввода

13-15
Как и в предыдущем примере, клиент инициализирует структуру
sri
, предназначенную для настройки потока, с которым клиент будет работать. Кроме того, клиент обнуляет буфер данных, из которого считывается пользовательский ввод. Затем программа входит в основной цикл, блокируясь в вызове
fgets
.

Предварительная обработка сообщения

16-20
Клиент определяет размер сообщения и удаляет символ перевода строки, если таковой находится в конце буфера.

Отправка сообщения по всем потокам

21-26
Клиент отсылает сообщение с помощью функции
sctp_sendmsg
. Передается все содержимое буфера длиной
SCTP_MAXLINE
. Перед отправкой сообщения к нему добавляется строка
.msg
, и номер потока, чтобы мы могли впоследствии определить порядок получения сообщений и сравнить его с порядком отправки сообщений. Обратите внимание, что клиент отправляет сообщения по заданному количеству потоков, не проверяя, сколько потоков было согласовано с сервером. Может получиться так, что некоторые операции отправки сообщений завершатся с ошибкой, если количество потоков будет снижено по запросу собеседника.

ПРИМЕЧАНИЕ

Этот код может работать неправильно, если окна приема и отправки будут слишком малы. Если окно приема собеседника слишком мало, клиент может заблокироваться. Поскольку клиент не переходит к считыванию данных из приемного буфера, пока он не отправит все сообщения, сервер также может заблокироваться в ожидании освобождения буфера клиента. В результате обе конечные точки SCTP зависнут. Приведенная программа не рассчитана на масштабирование. Она предназначена лишь для иллюстрации потоков и блокирования очередей в простейшем варианте.
Считывание и отображение эхо-ответа

27-35
Клиент блокируется в цикле считывания всех ответных сообщений сервера, которые отображаются на экране по мере поступления. После считывания последнего сообщения сервера клиент возвращается к обработке ввода пользователя.

Запуск программы

Мы запустили клиент и сервер на разных компьютерах с FreeBSD, между которыми был установлен настраиваемый маршрутизатор (рис. 10.4). Маршрутизатор может создавать задержку и сбрасывать часть пакетов. Сначала мы запускаем программу без сброса пакетов на маршрутизаторе.