diff options
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 a4943f3f8a4..1874e73474b 100644 --- a/src/mongo/db/repl/bgsync.cpp +++ b/src/mongo/db/repl/bgsync.cpp @@ -80,7 +80,8 @@ public: ReplicationCoordinatorExternalState* replicationCoordinatorExternalState, BackgroundSync* bgsync); bool shouldStopFetching(const HostAndPort& source, - const rpc::ReplSetMetadata& metadata) override; + const rpc::ReplSetMetadata& replMetadata, + boost::optional<rpc::OplogQueryMetadata> oqMetadata) override; private: BackgroundSync* _bgsync; @@ -94,12 +95,14 @@ DataReplicatorExternalStateBackgroundSync::DataReplicatorExternalStateBackground _bgsync(bgsync) {} bool DataReplicatorExternalStateBackgroundSync::shouldStopFetching( - const HostAndPort& source, const rpc::ReplSetMetadata& metadata) { + const HostAndPort& source, + const rpc::ReplSetMetadata& replMetadata, + boost::optional<rpc::OplogQueryMetadata> oqMetadata) { if (_bgsync->shouldStopFetching()) { return true; } - return DataReplicatorExternalStateImpl::shouldStopFetching(source, metadata); + return DataReplicatorExternalStateImpl::shouldStopFetching(source, replMetadata, oqMetadata); } size_t getSize(const BSONObj& o) { |