diff options
Diffstat (limited to 'cpp/src/Ice/RetryQueue.cpp')
-rw-r--r-- | cpp/src/Ice/RetryQueue.cpp | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/cpp/src/Ice/RetryQueue.cpp b/cpp/src/Ice/RetryQueue.cpp index 8f9694416fd..b52a6b59fc9 100644 --- a/cpp/src/Ice/RetryQueue.cpp +++ b/cpp/src/Ice/RetryQueue.cpp @@ -144,11 +144,14 @@ IceInternal::RetryQueue::cancel(const RetryTaskPtr& task) Lock sync(*this); if(_requests.erase(task) > 0) { - if(!_instance && _requests.empty()) + if(_instance) + { + return _instance->timer()->cancel(task); + } + else if(_requests.empty()) { notify(); // If we are destroying the queue, destroy is probably waiting on the queue to be empty. } - return _instance->timer()->cancel(task); } return false; } |