diff --git a/src/ca/tcpiiu.cpp b/src/ca/tcpiiu.cpp index 6ba03a751..e96dbd38e 100644 --- a/src/ca/tcpiiu.cpp +++ b/src/ca/tcpiiu.cpp @@ -1694,7 +1694,7 @@ void tcpiiu::decrementBlockingForFlushCount ( guard.assertIdenticalMutex ( this->mutex ); assert ( this->blockingForFlush > 0u ); this->blockingForFlush--; - if ( this->blockingForFlush == 0 ) { + if ( this->blockingForFlush > 0 ) { this->flushBlockEvent.signal (); } }