summaryrefslogtreecommitdiff
path: root/qpid
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2016-03-16 22:36:28 +0000
committerAndrew Stitcher <astitcher@apache.org>2016-03-16 22:36:28 +0000
commit8f7b5f1986b8d31cab6e7e2eb53004ce32181287 (patch)
tree94f74d10ef646e88ebba32c7003c951c83ac7dbc /qpid
parent9db3c30218c417dc5bfb3b7fbba85643969f3c90 (diff)
downloadqpid-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.cpp8
-rw-r--r--qpid/cpp/src/qpid/sys/rdma/RdmaServer.cpp8
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";