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

 42 Close(sockfd);
 43 continue;
 44 } else
 45 err_sys("bind error for %s",
 46 Sock_ntop(ifi->ifi_brdaddr, salen));
 47 }
 48 printf ("bound %s\n", Sock_ntop(ifi->ifi_brdaddr, salen));

 49 if ((pid = Fork) == 0) { /* дочерний процесс */
 50 mydg_echo(sockfd, ifi->ifi_brdaddr, salen);
51 exit(0); /* никогда не выполняется */
 52 }
 53 }
 54 }

 55 /* связывание с универсальным адресом */
 56 sockfd = Socket(family, SOCK_DGRAM, 0);
 57 Setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));

 58 wild = Malloc(salen);
 59 memcpy(wild, sa, salen); /* копирует семейство и порт */
 60 sock_set_wild(wild, salen);

 61 Bind(sockfd, wild, salen);
 62 printf("bound %s\n", Sock_ntop(wild, salen));

 63 if ((pid = Fork) == 0) { /* дочерний процесс */
 64 mydg_echo(sockfd, wild, salen);
 65 exit(0); /* никогда не выполняется */
 66 }
 67 exit(0);
 68 }

 69 void
 70 mydg_echo(int sockfd, SA *myaddr, socklen_t salen)
 71 {
 72 int n;
 73 char mesg[MAXLINE];
 74 socklen_t len;
 75 struct sockaddr *cli;

 76 cli = Malloc(salen);

 77 for (;;) {
 78 len = salen;
 79 n = Recvfrom(sockfd, mesg, MAXLINE, 0, cli, &len);
 80 printf("child %d, datagram from %s",
 81 getpid, Sock_ntop(cli, len));
 82 printf(", to %s\n", Sock_ntop(myaddr, salen));

 83 Sendto(sockfd, mesg, n, 0, cli, len),
 84 }
 85 }

Глава 24

24.1. Да, разница есть. В первом примере два байта отсылаются с единственным срочным указателем, который указывает на байт, следующий за b. Во втором же примере (вызываются две функции) сначала отсылается символ a с указателем срочности, который указывает на следующий за ним байт, а за этим сегментом следует еще один TCP-сегмент, содержащий символ b с другим указателем срочности, указывающим на следующий за ним байт.

24.2. В листинге Д.10 приведена версия программы с использованием функции poll.

Листинг Д.10. Версия программы из листинга 24.4, использующая функцию poll вместо функции select

 //oob/tcprecv03p.c
  1 #include "unp.h"

  2 int
  3 main(int argc, char **argv)
  4 {
  5 int listenfd, connfd, n, justreadoob = 0;
  6 char buff[100];
  7 struct pollfd pollfd[1];

  8 if (argc == 2)
  9 listenfd = Tcp_listen(NULL, argv[1], NULL);
 10 else if (argc == 3)
 11 listenfd = Tcp_listen(argv[1], argv[2], NULL);
 12 else
 13 err_quit("usage: tcprecv03p [ <host> ] <port#>");

 14 connfd = Accept(listenfd, NULL, NULL);

 15 pollfd[0].fd = connfd;
 16 pollfd[0].events = POLLRDNORM;
 17 for (;;) {
 18 if (justreadoob == 0)
 19 pollfd[0].events |= POLLRDBAND;

 20 Poll(pollfd, 1, INFTIM);

 21 if (pollfd[0].revents & POLLRDBAND) {
 22 n = Recv(connfd, buff, sizeof(buff) - 1, MSG_OOB);
 23 buff[n] = 0; /* завершающий нуль */
 24 printf("read %d OOB byte: %s\n", n, buff);
 25 justreadoob = 1;
 26 pollfd[0].events &= ~POLLRDBAND; /* отключение бита */
 27 }
 28 if (pollfd[0].revents & POLLRDNORM) {
 29 if ((n = Read(connfd, buff, sizeof(buff) - 1)) == 0) {
 30 printf("received EOF\n");
 31 exit(0);
 32 }
 33 buff[n] = 0; /* завершающий нуль */
 34 printf("read %d bytes %s\n", n, buff);
 35 justreadoob = 0;
 36 }