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

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

防火墙与安全工具

开发平台：

Visual C++

Thread.cpp：源码内容
  1. #include "stdafx.h"
  2. #include "FireWall1.h"
  3. #include "outnat.h"
  4. #include "authentication.h"
  5. /////////////////////////////////////
  6. /*
  7. 本程序从网卡1读出栈（TCP/IP栈）数据，
  8. 放入tempdataout[480][1600]。
  9. 并把tempdataout 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. extern BOOL Out_IOCancel;
  20. extern BOOL In_IOCancel;//在这里也需要
  21. extern global_var global[80];
  22. static offout;
  23. static mydataout;
  24. static count40out;
  25. static int countout;
  26. static int deferout;
  27. static int count1out;
  28. BOOL writeout;
  29. extern BOOL exeThread[480];
  30. void ReadOutBuffer();
  31. static BYTE tempdataout[480][1600];
  32. extern HANDLE global_handle;
  33. extern BYTE SourceIPFlag[4096];
  34. BOOL OPEROUT;
  35. static OVERLAPPED   OverLappedread_out,*lpOverLappedreadout;
  36. extern HANDLE mythread_out;
  37. extern BOOL ACK;
  38. extern int global_cur;
  39. extern HANDLE global_mutex;
  40. extern HANDLE fin_out1thread_mutex;
  41. //BYTE SpecialBuffer[1500];
  42. extern HANDLE mythread_write;
  43. extern int Resno;//恢复县城
  44. VOID WINAPI OutReadCompletionRoutine(DWORD dwErrorCode, 
  45.    DWORD dwNumberOfBytesTransferred, 
  46.    LPOVERLAPPED pOverlapped);
  47. void initdata_out();
  48. static int inittime_out=0;
  49. static int timecount;
  51. VOID ReadOutThread(VOID){
  52. if(inittime_out++==0) initdata_out();
  53. Sleep(1);//我认为出来包比入包应该慢一点
  54. while(!CloseAll)//洗垢函数通知
  55. {
  57. {
  60. if((offout>=235)&&(mydataout<190))
  61. {
  62. // continue;
  63. }
  64. if(count40out==60)
  65. {
  67. SleepEx(1,TRUE);
  68. continue;
  69. }
  70. else count40out++;
  71. if(offout>479)offout=0;
  72. ReadOutBuffer();
  73. }
  75. }
  79. // TRACE(_T("OUT THREAD FINISH_BEGINn"));
  82. }  
  83. void ReadOutBuffer()
  84. {
  86. BOOL Result;  
  87. memset(&OverLappedread_out,0,sizeof(OVERLAPPED));
  89. lpOverLappedreadout=&OverLappedread_out;
  90. Result=ReadFileEx(
  91. global_handle,
  92. tempdataout[offout],
  93. 1520,
  94. lpOverLappedreadout,
  95. OutReadCompletionRoutine);
  96. if (Result==0)
  97. {
  98. int ii=GetLastError();
  99. OPEROUT=FALSE;
  100. TRACE(_T("不通n"));
  103. }
  104. else
  105. {
  107. offout++;   
  108. OPEROUT=TRUE;
  110. }
  111. }
  113. VOID WINAPI OutReadCompletionRoutine(DWORD dwErrorCode, 
  114.    DWORD dwNumberOfBytesTransferred, 
  115.    LPOVERLAPPED pOverlapped) {
  117. if(OPEROUT)
  118. {
  119. if(mydataout>479)mydataout=0;
  121. countout++;
  122. DWORD dw=WaitForSingleObject(global_mutex,INFINITE);
  123. if(dw==WAIT_OBJECT_0)
  124. {
  125. BOOL fdoneout=FALSE;
  126. {
  128. memcpy(global[global_cur].Buffer,
  129. tempdataout[mydataout],
  130. 1518);
  131. fdoneout=TRUE;
  133. global[global_cur].overlap=*pOverlapped;
  134. SetEvent(global[global_cur].hMutex);
  136. global_cur++;
  137. if(global_cur>79)global_cur=0;
  138. ReleaseMutex(global_mutex);
  139. count40out--;
  140. // count40out=0;
  141. mydataout++;
  142. }
  144. }
  145. }
  147. if(dwErrorCode!= 0)
  148. {
  149. // TRACE(_T("I/O ERR OUT READCOMPn"));
  150.     return;
  151. }
  152. }
  153. void initdata_out()
  154. {
  155. mydataout=0;
  156. deferout=0;
  157. count40out=0;
  158. offout=0;
  159. count1out=0;
  160. timecount=0;
  161. OPEROUT=FALSE;
  162. memset(&OverLappedread_out,0,sizeof(OVERLAPPED));
  163. for(int aa=0;aa<480;aa++)
  164. {
  165. memset(tempdataout[aa],0,1600);
  166. tempdataout[aa][0]=1;
  167. }
  168. }