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

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

操作系统开发

开发平台：

DOS

FINGTEST.C：源码内容
  1. /*
  2.  * This implements the classic (outdated) FINGER protocol
  3.  * While the protocol has grown to be more complex, this gives a
  4.  * simplified example which can be queried by any FINGER client.
  5.  *
  6.  * We listen on port 79.  For each new connection we accept a line
  7.  * of input.  That line is either a user name, or a blank line meaning
  8.  * we should list everyone.
  9.  *
  10.  */
  11. #include <rtos.h>
  12. #include <net.h>
  13. #include <stdio.h>
  15. /*
  16.  * heartbeat - just thumps periodically and does network stuff
  17.  */
  18. void heartbeat( DWORD param )
  19. {
  20.     do {
  21.         tcp_tick( NULL );
  22.         rt_sleep( 100 );    /* every 100 ms we do another network tick */
  23.     } while ( 1 );
  24. }
  27. #define FINGERPORT 79
  28. #define MAXFINGERD 5
  30. tcp_Socket *fing;
  31. /*
  32.  * implement ONE finger server
  33.  */
  34. void fingerd( DWORD index )
  35. {
  36.     tcp_Socket *s;
  37.     char buffer[ 128 ];
  39.     s = &fing[ index ];
  41.     do {
  42.         /* start listenning */
  43.         tcp_listen( s, FINGERPORT, 0, 0, NULL, 0 );
  45.         /* wait for a connection */
  46.         do {
  47.             rt_sleep( 100 );    /* just waiting */
  48.             if ( tcp_tick( s ) == NULL ) goto reopen;
  49.         } while ( ! sock_established( s ));
  51.         /* get a line of text */
  52.         sock_mode( s, TCP_MODE_ASCII );
  53.         while ( ! sock_dataready( s )) {
  54.             rt_yield();
  55.             if ( tcp_tick( s ) == NULL ) goto reopen;
  56.         }
  57.         sock_gets( s, buffer, sizeof( buffer ));
  58.         rip( buffer );   /* remove CR/LF */
  60.         /* output the results */
  61.         sock_puts( s, "thanks for asking about ");
  62.         sock_puts( s, buffer );
  64. reopen:
  65.         sock_close( s );
  67.         /*
  68.          * and wait for it to close
  69.          */
  70.         while ( tcp_tick( s ) )
  71.             rt_sleep( 100 );
  73.         /* now we are unthreaded */
  74.     } while ( 1 );
  75. }
  78. main()
  79. {
  81.     int i;
  82.     kpreemptive = 1;
  83.     kdebug = 1;
  84.     rt_init(100);
  85.     sock_init();
  86.     cputs("starting...rn");
  88.     fing = kcalloc( sizeof( tcp_Socket ), MAXFINGERD );
  90.     rt_newthread( heartbeat, 1,2048, 0, "heartbeat" );
  92.     for ( i = 0 ; i < MAXFINGERD ; ++i )
  93.         rt_newthread( fingerd, i, 2048, 0, "fingerd worker" );
  94.     do {
  95.         /* nothing */
  96.         rt_yield();
  97.     } while ( 1 );
  98. }