diff options
| author | Gabriel Russell <gabriel.russell@mongodb.com> | 2020-02-13 11:49:46 -0500 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-02-13 18:16:35 +0000 |
| commit | a84c09a19720b73cedb2e8ef7c5cfeedfa1c9761 (patch) | |
| tree | 85ac46cd5f4ea6d5134560bf764fb9e6cf11fe4e /src/mongo/s/query/cluster_aggregation_planner.cpp | |
| parent | 6df40e01f7b6899affc4536e7e73a35802cabf98 (diff) | |
| download | mongo-a84c09a19720b73cedb2e8ef7c5cfeedfa1c9761.tar.gz | |
SERVER-45869 automatically converted structured logging
Diffstat (limited to 'src/mongo/s/query/cluster_aggregation_planner.cpp')
| -rw-r--r-- | src/mongo/s/query/cluster_aggregation_planner.cpp | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/src/mongo/s/query/cluster_aggregation_planner.cpp b/src/mongo/s/query/cluster_aggregation_planner.cpp index d778c8cb774..0a0eb8f109c 100644 --- a/src/mongo/s/query/cluster_aggregation_planner.cpp +++ b/src/mongo/s/query/cluster_aggregation_planner.cpp @@ -39,6 +39,7 @@ #include "mongo/db/pipeline/document_source_skip.h" #include "mongo/db/pipeline/sharded_agg_helpers.h" #include "mongo/db/query/find_common.h" +#include "mongo/logv2/log.h" #include "mongo/rpc/get_status_from_command_result.h" #include "mongo/rpc/op_msg_rpc_impls.h" #include "mongo/s/catalog_cache.h" @@ -87,7 +88,7 @@ AsyncRequestsSender::Response establishMergingShardCursor(OperationContext* opCt const BSONObj mergeCmdObj, const ShardId& mergingShardId) { if (MONGO_unlikely(shardedAggregateFailToEstablishMergingShardCursor.shouldFail())) { - log() << "shardedAggregateFailToEstablishMergingShardCursor fail point enabled."; + LOGV2(22834, "shardedAggregateFailToEstablishMergingShardCursor fail point enabled."); uasserted(ErrorCodes::FailPointEnabled, "Asserting on establishing merging shard cursor due to failpoint."); } @@ -205,7 +206,10 @@ Status dispatchMergingPipeline(const boost::intrusive_ptr<ExpressionContext>& ex auto mergeCmdObj = createCommandForMergingShard( serializedCommand, expCtx, mergingShardId, mergingShardContributesData, mergePipeline); - LOG(1) << "Dispatching merge pipeline " << redact(mergeCmdObj) << " to designated shard"; + LOGV2_DEBUG(22835, + 1, + "Dispatching merge pipeline {mergeCmdObj} to designated shard", + "mergeCmdObj"_attr = redact(mergeCmdObj)); // Dispatch $mergeCursors to the chosen shard, store the resulting cursor, and return. auto mergeResponse = @@ -352,7 +356,7 @@ DispatchShardPipelineResults dispatchExchangeConsumerPipeline( auto opCtx = expCtx->opCtx; if (MONGO_unlikely(shardedAggregateFailToDispatchExchangeConsumerPipeline.shouldFail())) { - log() << "shardedAggregateFailToDispatchExchangeConsumerPipeline fail point enabled."; + LOGV2(22836, "shardedAggregateFailToDispatchExchangeConsumerPipeline fail point enabled."); uasserted(ErrorCodes::FailPointEnabled, "Asserting on exhange consumer pipeline dispatch due to failpoint."); } |