From 0924f5eaf3724656ce2a3a417440cf756889f1ab Mon Sep 17 00:00:00 2001
From: shangdehao1 <dehao.shang@intel.com>
Date: Thu, 7 Mar 2019 08:06:12 +0800
Subject: [PATCH] tools: make cache watermark configurable

Signed-off-by: Dehao Shang <dehao.shang@intel.com>
---
 src/common/options.cc                                | 4 ++++
 src/tools/immutable_object_cache/ObjectCacheStore.cc | 9 ++++++---
 src/tools/immutable_object_cache/ObjectCacheStore.h  | 3 ++-
 3 files changed, 12 insertions(+), 4 deletions(-)

diff --git a/src/common/options.cc b/src/common/options.cc
index 59ed0e7f429c5..3a3c3be5a0b45 100644
--- a/src/common/options.cc
+++ b/src/common/options.cc
@@ -7409,6 +7409,10 @@ static std::vector<Option> get_immutable_object_cache_options() {
     Option("immutable_object_cache_client_dedicated_thread_num", Option::TYPE_UINT, Option::LEVEL_ADVANCED)
     .set_default(2)
     .set_description("immutable object cache client dedicated thread number"),
+
+    Option("immutable_object_cache_watermark", Option::TYPE_FLOAT, Option::LEVEL_ADVANCED)
+    .set_default(0.1)
+    .set_description("immutable object cache water mark"),
   });
 }
 
diff --git a/src/tools/immutable_object_cache/ObjectCacheStore.cc b/src/tools/immutable_object_cache/ObjectCacheStore.cc
index f0b6eb1a5ab90..df73bd3b1f14f 100644
--- a/src/tools/immutable_object_cache/ObjectCacheStore.cc
+++ b/src/tools/immutable_object_cache/ObjectCacheStore.cc
@@ -19,18 +19,21 @@ namespace immutable_obj_cache {
 ObjectCacheStore::ObjectCacheStore(CephContext *cct)
       : m_cct(cct), m_rados(new librados::Rados()),
         m_ioctx_map_lock("ceph::cache::ObjectCacheStore::m_ioctx_map_lock") {
-  object_cache_max_size =
+  m_object_cache_max_size =
     m_cct->_conf.get_val<Option::size_t>("immutable_object_cache_max_size");
 
   m_cache_root_dir =
     m_cct->_conf.get_val<std::string>("immutable_object_cache_path");
 
+  m_cache_watermark =
+    m_cct->_conf.get_val<double>("immutable_object_cache_watermark");
+
   if (m_cache_root_dir.back() != '/') {
     m_cache_root_dir += "/";
   }
 
-  // TODO(dehao): allow to set cache level
-  m_policy = new SimplePolicy(m_cct, object_cache_max_size, 0.1);
+  m_policy = new SimplePolicy(m_cct, m_object_cache_max_size,
+                              m_cache_watermark);
 }
 
 ObjectCacheStore::~ObjectCacheStore() {
diff --git a/src/tools/immutable_object_cache/ObjectCacheStore.h b/src/tools/immutable_object_cache/ObjectCacheStore.h
index fa86aca4032cc..2972f52a3e1aa 100644
--- a/src/tools/immutable_object_cache/ObjectCacheStore.h
+++ b/src/tools/immutable_object_cache/ObjectCacheStore.h
@@ -53,7 +53,8 @@ class ObjectCacheStore {
   Policy* m_policy;
   // TODO(dehao): make this configurable
   int m_dir_num = 10;
-  uint64_t object_cache_max_size;
+  uint64_t m_object_cache_max_size;
+  float m_cache_watermark;
   std::string m_cache_root_dir;
 };
 
-- 
2.39.5