From 8d4ae932d251fbe3ba7b078eb8c28e466dfcc100 Mon Sep 17 00:00:00 2001
From: Andrew Stitcher <astitcher@apache.org>
Date: Fri, 9 Oct 2009 03:37:54 +0000
Subject: Change TCP AsynchConnector so that it returns all failures
 asynchronously

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@823388 13f79535-47bb-0310-9956-ffa450edef68
---
 qpid/cpp/src/qpid/sys/posix/AsynchIO.cpp | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

(limited to 'qpid/cpp')

diff --git a/qpid/cpp/src/qpid/sys/posix/AsynchIO.cpp b/qpid/cpp/src/qpid/sys/posix/AsynchIO.cpp
index 31011d6f53..b389e6ca61 100644
--- a/qpid/cpp/src/qpid/sys/posix/AsynchIO.cpp
+++ b/qpid/cpp/src/qpid/sys/posix/AsynchIO.cpp
@@ -166,6 +166,7 @@ private:
 private:
     ConnectedCallback connCallback;
     FailedCallback failCallback;
+    std::string errMsg;
     const Socket& socket;
 
 public:
@@ -194,10 +195,14 @@ AsynchConnector::AsynchConnector(const Socket& s,
     socket.setNonblocking();
     try {
         socket.connect(hostname, port);
-        startWatch(poller);
     } catch(std::exception& e) {
-        failure(-1, e.what());
+        // Defer reporting failure
+        startWatch(poller);
+        errMsg = e.what();
+        DispatchHandle::call(boost::bind(&AsynchConnector::failure, this, -1, errMsg));
+        return;
     }
+    startWatch(poller);
 }
 
 void AsynchConnector::connComplete(DispatchHandle& h)
-- 
cgit v1.2.1