]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
osd: using SERVER_OCTOPUS everywhere
authorletterwuyu <lishuhao@unitedstack.com>
Sun, 5 May 2019 06:24:39 +0000 (14:24 +0800)
committerletterwuyu <lishuhao@unitedstack.com>
Mon, 6 May 2019 12:17:43 +0000 (20:17 +0800)
Signed-off-by: lishuhao <lishuhao@unitedstack.com>
src/osd/ReplicatedBackend.cc
src/osd/osd_types.h

index 5956750bbd70bb3d4eb43a5982fdd5a4ff92a824..1f8d0d33e3860d173ccb17a59007817ea20017f4 100644 (file)
@@ -1143,7 +1143,7 @@ void ReplicatedBackend::calc_head_subsets(
   if (size)
     data_subset.insert(0, size);
 
-  if (HAVE_FEATURE(parent->min_peer_features(), SERVER_NAUTILUS)) {
+  if (HAVE_FEATURE(parent->min_peer_features(), SERVER_OCTOPUS)) {
     const auto it = missing.get_items().find(head);
     assert(it != missing.get_items().end());
     data_subset.intersection_of(it->second.clean_regions.get_dirty_regions());
@@ -1382,7 +1382,7 @@ void ReplicatedBackend::prepare_pull(
     // pulling head or unversioned object.
     // always pull the whole thing.
     recovery_info.copy_subset.insert(0, (uint64_t)-1);
-    if (HAVE_FEATURE(parent->min_peer_features(), SERVER_NAUTILUS))
+    if (HAVE_FEATURE(parent->min_peer_features(), SERVER_OCTOPUS))
       recovery_info.copy_subset.intersection_of(missing_iter->second.clean_regions.get_dirty_regions());
     recovery_info.size = ((uint64_t)-1);
     recovery_info.object_exist = missing_iter->second.clean_regions.object_is_exist();
@@ -1397,7 +1397,7 @@ void ReplicatedBackend::prepare_pull(
   op.recovery_info.version = v;
   op.recovery_progress.data_complete = false;
   op.recovery_progress.omap_complete = !missing_iter->second.clean_regions.omap_is_dirty() 
-                                && HAVE_FEATURE(parent->min_peer_features(), SERVER_NAUTILUS);
+                                && HAVE_FEATURE(parent->min_peer_features(), SERVER_OCTOPUS);
   op.recovery_progress.data_recovered_to = 0;
   op.recovery_progress.first = true;
 
@@ -1525,7 +1525,7 @@ int ReplicatedBackend::prep_push(
   pi.recovery_info.version = version;
   pi.recovery_info.object_exist = missing_iter->second.clean_regions.object_is_exist();
   pi.recovery_progress.omap_complete = !missing_iter->second.clean_regions.omap_is_dirty() &&
-    HAVE_FEATURE(parent->min_peer_features(), SERVER_NAUTILUS);
+    HAVE_FEATURE(parent->min_peer_features(), SERVER_OCTOPUS);
   pi.lock_manager = std::move(lock_manager);
 
   ObjectRecoveryProgress new_progress;
index 8f42b4c3ecc8f2ee6b8c1a02dd5ebbc1869bf05a..f115b2f8da0298983271c196fdafc7773ac7115b 100644 (file)
@@ -4221,15 +4221,15 @@ struct pg_missing_item {
   void encode(ceph::buffer::list& bl, uint64_t features) const {
     using ceph::encode;
     // encoding a zeroed eversion_t to differentiate between OSD_RECOVERY_DELETES、
-    // SERVER_NAUTILUS and legacy unversioned encoding - a need value of 0'0 is not
+    // SERVER_OCTOPUS and legacy unversioned encoding - a need value of 0'0 is not
     // possible. This can be replaced with the legacy encoding
 
     bool have_recovery_deletes = HAVE_FEATURE(features, OSD_RECOVERY_DELETES);
-    bool have_server_nautilus = HAVE_FEATURE(features, SERVER_NAUTILUS);
+    bool have_server_octopus = HAVE_FEATURE(features, SERVER_OCTOPUS);
 
     if (have_recovery_deletes)
       encode(eversion_t(), bl);
-    if (have_server_nautilus)
+    if (have_server_octopus)
       encode(eversion_t(-1, -1), bl);
 
     encode(need, bl);
@@ -4237,7 +4237,7 @@ struct pg_missing_item {
       
     if (have_recovery_deletes)
       encode(static_cast<uint8_t>(flags), bl);
-    if (have_server_nautilus)
+    if (have_server_octopus)
       encode(clean_regions, bl);
   }
   void decode(ceph::buffer::list::const_iterator& bl) {