diff options
| author | Benety Goh <benety@mongodb.com> | 2016-10-28 20:30:54 -0400 |
|---|---|---|
| committer | Benety Goh <benety@mongodb.com> | 2016-11-02 18:45:41 -0400 |
| commit | cbb4f8ef9028461b682bd4aea5097a95f8cfe631 (patch) | |
| tree | 33d9a5aeae6f07f3ab2354adae6306bddc33af9c /src/mongo/db/repl/oplogreader.h | |
| parent | f0ada5e29eb5218c257897bfd1a8fb1e36e06733 (diff) | |
| download | mongo-cbb4f8ef9028461b682bd4aea5097a95f8cfe631.tar.gz | |
SERVER-25145 OplogReader::connectToSyncSource selects sync sources based on min valid if given
Diffstat (limited to 'src/mongo/db/repl/oplogreader.h')
| -rw-r--r-- | src/mongo/db/repl/oplogreader.h | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mongo/db/repl/oplogreader.h b/src/mongo/db/repl/oplogreader.h index 65e101415a0..1434125697a 100644 --- a/src/mongo/db/repl/oplogreader.h +++ b/src/mongo/db/repl/oplogreader.h @@ -157,7 +157,14 @@ public: */ void connectToSyncSource(OperationContext* txn, const OpTime& lastOpTimeFetched, + const OpTime& requiredOpTime, ReplicationCoordinator* replCoord); + +private: + /** + * Checks query response for required optime. + */ + Status _compareRequiredOpTimeWithQueryResponse(const OpTime& requiredOpTime); }; } // namespace repl |