1 | /* $Id: debug.c 82968 2020-02-04 10:35:17Z vboxsync $ */
|
---|
2 | /** @file
|
---|
3 | * NAT - debug helpers.
|
---|
4 | */
|
---|
5 |
|
---|
6 | /*
|
---|
7 | * Copyright (C) 2006-2020 Oracle Corporation
|
---|
8 | *
|
---|
9 | * This file is part of VirtualBox Open Source Edition (OSE), as
|
---|
10 | * available from http://www.virtualbox.org. This file is free software;
|
---|
11 | * you can redistribute it and/or modify it under the terms of the GNU
|
---|
12 | * General Public License (GPL) as published by the Free Software
|
---|
13 | * Foundation, in version 2 as it comes in the "COPYING" file of the
|
---|
14 | * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
|
---|
15 | * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
|
---|
16 | */
|
---|
17 |
|
---|
18 |
|
---|
19 | /*
|
---|
20 | * This code is based on:
|
---|
21 | *
|
---|
22 | * Copyright (c) 1995 Danny Gasparovski.
|
---|
23 | * Portions copyright (c) 2000 Kelly Price.
|
---|
24 | *
|
---|
25 | * Please read the file COPYRIGHT for the
|
---|
26 | * terms and conditions of the copyright.
|
---|
27 | */
|
---|
28 |
|
---|
29 | #include <slirp.h>
|
---|
30 | #include <iprt/string.h>
|
---|
31 | #include <iprt/stream.h>
|
---|
32 | #include <iprt/critsect.h>
|
---|
33 | #include "zone.h"
|
---|
34 |
|
---|
35 | #ifdef DEBUG
|
---|
36 | void dump_packet(void *, int);
|
---|
37 | #endif
|
---|
38 |
|
---|
39 | #ifndef STRINGIFY
|
---|
40 | # define STRINGIFY(x) #x
|
---|
41 | #endif
|
---|
42 |
|
---|
43 | static char *g_apszTcpStates[TCP_NSTATES] =
|
---|
44 | {
|
---|
45 | STRINGIFY(TCPS_CLOSED),
|
---|
46 | STRINGIFY(TCPS_LISTEN),
|
---|
47 | STRINGIFY(TCPS_SYN_SENT),
|
---|
48 | STRINGIFY(TCPS_SYN_RECEIVED),
|
---|
49 | STRINGIFY(TCPS_ESTABLISHED),
|
---|
50 | STRINGIFY(TCPS_CLOSE_WAIT),
|
---|
51 | STRINGIFY(TCPS_FIN_WAIT_1),
|
---|
52 | STRINGIFY(TCPS_CLOSING),
|
---|
53 | STRINGIFY(TCPS_LAST_ACK),
|
---|
54 | STRINGIFY(TCPS_FIN_WAIT_2),
|
---|
55 | STRINGIFY(TCPS_TIME_WAIT)
|
---|
56 | };
|
---|
57 |
|
---|
58 | typedef struct DEBUGSTRSOCKETSTATE
|
---|
59 | {
|
---|
60 | uint32_t u32SocketState;
|
---|
61 | const char *pcszSocketStateName;
|
---|
62 | } DEBUGSTRSOCKETSTATE;
|
---|
63 |
|
---|
64 | #define DEBUGSTRSOCKETSTATE_HELPER(x) {(x), #x}
|
---|
65 |
|
---|
66 | static DEBUGSTRSOCKETSTATE g_apszSocketStates[8] =
|
---|
67 | {
|
---|
68 | DEBUGSTRSOCKETSTATE_HELPER(SS_NOFDREF),
|
---|
69 | DEBUGSTRSOCKETSTATE_HELPER(SS_ISFCONNECTING),
|
---|
70 | DEBUGSTRSOCKETSTATE_HELPER(SS_ISFCONNECTED),
|
---|
71 | DEBUGSTRSOCKETSTATE_HELPER(SS_FCANTRCVMORE),
|
---|
72 | DEBUGSTRSOCKETSTATE_HELPER(SS_FCANTSENDMORE),
|
---|
73 | DEBUGSTRSOCKETSTATE_HELPER(SS_FWDRAIN),
|
---|
74 | DEBUGSTRSOCKETSTATE_HELPER(SS_FACCEPTCONN),
|
---|
75 | DEBUGSTRSOCKETSTATE_HELPER(SS_FACCEPTONCE),
|
---|
76 | };
|
---|
77 |
|
---|
78 | static DEBUGSTRSOCKETSTATE g_aTcpFlags[] =
|
---|
79 | {
|
---|
80 | DEBUGSTRSOCKETSTATE_HELPER(TH_FIN),
|
---|
81 | DEBUGSTRSOCKETSTATE_HELPER(TH_SYN),
|
---|
82 | DEBUGSTRSOCKETSTATE_HELPER(TH_RST),
|
---|
83 | DEBUGSTRSOCKETSTATE_HELPER(TH_PUSH),
|
---|
84 | DEBUGSTRSOCKETSTATE_HELPER(TH_ACK),
|
---|
85 | DEBUGSTRSOCKETSTATE_HELPER(TH_URG),
|
---|
86 | };
|
---|
87 |
|
---|
88 | /*
|
---|
89 | * Dump a packet in the same format as tcpdump -x
|
---|
90 | */
|
---|
91 | #ifdef DEBUG
|
---|
92 | void
|
---|
93 | dump_packet(void *dat, int n)
|
---|
94 | {
|
---|
95 | Log(("nat: PACKET DUMPED:\n%.*Rhxd\n", n, dat));
|
---|
96 | }
|
---|
97 | #endif
|
---|
98 |
|
---|
99 | #ifdef LOG_ENABLED
|
---|
100 | static void
|
---|
101 | lprint(const char *pszFormat, ...)
|
---|
102 | {
|
---|
103 | va_list args;
|
---|
104 | va_start(args, pszFormat);
|
---|
105 | RTLogPrintfV(pszFormat, args);
|
---|
106 | va_end(args);
|
---|
107 | }
|
---|
108 |
|
---|
109 | void
|
---|
110 | ipstats(PNATState pData)
|
---|
111 | {
|
---|
112 | lprint("\n");
|
---|
113 |
|
---|
114 | lprint("IP stats:\n");
|
---|
115 | lprint(" %6d total packets received (%d were unaligned)\n",
|
---|
116 | ipstat.ips_total, ipstat.ips_unaligned);
|
---|
117 | lprint(" %6d with incorrect version\n", ipstat.ips_badvers);
|
---|
118 | lprint(" %6d with bad header checksum\n", ipstat.ips_badsum);
|
---|
119 | lprint(" %6d with length too short (len < sizeof(iphdr))\n", ipstat.ips_tooshort);
|
---|
120 | lprint(" %6d with length too small (len < ip->len)\n", ipstat.ips_toosmall);
|
---|
121 | lprint(" %6d with bad header length\n", ipstat.ips_badhlen);
|
---|
122 | lprint(" %6d with bad packet length\n", ipstat.ips_badlen);
|
---|
123 | lprint(" %6d fragments received\n", ipstat.ips_fragments);
|
---|
124 | lprint(" %6d fragments dropped\n", ipstat.ips_fragdropped);
|
---|
125 | lprint(" %6d fragments timed out\n", ipstat.ips_fragtimeout);
|
---|
126 | lprint(" %6d packets reassembled ok\n", ipstat.ips_reassembled);
|
---|
127 | lprint(" %6d outgoing packets fragmented\n", ipstat.ips_fragmented);
|
---|
128 | lprint(" %6d total outgoing fragments\n", ipstat.ips_ofragments);
|
---|
129 | lprint(" %6d with bad protocol field\n", ipstat.ips_noproto);
|
---|
130 | lprint(" %6d total packets delivered\n", ipstat.ips_delivered);
|
---|
131 | }
|
---|
132 |
|
---|
133 | void
|
---|
134 | tcpstats(PNATState pData)
|
---|
135 | {
|
---|
136 | lprint("\n");
|
---|
137 |
|
---|
138 | lprint("TCP stats:\n");
|
---|
139 |
|
---|
140 | lprint(" %6d packets sent\n", tcpstat.tcps_sndtotal);
|
---|
141 | lprint(" %6d data packets (%d bytes)\n",
|
---|
142 | tcpstat.tcps_sndpack, tcpstat.tcps_sndbyte);
|
---|
143 | lprint(" %6d data packets retransmitted (%d bytes)\n",
|
---|
144 | tcpstat.tcps_sndrexmitpack, tcpstat.tcps_sndrexmitbyte);
|
---|
145 | lprint(" %6d ack-only packets (%d delayed)\n",
|
---|
146 | tcpstat.tcps_sndacks, tcpstat.tcps_delack);
|
---|
147 | lprint(" %6d URG only packets\n", tcpstat.tcps_sndurg);
|
---|
148 | lprint(" %6d window probe packets\n", tcpstat.tcps_sndprobe);
|
---|
149 | lprint(" %6d window update packets\n", tcpstat.tcps_sndwinup);
|
---|
150 | lprint(" %6d control (SYN/FIN/RST) packets\n", tcpstat.tcps_sndctrl);
|
---|
151 | lprint(" %6d times tcp_output did nothing\n", tcpstat.tcps_didnuttin);
|
---|
152 |
|
---|
153 | lprint(" %6d packets received\n", tcpstat.tcps_rcvtotal);
|
---|
154 | lprint(" %6d acks (for %d bytes)\n",
|
---|
155 | tcpstat.tcps_rcvackpack, tcpstat.tcps_rcvackbyte);
|
---|
156 | lprint(" %6d duplicate acks\n", tcpstat.tcps_rcvdupack);
|
---|
157 | lprint(" %6d acks for unsent data\n", tcpstat.tcps_rcvacktoomuch);
|
---|
158 | lprint(" %6d packets received in sequence (%d bytes)\n",
|
---|
159 | tcpstat.tcps_rcvpack, tcpstat.tcps_rcvbyte);
|
---|
160 | lprint(" %6d completely duplicate packets (%d bytes)\n",
|
---|
161 | tcpstat.tcps_rcvduppack, tcpstat.tcps_rcvdupbyte);
|
---|
162 |
|
---|
163 | lprint(" %6d packets with some duplicate data (%d bytes duped)\n",
|
---|
164 | tcpstat.tcps_rcvpartduppack, tcpstat.tcps_rcvpartdupbyte);
|
---|
165 | lprint(" %6d out-of-order packets (%d bytes)\n",
|
---|
166 | tcpstat.tcps_rcvoopack, tcpstat.tcps_rcvoobyte);
|
---|
167 | lprint(" %6d packets of data after window (%d bytes)\n",
|
---|
168 | tcpstat.tcps_rcvpackafterwin, tcpstat.tcps_rcvbyteafterwin);
|
---|
169 | lprint(" %6d window probes\n", tcpstat.tcps_rcvwinprobe);
|
---|
170 | lprint(" %6d window update packets\n", tcpstat.tcps_rcvwinupd);
|
---|
171 | lprint(" %6d packets received after close\n", tcpstat.tcps_rcvafterclose);
|
---|
172 | lprint(" %6d discarded for bad checksums\n", tcpstat.tcps_rcvbadsum);
|
---|
173 | lprint(" %6d discarded for bad header offset fields\n",
|
---|
174 | tcpstat.tcps_rcvbadoff);
|
---|
175 |
|
---|
176 | lprint(" %6d connection requests\n", tcpstat.tcps_connattempt);
|
---|
177 | lprint(" %6d connection accepts\n", tcpstat.tcps_accepts);
|
---|
178 | lprint(" %6d connections established (including accepts)\n", tcpstat.tcps_connects);
|
---|
179 | lprint(" %6d connections closed (including %d drop)\n",
|
---|
180 | tcpstat.tcps_closed, tcpstat.tcps_drops);
|
---|
181 | lprint(" %6d embryonic connections dropped\n", tcpstat.tcps_conndrops);
|
---|
182 | lprint(" %6d segments we tried to get rtt (%d succeeded)\n",
|
---|
183 | tcpstat.tcps_segstimed, tcpstat.tcps_rttupdated);
|
---|
184 | lprint(" %6d retransmit timeouts\n", tcpstat.tcps_rexmttimeo);
|
---|
185 | lprint(" %6d connections dropped by rxmt timeout\n",
|
---|
186 | tcpstat.tcps_timeoutdrop);
|
---|
187 | lprint(" %6d persist timeouts\n", tcpstat.tcps_persisttimeo);
|
---|
188 | lprint(" %6d keepalive timeouts\n", tcpstat.tcps_keeptimeo);
|
---|
189 | lprint(" %6d keepalive probes sent\n", tcpstat.tcps_keepprobe);
|
---|
190 | lprint(" %6d connections dropped by keepalive\n", tcpstat.tcps_keepdrops);
|
---|
191 | lprint(" %6d correct ACK header predictions\n", tcpstat.tcps_predack);
|
---|
192 | lprint(" %6d correct data packet header predictions\n", tcpstat.tcps_preddat);
|
---|
193 | lprint(" %6d TCP cache misses\n", tcpstat.tcps_socachemiss);
|
---|
194 |
|
---|
195 | /* lprint(" Packets received too short: %d\n", tcpstat.tcps_rcvshort); */
|
---|
196 | /* lprint(" Segments dropped due to PAWS: %d\n", tcpstat.tcps_pawsdrop); */
|
---|
197 |
|
---|
198 | }
|
---|
199 |
|
---|
200 | void
|
---|
201 | udpstats(PNATState pData)
|
---|
202 | {
|
---|
203 | lprint("\n");
|
---|
204 |
|
---|
205 | lprint("UDP stats:\n");
|
---|
206 | lprint(" %6d datagrams received\n", udpstat.udps_ipackets);
|
---|
207 | lprint(" %6d with packets shorter than header\n", udpstat.udps_hdrops);
|
---|
208 | lprint(" %6d with bad checksums\n", udpstat.udps_badsum);
|
---|
209 | lprint(" %6d with data length larger than packet\n", udpstat.udps_badlen);
|
---|
210 | lprint(" %6d UDP socket cache misses\n", udpstat.udpps_pcbcachemiss);
|
---|
211 | lprint(" %6d datagrams sent\n", udpstat.udps_opackets);
|
---|
212 | }
|
---|
213 |
|
---|
214 | void
|
---|
215 | icmpstats(PNATState pData)
|
---|
216 | {
|
---|
217 | lprint("\n");
|
---|
218 | lprint("ICMP stats:\n");
|
---|
219 | lprint(" %6d ICMP packets received\n", icmpstat.icps_received);
|
---|
220 | lprint(" %6d were too short\n", icmpstat.icps_tooshort);
|
---|
221 | lprint(" %6d with bad checksums\n", icmpstat.icps_checksum);
|
---|
222 | lprint(" %6d with type not supported\n", icmpstat.icps_notsupp);
|
---|
223 | lprint(" %6d with bad type feilds\n", icmpstat.icps_badtype);
|
---|
224 | lprint(" %6d ICMP packets sent in reply\n", icmpstat.icps_reflect);
|
---|
225 | }
|
---|
226 |
|
---|
227 | void
|
---|
228 | mbufstats(PNATState pData)
|
---|
229 | {
|
---|
230 | /*
|
---|
231 | * (vvl) this static code can't work with mbuf zone anymore
|
---|
232 | * @todo: make statistic correct
|
---|
233 | */
|
---|
234 | NOREF(pData);
|
---|
235 | }
|
---|
236 |
|
---|
237 | void
|
---|
238 | sockstats(PNATState pData)
|
---|
239 | {
|
---|
240 | char buff[256];
|
---|
241 | size_t n;
|
---|
242 | struct socket *so, *so_next;
|
---|
243 |
|
---|
244 | lprint("\n");
|
---|
245 |
|
---|
246 | lprint(
|
---|
247 | "Proto[state] Sock Local Address, Port Remote Address, Port RecvQ SendQ\n");
|
---|
248 |
|
---|
249 | QSOCKET_FOREACH(so, so_next, tcp)
|
---|
250 | /* { */
|
---|
251 | n = RTStrPrintf(buff, sizeof(buff), "tcp[%s]", so->so_tcpcb?tcpstates[so->so_tcpcb->t_state]:"NONE");
|
---|
252 | while (n < 17)
|
---|
253 | buff[n++] = ' ';
|
---|
254 | buff[17] = 0;
|
---|
255 | lprint("%s %3d %15s %5d ",
|
---|
256 | buff, so->s, inet_ntoa(so->so_laddr), RT_N2H_U16(so->so_lport));
|
---|
257 | lprint("%15s %5d %5d %5d\n",
|
---|
258 | inet_ntoa(so->so_faddr), RT_N2H_U16(so->so_fport),
|
---|
259 | SBUF_LEN(&so->so_rcv), SBUF_LEN(&so->so_snd));
|
---|
260 | LOOP_LABEL(tcp, so, so_next);
|
---|
261 | }
|
---|
262 |
|
---|
263 | QSOCKET_FOREACH(so, so_next, udp)
|
---|
264 | /* { */
|
---|
265 | n = RTStrPrintf(buff, sizeof(buff), "udp[%d sec]", (so->so_expire - curtime) / 1000);
|
---|
266 | while (n < 17)
|
---|
267 | buff[n++] = ' ';
|
---|
268 | buff[17] = 0;
|
---|
269 | lprint("%s %3d %15s %5d ",
|
---|
270 | buff, so->s, inet_ntoa(so->so_laddr), RT_N2H_U16(so->so_lport));
|
---|
271 | lprint("%15s %5d %5d %5d\n",
|
---|
272 | inet_ntoa(so->so_faddr), RT_N2H_U16(so->so_fport),
|
---|
273 | SBUF_LEN(&so->so_rcv), SBUF_LEN(&so->so_snd));
|
---|
274 | LOOP_LABEL(udp, so, so_next);
|
---|
275 | }
|
---|
276 | }
|
---|
277 | #endif
|
---|
278 |
|
---|
279 | static DECLCALLBACK(size_t)
|
---|
280 | printSocket(PFNRTSTROUTPUT pfnOutput, void *pvArgOutput,
|
---|
281 | const char *pszType, void const *pvValue,
|
---|
282 | int cchWidth, int cchPrecision, unsigned fFlags,
|
---|
283 | void *pvUser)
|
---|
284 | {
|
---|
285 | struct socket *so = (struct socket*)pvValue;
|
---|
286 | PNATState pData = (PNATState)pvUser;
|
---|
287 | size_t cb = 0;
|
---|
288 |
|
---|
289 | NOREF(cchWidth);
|
---|
290 | NOREF(cchPrecision);
|
---|
291 | NOREF(fFlags);
|
---|
292 | Assert(pData);
|
---|
293 |
|
---|
294 | AssertReturn(strcmp(pszType, "natsock") == 0, 0);
|
---|
295 |
|
---|
296 | if (so == NULL)
|
---|
297 | return RTStrFormat(pfnOutput, pvArgOutput, NULL, 0,
|
---|
298 | "socket is null");
|
---|
299 | if (so->s == -1)
|
---|
300 | return RTStrFormat(pfnOutput, pvArgOutput, NULL, 0,
|
---|
301 | "socket(%d)", so->s);
|
---|
302 |
|
---|
303 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0,
|
---|
304 | "socket %d", so->s);
|
---|
305 |
|
---|
306 | if (so->so_type == IPPROTO_TCP)
|
---|
307 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0,
|
---|
308 | " (tcp)");
|
---|
309 | else if (so->so_type == IPPROTO_UDP)
|
---|
310 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0,
|
---|
311 | " (udp)");
|
---|
312 | else
|
---|
313 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0,
|
---|
314 | " (proto %u)", so->so_type);
|
---|
315 |
|
---|
316 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0,
|
---|
317 | " exp. in %d"
|
---|
318 | " state=%R[natsockstate]"
|
---|
319 | "%s" /* fUnderPolling */
|
---|
320 | "%s" /* fShouldBeRemoved */
|
---|
321 | " f_(addr:port)=%RTnaipv4:%d"
|
---|
322 | " l_(addr:port)=%RTnaipv4:%d",
|
---|
323 | so->so_expire ? so->so_expire - curtime : 0,
|
---|
324 | so->so_state,
|
---|
325 | so->fUnderPolling ? " fUnderPolling" : "",
|
---|
326 | so->fShouldBeRemoved ? " fShouldBeRemoved" : "",
|
---|
327 | so->so_faddr.s_addr,
|
---|
328 | RT_N2H_U16(so->so_fport),
|
---|
329 | so->so_laddr.s_addr,
|
---|
330 | RT_N2H_U16(so->so_lport));
|
---|
331 |
|
---|
332 | if (so->s != -1)
|
---|
333 | {
|
---|
334 | struct sockaddr addr;
|
---|
335 | socklen_t socklen;
|
---|
336 | int status;
|
---|
337 |
|
---|
338 | socklen = sizeof(addr);
|
---|
339 | status = getsockname(so->s, &addr, &socklen);
|
---|
340 |
|
---|
341 | if (status != 0)
|
---|
342 | {
|
---|
343 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0,
|
---|
344 | " (getsockname failed)");
|
---|
345 | }
|
---|
346 | else if (addr.sa_family != AF_INET)
|
---|
347 | {
|
---|
348 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0,
|
---|
349 | " (unexpected address family %d)",
|
---|
350 | addr.sa_family);
|
---|
351 | }
|
---|
352 | else
|
---|
353 | {
|
---|
354 | struct sockaddr_in *in_addr = (struct sockaddr_in *)&addr;
|
---|
355 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0,
|
---|
356 | " name=%RTnaipv4:%d",
|
---|
357 | in_addr->sin_addr.s_addr,
|
---|
358 | RT_N2H_U16(in_addr->sin_port));
|
---|
359 | }
|
---|
360 | }
|
---|
361 | return cb;
|
---|
362 | }
|
---|
363 |
|
---|
364 | static DECLCALLBACK(size_t)
|
---|
365 | printNATSocketState(PFNRTSTROUTPUT pfnOutput, void *pvArgOutput,
|
---|
366 | const char *pszType, void const *pvValue,
|
---|
367 | int cchWidth, int cchPrecision, unsigned fFlags,
|
---|
368 | void *pvUser)
|
---|
369 | {
|
---|
370 | uint32_t u32SocketState = (uint32_t)(uintptr_t)pvValue;
|
---|
371 | int idxNATState = 0;
|
---|
372 | bool fFirst = true;
|
---|
373 | size_t cbReturn = 0;
|
---|
374 | NOREF(cchWidth);
|
---|
375 | NOREF(cchPrecision);
|
---|
376 | NOREF(fFlags);
|
---|
377 | NOREF(pvUser);
|
---|
378 | AssertReturn(strcmp(pszType, "natsockstate") == 0, 0);
|
---|
379 |
|
---|
380 | for (idxNATState = 0; idxNATState < RT_ELEMENTS(g_apszSocketStates); ++idxNATState)
|
---|
381 | {
|
---|
382 | if (u32SocketState & g_apszSocketStates[idxNATState].u32SocketState)
|
---|
383 | {
|
---|
384 | if (fFirst)
|
---|
385 | {
|
---|
386 | cbReturn += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, g_apszSocketStates[idxNATState].pcszSocketStateName);
|
---|
387 | fFirst = false;
|
---|
388 | }
|
---|
389 | else
|
---|
390 | cbReturn += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "|%s", g_apszSocketStates[idxNATState].pcszSocketStateName);
|
---|
391 | }
|
---|
392 | }
|
---|
393 |
|
---|
394 | if (!cbReturn)
|
---|
395 | return RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "[unknown state %RX32]", u32SocketState);
|
---|
396 |
|
---|
397 | return cbReturn;
|
---|
398 | }
|
---|
399 |
|
---|
400 | /**
|
---|
401 | * Print callback dumping TCP Control Block in terms of RFC 793.
|
---|
402 | */
|
---|
403 | static DECLCALLBACK(size_t)
|
---|
404 | printTcpcbRfc793(PFNRTSTROUTPUT pfnOutput, void *pvArgOutput,
|
---|
405 | const char *pszType, void const *pvValue,
|
---|
406 | int cchWidth, int cchPrecision, unsigned fFlags,
|
---|
407 | void *pvUser)
|
---|
408 | {
|
---|
409 | size_t cb = 0;
|
---|
410 | const struct tcpcb *tp = (const struct tcpcb *)pvValue;
|
---|
411 | NOREF(cchWidth);
|
---|
412 | NOREF(cchPrecision);
|
---|
413 | NOREF(fFlags);
|
---|
414 | NOREF(pvUser);
|
---|
415 | AssertReturn(RTStrCmp(pszType, "tcpcb793") == 0, 0);
|
---|
416 | if (tp)
|
---|
417 | {
|
---|
418 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "TCB793[ state:%R[tcpstate] SND(UNA: %x, NXT: %x, UP: %x, WND: %x, WL1:%x, WL2:%x, ISS:%x), ",
|
---|
419 | tp->t_state, tp->snd_una, tp->snd_nxt, tp->snd_up, tp->snd_wnd, tp->snd_wl1, tp->snd_wl2, tp->iss);
|
---|
420 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "RCV(WND: %x, NXT: %x, UP: %x, IRS:%x)]", tp->rcv_wnd, tp->rcv_nxt, tp->rcv_up, tp->irs);
|
---|
421 | }
|
---|
422 | else
|
---|
423 | {
|
---|
424 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "TCB793[ NULL ]");
|
---|
425 | }
|
---|
426 | return cb;
|
---|
427 | }
|
---|
428 | /*
|
---|
429 | * Prints TCP segment in terms of RFC 793.
|
---|
430 | */
|
---|
431 | static DECLCALLBACK(size_t)
|
---|
432 | printTcpSegmentRfc793(PFNRTSTROUTPUT pfnOutput, void *pvArgOutput,
|
---|
433 | const char *pszType, void const *pvValue,
|
---|
434 | int cchWidth, int cchPrecision, unsigned fFlags,
|
---|
435 | void *pvUser)
|
---|
436 | {
|
---|
437 | size_t cb = 0;
|
---|
438 | const struct tcpiphdr *ti = (const struct tcpiphdr *)pvValue;
|
---|
439 | NOREF(cchWidth);
|
---|
440 | NOREF(cchPrecision);
|
---|
441 | NOREF(fFlags);
|
---|
442 | NOREF(pvUser);
|
---|
443 | AssertReturn(RTStrCmp(pszType, "tcpseg793") == 0 && ti, 0);
|
---|
444 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "SEG[ACK: %x, SEQ: %x, LEN: %x, WND: %x, UP: %x]",
|
---|
445 | ti->ti_ack, ti->ti_seq, ti->ti_len, ti->ti_win, ti->ti_urp);
|
---|
446 | return cb;
|
---|
447 | }
|
---|
448 |
|
---|
449 | /*
|
---|
450 | * Prints TCP state
|
---|
451 | */
|
---|
452 | static DECLCALLBACK(size_t)
|
---|
453 | printTcpState(PFNRTSTROUTPUT pfnOutput, void *pvArgOutput,
|
---|
454 | const char *pszType, void const *pvValue,
|
---|
455 | int cchWidth, int cchPrecision, unsigned fFlags,
|
---|
456 | void *pvUser)
|
---|
457 | {
|
---|
458 | size_t cb = 0;
|
---|
459 | const int idxTcpState = (int)(uintptr_t)pvValue;
|
---|
460 | char *pszTcpStateName = (idxTcpState >= 0 && idxTcpState < TCP_NSTATES) ? g_apszTcpStates[idxTcpState] : "TCPS_INVALIDE_STATE";
|
---|
461 | NOREF(cchWidth);
|
---|
462 | NOREF(cchPrecision);
|
---|
463 | NOREF(fFlags);
|
---|
464 | NOREF(pvUser);
|
---|
465 | AssertReturn(RTStrCmp(pszType, "tcpstate") == 0, 0);
|
---|
466 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "%s", pszTcpStateName);
|
---|
467 | return cb;
|
---|
468 | }
|
---|
469 |
|
---|
470 | /*
|
---|
471 | * Prints TCP flags
|
---|
472 | */
|
---|
473 | static DECLCALLBACK(size_t)
|
---|
474 | printTcpFlags(PFNRTSTROUTPUT pfnOutput, void *pvArgOutput,
|
---|
475 | const char *pszType, void const *pvValue,
|
---|
476 | int cchWidth, int cchPrecision, unsigned fFlags,
|
---|
477 | void *pvUser)
|
---|
478 | {
|
---|
479 | size_t cbPrint = 0;
|
---|
480 | uint32_t u32TcpFlags = (uint32_t)(uintptr_t)pvValue;
|
---|
481 | bool fSingleValue = true;
|
---|
482 | int idxTcpFlags = 0;
|
---|
483 | NOREF(cchWidth);
|
---|
484 | NOREF(cchPrecision);
|
---|
485 | NOREF(fFlags);
|
---|
486 | NOREF(pvUser);
|
---|
487 | AssertReturn(RTStrCmp(pszType, "tcpflags") == 0, 0);
|
---|
488 | cbPrint += RTStrFormat(pfnOutput,
|
---|
489 | pvArgOutput,
|
---|
490 | NULL,
|
---|
491 | 0,
|
---|
492 | "tcpflags: %RX8 [", (uint8_t)u32TcpFlags);
|
---|
493 | for (idxTcpFlags = 0; idxTcpFlags < RT_ELEMENTS(g_aTcpFlags); ++idxTcpFlags)
|
---|
494 | {
|
---|
495 | if (u32TcpFlags & g_aTcpFlags[idxTcpFlags].u32SocketState)
|
---|
496 | {
|
---|
497 | cbPrint += RTStrFormat(pfnOutput,
|
---|
498 | pvArgOutput,
|
---|
499 | NULL,
|
---|
500 | 0,
|
---|
501 | fSingleValue ? "%s(%RX8)" : "|%s(%RX8)",
|
---|
502 | g_aTcpFlags[idxTcpFlags].pcszSocketStateName,
|
---|
503 | (uint8_t)g_aTcpFlags[idxTcpFlags].u32SocketState);
|
---|
504 | fSingleValue = false;
|
---|
505 | }
|
---|
506 | }
|
---|
507 | cbPrint += RTStrFormat(pfnOutput,
|
---|
508 | pvArgOutput,
|
---|
509 | NULL,
|
---|
510 | 0,
|
---|
511 | "]");
|
---|
512 | return cbPrint;
|
---|
513 | }
|
---|
514 |
|
---|
515 | /*
|
---|
516 | * Prints sbuf state
|
---|
517 | */
|
---|
518 | static DECLCALLBACK(size_t)
|
---|
519 | printSbuf(PFNRTSTROUTPUT pfnOutput, void *pvArgOutput,
|
---|
520 | const char *pszType, void const *pvValue,
|
---|
521 | int cchWidth, int cchPrecision, unsigned fFlags,
|
---|
522 | void *pvUser)
|
---|
523 | {
|
---|
524 | size_t cb = 0;
|
---|
525 | const struct sbuf *sb = (struct sbuf *)pvValue;
|
---|
526 | NOREF(cchWidth);
|
---|
527 | NOREF(cchPrecision);
|
---|
528 | NOREF(fFlags);
|
---|
529 | NOREF(pvUser);
|
---|
530 | AssertReturn(RTStrCmp(pszType, "sbuf") == 0, 0);
|
---|
531 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "[sbuf:%p cc:%d, datalen:%d, wprt:%p, rptr:%p data:%p]",
|
---|
532 | sb, sb->sb_cc, sb->sb_datalen, sb->sb_wptr, sb->sb_rptr, sb->sb_data);
|
---|
533 | return cb;
|
---|
534 | }
|
---|
535 |
|
---|
536 | /*
|
---|
537 | * Prints zone state
|
---|
538 | */
|
---|
539 | static DECLCALLBACK(size_t)
|
---|
540 | printMbufZone(PFNRTSTROUTPUT pfnOutput, void *pvArgOutput,
|
---|
541 | const char *pszType, void const *pvValue,
|
---|
542 | int cchWidth, int cchPrecision, unsigned fFlags,
|
---|
543 | void *pvUser)
|
---|
544 | {
|
---|
545 | size_t cb = 0;
|
---|
546 | const uma_zone_t zone = (const uma_zone_t)pvValue;
|
---|
547 | NOREF(cchWidth);
|
---|
548 | NOREF(cchPrecision);
|
---|
549 | NOREF(fFlags);
|
---|
550 | NOREF(pvUser);
|
---|
551 | AssertReturn(RTStrCmp(pszType, "mzone") == 0, 0);
|
---|
552 | if (!zone)
|
---|
553 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "[zone:NULL]");
|
---|
554 | else
|
---|
555 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "[zone:%p name:%s, master_zone:%R[mzone]]",
|
---|
556 | zone, zone->name, zone->master_zone);
|
---|
557 | return cb;
|
---|
558 | }
|
---|
559 |
|
---|
560 | /*
|
---|
561 | * Prints zone's item state
|
---|
562 | */
|
---|
563 | static DECLCALLBACK(size_t)
|
---|
564 | printMbufZoneItem(PFNRTSTROUTPUT pfnOutput, void *pvArgOutput,
|
---|
565 | const char *pszType, void const *pvValue,
|
---|
566 | int cchWidth, int cchPrecision, unsigned fFlags,
|
---|
567 | void *pvUser)
|
---|
568 | {
|
---|
569 | size_t cb = 0;
|
---|
570 | const struct item *it = (const struct item *)pvValue;
|
---|
571 | NOREF(cchWidth);
|
---|
572 | NOREF(cchPrecision);
|
---|
573 | NOREF(fFlags);
|
---|
574 | NOREF(pvUser);
|
---|
575 | AssertReturn(RTStrCmp(pszType, "mzoneitem") == 0, 0);
|
---|
576 | if (!it)
|
---|
577 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "[item:NULL]");
|
---|
578 | else
|
---|
579 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "[iptem:%p ref_count:%d, zone:%R[mzone]]",
|
---|
580 | it, it->ref_count, it->zone);
|
---|
581 | return cb;
|
---|
582 | }
|
---|
583 |
|
---|
584 | static DECLCALLBACK(size_t)
|
---|
585 | print_networkevents(PFNRTSTROUTPUT pfnOutput, void *pvArgOutput,
|
---|
586 | const char *pszType, void const *pvValue,
|
---|
587 | int cchWidth, int cchPrecision, unsigned fFlags,
|
---|
588 | void *pvUser)
|
---|
589 | {
|
---|
590 | size_t cb = 0;
|
---|
591 | #ifdef RT_OS_WINDOWS
|
---|
592 | WSANETWORKEVENTS *pNetworkEvents = (WSANETWORKEVENTS*)pvValue;
|
---|
593 | bool fDelim = false;
|
---|
594 | #endif
|
---|
595 |
|
---|
596 | NOREF(cchWidth);
|
---|
597 | NOREF(cchPrecision);
|
---|
598 | NOREF(fFlags);
|
---|
599 | NOREF(pvUser);
|
---|
600 |
|
---|
601 | #ifdef RT_OS_WINDOWS
|
---|
602 | AssertReturn(strcmp(pszType, "natwinnetevents") == 0, 0);
|
---|
603 |
|
---|
604 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, "events=%02x (",
|
---|
605 | pNetworkEvents->lNetworkEvents);
|
---|
606 | # define DO_BIT(bit) \
|
---|
607 | if (pNetworkEvents->lNetworkEvents & FD_ ## bit) \
|
---|
608 | { \
|
---|
609 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, \
|
---|
610 | "%s" #bit "(%d)", fDelim ? "," : "", \
|
---|
611 | pNetworkEvents->iErrorCode[FD_ ## bit ## _BIT]); \
|
---|
612 | fDelim = true; \
|
---|
613 | }
|
---|
614 | DO_BIT(READ);
|
---|
615 | DO_BIT(WRITE);
|
---|
616 | DO_BIT(OOB);
|
---|
617 | DO_BIT(ACCEPT);
|
---|
618 | DO_BIT(CONNECT);
|
---|
619 | DO_BIT(CLOSE);
|
---|
620 | DO_BIT(QOS);
|
---|
621 | # undef DO_BIT
|
---|
622 | cb += RTStrFormat(pfnOutput, pvArgOutput, NULL, 0, ")");
|
---|
623 | #else
|
---|
624 | NOREF(pfnOutput);
|
---|
625 | NOREF(pvArgOutput);
|
---|
626 | NOREF(pszType);
|
---|
627 | NOREF(pvValue);
|
---|
628 | #endif
|
---|
629 | return cb;
|
---|
630 | }
|
---|
631 |
|
---|
632 | #if 0
|
---|
633 | /*
|
---|
634 | * Debugging
|
---|
635 | */
|
---|
636 | int errno_func(const char *file, int line)
|
---|
637 | {
|
---|
638 | int err = WSAGetLastError();
|
---|
639 | LogRel(("errno=%d (%s:%d)\n", err, file, line));
|
---|
640 | return err;
|
---|
641 | }
|
---|
642 | #endif
|
---|
643 |
|
---|
644 | int
|
---|
645 | debug_init(PNATState pData)
|
---|
646 | {
|
---|
647 | int rc = VINF_SUCCESS;
|
---|
648 |
|
---|
649 | static int g_fFormatRegistered;
|
---|
650 |
|
---|
651 | if (!g_fFormatRegistered)
|
---|
652 | {
|
---|
653 |
|
---|
654 | rc = RTStrFormatTypeRegister("natsock", printSocket, pData); AssertRC(rc);
|
---|
655 | rc = RTStrFormatTypeRegister("natsockstate", printNATSocketState, NULL); AssertRC(rc);
|
---|
656 | rc = RTStrFormatTypeRegister("natwinnetevents",
|
---|
657 | print_networkevents, NULL); AssertRC(rc);
|
---|
658 | rc = RTStrFormatTypeRegister("tcpcb793", printTcpcbRfc793, NULL); AssertRC(rc);
|
---|
659 | rc = RTStrFormatTypeRegister("tcpseg793", printTcpSegmentRfc793, NULL); AssertRC(rc);
|
---|
660 | rc = RTStrFormatTypeRegister("tcpstate", printTcpState, NULL); AssertRC(rc);
|
---|
661 | rc = RTStrFormatTypeRegister("tcpflags", printTcpFlags, NULL); AssertRC(rc);
|
---|
662 | rc = RTStrFormatTypeRegister("sbuf", printSbuf, NULL); AssertRC(rc);
|
---|
663 | rc = RTStrFormatTypeRegister("mzone", printMbufZone, NULL); AssertRC(rc);
|
---|
664 | rc = RTStrFormatTypeRegister("mzoneitem", printMbufZoneItem, NULL); AssertRC(rc);
|
---|
665 | g_fFormatRegistered = 1;
|
---|
666 | }
|
---|
667 |
|
---|
668 | return rc;
|
---|
669 | }
|
---|