summaryrefslogtreecommitdiff
path: root/src/mongo/embedded
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/embedded')
-rw-r--r--src/mongo/embedded/replication_coordinator_embedded.cpp11
-rw-r--r--src/mongo/embedded/replication_coordinator_embedded.h7
2 files changed, 18 insertions, 0 deletions
diff --git a/src/mongo/embedded/replication_coordinator_embedded.cpp b/src/mongo/embedded/replication_coordinator_embedded.cpp
index 199bebd9d18..ae4ddee7270 100644
--- a/src/mongo/embedded/replication_coordinator_embedded.cpp
+++ b/src/mongo/embedded/replication_coordinator_embedded.cpp
@@ -353,6 +353,17 @@ 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 9e185f62a08..d29fd729b6a 100644
--- a/src/mongo/embedded/replication_coordinator_embedded.h
+++ b/src/mongo/embedded/replication_coordinator_embedded.h
@@ -104,6 +104,13 @@ 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;