summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/data_replicator_external_state_mock.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/data_replicator_external_state_mock.cpp')
-rw-r--r--src/mongo/db/repl/data_replicator_external_state_mock.cpp8
1 files changed, 7 insertions, 1 deletions
diff --git a/src/mongo/db/repl/data_replicator_external_state_mock.cpp b/src/mongo/db/repl/data_replicator_external_state_mock.cpp
index dddc2e4f9ba..ddcfc701ca6 100644
--- a/src/mongo/db/repl/data_replicator_external_state_mock.cpp
+++ b/src/mongo/db/repl/data_replicator_external_state_mock.cpp
@@ -98,13 +98,19 @@ ChangeSyncSourceAction DataReplicatorExternalStateMock::shouldStopFetching(
const rpc::ReplSetMetadata& replMetadata,
const rpc::OplogQueryMetadata& oqMetadata,
const OpTime& previousOpTimeFetched,
- const OpTime& lastOpTimeFetched) {
+ const OpTime& lastOpTimeFetched) const {
lastSyncSourceChecked = source;
syncSourceLastOpTime = oqMetadata.getLastOpApplied();
syncSourceHasSyncSource = oqMetadata.getSyncSourceIndex() != -1;
return shouldStopFetchingResult;
}
+ChangeSyncSourceAction DataReplicatorExternalStateMock::shouldStopFetchingOnError(
+ const HostAndPort& source, const OpTime& lastOpTimeFetched) const {
+ lastSyncSourceChecked = source;
+ return shouldStopFetchingResult;
+}
+
std::unique_ptr<OplogBuffer> DataReplicatorExternalStateMock::makeInitialSyncOplogBuffer(
OperationContext* opCtx) const {
return std::make_unique<OplogBufferBlockingQueue>();