tcprecv02.lc 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. #include "unp.h"## 1 ##src/oob/tcprecv02.c##
  2. int## 2 ##src/oob/tcprecv02.c##
  3. main(int argc, char **argv)## 3 ##src/oob/tcprecv02.c##
  4. {## 4 ##src/oob/tcprecv02.c##
  5. int listenfd, connfd, n;## 5 ##src/oob/tcprecv02.c##
  6. char buff[100];## 6 ##src/oob/tcprecv02.c##
  7. fd_set rset, xset;## 7 ##src/oob/tcprecv02.c##
  8. if (argc == 2)## 8 ##src/oob/tcprecv02.c##
  9. listenfd = Tcp_listen(NULL, argv[1], NULL);## 9 ##src/oob/tcprecv02.c##
  10. else if (argc == 3)## 10 ##src/oob/tcprecv02.c##
  11. listenfd = Tcp_listen(argv[1], argv[2], NULL);## 11 ##src/oob/tcprecv02.c##
  12. else## 12 ##src/oob/tcprecv02.c##
  13. err_quit("usage: tcprecv02 [ <host> ] <port#>");## 13 ##src/oob/tcprecv02.c##
  14. connfd = Accept(listenfd, NULL, NULL);## 14 ##src/oob/tcprecv02.c##
  15. FD_ZERO(&rset);## 15 ##src/oob/tcprecv02.c##
  16. FD_ZERO(&xset);## 16 ##src/oob/tcprecv02.c##
  17. for (;;) {## 17 ##src/oob/tcprecv02.c##
  18. FD_SET(connfd, &rset);## 18 ##src/oob/tcprecv02.c##
  19. FD_SET(connfd, &xset);## 19 ##src/oob/tcprecv02.c##
  20. Select(connfd + 1, &rset, NULL, &xset, NULL);## 20 ##src/oob/tcprecv02.c##
  21. if (FD_ISSET(connfd, &xset)) {## 21 ##src/oob/tcprecv02.c##
  22. n = Recv(connfd, buff, sizeof(buff) - 1, MSG_OOB);## 22 ##src/oob/tcprecv02.c##
  23. buff[n] = 0; /* null terminate */## 23 ##src/oob/tcprecv02.c##
  24. printf("read %d OOB byte: %s\n", n, buff);## 24 ##src/oob/tcprecv02.c##
  25. }## 25 ##src/oob/tcprecv02.c##
  26. if (FD_ISSET(connfd, &rset)) {## 26 ##src/oob/tcprecv02.c##
  27. if ((n = Read(connfd, buff, sizeof(buff) - 1)) == 0) {## 27 ##src/oob/tcprecv02.c##
  28. printf("received EOF\n");## 28 ##src/oob/tcprecv02.c##
  29. exit(0);## 29 ##src/oob/tcprecv02.c##
  30. }## 30 ##src/oob/tcprecv02.c##
  31. buff[n] = 0; /* null terminate */## 31 ##src/oob/tcprecv02.c##
  32. printf("read %d bytes: %s\n", n, buff);## 32 ##src/oob/tcprecv02.c##
  33. }## 33 ##src/oob/tcprecv02.c##
  34. }## 34 ##src/oob/tcprecv02.c##
  35. }## 35 ##src/oob/tcprecv02.c##