NVMeofGwMon: implement get_trim_to()

Signed-off-by: Alexander Indenbaum <[email protected]>
ceph · Jul 12, 2024 · 9ea3798 · 9ea3798
1 parent 13db198
commit 9ea3798
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 0 deletions.
diff --git a/src/common/options/global.yaml.in b/src/common/options/global.yaml.in
@@ -1755,6 +1755,13 @@ options:
   default: 500
   services:
   - mon
+- name: mon_max_nvmeof_epochs
+  type: int
+  level: advanced
+  desc: max number of nvmeof gateway maps to store
+  default: 500
+  services:
+  - mon
 - name: mon_max_osd
   type: int
   level: advanced

diff --git a/src/mon/NVMeofGwMon.cc b/src/mon/NVMeofGwMon.cc
@@ -120,6 +120,16 @@ const char **NVMeofGwMon::get_tracked_conf_keys() const
   return KEYS;
 }
 
+version_t NVMeofGwMon::get_trim_to() const
+{
+  // we don't actually need *any* old states, but keep a few.
+  int64_t max = g_conf().get_val<int64_t>("mon_max_nvmeof_epochs");
+  if (map.epoch > max) {
+    return map.epoch - max;
+  }
+  return 0;
+}
+
 void NVMeofGwMon::create_pending() {
 
     pending_map = map;// deep copy of the object

diff --git a/src/mon/NVMeofGwMon.h b/src/mon/NVMeofGwMon.h
@@ -60,6 +60,7 @@ class NVMeofGwMon: public PaxosService,
     void on_restart() override;
     void update_from_paxos(bool *need_bootstrap) override;
 
+    version_t get_trim_to() const override;
 
     bool preprocess_query(MonOpRequestRef op) override;
     bool prepare_update(MonOpRequestRef op) override;