diff options
Diffstat (limited to 'src/mongo/db/repl/opqueue_batcher.cpp')
-rw-r--r-- | src/mongo/db/repl/opqueue_batcher.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/mongo/db/repl/opqueue_batcher.cpp b/src/mongo/db/repl/opqueue_batcher.cpp index c0f9e604393..a7b41404193 100644 --- a/src/mongo/db/repl/opqueue_batcher.cpp +++ b/src/mongo/db/repl/opqueue_batcher.cpp @@ -154,7 +154,7 @@ void OpQueueBatcher::run() { // Draining state guarantees the producer has already been fully stopped and no more // operations will be pushed in to the oplog buffer until the applier state changes. auto isDraining = - _oplogApplier->getApplierState() == OplogApplier::ApplierState::Draining; + replCoord->getApplierState() == ReplicationCoordinator::ApplierState::Draining; // Check the oplog buffer after the applier state to ensure the producer is stopped. if (isDraining && _oplogBuffer->isEmpty()) { ops.setTermWhenExhausted(termWhenBufferIsEmpty); |