diff options
Diffstat (limited to 'src/mongo/db/repl/tenant_oplog_applier.cpp')
| -rw-r--r-- | src/mongo/db/repl/tenant_oplog_applier.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/mongo/db/repl/tenant_oplog_applier.cpp b/src/mongo/db/repl/tenant_oplog_applier.cpp index cab5881cfdf..72c5294867f 100644 --- a/src/mongo/db/repl/tenant_oplog_applier.cpp +++ b/src/mongo/db/repl/tenant_oplog_applier.cpp @@ -93,7 +93,8 @@ SemiFuture<TenantOplogApplier::OpTimePair> TenantOplogApplier::getNotificationFo return SemiFuture<OpTimePair>::makeReady(_finalStatus); } // If this optime has already passed, just return a ready future. - if (_lastBatchCompletedOpTimes.donorOpTime >= donorOpTime) { + if (_lastBatchCompletedOpTimes.donorOpTime >= donorOpTime || + _beginApplyingAfterOpTime >= donorOpTime) { return SemiFuture<OpTimePair>::makeReady(_lastBatchCompletedOpTimes); } |