From d646e44b7801a3e5b3230bbae7dcfe05a5ed8707 Mon Sep 17 00:00:00 2001
From: Will Buerger <will.buerger@mongodb.com>
Date: Tue, 16 May 2023 20:32:42 +0000
Subject: SERVER-76427: Rename $telemetry to $queryStats Co-authored-by: Ted
 Tuckman <ted.tuckman@mongodb.com>

---
 src/mongo/db/clientcursor.cpp | 36 ++++++++++++++++++------------------
 1 file changed, 18 insertions(+), 18 deletions(-)

(limited to 'src/mongo/db/clientcursor.cpp')

diff --git a/src/mongo/db/clientcursor.cpp b/src/mongo/db/clientcursor.cpp
index 55e116e5893..3b4f0143876 100644
--- a/src/mongo/db/clientcursor.cpp
+++ b/src/mongo/db/clientcursor.cpp
@@ -48,7 +48,7 @@
 #include "mongo/db/cursor_server_params.h"
 #include "mongo/db/jsobj.h"
 #include "mongo/db/query/explain.h"
-#include "mongo/db/query/telemetry.h"
+#include "mongo/db/query/query_stats.h"
 #include "mongo/db/repl/repl_client_info.h"
 #include "mongo/db/repl/replication_coordinator.h"
 #include "mongo/util/background.h"
@@ -124,10 +124,10 @@ ClientCursor::ClientCursor(ClientCursorParams params,
       _planSummary(_exec->getPlanExplainer().getPlanSummary()),
       _planCacheKey(CurOp::get(operationUsingCursor)->debug().planCacheKey),
       _queryHash(CurOp::get(operationUsingCursor)->debug().queryHash),
-      _telemetryStoreKeyHash(CurOp::get(operationUsingCursor)->debug().telemetryStoreKeyHash),
-      _telemetryStoreKey(CurOp::get(operationUsingCursor)->debug().telemetryStoreKey),
-      _telemetryRequestShapifier(
-          std::move(CurOp::get(operationUsingCursor)->debug().telemetryRequestShapifier)),
+      _queryStatsStoreKeyHash(CurOp::get(operationUsingCursor)->debug().queryStatsStoreKeyHash),
+      _queryStatsStoreKey(CurOp::get(operationUsingCursor)->debug().queryStatsStoreKey),
+      _queryStatsRequestShapifier(
+          std::move(CurOp::get(operationUsingCursor)->debug().queryStatsRequestShapifier)),
       _shouldOmitDiagnosticInformation(
           CurOp::get(operationUsingCursor)->debug().shouldOmitDiagnosticInformation),
       _opKey(operationUsingCursor->getOperationKey()) {
@@ -161,13 +161,13 @@ void ClientCursor::dispose(OperationContext* opCtx, boost::optional<Date_t> now)
         return;
     }
 
-    if (_telemetryStoreKeyHash && opCtx) {
-        telemetry::writeTelemetry(opCtx,
-                                  _telemetryStoreKeyHash,
-                                  _telemetryStoreKey,
-                                  std::move(_telemetryRequestShapifier),
-                                  _metrics.executionTime.value_or(Microseconds{0}).count(),
-                                  _metrics.nreturned.value_or(0));
+    if (_queryStatsStoreKeyHash && opCtx) {
+        query_stats::writeQueryStats(opCtx,
+                                     _queryStatsStoreKeyHash,
+                                     _queryStatsStoreKey,
+                                     std::move(_queryStatsRequestShapifier),
+                                     _metrics.executionTime.value_or(Microseconds{0}).count(),
+                                     _metrics.nreturned.value_or(0));
     }
 
     if (now) {
@@ -397,19 +397,19 @@ void startClientCursorMonitor() {
     getClientCursorMonitor(getGlobalServiceContext()).go();
 }
 
-void collectTelemetryMongod(OperationContext* opCtx, ClientCursorPin& pinnedCursor) {
+void collectQueryStatsMongod(OperationContext* opCtx, ClientCursorPin& pinnedCursor) {
     pinnedCursor->incrementCursorMetrics(CurOp::get(opCtx)->debug().additiveMetrics);
 }
 
-void collectTelemetryMongod(OperationContext* opCtx,
-                            std::unique_ptr<telemetry::RequestShapifier> requestShapifier) {
+void collectQueryStatsMongod(OperationContext* opCtx,
+                             std::unique_ptr<query_stats::RequestShapifier> requestShapifier) {
     // If we haven't registered a cursor to prepare for getMore requests, we record
     // telemetry directly.
     auto& opDebug = CurOp::get(opCtx)->debug();
-    telemetry::writeTelemetry(
+    query_stats::writeQueryStats(
         opCtx,
-        opDebug.telemetryStoreKeyHash,
-        opDebug.telemetryStoreKey,
+        opDebug.queryStatsStoreKeyHash,
+        opDebug.queryStatsStoreKey,
         std::move(requestShapifier),
         opDebug.additiveMetrics.executionTime.value_or(Microseconds{0}).count(),
         opDebug.additiveMetrics.nreturned.value_or(0));
-- 
cgit v1.2.1