]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
os/bluestore: Pass in parameters using a const reference instead of a pointer.
authorAbutalib Aghayev <agayev@psu.edu>
Fri, 18 Jun 2021 14:03:08 +0000 (10:03 -0400)
committerAbutalib Aghayev <agayev@psu.edu>
Tue, 22 Jun 2021 13:35:24 +0000 (09:35 -0400)
Signed-off-by: Abutalib Aghayev <agayev@psu.edu>
src/blk/BlockDevice.h
src/blk/zoned/HMSMRDevice.cc
src/blk/zoned/HMSMRDevice.h
src/os/bluestore/BlueStore.cc
src/os/bluestore/ZonedFreelistManager.cc
src/os/bluestore/ZonedFreelistManager.h

index b67312af2f85a404506b1186fd0773da6335f255..da80142ffe32b86875a8dff09e28fe0e9cf9b3b9 100644 (file)
@@ -199,7 +199,7 @@ public:
     ceph_assert(is_smr());
     return conventional_region_size;
   }
-  virtual void reset_zones(const std::set<uint64_t> *zones) {
+  virtual void reset_zones(const std::set<uint64_t>zones) {
     ceph_assert(is_smr());
   }
 
index 61a0d7d0affe64ad9f95479257bc28e1de48f67f..25d00bdbb759a34c02c562b118e8013212a49228 100644 (file)
@@ -412,8 +412,8 @@ void HMSMRDevice::_detect_vdo()
   return;
 }
 
-void HMSMRDevice::reset_zones(const std::set<uint64_t> *zones) {
-  for (auto zone_num : *zones) {
+void HMSMRDevice::reset_zones(const std::set<uint64_t>zones) {
+  for (auto zone_num : zones) {
     if (zbd_reset_zones(zbd_dev, zone_num * zone_size, zone_size) != 0) {
       derr << __func__ << " resetting zone failed for zone " << zone_num << dendl;
     }
index 0656a1dfed6fbe7d7eecf4587d451754d4319049..0efa78111bab179d3b73877290f0a71cb888711b 100644 (file)
@@ -136,7 +136,7 @@ public:
 
   bool is_smr() const final { return true; }
 
-  void reset_zones(const std::set<uint64_t> *zones) override;
+  void reset_zones(const std::set<uint64_t>zones) override;
 
   bool get_thin_utilization(uint64_t *total, uint64_t *avail) const final;
 
index 19faaa8859f9c6f1d537065567fdd3cd4b48321e..e60bb5523a8ebee74530baa8acb471fbd76b9ceb 100644 (file)
@@ -12418,12 +12418,12 @@ void BlueStore::_zoned_cleaner_thread() {
       dout(20) << __func__ << " wake" << dendl;
     } else {
       l.unlock();
-      f->mark_zones_to_clean_in_progress(zones_to_clean, db);
+      f->mark_zones_to_clean_in_progress(*zones_to_clean, db);
       for (auto zone_num : *zones_to_clean) {
        _zoned_clean_zone(zone_num);
       }
-      bdev->reset_zones(zones_to_clean);
-      f->mark_zones_to_clean_free(zones_to_clean, db);
+      bdev->reset_zones(*zones_to_clean);
+      f->mark_zones_to_clean_free(*zones_to_clean, db);
       a->mark_zones_to_clean_free();
       l.lock();
     }
index 40e4f51c1cc516e0afee7b506d242095394a2665..c077ca2e609e55264c855a2f956e396f9ec9a81b 100644 (file)
@@ -315,19 +315,17 @@ int ZonedFreelistManager::_read_cfg(cfg_reader_t cfg_reader) {
 }
 
 void ZonedFreelistManager::mark_zones_to_clean_free(
-    const std::set<uint64_t> *zones_to_clean, KeyValueDB *kvdb) {
+    const std::set<uint64_t>zones_to_clean, KeyValueDB *kvdb) {
   dout(10) << __func__ << dendl;
 
   KeyValueDB::Transaction txn = kvdb->get_transaction();
-  for (auto zone_num : *zones_to_clean) {
+  for (auto zone_num : zones_to_clean) {
     ldout(cct, 10) << __func__ << " zone " << zone_num << " is now clean in DB" << dendl;
 
     zone_state_t zone_state;
     write_zone_state_to_db(zone_num, zone_state, txn);
   }
-
   txn->rmkey(meta_prefix, "cleaning_in_progress_zones");
-
   kvdb->submit_transaction_sync(txn);
 }
 
@@ -336,7 +334,7 @@ void ZonedFreelistManager::mark_zones_to_clean_free(
 // if there is a key "cleaning_in_progress_zones" in the meta_prefix namespace,
 // and if so, will read the zones and resume cleaning.
 void ZonedFreelistManager::mark_zones_to_clean_in_progress(
-    const std::set<uint64_t> *zones_to_clean, KeyValueDB *kvdb) {
+    const std::set<uint64_t>zones_to_clean, KeyValueDB *kvdb) {
   dout(10) << __func__ << dendl;
 
   bufferlist bl;
index 9e01dcbe487d49c6e9408ea42b0f2f19582cfc8f..a74a06a00f26fc0add73d1c7fe263e849b447851 100644 (file)
@@ -102,9 +102,9 @@ public:
                std::vector<std::pair<string, string>>*) const override;
 
   std::vector<zone_state_t> get_zone_states(KeyValueDB *kvdb) const;
-  void mark_zones_to_clean_free(const std::set<uint64_t> *zones_to_clean, 
+  void mark_zones_to_clean_free(const std::set<uint64_t>zones_to_clean, 
                                KeyValueDB *kvdb);
-  void mark_zones_to_clean_in_progress(const std::set<uint64_t> *zones_to_clean,
+  void mark_zones_to_clean_in_progress(const std::set<uint64_t>zones_to_clean,
                                       KeyValueDB *kvdb);
 };