如何正常关闭ACE_Event_Handler的客户端？

peakzhang

我把ACE_Event_Handler继承后，VC环境下封装成了客户端的DLL，用来实现发送、接收、断开连接三个功能，但是不管怎么处理，都无法在主动关闭（VB环境，直接调用“断开连接”功能）情况下，正常关闭连接（总是出现崩溃或内存错误），请问该怎么处理？能给一份正确参考代码吗？

peakzhang

移除事件注册

关闭相应的流对象

。。。

peakzhang

这是我的实现代码：

1〉dll对外提供的接口函数代码

1. int __stdcall DisConnect( long nConn )
   
2. {
   
3. 
   
4. if( !find_connection(nConn) )return 0; //确认是否存在连接
   
5. 
   
6. Connector *connector_=(Connector *)nConn; //转换为指针
   
7. connector_->reactor()->remove_handler(connector_->get_handle(),
   
8.   ACE_Event_Handler::ALL_EVENTS_MASK);
   
9. 
   
10. return 0;
    
11. }
    
12. 
    
13. 
    
14. 2〉ACE_Event_Handler::handle_close代码
    
15. 
    
16. int Connector::handle_close (ACE_HANDLE h, ACE_Reactor_Mask mask)
    
17. {
    
18. ACE_DEBUG((LM_DEBUG, "[Connector::handle_close]handle_close\n"));
    
19. 
    
20. if(mask == ACE_Event_Handler::WRITE_MASK)
    
21.   return 0;
    
22. 
    
23. ::SendMessage(m_hPeerWnd, MSG_CONN_BROKEN, 0, (LPARAM)this); //通知应用层断开连接
    
24. 
    
25. mask = ACE_Event_Handler::ALL_EVENTS_MASK | ACE_Event_Handler::DONT_CALL;
    
26. //
    
27. //this->reactor()->remove_handler(this, mask);
    
28. this->sock_.close();                                       //客户端的ACE_SOCK_Stream
    
29. delete this;
    
30. delete_connection((long)this);                             //从连接列表中删除
    
31. return 0;//ACE_Event_Handler::handle_close(h, mask);
    
32. }

复制代码

上述代码在断开连接时严重崩溃，实在不晓得怎么回事？

peakzhang

把connector_->reactor()->remove_handler(connector_->get_handle(),
  ACE_Event_Handler::ALL_EVENTS_MASK);

改为

connector_->reactor()->remove_handler(connector,
  ACE_Event_Handler::ALL_EVENTS_MASK);

行不行

peakzhang

I can guess two cases.
1. handle_close be called twice
2. handler is used, after handle_close.
Comment out delete this, try it with logging on, then check the logs.
BTW,
You better refactor this code anyway.It's buggy.
Good luck!

peakzhang

这是我的客户端头文件定义：

1. class  Connector : public ACE_Event_Handler  
   
2. {
   
3. public:
   
4. Connector();
   
5. virtual ~Connector();
   
6. 
   
7. int open (const ACE_INET_Addr &listen_addr);
   
8. 
   
9. // Get this handler's I/O handle.
   
10. virtual ACE_HANDLE get_handle (void) const
    
11.     { return this->sock_.get_handle (); }
    
12. 
    
13. // Called when a connection is ready to accept.
    
14. virtual int handle_input (ACE_HANDLE fd = ACE_INVALID_HANDLE);
    
15. int handle_output(ACE_HANDLE);
    
16. 
    
17. // Called when this handler is removed from the ACE_Reactor.
    
18. virtual int handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask);
    
19. 
    
20. ACE_SOCK_Stream sock(void) const
    
21. { return sock_; }
    
22. 
    
23. 
    
24. HWND m_hOwnerWnd;
    
25. 
    
26. ACE_thread_t *m_pthreadID;
    
27. protected:
    
28. ACE_SOCK_Connector connector_;
    
29. ACE_SOCK_Stream sock_;
    
30. };

复制代码

m_pthreadID是后来增加的，另外有一个全局的vector存放每次连接服务器的连接变量，即上面这个类的实例变量，请问这样的客户端怎么主动关闭？

peakzhang

把connector_->reactor()->remove_handler(connector_->get_handle(),
  ACE_Event_Handler::ALL_EVENTS_MASK);

改为

reactor()->remove_handler(connector,
  ACE_Event_Handler::ALL_EVENTS_MASK);

peakzhang

把connector_->reactor()->remove_handler(connector_->get_handle(),
  ACE_Event_Handler::ALL_EVENTS_MASK);

改为

reactor()->remove_handler(this,
  ACE_Event_Handler::ALL_EVENTS_MASK);

peakzhang

呵！终于解决了！都是线程惹的祸。

demon

咋解决的？
给大家说下啊。