unpauseIfSpace --> unpauseIfSpaceAvailable
Change-Id: Ifb4ec181e2228d819ab460bd03eccfefd75c48d6
Reviewed-on: http://review.couchbase.org/57872
Tested-by: buildbot <build@couchbase.com>
Reviewed-by: Chiyoung Seo <chiyoung@couchbase.com>
return false;
}
-void DcpProducer::BufferLog::unpauseIfSpace() {
+void DcpProducer::BufferLog::unpauseIfSpaceAvailable() {
ReaderLockHolder rlh(logLock);
if (getState_UNLOCKED() != Full) {
producer.notifyPaused(true);
void DcpProducer::notifyStreamReady(uint16_t vbucket, bool schedule) {
bool expected = false;
if (vbReady[vbucket].compare_exchange_strong(expected, true)) {
- log.unpauseIfSpace();
+ log.unpauseIfSpaceAvailable();
}
}
/*
Unpause the producer if there's space (or disabled).
*/
- void unpauseIfSpace();
+ void unpauseIfSpaceAvailable();
private: