diff options
| author | Xuerui Fa <xuerui.fa@mongodb.com> | 2020-03-31 16:06:31 -0400 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-04-16 17:31:01 +0000 |
| commit | 405ee7a9a39f6dc3893e4e5039e2971e14d8c8d5 (patch) | |
| tree | 23e8028fd50750ffa2fba027e805ea2d6ada01de /src/mongo/db/repl/bgsync.cpp | |
| parent | 27c9e2a978009f6fb3d23d0327e2126bb6e662d6 (diff) | |
| download | mongo-405ee7a9a39f6dc3893e4e5039e2971e14d8c8d5.tar.gz | |
SERVER-31429: Use last fetched instead of last applied OpTime to eval sync sources
Diffstat (limited to 'src/mongo/db/repl/bgsync.cpp')
| -rw-r--r-- | src/mongo/db/repl/bgsync.cpp | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/mongo/db/repl/bgsync.cpp b/src/mongo/db/repl/bgsync.cpp index eed57307446..39e31ff0d83 100644 --- a/src/mongo/db/repl/bgsync.cpp +++ b/src/mongo/db/repl/bgsync.cpp @@ -111,7 +111,8 @@ public: BackgroundSync* bgsync); bool shouldStopFetching(const HostAndPort& source, const rpc::ReplSetMetadata& replMetadata, - const rpc::OplogQueryMetadata& oqMetadata) override; + const rpc::OplogQueryMetadata& oqMetadata, + const OpTime& lastOpTimeFetched) override; private: BackgroundSync* _bgsync; @@ -127,12 +128,14 @@ DataReplicatorExternalStateBackgroundSync::DataReplicatorExternalStateBackground bool DataReplicatorExternalStateBackgroundSync::shouldStopFetching( const HostAndPort& source, const rpc::ReplSetMetadata& replMetadata, - const rpc::OplogQueryMetadata& oqMetadata) { + const rpc::OplogQueryMetadata& oqMetadata, + const OpTime& lastOpTimeFetched) { if (_bgsync->shouldStopFetching()) { return true; } - return DataReplicatorExternalStateImpl::shouldStopFetching(source, replMetadata, oqMetadata); + return DataReplicatorExternalStateImpl::shouldStopFetching( + source, replMetadata, oqMetadata, lastOpTimeFetched); } size_t getSize(const BSONObj& o) { |