diff options
| author | Kevin Pulo <kevin.pulo@mongodb.com> | 2020-01-28 05:54:11 +0000 |
|---|---|---|
| committer | evergreen <evergreen@mongodb.com> | 2020-01-28 05:54:11 +0000 |
| commit | 823a131ca93354c42b767767269f5a9e70691e78 (patch) | |
| tree | 512664d00481301efdfd5f201752804a9bccf174 /src/mongo/db/repl/sync_source_resolver.cpp | |
| parent | 806bdd4c59adf3e9f9167e60bf6c48769310ad83 (diff) | |
| download | mongo-823a131ca93354c42b767767269f5a9e70691e78.tar.gz | |
SERVER-45692 make SyncSourceResolver pass readConcern local when querying remote oplogs
Diffstat (limited to 'src/mongo/db/repl/sync_source_resolver.cpp')
| -rw-r--r-- | src/mongo/db/repl/sync_source_resolver.cpp | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/src/mongo/db/repl/sync_source_resolver.cpp b/src/mongo/db/repl/sync_source_resolver.cpp index 0b371f9359d..a6c87de8731 100644 --- a/src/mongo/db/repl/sync_source_resolver.cpp +++ b/src/mongo/db/repl/sync_source_resolver.cpp @@ -172,7 +172,10 @@ std::unique_ptr<Fetcher> SyncSourceResolver::_makeFirstOplogEntryFetcher( BSON("find" << kLocalOplogNss.coll() << "limit" << 1 << "sort" << BSON("$natural" << 1) << "projection" << BSON(OplogEntryBase::kTimestampFieldName - << 1 << OplogEntryBase::kTermFieldName << 1)), + << 1 << OplogEntryBase::kTermFieldName << 1) + << "readConcern" + << BSON("level" + << "local")), [=](const StatusWith<Fetcher::QueryResponse>& response, Fetcher::NextAction*, BSONObjBuilder*) { @@ -194,7 +197,10 @@ std::unique_ptr<Fetcher> SyncSourceResolver::_makeRequiredOpTimeFetcher(HostAndP kLocalOplogNss.db().toString(), BSON("find" << kLocalOplogNss.coll() << "oplogReplay" << true << "filter" << BSON("ts" << BSON("$gte" << _requiredOpTime.getTimestamp() << "$lte" - << _requiredOpTime.getTimestamp()))), + << _requiredOpTime.getTimestamp())) + << "readConcern" + << BSON("level" + << "local")), [=](const StatusWith<Fetcher::QueryResponse>& response, Fetcher::NextAction*, BSONObjBuilder*) { |