diff options
| author | Kevin Pulo <kevin.pulo@mongodb.com> | 2020-02-20 21:42:07 +1100 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-03-05 13:03:43 +0000 |
| commit | 747ff353cbc819d032fa727d4bd7ffad16ea0437 (patch) | |
| tree | d9b3d7e9af26138d7b74e0416a93d6110e326af0 /src/mongo/db/repl/oplog_interface_remote.cpp | |
| parent | 7c4b875a8858c5bd5efc9bf4f285f7f440fdfdc0 (diff) | |
| download | mongo-747ff353cbc819d032fa727d4bd7ffad16ea0437.tar.gz | |
SERVER-45692 add explicit RWC to inter-node commands (even if merely kImplicitDefault)
Diffstat (limited to 'src/mongo/db/repl/oplog_interface_remote.cpp')
| -rw-r--r-- | src/mongo/db/repl/oplog_interface_remote.cpp | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/src/mongo/db/repl/oplog_interface_remote.cpp b/src/mongo/db/repl/oplog_interface_remote.cpp index a71aae7cb15..883596318b9 100644 --- a/src/mongo/db/repl/oplog_interface_remote.cpp +++ b/src/mongo/db/repl/oplog_interface_remote.cpp @@ -34,6 +34,7 @@ #include "mongo/client/dbclient_base.h" #include "mongo/client/dbclient_cursor.h" #include "mongo/db/jsobj.h" +#include "mongo/db/repl/read_concern_args.h" #include "mongo/util/str.h" namespace mongo { @@ -83,8 +84,14 @@ std::unique_ptr<OplogInterface::Iterator> OplogInterfaceRemote::makeIterator() c const Query query = Query().sort(BSON("$natural" << -1)); const BSONObj fields = BSON("ts" << 1 << "t" << 1); return std::unique_ptr<OplogInterface::Iterator>( - new OplogIteratorRemote(_getConnection()->query( - NamespaceString(_collectionName), query, 0, 0, &fields, 0, _batchSize))); + new OplogIteratorRemote(_getConnection()->query(NamespaceString(_collectionName), + query, + 0, + 0, + &fields, + 0, + _batchSize, + ReadConcernArgs::kImplicitDefault))); } std::unique_ptr<TransactionHistoryIteratorBase> |