Шрифт:
45-47
Функция rtt_ts
получает текущую отметку времени. Отметка времени хранится в структуре hdr
, которая добавляется к данным пользователя. Одиночная дейтаграмма UDP отправляется функцией sendmsg
. Функция rtt_start
возвращает количество секунд для этого тайм-аута, а сигнал SIGALRM
контролируется функцией alarm
. Установка буфера перехода
48
Мы устанавливаем буфер перехода для нашего обработчика сигналов с помощью функции sigsetjmp. Мы ждем прихода следующей дейтаграммы, вызывая функцию recvmsg
. (Совместное использование функций sigsetjmp
и siglongjmp
вместе с сигналом SIGALRM
мы обсуждали применительно к листингу 20.5.) Если время таймера истекает, функция sigsetjmp
возвращает 1. Обработка тайм-аута
49-55
Когда возникает тайм-аут, функция rtt_timeout
вычисляет следующее значение RTO (используя экспоненциальное смещение) и возвращает -1, если нужно прекратить попытки передачи дейтаграммы, или 0, если нужно выполнить очередную повторную передачу. Когда мы прекращаем попытки, мы присваиваем переменной errno
значение ETIMEDOUT
и возвращаемся в вызывающую функцию. Вызов функции recvmsg, сравнение порядковых номеров
57-59
Мы ждем прихода дейтаграммы, вызывая функцию recvmsg
. Длина полученной дейтаграммы не должна быть меньше размера структуры hdr
, а ее порядковый номер должен совпадать с порядковым номером запроса, ответом на который предположительно является эта дейтаграмма. Если при сравнении хотя бы одно из этих условий не выполняется, функция recvmsg
вызывается снова. Выключение таймера и обновление показателей RTT
60-62
Когда приходит ожидаемый ответ, функция alarm
отключается, а функция rtt_stop
обновляет оценочное значение RTT. Функция rtt_ts
возвращает текущую отметку времени, и отметка времени из полученной дейтаграммы вычитается из текущей отметки, что дает в результате RTT. Обработчик сигнала SIGALRM
65-69
Вызывается функция siglongjmp
, результатом выполнения которой является то, что функция sigsetjmp
в dg_send_recv
возвращает 1. Теперь мы рассмотрим различные функции RTT, которые вызывались нашей функцией
dg_send_recv
. В листинге 22.8 показан заголовочный файл unprtt.h
. Листинг 22.8. Заголовочный файл unprtt.h
//lib/unprtt.h
1 #ifndef __unp_rtt_h
2 #define __unp_rtt_h
3 #include "unp.h"
4 struct rtt_info {
5 float rtt_rtt; /* последнее измеренное значение RTT в секундах */
6 float rtt_srtt; /* сглаженная оценка RTT в секундах */
7 float rtt_rttvar; /* сглаженные средние значения отклонений
в секундах */
8 float rtt_rto; /* текущее используемое значение RTO, в секундах */
9 int rtt_nrexmt; /* количество повторных передач: 0, 1, 2, ... */
10 uint32_t rtt_base; /* число секунд, прошедшее после 1.1.1970 в начале */
11 };
12 #define RTT_RXTMIN 2 /* минимальное значение тайм-аута для
повторной передачи, в секундах */
13 #define RTT_RXTMAX 60 /* максимальное значение тайм-аута для
повторной передачи, в секундах */
14 #define RTT_MAXNREXMT 3 /* максимально допустимое количество
повторных передач одной дейтаграммы */
15 /* прототипы функций */
16 void rtt_debug(struct rtt_info*);
17 void rtt_init(struct rtt_info*);