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
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
| | /*
* This is an extremely detailed tapset for capturing all supported probe
* points in the current version of cmogstored. It likely contains too much
* information to be useful, extracting relevant probes is recommended,
* as is filtering this through an awk (or your favorite scripting language)
*/
/* avoid triggering copy faults because systemtap avoids page faults */
function cmogstored_user_string(a) {
try {
s = user_string(a);
} catch {
s = "???";
}
return s;
}
probe process("cmogstored").mark("http_accepted") {
fd = $arg1;
host = cmogstored_user_string($arg2);
serv = cmogstored_user_string($arg3);
listen = cmogstored_user_string($arg4);
printf("% 6d % 6d http_accepted %s %s %s\n",
pid(), fd, host, serv, listen);
}
/*
* ioq_blocked..ioq_reschedule = time waiting for others to finish IO
* ioq_reschedule..ioq_unblocked = time inside epoll ready list
*/
probe process("cmogstored").mark("ioq_blocked") {
fd = $arg1;
printf("% 6d % 6d ioq_blocked %u\n", pid(), fd, gettimeofday_us());
}
probe process("cmogstored").mark("http_req_start") {
fd = $arg1;
method = cmogstored_user_string($arg2);
path = cmogstored_user_string($arg3);
printf("% 6d % 6d http_req_start %s %s\n", pid(), fd, method, path);
}
probe process("cmogstored").mark("http_res_start") {
fd = $arg1;
try {
code = user_string_n($arg2, 3);
} catch {
code = "???";
}
printf("% 6d % 6d http_res_start %s\n", pid(), fd, code);
}
/*
* we hit ioq_reschedule when we are ready to enter the epoll ready-list
* we will hit ioq_unblocked eventually
*/
probe process("cmogstored").mark("ioq_reschedule") {
fd = $arg1;
printf("% 6d % 6d ioq_reschedule %u\n", pid(), fd, gettimeofday_us());
}
/*
* if ioq_unblock returns true, it means the fd was previously
* in ioq_reschedule
*/
probe process("cmogstored").mark("ioq_unblocked") {
fd = $arg1;
printf("% 6d % 6d ioq_unblocked %u\n", pid(), fd, gettimeofday_us());
}
/*
* HTTP client disconnected
*/
probe process("cmogstored").mark("http_client_close") {
fd = $arg1;
printf("% 6d % 6d http_client_close\n", pid(), fd);
}
/*
* We start reading/buffering the HTTP request here
*/
probe process("cmogstored").mark("http_req_begin") {
fd = $arg1;
is_pipelined = $arg2;
printf("% 6d % 6d http_req_begin %u %u\n",
pid(), fd, gettimeofday_us(), is_pipelined);
}
/*
* We blocked on writing (HTTP headers) to the client socket
*/
probe process("cmogstored").mark("write_buffered") {
fd = $arg1;
len = $arg2;
printf("% 6d % 6d write_buffered %lu\n", pid(), fd, len);
}
/* signals a client is making us reallocate on large requests */
probe process("cmogstored").mark("http_rbuf_grow") {
fd = $arg1;
buf_len = $arg2;
printf("% 6d % 6d http_rbuf_grow %lu\n", pid(), fd, buf_len);
}
/* signals a client is making us reallocate on large requests */
probe process("cmogstored").mark("mgmt_rbuf_grow") {
fd = $arg1;
buf_len = $arg2;
printf("% 6d % 6d mgmt_rbuf_grow %lu\n", pid(), fd, buf_len);
}
/* this signals a client is trickling requests to us */
probe process("cmogstored").mark("http_parse_continue") {
fd = $arg1;
buf_len = $arg2;
printf("% 6d % 6d http_parse_continue %lu\n", pid(), fd, buf_len);
}
/* this signals a client is trickling requests to us */
probe process("cmogstored").mark("mgmt_parse_continue") {
fd = $arg1;
buf_len = $arg2;
printf("% 6d % 6d mgmt_parse_continue %lu\n", pid(), fd, buf_len);
}
probe process("cmogstored").mark("mgmt_dig_start") {
fd = $arg1;
/* ref: lib/gc.h from gnulib */
if ($arg2 == 1) {
alg = "MD5";
} else if ($arg2 == 2) {
alg = "SHA-1";
} else {
alg = sprintf("???=%d", $arg2);
}
path = cmogstored_user_string($arg3);
printf("% 6d % 6d mgmt_dig_start %s %s\n", pid(), fd, alg, path);
}
probe process("cmogstored").mark("mgmt_dig_done") {
fd = $arg1;
if ($arg2 == 0) {
printf("% 6d % 6d mgmt_dig_done OK\n", pid(), fd);
} else if ($arg2 == -1) {
printf("% 6d % 6d mgmt_dig_done MISSING\n",
pid(), fd);
} else {
printf("% 6d % 6d mgmt_dig_done fail_offset=%ld\n",
pid(), fd, $arg2);
}
}
probe process("cmogstored").mark("http_bytes_xfer") {
fd = $arg1;
bytes = $arg2;
printf("% 6d % 6d http_bytes_xfer %d\n", pid(), fd, bytes);
}
probe process("cmogstored").mark("http_res_done") {
fd = $arg1;
printf("% 6d % 6d http_res_done %u\n", pid(), fd, gettimeofday_us());
}
|