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

peakzhang

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

peakzhang

移除事件注册

关闭相应的流对象

。。。

peakzhang

这是我的实现代码：

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

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

复制代码

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

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

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

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

复制代码

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

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