diff options
Diffstat (limited to 'src/mongo/s/query_analysis_sampler.cpp')
-rw-r--r-- | src/mongo/s/query_analysis_sampler.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/s/query_analysis_sampler.cpp b/src/mongo/s/query_analysis_sampler.cpp index acab8a53ba1..4e2b4dfa048 100644 --- a/src/mongo/s/query_analysis_sampler.cpp +++ b/src/mongo/s/query_analysis_sampler.cpp @@ -73,7 +73,7 @@ StatusWith<std::vector<CollectionQueryAnalyzerConfiguration>> executeRefreshComm cmd.setNumQueriesExecutedPerSecond(lastAvgCount); BSONObj resObj; - if (isMongos() || serverGlobalParams.clusterRole == ClusterRole::ShardServer) { + if (isMongos() || serverGlobalParams.clusterRole.has(ClusterRole::ShardServer)) { const auto configShard = Grid::get(opCtx)->shardRegistry()->getConfigShard(); auto swResponse = configShard->runCommandWithFixedRetryAttempts( opCtx, @@ -85,7 +85,7 @@ StatusWith<std::vector<CollectionQueryAnalyzerConfiguration>> executeRefreshComm return status; } resObj = swResponse.getValue().response; - } else if (serverGlobalParams.clusterRole == ClusterRole::None) { + } else if (serverGlobalParams.clusterRole.has(ClusterRole::None)) { resObj = executeCommandOnPrimary( opCtx, DatabaseName::kAdmin, cmd.toBSON({}), [&](const BSONObj& resObj) {}); if (auto status = getStatusFromCommandResult(resObj); !status.isOK()) { @@ -170,11 +170,11 @@ double QueryAnalysisSampler::QueryStats::_calculateExponentialMovingAverage( void QueryAnalysisSampler::QueryStats::refreshTotalCount() { long long newTotalCount = [&] { - if (isMongos() || serverGlobalParams.clusterRole == ClusterRole::None) { + if (isMongos() || serverGlobalParams.clusterRole.has(ClusterRole::None)) { return globalOpCounters.getUpdate()->load() + globalOpCounters.getDelete()->load() + _lastFindAndModifyQueriesCount + globalOpCounters.getQuery()->load() + _lastAggregateQueriesCount + _lastCountQueriesCount + _lastDistinctQueriesCount; - } else if (serverGlobalParams.clusterRole == ClusterRole::ShardServer) { + } else if (serverGlobalParams.clusterRole.has(ClusterRole::ShardServer)) { return globalOpCounters.getNestedAggregate()->load(); } MONGO_UNREACHABLE; |