socket关不掉吗？

开发者

我在Proactor下继承ACE_Service_Handler写了一个类Test（对象pTest），去连接另外一台机器；当去连接的时候会创建一个Test的实例pTest，可是在这个socket（也就是pTest）主动断开连接的时候，总是会出现程序挂掉的情况，请问有没有知道什么原因的！

是ACE对断开的连接有什么限制吗？

peakzhang

你程序的问题，设置断点追踪一下。
ACE对断开的连接都是可以处理的，问题在于你怎么处理。

开发者

我在程序跟踪的过程中，在delete pTest的时候，里面有一个指针总是在delete的时候有问题，好像有越位的情况，是不是程序里面有什么地方指针或者其他的东西使用不当造成的？

winston

这是很常见的C++程序错误，你删除指针指向的对象的时候，这个对象还在被别的线程操作。
应该是典型的同步问题。

开发者

所有程序都是在一个Thread里面跑的

winston

那就更好查了。贴上程序，我们帮你分析分析。

开发者

外面在使用的时候是
CTestA *pTest = new CTestA();
pTest.Connect();

delete的时候是：
pTest.DisConnect();
delete pTest;//问题就再这里，总是delete的时候错误，甚至导致程序挂掉
pTest = 0;

开发者

下面是代码：

1. CTestA::CTestA()
2. {
3.         pSoc                = 0;
4. }
6. CTestA::~CTestA()
7. {
8.         if (pSoc)
9.         {
10.                 delete pSoc;
11.                 pSoc = 0;
12.         }
13. }
15. bool CTestA::Connect()
16. {
17.         ACE_Asynch_Connector<CTestB> vConnector;
18.         vConnector.open();
19.         ACE_INET_Addr peer_addr (8000, 192.168.1.10);
20.         if (vConnector.connect(peer_addr, (const ACE_INET_Addr &)ACE_Addr::sap_any, 1, this) == -1)
21.         {
22.                 return false;
23.         }
24.         return true;
25. }
27. bool CTestA:isConnect()
28. {
29.         if (!pSoc)
30.                 return false;
32.         if (pSoc->handle() != ACE_INVALID_HANDLE)
33.                 ACE_OS::closesocket (pSoc->handle());
35.         if (pSoc)
36.         {
37.                 pSoc->m_pTestA = 0;
38.                 delete pSoc;
39.                 pSoc = 0;
40.         }
42.         return true;
43. }
45. void CTestA::MethodA(void* pSocket)
46. {
47.         if (!pSocket) return;
48.         pSoc = (CTestB*) pSocket;
50.         ACE_OS::memset(cBuffer, 0, 1024);//cBuffer成员变量
51. }
53. void CTestA::MethodB()
54. {
55.         if (!pSoc) return;
57.         ACE_CString str = "ddddddddddddddddddd";
58.         pSoc->ostWrite((char*)str.fast_rep(), str.length());
59. }
61. void CTestA::MethodC(char *pContent, int nSize)
62. {
63.         //
64. }
66. void CTestA::CloseA()
67. {
68.         pSoc = 0;
69. }
72. CTestB继承ACE_Service_Handler
73. CTestB::CTestB()
74. {
75.         m_pTestA        = 0;
76.         m_pReaderMB                = 0;
77. }
79. CTestB::~CTestB()
80. {
81.         if (m_pTestA)
82.         {
83.                 m_pTestA->CloseA();
84.                 m_pTestA = 0;
85.         }
87.         if (this->handle() != ACE_INVALID_HANDLE)
88.                 ACE_OS::closesocket (this->handle());
90.         if (m_pReaderMB)
91.         {
92.                 m_pReaderMB->release();
93.                 m_pReaderMB = 0;
94.         }
95. }
97. void CTestB::act (const void *pTest)
98. {
99.         m_pTestA = (CTestA*)pTest;
100.         if (m_pTestA)
101.                 m_pTestA->MethodA(this);
102. }
104. void CTestB:pen (ACE_HANDLE h, ACE_Message_Block&)
105. {
106.         if (!m_pTestA)
107.         {
108.                 delete this;
109.                 return;
110.         }
112.         this->handle (h);
113.         if (this->m_Reader.open (*this) != 0 || this->m_Writer.open (*this) != 0)
114.         {
115.                 delete this;
116.                 return;
117.         }
119.         ACE_NEW_NORETURN (m_pReaderMB, ACE_Message_Block (PACKET_BUFFERSIZE));
121.         if (m_pTestA)
122.                 m_pTestA->MethodB();
124.         PostRead();
125. }
127. void CTestB::handle_read_stream(const ACE_Asynch_Read_Stream::Result &result)
128. {
129.         if (!result.success () || result.bytes_transferred () == 0)
130.         {
131.                 delete this;
132.                 return;
133.         }
135.         ACE_Message_Block &mb = result.message_block();
137.         if (m_pTestA)
138.                 m_pTestA->MethodC(mb.rd_ptr(), mb.length());
140.         PostRead();
141. }
143. void CTestB::handle_write_stream(const ACE_Asynch_Write_Stream::Result &result)
144. {
145.         result.message_block().release();
147.         if (!result.success () || result.bytes_transferred () == 0)
148.         {
149.                 delete this;
150.                 return;
151.         }
152.         return;
153. }
155. void CTestB:ostRead()
156. {
157.         if (!m_pReaderMB) return;
158.         if (this->handle() == ACE_INVALID_HANDLE) return;
160.         m_pReaderMB->reset();
161.         if (this->m_Reader.read (*m_pReaderMB, m_pReaderMB->space()) != 0);
162. }
164. bool CTestB:ostWrite(char* pBuffer, int nSize)
165. {
166.         if (this->handle() == ACE_INVALID_HANDLE) return false;
168.         ACE_Message_Block* pWriterMB = 0;
169.         ACE_NEW_RETURN (pWriterMB, ACE_Message_Block (1024), false);
171.         pWriterMB->copy(pBuffer, nSize);
172.         if (this->m_Writer.write (*pWriterMB, pWriterMB->length ()) != 0);
174.         return true;
175. }

复制代码

[ 本帖最后由 winston 于 2007-12-25 15:16 编辑 ]

winston

pTest.DisConnect(); 怎么写的？

感觉是你的程序退出了，但是还有对象在操作导致。

开发者

外面在使用的时候是
CTestA *pTest = new CTestA();
pTest.Connect();

delete的时候是：
pTest.isConnect();//打错了
delete pTest;//问题就再这里，总是delete的时候错误，甚至导致程序挂掉
pTest = 0;