diff options
| author | Scott Hernandez <scotthernandez@gmail.com> | 2015-09-23 22:36:21 -0400 |
|---|---|---|
| committer | Scott Hernandez <scotthernandez@gmail.com> | 2015-09-25 17:30:33 -0400 |
| commit | 18de2f3d6bb4c01fb600bbb0e3a2c2e4ab0cc9ee (patch) | |
| tree | 746011a289a10486090780e3ca0810919bbeba5b /src/mongo/db/repl/oplogreader.cpp | |
| parent | 4980f0d20ed494da2862c337cd2dc1fc7a5dd422 (diff) | |
| download | mongo-18de2f3d6bb4c01fb600bbb0e3a2c2e4ab0cc9ee.tar.gz | |
SERVER-20326: record apply batch boundaries
Diffstat (limited to 'src/mongo/db/repl/oplogreader.cpp')
| -rw-r--r-- | src/mongo/db/repl/oplogreader.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/mongo/db/repl/oplogreader.cpp b/src/mongo/db/repl/oplogreader.cpp index ecda101a91f..4ba200694a6 100644 --- a/src/mongo/db/repl/oplogreader.cpp +++ b/src/mongo/db/repl/oplogreader.cpp @@ -165,7 +165,7 @@ void OplogReader::connectToSyncSource(OperationContext* txn, log() << "our last optime : " << lastOpTimeFetched; log() << "oldest available is " << oldestOpTimeSeen; log() << "See http://dochub.mongodb.org/core/resyncingaverystalereplicasetmember"; - setMinValid(txn, oldestOpTimeSeen); + setMinValid(txn, {lastOpTimeFetched, oldestOpTimeSeen}); bool worked = replCoord->setFollowerMode(MemberState::RS_RECOVERING); if (!worked) { warning() << "Failed to transition into " << MemberState(MemberState::RS_RECOVERING) |