#include <libcfs/util/list.h>
#include <libcfs/util/ioctl.h>
#include <sys/ioctl.h>
+#include <libgen.h>
#include "lfs_project.h"
#include <lustre/lustreapi.h>
+const char *progname;
+
struct lfs_project_item {
struct list_head lpi_list;
- char lpi_pathname[PATH_MAX];
+ char *lpi_pathname;
};
static int
return -ENOMEM;
}
- strncpy(lpi->lpi_pathname, pathname, sizeof(lpi->lpi_pathname));
- list_add_tail(&lpi->lpi_list, head);
+ lpi->lpi_pathname = strdup(pathname);
+ if (!lpi->lpi_pathname) {
+ free(lpi);
+ return -ENOMEM;
+ } else
+ list_add_tail(&lpi->lpi_list, head);
return 0;
}
-static int project_get_xattr(const char *pathname, struct fsxattr *fsx)
+static int project_get_fsxattr(const char *pathname, struct fsxattr *fsx,
+ struct stat *st, char *ret_bname)
{
- int ret, fd;
+ int ret = 0, fd = -1;
+ char dname_path[PATH_MAX + 1] = { 0 };
+ char bname_path[PATH_MAX + 1] = { 0 };
+ char *dname, *bname;
+ struct lu_project lu_project = { 0 };
+
+ ret = lstat(pathname, st);
+ if (ret) {
+ fprintf(stderr, "%s: failed to stat '%s': %s\n",
+ progname, pathname, strerror(errno));
+ ret = -errno;
+ goto out;
+ }
+
+ /* currently, only file and dir supported */
+ if (!S_ISREG(st->st_mode) && !S_ISDIR(st->st_mode))
+ goto new_api;
- fd = open(pathname, O_RDONLY | O_NOCTTY);
+ fd = open(pathname, O_RDONLY | O_NOCTTY | O_NDELAY);
if (fd < 0) {
fprintf(stderr, "%s: failed to open '%s': %s\n",
progname, pathname, strerror(errno));
- return -errno;
+ ret = -errno;
+ goto out;
}
- ret = ioctl(fd, LL_IOC_FSGETXATTR, fsx);
+ ret = ioctl(fd, FS_IOC_FSGETXATTR, fsx);
+ if (ret) {
+ fprintf(stderr, "%s: failed to get xattr for '%s': %s\n",
+ progname, pathname, strerror(errno));
+ ret = -errno;
+ }
+ goto out;
+new_api:
+ strncpy(dname_path, pathname, PATH_MAX);
+ strncpy(bname_path, pathname, PATH_MAX);
+ dname = dirname(dname_path);
+ bname = basename(bname_path);
+ fd = open(dname, O_RDONLY | O_NOCTTY | O_NDELAY);
+ if (fd < 0) {
+ ret = -errno;
+ goto out;
+ }
+ lu_project.project_type = LU_PROJECT_GET;
+ if (bname) {
+ strncpy(lu_project.project_name, bname, NAME_MAX);
+ if (ret_bname)
+ strncpy(ret_bname, bname, NAME_MAX);
+ }
+ ret = ioctl(fd, LL_IOC_PROJECT, &lu_project);
if (ret) {
fprintf(stderr, "%s: failed to get xattr for '%s': %s\n",
progname, pathname, strerror(errno));
- return -errno;
+ ret = -errno;
+ } else {
+ fsx->fsx_xflags = lu_project.project_xflags;
+ fsx->fsx_projid = lu_project.project_id;
}
- return fd;
+out:
+ if (ret && fd >= 0)
+ close(fd);
+ return ret ? ret : fd;
}
static int
project_check_one(const char *pathname, struct project_handle_control *phc)
{
struct fsxattr fsx;
- struct stat st;
int ret;
+ struct stat st;
- ret = stat(pathname, &st);
- if (ret) {
- fprintf(stderr, "%s: failed to stat '%s': %s\n",
- progname, pathname, strerror(errno));
- return -errno;
- }
-
- ret = project_get_xattr(pathname, &fsx);
+ ret = project_get_fsxattr(pathname, &fsx, &st, NULL);
if (ret < 0)
return ret;
phc->projid = fsx.fsx_projid;
}
- if (!(fsx.fsx_xflags & LL_PROJINHERIT_FL)) {
+ if (!(fsx.fsx_xflags & FS_XFLAG_PROJINHERIT) &&
+ S_ISDIR(st.st_mode)) {
if (!phc->newline) {
printf("%s%c", pathname, '\0');
goto out;
project_list_one(const char *pathname, struct project_handle_control *phc)
{
struct fsxattr fsx;
+ struct stat st;
int ret;
- ret = project_get_xattr(pathname, &fsx);
+ ret = project_get_fsxattr(pathname, &fsx, &st, NULL);
if (ret < 0)
return ret;
printf("%5u %c %s\n", fsx.fsx_projid,
- (fsx.fsx_xflags & LL_PROJINHERIT_FL) ?
+ (fsx.fsx_xflags & FS_XFLAG_PROJINHERIT) ?
'P' : '-', pathname);
close(ret);
project_set_one(const char *pathname, struct project_handle_control *phc)
{
struct fsxattr fsx;
+ struct stat st;
int fd, ret = 0;
+ char bname[NAME_MAX + 1] = { 0 };
+ struct lu_project lp = { 0 };
- fd = project_get_xattr(pathname, &fsx);
+ fd = project_get_fsxattr(pathname, &fsx, &st, bname);
if (fd < 0)
return fd;
if ((!phc->set_projid || fsx.fsx_projid == phc->projid) &&
- (!phc->set_inherit || (fsx.fsx_xflags & LL_PROJINHERIT_FL)))
+ (!phc->set_inherit || (fsx.fsx_xflags & FS_XFLAG_PROJINHERIT)))
goto out;
if (phc->set_inherit)
- fsx.fsx_xflags |= LL_PROJINHERIT_FL;
+ fsx.fsx_xflags |= FS_XFLAG_PROJINHERIT;
if (phc->set_projid)
fsx.fsx_projid = phc->projid;
- ret = ioctl(fd, LL_IOC_FSSETXATTR, &fsx);
+ if (S_ISREG(st.st_mode) || S_ISDIR(st.st_mode)) {
+ ret = ioctl(fd, FS_IOC_FSSETXATTR, &fsx);
+ } else {
+ lp.project_xflags = fsx.fsx_xflags;
+ lp.project_id = fsx.fsx_projid;
+ lp.project_type = LU_PROJECT_SET;
+ strncpy(lp.project_name, bname, NAME_MAX);
+ lp.project_name[NAME_MAX] = '\0';
+ ret = ioctl(fd, LL_IOC_PROJECT, &lp);
+ }
+out:
if (ret)
fprintf(stderr, "%s: failed to set xattr for '%s': %s\n",
progname, pathname, strerror(errno));
-out:
close(fd);
return ret;
}
project_clear_one(const char *pathname, struct project_handle_control *phc)
{
struct fsxattr fsx;
+ struct stat st;
int ret = 0, fd;
+ char bname[NAME_MAX + 1] = { 0 };
+ struct lu_project lp = { 0 };
- fd = project_get_xattr(pathname, &fsx);
+ fd = project_get_fsxattr(pathname, &fsx, &st, bname);
if (fd < 0)
return fd;
- if ((!(fsx.fsx_xflags & LL_PROJINHERIT_FL)) &&
+ if ((!(fsx.fsx_xflags & FS_XFLAG_PROJINHERIT)) &&
(fsx.fsx_projid == 0 || phc->keep_projid))
goto out;
- fsx.fsx_xflags &= ~LL_PROJINHERIT_FL;
+ fsx.fsx_xflags &= ~FS_XFLAG_PROJINHERIT;
if (!phc->keep_projid)
fsx.fsx_projid = 0;
- ret = ioctl(fd, LL_IOC_FSSETXATTR, &fsx);
+ if (S_ISREG(st.st_mode) || S_ISDIR(st.st_mode)) {
+ ret = ioctl(fd, FS_IOC_FSSETXATTR, &fsx);
+ } else {
+ lp.project_xflags = fsx.fsx_xflags;
+ lp.project_id = fsx.fsx_projid;
+ lp.project_type = LU_PROJECT_SET;
+ strncpy(lp.project_name, bname, NAME_MAX);
+ lp.project_name[NAME_MAX] = '\0';
+ ret = ioctl(fd, LL_IOC_PROJECT, &lp);
+ }
if (ret)
fprintf(stderr, "%s: failed to set xattr for '%s': %s\n",
progname, pathname, strerror(errno));
struct dirent *ent;
DIR *dir;
int ret = 0;
+ int rc;
dir = opendir(pathname);
if (dir == NULL) {
return ret;
}
- while (ret == 0 && (ent = readdir(dir)) != NULL) {
+ while ((ent = readdir(dir)) != NULL) {
/* skip "." and ".." */
if (strcmp(ent->d_name, ".") == 0 ||
strcmp(ent->d_name, "..") == 0)
continue;
- if (strlen(ent->d_name) + strlen(pathname) >=
- sizeof(fullname) + 1) {
+ if (strlen(ent->d_name) + strlen(pathname) + 1 >=
+ sizeof(fullname)) {
ret = -ENAMETOOLONG;
errno = ENAMETOOLONG;
- break;
+ fprintf(stderr, "%s: ignored too long path: %s/%s\n",
+ progname, pathname, ent->d_name);
+ continue;
}
snprintf(fullname, PATH_MAX, "%s/%s", pathname,
ent->d_name);
- ret = func(fullname, phc);
- if (phc->recursive && ret == 0 && ent->d_type == DT_DIR)
- ret = lfs_project_item_alloc(head, fullname);
+ rc = func(fullname, phc);
+ if (rc && !ret)
+ ret = rc;
+ if (phc->recursive && ent->d_type == DT_DIR) {
+ rc = lfs_project_item_alloc(head, fullname);
+ if (rc && !ret)
+ ret = rc;
+ }
}
- if (ret)
- fprintf(stderr, "%s: failed to handle dir '%s': %s\n",
- progname, pathname, strerror(errno));
-
closedir(dir);
return ret;
}
struct list_head head;
struct stat st;
int ret = 0;
- bool top_dir = true;
+ int rc = 0;
ret = stat(pathname, &st);
if (ret) {
while (!list_empty(&head)) {
lpi = list_entry(head.next, struct lfs_project_item, lpi_list);
list_del(&lpi->lpi_list);
- if (ret == 0) {
- ret = lfs_project_handle_dir(&head, lpi->lpi_pathname,
- phc, func);
- /* only ignore ENOENT error if this is
- * not top directory. */
- if (ret == -ENOENT && !top_dir)
- ret = 0;
- }
+ rc = lfs_project_handle_dir(&head, lpi->lpi_pathname,
+ phc, func);
+ if (!ret && rc)
+ ret = rc;
+ free(lpi->lpi_pathname);
free(lpi);
- top_dir = false;
}
return ret;
}
-inline int lfs_project_check(const char *pathname,
- struct project_handle_control *phc)
+int lfs_project_check(const char *pathname,
+ struct project_handle_control *phc)
{
return lfs_project_iterate(pathname, phc, project_check_one);
}
-inline int lfs_project_clear(const char *pathname,
- struct project_handle_control *phc)
+int lfs_project_clear(const char *pathname,
+ struct project_handle_control *phc)
{
return lfs_project_iterate(pathname, phc, project_clear_one);
}
-inline int lfs_project_set(const char *pathname,
- struct project_handle_control *phc)
+int lfs_project_set(const char *pathname,
+ struct project_handle_control *phc)
{
return lfs_project_iterate(pathname, phc, project_set_one);
}
-inline int lfs_project_list(const char *pathname,
- struct project_handle_control *phc)
+int lfs_project_list(const char *pathname,
+ struct project_handle_control *phc)
{
return lfs_project_iterate(pathname, phc, project_list_one);
}
git://git.whamcloud.com / fs / lustre-release.git / blobdiff