From 0a3850a0c401d8d2e988b3fa86996813e788c829 Mon Sep 17 00:00:00 2001
From: Andrew Stitcher <astitcher@apache.org>
Date: Thu, 28 May 2009 06:13:57 +0000
Subject: Whitespace fixes

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@779446 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/sys/rdma/RdmaIO.cpp | 20 ++++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

(limited to 'cpp/src/qpid/sys/rdma/RdmaIO.cpp')

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,
-- 
cgit v1.2.1