summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/oplog_applier_impl.cpp
diff options
context:
space:
mode:
authorMatthew Russotto <matthew.russotto@mongodb.com>2022-05-31 09:46:33 -0400
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-06-01 21:20:13 +0000
commit7aeab9f7830c47e8b8e3633da35c36d8cfe5a878 (patch)
treec1ce2f5fd76a825c17ca0ea3a217a3a2d4cfb94d /src/mongo/db/repl/oplog_applier_impl.cpp
parent05d91d94697112517e8120e95294212a9e4af2ae (diff)
downloadmongo-7aeab9f7830c47e8b8e3633da35c36d8cfe5a878.tar.gz
SERVER-65657 Reduce calls to the cappedInsertNotifier for the oplog
Diffstat (limited to 'src/mongo/db/repl/oplog_applier_impl.cpp')
-rw-r--r--src/mongo/db/repl/oplog_applier_impl.cpp3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/mongo/db/repl/oplog_applier_impl.cpp b/src/mongo/db/repl/oplog_applier_impl.cpp
index 2e15cf08c73..e9ca22da35c 100644
--- a/src/mongo/db/repl/oplog_applier_impl.cpp
+++ b/src/mongo/db/repl/oplog_applier_impl.cpp
@@ -148,6 +148,9 @@ protected:
// We have to use setMyLastAppliedOpTimeAndWallTimeForward since this thread races with
// ReplicationExternalStateImpl::onTransitionToPrimary.
_replCoord->setMyLastAppliedOpTimeAndWallTimeForward(newOpTimeAndWallTime);
+ // We know we're at a no-holes point and we've already advanced visibility; we need
+ // to notify waiters since we changed the lastAppliedSnapshot.
+ signalOplogWaiters();
}
void _recordDurable(const OpTimeAndWallTime& newOpTimeAndWallTime) {