summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/sys/rdma/rdma_wrap.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/sys/rdma/rdma_wrap.cpp')
-rw-r--r--cpp/src/qpid/sys/rdma/rdma_wrap.cpp6
1 files changed, 5 insertions, 1 deletions
diff --git a/cpp/src/qpid/sys/rdma/rdma_wrap.cpp b/cpp/src/qpid/sys/rdma/rdma_wrap.cpp
index 2581aaedcb..b046b012db 100644
--- a/cpp/src/qpid/sys/rdma/rdma_wrap.cpp
+++ b/cpp/src/qpid/sys/rdma/rdma_wrap.cpp
@@ -154,11 +154,15 @@ namespace Rdma {
// Reset back pointer in case someone else has the qp
qp->qp_context = 0;
+
+ // The buffers ptr_deque automatically deletes all the buffers we've allocated
}
// Create a buffer to use for writing
Buffer* QueuePair::createBuffer(int s) {
- return new Buffer(pd.get(), s);
+ Buffer* b = new Buffer(pd.get(), s);
+ buffers.push_front(b);
+ return b;
}
// Make channel non-blocking by making