summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/sys/RdmaIOPlugin.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/sys/RdmaIOPlugin.cpp')
-rw-r--r--cpp/src/qpid/sys/RdmaIOPlugin.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/sys/RdmaIOPlugin.cpp b/cpp/src/qpid/sys/RdmaIOPlugin.cpp
index c2ea815d31..9eb2eb7b5d 100644
--- a/cpp/src/qpid/sys/RdmaIOPlugin.cpp
+++ b/cpp/src/qpid/sys/RdmaIOPlugin.cpp
@@ -116,7 +116,7 @@ void RdmaIOHandler::start(Poller::shared_ptr poller) {
void RdmaIOHandler::write(const framing::ProtocolInitiation& data)
{
QPID_LOG(debug, "Rdma: SENT [" << identifier << "] INIT(" << data << ")");
- Rdma::Buffer* buff = aio->getBuffer();
+ Rdma::Buffer* buff = aio->getSendBuffer();
assert(buff);
framing::Buffer out(buff->bytes(), buff->byteCount());
data.encode(out);
@@ -146,7 +146,7 @@ void RdmaIOHandler::idle(Rdma::AsynchIO&) {
if (!codec->canEncode()) {
return;
}
- Rdma::Buffer* buff = aio->getBuffer();
+ Rdma::Buffer* buff = aio->getSendBuffer();
if (buff) {
size_t encoded=codec->encode(buff->bytes(), buff->byteCount());
buff->dataCount(encoded);