Revert "tools/cephfs-data-scan: Recover referent hardlink - build dentry"

This reverts commit 3d4ac8c82fe7a67a984a343d8fbd270a8e92ed9d.

Signed-off-by: Venky Shankar <vshankar@redhat.com>

diff --git a/src/cls/cephfs/cls_cephfs_client.cc b/src/cls/cephfs/cls_cephfs_client.cc
index 3546de9222a86a028d1f04941c94044cad22ded3..a8cd9c68000ed375a92f4ecc4a9eea9f11ee8e64 100644 (file)
--- a/src/cls/cephfs/cls_cephfs_client.cc
+++ b/src/cls/cephfs/cls_cephfs_client.cc
@@ -86,7 +86,6 @@ int ClsCephFSClient::fetch_inode_accumulate_result(
   inode_backtrace_t *backtrace,
   file_layout_t *layout,
   std::string *symlink,
-  inodeno_t *remote_inode,
   AccumulateResult *result)
 {
   ceph_assert(backtrace != NULL);
@@ -126,11 +125,6 @@ int ClsCephFSClient::fetch_inode_accumulate_result(
   op.getxattr("symlink", &symlink_bl, &symlink_r);
   op.set_op_flags2(librados::OP_FAILOK);
 
-  int remote_inode_r = 0;
-  bufferlist remote_inode_bl;
-  op.getxattr("remote_inode", &remote_inode_bl, &remote_inode_r);
-  op.set_op_flags2(librados::OP_FAILOK);
-
   bufferlist op_bl;
   int r = ctx.operate(oid, &op, &op_bl);
   if (r < 0) {
@@ -209,16 +203,6 @@ int ClsCephFSClient::fetch_inode_accumulate_result(
     }
   }
 
-  // Deserialize remote_inode
-  if (remote_inode_bl.length()) {
-    try {
-      auto q = remote_inode_bl.cbegin();
-      decode(*remote_inode, q);
-    } catch (ceph::buffer::error &e) {
-      return -EINVAL;
-    }
-  }
-
   return 0;
 }
 

diff --git a/src/cls/cephfs/cls_cephfs_client.h b/src/cls/cephfs/cls_cephfs_client.h
index df523529c40c36ac55b6c86c8d03baef3f8b7fdc..1036d1443a7fa41a28d9aac71f3f5f4326c16133 100644 (file)
--- a/src/cls/cephfs/cls_cephfs_client.h
+++ b/src/cls/cephfs/cls_cephfs_client.h
@@ -25,7 +25,6 @@ class ClsCephFSClient
       inode_backtrace_t *backtrace,
       file_layout_t *layout,
       std::string *symlink,
-      inodeno_t *remote_inode,
       AccumulateResult *result);
 
   static int delete_inode_accumulate_result(

diff --git a/src/tools/cephfs/DataScan.cc b/src/tools/cephfs/DataScan.cc
index 49fd491738c894e236e0f6f3765528a45025d371..a847f172a8ba0cd32682939eddb0129abda8e0d9 100644 (file)
--- a/src/tools/cephfs/DataScan.cc
+++ b/src/tools/cephfs/DataScan.cc
@@ -883,9 +883,8 @@ int DataScan::scan_inodes()
         inode_backtrace_t backtrace;
         file_layout_t loaded_layout = file_layout_t::get_default();
         std::string symlink;
-        inodeno_t remote_inode;
         r = ClsCephFSClient::fetch_inode_accumulate_result(
-            data_io, oid, &backtrace, &loaded_layout, &symlink, &remote_inode,
+            data_io, oid, &backtrace, &loaded_layout, &symlink,
             &accum_res);
 
         if (r == -EINVAL) {
@@ -1097,8 +1096,7 @@ int DataScan::scan_inodes()
 
         InodeStore dentry;
         build_file_dentry(
-            obj_name_ino, file_size, file_mtime, guessed_layout, symlink,
-            remote_inode, &dentry);
+          obj_name_ino, file_size, file_mtime, guessed_layout, &dentry, symlink);
 
         // Inject inode to the metadata pool
         if (have_backtrace) {
@@ -1459,52 +1457,15 @@ int DataScan::scan_links()
               }
             }
           } else if (
-              dentry_type == 'L' || dentry_type == 'l' || dentry_type == 'R' ||
-              dentry_type == 'r') {
+              dentry_type == 'L' || dentry_type == 'l') {
             inodeno_t ino;
-            inodeno_t referent_ino;
-            InodeStore inode;
             unsigned char d_type;
-
-            if (dentry_type == 'r') {
-              DECODE_START(2, q);
-              if (struct_v >= 2)
-                decode(alternate_name, q);
-              dout(20) << "decoding referent inode dentry  type 'r' 0x"
-                       << std::hex << dir_ino << std::dec << "/" << dname
-                       << dendl;
-              inode.decode(q);
-              DECODE_FINISH(q);
-              ino = inode.inode->remote_ino;
-              referent_ino = inode.inode->ino;
-            } else if (dentry_type == 'R') {
-              dout(20) << "decoding referent inode dentry type 'R' 0x"
-                       << std::hex << dir_ino << std::dec << "/" << dname
-                       << dendl;
-              inode.decode_bare(q);
-              ino = inode.inode->remote_ino;
-              referent_ino = inode.inode->ino;
-            } else {
-              CDentry::decode_remote(
-                  dentry_type, ino, d_type, alternate_name, q);
-            }
+            CDentry::decode_remote(
+                dentry_type, ino, d_type, alternate_name, q);
 
             if (step == SCAN_INOS) {
-              dout(20) << "Add referent inode dentry 0x" << std::hex << dir_ino
-                       << std::dec << "/" << dname << " to used_inos" << dendl;
-              used_inos.insert(referent_ino);
-              dout(20) << "Add referent inode dentry 0x" << std::hex << dir_ino
-                       << std::dec << "/" << dname << " to remote_links"
-                       << dendl;
               remote_links[ino]++;
             } else if (step == CHECK_LINK) {
-              if (dnfirst == CEPH_NOSNAP) {
-                injected_inos.insert(
-                    {referent_ino,
-                     link_info_t(dir_ino, frag_id, dname, inode.inode)});
-                dout(20) << "Adding referent inode " << referent_ino
-                         << " for future processing to fix dnfirst" << dendl;
-              }
               if (!used_inos.contains(ino, 1)) {
                 derr << "Bad remote link dentry 0x" << std::hex << dir_ino
                      << std::dec << "/" << dname << ", ino " << ino
@@ -1983,8 +1944,8 @@ int MetadataTool::read_dentry(inodeno_t parent_ino, frag_t frag,
     decode(first, q);
     char dentry_type;
     decode(dentry_type, q);
-    if (dentry_type == 'I' || dentry_type == 'i' || dentry_type == 'R' || dentry_type == 'r') {
-      if (dentry_type == 'i' || dentry_type == 'r') {
+    if (dentry_type == 'I' || dentry_type == 'i') {
+      if (dentry_type == 'i') {
         mempool::mds_co::string alternate_name;
 
         DECODE_START(2, q);
@@ -2468,10 +2429,7 @@ int MetadataDriver::inject_linkage(
 
   bufferlist dentry_bl;
   encode(dnfirst, dentry_bl);
-  if (inode.inode->remote_ino)
-    encode('R', dentry_bl);
-  else
-    encode('I', dentry_bl);
+  encode('I', dentry_bl);
   inode.encode_bare(dentry_bl, CEPH_FEATURES_SUPPORTED_DEFAULT);
 
   // Write out
@@ -2646,8 +2604,7 @@ int LocalFileDriver::check_roots(bool *result)
 
 void MetadataTool::build_file_dentry(
     inodeno_t ino, uint64_t file_size, time_t file_mtime,
-    const file_layout_t &layout, std::string symlink, inodeno_t remote_inode,
-    InodeStore *out)
+    const file_layout_t &layout, InodeStore *out, std::string symlink)
 {
   ceph_assert(out != NULL);
 
@@ -2679,7 +2636,6 @@ void MetadataTool::build_file_dentry(
   inode->backtrace_version = 1;
   inode->uid = g_conf()->mds_root_ino_uid;
   inode->gid = g_conf()->mds_root_ino_gid;
-  inode->remote_ino = remote_inode;
 }
 
 void MetadataTool::build_dir_dentry(

diff --git a/src/tools/cephfs/DataScan.h b/src/tools/cephfs/DataScan.h
index ca14dd59a6bb03f06b26479b127d224731743739..dff82839aaa12648de9176e85c2e21a0904cbf79 100644 (file)
--- a/src/tools/cephfs/DataScan.h
+++ b/src/tools/cephfs/DataScan.h
@@ -157,9 +157,8 @@ class MetadataTool
   void build_file_dentry(
     inodeno_t ino, uint64_t file_size, time_t file_mtime,
     const file_layout_t &layout,
-    std::string symlink,
-    inodeno_t remote_inode,
-    InodeStore *out);
+    InodeStore *out,
+    std::string symlink);
 
   /**
    * Construct a synthetic InodeStore for a directory