summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--src/mongo/base/error_codes.err1
-rw-r--r--src/mongo/db/SConscript3
-rw-r--r--src/mongo/db/repl/SConscript3
-rw-r--r--src/mongo/db/repl/replication_coordinator.h21
-rw-r--r--src/mongo/db/repl/replication_coordinator_impl.cpp46
-rw-r--r--src/mongo/db/repl/replication_coordinator_impl.h10
-rw-r--r--src/mongo/db/repl/replication_coordinator_mock.cpp11
-rw-r--r--src/mongo/db/repl/replication_coordinator_mock.h6
-rw-r--r--src/mongo/db/repl/topology_coordinator.cpp61
-rw-r--r--src/mongo/db/repl/topology_coordinator.h18
-rw-r--r--src/mongo/db/repl/topology_coordinator_v1_test.cpp149
-rw-r--r--src/mongo/embedded/replication_coordinator_embedded.cpp11
-rw-r--r--src/mongo/embedded/replication_coordinator_embedded.h7
13 files changed, 0 insertions, 347 deletions
diff --git a/src/mongo/base/error_codes.err b/src/mongo/base/error_codes.err
index b0be7a0303d..9f70c55617d 100644
--- a/src/mongo/base/error_codes.err
+++ b/src/mongo/base/error_codes.err
@@ -275,7 +275,6 @@ error_code("ProducerConsumerQueueConsumed", 274)
error_code("ExchangePassthrough", 275) # For exchange execution in aggregation. Do not reuse.
error_code("IndexBuildAborted", 276)
error_code("AlarmAlreadyFulfilled", 277)
-error_code("UnsatisfiableCommitQuorum", 278)
# Error codes 4000-8999 are reserved.
# Non-sequential error codes (for compatibility only)
diff --git a/src/mongo/db/SConscript b/src/mongo/db/SConscript
index 4ece86d1ee3..aca5070ff88 100644
--- a/src/mongo/db/SConscript
+++ b/src/mongo/db/SConscript
@@ -931,9 +931,6 @@ env.Library(
"index_builds_coordinator_interface",
"$BUILD_DIR/mongo/util/concurrency/thread_pool",
],
- LIBDEPS_PRIVATE=[
- "$BUILD_DIR/mongo/db/catalog/commit_quorum_options",
- ],
)
env.Library(
diff --git a/src/mongo/db/repl/SConscript b/src/mongo/db/repl/SConscript
index 03481453497..f78940a728d 100644
--- a/src/mongo/db/repl/SConscript
+++ b/src/mongo/db/repl/SConscript
@@ -790,9 +790,6 @@ env.Library('topology_coordinator',
'repl_settings',
'rslog',
'repl_coordinator_interface',
- ],
- LIBDEPS_PRIVATE=[
- '$BUILD_DIR/mongo/db/catalog/commit_quorum_options',
])
env.CppUnitTest('repl_set_heartbeat_response_test',
diff --git a/src/mongo/db/repl/replication_coordinator.h b/src/mongo/db/repl/replication_coordinator.h
index 9c310e41025..229ee7e5df3 100644
--- a/src/mongo/db/repl/replication_coordinator.h
+++ b/src/mongo/db/repl/replication_coordinator.h
@@ -46,7 +46,6 @@ namespace mongo {
class BSONObj;
class BSONObjBuilder;
-class CommitQuorumOptions;
class IndexDescriptor;
class NamespaceString;
class OperationContext;
@@ -252,26 +251,6 @@ public:
const WriteConcernOptions& writeConcern) const = 0;
/**
- * Checks if the 'commitQuorum' can be satisfied by all the members in the replica set; if it
- * cannot be satisfied, then the 'UnsatisfiableCommitQuorum' error code is returned.
- *
- * Returns the 'NoReplicationEnabled' error code if this is called without replication enabled.
- */
- virtual Status checkIfCommitQuorumCanBeSatisfied(
- const CommitQuorumOptions& commitQuorum) const = 0;
-
- /**
- * Checks if the 'commitQuorum' has been satisfied by the 'commitReadyMembers', if it has been
- * satisfied, return true.
- *
- * Prior to checking if the 'commitQuorum' is satisfied by 'commitReadyMembers', it calls
- * 'checkIfCommitQuorumCanBeSatisfied()' with all the replica set members.
- */
- virtual StatusWith<bool> checkIfCommitQuorumIsSatisfied(
- const CommitQuorumOptions& commitQuorum,
- const std::vector<HostAndPort>& commitReadyMembers) const = 0;
-
- /**
* Returns Status::OK() if it is valid for this node to serve reads on the given collection
* and an errorcode indicating why the node cannot if it cannot.
*/
diff --git a/src/mongo/db/repl/replication_coordinator_impl.cpp b/src/mongo/db/repl/replication_coordinator_impl.cpp
index 9da656c3138..560e2d61338 100644
--- a/src/mongo/db/repl/replication_coordinator_impl.cpp
+++ b/src/mongo/db/repl/replication_coordinator_impl.cpp
@@ -42,7 +42,6 @@
#include "mongo/base/status.h"
#include "mongo/client/fetcher.h"
#include "mongo/db/audit.h"
-#include "mongo/db/catalog/commit_quorum_options.h"
#include "mongo/db/client.h"
#include "mongo/db/commands.h"
#include "mongo/db/commands/test_commands_enabled.h"
@@ -3119,51 +3118,6 @@ Status ReplicationCoordinatorImpl::_checkIfWriteConcernCanBeSatisfied_inlock(
return _rsConfig.checkIfWriteConcernCanBeSatisfied(writeConcern);
}
-Status ReplicationCoordinatorImpl::checkIfCommitQuorumCanBeSatisfied(
- const CommitQuorumOptions& commitQuorum) const {
- stdx::lock_guard<stdx::mutex> lock(_mutex);
- return _checkIfCommitQuorumCanBeSatisfied(lock, commitQuorum);
-}
-
-Status ReplicationCoordinatorImpl::_checkIfCommitQuorumCanBeSatisfied(
- WithLock, const CommitQuorumOptions& commitQuorum) const {
- if (getReplicationMode() == modeNone) {
- return Status(ErrorCodes::NoReplicationEnabled,
- "No replication enabled when checking if commit quorum can be satisfied");
- }
-
- invariant(getReplicationMode() == modeReplSet);
-
- std::vector<MemberConfig> memberConfig(_rsConfig.membersBegin(), _rsConfig.membersEnd());
-
- // We need to ensure that the 'commitQuorum' can be satisfied by all the members of this
- // replica set.
- bool commitQuorumCanBeSatisfied =
- _topCoord->checkIfCommitQuorumCanBeSatisfied(commitQuorum, memberConfig);
- if (!commitQuorumCanBeSatisfied) {
- return Status(ErrorCodes::UnsatisfiableCommitQuorum,
- str::stream() << "Commit quorum cannot be satisfied with the current replica "
- << "set configuration");
- }
- return Status::OK();
-}
-
-StatusWith<bool> ReplicationCoordinatorImpl::checkIfCommitQuorumIsSatisfied(
- const CommitQuorumOptions& commitQuorum,
- const std::vector<HostAndPort>& commitReadyMembers) const {
- // If the 'commitQuorum' cannot be satisfied with all the members of this replica set, we
- // need to inform the caller to avoid hanging while waiting for satisfiability of the
- // 'commitQuorum' with 'commitReadyMembers' due to replica set reconfigurations.
- stdx::lock_guard<stdx::mutex> lock(_mutex);
- Status status = _checkIfCommitQuorumCanBeSatisfied(lock, commitQuorum);
- if (!status.isOK()) {
- return status;
- }
-
- // Return whether or not the 'commitQuorum' is satisfied by the 'commitReadyMembers'.
- return _topCoord->checkIfCommitQuorumIsSatisfied(commitQuorum, commitReadyMembers);
-}
-
WriteConcernOptions ReplicationCoordinatorImpl::getGetLastErrorDefault() {
stdx::lock_guard<stdx::mutex> lock(_mutex);
if (_rsConfig.isInitialized()) {
diff --git a/src/mongo/db/repl/replication_coordinator_impl.h b/src/mongo/db/repl/replication_coordinator_impl.h
index 04aeb218525..be46d90817d 100644
--- a/src/mongo/db/repl/replication_coordinator_impl.h
+++ b/src/mongo/db/repl/replication_coordinator_impl.h
@@ -137,13 +137,6 @@ public:
virtual Status checkIfWriteConcernCanBeSatisfied(const WriteConcernOptions& writeConcern) const;
- virtual Status checkIfCommitQuorumCanBeSatisfied(
- const CommitQuorumOptions& commitQuorum) const override;
-
- virtual StatusWith<bool> checkIfCommitQuorumIsSatisfied(
- const CommitQuorumOptions& commitQuorum,
- const std::vector<HostAndPort>& commitReadyMembers) const override;
-
virtual Status checkCanServeReadsFor(OperationContext* opCtx,
const NamespaceString& ns,
bool slaveOk);
@@ -749,9 +742,6 @@ private:
Status _checkIfWriteConcernCanBeSatisfied_inlock(const WriteConcernOptions& writeConcern) const;
- Status _checkIfCommitQuorumCanBeSatisfied(WithLock,
- const CommitQuorumOptions& commitQuorum) const;
-
bool _canAcceptWritesFor_inlock(const NamespaceString& ns);
int _getMyId_inlock() const;
diff --git a/src/mongo/db/repl/replication_coordinator_mock.cpp b/src/mongo/db/repl/replication_coordinator_mock.cpp
index a2961c4fdfd..040acc9c965 100644
--- a/src/mongo/db/repl/replication_coordinator_mock.cpp
+++ b/src/mongo/db/repl/replication_coordinator_mock.cpp
@@ -380,17 +380,6 @@ Status ReplicationCoordinatorMock::checkIfWriteConcernCanBeSatisfied(
return Status::OK();
}
-Status ReplicationCoordinatorMock::checkIfCommitQuorumCanBeSatisfied(
- const CommitQuorumOptions& commitQuorum) const {
- return Status::OK();
-}
-
-StatusWith<bool> ReplicationCoordinatorMock::checkIfCommitQuorumIsSatisfied(
- const CommitQuorumOptions& commitQuorum,
- const std::vector<HostAndPort>& commitReadyMembers) const {
- return true;
-}
-
WriteConcernOptions ReplicationCoordinatorMock::getGetLastErrorDefault() {
return WriteConcernOptions();
}
diff --git a/src/mongo/db/repl/replication_coordinator_mock.h b/src/mongo/db/repl/replication_coordinator_mock.h
index f79dadbc776..ed18860e16c 100644
--- a/src/mongo/db/repl/replication_coordinator_mock.h
+++ b/src/mongo/db/repl/replication_coordinator_mock.h
@@ -109,12 +109,6 @@ public:
virtual Status checkIfWriteConcernCanBeSatisfied(const WriteConcernOptions& writeConcern) const;
- virtual Status checkIfCommitQuorumCanBeSatisfied(const CommitQuorumOptions& commitQuorum) const;
-
- virtual StatusWith<bool> checkIfCommitQuorumIsSatisfied(
- const CommitQuorumOptions& commitQuorum,
- const std::vector<HostAndPort>& commitReadyMembers) const;
-
virtual Status checkCanServeReadsFor(OperationContext* opCtx,
const NamespaceString& ns,
bool slaveOk);
diff --git a/src/mongo/db/repl/topology_coordinator.cpp b/src/mongo/db/repl/topology_coordinator.cpp
index df4e115f999..54724c9683d 100644
--- a/src/mongo/db/repl/topology_coordinator.cpp
+++ b/src/mongo/db/repl/topology_coordinator.cpp
@@ -41,7 +41,6 @@
#include "mongo/bson/simple_bsonobj_comparator.h"
#include "mongo/db/audit.h"
-#include "mongo/db/catalog/commit_quorum_options.h"
#include "mongo/db/client.h"
#include "mongo/db/mongod_options.h"
#include "mongo/db/operation_context.h"
@@ -2792,65 +2791,5 @@ TopologyCoordinator::latestKnownOpTimeSinceHeartbeatRestartPerMember() const {
return opTimesPerMember;
}
-bool TopologyCoordinator::checkIfCommitQuorumCanBeSatisfied(
- const CommitQuorumOptions& commitQuorum, const std::vector<MemberConfig>& members) const {
- if (!commitQuorum.mode.empty() && commitQuorum.mode != CommitQuorumOptions::kMajority) {
- StatusWith<ReplSetTagPattern> tagPatternStatus =
- _rsConfig.findCustomWriteMode(commitQuorum.mode);
- if (!tagPatternStatus.isOK()) {
- return false;
- }
-
- ReplSetTagMatch matcher(tagPatternStatus.getValue());
- for (auto&& member : members) {
- for (MemberConfig::TagIterator it = member.tagsBegin(); it != member.tagsEnd(); ++it) {
- if (matcher.update(*it)) {
- return true;
- }
- }
- }
-
- // Even if all the nodes in the set had a given write it still would not satisfy this
- // commit quorum.
- return false;
- } else {
- int nodesRemaining = 0;
- if (!commitQuorum.mode.empty()) {
- invariant(commitQuorum.mode == CommitQuorumOptions::kMajority);
- nodesRemaining = _rsConfig.getWriteMajority();
- } else {
- nodesRemaining = commitQuorum.numNodes;
- }
-
- for (auto&& member : members) {
- if (!member.isArbiter()) { // Only count data-bearing nodes
- --nodesRemaining;
- if (nodesRemaining <= 0) {
- return true;
- }
- }
- }
- return false;
- }
-}
-
-bool TopologyCoordinator::checkIfCommitQuorumIsSatisfied(
- const CommitQuorumOptions& commitQuorum,
- const std::vector<HostAndPort>& commitReadyMembers) const {
- std::vector<MemberConfig> commitReadyMemberConfigs;
- for (auto& commitReadyMember : commitReadyMembers) {
- const MemberConfig* memberConfig = _rsConfig.findMemberByHostAndPort(commitReadyMember);
-
- invariant(memberConfig);
- commitReadyMemberConfigs.push_back(*memberConfig);
- }
-
- // Calling this with commit ready members only is the same as checking if the commit quorum is
- // satisfied. Because the 'commitQuorum' is based on the participation of all the replica set
- // members, and if the 'commitQuorum' can be satisfied with all the commit ready members, then
- // the commit quorum is satisfied in this replica set configuration.
- return checkIfCommitQuorumCanBeSatisfied(commitQuorum, commitReadyMemberConfigs);
-}
-
} // namespace repl
} // namespace mongo
diff --git a/src/mongo/db/repl/topology_coordinator.h b/src/mongo/db/repl/topology_coordinator.h
index 04656beaa26..b2c4f44fea4 100644
--- a/src/mongo/db/repl/topology_coordinator.h
+++ b/src/mongo/db/repl/topology_coordinator.h
@@ -44,7 +44,6 @@
#include "mongo/util/time_support.h"
namespace mongo {
-class CommitQuorumOptions;
class Timestamp;
namespace repl {
@@ -660,23 +659,6 @@ public:
*/
std::map<int, boost::optional<OpTime>> latestKnownOpTimeSinceHeartbeatRestartPerMember() const;
- /**
- * Checks if the 'commitQuorum' can be satisifed by 'members'. Returns true if it can be
- * satisfied.
- *
- * 'members' must be part of the replica set configuration.
- */
- bool checkIfCommitQuorumCanBeSatisfied(const CommitQuorumOptions& commitQuorum,
- const std::vector<MemberConfig>& members) const;
-
- /**
- * Returns 'true' if the 'commitQuorum' is satisifed by the 'commitReadyMembers'.
- *
- * 'commitReadyMembers' must be part of the replica set configuration.
- */
- bool checkIfCommitQuorumIsSatisfied(const CommitQuorumOptions& commitQuorum,
- const std::vector<HostAndPort>& commitReadyMembers) const;
-
////////////////////////////////////////////////////////////
//
// Test support methods
diff --git a/src/mongo/db/repl/topology_coordinator_v1_test.cpp b/src/mongo/db/repl/topology_coordinator_v1_test.cpp
index 57fcabefdee..c44f572fe3b 100644
--- a/src/mongo/db/repl/topology_coordinator_v1_test.cpp
+++ b/src/mongo/db/repl/topology_coordinator_v1_test.cpp
@@ -33,7 +33,6 @@
#include <iostream>
#include "mongo/bson/json.h"
-#include "mongo/db/catalog/commit_quorum_options.h"
#include "mongo/db/repl/heartbeat_response_action.h"
#include "mongo/db/repl/repl_set_heartbeat_args_v1.h"
#include "mongo/db/repl/repl_set_heartbeat_response.h"
@@ -5102,154 +5101,6 @@ TEST_F(TopoCoordTest, ArbitersNotIncludedInW2WriteInPSSAAReplSet) {
caughtUpOpTime, 2 /* numNodes */, false /* durablyWritten */));
}
-TEST_F(TopoCoordTest, CheckIfCommitQuorumCanBeSatisfied) {
- ReplSetConfig configA;
- ASSERT_OK(configA.initialize(BSON("_id"
- << "rs0"
- << "version"
- << 1
- << "protocolVersion"
- << 1
- << "members"
- << BSON_ARRAY(BSON("_id" << 0 << "host"
- << "node0"
- << "tags"
- << BSON("dc"
- << "NA"
- << "rack"
- << "rackNA1"))
- << BSON("_id" << 1 << "host"
- << "node1"
- << "tags"
- << BSON("dc"
- << "NA"
- << "rack"
- << "rackNA2"))
- << BSON("_id" << 2 << "host"
- << "node2"
- << "tags"
- << BSON("dc"
- << "NA"
- << "rack"
- << "rackNA3"))
- << BSON("_id" << 3 << "host"
- << "node3"
- << "tags"
- << BSON("dc"
- << "EU"
- << "rack"
- << "rackEU1"))
- << BSON("_id" << 4 << "host"
- << "node4"
- << "tags"
- << BSON("dc"
- << "EU"
- << "rack"
- << "rackEU2"))
- << BSON("_id" << 5 << "host"
- << "node5"
- << "arbiterOnly"
- << true))
- << "settings"
- << BSON("getLastErrorModes"
- << BSON("valid" << BSON("dc" << 2 << "rack" << 3)
- << "invalidNotEnoughValues"
- << BSON("dc" << 3)
- << "invalidNotEnoughNodes"
- << BSON("rack" << 6))))));
- getTopoCoord().updateConfig(configA, -1, Date_t());
-
- std::vector<MemberConfig> memberConfig;
- for (auto it = configA.membersBegin(); it != configA.membersEnd(); it++) {
- memberConfig.push_back(*it);
- }
-
- // Consider all the replica set members.
- {
- CommitQuorumOptions validNumberWC;
- validNumberWC.numNodes = 5;
- ASSERT_TRUE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(validNumberWC, memberConfig));
-
- CommitQuorumOptions invalidNumberWC;
- invalidNumberWC.numNodes = 6;
- ASSERT_FALSE(
- getTopoCoord().checkIfCommitQuorumCanBeSatisfied(invalidNumberWC, memberConfig));
-
- CommitQuorumOptions majorityWC;
- majorityWC.mode = "majority";
- ASSERT_TRUE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(majorityWC, memberConfig));
-
- CommitQuorumOptions validModeWC;
- validModeWC.mode = "valid";
- ASSERT_TRUE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(validModeWC, memberConfig));
-
- CommitQuorumOptions invalidModeWC;
- invalidModeWC.mode = "invalidNotEnoughNodes";
- ASSERT_FALSE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(invalidModeWC, memberConfig));
-
- CommitQuorumOptions fakeModeWC;
- fakeModeWC.mode = "fake";
- ASSERT_FALSE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(fakeModeWC, memberConfig));
- }
-
- // Use a list of commit ready members that is not a majority.
- {
- std::vector<MemberConfig> commitReadyMembersNoMajority;
- commitReadyMembersNoMajority.push_back(*configA.findMemberByID(0));
- commitReadyMembersNoMajority.push_back(*configA.findMemberByID(1));
- commitReadyMembersNoMajority.push_back(*configA.findMemberByID(2));
-
- CommitQuorumOptions validNumberWC;
- validNumberWC.numNodes = 3;
- ASSERT_TRUE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(validNumberWC,
- commitReadyMembersNoMajority));
-
- CommitQuorumOptions invalidNumberWC;
- invalidNumberWC.numNodes = 4;
- ASSERT_FALSE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(
- invalidNumberWC, commitReadyMembersNoMajority));
-
- CommitQuorumOptions majorityWC;
- majorityWC.mode = "majority";
- ASSERT_FALSE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(
- majorityWC, commitReadyMembersNoMajority));
-
- CommitQuorumOptions invalidModeWC;
- invalidModeWC.mode = "valid";
- ASSERT_FALSE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(
- invalidModeWC, commitReadyMembersNoMajority));
- }
-
- // Use a list of commit ready members that is a majority.
- {
- std::vector<MemberConfig> commitReadyMembersMajority;
- commitReadyMembersMajority.push_back(*configA.findMemberByID(0));
- commitReadyMembersMajority.push_back(*configA.findMemberByID(1));
- commitReadyMembersMajority.push_back(*configA.findMemberByID(2));
- commitReadyMembersMajority.push_back(*configA.findMemberByID(3));
-
- CommitQuorumOptions validNumberWC;
- validNumberWC.numNodes = 4;
- ASSERT_TRUE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(validNumberWC,
- commitReadyMembersMajority));
-
- CommitQuorumOptions invalidNumberWC;
- invalidNumberWC.numNodes = 5;
- ASSERT_FALSE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(invalidNumberWC,
- commitReadyMembersMajority));
-
- CommitQuorumOptions majorityWC;
- majorityWC.mode = "majority";
- ASSERT_TRUE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(majorityWC,
- commitReadyMembersMajority));
-
- CommitQuorumOptions invalidModeWC;
- invalidModeWC.mode = "valid";
- ASSERT_TRUE(getTopoCoord().checkIfCommitQuorumCanBeSatisfied(invalidModeWC,
- commitReadyMembersMajority));
- }
-}
-
TEST_F(HeartbeatResponseTestV1,
ScheduleACatchupTakeoverWhenElectableAndReceiveHeartbeatFromPrimaryInCatchup) {
updateConfig(BSON("_id"
diff --git a/src/mongo/embedded/replication_coordinator_embedded.cpp b/src/mongo/embedded/replication_coordinator_embedded.cpp
index ae4ddee7270..199bebd9d18 100644
--- a/src/mongo/embedded/replication_coordinator_embedded.cpp
+++ b/src/mongo/embedded/replication_coordinator_embedded.cpp
@@ -353,17 +353,6 @@ Status ReplicationCoordinatorEmbedded::checkIfWriteConcernCanBeSatisfied(
UASSERT_NOT_IMPLEMENTED;
}
-Status ReplicationCoordinatorEmbedded::checkIfCommitQuorumCanBeSatisfied(
- const CommitQuorumOptions& commitQuorum) const {
- UASSERT_NOT_IMPLEMENTED;
-}
-
-StatusWith<bool> ReplicationCoordinatorEmbedded::checkIfCommitQuorumIsSatisfied(
- const CommitQuorumOptions& commitQuorum,
- const std::vector<HostAndPort>& commitReadyMembers) const {
- UASSERT_NOT_IMPLEMENTED;
-}
-
Status ReplicationCoordinatorEmbedded::checkReplEnabledForCommand(BSONObjBuilder*) {
return Status(ErrorCodes::NoReplicationEnabled, "no replication on embedded");
}
diff --git a/src/mongo/embedded/replication_coordinator_embedded.h b/src/mongo/embedded/replication_coordinator_embedded.h
index d29fd729b6a..9e185f62a08 100644
--- a/src/mongo/embedded/replication_coordinator_embedded.h
+++ b/src/mongo/embedded/replication_coordinator_embedded.h
@@ -104,13 +104,6 @@ public:
Status checkIfWriteConcernCanBeSatisfied(const WriteConcernOptions&) const override;
- Status checkIfCommitQuorumCanBeSatisfied(
- const CommitQuorumOptions& commitQuorum) const override;
-
- StatusWith<bool> checkIfCommitQuorumIsSatisfied(
- const CommitQuorumOptions& commitQuorum,
- const std::vector<HostAndPort>& commitReadyMembers) const override;
-
void setMyLastAppliedOpTime(const repl::OpTime&) override;
void setMyLastDurableOpTime(const repl::OpTime&) override;
View Lorry Controller Status