summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/sys/posix/AsynchIO.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2010-06-11 08:42:37 +0000
committerGordon Sim <gsim@apache.org>2010-06-11 08:42:37 +0000
commit4467d34858ea0ab6d11fbc90f81162e642fe3133 (patch)
tree55725d96eb38456f755e59410253ad6ccb737cf1 /cpp/src/qpid/sys/posix/AsynchIO.cpp
parent85e7cf723b05620e1ed44d50a9533811e823585f (diff)
downloadqpid-python-4467d34858ea0ab6d11fbc90f81162e642fe3133.tar.gz
Ensure that AsynchConnector is disassociated from Poller when aborting connection attempt due to a heartbeat timeout
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@953610 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/sys/posix/AsynchIO.cpp')
-rw-r--r--cpp/src/qpid/sys/posix/AsynchIO.cpp6
1 files changed, 6 insertions, 0 deletions
diff --git a/cpp/src/qpid/sys/posix/AsynchIO.cpp b/cpp/src/qpid/sys/posix/AsynchIO.cpp
index cef9f1fcef..7d85b4325b 100644
--- a/cpp/src/qpid/sys/posix/AsynchIO.cpp
+++ b/cpp/src/qpid/sys/posix/AsynchIO.cpp
@@ -157,6 +157,7 @@ public:
ConnectedCallback connCb,
FailedCallback failCb);
void start(Poller::shared_ptr poller);
+ void stop();
};
AsynchConnector::AsynchConnector(const Socket& s,
@@ -183,6 +184,11 @@ void AsynchConnector::start(Poller::shared_ptr poller)
startWatch(poller);
}
+void AsynchConnector::stop()
+{
+ stopWatch();
+}
+
void AsynchConnector::connComplete(DispatchHandle& h)
{
h.stopWatch();