Merge branch 'watson'
[ep-engine.git] / src / dcp / producer.cc
index 84e279b..7159dd3 100644 (file)
@@ -242,7 +242,7 @@ ENGINE_ERROR_CODE DcpProducer::streamRequest(uint32_t flags,
             logHeader(), vbucket, vb->toString(vb->getState()));
         return ENGINE_NOT_MY_VBUCKET;
     }
-    if (vb->isBackfillPhase()) {
+    if (vb->checkpointManager.getOpenCheckpointId() == 0) {
         LOG(EXTENSION_LOG_WARNING, "%s (vb %d) Stream request failed because "
             "this vbucket is in backfill state", logHeader(), vbucket);
         return ENGINE_TMPFAIL;