diff options
| author | Andrew Stitcher <astitcher@apache.org> | 2009-05-28 06:13:57 +0000 |
|---|---|---|
| committer | Andrew Stitcher <astitcher@apache.org> | 2009-05-28 06:13:57 +0000 |
| commit | 0a3850a0c401d8d2e988b3fa86996813e788c829 (patch) | |
| tree | 15146716a6569d251cba2c97091ca1f81f5dcc13 /cpp/src/qpid/sys/rdma/RdmaIO.cpp | |
| parent | ce6f7a2cd0a604e12e72e99f017edab9c2f2f24b (diff) | |
| download | qpid-python-0a3850a0c401d8d2e988b3fa86996813e788c829.tar.gz | |
Whitespace fixes
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@779446 13f79535-47bb-0310-9956-ffa450edef68
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, |
