Method file_blockdiff

src/client/Client.cc:10406–10467

}

int Client::file_blockdiff(struct scan_state_t *state, const UserPerm &perms,
			   std::vector<std::pair<uint64_t,uint64_t>> *blocks)
{
  RWRef_t mref_reader(mount_state, CLIENT_MOUNTING);
  if (!mref_reader.is_state_satisfied()) {
    return -ENOTCONN;
  }

  ldout(cct, 20) << __func__ << dendl;

  InodeRef inode1;
  InodeRef inode2;

  std::unique_lock lock(client_lock);

  int r = get_fd_inode(state->fd1, &inode1);
  if (r < 0) {
    return r;
  }
  r = get_fd_inode(state->fd2, &inode2);
  if (r < 0) {
    return r;
  }

  ceph_assert(inode1->ino == inode2->ino);

  MetaRequest *req = new MetaRequest(CEPH_MDS_OP_FILE_BLOCKDIFF);

  filepath path1, path2;
  inode1->make_nosnap_relative_path(path1);
  req->set_filepath(path1);

  inode2->make_nosnap_relative_path(path2);
  req->set_filepath2(path2);
  req->set_inode(inode2.get());

  req->head.args.blockdiff.scan_idx = state->index;
  req->head.args.blockdiff.max_objects =
    cct->_conf.get_val<uint64_t>("client_file_blockdiff_max_concurrent_object_scans");

  bufferlist bl;
  r = make_request(req, perms, nullptr, nullptr, -1, &bl, CEPHFS_FEATURE_BLOCKDIFF);
  ldout(cct, 10) << __func__ << ": result=" << r << dendl;

  if (r < 0) {
    return r;
  }

  BlockDiff block_diff;
  auto p = bl.cbegin();
  decode(block_diff, p);

  ldout(cct, 10) << __func__ << ": block_diff=" << block_diff << dendl;
  if (!block_diff.blocks.empty()) {
    for (auto &block : block_diff.blocks) {
      blocks->emplace_back(std::make_pair(block.first, block.second));
    }
  }