Changing rgw_gc_num_urgent_data_entries to rgw_gc_max_deferred,

and rgw_gc_max_urgent_data_size to rgw_gc_max_deferred_entries_size.

Signed-off-by: Pritha Srivastava <prsrivas@redhat.com>

diff --git a/src/cls/rgw_gc/cls_rgw_gc.cc b/src/cls/rgw_gc/cls_rgw_gc.cc
index 1d485753c1ff1195e3a3a2a0501ced3844ee7e1d..976e49ea52e114d5050ccb048b09a0c2535ea0ad 100644 (file)
--- a/src/cls/rgw_gc/cls_rgw_gc.cc
+++ b/src/cls/rgw_gc/cls_rgw_gc.cc
@@ -38,14 +38,14 @@ static int cls_rgw_gc_queue_init(cls_method_context_t hctx, bufferlist *in, buff
   }
 
   cls_rgw_gc_urgent_data urgent_data;
-  urgent_data.num_urgent_data_entries = op.num_urgent_data_entries;
+  urgent_data.num_urgent_data_entries = op.num_deferred_entries;
 
   cls_queue_init_op init_op;
 
   CLS_LOG(10, "INFO: cls_rgw_gc_queue_init: queue size is %lu\n", op.size);
 
   init_op.queue_size = op.size;
-  init_op.max_urgent_data_size = g_ceph_context->_conf->rgw_gc_max_urgent_data_size;
+  init_op.max_urgent_data_size = g_ceph_context->_conf->rgw_gc_max_deferred_entries_size;
   encode(urgent_data, init_op.bl_urgent_data);
 
   return queue_init(hctx, init_op);

diff --git a/src/cls/rgw_gc/cls_rgw_gc_client.cc b/src/cls/rgw_gc/cls_rgw_gc_client.cc
index ac22d8628d19080d736de4a78044f07ba77e8032..907a58d237708c1b8a52a2a5f9c31de1500ed2ab 100644 (file)
--- a/src/cls/rgw_gc/cls_rgw_gc_client.cc
+++ b/src/cls/rgw_gc/cls_rgw_gc_client.cc
@@ -11,12 +11,12 @@
 
 using namespace librados;
 
-void cls_rgw_gc_queue_init(ObjectWriteOperation& op, uint64_t size, uint64_t num_urgent_data_entries)
+void cls_rgw_gc_queue_init(ObjectWriteOperation& op, uint64_t size, uint64_t num_deferred_entries)
 {
   bufferlist in;
   cls_rgw_gc_queue_init_op call;
   call.size = size;
-  call.num_urgent_data_entries = num_urgent_data_entries;
+  call.num_deferred_entries = num_deferred_entries;
   encode(call, in);
   op.exec(RGW_GC_CLASS, RGW_GC_QUEUE_INIT, in);
 }

diff --git a/src/cls/rgw_gc/cls_rgw_gc_client.h b/src/cls/rgw_gc/cls_rgw_gc_client.h
index 107bed4eb9e1df20e03233cb8c7ab5fd8cc98733..35654e76c035e6909f082aa13ef42260f9d7a515 100644 (file)
--- a/src/cls/rgw_gc/cls_rgw_gc_client.h
+++ b/src/cls/rgw_gc/cls_rgw_gc_client.h
@@ -6,7 +6,7 @@
 #include "cls/queue/cls_queue_ops.h"
 #include "common/ceph_time.h"
 
-void cls_rgw_gc_queue_init(librados::ObjectWriteOperation& op, uint64_t size, uint64_t num_urgent_data_entries);
+void cls_rgw_gc_queue_init(librados::ObjectWriteOperation& op, uint64_t size, uint64_t num_deferred_entries);
 int cls_rgw_gc_queue_get_capacity(librados::IoCtx& io_ctx, const string& oid, uint64_t& size);
 void cls_rgw_gc_queue_enqueue(librados::ObjectWriteOperation& op, uint32_t expiration_secs, const cls_rgw_gc_obj_info& info);
 int cls_rgw_gc_queue_list_entries(librados::IoCtx& io_ctx, const string& oid, const string& marker, uint32_t max, bool expired_only,

diff --git a/src/cls/rgw_gc/cls_rgw_gc_ops.h b/src/cls/rgw_gc/cls_rgw_gc_ops.h
index e51ff946ae1a9413e8e469c8adc86ae419c52b2b..e2f55fb7593685e80e0a2dbda4911c846170357d 100644 (file)
--- a/src/cls/rgw_gc/cls_rgw_gc_ops.h
+++ b/src/cls/rgw_gc/cls_rgw_gc_ops.h
@@ -5,21 +5,21 @@
 
 struct cls_rgw_gc_queue_init_op {
   uint64_t size;
-  uint64_t num_urgent_data_entries{0};
+  uint64_t num_deferred_entries{0};
 
   cls_rgw_gc_queue_init_op() {}
 
   void encode(bufferlist& bl) const {
     ENCODE_START(1, 1, bl);
     encode(size, bl);
-    encode(num_urgent_data_entries, bl);
+    encode(num_deferred_entries, bl);
     ENCODE_FINISH(bl);
   }
 
   void decode(bufferlist::const_iterator& bl) {
     DECODE_START(1, bl);
     decode(size, bl);
-    decode(num_urgent_data_entries, bl);
+    decode(num_deferred_entries, bl);
     DECODE_FINISH(bl);
   }
 

diff --git a/src/common/legacy_config_opts.h b/src/common/legacy_config_opts.h
index 82c3648e2680dd3f84fea3a1d3f0c09c202418ad..5a712765f4acace2a02b31c5a16d83c549a02969 100644 (file)
--- a/src/common/legacy_config_opts.h
+++ b/src/common/legacy_config_opts.h
@@ -1564,6 +1564,6 @@ OPTION(rgw_sts_token_introspection_url, OPT_STR)  // url for introspecting web t
 OPTION(rgw_sts_client_id, OPT_STR) // Client Id
 OPTION(rgw_sts_client_secret, OPT_STR) // Client Secret
 OPTION(debug_allow_any_pool_priority, OPT_BOOL)
-OPTION(rgw_gc_max_urgent_data_size, OPT_U64) // GC urgent data size
+OPTION(rgw_gc_max_deferred_entries_size, OPT_U64) // GC deferred entries size in queue head
 OPTION(rgw_gc_max_queue_size, OPT_U64) // GC max queue size
-OPTION(rgw_gc_num_urgent_data_entries, OPT_U64) // GC number of urgent data entries
+OPTION(rgw_gc_max_deferred, OPT_U64) // GC max number of deferred entries

diff --git a/src/common/options.cc b/src/common/options.cc
index e505aed4edca746363add94c7cea012773699b27..2612e6b19177794e5fde16eee06c651f0c782af3 100644 (file)
--- a/src/common/options.cc
+++ b/src/common/options.cc
@@ -6462,9 +6462,9 @@ std::vector<Option> get_rgw_options() {
     .set_description("Max number of keys to remove from garbage collector log in a single operation")
     .add_see_also({"rgw_gc_max_objs", "rgw_gc_obj_min_wait", "rgw_gc_processor_max_time", "rgw_gc_max_concurrent_io"}),
 
-    Option("rgw_gc_max_urgent_data_size", Option::TYPE_UINT, Option::LEVEL_ADVANCED)
+    Option("rgw_gc_max_deferred_entries_size", Option::TYPE_UINT, Option::LEVEL_ADVANCED)
     .set_default(3072)
-    .set_description("maximum allowed size of urgent data in queue head for gc"),
+    .set_description("maximum allowed size of deferred entries in queue head for gc"),
 
     Option("rgw_gc_max_queue_size", Option::TYPE_UINT, Option::LEVEL_ADVANCED)
     .set_default(128_M)
@@ -6474,9 +6474,9 @@ std::vector<Option> get_rgw_options() {
         "be greater than osd_max_object_size.")
     .add_see_also({"osd_max_object_size"}),
 
-    Option("rgw_gc_num_urgent_data_entries", Option::TYPE_UINT, Option::LEVEL_ADVANCED)
+    Option("rgw_gc_max_deferred", Option::TYPE_UINT, Option::LEVEL_ADVANCED)
     .set_default(50)
-    .set_description("Number of urgent data entries to be stored in queue for gc"),
+    .set_description("Number of maximum deferred data entries to be stored in queue for gc"),
 
     Option("rgw_s3_success_create_obj_status", Option::TYPE_INT, Option::LEVEL_ADVANCED)
     .set_default(0)

diff --git a/src/rgw/rgw_gc.cc b/src/rgw/rgw_gc.cc
index 6d24a0950439247189ef59987613993d60b252aa..c015e76c29f967ccc13797a1d44304b72d2eccaa 100644 (file)
--- a/src/rgw/rgw_gc.cc
+++ b/src/rgw/rgw_gc.cc
@@ -47,8 +47,8 @@ void RGWGC::initialize(CephContext *_cct, RGWRados *_store) {
     //version = 1 -> marked ready for transition
     librados::ObjectWriteOperation op;
     op.create(false);
-    const uint64_t queue_size = cct->_conf->rgw_gc_max_queue_size, num_urgent_data_entries = cct->_conf->rgw_gc_num_urgent_data_entries;
-    gc_log_init2(op, queue_size, num_urgent_data_entries);
+    const uint64_t queue_size = cct->_conf->rgw_gc_max_queue_size, num_deferred_entries = cct->_conf->rgw_gc_max_deferred;
+    gc_log_init2(op, queue_size, num_deferred_entries);
     store->gc_operate(obj_names[i], &op);
   }
 }

diff --git a/src/rgw/rgw_gc_log.cc b/src/rgw/rgw_gc_log.cc
index 53dd7ec0efdeb6356c1518b2dff3163c53b9b40b..ad819eddc059bf48336380ff945ff50b79187152 100644 (file)
--- a/src/rgw/rgw_gc_log.cc
+++ b/src/rgw/rgw_gc_log.cc
@@ -9,11 +9,11 @@
 
 
 void gc_log_init2(librados::ObjectWriteOperation& op,
-                  uint64_t max_size, uint64_t max_urgent)
+                  uint64_t max_size, uint64_t max_deferred)
 {
   obj_version objv; // objv.ver = 0
   cls_version_check(op, objv, VER_COND_EQ);
-  cls_rgw_gc_queue_init(op, max_size, max_urgent);
+  cls_rgw_gc_queue_init(op, max_size, max_deferred);
   objv.ver = 1;
   cls_version_set(op, objv);
 }

diff --git a/src/rgw/rgw_gc_log.h b/src/rgw/rgw_gc_log.h
index 8c223e5391d1e8db09d0a212e17d289fbf0a6bea..a37672617bb013c57be163939a09a44b4ba21704 100644 (file)
--- a/src/rgw/rgw_gc_log.h
+++ b/src/rgw/rgw_gc_log.h
@@ -9,7 +9,7 @@
 
 // initialize the cls_rgw_gc queue
 void gc_log_init2(librados::ObjectWriteOperation& op,
-                  uint64_t max_size, uint64_t max_urgent);
+                  uint64_t max_size, uint64_t max_deferred);
 
 // enqueue a gc entry to omap with cls_rgw
 void gc_log_enqueue1(librados::ObjectWriteOperation& op,