From 304143ac82ee910df84c58a62f3f18137290ca82 Mon Sep 17 00:00:00 2001
From: Mark Benvenuto <mark.benvenuto@mongodb.com>
Date: Thu, 13 Feb 2020 20:40:09 -0500
Subject: SERVER-45822 Manually convert slow query and slow query-like logs

 create mode 100644 jstests/libs/logv2_helpers.js
---
 src/mongo/db/repl/oplog_applier_impl.cpp | 33 +++++++++++++++++++++++---------
 1 file changed, 24 insertions(+), 9 deletions(-)

(limited to 'src/mongo/db/repl/oplog_applier_impl.cpp')

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;
-- 
cgit v1.2.1