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

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

Установка порта получателя и отправка UDP-дейтаграммы

39-40

Каждый раз, когда посылается пробный пакет, порт получателя в структуре адреса сокета

sasend

меняется с помощью вызова функции

sock_set_port

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

sendto

посылает UDP-дейтаграмму.

Чтение ICMP-сообщения

41-42

Одна из функций

recv_v4

или

recv_v6

вызывает функцию recvfrom для чтения и обработки вернувшихся ICMP-сообщений. Обе эти функции возвращают значение -3 в случае истечения времени ожидания (сообщая, что следует послать следующий пробный пакет, если для данного значения TTL еще не посланы все три пакета), значение -2, если приходит ICMP-ошибка о превышении времени передачи, и значение -1, если получена ICMP-ошибка «Port unreachable» (Порт недоступен), то есть достигнут конечный получатель. Если же приходит какая-либо другая ICMP-ошибка недоступности получателя («Destination unreachable»), эти функции возвращают неотрицательный ICMP-код.

Вывод ответа

43-63

Как отмечалось выше, в случае первого ответа для данного значения TTL, а также если для данного TTL меняется IP-адрес узла, посылающего ICMP-сообщение, выводится имя узла и IP-адрес (или только IP-адрес, если вызов функции

getnameinfo

не возвращает имени узла). Время RTT вычисляется как разность между временем отправки пробного пакета и временем возвращения и вывода ICMP-сообщения.

Функция

recv_v4

приведена в листинге 28.16.

Листинг 28.16. Функция recv_v4: чтение и обработка сообщений ICMPv4

//traceroute/recv_v4

1 #include "trace.h"

2 extern int gotalarm;

3 /* Возвращает:

4 * -3 при тайм-ауте

5 * -2 при сообщении ICMP time exceeded in transit (продолжаем поиск)

6 * -1 при сообщении ICMP port unreachable (цель достигнута)

7 * неотрицательные значения соответствуют всем прочим ошибкам ICMP

8 */

9 int

10 recv_v4(int seq, struct timeval *tv)

11 {

12 int hlen1, hlen2, icmplen, ret;

13 socklen_t len;

14 ssize_t n;

15 struct ip *ip, *hip;

16 struct icmp *icmp;

17 struct udphdr *udp;

18 gotalarm = 0;

19 alarm(3);

20 for (;;) {

21 if (gotalarm)

22 return(-3); /*

истек таймер */

23 len = pr->salen;

24 n = recvfrom(recvfd, recvbuf, sizeof(recvbuf), 0, pr->sarecv, &len);

25 if (n < 0) {

26 if (errno == EINTR)

27 continue;

28 else

29 err_sys("recvfrom error");

30 }

31 ip = (struct ip*)recvbuf; /* начало IP-заголовка */

32 hlenl = ip->ip_hl << 2; /* длина IP-заголовка */

33 icmp = (struct icmp*)(recvbuf + hlen1); /* начало ICMP-заголовка */

34 if ((icmplen = n - hlen1) < 8)

35 continue; /* недостаточно данных для проверки ICMP-заголовка */

36 if (icmp->icmp_type == ICMP_TIMXCEED &&

37 icmp->icmp_code == ICMP_TIMXCEED_INTRANS) {

38 if (icmplen < 8 + sizeof(struct ip))

39 continue; /* недостаточно данных для проверки внутреннего IP */

40 hip = (struct ip*)(recvbuf + hlen1 + 8);

41 hlen2 = hip->ip_hl << 2;

42 if (icmplen < 8 + hlen2 + 4)

43 continue; /* недостаточно данных для проверки UDP-порта */

44 udp = (struct udphdr*)(recvbuf + hlen1 + 8 + hlen2);

45 if (hip->ip_p == IPPROTO_UDP &&

46 udp->uh_sport == htons(sport) &&

47 udp->uh_dport == htons(dport + seq)) {

48 ret = -2; /* ответил промежуточный маршрутизатор */

49 break;

50 }

51 } else if (icmp->icmp_type == ICMP_UNREACH) {

52 if (icmplen < 8 + sizeof(struct ip))