Avoid Rdma::AsynchIO leaking when stopped without being drained and

add in asserts to be sure that you call stopped and drained callbacks
in the correct state

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

1 files changed, 3 insertions, 1 deletions

diff --git a/qpid/cpp/src/qpid/sys/rdma/RdmaIO.cpp b/qpid/cpp/src/qpid/sys/rdma/RdmaIO.cpp
index 3e0f1c1dad..068e8cf187 100644
--- a/qpid/cpp/src/qpid/sys/rdma/RdmaIO.cpp
+++ b/qpid/cpp/src/qpid/sys/rdma/RdmaIO.cpp
@@ -452,7 +452,7 @@ namespace Rdma {
         }
 
         // We might need to delete ourselves
-        if (notifyCallback && outstandingWrites == 0) {
+        if (notifyCallback) {
             doStoppedCallback();
         }
     }
@@ -464,6 +464,7 @@ namespace Rdma {
         State oldState;
         do {
             oldState = state.get();
+            assert(oldState==IDLE);
         } while (!state.boolCompareAndSwap(oldState, DRAINED));
         nc(*this);
     }
@@ -475,6 +476,7 @@ namespace Rdma {
         State oldState;
         do {
             oldState = state.get();
+            assert(oldState==IDLE);
         } while (!state.boolCompareAndSwap(oldState, SHUTDOWN));
         nc(*this);
     }