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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 操作系统开发 > 查看源码
PCDBUG.C
资源名称：ertos.rar　[点击查看]
上传用户：sunrenlu
上传日期：2022-06-13
资源大小：1419k
文件大小：8k
源码类别：

操作系统开发

开发平台：

DOS

PCDBUG.C：源码内容
  1. #include <stdio.h>
  2. #include <wattcp.h>
  3. #include <fcntl.h>
  4. #include <sys/stat.h>
  5. #include <ctype.h>
  6. #include <stdlib.h>
  7. #include <stdarg.h>
  8. #include <io.h>
  9. #include <string.h>
  10. #include <mem.h>
  11. #include <icmp.h> // R. Whitby
  13. extern void (*_dbugxmit)( sock_type *s, in_Header *inp, void *phdr, unsigned line );
  14. extern void (*_dbugrecv)( sock_type *s, in_Header *inp, void *phdr, unsigned line );
  15. #define DEBUGNAME "WATTCP.DBG"
  17. char debugname[ 128 ];
  18. int debugheaders, debugdump, debugudp, debugtcp, debugicmp;   // R. Whitby
  20. static char localbuf[ 128 ];
  21. static int localhandle = 0;
  23. void db_write( char *msg )
  24. {
  25.     if (localhandle) // R. Whitby
  26.        write( localhandle, msg, strlen(msg));
  27. }
  29. void db_open( void )
  30. {
  31.     if (!localhandle) {
  32. localhandle = _creat( debugname, 0 );
  33. if (localhandle < 0 ) {
  34.     outs("ERROR:unable to open debug file!n");
  35.     exit(3);
  36. }
  37.     }
  38. }
  40. void db_close( void )
  41. {
  42.     int i;
  43.     if ( (i = dup( localhandle )) != -1 )
  44. close(i);
  45. }
  47. void dbug_printf( char *format, ... )
  48. {
  49.     va_list argptr;
  50.     static char localspace[ 256 ];
  51.     if ( localhandle ) {
  52. db_write( "n > ");
  53. va_start( argptr, format );
  54. vsprintf( localspace, format, argptr );
  55. va_end( argptr );
  56. db_write( localspace );
  57. db_write( "n" );
  58. db_close();
  59.     }
  60. }
  62. static char *tcpflag[] =
  63.     /*  7  ,   6 ,  5  ,   4 ,   3 ,   2 ,   1 ,   0 */
  64.       {"??7","??6","URG","ACK","PSH","RST","SYN","FIN" };
  65. static char *tcpmode[] = {
  66.     "LISTEN","SYNSENT","SYNREC","ESTAB","ESTCLOSE","FINWT1","FINWT2",
  67. "CLOSWT","CLOSING","LASTACK","TIMEWT","CLOSEMSL","CLOSED" };
  69. static void db_msg( char *msg, sock_type *sock, in_Header *ip, tcp_Header *tp, int line )
  70. {
  71.     int i,j,datalen, protocol;
  72.     byte ch, *data;
  73.     udp_Header *up;
  74.     icmp_pkt *icmp; // R. Whitby
  76.     switch ( protocol = ip->proto ) {
  78. case ICMP_PROTO :
  79.     if (!debugicmp) return;
  80.     icmp = (icmp_pkt*)(tp);
  81.     i = in_GetHdrlenBytes(ip);
  82.     data = (byte *)(icmp);
  83.     datalen = intel16(ip->length) - i;
  84.     break;
  86. case UDP_PROTO :
  87.     if (!debugudp) return;
  88.     up = (udp_Header*)(tp);
  89.     datalen = intel16(up->length);
  90.     data = (char *)(up) + sizeof( udp_Header );
  91.     break;
  93. case TCP_PROTO :
  94.     if (!debugtcp) return;
  95.     i = (tcp_GetDataOffset(tp) << 2); /* qwords to bytes */
  96.     j = in_GetHdrlenBytes(ip);
  97.     data = (char*)(tp) + i;
  98.     datalen = intel16(ip->length) - j - i;
  99.     break;
  101. default :
  102.     return;
  103.     }
  104.     db_open();
  105.     /* skip packet if no data and that was all we were looking for */
  106.     if (!debugheaders && !datalen) return;
  107.     db_write( msg );
  108.     if (!sock) {
  109. db_write( inet_ntoa( localbuf, intel( ip->source) ));
  110. if (protocol != ICMP_PROTO) { // R. Whitby
  111.     db_write( ":" );
  112.     db_write( itoa( intel16(tp->srcPort), localbuf, 10));
  113. }
  114. db_write( "   ");
  115. if (protocol != ICMP_PROTO) { // R. Whitby
  116.     db_write( inet_ntoa( localbuf, intel( ip->destination ) ));
  117.     db_write( ":" );
  118.     db_write( itoa( intel16(tp->dstPort),  localbuf, 10));
  119. }
  120. db_write( " (NO SOCKET)");
  121. /*
  122. return;
  123. */
  124.     } else {
  125. db_write( inet_ntoa( localbuf, sock->tcp.hisaddr ));
  126. db_write( ":" );
  127. db_write( itoa( sock->tcp.hisport, localbuf, 10));
  128. db_write( "   0.0.0.0:");
  129. db_write( itoa( sock->tcp.myport,  localbuf, 10));
  130.     }
  131.     db_write("n");
  132.     if (debugheaders) {
  133. switch (protocol) {
  134.     // R. Whitby
  135.     case ICMP_PROTO :
  136. db_write("ICMP PACKET : ");
  137. switch ( icmp->unused.type) {
  138.     case 0 : /* icmp echo reply received */
  139. db_write("ECHO REPLY");
  140. break;
  141.     case 3 : /* destination unreachable message */
  142. db_write("DESTINATION UNREACHABLE");
  143. break;
  144.     case 4  : /* source quench */
  145. db_write("SOURCE QUENCH");
  146. break;
  147.     case 5  : /* redirect */
  148. db_write("REDIRECT");
  149. break;
  150.     case 8  : /* icmp echo request */
  151. db_write("ECHO REQUEST");
  152. break;
  153.     case 11 : /* time exceeded message */
  154. db_write("TIME EXCEEDED");
  155. break;
  156.     case 12 : /* parameter problem message */
  157. db_write("PARAMETER PROBLEM");
  158. break;
  159.     case 13 : /* timestamp message */
  160. db_write("TIMESTAMP REQUEST");
  161. break;
  162.     case 14 : /* timestamp reply */
  163. db_write("TIMESTAMP REPLY");
  164. break;
  165.     case 15 : /* info request */
  166. db_write("INFORMATION REQUEST");
  167. break;
  168.     case 16 : /* info reply */
  169. db_write("INFORMATION REPLU");
  170. break;
  171.     default : /* unknown */
  172. db_write("UNKNOWN TYPE");
  173. break;
  174. }
  175. break;
  177.     case UDP_PROTO :
  178. db_write("UDP PACKET");
  179. break;
  180.     case TCP_PROTO :
  181. db_write("    TCP PACKET : ");
  182. db_write( tcpmode[ sock->tcp.state ] );
  183. db_write("  (LSEQ: 0x");
  184. db_write(ltoa(sock->tcp.seqnum,localbuf,16));
  185. db_write("  LACK: 0x");
  186. db_write(ltoa(sock->tcp.acknum,localbuf,16));
  187. db_write(") NOW: ");
  188. db_write( ltoa( set_timeout(0), localbuf,10));
  189. db_write("n    TCP FLAGS : ");
  190. for ( i = 0; i < 8 ; ++i ) {
  191.     if ( intel16(tp->flags) & ( 0x80 >> i )) {
  192. db_write( tcpflag[i] );
  193. db_write(" ");
  194.     }
  195. }
  197. db_write("  SEQ : 0x");
  198. db_write(ltoa(intel(tp->seqnum),localbuf,16));
  199. db_write("  ACK : 0x");
  200. db_write(ltoa(intel(tp->acknum),localbuf,16));
  201. db_write("  WINDOW : ");
  202. db_write(itoa(intel16(tp->window),localbuf,10));
  203. db_write("n K_C : ");
  204. db_write(itoa(sock->tcp.karn_count,localbuf,10 ));
  205. db_write("  VJ_SA : ");
  206. db_write(itoa(sock->tcp.vj_sa ,localbuf,10 ) );
  207. db_write("  VJ_SD : ");
  208. db_write(itoa(sock->tcp.vj_sd,localbuf,10 ) );
  209. db_write("  RTO : ");
  210. db_write(itoa(sock->tcp.rto ,localbuf,10 ));
  211. db_write(" RTT : ");
  212. db_write(ltoa(sock->tcp.rtt_time ,localbuf,10 ));
  213. db_write(" RTTDIFF : ");
  214. db_write(ltoa(sock->tcp.rtt_time - set_ttimeout(0),localbuf,10 ));
  215. db_write(" UNHAPPY : ");
  216. db_write(itoa(sock->tcp.unhappy,localbuf,10 ));
  217. if (line) {
  218.     db_write(" LINE : ");
  219.     db_write(itoa(line, localbuf, 10 ));
  220. }
  221. break;
  222. }
  223.     db_write("n");
  224.     }
  225.     if (debugdump) {
  226. for (i = 0; i < datalen ; i+= 16 ) {
  227.     sprintf(localbuf,"%04x : ", i );
  228.     db_write( localbuf );
  229.     for (j = 0 ; (j < 16) && (j +i < datalen) ; ++j ) {
  230.                 sprintf( localbuf, "%02x%c", (unsigned) data[j+i], (j==7)?'-':' ');
  231. db_write( localbuf );
  232.     }
  233.     for ( ; j < 16 ; ++j )
  234. db_write("   ");
  236.     memset( localbuf, 0, 17 );
  237.     for ( j = 0; (j<16) && (j+i<datalen) ; ++j ) {
  238. ch = data[j+i];
  239. if ( !isprint(ch) ) ch = '.';
  240.                 localbuf[j] = ch;
  241.             }
  242.             db_write( localbuf);
  243.             db_write("n");
  244.         }
  245.     }
  246.     db_write("n");
  247.     db_close();
  248. }
  250. static void _dbxmit( sock_type *sock, in_Header *ip, void *prot, unsigned line )
  251. {
  252.     db_msg("Tx:",sock,ip,prot,line);
  253. }
  255. static void _dbrecv( sock_type *sock, in_Header *ip, void *prot, unsigned line )
  256. {
  257.     db_msg("Rx:",sock,ip,prot, line);
  258. }
  260. static void (*otherinit)( char *name, char *value );
  262. static void ourinit( char *name, char *value )
  263. {
  264.     if (!strcmp(name,"DEBUG.FILE")) {
  265. strncpy(debugname, value, sizeof(debugname)-2);
  266. debugname[sizeof(debugname) -1] = 0;
  267. db_open();
  268.     } else if (!strcmp(name,"DEBUG.MODE")) {
  269. if (!stricmp( value, "DUMP" )) debugdump = 1;
  270. if (!stricmp( value, "HEADERS")) debugheaders =1;
  271. if (!stricmp( value, "ALL")) debugheaders = debugdump = 1;
  272.     } else if (!strcmp(name,"DEBUG.PROTO")) {
  273. if (!stricmp( value, "ICMP")) debugicmp = 1; // R. Whitby
  274. if (!stricmp( value, "TCP")) debugtcp = 1;
  275. if (!stricmp( value, "UDP")) debugudp =1;
  276. if (!stricmp( value, "ALL")) debugudp = debugtcp = 1;
  277.     } else if (otherinit)
  278. (*otherinit)(name,value);
  279. }
  281. extern void (*usr_init)( char *name, char *value );
  283. void dbug_init( void )
  284. {
  285.     strcpy(debugname,DEBUGNAME );
  286.     otherinit = usr_init;
  287.     usr_init = ourinit;
  288.     _dbugxmit = _dbxmit;
  289.     _dbugrecv = _dbrecv;
  290.     debugheaders = debugdump = debugicmp = debugudp = debugtcp = 0; // R. Whitby
  291. }