From dfb3d6d99b2065349ef46bbf8b66d58610b93a17 Mon Sep 17 00:00:00 2001
From: Adam Kupczyk <akupczyk@redhat.com>
Date: Fri, 26 Jun 2020 18:04:57 +0200
Subject: [PATCH] os/bluestore: Add ability to disable compaction

This ability only makes sense as a step that allows to perform fsck before commiting recovered bluefs log.

Signed-off-by: Adam Kupczyk <akupczyk@redhat.com>
---
 src/common/legacy_config_opts.h |  1 +
 src/common/options.cc           |  4 ++++
 src/os/bluestore/BlueFS.cc      | 25 ++++++++++++++-----------
 3 files changed, 19 insertions(+), 11 deletions(-)

diff --git a/src/common/legacy_config_opts.h b/src/common/legacy_config_opts.h
index da5d961dcccda..9e2315362ebf9 100644
--- a/src/common/legacy_config_opts.h
+++ b/src/common/legacy_config_opts.h
@@ -996,6 +996,7 @@ OPTION(bluefs_sync_write, OPT_BOOL)
 OPTION(bluefs_allocator, OPT_STR)     // stupid | bitmap
 OPTION(bluefs_preextend_wal_files, OPT_BOOL)  // this *requires* that rocksdb has recycling enabled
 OPTION(bluefs_replay_recovery, OPT_BOOL)
+OPTION(bluefs_replay_recovery_disable_compact, OPT_BOOL)
 
 OPTION(bluestore_bluefs, OPT_BOOL)
 OPTION(bluestore_bluefs_env_mirror, OPT_BOOL) // mirror to normal Env for debug
diff --git a/src/common/options.cc b/src/common/options.cc
index 5c982c81e0370..a772ec02332dd 100644
--- a/src/common/options.cc
+++ b/src/common/options.cc
@@ -3385,6 +3385,10 @@ std::vector<Option> get_global_options() {
 			  "This options enables heuristics that scans devices for missing data. "
 			  "DO NOT ENABLE BY DEFAULT"),
 
+    Option("bluefs_replay_recovery_disable_compact", Option::TYPE_BOOL, Option::LEVEL_ADVANCED)
+    .set_default(false)
+    .set_description(""),
+
     Option("bluestore_bluefs", Option::TYPE_BOOL, Option::LEVEL_DEV)
     .set_default(true)
     .add_tag("mkfs")
diff --git a/src/os/bluestore/BlueFS.cc b/src/os/bluestore/BlueFS.cc
index b9ee408601ca3..2334725f2ffee 100644
--- a/src/os/bluestore/BlueFS.cc
+++ b/src/os/bluestore/BlueFS.cc
@@ -1182,10 +1182,12 @@ uint64_t BlueFS::_estimate_log_size()
 void BlueFS::compact_log()
 {
   std::unique_lock<std::mutex> l(lock);
-  if (cct->_conf->bluefs_compact_log_sync) {
-     _compact_log_sync();
-  } else {
-    _compact_log_async(l);
+  if (!cct->_conf->bluefs_replay_recovery_disable_compact) {
+    if (cct->_conf->bluefs_compact_log_sync) {
+      _compact_log_sync();
+    } else {
+      _compact_log_async(l);
+    }
   }
 }
 
@@ -2061,13 +2063,14 @@ void BlueFS::sync_metadata()
     utime_t end = ceph_clock_now();
     utime_t dur = end - start;
     dout(10) << __func__ << " done in " << dur << dendl;
-  }
-
-  if (_should_compact_log()) {
-    if (cct->_conf->bluefs_compact_log_sync) {
-      _compact_log_sync();
-    } else {
-      _compact_log_async(l);
+    if (!cct->_conf->bluefs_replay_recovery_disable_compact) {
+      if (_should_compact_log()) {
+	if (cct->_conf->bluefs_compact_log_sync) {
+	  _compact_log_sync();
+	} else {
+	  _compact_log_async(l);
+	}
+      }
     }
   }
 }
-- 
2.39.5