diff options
| author | XueruiFa <xuerui.fa@mongodb.com> | 2020-06-30 15:32:39 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-07-09 16:45:25 +0000 |
| commit | 1b0445dc3ea2a3d15ae477238f68b0a4438a7212 (patch) | |
| tree | f46e6f7e4cf4a2fd64110d6b62984e6526a6acdf /src/mongo/embedded | |
| parent | 98cf395c1e85d015032a4ef542fb491c47d726c3 (diff) | |
| download | mongo-1b0445dc3ea2a3d15ae477238f68b0a4438a7212.tar.gz | |
SERVER-48930: Use lastFetched from previous batch when comparing optimes for re-evaluating sync source
Diffstat (limited to 'src/mongo/embedded')
| -rw-r--r-- | src/mongo/embedded/replication_coordinator_embedded.cpp | 10 | ||||
| -rw-r--r-- | src/mongo/embedded/replication_coordinator_embedded.h | 9 |
2 files changed, 11 insertions, 8 deletions
diff --git a/src/mongo/embedded/replication_coordinator_embedded.cpp b/src/mongo/embedded/replication_coordinator_embedded.cpp index 96b4dac3cfa..9d08d1519de 100644 --- a/src/mongo/embedded/replication_coordinator_embedded.cpp +++ b/src/mongo/embedded/replication_coordinator_embedded.cpp @@ -421,10 +421,12 @@ void ReplicationCoordinatorEmbedded::resetLastOpTimesFromOplog(OperationContext* UASSERT_NOT_IMPLEMENTED; } -bool ReplicationCoordinatorEmbedded::shouldChangeSyncSource(const HostAndPort&, - const rpc::ReplSetMetadata&, - const rpc::OplogQueryMetadata&, - const OpTime&) { +ChangeSyncSourceAction ReplicationCoordinatorEmbedded::shouldChangeSyncSource( + const HostAndPort&, + const rpc::ReplSetMetadata&, + const rpc::OplogQueryMetadata&, + const OpTime&, + const OpTime&) { UASSERT_NOT_IMPLEMENTED; } diff --git a/src/mongo/embedded/replication_coordinator_embedded.h b/src/mongo/embedded/replication_coordinator_embedded.h index b1e8174beb6..4201903d3a0 100644 --- a/src/mongo/embedded/replication_coordinator_embedded.h +++ b/src/mongo/embedded/replication_coordinator_embedded.h @@ -218,10 +218,11 @@ public: void resetLastOpTimesFromOplog(OperationContext*, DataConsistency) override; - bool shouldChangeSyncSource(const HostAndPort&, - const rpc::ReplSetMetadata&, - const rpc::OplogQueryMetadata&, - const repl::OpTime&) override; + repl::ChangeSyncSourceAction shouldChangeSyncSource(const HostAndPort&, + const rpc::ReplSetMetadata&, + const rpc::OplogQueryMetadata&, + const repl::OpTime&, + const repl::OpTime&) override; repl::OpTime getLastCommittedOpTime() const override; |