summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2010-01-26 20:45:03 +0000
committerAndrew Stitcher <astitcher@apache.org>2010-01-26 20:45:03 +0000
commit832887152f0cfbb0ff1d9ca3d3c5624818ecc87d (patch)
tree70f94276df7fb709018d809bdf0f9f597f549d65 /cpp/src/qpid/client
parentfaeceaf81e73b23260d32503bc09e87f6ed2e735 (diff)
downloadqpid-python-832887152f0cfbb0ff1d9ca3d3c5624818ecc87d.tar.gz
Fix memory error in previous SocketAddress refactoring
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903407 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client')
-rw-r--r--cpp/src/qpid/client/RdmaConnector.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/qpid/client/RdmaConnector.cpp b/cpp/src/qpid/client/RdmaConnector.cpp
index d67a0fcb2e..fbf4e02f69 100644
--- a/cpp/src/qpid/client/RdmaConnector.cpp
+++ b/cpp/src/qpid/client/RdmaConnector.cpp
@@ -49,7 +49,7 @@ using namespace qpid::framing;
using boost::format;
using boost::str;
- class RdmaConnector : public Connector, public sys::Codec
+class RdmaConnector : public Connector, public sys::Codec
{
struct Buff;
@@ -164,17 +164,17 @@ void RdmaConnector::connect(const std::string& host, int port){
Mutex::ScopedLock l(pollingLock);
assert(!polling);
- SocketAddress sa(host, boost::lexical_cast<std::string>(port));
Rdma::Connector* c = new Rdma::Connector(
- sa,
Rdma::ConnectionParams(maxFrameSize, Rdma::DEFAULT_WR_ENTRIES),
boost::bind(&RdmaConnector::connected, this, poller, _1, _2),
boost::bind(&RdmaConnector::connectionError, this, poller, _1, _2),
boost::bind(&RdmaConnector::disconnected, this, poller, _1),
boost::bind(&RdmaConnector::rejected, this, poller, _1, _2));
+
polling = true;
- c->start(poller);
+ SocketAddress sa(host, boost::lexical_cast<std::string>(port));
+ c->start(poller, sa);
}
// The following only gets run when connected