forked from ceph/ceph
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
FileStore: introduce XfsFileStoreBackend class
Introduce XfsFileStoreBackend class, currently the only filestore backend implementing SETALLOCHINT op. This commit adds a build-time dependency on libxfs as xfs-specific ioctl (XFS_IOC_FSSETXATTR / XFS_XFLAG_EXTSIZE) is used to implement the new set_alloc_hint() method. Signed-off-by: Ilya Dryomov <[email protected]>
- Loading branch information
Showing
8 changed files
with
187 additions
and
3 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,124 @@ | ||
| // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- | ||
| // vim: ts=8 sw=2 smarttab | ||
| /* | ||
| * Ceph - scalable distributed file system | ||
| * | ||
| * Copyright (C) 2014 Inktank, Inc | ||
| * | ||
| * This is free software; you can redistribute it and/or | ||
| * modify it under the terms of the GNU Lesser General Public | ||
| * License version 2.1, as published by the Free Software | ||
| * Foundation. See file COPYING. | ||
| * | ||
| */ | ||
|
|
||
| #include "XfsFileStoreBackend.h" | ||
|
|
||
| #include <errno.h> | ||
| #include <fcntl.h> | ||
| #include <sys/ioctl.h> | ||
| #include <sys/stat.h> | ||
| #include <unistd.h> | ||
|
|
||
| #include <xfs/xfs.h> | ||
|
|
||
| #include "common/errno.h" | ||
| #include "include/assert.h" | ||
| #include "include/compat.h" | ||
|
|
||
| #define dout_subsys ceph_subsys_filestore | ||
| #undef dout_prefix | ||
| #define dout_prefix *_dout << "xfsfilestorebackend(" << get_basedir_path() << ") " | ||
|
|
||
| XfsFileStoreBackend::XfsFileStoreBackend(FileStore *fs): | ||
| GenericFileStoreBackend(fs), m_has_extsize(false) { } | ||
|
|
||
| /* | ||
| * Set extsize attr on a file to val. Should be a free-standing | ||
| * function, but dout_prefix expanding to a call to get_basedir_path() | ||
| * protected member function won't let it. | ||
| */ | ||
| int XfsFileStoreBackend::set_extsize(int fd, unsigned int val) | ||
| { | ||
| struct fsxattr fsx; | ||
| struct stat sb; | ||
| int ret; | ||
|
|
||
| if (fstat(fd, &sb) < 0) { | ||
| ret = -errno; | ||
| dout(0) << "set_extsize: fstat: " << cpp_strerror(ret) << dendl; | ||
| goto out; | ||
| } | ||
| if (!S_ISREG(sb.st_mode)) { | ||
| ret = -EINVAL; | ||
| dout(0) << "set_extsize: invalid target file type" << dendl; | ||
| goto out; | ||
| } | ||
|
|
||
| if (ioctl(fd, XFS_IOC_FSGETXATTR, &fsx) < 0) { | ||
| ret = -errno; | ||
| dout(0) << "set_extsize: FSGETXATTR: " << cpp_strerror(ret) << dendl; | ||
| goto out; | ||
| } | ||
|
|
||
| fsx.fsx_xflags |= XFS_XFLAG_EXTSIZE; | ||
| fsx.fsx_extsize = val; | ||
|
|
||
| if (ioctl(fd, XFS_IOC_FSSETXATTR, &fsx) < 0) { | ||
| ret = -errno; | ||
| dout(0) << "set_extsize: FSSETXATTR: " << cpp_strerror(ret) << dendl; | ||
| goto out; | ||
| } | ||
| ret = 0; | ||
|
|
||
| out: | ||
| return ret; | ||
| } | ||
|
|
||
| int XfsFileStoreBackend::detect_features() | ||
| { | ||
| int ret; | ||
|
|
||
| ret = GenericFileStoreBackend::detect_features(); | ||
| if (ret < 0) | ||
| return ret; | ||
|
|
||
| // extsize? | ||
| int fd = ::openat(get_basedir_fd(), "extsize_test", O_CREAT|O_WRONLY, 0600); | ||
| if (fd < 0) { | ||
| ret = -errno; | ||
| dout(0) << "detect_feature: failed to create test file for extsize attr: " | ||
| << cpp_strerror(ret) << dendl; | ||
| goto out; | ||
| } | ||
| if (::unlinkat(get_basedir_fd(), "extsize_test", 0) < 0) { | ||
| ret = -errno; | ||
| dout(0) << "detect_feature: failed to unlink test file for extsize attr: " | ||
| << cpp_strerror(ret) << dendl; | ||
| goto out_close; | ||
| } | ||
|
|
||
| ret = set_extsize(fd, 1U << 15); // a few pages | ||
| if (ret) { | ||
| ret = 0; | ||
| dout(0) << "detect_feature: failed to set test file extsize, assuming extsize is NOT supported" << dendl; | ||
| goto out_close; | ||
| } | ||
|
|
||
| dout(0) << "detect_feature: extsize is supported" << dendl; | ||
| m_has_extsize = true; | ||
|
|
||
| out_close: | ||
| TEMP_FAILURE_RETRY(::close(fd)); | ||
| out: | ||
| return ret; | ||
| } | ||
|
|
||
| int XfsFileStoreBackend::set_alloc_hint(int fd, uint64_t hint) | ||
| { | ||
| if (!m_has_extsize) | ||
| return -EOPNOTSUPP; | ||
|
|
||
| assert(hint < UINT_MAX); | ||
| return set_extsize(fd, hint); | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,33 @@ | ||
| // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- | ||
| // vim: ts=8 sw=2 smarttab | ||
| /* | ||
| * Ceph - scalable distributed file system | ||
| * | ||
| * Copyright (C) 2014 Inktank, Inc | ||
| * | ||
| * This is free software; you can redistribute it and/or | ||
| * modify it under the terms of the GNU Lesser General Public | ||
| * License version 2.1, as published by the Free Software | ||
| * Foundation. See file COPYING. | ||
| * | ||
| */ | ||
|
|
||
| #ifndef CEPH_XFSFILESTOREBACKEND_H | ||
| #define CEPH_XFSFILESTOREBACKEND_H | ||
|
|
||
| #include "GenericFileStoreBackend.h" | ||
|
|
||
| #include "include/int_types.h" | ||
|
|
||
| class XfsFileStoreBackend : public GenericFileStoreBackend { | ||
| private: | ||
| bool m_has_extsize; | ||
| int set_extsize(int fd, unsigned int val); | ||
| public: | ||
| XfsFileStoreBackend(FileStore *fs); | ||
| ~XfsFileStoreBackend() {}; | ||
| int detect_features(); | ||
| int set_alloc_hint(int fd, uint64_t hint); | ||
| }; | ||
|
|
||
| #endif /* CEPH_XFSFILESTOREBACKEND_H */ |