ACE_Connector重连出错

peakzhang

ACE_Connector<BillingHandler, ACE_SOCK_CONNECTOR> m_Connector;重连部分代码:

2. BillingHandler* pHandler = this;
3.   nRet = m_Connector.connect(pHandler, m_SvrAddr, ACE_Synch_Options::asynch);
4.   if(nRet==-1)
5.   {
6.     int nErrno = errno;
7.     if(nErrno != EWOULDBLOCK)
8.     //nErrno总是返回10038
9.     ...........
10.   }
11. 连接关闭的处理:
12. int BillingHandler::handle_close(ACE_HANDLE, ACE_Reactor_Mask)
13. {
14.   ACE_Reactor::instance()->remove_handler(this, ACE_Event_Handler::ALL_EVENTS_MASK|ACE_Event_Handler::DONT_CALL);
15.   if(get_handle() != ACE_INVALID_HANDLE)
16.   {
17.     m_Peer.close();
18.     m_Connector.cancel(this);
19.   }
20.   ...
21. }

复制代码

连接完成时的处理:

2. int BillingHandler::open(void*)
3. {
4.   m_Peer = peer();
5.   if(m_Peer.enable(ACE_NONBLOCK) == -1)
6.   {
7.     ACE_ERROR_RETURN((LM_ERROR, "(%t) %p\n", "enable"), -1);
8.   }
9.   
10.   if(ACE_Reactor::instance()->->register_handler(this, ACE_Event_Handler::READ_MASK) == -1)
11.   {
12.     ACE_ERROR_RETURN((LM_ERROR,"(%t) %p\n","register_handler"), -1);
13.   }
14.     return 0;
15. }

复制代码

重连时nErrno总是返回10038, 问题出在哪里呢?或者handle_close处理不当?

peakzhang

10038—WSAENOTSOCK
Socket operation on an invalid socket. This error can be returned from any Winsock function that takes a SOCKET handle as a parameter. This error indicates that the supplied socket handle is not valid.

你的代码返回这个错误，说明socket已经被关闭了，你后续的所有socket操作，都是无效的。
解决办法也简单，你delete这个handler，然后通过重新连接，重新建立一个就成了。