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

  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). Маршрутизатор может создавать задержку и сбрасывать часть пакетов. Сначала мы запускаем программу без сброса пакетов на маршрутизаторе.

Рис. 10.4. Тестовая конфигурация сети

Мы запускаем сервер с аргументом 0 в командной строке, благодаря чему сервер не увеличивает номер потока при отправке эхо-ответа.

Затем мы запускаем клиент, передавая ему в командной строке адрес эхо-сервера и дополнительный аргумент, указывающий на необходимость отправки сообщений по всем потокам одновременно.

 freebsd4% sctpclient01 10.1.4.1 echo
 Echoing messages to all streams
  Hello
 From str:0 seq:0 (assoc:0xc99e15a0):Hello.msg.0
 From str:1 seq:0 (assoc.0xc99e15a0):Hello.msg.1
 From str:2 seq:0 (assoc:0xc99e15a0):Hello.msg.2
 From str:3 seq:0 (assoc 0xc99e15a0):Hello.msg.3
 From str:4 seq:0 (assoc.0xc99e15a0):Hello.msg.4
 From str:5 seq:0 (assoc:0xc99e15a0):Hello.msg.5
 From str:6 seq:0 (assoc.0xc99e15a0):Hello.msg.6
 From str:7 seq:0 (assoc:0xc99e15a0):Hello.msg.7
 From str:8 seq:0 (assoc:0xc99e15a0):Hello.msg.8
 From str:9 seq:0 (assoc:0xc99e15a0).Hello.msg.9
  ^D
 freebsd4%

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

 freebsd4% sctpclient01 10.1.4.1 echo
 Echoing messages to all streams
  Hello
 From str:0 seq:0 (assoc:0xc99e15a0):Hello.msg.0
 From str:2 seq:0 (assoc:0xc99e15a0):Hello.msg.2
 From str:3 seq:0 (assoc:0xc99e15a0):Hello.msg.3
 From str:5 seq:0 (assoc:0xc99e15a0):Hello.msg.5
 From str:1 seq:0 (assoc:0xc99e15a0):Hello.msg.1