diff options
Diffstat (limited to 'src/mongo/db/clientcursor.cpp')
-rw-r--r-- | src/mongo/db/clientcursor.cpp | 36 |
1 files changed, 18 insertions, 18 deletions
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)); |