summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/sys/rdma/RdmaIO.cpp
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2010-12-23 17:11:57 +0000
committerAndrew Stitcher <astitcher@apache.org>2010-12-23 17:11:57 +0000
commitc3d6047e94210bd35f7c35b9bba0bc2e60841fa7 (patch)
tree6e6ab77a94534863b37069f7b48c82b2bd411f51 /cpp/src/qpid/sys/rdma/RdmaIO.cpp
parentff152807775cf3ad146742a59bbe44146cbb9a34 (diff)
downloadqpid-python-c3d6047e94210bd35f7c35b9bba0bc2e60841fa7.tar.gz
Rename Rdma send buffer operations.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1052331 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/sys/rdma/RdmaIO.cpp')
-rw-r--r--cpp/src/qpid/sys/rdma/RdmaIO.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/cpp/src/qpid/sys/rdma/RdmaIO.cpp b/cpp/src/qpid/sys/rdma/RdmaIO.cpp
index 74ceceffad..c80c94cba6 100644
--- a/cpp/src/qpid/sys/rdma/RdmaIO.cpp
+++ b/cpp/src/qpid/sys/rdma/RdmaIO.cpp
@@ -198,7 +198,7 @@ namespace Rdma {
switch (protocolVersion) {
case 0:
if (!buff) {
- Buffer* ob = getBuffer();
+ Buffer* ob = getSendBuffer();
// Have to send something as adapters hate it when you try to transfer 0 bytes
*reinterpret_cast< uint32_t* >(ob->bytes()) = htonl(credit);
ob->dataCount(sizeof(uint32_t));
@@ -210,7 +210,7 @@ namespace Rdma {
}
break;
case 1:
- Buffer* ob = buff ? buff : getBuffer();
+ Buffer* ob = buff ? buff : getSendBuffer();
// Add FrameHeader after frame data
FrameHeader header(credit);
::memcpy(ob->bytes()+ob->dataCount(), &header, FrameHeaderSize);
@@ -266,7 +266,7 @@ namespace Rdma {
fullCallback(*this, buff);
} else {
QPID_LOG(error, "RDMA: qp=" << qp << ": Write queue full, but no callback, throwing buffer away");
- returnBuffer(buff);
+ returnSendBuffer(buff);
}
}
}
@@ -375,7 +375,7 @@ namespace Rdma {
if (dir == SEND) {
Buffer* b = e.getBuffer();
++sendEvents;
- returnBuffer(b);
+ returnSendBuffer(b);
--outstandingWrites;
} else {
++recvEvents;
@@ -426,7 +426,7 @@ namespace Rdma {
} else {
Buffer* b = e.getBuffer();
++sendEvents;
- returnBuffer(b);
+ returnSendBuffer(b);
--outstandingWrites;
}
} while (true);