From 564d179640cf49feeb8ff84133f892499afb0e65 Mon Sep 17 00:00:00 2001 From: Andrew Stitcher Date: Mon, 4 May 2009 15:55:21 +0000 Subject: Refactored the DispatchHandle/Poller code to remove a long standing set of race conditions. - Changed Poller naming for better clarity with new semantics. - Changed Poller semantics to avoid DispatchHandle keeping so much state - Changed Poller so that it will never re-enable a Handle until Poller::wait is called again on the same thread that returned the Handle. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@771338 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/sys/posix/AsynchIO.cpp | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'cpp/src/qpid/sys/posix/AsynchIO.cpp') diff --git a/cpp/src/qpid/sys/posix/AsynchIO.cpp b/cpp/src/qpid/sys/posix/AsynchIO.cpp index a914dc817a..ecfed6b42a 100644 --- a/cpp/src/qpid/sys/posix/AsynchIO.cpp +++ b/cpp/src/qpid/sys/posix/AsynchIO.cpp @@ -75,6 +75,7 @@ namespace sys { class AsynchAcceptorPrivate { public: AsynchAcceptorPrivate(const Socket& s, AsynchAcceptor::Callback callback); + ~AsynchAcceptorPrivate(); void start(Poller::shared_ptr poller); private: @@ -109,6 +110,10 @@ AsynchAcceptorPrivate::AsynchAcceptorPrivate(const Socket& s, s.setNonblocking(); } +AsynchAcceptorPrivate::~AsynchAcceptorPrivate() { + handle.stopWatch(); +} + void AsynchAcceptorPrivate::start(Poller::shared_ptr poller) { handle.startWatch(poller); } -- cgit v1.2.1