/* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
* vim:expandtab:shiftwidth=8:tabstop=8:
*
- * Copyright (C) 2004-2006 Cluster File Systems, Inc.
- * Author: Lai Siyao <lsy@clusterfs.com>
- * Author: Fan Yong <fanyong@clusterfs.com>
+ * GPL HEADER START
*
- * This file is part of the Lustre file system, http://www.lustre.org
- * Lustre is a trademark of Cluster File Systems, Inc.
+ * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
- * You may have signed or agreed to another license before downloading
- * this software. If so, you are bound by the terms and conditions
- * of that agreement, and the following does not apply to you. See the
- * LICENSE file included with this distribution for more information.
+ * 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.
*
- * If you did not agree to a different license, then this copy of Lustre
- * is open source software; you can redistribute it and/or modify it
- * under the terms of version 2 of the GNU General Public License 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).
*
- * In either case, Lustre 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
- * license text for more details.
+ * You should have received a copy of the GNU General Public License
+ * version 2 along with this program; If not, see
+ * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
*
+ * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
+ * CA 95054 USA or visit www.sun.com if you need additional information or
+ * have any questions.
+ *
+ * GPL HEADER END
+ */
+/*
+ * Copyright 2008 Sun Microsystems, Inc. All rights reserved
+ * Use is subject to license terms.
+ */
+/*
+ * This file is part of Lustre, http://www.lustre.org/
+ * Lustre is a trademark of Sun Microsystems, Inc.
+ *
+ * lustre/mdt/mdt_lproc.c
+ *
+ * Author: Lai Siyao <lsy@clusterfs.com>
+ * Author: Fan Yong <fanyong@clusterfs.com>
*/
#ifndef EXPORT_SYMTAB
#include <lprocfs_status.h>
#include <lu_time.h>
#include "mdt_internal.h"
+#include <lnet/lib-lnet.h>
static const char *mdt_proc_names[LPROC_MDT_NR] = {
};
{
struct obd_device *obd = data;
struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
+ struct upcall_cache *hash = mdt->mdt_identity_cache;
+ int len;
*eof = 1;
- return snprintf(page, count, "%s\n",
- mdt->mdt_identity_cache->uc_upcall);
+ read_lock(&hash->uc_upcall_rwlock);
+ len = snprintf(page, count, "%s\n", hash->uc_upcall);
+ read_unlock(&hash->uc_upcall_rwlock);
+ return len;
}
static int lprocfs_wr_identity_upcall(struct file *file, const char *buffer,
return -EINVAL;
}
- if (copy_from_user(kernbuf, buffer,
- min(count, UC_CACHE_UPCALL_MAXPATH - 1)))
+ if (copy_from_user(kernbuf, buffer, min_t(unsigned long, count,
+ UC_CACHE_UPCALL_MAXPATH - 1)))
return -EFAULT;
/* Remove any extraneous bits from the upcall (e.g. linefeeds) */
+ write_lock(&hash->uc_upcall_rwlock);
sscanf(kernbuf, "%s", hash->uc_upcall);
+ write_unlock(&hash->uc_upcall_rwlock);
if (strcmp(hash->uc_name, obd->obd_name) != 0)
CWARN("%s: write to upcall name %s\n",
obd->obd_name, hash->uc_upcall);
- CWARN("%s: identity upcall set to %s\n", obd->obd_name, hash->uc_upcall);
+ if (strcmp(hash->uc_upcall, "NONE") == 0 && mdt->mdt_opts.mo_acl)
+ CWARN("%s: disable \"identity_upcall\" with ACL enabled maybe "
+ "cause unexpected \"EACCESS\"\n", obd->obd_name);
+
+ CWARN("%s: identity upcall set to %s\n", obd->obd_name, hash->uc_upcall);
return count;
}
{
struct obd_device *obd = data;
struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
- struct lu_site *s = mdt->mdt_md_dev.md_lu_dev.ld_site;
- int i;
- int populated;
-
- /*
- * How many hash buckets are not-empty? Don't bother with locks: it's
- * an estimation anyway.
- */
- for (i = 0, populated = 0; i < s->ls_hash_size; i++)
- populated += !hlist_empty(&s->ls_hash[i]);
-
- return snprintf(page, count, "%d %d %d/%d %d %d %d %d %d %d\n",
- s->ls_total,
- s->ls_busy,
- populated,
- s->ls_hash_size,
- s->ls_stats.s_created,
- s->ls_stats.s_cache_hit,
- s->ls_stats.s_cache_miss,
- s->ls_stats.s_cache_check,
- s->ls_stats.s_cache_race,
- s->ls_stats.s_lru_purged);
+
+ return lu_site_stats_print(mdt_lu_site(mdt), page, count);
}
static int lprocfs_rd_capa_timeout(char *page, char **start, off_t off,
return count;
}
+static int lprocfs_rd_sec_level(char *page, char **start, off_t off,
+ int count, int *eof, void *data)
+{
+ struct obd_device *obd = data;
+ struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
+
+ return snprintf(page, count, "%d\n", mdt->mdt_sec_level);
+}
+
+static int lprocfs_wr_sec_level(struct file *file, const char *buffer,
+ unsigned long count, void *data)
+{
+ struct obd_device *obd = data;
+ struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
+ int val, rc;
+
+ rc = lprocfs_write_helper(buffer, count, &val);
+ if (rc)
+ return rc;
+
+ if (val > LUSTRE_SEC_ALL || val < LUSTRE_SEC_NONE)
+ return -EINVAL;
+
+ if (val == LUSTRE_SEC_SPECIFY) {
+ CWARN("security level %d will be supported in future.\n",
+ LUSTRE_SEC_SPECIFY);
+ return -EINVAL;
+ }
+
+ mdt->mdt_sec_level = val;
+ return count;
+}
+
+static int lprocfs_rd_cos(char *page, char **start, off_t off,
+ int count, int *eof, void *data)
+{
+ struct obd_device *obd = data;
+ struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
+
+ return snprintf(page, count, "%u\n", mdt_cos_is_enabled(mdt));
+}
+
+static int lprocfs_wr_cos(struct file *file, const char *buffer,
+ unsigned long count, void *data)
+{
+ struct obd_device *obd = data;
+ struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
+ int val, rc;
+
+ rc = lprocfs_write_helper(buffer, count, &val);
+ if (rc)
+ return rc;
+ mdt_enable_cos(mdt, val);
+ return count;
+}
+
+static int lprocfs_rd_root_squash(char *page, char **start, off_t off,
+ int count, int *eof, void *data)
+{
+ struct obd_device *obd = data;
+ struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
+ ENTRY;
+
+ return snprintf(page, count, "%u:%u\n", mdt->mdt_squash_uid,
+ mdt->mdt_squash_gid);
+}
+
+static int safe_strtoul(const char *str, char **endp, unsigned long *res)
+{
+ char n[24];
+
+ *res = simple_strtoul(str, endp, 0);
+ if (str == *endp)
+ return 1;
+
+ sprintf(n, "%lu", *res);
+ if (strncmp(n, str, *endp - str))
+ /* overflow */
+ return 1;
+ return 0;
+}
+
+static int lprocfs_wr_root_squash(struct file *file, const char *buffer,
+ unsigned long count, void *data)
+{
+ struct obd_device *obd = data;
+ struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
+ char kernbuf[50], *tmp, *end;
+ unsigned long uid, gid;
+ int nouid, nogid;
+ ENTRY;
+
+ if (count > (sizeof(kernbuf) - 1) ||
+ copy_from_user(kernbuf, buffer, count)) {
+ CWARN("%s: can't copy string to kernel space, "
+ "uid:gid is expected, "
+ "continue with %u:%u, "
+ "there will be 0:0 on MDS restart\n",
+ obd->obd_name, mdt->mdt_squash_uid,
+ mdt->mdt_squash_gid);
+ RETURN(count);
+ }
+
+ if (copy_from_user(kernbuf, buffer, count))
+ RETURN(-EFAULT);
+
+ kernbuf[count] = '\0';
+
+ nouid = nogid = 0;
+ if (safe_strtoul(buffer, &tmp, &uid)) {
+ uid = mdt->mdt_squash_uid;
+ nouid = 1;
+ }
+
+ /* skip ':' */
+ if (*tmp == ':') {
+ tmp++;
+ if (safe_strtoul(tmp, &end, &gid)) {
+ gid = mdt->mdt_squash_gid;
+ nogid = 1;
+ }
+ } else {
+ gid = mdt->mdt_squash_gid;
+ nogid = 1;
+ }
+
+ mdt->mdt_squash_uid = uid;
+ mdt->mdt_squash_gid = gid;
+
+ if (nouid || nogid)
+ CWARN("%s: can't parse \"\%s\", uid:gid is expected, "
+ "continue with %u:%u, "
+ "there will be %u:%u on MDS restart\n",
+ obd->obd_name,
+ buffer, mdt->mdt_squash_uid, mdt->mdt_squash_gid,
+ nouid ? 0 : mdt->mdt_squash_uid,
+ nogid ? 0 : mdt->mdt_squash_gid);
+ else
+ LCONSOLE_INFO("%s: root_squash is set to %u:%u\n",
+ obd->obd_name,
+ mdt->mdt_squash_uid, mdt->mdt_squash_gid);
+ RETURN(count);
+}
+
+static int lprocfs_rd_nosquash_nids(char *page, char **start, off_t off,
+ int count, int *eof, void *data)
+{
+ struct obd_device *obd = data;
+ struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
+
+ if (mdt->mdt_nosquash_str)
+ return snprintf(page, count, "%s\n", mdt->mdt_nosquash_str);
+ return snprintf(page, count, "NONE\n");
+}
+
+static int lprocfs_wr_nosquash_nids(struct file *file, const char *buffer,
+ unsigned long count, void *data)
+{
+ struct obd_device *obd = data;
+ struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
+ int rc;
+ char *new;
+ struct list_head tmp;
+ ENTRY;
+
+ /* copy to kernel space */
+ OBD_ALLOC(new, count + 1);
+ if (new == 0)
+ GOTO(failed, rc = -ENOMEM);
+
+ if (copy_from_user(new, buffer, count))
+ GOTO(failed, rc = -EFAULT);
+
+ new[count] = 0;
+ if (strlen(new) != count)
+ GOTO(failed, rc = -EINVAL);
+
+ if (!strcmp(new, "NONE") || !strcmp(new, "clear")) {
+ /* empty string is special case */
+ down_write(&mdt->mdt_squash_sem);
+ if (!list_empty(&mdt->mdt_nosquash_nids)) {
+ cfs_free_nidlist(&mdt->mdt_nosquash_nids);
+ OBD_FREE(mdt->mdt_nosquash_str,
+ mdt->mdt_nosquash_strlen);
+ mdt->mdt_nosquash_str = NULL;
+ mdt->mdt_nosquash_strlen = 0;
+ }
+ up_write(&mdt->mdt_squash_sem);
+ LCONSOLE_INFO("%s: nosquash_nids is cleared\n",
+ obd->obd_name);
+ OBD_FREE(new, count + 1);
+ RETURN(0);
+ }
+
+ CFS_INIT_LIST_HEAD(&tmp);
+ if (cfs_parse_nidlist(new, count, &tmp) <= 0)
+ GOTO(failed, rc = -EINVAL);
+
+ down_write(&mdt->mdt_squash_sem);
+ if (!list_empty(&mdt->mdt_nosquash_nids)) {
+ cfs_free_nidlist(&mdt->mdt_nosquash_nids);
+ OBD_FREE(mdt->mdt_nosquash_str, mdt->mdt_nosquash_strlen);
+ }
+ mdt->mdt_nosquash_str = new;
+ mdt->mdt_nosquash_strlen = count + 1;
+ list_splice(&tmp, &mdt->mdt_nosquash_nids);
+
+ LCONSOLE_INFO("%s: nosquash_nids is set to %s\n", obd->obd_name, new);
+ up_write(&mdt->mdt_squash_sem);
+ RETURN(count);
+
+ failed:
+ CWARN("%s: failed to set nosquash_nids (rc %d), "
+ "on MDS restart we will try to set it again, "
+ "continue with current nosquash_nids\n",
+ obd->obd_name, rc);
+ if (new)
+ OBD_FREE(new, count + 1);
+ RETURN(count);
+}
+
static struct lprocfs_vars lprocfs_mdt_obd_vars[] = {
{ "uuid", lprocfs_rd_uuid, 0, 0 },
{ "recovery_status", lprocfs_obd_rd_recovery_status, 0, 0 },
{ "capa_count", lprocfs_rd_capa_count, 0, 0 },
{ "site_stats", lprocfs_rd_site_stats, 0, 0 },
{ "evict_client", 0, lprocfs_mdt_wr_evict_client, 0 },
+ { "hash_stats", lprocfs_obd_rd_hash, 0, 0 },
+ { "sec_level", lprocfs_rd_sec_level,
+ lprocfs_wr_sec_level, 0 },
+ { "commit_on_sharing", lprocfs_rd_cos, lprocfs_wr_cos, 0 },
+ { "root_squash", lprocfs_rd_root_squash,
+ lprocfs_wr_root_squash, 0 },
+ { "nosquash_nids", lprocfs_rd_nosquash_nids,
+ lprocfs_wr_nosquash_nids, 0 },
{ 0 }
};
git://git.whamcloud.com / fs / lustre-release.git / blobdiff