1) // 2) I/O 3) Japan Advanced Institute of Science and Technology 2013/07/26 1

Size: px

Start display at page:

Download "1) // 2) I/O 3) Japan Advanced Institute of Science and Technology 2013/07/26 1"

すずりたかぎ
5 years ago
Views:

1 I /07/26 Dependable Network Innovation Center, Japan Advanced Institute of Science and Technology

2 1) // 2) I/O 3) Japan Advanced Institute of Science and Technology 2013/07/26 1

3 1) Comer: Internetworking with TCP/IP Volume 3 Linux/POSIX Socket Version 2) Stevens: Unix Network Programming (3rd Edition) 3) Stevens: Advanced Programming in the UNIX Environment (3rd Edition) 1) 2) 3) Japan Advanced Institute of Science and Technology 2013/07/26 2

4 OS C BSD OS man WWW OS Japan Advanced Institute of Science and Technology 2013/07/26 3

5 man // RETURN VALUE(S) errno // ERRORS int errno.h #include <errno.h> Japan Advanced Institute of Science and Technology 2013/07/26 4

6 socket connect write read socket bind listen accept read write close close 5 Japan Advanced Institute of Science and Technology 2013/07/26

7 (cont.) socket connect write read HTTP write read close Japan Advanced Institute of Science and Technology 2013/07/26 6

8 (cont.) socket bind listen HTTP accept write read read write accept close 7 Japan Advanced Institute of Science and Technology 2013/07/26

9 (cont.) parent(inetd) socket bind listen accept close inetd xinetd child read write close Japan Advanced Institute of Science and Technology 2013/07/26 8

10 (file descriptor; fd) socket open read, recv, recvmsg write, send, sendmsg close shutdown Japan Advanced Institute of Science and Technology 2013/07/26 9

11 setsockopt, getsockopt gethostbyname, getservbyname, getprotobyname ID fork wait Japan Advanced Institute of Science and Technology 2013/07/26 10

13 IPv6 IPv6 IPv4 IPv4 IPv6 sockaddr in sockaddr storage gethostbyname getaddrinfo/getnameinfo Japan Advanced Institute of Science and Technology 2013/07/26 12

14 iterative server; server concurrent server; server server server server Japan Advanced Institute of Science and Technology 2013/07/26 13

15 iterative single context concurrent multipul context time Japan Advanced Institute of Science and Technology 2013/07/26 14

16 1 lfd = socket(...) bind(lfd,...) listen(lfd,...) while(1) { sfd = accept(lfd,...) read(sfd) write(sfd) close(sfd) } M/M/1 Japan Advanced Institute of Science and Technology 2013/07/26 15

17 fork M/M/n while(1) { sfd = accept(lfd,...) pid = fork() if(pid>0) { close(sfd); continue; } read(sfd) write(sfd) close(sfd) exit(0) } Japan Advanced Institute of Science and Technology 2013/07/26 16

18 fork pthread creare exit pthread exit mutex, condition variable Japan Advanced Institute of Science and Technology 2013/07/26 17

19 1 1 fork pthread create fork accept Japan Advanced Institute of Science and Technology 2013/07/26 18

20 time * * * accept Japan Advanced Institute of Science and Technology 2013/07/26 19

21 I/O accept read/write I/O Japan Advanced Institute of Science and Technology 2013/07/26 20

22 I/O accept read/write accept read/write : read time read write idle read write Japan Advanced Institute of Science and Technology 2013/07/26 21

23 lfd sfd1 sfd2 accept read write time read write I/O... lfd sfd1 sfd2 accept read write read write

24 accept: read: write: close: bind,listen: connect: Japan Advanced Institute of Science and Technology 2013/07/26 23

25 n accept fd Japan Advanced Institute of Science and Technology 2013/07/26 24

26 I/O select fd fd poll fd fd Japan Advanced Institute of Science and Technology 2013/07/26 25

27 select fd (fd set) fd lfd accept sfd FD_ZERO(&fds); FD_SET(lfd, &fds); while(1) { memcpy(&rfds, &fds, sizeof(fds)); ik = select(nfd, &rfds, NULL,NULL,NULL); if(fd_isset(lfd, &rfds)) { sfd = accept(lfd,...); FD_SET(sfd, &fds); if(sfd>nfd) nfd = sfd; } } Japan Advanced Institute of Science and Technology 2013/07/26 26

28 fd set fd set FD ZERO FD SET fd FD ISSET fd FD CLEAR fd typedef fd set Japan Advanced Institute of Science and Technology 2013/07/26 27

29 fd set (cont.) select fd set select select fds rfds select select Japan Advanced Institute of Science and Technology 2013/07/26 28

30 select int select(int nfd, fd_set *rfds, fd_set *wfds, fd_set *efds, struct timeval *tout) nfd fd rfds read fd wfds write fd efds fd tout read ik = select(nfd, &rfds,null,null,null); Japan Advanced Institute of Science and Technology 2013/07/26 29

31 Linux CentOS GB 500 OS select/poll Japan Advanced Institute of Science and Technology 2013/07/26 30

32 IP fd accept select fd set select Japan Advanced Institute of Science and Technology 2013/07/26 31

33 typedef struct { char *user; struct sockaddr_storage *addr; int fd char *req; struct timeval start; } conn_cntl_blk; int nconns=0; conn_cntl_blk *conns=null; int addnewconn(int nfd); int extracefdset(struct fd_set *fds); conn_cntl_blk* findconn( struct fd_set *fds); 32 Japan Advanced Institute of Science and Technology 2013/07/26

34 poll select SYSV struct pollfd fds; fds.fd lfd; fds.events = POLLIN; ik = poll(&fds, 1, wtime); if(fds.revents & POLLIN) { sfd = accept(lfd,...); } fd fds events revents Japan Advanced Institute of Science and Technology 2013/07/26 33

35 poll (cont.) fd struct pollfd *fds; fds[0].fd = 7; fds[0].events = POLLIN; fds[1].fd = 5; fds[1].events = POLLIN; ik = poll(fds, 2, wtime); select 8 fd FD_ZEERO(fds) FD_SET(5, &fds) FD_SET(7, &fds) memcpy(&rfd, &fds, sizeof(fds)); ik = select(8, &rfd, NULL, NULL, NULL); Japan Advanced Institute of Science and Technology 2013/07/26 34

36 I/O select/poll getsockopt elen = sizeof(err); chk = getsockopt(xfd, SOL_SOCKET, SO_ERROR, &err, &elen); if(err) { if(err==econnrefused)... { if(err==ehostunreach)... { } Japan Advanced Institute of Science and Technology 2013/07/26 35

37 epoll kqueue /dev/poll libevents Japan Advanced Institute of Science and Technology 2013/07/26 36

I /07/30 Dependable Network Innovation Center, Japan Advanced Institute of Science and Technology

I /07/30 Dependable Network Innovation Center, Japan Advanced Institute of Science and Technology I441 2013/07/30 Dependable Network Innovation Center, Japan Advanced Institute of Science and Technology I/O Japan Advanced Institute of Science and Technology 2013/07/30 1 fork/pthread create I/O Japan