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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 远程控制编程 > 查看源码
thread1.cpp
资源名称：anywhere.zip　[点击查看]
上传用户：zhenhuadz
上传日期：2007-01-07
资源大小：1511k
文件大小：17k
源码类别：

远程控制编程

开发平台：

Visual C++

thread1.cpp：源码内容
  1. // thread1.cpp: implementation of the thread class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "anywhere.h"
  7. #include "thread1.h"
  9. #include "blocksock.h"
  10. //#include "msgman.h"
  11. //#include "mainfrm.h"
  12. //#include "thread.h"
  14. #ifdef _DEBUG
  15. #undef THIS_FILE
  16. static char THIS_FILE[]=__FILE__;
  17. #define new DEBUG_NEW
  18. #endif
  20. //////////////////////////////////////////////////////////////////////
  21. // Construction/Destruction
  22. //////////////////////////////////////////////////////////////////////
  23. //#define timeout 15
  24. //#define request 400
  27. HWND m_hMainWnd;
  28. HANDLE hRecv,hSend;//接受,发送两个线程的句柄
  29. HANDLE recvevent,sendevent;
  30. CCriticalSection cs;
  31. Link linkrc;
  32. int timeout,request;
  33. CString pix="800*600";
  35. void LogBlockingSocketException(LPVOID pParam, char* pch, CBlockingSocketException* pe)
  36. { // pParam holds the HWND for the destination window (in another thread)
  37. /* CString strGmt = CTime::GetCurrentTime().FormatGmt("%m/%d/%y %H:%M:%S GMT");
  38. char text1[200], text2[50];
  39. pe->GetErrorMessage(text2, 49);
  40. wsprintf(text1, "WINSOCK ERROR--%s %s -- %srn", pch, text2, (const char*) strGmt);
  41. ::SendMessage((HWND) pParam, EM_SETSEL, (WPARAM) 65534, 65535);
  42. ::SendMessage((HWND) pParam, EM_REPLACESEL, (WPARAM) 0, (LPARAM) text1);
  43. */
  44. MessageBox(NULL,pch,NULL,MB_OK);
  45. }
  47. UINT Connect(LPVOID pParam)
  48. {
  49. Link *plinkrc;
  50. plinkrc=(Link*)pParam;
  51. CBlockingSocket saClient;
  52. char connect[17];
  53. char assume[17];
  54.     cs.Lock();
  55.     strcpy(assume,plinkrc->username);
  56. strcat(assume,plinkrc->password);
  57. //strcpy(szsBuf,plinkrc->sbuf);
  58. CSockAddr sa=plinkrc->sAddr;
  59.     cs.Unlock();//将待发消息传给变量
  60. connect[16]=0;
  61. assume[16]=0;
  63.     //CBlockingSocket sockClient;
  64. try {
  65. saClient.Create();
  66. saClient.Connect(sa);
  67. if (!plinkrc->bConnected) {
  68. saClient.Write(assume,strlen(assume),timeout);
  69.             saClient.Receive(connect,16,timeout);
  70. if (strcmp(assume,connect)) {
  71. MessageBox(m_hMainWnd,"不正确的用户或密码,被服务端拒绝服务","提示:",MB_OK);
  72. ExitThread(0);//不等退出
  73. }//认证过程
  74. else plinkrc->bConnected=TRUE;
  76. }
  77. cs.Lock();
  78. plinkrc->bConnected=TRUE;
  79. cs.Unlock();
  80. saClient.Close();
  81. return 1;
  82. }
  83. catch (CBlockingSocketException *e) {
  84. MessageBox(NULL,"连接错误!","提示",MB_OK);
  85. e->Delete();
  86. saClient.Close();
  87.     return 0;
  88. //cs.Unlock();
  89. }
  90. //sockClient.Close();
  92. }
  96. DWORD WINAPI SysThread(LPVOID pParam)
  98. {
  100.     WaitForSingleObject(sendevent,INFINITE);//无限阻塞
  101. //自动重设,使信号实效
  102. Link *plinkrc;
  103. plinkrc=(Link *)pParam;
  104.     char szsBuf[1024];//待发字串
  105. //char connect[17]; //认证
  106. //char assume[17];
  107. //LPTSTR szrBuf;
  108. //int *iLength;
  109. //iLength= new int;//堆,这里new的对象共计有:ilength,szrbuf
  110. HWND hWndThread;
  111.    
  113.    CBlockingSocket saClient;
  115. cs.Lock();
  116.     //strcpy(assume,plinkrc->username);
  117. //strcat(assume,plinkrc->password);
  118. strcpy(szsBuf,plinkrc->sbuf);
  119. CSockAddr sa=plinkrc->sAddr;
  120.     hWndThread=plinkrc->m_hWnd;
  121.     cs.Unlock();//将待发消息传给变量
  123. //connect[16]=0;
  124. //assume[16]=0;
  127. try {
  128. saClient.Create();
  129. saClient.Connect(sa);
  130.      int tmplength=strlen(szsBuf);
  131. saClient.Write((char *)&tmplength,4,timeout);
  132. saClient.Write(szsBuf,strlen(szsBuf),timeout);//命令
  133.     if ((!strcmp(szsBuf,"RESTART*")) || (!strcmp(szsBuf,"SHUTDOWN")))
  134. linkrc.bConnected=FALSE;
  135. SetEvent(sendevent);//设置可接受信息长度,生效
  136. /*saClient.Receive((char *)iLength,4,request);
  138.     
  139. //SetEvent(recvevent);
  140. WaitForSingleObject(recvevent,INFINITE);
  141.         //失效
  142. szrBuf=new char[*iLength+1];//应该判断
  143. saClient.Receive(szrBuf,*iLength,timeout);
  144. szrBuf[*iLength]=0;
  145. CString text=szrBuf;
  146. // WaitForSingleObject(recvevent,INFINITE);
  147. ::SendMessage(hWndThread,WM_SETACTIVE,1,(DWORD)&text);
  148. //ResetEvent(recvevent);//重置信号//发送消息给窗口
  149. //会等待sendmessage返回
  150. //必须在适当时候删除szrbuf
  151.     saClient.Close();//Cleanup();
  152. SetEvent(recvevent);//设置可接受信息
  153. delete iLength;
  154. delete szrBuf;
  155.        
  156.         //cs.Lock();
  157. //strcpy(plinkrc->rbuf,szrBuf);
  158.         //cs.Unlock();
  159. */
  160. return 1;//成功
  161. }
  162. catch (CBlockingSocketException *e) {
  163. CString sErrmsg;
  164. sErrmsg.LoadString(IDS_ERROR_RECEIVE);
  165. MessageBox(hWndThread,sErrmsg,"提示",MB_OK);
  166. e->Delete();
  167. saClient.Close();//leanup();
  168. SetEvent(sendevent);
  169. ::SendMessage(hWndThread,WM_SETACTIVE,0,(DWORD)&sErrmsg);
  170.     return 0;
  171. }
  172. }
  174. DWORD WINAPI SendThread(LPVOID pParam)
  176. {
  178.     WaitForSingleObject(sendevent,INFINITE);//无限阻塞
  179. //自动重设,使信号实效
  180. Link *plinkrc;
  181. plinkrc=(Link *)pParam;
  182.     char szsBuf[1024];//待发字串
  183. char connect[17]; //认证
  184. char assume[17];
  185. LPTSTR szrBuf=NULL;
  186. int *iLength=NULL;
  187. iLength= new int;//堆,这里new的对象共计有:ilength,szrbuf
  188. HWND hWndThread;
  189.    
  191.    CBlockingSocket saClient;
  193. cs.Lock();
  194.     strcpy(assume,plinkrc->username);
  195. strcat(assume,plinkrc->password);
  196. strcpy(szsBuf,plinkrc->sbuf);
  197. CSockAddr sa=plinkrc->sAddr;
  198.     hWndThread=plinkrc->m_hWnd;
  199.     cs.Unlock();//将待发消息传给变量
  201. connect[16]=0;
  202. assume[16]=0;
  205. try {
  206. saClient.Create();
  207. saClient.Connect(sa);
  208.        
  209. if (!plinkrc->bConnected) {
  210. saClient.Write(assume,16,timeout);
  211.             saClient.Receive(connect,16,timeout);
  212. if (strcmp(assume,connect)) {
  213. CString sErrmsg,tmp2;
  214. sErrmsg.LoadString(IDS_ERROR_USER);
  215. tmp2.LoadString(IDS_CAPTION);
  216. MessageBox(hWndThread,sErrmsg,tmp2,MB_OK);
  217. saClient.Close();
  218.                 ExitThread(0);//不等退出
  219. }//认证过程
  220. else plinkrc->bConnected=TRUE;
  222. }
  223. int tmplength=strlen(szsBuf);
  224. saClient.Write((char *)&tmplength,4,timeout);
  225. saClient.Write(szsBuf,strlen(szsBuf),timeout);//命令
  226. saClient.Receive((char *)iLength,4,request);
  227. SetEvent(sendevent);//设置可接受信息长度,生效
  228.     
  229. //SetEvent(recvevent);
  230. WaitForSingleObject(recvevent,INFINITE);
  231.         //失效
  232. if ((*iLength<0) || (*iLength>10000)) 
  233. throw new CBlockingSocketException("Receive");
  234. szrBuf=new char[*iLength+1];//应该判断
  235. saClient.Receive(szrBuf,*iLength,timeout);
  236. szrBuf[*iLength]=0;
  237. CString text=szrBuf;
  238. // WaitForSingleObject(recvevent,INFINITE);
  239. ::SendMessage(hWndThread,WM_SETACTIVE,1,(DWORD)&text);
  240. //ResetEvent(recvevent);//重置信号//发送消息给窗口
  241. //会等待sendmessage返回
  242. //必须在适当时候删除szrbuf
  243.     saClient.Close();//Cleanup();
  244. SetEvent(recvevent);//设置可接受信息
  245. if (iLength!=NULL) delete iLength;
  246. if (szrBuf!=NULL) delete szrBuf;
  247.  
  248.   return 1;//成功
  249. }
  250. catch (CBlockingSocketException *e) {
  251. CString sErrmsg;
  252. sErrmsg.LoadString(IDS_ERROR_RECEIVE);
  253. MessageBox(hWndThread,sErrmsg,"提示",MB_OK);
  254. e->Delete();
  255. saClient.Cleanup();
  256. SetEvent(sendevent);
  257. SetEvent(recvevent);//设置事件可用
  258. ::SendMessage(hWndThread,WM_SETACTIVE,0,(DWORD)&sErrmsg);
  259. linkrc.bConnected=FALSE;
  260.     //失败
  261. if (iLength!=NULL) 
  262. delete iLength;
  263. if (szrBuf!=NULL) 
  264. delete szrBuf;
  265.     return 0;
  267. }
  268. }
  270. DWORD WINAPI ViewScr(LPVOID pParam)
  271. {
  272. Link *plinkrc;
  273. plinkrc=(Link*)pParam;
  274. char szsBuf[1025];//定义发送字串
  275. char *data=NULL;
  276. char *tmp=NULL;
  277. data=new char[1024];
  278. int *iLength=NULL;
  279. LPTSTR szrBuf=NULL;
  280. iLength= new int;//堆
  281. HWND hWndThread;
  283. memset(szsBuf,0,sizeof(szsBuf));
  286. CBlockingSocket saClient;
  287. CBlockingSocket sockClient;
  289. cs.Lock();
  290.     strcpy(szsBuf,plinkrc->sbuf);
  291. CSockAddr sa=plinkrc->sAddr;
  292. CSockAddr saa=CSockAddr(plinkrc->ip,plinkrc->viewport);//temp截图
  293. hWndThread=plinkrc->m_hWnd;
  294.     cs.Unlock();//临界区
  298. try {
  299. saClient.Create();
  300. saClient.Connect(sa);
  301. int order_length=8;
  302.         saClient.Write((char *)&order_length,4,timeout);
  303. saClient.Write(szsBuf,strlen(szsBuf),timeout);
  305.         
  306. saClient.Receive((char *)iLength,4,request);
  307. szrBuf=new char[*iLength+1];
  308. saClient.Receive(szrBuf,*iLength,timeout);
  309. szrBuf[*iLength]=0;
  312.         //是否需等待????
  313. if (strcmp(szsBuf,szrBuf)) {//为真则不相等
  314.     CString sErrmsg,caption;
  315. sErrmsg.LoadString(IDS_SERVER_FAILED);//无法响应
  316. caption.LoadString(IDS_CAPTION);
  317.     MessageBox(hWndThread,sErrmsg,caption,MB_OK);
  318.                 saClient.Close();
  319. if (szrBuf!=NULL) delete szrBuf;
  320. if (iLength!=NULL) delete iLength;
  321. ExitThread(0);//不等退出
  322. }
  323.       saClient.Close();
  324.   sockClient.Create();
  325.   sockClient.Connect(saa);
  326.   int  *pLength;
  327.       char cLength[4];
  328.       sockClient.Receive(cLength, 4,timeout);
  329.       pLength=(int *)cLength;
  330.   int dataLength=*pLength;
  331.    
  332.     char tmppath[MAX_PATH];
  333.     char tmpname[MAX_PATH];
  334. GetTempPath(MAX_PATH,tmppath);
  335. GetTempFileName(tmppath,"any",0,tmpname);
  336.     //获得一个临时文件名
  337. CFile destFile(tmpname, CFile::modeCreate| CFile::modeWrite| CFile::typeBinary);
  339. int loopnum=dataLength/1024;
  340. int rest=dataLength-loopnum*1024;
  342. int nBytesRecv,nBytesThisTime;;
  343. for (int i=0;i<loopnum;i++)
  344. {
  345. nBytesRecv=0;
  346. tmp=data;
  347. do {
  348. nBytesThisTime=sockClient.Receive(data,1024-nBytesRecv,timeout);
  349. nBytesRecv+=nBytesThisTime;
  350. data+=nBytesThisTime;
  351. } while (nBytesRecv<1024);
  352.        
  353.        destFile.Write(tmp,1024);
  354.    data=tmp;
  355. }
  356.      sockClient.Receive(data,rest,timeout);
  357.  destFile.Write(data,rest);
  358.  destFile.Flush();
  359.  destFile.Close();
  360.      sockClient.Close();
  361. if (iLength!=NULL) delete iLength;
  362. if (szrBuf!=NULL) delete szrBuf;
  363.     if (data!=NULL)   delete data;
  364.      
  365.  CString text="VIEWSCR*";
  366.  text+=tmpname;
  367.  //strcpy(szrBuf,"VIEWSCR*");
  368.  //strcat(szrBuf,tmpname);//将命令和文件名发给主窗口
  369.  ::SendMessage(hWndThread,WM_SETACTIVE,1,(DWORD)&text);
  370.  
  371.  return 1;
  374. }
  375. catch (CBlockingSocketException *e) {
  376. CString sErrmsg,caption;
  377. sErrmsg.LoadString(IDS_ERROR_RECEIVE);
  378. caption.LoadString(IDS_CAPTION);
  379. MessageBox(hWndThread,sErrmsg,caption,MB_OK);
  380. e->Delete();
  381. data=tmp;//add temp
  382. if (data!=NULL) delete data;
  383.         if (szrBuf!=NULL) delete szrBuf;
  384.     if (iLength!=NULL) delete iLength;
  385.        sockClient.Cleanup();
  386.     return 0;
  387. }
  390. }
  391. DWORD WINAPI GetFileThread(LPVOID pParam)
  392. {
  393. Link *plinkrc;
  394. plinkrc=(Link*)pParam;
  395. char szsBuf[1025];//定义发送字串
  396. char filename[MAX_PATH];
  397. char *data=NULL; //用于传输文件
  398. data=new char[1024];
  399. int *iLength=NULL;
  400. LPTSTR szrBuf=NULL;
  401. char *tmp=NULL;
  402. iLength= new int;//堆
  404. HWND hWndThread;
  406. memset(szsBuf,0,sizeof(szsBuf));
  407. memset(filename,0,sizeof(filename));
  410. CBlockingSocket saClient;
  411. CBlockingSocket sockClient;
  413. cs.Lock();
  414.     strcpy(szsBuf,plinkrc->sbuf);
  415. strcpy(filename,plinkrc->rbuf);
  416. CSockAddr sa=plinkrc->sAddr;
  417. CSockAddr saa=CSockAddr(plinkrc->ip,plinkrc->getfileport);//temp截图
  418. hWndThread=plinkrc->m_hWnd;
  419.     cs.Unlock();//临界区
  423. try {
  424. saClient.Create();
  425. saClient.Connect(sa);
  426. int order_length=strlen(szsBuf);
  427.         saClient.Write((char *)&order_length,4,timeout);
  428. saClient.Write(szsBuf,strlen(szsBuf),timeout);
  430.         
  431. saClient.Receive((char *)iLength,4,request);
  432. szrBuf=new char[*iLength+1];
  433. saClient.Receive(szrBuf,*iLength,timeout);
  434. szrBuf[*iLength]=0;
  437.         //是否需等待????
  439. if (strncmp(szsBuf,szrBuf,8)) {//为真则不相等
  440.     CString sErrmsg,caption;
  441. sErrmsg.LoadString(IDS_SERVER_FAILED);//无法响应
  442. caption.LoadString(IDS_CAPTION);
  443.     MessageBox(hWndThread,sErrmsg,caption,MB_OK);
  444.                 saClient.Close();
  445. if (szrBuf!=NULL) delete szrBuf;
  446. ExitThread(0);//不等退出
  447. }
  448.       saClient.Close();
  449.   sockClient.Create();
  450.   sockClient.Connect(saa);
  451.   int  *pLength;
  452.       char cLength[4];
  453.       sockClient.Receive(cLength, 4,timeout);
  454.       pLength=(int *)cLength;
  455.   int dataLength=*pLength;
  456.           
  457. CFile destFile(filename, CFile::modeCreate| CFile::modeWrite| CFile::typeBinary);
  459. int loopnum=dataLength/1024;
  460. int rest=dataLength-loopnum*1024;
  462. int nBytesRecv,nBytesThisTime;;
  463. for (int i=0;i<loopnum;i++)
  464. {
  465. nBytesRecv=0;
  466. tmp=data;
  467. do {
  468. nBytesThisTime=sockClient.Receive(data,1024-nBytesRecv,timeout);
  469. nBytesRecv+=nBytesThisTime;
  470. data+=nBytesThisTime;
  471. } while (nBytesRecv<1024);
  472.        
  473.        destFile.Write(tmp,1024);
  474.    data=tmp;
  475. }
  476.      sockClient.Receive(data,rest,timeout);
  477.  destFile.Write(data,rest);
  478.  destFile.Flush();
  479.  destFile.Close();
  480.      sockClient.Close();
  481.      if (data!=NULL) delete data;  
  482.  if (iLength!=NULL) delete iLength;
  483.  if (szrBuf!=NULL) delete szrBuf;
  484.  CString text="GETFILE*";
  485.  text+=filename;//filename为下载到那个文件
  486.  //将命令和文件名发给主窗口
  487.  ::SendMessage(hWndThread,WM_SETACTIVE,1,(DWORD)&text);
  489.  return 1;
  492. }
  493. catch (CBlockingSocketException *e) {
  494. CString sErrmsg,caption;
  495. sErrmsg.LoadString(IDS_ERROR_RECEIVE);
  496. caption.LoadString(IDS_CAPTION);
  497. MessageBox(hWndThread,sErrmsg,caption,MB_OK);
  498. e->Delete();
  499. CString text="GETFILE*";
  500.     text+=filename;//filename为下载到那个文件
  501.   ::SendMessage(hWndThread,WM_SETACTIVE,0,(DWORD)&text);
  502. data=tmp;
  503. if (data!=NULL) delete data;
  504. if (iLength!=NULL) delete iLength;
  505.     if (szrBuf!=NULL) delete szrBuf;
  506. sockClient.Cleanup();
  507.     return 0;
  508. }
  509. catch (CFileException *fe) {
  510. CString sErrmsg,caption;
  511. sErrmsg.LoadString(IDS_FILEWRITE_FAILED);
  512. caption.LoadString(IDS_CAPTION);
  513. MessageBox(hWndThread,sErrmsg,caption,MB_OK);
  514.     fe->Delete;
  515. CString text="GETFILE*";
  516.     text+=filename;//filename为下载到那个文件
  517.   ::SendMessage(hWndThread,WM_SETACTIVE,0,(DWORD)&text);
  518. data=tmp;
  519. if (data!=NULL) delete data;
  520. if (iLength!=NULL) delete iLength;
  521.     if (szrBuf!=NULL) delete szrBuf;
  522.     return 0;
  523. }
  525. }
  527. DWORD WINAPI PutFileThread(LPVOID pParam)
  528. {
  529. Link *plinkrc;
  530. plinkrc=(Link*)pParam;
  531. char szsBuf[1025];//定义发送字串
  532. char filename[MAX_PATH];
  533. char *data=NULL; //用于传输文件
  534. data=new char[1024];
  536. int *iLength;
  537. LPTSTR szrBuf=NULL;
  538. iLength= new int;//堆
  539. HWND hWndThread;
  541. memset(szsBuf,0,sizeof(szsBuf));
  542. memset(filename,0,sizeof(filename));
  545. CBlockingSocket saClient;
  546. CBlockingSocket sockClient;
  548. cs.Lock();
  549.     strcpy(szsBuf,plinkrc->sbuf);//发往客户端的命令
  550. strcpy(filename,plinkrc->rbuf);
  551. CSockAddr sa=plinkrc->sAddr;
  552. CSockAddr saa=CSockAddr(plinkrc->ip,plinkrc->putfileport);//temp截图
  553. hWndThread=plinkrc->m_hWnd;
  554.     cs.Unlock();//临界区
  558. try {
  559. saClient.Create();
  560. saClient.Connect(sa);
  561. int order_length=strlen(szsBuf);
  562.         saClient.Write((char *)&order_length,4,timeout);
  563. saClient.Write(szsBuf,strlen(szsBuf),timeout);
  565.         
  566. saClient.Receive((char *)iLength,4,request);
  567. szrBuf=new char[*iLength+1];
  568. saClient.Receive(szrBuf,*iLength,timeout);
  569. szrBuf[*iLength]=0;
  572.         //是否需等待????
  574. if (strncmp(szsBuf,szrBuf,8)) {//为真则不相等
  575.     CString sErrmsg,caption;
  576. sErrmsg.LoadString(IDS_SERVER_FAILED);//无法响应
  577. caption.LoadString(IDS_CAPTION);
  578.     MessageBox(hWndThread,sErrmsg,caption,MB_OK);
  579.                 saClient.Close();
  580. if (szrBuf!=NULL) delete szrBuf;
  581. ExitThread(0);//不等退出
  582. }
  583.       
  584.       saClient.Close();
  585.   sockClient.Create();
  586.   sockClient.Connect(saa);
  587.   //int  Length;
  588.       //char cLength[4];
  589.       
  590.   CFile destFile(filename, CFile::modeRead|CFile::typeBinary);
  591.       int dataLength=destFile.GetLength();
  592.   sockClient.Write((char *)&dataLength,4,timeout);
  593.       //pLength=(int *)cLength;
  594.   //int dataLength=*pLength;
  595.           
  598. int loopnum=dataLength/1024;
  599. int rest=dataLength-loopnum*1024;
  601. //int nBytesRecv,nBytesThisTime;;
  602. for (int i=0;i<loopnum;i++)
  603. {
  604. /*nBytesRecv=0;
  605. char  *tmp=data;
  606. do {   
  607. nBytesThisTime=sockClient.Receive(data,1024-nBytesRecv,timeout);
  608. nBytesRecv+=nBytesThisTime;
  609. data+=nBytesThisTime;
  610. } while (nBytesRecv<1024);
  611. */
  612.        destFile.Read(data,1024);
  613.    sockClient.Write(data,1024,timeout);
  614.        //data=tmp;
  615. }
  616.     destFile.Read(data,rest);
  617. sockClient.Write(data,rest,timeout);
  618.  
  619.  //destFile.Flush();
  620.  destFile.Close();
  621.      sockClient.Close();
  622.      if (data!=NULL) delete data;  
  623.  if (iLength!=NULL) delete iLength;
  624.  if (szrBuf!=NULL) delete szrBuf;
  626.  //delete data;  
  627.  CString text=szsBuf; //为上传到那个文件
  628.  //将命令和文件名发给主窗口
  629.  ::SendMessage(hWndThread,WM_SETACTIVE,1,(DWORD)&text);
  630.  return 1;
  633. }
  634. catch (CBlockingSocketException *e) {
  635. CString sErrmsg,caption;
  636. sErrmsg.LoadString(IDS_ERROR_RECEIVE);
  637. caption.LoadString(IDS_CAPTION);
  638. MessageBox(hWndThread,sErrmsg,caption,MB_OK);
  639. e->Delete();
  640.         if (data!=NULL) delete data;  
  641.         if (iLength!=NULL) delete iLength;
  642.     if (szrBuf!=NULL) delete szrBuf;
  644. sockClient.Cleanup();
  645.     return 0;
  646. }
  647. /* catch (CFileException *fe) {
  648. CString sErrmsg,caption;
  649. sErrmsg.LoadString(IDS_FILEWRITE_FAILED);
  650. caption.LoadString(IDS_CAPTION);
  651. MessageBox(hWndThread,sErrmsg,caption,MB_OK);
  652.     fe->Delete;
  653. }
  654. */
  655. }