From 0ea432a638ff7cf6124eb0a27427a658529ec068 Mon Sep 17 00:00:00 2001
From: Jingyu Zhou <jingyuzhou@gmail.com>
Date: Fri, 30 Jul 2021 18:26:34 -0700
Subject: [PATCH] Add traceevent for all printed mutations

---
 fdbbackup/FileDecoder.actor.cpp | 28 ++++++++++++++--------------
 1 file changed, 14 insertions(+), 14 deletions(-)

diff --git a/fdbbackup/FileDecoder.actor.cpp b/fdbbackup/FileDecoder.actor.cpp
index 018ddd3251..e2c337a7d8 100644
--- a/fdbbackup/FileDecoder.actor.cpp
+++ b/fdbbackup/FileDecoder.actor.cpp
@@ -583,22 +583,21 @@ ACTOR Future<Void> decode_logs(DecodeParams params) {
 			}
 
 			for (const auto& m : vms.mutations) {
-				if (params.prefix.empty()) { // no filtering
-					std::cout << vms.version << " " << m.toString() << "\n";
-					continue;
-				}
+				bool print = params.prefix.empty(); // no filtering
 
-				if (isSingleKeyMutation((MutationRef::Type)m.type)) {
-					if (m.param1.startsWith(params.prefix)) {
-						std::cout << vms.version << " " << m.toString() << "\n";
+				if (!print) {
+					if (isSingleKeyMutation((MutationRef::Type)m.type)) {
+						print = m.param1.startsWith(params.prefix);
+					} else if (m.type == MutationRef::ClearRange) {
+						KeyRange range(KeyRangeRef(m.param1, m.param2));
+						print = range.contains(params.prefix);
+					} else {
+						ASSERT(false);
 					}
-				} else if (m.type == MutationRef::ClearRange) {
-					KeyRange range(KeyRangeRef(m.param1, m.param2));
-					if (range.contains(params.prefix)) {
-						std::cout << vms.version << " " << m.toString() << "\n";
-					}
-				} else {
-					ASSERT(false);
+				}
+				if (print) {
+					TraceEvent("Mutation").detail("Version", vms.version).detail("M", m.toString());
+					std::cout << vms.version << " " << m.toString() << "\n";
 				}
 			}
 		}
@@ -607,6 +606,7 @@ ACTOR Future<Void> decode_logs(DecodeParams params) {
 			TraceEvent("UnfinishedFile").detail("File", logs[i].fileName).detail("Q", left.size());
 		}
 	}
+	TraceEvent("DecodeDone");
 	return Void();
 }