summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/config_server_op_observer.cpp
diff options
context:
space:
mode:
authorSilvia Surroca <silvia.surroca@mongodb.com>2022-06-03 11:58:55 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-06-03 12:36:42 +0000
commitcc541819baf3d798f8f0da1edf6f9beda10961a7 (patch)
tree95ec3ce26711e0749796795d0dfd78cf279fd108 /src/mongo/db/s/config_server_op_observer.cpp
parent9aafbc13112e03e9aa6889b0fb754adaac8d1e84 (diff)
downloadmongo-cc541819baf3d798f8f0da1edf6f9beda10961a7.tar.gz
SERVER-66431 Replace all usages of ShardType::ConfigNS by kConfigsvrShardsNamespace
Diffstat (limited to 'src/mongo/db/s/config_server_op_observer.cpp')
-rw-r--r--src/mongo/db/s/config_server_op_observer.cpp7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/mongo/db/s/config_server_op_observer.cpp b/src/mongo/db/s/config_server_op_observer.cpp
index dff7d0d6022..c0081d68a41 100644
--- a/src/mongo/db/s/config_server_op_observer.cpp
+++ b/src/mongo/db/s/config_server_op_observer.cpp
@@ -96,7 +96,8 @@ void ConfigServerOpObserver::_onReplicationRollback(OperationContext* opCtx,
ClusterIdentityLoader::get(opCtx)->discardCachedClusterId();
}
- if (rbInfo.rollbackNamespaces.find(ShardType::ConfigNS) != rbInfo.rollbackNamespaces.end()) {
+ if (rbInfo.rollbackNamespaces.find(NamespaceString::kConfigsvrShardsNamespace) !=
+ rbInfo.rollbackNamespaces.end()) {
// If some entries were rollbacked from config.shards we might need to discard some tick
// points from the TopologyTimeTicker
const auto lastApplied = repl::ReplicationCoordinator::get(opCtx)->getMyLastAppliedOpTime();
@@ -110,7 +111,7 @@ void ConfigServerOpObserver::onInserts(OperationContext* opCtx,
std::vector<InsertStatement>::const_iterator begin,
std::vector<InsertStatement>::const_iterator end,
bool fromMigrate) {
- if (nss != ShardType::ConfigNS) {
+ if (nss != NamespaceString::kConfigsvrShardsNamespace) {
return;
}
@@ -137,7 +138,7 @@ void ConfigServerOpObserver::onInserts(OperationContext* opCtx,
}
void ConfigServerOpObserver::onUpdate(OperationContext* opCtx, const OplogUpdateEntryArgs& args) {
- if (args.nss != ShardType::ConfigNS) {
+ if (args.nss != NamespaceString::kConfigsvrShardsNamespace) {
return;
}