diff options
| author | Geert Bosch <geert@mongodb.com> | 2017-09-07 13:33:32 -0400 |
|---|---|---|
| committer | Geert Bosch <geert@mongodb.com> | 2017-10-10 09:00:15 -0400 |
| commit | ec5486e08cef499d894babaa2be7e4260bb601bb (patch) | |
| tree | 2792a1fa8e8611fb29c7f841649ed1c7f79b99ba | |
| parent | 1b3b9fdec94021c36def1c9d021c4104b3677aa4 (diff) | |
| download | mongo-ec5486e08cef499d894babaa2be7e4260bb601bb.tar.gz | |
SERVER-30927 Use readConcern afterOpTime for initsync oplog queries
(cherry picked from commit f9438895085bf788a7d7276221b5efd865391df7)
Conflicts:
src/mongo/db/repl/oplog_fetcher.cpp
| -rw-r--r-- | src/mongo/db/repl/oplog_fetcher.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/mongo/db/repl/oplog_fetcher.cpp b/src/mongo/db/repl/oplog_fetcher.cpp index ece0ef266fd..05890b07985 100644 --- a/src/mongo/db/repl/oplog_fetcher.cpp +++ b/src/mongo/db/repl/oplog_fetcher.cpp @@ -102,6 +102,10 @@ BSONObj makeFindCommandObject(const NamespaceString& nss, if (currentTerm != OpTime::kUninitializedTerm) { cmdBob.append("term", currentTerm); } + if (serverGlobalParams.featureCompatibility.version.load() == + ServerGlobalParams::FeatureCompatibility::Version::k34) { + cmdBob.append("readConcern", BSON("afterOpTime" << lastOpTimeFetched.toBSON())); + } return cmdBob.obj(); } |