开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 嵌入式/单片机编程 > 查看源码
tcp_debug.c
资源名称：vxWorks_src.rar　[点击查看]
上传用户：baixin
上传日期：2008-03-13
资源大小：4795k
文件大小：7k
源码类别：

嵌入式/单片机编程

开发平台：

MultiPlatform

tcp_debug.c：源码内容
  1. /* tcp_debug.c - TCP debug routines */
  3. /* Copyright 1984 - 2002 Wind River Systems, Inc. */
  4. #include "copyright_wrs.h"
  6. /*
  7.  * Copyright (c) 1982, 1986, 1993
  8.  * The Regents of the University of California.  All rights reserved.
  9.  *
  10.  * Redistribution and use in source and binary forms, with or without
  11.  * modification, are permitted provided that the following conditions
  12.  * are met:
  13.  * 1. Redistributions of source code must retain the above copyright
  14.  *    notice, this list of conditions and the following disclaimer.
  15.  * 2. Redistributions in binary form must reproduce the above copyright
  16.  *    notice, this list of conditions and the following disclaimer in the
  17.  *    documentation and/or other materials provided with the distribution.
  18.  * 3. All advertising materials mentioning features or use of this software
  19.  *    must display the following acknowledgement:
  20.  * This product includes software developed by the University of
  21.  * California, Berkeley and its contributors.
  22.  * 4. Neither the name of the University nor the names of its contributors
  23.  *    may be used to endorse or promote products derived from this software
  24.  *    without specific prior written permission.
  25.  *
  26.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  27.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  28.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  29.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  30.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  31.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  32.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  33.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  34.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  35.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  36.  * SUCH DAMAGE.
  37.  *
  38.  * @(#)tcp_debug.c 8.1 (Berkeley) 6/10/93
  39.  */
  41. /*
  42. modification history
  43. --------------------
  44. 01d,20may02,vvv  moved tcpstates definition and pTcpstates initialization to
  45.                  tcpLib.c (SPR #62272)
  46. 01c,12oct01,rae  merge from truestack (VIRTUAL_STACK, printf formats)
  47. 01b,14nov00,ham  fixed messed tcpstates declaration(SPR 62272).
  48. 01a,03mar96,vin  created from BSD4.4 stuff,integrated with 02l of tcp_debug.c
  49. */
  51. /*
  52. DESCRIPTION
  53. */
  55. /* includes */
  57. #define TCPDEBUG
  58. #ifdef TCPDEBUG
  59. /* load symbolic names */
  60. #define PRUREQUESTS
  61. #define TCPSTATES
  62. #define TCPTIMERS
  63. #define TANAMES
  64. #endif
  66. #include "vxWorks.h"
  67. #include "stdioLib.h"
  68. #include "net/systm.h"
  69. #include "net/unixLib.h"
  70. #include "net/mbuf.h"
  71. #include "sys/socket.h"
  72. #include "net/socketvar.h"
  73. #include "net/protosw.h"
  74. #include "errno.h"
  76. #include "net/route.h"
  77. #include "net/if.h"
  79. #include "netinet/in.h"
  80. #include "netinet/in_pcb.h"
  81. #include "netinet/in_systm.h"
  82. #include "netinet/ip.h"
  83. #include "netinet/ip_var.h"
  84. #include "netinet/tcp.h"
  85. #include "netinet/tcp_fsm.h"
  86. #include "netinet/tcp_seq.h"
  87. #include "netinet/tcp_timer.h"
  88. #include "netinet/tcp_var.h"
  89. #include "netinet/tcpip.h"
  90. #include "netinet/tcp_debug.h"
  92. /* globals */
  94. #ifdef VIRTUAL_STACK
  95. #include "netinet/vsLib.h"
  96. #else
  97. int tcpDebugCons = 0;
  98. BOOL tcpDebugConsVerbose = TRUE;
  99. #endif
  101. /* locals */
  103. #ifndef VIRTUAL_STACK
  104. LOCAL struct tcp_debug tcp_debug[TCP_NDEBUG];
  105. LOCAL int tcp_debx;
  106. LOCAL int tcp_debug_valid = 0;
  107. #endif
  109. /* forward declarations */
  111. LOCAL void tcp_trace (short act, short ostate, struct tcpcb *tp,
  112.     struct tcpiphdr *ti, int req);
  113. LOCAL void tcpDebugPrint (struct tcp_debug *td, BOOL verbose);
  114. LOCAL void tcp_report (int num, BOOL verbose);
  116. void tcpTraceInit (void)
  117.     {
  118.     tcpTraceRtn = (VOIDFUNCPTR) tcp_trace;
  119.     tcpReportRtn = (VOIDFUNCPTR) tcp_report;
  121. #ifdef VIRTUAL_STACK
  122.     /*
  123.      * Assign (former) global variables previously initialized by the compiler.
  124.      * Setting 0 is repeated for clarity - the vsLib.c setup zeroes all values.
  125.      */
  127.     tcpDebugCons = 0;
  128.     tcpDebugConsVerbose = TRUE;
  129.     tcp_debug_valid = 0;
  130. #endif
  131.     }
  133. LOCAL void tcp_trace
  134.     (
  135.     short act,
  136.     short ostate,
  137.     struct tcpcb *tp,
  138.     struct tcpiphdr *ti,
  139.     int req
  140.     )
  141.     {
  142. #ifdef VIRTUAL_STACK
  143.     /* Virtual stack requires different variable name from structure tag. */
  145.     struct tcp_debug *td = &tcp_tracelog[tcp_debx++];
  146. #else
  147.     struct tcp_debug *td = &tcp_debug[tcp_debx++];
  148. #endif
  150.     if (tcp_debug_valid < TCP_NDEBUG)
  151.         tcp_debug_valid++;
  152.     if (tcp_debx == TCP_NDEBUG)
  153. tcp_debx = 0;
  155.     td->td_time = iptime();
  156.     td->td_act = act;
  157.     td->td_ostate = ostate;
  158.     td->td_req = req;
  160.     if (tp)
  161. {
  162. td->td_cb = *tp;
  163. td->td_tcb = (caddr_t) tp;
  164. }
  165.     else
  166. td->td_tcb = NULL;
  168.     if (ti)
  169. {
  170. td->td_ti = *ti;
  171. td->td_tiphdr = (caddr_t) ti;
  172. }
  173.     else
  174. td->td_tiphdr = NULL;
  176.     if (tcpDebugCons)
  177.         tcpDebugPrint (td, tcpDebugConsVerbose);
  178.     }
  180. LOCAL void tcpDebugPrint
  181.     (
  182.     struct tcp_debug *td,
  183.     BOOL verbose
  184.     )
  185.     {
  186.     struct tcpcb *tp;
  187.     struct tcpiphdr *ti;
  188.     tcp_seq seq, ack;
  189.     int len;
  191.     printf ("%lu  %s  %s", td->td_time, tanames [td->td_act],
  192. pTcpstates [td->td_ostate]);
  194.     if (!verbose)
  195.         printf ("n");
  196.     else
  197. {
  198.         if (td->td_tcb != NULL)
  199.     printf(" -> %s , &tcpcb=%xn", pTcpstates[td->td_cb.t_state],
  200. (UINT32) td->td_tcb);
  201. switch (td->td_act)
  202.     {
  203.     case TA_INPUT:
  204.     case TA_OUTPUT:
  205.     case TA_DROP:
  206. if (td->td_tiphdr == NULL)
  207.     break;
  209.                 ti = &td->td_ti;
  210. if (td->td_act == TA_OUTPUT)
  211.     {
  212.     seq = ntohl(ti->ti_seq);
  213.     ack = ntohl(ti->ti_ack);
  214.     len = ntohs(ti->ti_len);
  215.     }
  216.                 else
  217.     {
  218.     seq = ti->ti_seq;
  219.     ack = ti->ti_ack;
  220.     len = ti->ti_len;
  221.     }
  223. if (td->td_act == TA_OUTPUT)
  224.     len -= sizeof (struct tcphdr);
  226. if (len)
  227. printf("tseq=[%lx..%lx]", seq, seq+len);
  228. else
  229. printf("tseq=%lx", seq);
  230. printf(" ack=%lx, urp=%x, ", ack, ti->ti_urp);
  232. if (ti->ti_flags)
  233.     {
  234.     printf ("flags=<");
  235.     if (ti->ti_flags & TH_FIN)
  236. printf (" FIN");
  237.     if (ti->ti_flags & TH_SYN)
  238. printf (" SYN");
  239.     if (ti->ti_flags & TH_RST)
  240. printf (" RST");
  241.     if (ti->ti_flags & TH_PUSH)
  242. printf (" PUSH");
  243.     if (ti->ti_flags & TH_ACK)
  244. printf (" ACK");
  245.     if (ti->ti_flags & TH_URG)
  246. printf (" URG");
  247.     printf (" >n");
  248.     }
  250. break;
  252.     case TA_USER:
  253. printf("%s", prurequests[td->td_req&0xff]);
  254. if ((td->td_req & 0xff) == PRU_SLOWTIMO)
  255. printf("<%s>n", tcptimers[td->td_req>>8]);
  256.                 break;
  257.     }
  259. if (td->td_tcb == NULL)
  260.     {
  261.     printf ("nn");
  262.     return;
  263.     }
  265.         tp = &td->td_cb;
  266. printf("trcv_(nxt,wnd,up)  = (%lx,%lx,%lx)n",
  267.     tp->rcv_nxt, tp->rcv_wnd, tp->rcv_up);
  268. printf("tsnd_(una,nxt,max) = (%lx,%lx,%lx)n",
  269.     tp->snd_una, tp->snd_nxt, tp->snd_max);
  270. printf("tsnd_(wl1,wl2,wnd) = (%lx,%lx,%lx)nn",
  271.     tp->snd_wl1, tp->snd_wl2, tp->snd_wnd);
  272.         }
  273.     }
  275. LOCAL void tcp_report 
  276.     (
  277.     int num, /* number of entries to print */
  278.     BOOL verbose
  279.     )
  280.     {
  281.     int s = splnet(); /* accessing structures that change async */
  283.     num = max (num, 0);
  284.     num = tcp_debx - min (num, tcp_debug_valid);
  286.     if (num < 0) /* adjust for warap-around */
  287. num += (TCP_NDEBUG + 1);
  289.     for (; num != tcp_debx; num++)
  290. {
  291. if (num >= TCP_NDEBUG) /* start over at beginning of array */
  292.     num = 0;
  294. #ifdef VIRTUAL_STACK
  295.     /* Virtual stack requires different variable name from structure tag. */
  297.         tcpDebugPrint (&tcp_tracelog [num], verbose);
  298. #else
  299.         tcpDebugPrint (&tcp_debug [num], verbose);
  300. #endif
  301.         }
  303.     splx (s);
  304.     }