TCP UDP TCP UDP send()sendto()sendmsg() recv()recvfrom()recvmsg() OS Passive Active TCP UDP IP TCP UDP MTAMail Transf

Transcription

1 TCPUDP APIApplication Programming Interface BSD UNIX C System V UNIX XTIX /Open Transport Interface XTI TCP/IP ISO OSI XTI TCP/IP OSI TCP UDP API API API API UNIX Windows 7-1 TCP UDP 7-2 TCP UDP c /(18)

2 TCP UDP TCP UDP send()sendto()sendmsg() recv()recvfrom()recvmsg() OS Passive Active TCP UDP IP TCP UDP MTAMail Transfer Agent Web SIP User Agent c /(18)

3 socket() IP UNIX open() socket() socket() UNIX close() Windows closesocket() TCP shutdown() bind() IP connect() IP connect() IP OS TCP socket() socket() listen() TCP accept() TCP accept() accept() TCP listen() send()sendto()sendmsg() recv()recvfrom() recvmsg() send()recv() TCP UDP connect() IP IP sendto() recvfrom() UDP IP send()sendto()recv()recvfrom() sendmsg()recvmsg() setsockopt() getsockopt() Nagle IP c /(18)

4 IPv4 sockaddr_in IPv6 sockaddr_in6 IPv6 IPv4 IPv6 IPv4/IPv6 Protocol-independent 1) sockaddr_storage addrinfo getaddrinfo()getnameinfo()freeaddrinfo() sockaddr_storage IP addrinfo sockaddr_storage IPv4 IPv6 getaddrinfo() IP addrinfo getaddrinfo() freeaddrinfo() IP IP IPv6 getnameinfo() addrinfo IP DNS UNIX errno TCP RST Windows Winsock errno WSAGetLastError() UNIX getaddrinfo() errno gai_strerror() UNIX TCP TCP RST send() SIGPIPE SIGPIPE Linux send() MSG_NOSIGNAL sockaddr c /(18)

5 TCP UDP send() recv() setsockopt() SO_RCVTIMEOSO_SNDTIMEO SOL_SOCKET error TCP 2) setsockopt() SO_KEEPALIVE SOL_SOCKET select()poll() UNIX fcntl() ioctl() Linux send() recv() MSG_DONTWAIT Windows ioctlsocket() WSAAsync c /(18)

6 TCP UDP file_client0.c) (file_server0.c IP IPv6 getaddrinfo() getnameinfo() IPv4 IPv6 LinuxMacOS XWindows IPv6 OS TCP UDP TCP UDP TCP/UDP #ifdef #else#endif UDP (le server0.c) 1 /* file_server0.c: TCP/UDP Ver #include <stdio.h> 3 #include <stdlib.h> 4 #include <string.h> 5 #ifdef _WIN32 6 #include <winsock2.h> 7 #include <ws2tcpip.h> 8 #define exit(_z) WSACleanup();exit(_Z) 9 #define close(_z) closesocket(_z); 10 typedef int socklen_t; 11 #else 12 #include <sys/types.h> 13 #include <sys/socket.h> 14 #include <netdb.h> 15 #include <netinet/in.h> c /(18)

7 16 #include <unistd.h> 17 #endif //#define UDP /* TCP UDP // 20 #define BUFSIZE 8192 /* BUFSIZE >= MSGSIZE + DUMMY #ifdef UDP 23 #define MSGSIZE #define DUMMY 4 25 #else 26 #define MSGSIZE #endif enum args {CMD_NAME, READ_FILE, LOCAL_PORT}; int main(int argc, char *argv[]) 32 { 33 struct sockaddr_storage foreign; /* 34 struct addrinfo *local; /* 35 struct addrinfo hints; /* getaddrinfo 36 socklen_t len; /* 37 int sock0; /* 38 int sock; /* 39 char buf[bufsize]; /* 40 int size; /* 41 int total; /* 42 char ip[ni_maxhost]; /* IP ( ) 43 char port[ni_maxserv]; /* ( ) 44 FILE *fp; #ifdef _WIN32 47 WSA wsadata; 48 WSAStartup(MAKEWORD(2, 0), &wsadata); 49 #endif if (argc!= 3) { 52 fprintf(stderr, "Useage: %s [read file] [local port]\n", argv[cmd_name]); 53 exit(1); 54 } /* local 57 memset(&hints, 0, sizeof hints); 58 #ifndef UDP 59 hints.ai_socktype = SOCK_STREAM; /* TCP 60 #else 61 hints.ai_socktype = SOCK_DGRAM; /* UDP 62 #endif 63 hints.ai_flags = AI_PASSIVE; /* 64 getaddrinfo(null, argv[local_port], &hints, &local); /* 67 sock0 = socket(local->ai_family, local->ai_socktype, local->ai_protocol); /* 70 bind(sock0, local->ai_addr, local->ai_addrlen); 71 #ifndef UDP 72 listen(sock0, 5); /* (TCP) 73 #endif while (1) { 76 fp = fopen(argv[read_file], "rb"); 77 c /(18)

8 78 len = sizeof foreign; 79 #ifndef UDP /* (TCP) 80 sock = accept(sock0, (struct sockaddr *) &foreign, &len); 81 #else /* (UDP) 82 recvfrom(sock0, buf, sizeof buf, 0, (struct sockaddr *) &foreign, &len); 83 sock = sock0; /* UDP 1 84 #endif /* IP 87 getnameinfo((struct sockaddr *) &foreign, len, ip, sizeof ip, port, sizeof port, 88 NI_NUMERICHOST NI_NUMERICSERV); 89 printf("ip=%s PORT=%s\n", ip, port); total = 0; 92 while ((size = fread(buf, sizeof buf[0], MSGSIZE, fp)) > 0) { 93 #ifndef UDP /* (TCP) 94 send(sock, buf, size, 0); 95 #else /* (UDP) (4 ) 96 sendto(sock, buf, size + DUMMY, 0, (struct sockaddr *) &foreign, len); 97 #endif 98 printf("%d ", size); 99 total += size; 100 fflush(stdout); 101 } 102 printf("\ntotal = %d byte\n", total); #ifndef UDP /* (TCP) 105 close(sock); 106 #else /* (UDP) 107 sendto(sock, buf, DUMMY, 0, (struct sockaddr *) &foreign, len); 108 #endif 109 fclose(fp); 110 } 111 /* 112 freeaddrinfo(local); /* getaddrinfo 113 close(sock0); /* 114 exit(0); return 0; 117 } (le client0.c) 1 /* file_client0.c: TCP/UDP Ver #include <stdio.h> 3 #include <stdlib.h> 4 #include <string.h> 5 #ifdef _WIN32 6 #include <winsock2.h> 7 #include <ws2tcpip.h> 8 #define exit(_z) WSACleanup();exit(_Z) 9 #define close(_z) closesocket(_z); 10 #else 11 #include <sys/types.h> 12 #include <sys/socket.h> 13 #include <netdb.h> 14 #include <netinet/in.h> 15 #include <unistd.h> 16 #endif 17 c /(18)

9 18 //#define UDP /* TCP UDP // 19 #define BUFSIZE #ifdef UDP 22 #define DUMMY 4 23 #endif enum args {CMD_NAME, WRITE_FILE, FOREIGN_IP, FOREIGN_PORT}; int main(int argc, char *argv[]) 28 { 29 struct addrinfo *foreign; /* 30 struct addrinfo hints; /* getaddrinfo 31 int sock; /* 32 char buf[bufsize]; /* 33 int size; /* 34 int total; /* 35 FILE *fp; #ifdef _WIN32 38 WSA wsadata; 39 WSAStartup(MAKEWORD(2, 0), &wsadata); 40 #endif if (argc!= 4) { 43 fprintf(stderr, "Useage: %s [write file] [foreign ip] [foreign port]\n", argv[cmd_name]); 44 exit(1); 45 } 46 fp = fopen(argv[write_file], "wb"); /* foreign IP 49 memset(&hints, 0, sizeof hints); 50 hints.ai_family = PF_UNSPEC; /* 51 #ifndef UDP 52 hints.ai_socktype = SOCK_STREAM; /* TCP 53 #else 54 hints.ai_socktype = SOCK_DGRAM; /* UDP 55 #endif 56 getaddrinfo(argv[foreign_ip], argv[foreign_port], &hints, &foreign); /* 59 sock = socket(foreign->ai_family, foreign->ai_socktype, foreign->ai_protocol); /* 62 connect(sock, foreign->ai_addr, foreign->ai_addrlen); 63 #ifdef UDP /* (UDP) 64 send(sock, buf, DUMMY, 0); 65 #endif total = 0; 68 while ((size = recv(sock, buf, BUFSIZE, 0)) > 0) { /* 69 #ifdef UDP /* (4 ) (UDP) 70 if ((size -= DUMMY) <= 0) 71 break; 72 #endif 73 fwrite(buf, sizeof buf[0], size, fp); 74 printf("%d ", size); 75 total += size; 76 fflush(stdout); 77 } 78 printf("\ntotal = %d byte\n", total); 79 c /(18)

10 80 freeaddrinfo(foreign); /* getaddrinfo 81 close(sock); /* ( ) 82 fclose(fp); 83 exit(0); return 0; 86 } LinuxMacOS X UNIX OS cc -o file_server0 file_server0.c cc -o file_clinet0 file_clinet0.c Windows Visual Studio Tools GUI ws2_32.lib cl ws2_32.lib file_server0.c cl ws2_32.lib file_clinet0.c TCP UDP (file_server0.c) 19 (file_client0.c) 18 2 Windows././file_server0 getaddrinfo() addrinfo bind() IPv6 IPv4 IPv6 IPv4 IPv6 IPv6 IPv4./file_client0 IP IP DNS c /(18)

11 TCP UDP TCP UDP 1 TCP TCP FTP 3) UDP TCP UDP file_client0.c 64 file_server0.c UDP TCP UDP TFTP 4) 2 TCP send() recv() 8192 UDP send() TCP IP UDP IP IP Ethernet K UDP connect TCP UDP UDP connect() UDP connect() connect() send()recv() sendto()recvfrom() UDP connect() ICMP connect() ICMP send() recv() connect() ICMP recvfrom() sendto() UNIX 0 0 Windows UDP ICMP ICMP Type 3 (Destination Unreachable)Code 3 (port unreachable) c /(18)

12 TCP/UDP TCP UDP IP 2 send() send() 1 recv() recv() UDP 4 1TCP $./file_clinet0 file total = byte 2UDP $./file_clinet0 file total = byte $./file_server0 file IP=::ffff: PORT= total = byte $./file_server0 file IP=::ffff: PORT= total = byte TCP UDP sockaddr ai_socktype SOCK_STREAMSOCK_DGRAM send()recv() send() recv() TCP send() recv() 1 1 TCP MSSMaximum Segment Size Nagle c /(18)

13 send(8192) 1028 send(1028) recv() recv(1028) 1028 send(1028) recv() recv(1028) 1028 recv(1028) send(1028) recv(1028) 1028 send(1028) recv(1028) 1028 send(1028) send(8192) recv(1028) 1028 send(1028) 1028 recv(1028) send(1028) 1028 send(1028) recv(8192) recv(1028) 1028 send(1028) recv(1944) recv(1028) 1028 send(1028) recv(1028) 1028 send(1028) send(1028) recv(1028) recv(4800) send(8192) send(1028) recv(4344) recv(1028) 1028 send(1028) recv() recv(1028) 1028 send(925) send(1028) 429 recv(1028) 1028 send(1028) recv(1877) recv(1028) recv(929) 929 send(929) 71 send() TCP 1 send() TCP recv() OS recv() 1MSS recv() UDP send() recv() 1 1 UDP UDP send() recv() UDP UDP UDP TCP TCP recv() send() send() OS send() OS send() Linux send() sendto() MSG MORE send() UDP c /(18)

14 close() close() TCP setsockopt() SO_LINGER 10 SOL_SOCKET close() TCP TIME WAIT TCP 72 TIME_WAIT TCBTransmission Control Block 2 MSLMaximum Segment Lifetime 5) TIME_WAIT TCB FIN close( ) FIN close( ) close( ) FIN close( ) FIN RST RST TCB 2MSL TCB SO_LINGER SO_LINGER 72 SO LINGER setsockopt() SO_LINGER SOL_SOCKET TCB RTT 72 TCP RST TCP SO_LINGER 0 close() FIN RST c /(18)

15 TCP Web TCP MSS FTP HTTP SMTP RTT RTT 73 Long Fat Pipe TCP TCP setsockopt() SO_SNDBUFSO_RCVBUF SOL_SOCKETTCP SO_RCVBUF SO_SNDBUF SO_RCVBUF SO_SNDBUF TCP TCP 6) OS OS TCP c /(18)

16 send() 8192 send() 7) TCP OS 512 8) MSS Alignment p1 p2 #define BUFSIZE 8192 #define ALIGNMENT 4096 char buf[bufsize + ALIGNMENT], *p1, *p2; p1 = buf; p2 = buf + (ALIGNMENT - ((unsigned long) buf % ALIGNMENT)); p1 p2 DMA 9) OS 10) MSS SMTP SIPFTP HTTP TCP Nagle send() 2 send() c /(18)

17 1 1 send() sendmsg() TCP Nagle 75 send() 75 Nagle c /(18)

18 Nagle 75 Nagle Nagle setsockopt() TCP_NODELAY IPPROTO_TCP Nagle Nagle Nagle HTTP SMTP Nagle Nagle 1) R. Gilligan, S. Thomson, J. Bound, J. McCann, W. Stevens: Basic Socket Interface Extensions for IPv6, RFC 3493, ) R. Braden: Requirements for Internet Hosts Communication Layers, RFC 1122, ) J. Postel, J. Reynolds: File Transfer Protocol, RFC 959, ) K. Sollins: The TFTP Protocol (Revision 2), RFC 1350, ) J. Postel: Transmission Control Protocol, RFC 793, ) J. Semke, J. Mahdavi, and M. Mathis, Automatic TCP buffer tuning, ACM SIGCOMM 98, pp , Aug ) Crowcroft, J. I. Wakeman, Zheng Wang, D. Sirovica: Is Layering Harmful?, IEEE Network Magazine, vol.6, pp.20-24, Jan ) 3, ) Silicon Graphics, Inc.: TTCP.C modified in 1989 at Silicon Graphics, Inc., ttcp.c, ) S. Parker, C. Schmechel: Some Testing Tools for TCP Implementors, RFC 2398, c /(18)