diff options
author | Mark Benvenuto <mark.benvenuto@mongodb.com> | 2020-02-13 20:40:09 -0500 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-02-14 15:44:44 +0000 |
commit | 304143ac82ee910df84c58a62f3f18137290ca82 (patch) | |
tree | f31a241cea79a49aedf956bb2f28929253dc9fd6 /src/mongo/db/repl/oplog_applier_impl.cpp | |
parent | efa43f5170ab702319128770b0347df0bb2bd8b8 (diff) | |
download | mongo-304143ac82ee910df84c58a62f3f18137290ca82.tar.gz |
SERVER-45822 Manually convert slow query and slow query-like logs
create mode 100644 jstests/libs/logv2_helpers.js
Diffstat (limited to 'src/mongo/db/repl/oplog_applier_impl.cpp')
-rw-r--r-- | src/mongo/db/repl/oplog_applier_impl.cpp | 33 |
1 files changed, 24 insertions, 9 deletions
diff --git a/src/mongo/db/repl/oplog_applier_impl.cpp b/src/mongo/db/repl/oplog_applier_impl.cpp index e54bc128219..e801962d0df 100644 --- a/src/mongo/db/repl/oplog_applier_impl.cpp +++ b/src/mongo/db/repl/oplog_applier_impl.cpp @@ -113,20 +113,35 @@ Status finishAndLogApply(OperationContext* opCtx, Milliseconds(opDuration), Milliseconds(serverGlobalParams.slowMS)) .first) { + if (serverGlobalParams.logFormat == logv2::LogFormat::kJson) { - StringBuilder s; - s << "applied op: "; + logv2::DynamicAttributes attrs; - if (entryOrGroupedInserts.getOp().getOpType() == OpTypeEnum::kCommand) { - s << "command "; + auto redacted = redact(entryOrGroupedInserts.toBSON()); + if (entryOrGroupedInserts.getOp().getOpType() == OpTypeEnum::kCommand) { + attrs.add("command", redacted); + } else { + attrs.add("CRUD", redacted); + } + + attrs.add("duration", opDuration); + + LOGV2(51801, "applied op", attrs); } else { - s << "CRUD "; - } + StringBuilder s; + s << "applied op: "; - s << redact(entryOrGroupedInserts.toBSON()); - s << ", took " << opDuration << "ms"; + if (entryOrGroupedInserts.getOp().getOpType() == OpTypeEnum::kCommand) { + s << "command "; + } else { + s << "CRUD "; + } + + s << redact(entryOrGroupedInserts.toBSON()); + s << ", took " << opDuration << "ms"; - LOGV2(21228, "{s_str}", "s_str"_attr = s.str()); + LOGV2(21228, "{s_str}", "s_str"_attr = s.str()); + } } } return finalStatus; |