diff options
Diffstat (limited to 'cpp/src/qpid/sys/rdma/RdmaIO.cpp')
| -rw-r--r-- | cpp/src/qpid/sys/rdma/RdmaIO.cpp | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/cpp/src/qpid/sys/rdma/RdmaIO.cpp b/cpp/src/qpid/sys/rdma/RdmaIO.cpp index 77e766dd79..0ca4c5e259 100644 --- a/cpp/src/qpid/sys/rdma/RdmaIO.cpp +++ b/cpp/src/qpid/sys/rdma/RdmaIO.cpp @@ -68,7 +68,7 @@ namespace Rdma { b->dataCount = b->byteCount; qp->postRecv(b); } - + for (int i = 0; i<xmitBufferCount; ++i) { // Allocate xmit buffer Buffer* b = qp->createBuffer(bufferSize); @@ -86,7 +86,7 @@ namespace Rdma { // Turn off callbacks (before doing the deletes) dataHandle.stopWatch(); - + // The buffers ptr_deque automatically deletes all the buffers we've allocated // TODO: It might turn out to be more efficient in high connection loads to reuse the // buffers rather than having to reregister them all the time (this would be straightforward if all @@ -189,7 +189,7 @@ namespace Rdma { if (doReturn) { return; } - + doWriteCallback(); // Keep track of what we need to do so that we can release the lock @@ -317,7 +317,7 @@ namespace Rdma { // disabled by the poller until we leave this code qp->notifyRecv(); qp->notifySend(); - + int recvEvents = 0; int sendEvents = 0; @@ -353,7 +353,7 @@ namespace Rdma { xmitCredit += (e.getImm() & ~FlagsMask); dataPresent = ((e.getImm() & IgnoreData) == 0); } - + // if there was no data sent then the message was only to update our credit if ( dataPresent ) { readCallback(*this, b); @@ -366,7 +366,7 @@ namespace Rdma { // Received another message ++recvCredit; - + // Send recvCredit if it is large enough (it will have got this large because we've not sent anything recently) if (recvCredit > recvBufferCount/2) { // TODO: This should use RDMA write with imm as there might not ever be a buffer to receive this message @@ -377,7 +377,7 @@ namespace Rdma { // Have to send something as adapters hate it when you try to transfer 0 bytes *reinterpret_cast< uint32_t* >(ob->bytes) = htonl(recvCredit); ob->dataCount = sizeof(uint32_t); - + int creditSent = recvCredit & ~FlagsMask; qp->postSend(creditSent | IgnoreData, ob); recvCredit -= creditSent; @@ -426,7 +426,7 @@ namespace Rdma { b->dataStart = 0; return b; } - + void AsynchIO::returnBuffer(Buffer* b) { qpid::sys::ScopedLock<qpid::sys::Mutex> l(bufferQueueLock); bufferQueue.push_front(b); @@ -445,7 +445,7 @@ namespace Rdma { { ci->nonblocking(); } - + void ConnectionManager::start(Poller::shared_ptr poller) { startConnection(ci); handle.startWatch(poller); @@ -454,7 +454,7 @@ namespace Rdma { void ConnectionManager::event(DispatchHandle&) { connectionEvent(ci); } - + Listener::Listener( const sockaddr& src, const ConnectionParams& cp, |
