diff options
| author | Andrew Stitcher <astitcher@apache.org> | 2010-09-08 16:49:26 +0000 |
|---|---|---|
| committer | Andrew Stitcher <astitcher@apache.org> | 2010-09-08 16:49:26 +0000 |
| commit | 518596d72441fb1ed8a04717e378a9296d8bdc76 (patch) | |
| tree | f2e88365168aed85f15cbe281ea398f26d03f0fe /cpp/src | |
| parent | 97b75790dfa2e7ec95927159c89914879970bc46 (diff) | |
| download | qpid-python-518596d72441fb1ed8a04717e378a9296d8bdc76.tar.gz | |
Trivial comment fix
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995138 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
| -rw-r--r-- | cpp/src/qpid/client/RdmaConnector.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/cpp/src/qpid/client/RdmaConnector.cpp b/cpp/src/qpid/client/RdmaConnector.cpp index 83a7191286..e5be1f8fbf 100644 --- a/cpp/src/qpid/client/RdmaConnector.cpp +++ b/cpp/src/qpid/client/RdmaConnector.cpp @@ -210,7 +210,7 @@ void RdmaConnector::connected(Poller::shared_ptr poller, Rdma::Connection::intru } { Mutex::ScopedLock l(pollingLock); - // If we're closed already then we'll get to drain() anyway + // If we're closed already then we'll get to stopped() anyway if (!polling) return; polling = false; } @@ -221,7 +221,7 @@ void RdmaConnector::connectionError(sys::Poller::shared_ptr, Rdma::Connection::i QPID_LOG(debug, "Connection Error " << identifier); { Mutex::ScopedLock l(pollingLock); - // If we're closed already then we'll get to drain() anyway + // If we're closed already then we'll get to stopped() anyway if (!polling) return; polling = false; } @@ -232,7 +232,7 @@ void RdmaConnector::disconnected(sys::Poller::shared_ptr, Rdma::Connection::intr QPID_LOG(debug, "Connection disconnected " << identifier); { Mutex::ScopedLock l(pollingLock); - // If we're closed already then we'll get to drain() anyway + // If we're closed already then we'll get to drained() anyway if (!polling) return; polling = false; } @@ -243,7 +243,7 @@ void RdmaConnector::rejected(sys::Poller::shared_ptr, Rdma::Connection::intrusiv QPID_LOG(debug, "Connection Rejected " << identifier << ": " << cp.maxRecvBufferSize); { Mutex::ScopedLock l(pollingLock); - // If we're closed already then we'll get to drain() anyway + // If we're closed already then we'll get to stopped() anyway if (!polling) return; polling = false; } @@ -254,7 +254,7 @@ void RdmaConnector::dataError(Rdma::AsynchIO&) { QPID_LOG(debug, "Data Error " << identifier); { Mutex::ScopedLock l(pollingLock); - // If we're closed already then we'll get to drain() anyway + // If we're closed already then we'll get to drained() anyway if (!polling) return; polling = false; } |