forked from unpbook/unpv13e
-
Notifications
You must be signed in to change notification settings - Fork 0
/
qlen.lc
119 lines (95 loc) · 5.29 KB
/
qlen.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
#include "unpxti.h"## 1 ##src/debug/qlen.c##
#define PORT 9999## 2 ##src/debug/qlen.c##
#define ADDR "127.0.0.1"## 3 ##src/debug/qlen.c##
#define MAXBACKLOG 100## 4 ##src/debug/qlen.c##
/* globals */## 5 ##src/debug/qlen.c##
struct sockaddr_in serv;## 6 ##src/debug/qlen.c##
pid_t pid; /* of child */## 7 ##src/debug/qlen.c##
int pipefd[2];## 8 ##src/debug/qlen.c##
#define pfd pipefd[1] /* parent's end */## 9 ##src/debug/qlen.c##
#define cfd pipefd[0] /* child's end */## 10 ##src/debug/qlen.c##
/* function prototypes */## 11 ##src/debug/qlen.c##
void do_parent(void);## 12 ##src/debug/qlen.c##
void do_child(void);## 13 ##src/debug/qlen.c##
int## 14 ##src/debug/qlen.c##
main(int argc, char **argv)## 15 ##src/debug/qlen.c##
{## 16 ##src/debug/qlen.c##
if (argc != 1)## 17 ##src/debug/qlen.c##
err_quit("usage: qlen");## 18 ##src/debug/qlen.c##
Socketpair(AF_UNIX, SOCK_STREAM, 0, pipefd);## 19 ##src/debug/qlen.c##
bzero(&serv, sizeof(serv));## 20 ##src/debug/qlen.c##
serv.sin_family = AF_INET;## 21 ##src/debug/qlen.c##
serv.sin_port = htons(PORT);## 22 ##src/debug/qlen.c##
Inet_pton(AF_INET, ADDR, &serv.sin_addr);## 23 ##src/debug/qlen.c##
if ((pid = Fork()) == 0)## 24 ##src/debug/qlen.c##
do_child();## 25 ##src/debug/qlen.c##
else## 26 ##src/debug/qlen.c##
do_parent();## 27 ##src/debug/qlen.c##
exit(0);## 28 ##src/debug/qlen.c##
}## 29 ##src/debug/qlen.c##
void## 30 ##src/debug/qlen.c##
parent_alrm(int signo)## 31 ##src/debug/qlen.c##
{## 32 ##src/debug/qlen.c##
return; /* just interrupt blocked connect() */## 33 ##src/debug/qlen.c##
}## 34 ##src/debug/qlen.c##
/* include qlen */
void## 35 ##src/debug/qlen.c##
do_parent(void)## 36 ##src/debug/qlen.c##
{## 37 ##src/debug/qlen.c##
int qlen, j, k, junk, fd[MAXBACKLOG + 1];## 38 ##src/debug/qlen.c##
struct t_call tcall;## 39 ##src/debug/qlen.c##
Close(cfd);## 40 ##src/debug/qlen.c##
Signal(SIGALRM, parent_alrm);## 41 ##src/debug/qlen.c##
for (qlen = 0; qlen <= 14; qlen++) {## 42 ##src/debug/qlen.c##
printf("qlen = %d: ", qlen);## 43 ##src/debug/qlen.c##
Write(pfd, &qlen, sizeof(int)); /* tell child value */## 44 ##src/debug/qlen.c##
Read(pfd, &junk, sizeof(int)); /* wait for child */## 45 ##src/debug/qlen.c##
for (j = 0; j <= MAXBACKLOG; j++) {## 46 ##src/debug/qlen.c##
fd[j] = T_open(XTI_TCP, O_RDWR, NULL);## 47 ##src/debug/qlen.c##
T_bind(fd[j], NULL, NULL);## 48 ##src/debug/qlen.c##
tcall.addr.maxlen = sizeof(serv);## 49 ##src/debug/qlen.c##
tcall.addr.len = sizeof(serv);## 50 ##src/debug/qlen.c##
tcall.addr.buf = &serv;## 51 ##src/debug/qlen.c##
tcall.opt.len = 0;## 52 ##src/debug/qlen.c##
tcall.udata.len = 0;## 53 ##src/debug/qlen.c##
alarm(2);## 54 ##src/debug/qlen.c##
if (t_connect(fd[j], &tcall, NULL) < 0) {## 55 ##src/debug/qlen.c##
if (errno != EINTR)## 56 ##src/debug/qlen.c##
err_xti("t_connect error, j = %d", j);## 57 ##src/debug/qlen.c##
printf("timeout, %d connections completed\n", j - 1);## 58 ##src/debug/qlen.c##
for (k = 1; k < j; k++)## 59 ##src/debug/qlen.c##
T_close(fd[k]);## 60 ##src/debug/qlen.c##
break; /* next value of qlen */## 61 ##src/debug/qlen.c##
}## 62 ##src/debug/qlen.c##
alarm(0);## 63 ##src/debug/qlen.c##
}## 64 ##src/debug/qlen.c##
if (j > MAXBACKLOG)## 65 ##src/debug/qlen.c##
printf("%d connections?\n", MAXBACKLOG);## 66 ##src/debug/qlen.c##
}## 67 ##src/debug/qlen.c##
qlen = -1; /* tell child we're all done */## 68 ##src/debug/qlen.c##
Write(pfd, &qlen, sizeof(int));## 69 ##src/debug/qlen.c##
}## 70 ##src/debug/qlen.c##
void## 71 ##src/debug/qlen.c##
do_child(void)## 72 ##src/debug/qlen.c##
{## 73 ##src/debug/qlen.c##
int listenfd, qlen, junk;## 74 ##src/debug/qlen.c##
struct t_bind tbind, tbindret;## 75 ##src/debug/qlen.c##
Close(pipefd[1]);## 76 ##src/debug/qlen.c##
Read(cfd, &qlen, sizeof(int)); /* wait for parent */## 77 ##src/debug/qlen.c##
while (qlen >= 0) {## 78 ##src/debug/qlen.c##
listenfd = T_open(XTI_TCP, O_RDWR, NULL);## 79 ##src/debug/qlen.c##
tbind.addr.maxlen = sizeof(serv);## 80 ##src/debug/qlen.c##
tbind.addr.len = sizeof(serv);## 81 ##src/debug/qlen.c##
tbind.addr.buf = &serv;## 82 ##src/debug/qlen.c##
tbind.qlen = qlen;## 83 ##src/debug/qlen.c##
tbindret.addr.maxlen = 0;## 84 ##src/debug/qlen.c##
tbindret.addr.len = 0;## 85 ##src/debug/qlen.c##
T_bind(listenfd, &tbind, &tbindret);## 86 ##src/debug/qlen.c##
printf("returned qlen = %d, ", tbindret.qlen);## 87 ##src/debug/qlen.c##
fflush(stdout);## 88 ##src/debug/qlen.c##
Write(cfd, &junk, sizeof(int)); /* tell parent */## 89 ##src/debug/qlen.c##
Read(cfd, &qlen, sizeof(int)); /* just wait for parent */## 90 ##src/debug/qlen.c##
T_close(listenfd); /* closes all queued connections too */## 91 ##src/debug/qlen.c##
}## 92 ##src/debug/qlen.c##
}## 93 ##src/debug/qlen.c##
/* end qlen */