diff options
author | Davis Haupt <davis.haupt@mongodb.com> | 2023-05-15 13:22:59 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2023-05-15 15:24:46 +0000 |
commit | 572a0c3987787a66f0192009b30651b8bae822ff (patch) | |
tree | a9613a37fccc420c88cd113f0ad419824ddf25df /src/mongo/db/clientcursor.cpp | |
parent | 8896b5ba5a84d1b6b63953b9009ca16eda69d3c6 (diff) | |
download | mongo-572a0c3987787a66f0192009b30651b8bae822ff.tar.gz |
SERVER-75512 key telemetry store on hash rather than BSONObj
Diffstat (limited to 'src/mongo/db/clientcursor.cpp')
-rw-r--r-- | src/mongo/db/clientcursor.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/mongo/db/clientcursor.cpp b/src/mongo/db/clientcursor.cpp index a18b2fec45b..55e116e5893 100644 --- a/src/mongo/db/clientcursor.cpp +++ b/src/mongo/db/clientcursor.cpp @@ -124,6 +124,7 @@ 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)), @@ -160,8 +161,9 @@ void ClientCursor::dispose(OperationContext* opCtx, boost::optional<Date_t> now) return; } - if (_telemetryStoreKey && opCtx) { + if (_telemetryStoreKeyHash && opCtx) { telemetry::writeTelemetry(opCtx, + _telemetryStoreKeyHash, _telemetryStoreKey, std::move(_telemetryRequestShapifier), _metrics.executionTime.value_or(Microseconds{0}).count(), @@ -406,6 +408,7 @@ void collectTelemetryMongod(OperationContext* opCtx, auto& opDebug = CurOp::get(opCtx)->debug(); telemetry::writeTelemetry( opCtx, + opDebug.telemetryStoreKeyHash, opDebug.telemetryStoreKey, std::move(requestShapifier), opDebug.additiveMetrics.executionTime.value_or(Microseconds{0}).count(), |