summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/bgsync.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/bgsync.cpp')
-rw-r--r--src/mongo/db/repl/bgsync.cpp9
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) {