diff options
author | Will Buerger <will.buerger@mongodb.com> | 2023-05-17 11:49:47 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2023-05-17 12:58:52 +0000 |
commit | ae65ecae5514adc99d60b7396137a1acf2b44335 (patch) | |
tree | 24169f9a640321bfbbec649e869fe51b273b35e3 /src/mongo/s/query/cluster_cursor_manager.cpp | |
parent | 1b4a551a6b8c85611e26857217ce1a1e1363e716 (diff) | |
download | mongo-ae65ecae5514adc99d60b7396137a1acf2b44335.tar.gz |
SERVER-76427 Rename $telemetry to $queryStats
Diffstat (limited to 'src/mongo/s/query/cluster_cursor_manager.cpp')
-rw-r--r-- | src/mongo/s/query/cluster_cursor_manager.cpp | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/mongo/s/query/cluster_cursor_manager.cpp b/src/mongo/s/query/cluster_cursor_manager.cpp index d8e47e55ecf..68436d25c6e 100644 --- a/src/mongo/s/query/cluster_cursor_manager.cpp +++ b/src/mongo/s/query/cluster_cursor_manager.cpp @@ -38,7 +38,7 @@ #include "mongo/db/allocate_cursor_id.h" #include "mongo/db/curop.h" #include "mongo/db/query/query_knobs_gen.h" -#include "mongo/db/query/telemetry.h" +#include "mongo/db/query/query_stats.h" #include "mongo/db/session/kill_sessions_common.h" #include "mongo/db/session/logical_session_cache.h" #include "mongo/logv2/log.h" @@ -591,25 +591,25 @@ StatusWith<ClusterClientCursorGuard> ClusterCursorManager::_detachCursor(WithLoc return std::move(cursor); } -void collectTelemetryMongos(OperationContext* opCtx, - std::unique_ptr<telemetry::RequestShapifier> requestShapifier) { +void collectQueryStatsMongos(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. + // queryStats 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)); } -void collectTelemetryMongos(OperationContext* opCtx, ClusterClientCursorGuard& cursor) { +void collectQueryStatsMongos(OperationContext* opCtx, ClusterClientCursorGuard& cursor) { cursor->incrementCursorMetrics(CurOp::get(opCtx)->debug().additiveMetrics); } -void collectTelemetryMongos(OperationContext* opCtx, ClusterCursorManager::PinnedCursor& cursor) { +void collectQueryStatsMongos(OperationContext* opCtx, ClusterCursorManager::PinnedCursor& cursor) { cursor->incrementCursorMetrics(CurOp::get(opCtx)->debug().additiveMetrics); } |