diff options
| author | Ben Shteinfeld <ben.shteinfeld@mongodb.com> | 2022-11-08 21:40:31 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-11-08 22:33:43 +0000 |
| commit | bae712c9891ad30c4fa9e1413efa4b3f3aa5c828 (patch) | |
| tree | b73222332a3b0de6067b94a3a710a03d1fa827d6 /src/mongo/db/stats | |
| parent | 7a45a7307f2aac8389a0cb0a9b805e28686b4874 (diff) | |
| download | mongo-bae712c9891ad30c4fa9e1413efa4b3f3aa5c828.tar.gz | |
SERVER-68847 Include query framework information in GetMore profiler entries
Diffstat (limited to 'src/mongo/db/stats')
| -rw-r--r-- | src/mongo/db/stats/counters.h | 53 |
1 files changed, 31 insertions, 22 deletions
diff --git a/src/mongo/db/stats/counters.h b/src/mongo/db/stats/counters.h index 65b15958c59..d066202d375 100644 --- a/src/mongo/db/stats/counters.h +++ b/src/mongo/db/stats/counters.h @@ -323,31 +323,40 @@ public: auto& debug = curop->debug(); const BSONObj& cmdObj = curop->opDescription(); auto cmdName = cmdObj.firstElementFieldNameStringData(); - if (cmdName == "find" && debug.classicEngineUsed) { - if (debug.classicEngineUsed.get()) { - classicFindQueryCounter.increment(); - } else { - sbeFindQueryCounter.increment(); + + if (cmdName == "find") { + switch (debug.queryFramework) { + case PlanExecutor::QueryFramework::kClassicOnly: + classicFindQueryCounter.increment(); + break; + case PlanExecutor::QueryFramework::kSBEOnly: + sbeFindQueryCounter.increment(); + break; + case PlanExecutor::QueryFramework::kCQF: + cqfFindQueryCounter.increment(); + break; + default: + break; } - } else if (cmdName == "aggregate" && debug.classicEngineUsed && debug.documentSourceUsed) { - if (debug.classicEngineUsed.get()) { - if (debug.documentSourceUsed.get()) { - classicHybridAggregationCounter.increment(); - } else { + } else if (cmdName == "aggregate") { + switch (debug.queryFramework) { + case PlanExecutor::QueryFramework::kClassicOnly: classicOnlyAggregationCounter.increment(); - } - } else { - if (debug.documentSourceUsed.get()) { - sbeHybridAggregationCounter.increment(); - } else { + break; + case PlanExecutor::QueryFramework::kClassicHybrid: + classicHybridAggregationCounter.increment(); + break; + case PlanExecutor::QueryFramework::kSBEOnly: sbeOnlyAggregationCounter.increment(); - } - } - } else if (debug.cqfUsed) { - if (cmdName == "find") { - cqfFindQueryCounter.increment(); - } else { - cqfAggregationQueryCounter.increment(); + break; + case PlanExecutor::QueryFramework::kSBEHybrid: + sbeHybridAggregationCounter.increment(); + break; + case PlanExecutor::QueryFramework::kCQF: + cqfAggregationQueryCounter.increment(); + break; + case PlanExecutor::QueryFramework::kUnknown: + break; } } } |