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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 防火墙与安全工具 > 查看源码
inThread.cpp
资源名称：Firewall防火墙.rar　[点击查看]
上传用户：heseme
上传日期：2009-12-23
资源大小：228k
文件大小：3k
源码类别：

防火墙与安全工具

开发平台：

Visual C++

inThread.cpp：源码内容
  1. #include "stdafx.h"
  2. #include "FireWall1.h"
  3. #include "outnat.h"
  4. #include "authentication.h"
  5. /////////////////////////////////////
  6. /*
  7. 本程序从网卡1读入栈（TCP/IP栈）数据，
  8. 放入tempdata[480][1600]。
  9. 并把tempdata COPY到公共缓冲区global[68]的Buffer。
  10. global_var global[68]见"testddk.h"
  11. 用到两种类型变量控制县城同步，
  12. 其中global_mutex是一个mutex，
  13. 用于控制global[]的下标global_cur。
  14. global[].hMutex是一组Event，
  15. 用于控制缓冲区。
  16. */
  17. ////////////////////////////////////////
  18. extern BOOL CloseAll;
  19. global_var global[80];//全局管理数据
  20. int global_cur;
  21. extern int Resno;//恢复县城
  22. HANDLE global_mutex;//控制global_cur
  23. extern HANDLE mythread_write;
  24. BOOL OPER;
  25. BOOL write;   
  26. BYTE tempdata[480][1600];//网卡1入栈数据包
  27. //extern BYTE  SpecialBuffer[1500];
  28. BOOL  ACK = 0;
  29. static OVERLAPPED   OverLappedread_in,*lpOverLappedread;
  30. static int defer;
  31. extern HANDLE global_handle,global_handle1;
  32. OVERLAPPED myoverlap;
  33. static int off;
  34. static int count40;
  35. static int count = 0;
  37. static int mydata;
  38. extern HANDLE mythread_in;
  39. static int aaa=0;
  40. static int bbb=0;
  41. VOID WINAPI ReadCompletionRoutine(DWORD dwErrorCode, 
  42.    DWORD dwNumberOfBytesTransferred, 
  43.    LPOVERLAPPED pOverlapped);
  44. void initdata_in();
  45. void ReadInBuffer();
  46. static int inittime_in=0;
  47. VOID ReadInThread(VOID)
  48. {
  49. if(inittime_in++==0) initdata_in();
  50. while(!CloseAll)//洗垢函数通知
  51. {
  52. if((off>=235)&&(mydata<190))
  53. {
  54. // continue;
  55. }
  56. if(count40==60)//45*1518>65535,这样才能大数据包有效
  57. {
  58.   aaa++;
  59. SleepEx(1,TRUE);
  60. continue;
  61. }
  62. else count40++;
  63. if(off>79)off=0;
  64. ReadInBuffer();
  65. }
  67. //   TRACE(_T("INTHREAD FINISHn"));
  69. }
  72. VOID WINAPI ReadCompletionRoutine(DWORD dwErrorCode, 
  73.    DWORD dwNumberOfBytesTransferred, 
  74.    LPOVERLAPPED pOverlapped) {
  75. if(OPER)
  76. {
  77. if(mydata>79)
  78. {
  79. bbb++;
  80. mydata=0;
  81. }
  83. DWORD dw=WaitForSingleObject(global_mutex,INFINITE);
  84. if(dw==WAIT_OBJECT_0)
  85. {
  87. BOOL fdone=FALSE;
  89. {
  90. {
  92. memcpy(global[global_cur].Buffer,
  93. tempdata[mydata],
  94. 1518);
  96. global[global_cur].overlap=*pOverlapped;
  97. SetEvent(global[global_cur].hMutex);
  99. global_cur++;
  100. if(global_cur>79)global_cur=0;
  102. ReleaseMutex(global_mutex);
  103. fdone=TRUE;
  104. mydata++;
  105. count40--;
  106. // count40=0;
  107. }
  109. }
  111. if(dwErrorCode!= 0)
  112. {
  113. //   TRACE(_T("I/O ERR IN READCOMPn"));
  114. return;
  115. }
  116. }
  117. }
  120. }
  123. void ReadInBuffer()
  124. {
  126. BOOL Result;
  127. memset(&OverLappedread_in,0,sizeof(OVERLAPPED));
  128. lpOverLappedread=&OverLappedread_in;
  129. Result=ReadFileEx(
  130. global_handle,
  131. tempdata[off],
  132. 1520,
  133. lpOverLappedread,
  134. ReadCompletionRoutine);
  135. if (Result==0)
  136. {
  138. int ii=GetLastError();
  139. OPER=FALSE;
  140. // if((ii==1450)||(ii==998))
  141. TRACE(_T("不通n"));
  144. }
  145. else
  146. {
  148. off++;
  149. OPER=TRUE;
  150. }
  151. }
  152. void initdata_in()
  153. {
  155. mydata=0;
  156. defer=0;
  157. count40=0;
  158. off=0;         
  159. global_cur=0;
  160. global_mutex=CreateMutex(NULL,0,NULL);
  161. for(int aa=0;aa<480;aa++)
  162. {   
  163. memset(tempdata[aa],0,1600);
  164. }
  165. for(int i=0;i<80;i++)
  166. {
  167. memset(&global[i],0,sizeof(global_var));
  168. global[i].hMutex =CreateEvent(0,0,0,0);
  169. }
  171. memset(&myoverlap,0,sizeof(myoverlap));
  172. OPER=FALSE;
  173. }