summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/oplog_applier_impl.cpp
diff options
context:
space:
mode:
authorMark Benvenuto <mark.benvenuto@mongodb.com>2020-02-13 20:40:09 -0500
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2020-02-14 15:44:44 +0000
commit304143ac82ee910df84c58a62f3f18137290ca82 (patch)
treef31a241cea79a49aedf956bb2f28929253dc9fd6 /src/mongo/db/repl/oplog_applier_impl.cpp
parentefa43f5170ab702319128770b0347df0bb2bd8b8 (diff)
downloadmongo-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.cpp33
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;