summaryrefslogtreecommitdiff
path: root/src/mongo/db/commands/count_cmd.cpp
diff options
context:
space:
mode:
authorLucas de Castro Borges <lucas@gnuabordo.com.br>2025-02-11 15:07:35 -0300
committerLucas de Castro Borges <lucas@gnuabordo.com.br>2025-02-11 15:07:35 -0300
commit4cb8841196d0625dfa3825aa326f071cd27c7b8b (patch)
tree1682a647d4463397c119183369ae6f750d5fdcff /src/mongo/db/commands/count_cmd.cpp
parentaa03c6362cbaa767638e6eed9b031d86dd2643d1 (diff)
parent8f0827553e09872941945a093b647a4211a9db7f (diff)
Update upstream source from tag 'upstream/6.0.0'master
Update to upstream version '6.0.0' with Debian dir 5604a80ec1c96ca76f25f40d78e6ef855abec322
Diffstat (limited to 'src/mongo/db/commands/count_cmd.cpp')
-rw-r--r--src/mongo/db/commands/count_cmd.cpp14
1 files changed, 8 insertions, 6 deletions
diff --git a/src/mongo/db/commands/count_cmd.cpp b/src/mongo/db/commands/count_cmd.cpp
index 57291c7b782..c548bf3ef1c 100644
--- a/src/mongo/db/commands/count_cmd.cpp
+++ b/src/mongo/db/commands/count_cmd.cpp
@@ -110,7 +110,7 @@ public:
Status::OK()};
}
- bool shouldAffectReadOptionCounters() const override {
+ bool shouldAffectReadConcernCounter() const override {
return true;
}
@@ -182,8 +182,12 @@ public:
// An empty PrivilegeVector is acceptable because these privileges are only checked on
// getMore and explain will not open a cursor.
- return runAggregate(
- opCtx, viewAggRequest, viewAggregation.getValue(), PrivilegeVector(), result);
+ return runAggregate(opCtx,
+ viewAggRequest.getNamespace(),
+ viewAggRequest,
+ viewAggregation.getValue(),
+ PrivilegeVector(),
+ result);
}
const auto& collection = ctx->getCollection();
@@ -232,8 +236,6 @@ public:
&hangBeforeCollectionCount, opCtx, "hangBeforeCollectionCount", []() {}, nss);
auto request = CountCommandRequest::parse(IDLParserErrorContext("count"), cmdObj);
- auto curOp = CurOp::get(opCtx);
- curOp->beginQueryPlanningTimer();
if (shouldDoFLERewrite(request)) {
processFLECountD(opCtx, nss, &request);
}
@@ -283,6 +285,7 @@ public:
auto exec = std::move(statusWithPlanExecutor.getValue());
// Store the plan summary string in CurOp.
+ auto curOp = CurOp::get(opCtx);
{
stdx::lock_guard<Client> lk(*opCtx->getClient());
curOp->setPlanSummary_inlock(exec->getPlanExplainer().getPlanSummary());
@@ -319,7 +322,6 @@ public:
keyBob.append("hint", 1);
keyBob.append("collation", 1);
keyBob.append("shardVersion", 1);
- keyBob.append("databaseVersion", 1);
return keyBob.obj();
}();