diff options
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.cpp | 8 |
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>(); |