lustre/mdt/mdt_lproc.c

   1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
   2  * vim:expandtab:shiftwidth=8:tabstop=8:
   3  *
   4  * Copyright (C) 2004-2006 Cluster File Systems, Inc.
   5  *   Author: Lai Siyao <lsy@clusterfs.com>
   6  *   Author: Fan Yong <fanyong@clusterfs.com>
   7  *
   8  *   This file is part of the Lustre file system, http://www.lustre.org
   9  *   Lustre is a trademark of Cluster File Systems, Inc.
  10  *
  11  *   You may have signed or agreed to another license before downloading
  12  *   this software.  If so, you are bound by the terms and conditions
  13  *   of that agreement, and the following does not apply to you.  See the
  14  *   LICENSE file included with this distribution for more information.
  15  *
  16  *   If you did not agree to a different license, then this copy of Lustre
  17  *   is open source software; you can redistribute it and/or modify it
  18  *   under the terms of version 2 of the GNU General Public License as
  19  *   published by the Free Software Foundation.
  20  *
  21  *   In either case, Lustre is distributed in the hope that it will be
  22  *   useful, but WITHOUT ANY WARRANTY; without even the implied warranty
  23  *   of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  24  *   license text for more details.
  25  *
  26  */
  27
  28 #ifndef EXPORT_SYMTAB
  29 # define EXPORT_SYMTAB
  30 #endif
  31 #define DEBUG_SUBSYSTEM S_MDS
  32
  33 #include <linux/version.h>
  34 #include <asm/statfs.h>
  35
  36 #include <linux/module.h>
  37
  38 /* LUSTRE_VERSION_CODE */
  39 #include <lustre_ver.h>
  40 /*
  41  * struct OBD_{ALLOC,FREE}*()
  42  * MDT_FAIL_CHECK
  43  */
  44 #include <obd_support.h>
  45 /* struct obd_export */
  46 #include <lustre_export.h>
  47 /* struct obd_device */
  48 #include <obd.h>
  49 #include <obd_class.h>
  50 #include <lustre_mds.h>
  51 #include <lustre_mdt.h>
  52 #include <lprocfs_status.h>
  53 #include <lu_time.h>
  54 #include "mdt_internal.h"
  55
  56 static const char *mdt_proc_names[LPROC_MDT_NR] = {
  57 };
  58
  59 int mdt_procfs_init(struct mdt_device *mdt, const char *name)
  60 {
  61         struct lu_device *ld = &mdt->mdt_md_dev.md_lu_dev;
  62         int result;
  63         ENTRY;
  64
  65         LASSERT(name != NULL);
  66         mdt->mdt_proc_entry = ld->ld_obd->obd_proc_entry;
  67         LASSERT(mdt->mdt_proc_entry != NULL);
  68
  69         result = lu_time_init(&mdt->mdt_stats, mdt->mdt_proc_entry,
  70                               mdt_proc_names, ARRAY_SIZE(mdt_proc_names));
  71         if (result == 0)
  72                 result = lu_time_named_init(&ld->ld_site->ls_time_stats,
  73                                             "site_time", mdt->mdt_proc_entry,
  74                                             lu_time_names,
  75                                             ARRAY_SIZE(lu_time_names));
  76         RETURN(result);
  77 }
  78
  79 int mdt_procfs_fini(struct mdt_device *mdt)
  80 {
  81         struct lu_device *ld = &mdt->mdt_md_dev.md_lu_dev;
  82         lu_time_fini(&ld->ld_site->ls_time_stats);
  83         lu_time_fini(&mdt->mdt_stats);
  84         mdt->mdt_proc_entry = NULL;
  85         RETURN(0);
  86 }
  87
  88 void mdt_time_start(const struct mdt_thread_info *info)
  89 {
  90         lu_lprocfs_time_start(info->mti_env);
  91 }
  92
  93 void mdt_time_end(const struct mdt_thread_info *info, int idx)
  94 {
  95         lu_lprocfs_time_end(info->mti_env, info->mti_mdt->mdt_stats, idx);
  96 }
  97
  98 static int lprocfs_rd_identity_expire(char *page, char **start, off_t off,
  99                                       int count, int *eof, void *data)
 100 {
 101         struct obd_device *obd = data;
 102         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 103
 104         *eof = 1;
 105         return snprintf(page, count, "%lu\n",
 106                         mdt->mdt_identity_cache->uc_entry_expire / HZ);
 107 }
 108
 109 static int lprocfs_wr_identity_expire(struct file *file, const char *buffer,
 110                                       unsigned long count, void *data)
 111 {
 112         struct obd_device *obd = data;
 113         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 114         int rc, val;
 115
 116         rc = lprocfs_write_helper(buffer, count, &val);
 117         if (rc)
 118                 return rc;
 119
 120         mdt->mdt_identity_cache->uc_entry_expire = val * HZ;
 121         return count;
 122 }
 123
 124 static int lprocfs_rd_identity_acquire_expire(char *page, char **start,
 125                                               off_t off, int count, int *eof,
 126                                               void *data)
 127 {
 128         struct obd_device *obd = data;
 129         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 130
 131         *eof = 1;
 132         return snprintf(page, count, "%lu\n",
 133                         mdt->mdt_identity_cache->uc_acquire_expire / HZ);
 134 }
 135
 136 static int lprocfs_wr_identity_acquire_expire(struct file *file,
 137                                               const char *buffer,
 138                                               unsigned long count,
 139                                               void *data)
 140 {
 141         struct obd_device *obd = data;
 142         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 143         int rc, val;
 144
 145         rc = lprocfs_write_helper(buffer, count, &val);
 146         if (rc)
 147                 return rc;
 148
 149         mdt->mdt_identity_cache->uc_acquire_expire = val * HZ;
 150         return count;
 151 }
 152
 153 static int lprocfs_rd_identity_upcall(char *page, char **start, off_t off,
 154                                       int count, int *eof, void *data)
 155 {
 156         struct obd_device *obd = data;
 157         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 158
 159         *eof = 1;
 160         return snprintf(page, count, "%s\n",
 161                         mdt->mdt_identity_cache->uc_upcall);
 162 }
 163
 164 static int lprocfs_wr_identity_upcall(struct file *file, const char *buffer,
 165                                       unsigned long count, void *data)
 166 {
 167         struct obd_device *obd = data;
 168         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 169         struct upcall_cache *hash = mdt->mdt_identity_cache;
 170         char kernbuf[UC_CACHE_UPCALL_MAXPATH] = { '\0' };
 171
 172         if (count >= UC_CACHE_UPCALL_MAXPATH) {
 173                 CERROR("%s: identity upcall too long\n", obd->obd_name);
 174                 return -EINVAL;
 175         }
 176
 177         if (copy_from_user(kernbuf, buffer,
 178                            min(count, UC_CACHE_UPCALL_MAXPATH - 1)))
 179                 return -EFAULT;
 180
 181         /* Remove any extraneous bits from the upcall (e.g. linefeeds) */
 182         sscanf(kernbuf, "%s", hash->uc_upcall);
 183
 184         if (strcmp(hash->uc_name, obd->obd_name) != 0)
 185                 CWARN("%s: write to upcall name %s\n",
 186                       obd->obd_name, hash->uc_upcall);
 187         CWARN("%s: identity upcall set to %s\n", obd->obd_name, hash->uc_upcall);
 188
 189         return count;
 190 }
 191
 192 static int lprocfs_wr_identity_flush(struct file *file, const char *buffer,
 193                                      unsigned long count, void *data)
 194 {
 195         struct obd_device *obd = data;
 196         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 197         int rc, uid;
 198
 199         rc = lprocfs_write_helper(buffer, count, &uid);
 200         if (rc)
 201                 return rc;
 202
 203         mdt_flush_identity(mdt->mdt_identity_cache, uid);
 204         return count;
 205 }
 206
 207 static int lprocfs_wr_identity_info(struct file *file, const char *buffer,
 208                                     unsigned long count, void *data)
 209 {
 210         struct obd_device *obd = data;
 211         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 212         struct identity_downcall_data sparam, *param = &sparam;
 213         int size = 0, rc = 0;
 214
 215         if (count < sizeof(*param)) {
 216                 CERROR("%s: invalid data size %lu\n", obd->obd_name, count);
 217                 return count;
 218         }
 219
 220         if (copy_from_user(&sparam, buffer, sizeof(sparam))) {
 221                 CERROR("%s: bad identity data\n", obd->obd_name);
 222                 GOTO(out, rc = -EFAULT);
 223         }
 224
 225         if (sparam.idd_magic != IDENTITY_DOWNCALL_MAGIC) {
 226                 CERROR("%s: MDS identity downcall bad params\n", obd->obd_name);
 227                 GOTO(out, rc = -EINVAL);
 228         }
 229
 230         if (sparam.idd_nperms > N_PERMS_MAX) {
 231                 CERROR("%s: perm count %d more than maximum %d\n",
 232                        obd->obd_name, sparam.idd_nperms, N_PERMS_MAX);
 233                 GOTO(out, rc = -EINVAL);
 234         }
 235
 236         if (sparam.idd_ngroups > NGROUPS_MAX) {
 237                 CERROR("%s: group count %d more than maximum %d\n",
 238                        obd->obd_name, sparam.idd_ngroups, NGROUPS_MAX);
 239                 GOTO(out, rc = -EINVAL);
 240         }
 241
 242         if (sparam.idd_ngroups) {
 243                 size = offsetof(struct identity_downcall_data,
 244                                 idd_groups[sparam.idd_ngroups]);
 245                 OBD_ALLOC(param, size);
 246                 if (!param) {
 247                         CERROR("%s: fail to alloc %d bytes for uid %u"
 248                                " with %d groups\n", obd->obd_name, size,
 249                                sparam.idd_uid, sparam.idd_ngroups);
 250                         param = &sparam;
 251                         param->idd_ngroups = 0;
 252                 } else if (copy_from_user(param, buffer, size)) {
 253                         CERROR("%s: uid %u bad supplementary group data\n",
 254                                obd->obd_name, sparam.idd_uid);
 255                         OBD_FREE(param, size);
 256                         param = &sparam;
 257                         param->idd_ngroups = 0;
 258                 }
 259         }
 260
 261         rc = upcall_cache_downcall(mdt->mdt_identity_cache, param->idd_err,
 262                                    param->idd_uid, param);
 263
 264 out:
 265         if (param && (param != &sparam))
 266                 OBD_FREE(param, size);
 267
 268         return rc ?: count;
 269 }
 270
 271 /* for debug only */
 272 static int lprocfs_rd_capa(char *page, char **start, off_t off,
 273                            int count, int *eof, void *data)
 274 {
 275         struct obd_device *obd = data;
 276         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 277
 278         return snprintf(page, count, "capability on: %s %s\n",
 279                         mdt->mdt_opts.mo_oss_capa ? "oss" : "",
 280                         mdt->mdt_opts.mo_mds_capa ? "mds" : "");
 281 }
 282
 283 static int lprocfs_wr_capa(struct file *file, const char *buffer,
 284                            unsigned long count, void *data)
 285 {
 286         struct obd_device *obd = data;
 287         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 288         int val, rc;
 289
 290         rc = lprocfs_write_helper(buffer, count, &val);
 291         if (rc)
 292                 return rc;
 293
 294         if (val < 0 || val > 3) {
 295                 CERROR("invalid capability mode, only 0/2/3 is accepted.\n"
 296                        " 0:  disable fid capability\n"
 297                        " 2:  enable MDS fid capability\n"
 298                        " 3:  enable both MDS and OSS fid capability\n");
 299                 return -EINVAL;
 300         }
 301
 302         /* OSS fid capability needs enable both MDS and OSS fid capability on
 303          * MDS */
 304         if (val == 1) {
 305                 CERROR("can't enable OSS fid capability only, you should use "
 306                        "'3' to enable both MDS and OSS fid capability.\n");
 307                 return -EINVAL;
 308         }
 309
 310         mdt->mdt_opts.mo_oss_capa = (val & 0x1);
 311         mdt->mdt_opts.mo_mds_capa = !!(val & 0x2);
 312         mdt->mdt_capa_conf = 1;
 313         LCONSOLE_INFO("MDS %s %s MDS fid capability.\n",
 314                       obd->obd_name,
 315                       mdt->mdt_opts.mo_mds_capa ? "enabled" : "disabled");
 316         LCONSOLE_INFO("MDS %s %s OSS fid capability.\n",
 317                       obd->obd_name,
 318                       mdt->mdt_opts.mo_oss_capa ? "enabled" : "disabled");
 319         return count;
 320 }
 321
 322 static int lprocfs_rd_capa_count(char *page, char **start, off_t off,
 323                                  int count, int *eof, void *data)
 324 {
 325         return snprintf(page, count, "%d %d\n",
 326                         capa_count[CAPA_SITE_CLIENT],
 327                         capa_count[CAPA_SITE_SERVER]);
 328 }
 329
 330 static int lprocfs_rd_site_stats(char *page, char **start, off_t off,
 331                                  int count, int *eof, void *data)
 332 {
 333         struct obd_device *obd = data;
 334         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 335         struct lu_site    *s   = mdt->mdt_md_dev.md_lu_dev.ld_site;
 336         int i;
 337         int populated;
 338
 339         /*
 340          * How many hash buckets are not-empty? Don't bother with locks: it's
 341          * an estimation anyway.
 342          */
 343         for (i = 0, populated = 0; i < s->ls_hash_size; i++)
 344                 populated += !hlist_empty(&s->ls_hash[i]);
 345
 346         return snprintf(page, count, "%d %d %d/%d %d %d %d %d %d %d\n",
 347                         s->ls_total,
 348                         s->ls_busy,
 349                         populated,
 350                         s->ls_hash_size,
 351                         s->ls_stats.s_created,
 352                         s->ls_stats.s_cache_hit,
 353                         s->ls_stats.s_cache_miss,
 354                         s->ls_stats.s_cache_check,
 355                         s->ls_stats.s_cache_race,
 356                         s->ls_stats.s_lru_purged);
 357 }
 358
 359 static int lprocfs_rd_capa_timeout(char *page, char **start, off_t off,
 360                                    int count, int *eof, void *data)
 361 {
 362         struct obd_device *obd = data;
 363         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 364
 365         return snprintf(page, count, "%lu\n", mdt->mdt_capa_timeout);
 366 }
 367
 368 static int lprocfs_wr_capa_timeout(struct file *file, const char *buffer,
 369                                    unsigned long count, void *data)
 370 {
 371         struct obd_device *obd = data;
 372         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 373         int val, rc;
 374
 375         rc = lprocfs_write_helper(buffer, count, &val);
 376         if (rc)
 377                 return rc;
 378
 379         mdt->mdt_capa_timeout = (unsigned long)val;
 380         mdt->mdt_capa_conf = 1;
 381         return count;
 382 }
 383
 384 static int lprocfs_rd_ck_timeout(char *page, char **start, off_t off, int count,
 385                                  int *eof, void *data)
 386 {
 387         struct obd_device *obd = data;
 388         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 389
 390         return snprintf(page, count, "%lu\n", mdt->mdt_ck_timeout);
 391 }
 392
 393 static int lprocfs_wr_ck_timeout(struct file *file, const char *buffer,
 394                                  unsigned long count, void *data)
 395 {
 396         struct obd_device *obd = data;
 397         struct mdt_device *mdt = mdt_dev(obd->obd_lu_dev);
 398         int val, rc;
 399
 400         rc = lprocfs_write_helper(buffer, count, &val);
 401         if (rc)
 402                 return rc;
 403
 404         mdt->mdt_ck_timeout = (unsigned long)val;
 405         mdt->mdt_capa_conf = 1;
 406         return count;
 407 }
 408
 409 static int lprocfs_mdt_wr_evict_client(struct file *file, const char *buffer,
 410                                        unsigned long count, void *data)
 411 {
 412         char tmpbuf[sizeof(struct obd_uuid)];
 413
 414         sscanf(buffer, "%40s", tmpbuf);
 415
 416         if (strncmp(tmpbuf, "nid:", 4) != 0)
 417                 return lprocfs_wr_evict_client(file, buffer, count, data);
 418
 419         CERROR("NOT implement evict client by nid %s\n", tmpbuf);
 420
 421         return count;
 422 }
 423
 424 static struct lprocfs_vars lprocfs_mdt_obd_vars[] = {
 425         { "uuid",                       lprocfs_rd_uuid,                 0, 0 },
 426         { "recovery_status",            lprocfs_obd_rd_recovery_status,  0, 0 },
 427         { "num_exports",                lprocfs_rd_num_exports,          0, 0 },
 428         { "identity_expire",            lprocfs_rd_identity_expire,
 429                                         lprocfs_wr_identity_expire,         0 },
 430         { "identity_acquire_expire",    lprocfs_rd_identity_acquire_expire,
 431                                         lprocfs_wr_identity_acquire_expire, 0 },
 432         { "identity_upcall",            lprocfs_rd_identity_upcall,
 433                                         lprocfs_wr_identity_upcall,         0 },
 434         { "identity_flush",             0, lprocfs_wr_identity_flush,       0 },
 435         { "identity_info",              0, lprocfs_wr_identity_info,        0 },
 436         { "capa",                       lprocfs_rd_capa,
 437                                         lprocfs_wr_capa,                    0 },
 438         { "capa_timeout",               lprocfs_rd_capa_timeout,
 439                                         lprocfs_wr_capa_timeout,            0 },
 440         { "capa_key_timeout",           lprocfs_rd_ck_timeout,
 441                                         lprocfs_wr_ck_timeout,              0 },
 442         { "capa_count",                 lprocfs_rd_capa_count,           0, 0 },
 443         { "site_stats",                 lprocfs_rd_site_stats,           0, 0 },
 444         { "evict_client",               0, lprocfs_mdt_wr_evict_client,     0 },
 445         { 0 }
 446 };
 447
 448 static struct lprocfs_vars lprocfs_mdt_module_vars[] = {
 449         { "num_refs",                   lprocfs_rd_numrefs,              0, 0 },
 450         { 0 }
 451 };
 452
 453 void lprocfs_mdt_init_vars(struct lprocfs_static_vars *lvars)
 454 {
 455     lvars->module_vars  = lprocfs_mdt_module_vars;
 456     lvars->obd_vars     = lprocfs_mdt_obd_vars;
 457 }