+/*
+ * GPL HEADER START
+ *
+ * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License version 2 only,
+ * as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * General Public License version 2 for more details (a copy is included
+ * in the LICENSE file that accompanied this code).
+ *
+ * You should have received a copy of the GNU General Public License
+ * version 2 along with this program; If not, see
+ * http://www.gnu.org/licenses/gpl-2.0.html
+ *
+ * GPL HEADER END
+ */
+/*
+ * Copyright (c) 2017, DataDirect Networks Storage.
+ * Copyright (c) 2017, Intel Corporation.
+ */
+/*
+ * This file is part of Lustre, http://www.lustre.org/
+ *
+ * lustre/utils/lfs_project.c
+ *
+ * Author: Wang Shilong <wshilong@ddn.com>
+ * Author: Fan Yong <fan.yong@intel.com>
+ */
+#include <errno.h>
+#include <getopt.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <strings.h>
+#include <unistd.h>
+#include <fcntl.h>
+#include <dirent.h>
+#include <stddef.h>
+#include <libintl.h>
+#include <sys/stat.h>
+#include <sys/types.h>
+#include <string.h>
+#include <libcfs/util/list.h>
+#include <libcfs/util/ioctl.h>
+#include <sys/ioctl.h>
+
+#include "lfs_project.h"
+#include <lustre/lustreapi.h>
+
+struct lfs_project_item {
+ struct list_head lpi_list;
+ char lpi_pathname[PATH_MAX];
+};
+
+static int
+lfs_project_item_alloc(struct list_head *head, const char *pathname)
+{
+ struct lfs_project_item *lpi;
+
+ lpi = malloc(sizeof(struct lfs_project_item));
+ if (lpi == NULL) {
+ fprintf(stderr,
+ "%s: cannot allocate project item for '%s': %s\n",
+ progname, pathname, strerror(ENOMEM));
+ return -ENOMEM;
+ }
+
+ strncpy(lpi->lpi_pathname, pathname, sizeof(lpi->lpi_pathname));
+ list_add_tail(&lpi->lpi_list, head);
+
+ return 0;
+}
+
+static int project_get_xattr(const char *pathname, struct fsxattr *fsx)
+{
+ int ret, fd;
+
+ fd = open(pathname, O_RDONLY | O_NOCTTY);
+ if (fd < 0) {
+ fprintf(stderr, "%s: failed to open '%s': %s\n",
+ progname, pathname, strerror(errno));
+ return -errno;
+ }
+
+ ret = ioctl(fd, LL_IOC_FSGETXATTR, fsx);
+ if (ret) {
+ fprintf(stderr, "%s: failed to get xattr for '%s': %s\n",
+ progname, pathname, strerror(errno));
+ return -errno;
+ }
+ return fd;
+}
+
+static int
+project_check_one(const char *pathname, struct project_handle_control *phc)
+{
+ struct fsxattr fsx;
+ struct stat st;
+ int ret;
+
+ 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);
+ if (ret < 0)
+ return ret;
+
+ /* use top directory's project ID if not specified */
+ if (!phc->assign_projid) {
+ phc->assign_projid = true;
+ phc->projid = fsx.fsx_projid;
+ }
+
+ if (!(fsx.fsx_xflags & LL_PROJINHERIT_FL)) {
+ if (!phc->newline) {
+ printf("%s%c", pathname, '\0');
+ goto out;
+ }
+ printf("%s - project inheritance flag is not set\n",
+ pathname);
+ }
+
+ if (fsx.fsx_projid != phc->projid) {
+ if (!phc->newline) {
+ printf("%s%c", pathname, '\0');
+ goto out;
+ }
+ printf("%s - project identifier is not set (inode=%u, tree=%u)\n",
+ pathname, fsx.fsx_projid, phc->projid);
+ }
+out:
+ close(ret);
+ return 0;
+}
+
+static int
+project_list_one(const char *pathname, struct project_handle_control *phc)
+{
+ struct fsxattr fsx;
+ int ret;
+
+ ret = project_get_xattr(pathname, &fsx);
+ if (ret < 0)
+ return ret;
+
+ printf("%5u %c %s\n", fsx.fsx_projid,
+ (fsx.fsx_xflags & LL_PROJINHERIT_FL) ?
+ 'P' : '-', pathname);
+
+ close(ret);
+ return 0;
+}
+
+static int
+project_set_one(const char *pathname, struct project_handle_control *phc)
+{
+ struct fsxattr fsx;
+ int fd, ret = 0;
+
+ fd = project_get_xattr(pathname, &fsx);
+ if (fd < 0)
+ return fd;
+
+ if ((!phc->set_projid || fsx.fsx_projid == phc->projid) &&
+ (!phc->set_inherit || (fsx.fsx_xflags & LL_PROJINHERIT_FL)))
+ goto out;
+
+ if (phc->set_inherit)
+ fsx.fsx_xflags |= LL_PROJINHERIT_FL;
+ if (phc->set_projid)
+ fsx.fsx_projid = phc->projid;
+
+ ret = ioctl(fd, LL_IOC_FSSETXATTR, &fsx);
+ if (ret)
+ fprintf(stderr, "%s: failed to set xattr for '%s': %s\n",
+ progname, pathname, strerror(errno));
+out:
+ close(fd);
+ return ret;
+}
+
+static int
+project_clear_one(const char *pathname, struct project_handle_control *phc)
+{
+ struct fsxattr fsx;
+ int ret = 0, fd;
+
+ fd = project_get_xattr(pathname, &fsx);
+ if (fd < 0)
+ return fd;
+
+ if ((!(fsx.fsx_xflags & LL_PROJINHERIT_FL)) &&
+ (fsx.fsx_projid == 0 || phc->keep_projid))
+ goto out;
+
+ fsx.fsx_xflags &= ~LL_PROJINHERIT_FL;
+ if (!phc->keep_projid)
+ fsx.fsx_projid = 0;
+
+ ret = ioctl(fd, LL_IOC_FSSETXATTR, &fsx);
+ if (ret)
+ fprintf(stderr, "%s: failed to set xattr for '%s': %s\n",
+ progname, pathname, strerror(errno));
+out:
+ close(fd);
+ return ret;
+}
+
+static int
+lfs_project_handle_dir(struct list_head *head, const char *pathname,
+ struct project_handle_control *phc,
+ int (*func)(const char *,
+ struct project_handle_control *))
+{
+ char fullname[PATH_MAX];
+ struct dirent *ent;
+ DIR *dir;
+ int ret = 0;
+
+ dir = opendir(pathname);
+ if (dir == NULL) {
+ ret = -errno;
+ fprintf(stderr, "%s: failed to opendir '%s': %s\n",
+ progname, pathname, strerror(-ret));
+ return ret;
+ }
+
+ while (ret == 0 && (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) {
+ ret = -ENAMETOOLONG;
+ errno = ENAMETOOLONG;
+ break;
+ }
+ 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);
+ }
+
+ if (ret)
+ fprintf(stderr, "%s: failed to handle dir '%s': %s\n",
+ progname, pathname, strerror(errno));
+
+ closedir(dir);
+ return ret;
+}
+
+static int lfs_project_iterate(const char *pathname,
+ struct project_handle_control *phc,
+ int (*func)(const char *,
+ struct project_handle_control *))
+{
+ struct lfs_project_item *lpi;
+ struct list_head head;
+ struct stat st;
+ int ret = 0;
+ bool top_dir = true;
+
+ ret = stat(pathname, &st);
+ if (ret) {
+ fprintf(stderr, "%s: failed to stat '%s': %s\n",
+ progname, pathname, strerror(errno));
+ return ret;
+ }
+
+ /* list opeation will skip top directory in default */
+ if (!S_ISDIR(st.st_mode) || phc->dironly ||
+ project_list_one != func)
+ ret = func(pathname, phc);
+
+ /* dironly first, recursive will be ignored */
+ if (!S_ISDIR(st.st_mode) || phc->dironly || ret)
+ return ret;
+
+ INIT_LIST_HEAD(&head);
+ ret = lfs_project_item_alloc(&head, pathname);
+ if (ret)
+ return 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;
+ }
+ free(lpi);
+ top_dir = false;
+ }
+
+ return ret;
+}
+
+
+inline 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)
+{
+ return lfs_project_iterate(pathname, phc, project_clear_one);
+}
+
+inline 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)
+{
+ return lfs_project_iterate(pathname, phc, project_list_one);
+}
git://git.whamcloud.com / fs / lustre-release.git / commitdiff