求助；ACE Reactor中建立连接时内存泄露问题

law5211314

本人ACE新手，最近在开发项目时遇到了问题。（vs2008）
当使用ACE的反应器中连接器建立连接时，如果使用同步阻塞方式连接，程序退出时不会有内存泄露。
如果设置超时时间，建立连接时则会发现有一次性的44+28字节的内存泄露。如下所示。
{7987} normal block at 0x00DE6BD8, 44 bytes long.
Data: < ` > 00 00 00 00 60 0D 16 00 FF FF FF FF 00 00 00 00  
{7986} normal block at 0x0039CBD8, 28 bytes long.
Data: < > E8 EF 15 00 FF FF FF FF 00 00 00 00 00 00 00 00  
如果在连接时使用异步连接方式如下程序所示，就会产生一次性的内存泄露44+28字节，同上，和循环内存泄露40字节（每connect一次就泄露40字节），如下。
{7987} normal block at 0x00DE6BD8, 44 bytes long.
Data: < ` > 00 00 00 00 60 0D 16 00 FF FF FF FF 00 00 00 00  
{7986} normal block at 0x0039CBD8, 28 bytes long.
Data: < > E8 EF 15 00 FF FF FF FF 00 00 00 00 00 00 00 00  
{7899} normal block at 0x00DE6CA8, 40 bytes long.
Data: < T 9 > 04 54 06 10 01 00 00 00 00 00 00 00 E8 D6 39 00  
{7801} normal block at 0x00DE6C40, 40 bytes long.
以上泄露都是在程序退出时发现的，下面是我简化了的测试程序，不知道是我在程序退出时少调用了某些函数还是什么其他的原因，希望大侠们能够指点一下小弟，小弟跪谢。

1. // Client.cpp : Defines the entry point for the console application.
2. //
4. #include "stdafx.h"
5. #include <iostream>
6. #include <ace\Svc_Handler.h>
7. #include <ace\SOCK_Stream.h>
8. #include <ace\Connector.h>
9. #include <ace\SOCK_Connector.h>
10. using namespace std;
11. #pragma comment(lib , "aced.lib")
13. class CTestSvc :
14.     public ACE_Svc_Handler<ACE_SOCK_Stream , ACE_MT_SYNCH>
15. {
16. public:
17.     CTestSvc(void){;}
18.     virtual ~CTestSvc(){;}   
19.     //连接关闭回调接口
20.     virtual int handle_close(ACE_HANDLE  = ACE_INVALID_HANDLE ,
21.         ACE_Reactor_Mask  = ACE_Event_Handler::ALL_EVENTS_MASK )
22.        {
23.           if(reactor())
24.         {
25.             reactor()->end_reactor_event_loop();
26.             reactor()->remove_handler(this , WRITE_MASK);
27.             reactor(0);
28.             cout<<"handle_close"<<endl;
29.         }
30.    
31.         return 0;
32.         }   
33.     virtual int handle_output(ACE_HANDLE fd /* = ACE_INVALID_HANDLE */)
34.     {
35.         cout<<"handle_output"<<endl;
36.         return 0;
37.     }
38.    
39. };
42. //////////////////////////////////////////////////////////////////////////
43. class CCmdConnector :
44.     public ACE_Connector<CTestSvc , ACE_SOCK_Connector>
45. {
46. public:
47.     typedef ACE_Connector<CTestSvc , ACE_SOCK_Connector> parentclass;
48.     CCmdConnector(void){;}
49.     virtual ~CCmdConnector(void){;}
50.     //创建服务句柄
51.     virtual int make_svc_handler(CTestSvc *& sn)
52.     {
53.         return parentclass::make_svc_handler(sn);
54.     }
55. };
57. //////////////////////////////////////////////////////////////////////////
58. class CClient :
59.     public ACE_Task<ACE_MT_SYNCH>
60. {
61. public:
62.     CCmdConnector m_Connector;
63.     CTestSvc * m_pTestsvc;
64. public:
65.     CClient()
66.     {
67.         m_pTestsvc = new CTestSvc;
68.     }
69.     ~CClient()
70.     {
71.         if(m_pTestsvc)
72.         {
73.             delete m_pTestsvc;
74.             m_pTestsvc = NULL;
75.         }
76.         reactor(0);
77.     }
78.     //启动
79.     void Start()
80.     {
81.         int nRet = 0;
82.         nRet = m_Connector.open();
83.         if(nRet == -1)
84.         {
85.             cout<<"启动失败"<<endl;
86.             return;
87.         }
89.         ACE_INET_Addr addr("192.168.5.112:27015");
90.         nRet = m_Connector.connect(m_pTestsvc , addr , ACE_Synch_Options::asynch);   
91.         this->activate();
92.     }
94.     void End()
95.     {
96.         m_Connector.cancel(m_pTestsvc);
97.         m_Connector.close();
98.         m_pTestsvc->handle_close();
99.         wait();
100.     }
102. };
104. //////////////////////////////////////////////////////////////////
106. int _tmain(int argc, _TCHAR* argv[])
107. {  
108.     CClient client;
110.      client.Start();
111.      Sleep(5000);
112.      client.End();
114.     return 0;
115. }

复制代码

yoogera

找个工具看一下吧，