diff options
author | Andrew Stitcher <astitcher@apache.org> | 2016-03-16 22:36:28 +0000 |
---|---|---|
committer | Andrew Stitcher <astitcher@apache.org> | 2016-03-16 22:36:28 +0000 |
commit | 8f7b5f1986b8d31cab6e7e2eb53004ce32181287 (patch) | |
tree | 94f74d10ef646e88ebba32c7003c951c83ac7dbc /qpid | |
parent | 9db3c30218c417dc5bfb3b7fbba85643969f3c90 (diff) | |
download | qpid-python-8f7b5f1986b8d31cab6e7e2eb53004ce32181287.tar.gz |
QPID-7146: Fix function binding error
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1735325 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid')
-rw-r--r-- | qpid/cpp/src/qpid/sys/rdma/RdmaClient.cpp | 8 | ||||
-rw-r--r-- | qpid/cpp/src/qpid/sys/rdma/RdmaServer.cpp | 8 |
2 files changed, 8 insertions, 8 deletions
diff --git a/qpid/cpp/src/qpid/sys/rdma/RdmaClient.cpp b/qpid/cpp/src/qpid/sys/rdma/RdmaClient.cpp index 504000af08..9bb82b4f35 100644 --- a/qpid/cpp/src/qpid/sys/rdma/RdmaClient.cpp +++ b/qpid/cpp/src/qpid/sys/rdma/RdmaClient.cpp @@ -160,7 +160,7 @@ void drained(Rdma::AsynchIO&) { cout << "Drained:\n"; } -void connected(Poller::shared_ptr poller, Rdma::Connection::intrusive_ptr& ci, const Rdma::ConnectionParams& cp) { +void connected(Poller::shared_ptr poller, const Rdma::Connection::intrusive_ptr& ci, const Rdma::ConnectionParams& cp) { cout << "Connected\n"; Rdma::QueuePair::intrusive_ptr q = ci->getQueuePair(); @@ -178,17 +178,17 @@ void connected(Poller::shared_ptr poller, Rdma::Connection::intrusive_ptr& ci, c aio->start(poller); } -void disconnected(boost::shared_ptr<Poller> p, Rdma::Connection::intrusive_ptr&) { +void disconnected(boost::shared_ptr<Poller> p, const Rdma::Connection::intrusive_ptr&) { cout << "Disconnected\n"; p->shutdown(); } -void connectionError(boost::shared_ptr<Poller> p, Rdma::Connection::intrusive_ptr&, const Rdma::ErrorType) { +void connectionError(boost::shared_ptr<Poller> p, const Rdma::Connection::intrusive_ptr&, const Rdma::ErrorType) { cout << "Connection error\n"; p->shutdown(); } -void rejected(boost::shared_ptr<Poller> p, Rdma::Connection::intrusive_ptr&, const Rdma::ConnectionParams&) { +void rejected(boost::shared_ptr<Poller> p, const Rdma::Connection::intrusive_ptr&, const Rdma::ConnectionParams&) { cout << "Connection rejected\n"; p->shutdown(); } diff --git a/qpid/cpp/src/qpid/sys/rdma/RdmaServer.cpp b/qpid/cpp/src/qpid/sys/rdma/RdmaServer.cpp index 9b0710fd8f..3764792d48 100644 --- a/qpid/cpp/src/qpid/sys/rdma/RdmaServer.cpp +++ b/qpid/cpp/src/qpid/sys/rdma/RdmaServer.cpp @@ -119,7 +119,7 @@ void drained(Rdma::AsynchIO&) { cout << "Drained:\n"; } -void disconnected(Rdma::Connection::intrusive_ptr& ci) { +void disconnected(const Rdma::Connection::intrusive_ptr& ci) { ConRec* cr = ci->getContext<ConRec>(); cr->connection->disconnect(); cr->data->drainWriteQueue(drained); @@ -127,7 +127,7 @@ void disconnected(Rdma::Connection::intrusive_ptr& ci) { cout << "Disconnected: " << cr << "\n"; } -void connectionError(Rdma::Connection::intrusive_ptr& ci, Rdma::ErrorType) { +void connectionError(const Rdma::Connection::intrusive_ptr& ci, Rdma::ErrorType) { ConRec* cr = ci->getContext<ConRec>(); cr->connection->disconnect(); if (cr) { @@ -137,7 +137,7 @@ void connectionError(Rdma::Connection::intrusive_ptr& ci, Rdma::ErrorType) { cout << "Connection error: " << cr << "\n"; } -bool connectionRequest(Rdma::Connection::intrusive_ptr& ci, const Rdma::ConnectionParams& cp) { +bool connectionRequest(const Rdma::Connection::intrusive_ptr& ci, const Rdma::ConnectionParams& cp) { cout << "Incoming connection: "; // For fun reject alternate connection attempts @@ -165,7 +165,7 @@ bool connectionRequest(Rdma::Connection::intrusive_ptr& ci, const Rdma::Connect return x; } -void connected(Poller::shared_ptr poller, Rdma::Connection::intrusive_ptr& ci) { +void connected(Poller::shared_ptr poller, const Rdma::Connection::intrusive_ptr& ci) { static int cnt = 0; ConRec* cr = ci->getContext<ConRec>(); cout << "Connected: " << cr << "(" << ++cnt << ")\n"; |