X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Fmdt%2Fmdt_fs.c;h=a5b0df37bab2198787144b8adf4bd0fe295729fd;hb=e2e7ea06c66d57ba214cd76e3d19420632aba8dd;hp=8621475e3cde96ee916e5dc99c2a992e87a64593;hpb=0bb171673e30fa3271b851f6274ca9cdb8f5e55f;p=fs%2Flustre-release.git diff --git a/lustre/mdt/mdt_fs.c b/lustre/mdt/mdt_fs.c index 8621475..a5b0df3 100644 --- a/lustre/mdt/mdt_fs.c +++ b/lustre/mdt/mdt_fs.c @@ -27,7 +27,7 @@ * Copyright (c) 2008, 2010, Oracle and/or its affiliates. All rights reserved. * Use is subject to license terms. * - * Copyright (c) 2011, Intel Corporation. + * Copyright (c) 2011, 2013, Intel Corporation. */ /* * This file is part of Lustre, http://www.lustre.org/ @@ -42,41 +42,67 @@ #include "mdt_internal.h" -int mdt_export_stats_init(struct obd_device *obd, - struct obd_export *exp, - void *localdata) +static const struct file_operations mdt_open_files_seq_fops = { + .owner = THIS_MODULE, + .open = lprocfs_mdt_open_files_seq_open, + .read = seq_read, + .llseek = seq_lseek, + .release = seq_release, +}; + +/** + * Initialize MDT per-export statistics. + * + * This function sets up procfs entries for various MDT export counters. These + * counters are for per-client statistics tracked on the server. + * + * \param[in] obd OBD device + * \param[in] exp OBD export + * \param[in] localdata NID of client + * + * \retval 0 if successful + * \retval negative value on error + */ +int mdt_export_stats_init(struct obd_device *obd, struct obd_export *exp, + void *localdata) { - lnet_nid_t *client_nid = localdata; - int rc, newnid; - ENTRY; + lnet_nid_t *client_nid = localdata; + struct nid_stat *stats; + int rc; + ENTRY; LASSERT(!obd->obd_uses_nid_stats); - rc = lprocfs_exp_setup(exp, client_nid, &newnid); - if (rc) { - /* Mask error for already created - * /proc entries */ - if (rc == -EALREADY) - rc = 0; - RETURN(rc); - } - if (newnid) { - struct nid_stat *tmp = exp->exp_nid_stats; + rc = lprocfs_exp_setup(exp, client_nid); + if (rc != 0) + /* Mask error for already created /proc entries */ + RETURN(rc == -EALREADY ? 0 : rc); - tmp->nid_stats = lprocfs_alloc_stats(LPROC_MDT_LAST, + stats = exp->exp_nid_stats; + stats->nid_stats = lprocfs_alloc_stats(LPROC_MDT_LAST, LPROCFS_STATS_FLAG_NOPERCPU); - if (tmp->nid_stats == NULL) - RETURN(-ENOMEM); - mdt_stats_counter_init(tmp->nid_stats); - rc = lprocfs_register_stats(tmp->nid_proc, "stats", - tmp->nid_stats); - if (rc) - GOTO(clean, rc); - rc = lprocfs_nid_ldlm_stats_init(tmp); - if (rc) - GOTO(clean, rc); - } - RETURN(0); - clean: - return rc; + if (stats->nid_stats == NULL) + RETURN(-ENOMEM); + + mdt_stats_counter_init(stats->nid_stats); + + rc = lprocfs_register_stats(stats->nid_proc, "stats", stats->nid_stats); + if (rc != 0) { + lprocfs_free_stats(&stats->nid_stats); + GOTO(out, rc); + } + + rc = lprocfs_nid_ldlm_stats_init(stats); + if (rc != 0) + GOTO(out, rc); + + rc = lprocfs_seq_create(stats->nid_proc, "open_files", + 0444, &mdt_open_files_seq_fops, stats); + if (rc != 0) { + CWARN("%s: error adding the open_files file: rc = %d\n", + obd->obd_name, rc); + GOTO(out, rc); + } +out: + RETURN(rc); }