Added asserts to ensure that we catch it if xmitCredit isn't sane

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@954494 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 7 insertions, 0 deletions

diff --git a/cpp/src/qpid/sys/rdma/RdmaIO.cpp b/cpp/src/qpid/sys/rdma/RdmaIO.cpp
index bd0005dbe3..45295d470c 100644
--- a/cpp/src/qpid/sys/rdma/RdmaIO.cpp
+++ b/cpp/src/qpid/sys/rdma/RdmaIO.cpp
@@ -171,6 +171,7 @@ namespace Rdma {
             }
             ++outstandingWrites;
             --xmitCredit;
+            assert(xmitCredit>=0);
         } else {
             if (fullCallback) {
                 fullCallback(*this, buff);
@@ -397,8 +398,10 @@ namespace Rdma {
                 // Get our xmitCredit if it was sent
                 bool dataPresent = true;
                 if (e.immPresent() ) {
+                    assert(xmitCredit>=0);
                     xmitCredit += (e.getImm() & ~FlagsMask);
                     dataPresent = ((e.getImm() & IgnoreData) == 0);
+                    assert(xmitCredit>0);
                 }
 
                 // if there was no data sent then the message was only to update our credit
@@ -430,6 +433,7 @@ namespace Rdma {
                         recvCredit -= creditSent;
                         ++outstandingWrites;
                         --xmitCredit;
+                        assert(xmitCredit>=0);
                     } else {
                         QPID_LOG(warning, "RDMA: qp=" << qp << ":  Unable to send unsolicited credit");
                     }
@@ -453,6 +457,9 @@ namespace Rdma {
     void AsynchIO::doWriteCallback() {
         // TODO: maybe don't call idle unless we're low on write buffers
         // Keep on calling the idle routine as long as we are writable and we got something to write last call
+
+        // Do callback even if there are no available free buffers as the application itself might be
+        // holding onto buffers
         while (writable()) {
             int xc = xmitCredit;
             idleCallback(*this);