From d29f96ae3e1b7d65b2f513340e8c2c42cf6de9f1 Mon Sep 17 00:00:00 2001
From: Casey Bodley <cbodley@redhat.com>
Date: Thu, 7 Sep 2017 12:48:47 -0400
Subject: [PATCH] rgw: add configure_bucket_trim()

Signed-off-by: Casey Bodley <cbodley@redhat.com>
---
 src/common/options.cc        | 12 ++++++++++++
 src/rgw/rgw_sync_log_trim.cc | 19 +++++++++++++++++++
 2 files changed, 31 insertions(+)

diff --git a/src/common/options.cc b/src/common/options.cc
index 2e70f1c592e..881a18d73d1 100644
--- a/src/common/options.cc
+++ b/src/common/options.cc
@@ -5010,6 +5010,18 @@ std::vector<Option> get_rgw_options() {
     .set_default(1200)
     .set_description(""),
 
+    Option("rgw_sync_log_trim_max_buckets", Option::TYPE_INT, Option::LEVEL_ADVANCED)
+    .set_default(16)
+    .set_description("Maximum number of buckets to trim per interval"),
+
+    Option("rgw_sync_log_trim_min_cold_buckets", Option::TYPE_INT, Option::LEVEL_ADVANCED)
+    .set_default(4)
+    .set_description("Minimum number of cold buckets to trim per interval"),
+
+    Option("rgw_sync_log_trim_concurrent_buckets", Option::TYPE_INT, Option::LEVEL_ADVANCED)
+    .set_default(4)
+    .set_description("Maximum number of buckets to trim in parallel"),
+
     Option("rgw_sync_data_inject_err_probability", Option::TYPE_FLOAT, Option::LEVEL_DEV)
     .set_default(0)
     .set_description(""),
diff --git a/src/rgw/rgw_sync_log_trim.cc b/src/rgw/rgw_sync_log_trim.cc
index a3c21329822..0ff0b0e169b 100644
--- a/src/rgw/rgw_sync_log_trim.cc
+++ b/src/rgw/rgw_sync_log_trim.cc
@@ -737,6 +737,25 @@ class RecentEventList {
 
 namespace rgw {
 
+// read bucket trim configuration from ceph context
+void configure_bucket_trim(CephContext *cct, BucketTrimConfig& config)
+{
+  auto conf = cct->_conf;
+
+  config.trim_interval_sec =
+      conf->get_val<int64_t>("rgw_sync_log_trim_interval");
+  config.counter_size = 512;
+  config.buckets_per_interval =
+      conf->get_val<int64_t>("rgw_sync_log_trim_max_buckets");
+  config.min_cold_buckets_per_interval =
+      conf->get_val<int64_t>("rgw_sync_log_trim_min_cold_buckets");
+  config.concurrent_buckets =
+      conf->get_val<int64_t>("rgw_sync_log_trim_concurrent_buckets");
+  config.notify_timeout_ms = 10;
+  config.recent_size = 128;
+  config.recent_duration = std::chrono::hours(2);
+}
+
 class BucketTrimManager::Impl : public TrimCounters::Server,
                                 public BucketTrimObserver {
  public: