[ACE编程] 菜鸟求助，有代码求真相!!!

hiterator

刚学习ACE编程，找了个程序调试了下，看起来没问题；
连接服务器成，之后程序结束时就崩溃了，请懂行的大侠给指导下，看是不是违反了ACE编程规则；
感谢~

补充：
1. 把fini去掉好像就好了，why? 有人说init和fini必须配对使用；

1. 
   
2. #include "ace/ACE.h"
   
3. #include "ace/Log_Msg.h"
   
4. 
   
5. #include "ace/OS.h"
   
6. #include "ace/Reactor.h"
   
7. #include "ace/SOCK_Connector.h"
   
8. 
   
9. #define MAX_MYCLIENT_BUFFER     (1023)
   
10. 
    
11. 
    
12. #ifdef _DEBUG
    
13. #pragma comment(lib, "ACEd.lib")
    
14. #else
    
15. #pragma comment(lib, "ACE.lib")
    
16. #endif // _DEBUG
    
17. 
    
18. using namespace std;
    
19. 
    
20. class CMyClient : public ACE_Event_Handler
    
21. {
    
22. public:
    
23.     bool open()
    
24.     {
    
25.         ACE_SOCK_Connector conn;
    
26.         ACE_INET_Addr addr(6789, "127.0.0.1");
    
27. 
    
28.         ACE_Time_Value timeout(5, 0);
    
29. 
    
30.         int nRet = conn.connect(peer_, addr, &timeout);
    
31.         if (0 != nRet)
    
32.         {
    
33.             ACE_ERROR((LM_ERROR, "connect ret(%d) failed.\n", nRet));
    
34.             return false;
    
35.         }
    
36. 
    
37.         ACE_Reactor::instance()->register_handler(this, ACE_Event_Handler::READ_MASK);
    
38. 
    
39.         ACE_DEBUG((LM_DEBUG, "connect ok.\n"));
    
40. 
    
41.         return true;
    
42.     }
    
43. 
    
44.     int close()
    
45.     {
    
46.         int nRet = 0;
    
47. 
    
48.         nRet = ACE_Reactor::instance()->remove_handler(this, ACE_Event_Handler::READ_MASK);
    
49. 
    
50.         return nRet;
    
51.     }
    
52. 
    
53.     ACE_HANDLE get_handle(void) const   
    
54.     {
    
55.         return peer_.get_handle();
    
56.     }
    
57. 
    
58.     virtual int handle_input(ACE_HANDLE fd)
    
59.     {
    
60.         int recv = 0;
    
61.         ACE_Time_Value timeout(3, 0);
    
62. 
    
63.         recv = peer_.recv(buffer_, MAX_MYCLIENT_BUFFER, &timeout);
    
64.         if (recv > 0)
    
65.         {
    
66.             buffer_[recv] = '\0';
    
67.             ACE_DEBUG((LM_DEBUG, "recv: [%s]\n", buffer_));
    
68.         }
    
69.         else // (recv <= 0)
    
70.         {
    
71.             ACE_ERROR((LM_ERROR, "[handle_input:%t] recv(%d), error(%d)\n", recv, ::WSAGetLastError()));
    
72.             return -1;
    
73.         }
    
74. 
    
75.         return 0;
    
76.     }
    
77. 
    
78.     virtual int handle_close(ACE_HANDLE handle, ACE_Reactor_Mask close_mask)
    
79.     {
    
80.         int nRet = 0;
    
81. 
    
82.         nRet = peer_.close();
    
83. 
    
84.         return nRet;
    
85.     }
    
86. 
    
87. private:
    
88.     ACE_SOCK_Stream peer_;
    
89.     char buffer_[MAX_MYCLIENT_BUFFER + 1];
    
90. 
    
91.     long timer_;
    
92. };
    
93. 
    
94. 
    
95. int main(int, char *[])
    
96. {
    
97.     ACE_ERROR((LM_ERROR, "[main tid:%t] start.\n"));
    
98. 
    
99.     ACE::init();
    
100. 
     
101.     CMyClient *pClient = new CMyClient();
     
102. 
     
103.     pClient->open();
     
104. 
     
105.     ACE_Reactor::instance()->run_reactor_event_loop(ACE_Time_Value(10));  // 是不是这个使用有问题??
     
106. 
     
107.     pClient->close();
     
108. 
     
109.     delete pClient; pClient=NULL;
     
110. 
     
111.     ACE::fini(); // 把这个去掉好像就好了
     
112.     return 0;
     
113. } // 运行结束后程序出现崩溃
     

复制代码

hiterator

顶一下，给出调用栈信息，但偶还是看不懂啊....

{:2_166:}

好像是 析构时出错了，why???

求大侠快来！！！

{:3_190:}

1.         ACEd.dll!ACE_WFMO_Reactor_Handler_Repository::make_changes_in_current_infos()  行771 + 0x12 字节        C++
   
2. >        ACEd.dll!ACE_WFMO_Reactor_Handler_Repository::make_changes()  行417        C++
   
3.         ACEd.dll!ACE_WFMO_Reactor::~ACE_WFMO_Reactor()  行1329 + 0x19 字节        C++
   
4.         ACEd.dll!ACE_WFMO_Reactor::`vector deleting destructor'()  + 0x57 字节        C++
   
5.         ACEd.dll!ACE_Reactor::~ACE_Reactor()  行115 + 0x27 字节        C++
   
6.         ACEd.dll!ACE_Reactor::`vector deleting destructor'()  + 0x54 字节        C++
   
7.         ACEd.dll!ACE_Reactor::close_singleton()  行179 + 0x25 字节        C++
   
8.         ACEd.dll!ACE_Framework_Component_T<ACE_Reactor>::~ACE_Framework_Component_T<ACE_Reactor>()  行22        C++
   
9.         ACEd.dll!ACE_Framework_Component_T<ACE_Reactor>::`scalar deleting destructor'()  + 0x16 字节        C++
   
10.         ACEd.dll!ACE_Framework_Repository::close()  行75 + 0x23 字节        C++
    
11.         ACEd.dll!ACE_Framework_Repository::~ACE_Framework_Repository()  行38        C++
    
12.         ACEd.dll!ACE_Framework_Repository::`scalar deleting destructor'()  + 0x16 字节        C++
    
13.         ACEd.dll!ACE_Framework_Repository::close_singleton()  行120 + 0x1f 字节        C++
    
14.         ACEd.dll!ACE_Object_Manager::fini()  行749        C++
    
15.         ACEd.dll!ACE::fini()  行30 + 0x17 字节        C++
    
16.         ACEd.dll!ACE_Main_Base::~ACE_Main_Base()  行84        C++
    
17.         Test.exe!ACE_Main::~ACE_Main()  + 0x2e 字节        C++
    
18.         Test.exe!main(int argc=1, char * * argv=0x00a7e5f0)  行97 + 0x7b 字节        C++
    
19.         Test.exe!__tmainCRTStartup()  行582 + 0x19 字节        C
    
20.         Test.exe!mainCRTStartup()  行399        C
    
21.         kernel32.dll!755c33aa()        
    
22.         [下面的框架可能不正确和/或缺失，没有为 kernel32.dll 加载符号]       
    
23.         ntdll.dll!77209ef2()        
    
24.         ntdll.dll!77209ec5()        
    

复制代码