You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2009/05/21 10:21:26 UTC
svn commit: r777006 - /qpid/trunk/qpid/cpp/src/qpid/client/Connector.cpp
Author: gsim
Date: Thu May 21 08:21:26 2009
New Revision: 777006
URL: http://svn.apache.org/viewvc?rev=777006&view=rev
Log:
QPID-1869: Set closed flag to false only after poller and aio are initialised.
Modified:
qpid/trunk/qpid/cpp/src/qpid/client/Connector.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/client/Connector.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/Connector.cpp?rev=777006&r1=777005&r2=777006&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/Connector.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/Connector.cpp Thu May 21 08:21:26 2009
@@ -197,7 +197,6 @@
}
identifier = str(format("[%1% %2%]") % socket.getLocalPort() % socket.getPeerAddress());
- closed = false;
poller = Poller::shared_ptr(new Poller);
aio = AsynchIO::create(socket,
boost::bind(&TCPConnector::readbuff, this, _1, _2),
@@ -206,6 +205,7 @@
0, // closed
0, // nobuffs
boost::bind(&TCPConnector::writebuff, this, _1));
+ closed = false;
}
void TCPConnector::init(){
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org