forked from unpbook/unpv13e
-
Notifications
You must be signed in to change notification settings - Fork 0
/
web01.lc
149 lines (120 loc) · 6.97 KB
/
web01.lc
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
/* include web1 */
#include "unpthread.h"## 1 ##src/threads/web01.c##
#include <thread.h> /* Solaris threads */## 2 ##src/threads/web01.c##
#define MAXFILES 20## 3 ##src/threads/web01.c##
#define SERV "80" /* port number or service name */## 4 ##src/threads/web01.c##
struct file {## 5 ##src/threads/web01.c##
char *f_name; /* filename */## 6 ##src/threads/web01.c##
char *f_host; /* hostname or IP address */## 7 ##src/threads/web01.c##
int f_fd; /* descriptor */## 8 ##src/threads/web01.c##
int f_flags; /* F_xxx below */## 9 ##src/threads/web01.c##
pthread_t f_tid; /* thread ID */## 10 ##src/threads/web01.c##
} file[MAXFILES];## 11 ##src/threads/web01.c##
#define F_CONNECTING 1 /* connect() in progress */## 12 ##src/threads/web01.c##
#define F_READING 2 /* connect() complete; now reading */## 13 ##src/threads/web01.c##
#define F_DONE 4 /* all done */## 14 ##src/threads/web01.c##
#define GET_CMD "GET %s HTTP/1.0\r\n\r\n"## 15 ##src/threads/web01.c##
int nconn, nfiles, nlefttoconn, nlefttoread;## 16 ##src/threads/web01.c##
void *do_get_read(void *);## 17 ##src/threads/web01.c##
void home_page(const char *, const char *);## 18 ##src/threads/web01.c##
void write_get_cmd(struct file *);## 19 ##src/threads/web01.c##
int## 20 ##src/threads/web01.c##
main(int argc, char **argv)## 21 ##src/threads/web01.c##
{## 22 ##src/threads/web01.c##
int i, n, maxnconn;## 23 ##src/threads/web01.c##
pthread_t tid;## 24 ##src/threads/web01.c##
struct file *fptr;## 25 ##src/threads/web01.c##
if (argc < 5)## 26 ##src/threads/web01.c##
err_quit("usage: web <#conns> <IPaddr> <homepage> file1 ...");## 27 ##src/threads/web01.c##
maxnconn = atoi(argv[1]);## 28 ##src/threads/web01.c##
nfiles = min(argc - 4, MAXFILES);## 29 ##src/threads/web01.c##
for (i = 0; i < nfiles; i++) {## 30 ##src/threads/web01.c##
file[i].f_name = argv[i + 4];## 31 ##src/threads/web01.c##
file[i].f_host = argv[2];## 32 ##src/threads/web01.c##
file[i].f_flags = 0;## 33 ##src/threads/web01.c##
}## 34 ##src/threads/web01.c##
printf("nfiles = %d\n", nfiles);## 35 ##src/threads/web01.c##
home_page(argv[2], argv[3]);## 36 ##src/threads/web01.c##
nlefttoread = nlefttoconn = nfiles;## 37 ##src/threads/web01.c##
nconn = 0;## 38 ##src/threads/web01.c##
/* end web1 */
/* include web2 */
while (nlefttoread > 0) {## 39 ##src/threads/web01.c##
while (nconn < maxnconn && nlefttoconn > 0) {## 40 ##src/threads/web01.c##
/* 4find a file to read */## 41 ##src/threads/web01.c##
for (i = 0; i < nfiles; i++)## 42 ##src/threads/web01.c##
if (file[i].f_flags == 0)## 43 ##src/threads/web01.c##
break;## 44 ##src/threads/web01.c##
if (i == nfiles)## 45 ##src/threads/web01.c##
err_quit("nlefttoconn = %d but nothing found", nlefttoconn);## 46 ##src/threads/web01.c##
file[i].f_flags = F_CONNECTING;## 47 ##src/threads/web01.c##
Pthread_create(&tid, NULL, &do_get_read, &file[i]);## 48 ##src/threads/web01.c##
file[i].f_tid = tid;## 49 ##src/threads/web01.c##
nconn++;## 50 ##src/threads/web01.c##
nlefttoconn--;## 51 ##src/threads/web01.c##
}## 52 ##src/threads/web01.c##
if ((n = thr_join(0, &tid, (void **) &fptr)) != 0)## 53 ##src/threads/web01.c##
errno = n, err_sys("thr_join error");## 54 ##src/threads/web01.c##
nconn--;## 55 ##src/threads/web01.c##
nlefttoread--;## 56 ##src/threads/web01.c##
printf("thread id %d for %s done\n", tid, fptr->f_name);## 57 ##src/threads/web01.c##
}## 58 ##src/threads/web01.c##
exit(0);## 59 ##src/threads/web01.c##
}## 60 ##src/threads/web01.c##
/* end web2 */
/* include do_get_read */
void *## 61 ##src/threads/web01.c##
do_get_read(void *vptr)## 62 ##src/threads/web01.c##
{## 63 ##src/threads/web01.c##
int fd, n;## 64 ##src/threads/web01.c##
char line[MAXLINE];## 65 ##src/threads/web01.c##
struct file *fptr;## 66 ##src/threads/web01.c##
fptr = (struct file *) vptr;## 67 ##src/threads/web01.c##
fd = Tcp_connect(fptr->f_host, SERV);## 68 ##src/threads/web01.c##
fptr->f_fd = fd;## 69 ##src/threads/web01.c##
printf("do_get_read for %s, fd %d, thread %d\n",## 70 ##src/threads/web01.c##
fptr->f_name, fd, fptr->f_tid);## 71 ##src/threads/web01.c##
write_get_cmd(fptr); /* write() the GET command */## 72 ##src/threads/web01.c##
/* 4Read server's reply */## 73 ##src/threads/web01.c##
for (;;) {## 74 ##src/threads/web01.c##
if ((n = Read(fd, line, MAXLINE)) == 0)## 75 ##src/threads/web01.c##
break; /* server closed connection */## 76 ##src/threads/web01.c##
printf("read %d bytes from %s\n", n, fptr->f_name);## 77 ##src/threads/web01.c##
}## 78 ##src/threads/web01.c##
printf("end-of-file on %s\n", fptr->f_name);## 79 ##src/threads/web01.c##
Close(fd);## 80 ##src/threads/web01.c##
fptr->f_flags = F_DONE; /* clears F_READING */## 81 ##src/threads/web01.c##
return (fptr); /* terminate thread */## 82 ##src/threads/web01.c##
}## 83 ##src/threads/web01.c##
/* end do_get_read */
/* include write_get_cmd */
void## 84 ##src/threads/web01.c##
write_get_cmd(struct file *fptr)## 85 ##src/threads/web01.c##
{## 86 ##src/threads/web01.c##
int n;## 87 ##src/threads/web01.c##
char line[MAXLINE];## 88 ##src/threads/web01.c##
n = snprintf(line, sizeof(line), GET_CMD, fptr->f_name);## 89 ##src/threads/web01.c##
Writen(fptr->f_fd, line, n);## 90 ##src/threads/web01.c##
printf("wrote %d bytes for %s\n", n, fptr->f_name);## 91 ##src/threads/web01.c##
fptr->f_flags = F_READING; /* clears F_CONNECTING */## 92 ##src/threads/web01.c##
}## 93 ##src/threads/web01.c##
/* end write_get_cmd */
/* include home_page */
void## 94 ##src/threads/web01.c##
home_page(const char *host, const char *fname)## 95 ##src/threads/web01.c##
{## 96 ##src/threads/web01.c##
int fd, n;## 97 ##src/threads/web01.c##
char line[MAXLINE];## 98 ##src/threads/web01.c##
fd = Tcp_connect(host, SERV); /* blocking connect() */## 99 ##src/threads/web01.c##
n = snprintf(line, sizeof(line), GET_CMD, fname);##100 ##src/threads/web01.c##
Writen(fd, line, n);##101 ##src/threads/web01.c##
for (;;) {##102 ##src/threads/web01.c##
if ((n = Read(fd, line, MAXLINE)) == 0)##103 ##src/threads/web01.c##
break; /* server closed connection */##104 ##src/threads/web01.c##
printf("read %d bytes of home page\n", n);##105 ##src/threads/web01.c##
/* do whatever with data */##106 ##src/threads/web01.c##
}##107 ##src/threads/web01.c##
printf("end-of-file on home page\n");##108 ##src/threads/web01.c##
Close(fd);##109 ##src/threads/web01.c##
}##110 ##src/threads/web01.c##
/* end home_page */