summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_coordinator_impl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/replication_coordinator_impl.cpp')
-rw-r--r--src/mongo/db/repl/replication_coordinator_impl.cpp6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_impl.cpp b/src/mongo/db/repl/replication_coordinator_impl.cpp
index 564744ca4dd..8db38fa5803 100644
--- a/src/mongo/db/repl/replication_coordinator_impl.cpp
+++ b/src/mongo/db/repl/replication_coordinator_impl.cpp
@@ -1413,8 +1413,12 @@ OpTime ReplicationCoordinatorImpl::getMyLastAppliedOpTime() const {
return _getMyLastAppliedOpTime_inlock();
}
-OpTimeAndWallTime ReplicationCoordinatorImpl::getMyLastAppliedOpTimeAndWallTime() const {
+OpTimeAndWallTime ReplicationCoordinatorImpl::getMyLastAppliedOpTimeAndWallTime(
+ bool rollbackSafe) const {
stdx::lock_guard<Latch> lock(_mutex);
+ if (rollbackSafe && _getMemberState_inlock().rollback()) {
+ return {};
+ }
return _getMyLastAppliedOpTimeAndWallTime_inlock();
}