lustre/quota/qsd_config.c

   1 /*
   2  * GPL HEADER START
   3  *
   4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   5  *
   6  * This program is free software; you can redistribute it and/or modify
   7  * it under the terms of the GNU General Public License version 2 only,
   8  * as published by the Free Software Foundation.
   9  *
  10  * This program is distributed in the hope that it will be useful, but
  11  * WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * General Public License version 2 for more details (a copy is included
  14  * in the LICENSE file that accompanied this code).
  15  *
  16  * You should have received a copy of the GNU General Public License
  17  * version 2 along with this program; if not, write to the
  18  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  19  * Boston, MA 021110-1307, USA
  20  *
  21  * GPL HEADER END
  22  */
  23 /*
  24  * Copyright (c) 2012, 2014, Intel Corporation.
  25  * Use is subject to license terms.
  26  *
  27  * Author: Johann Lombardi <johann.lombardi@intel.com>
  28  * Author: Niu    Yawei    <yawei.niu@intel.com>
  29  */
  30
  31 #define DEBUG_SUBSYSTEM S_LQUOTA
  32
  33 #include <obd_class.h>
  34 #include <lustre_param.h>
  35
  36 #include "qsd_internal.h"
  37
  38 static struct list_head qfs_list = LIST_HEAD_INIT(qfs_list);
  39 /* protect the qfs_list */
  40 static DEFINE_SPINLOCK(qfs_list_lock);
  41
  42 /*
  43  * Put reference of qsd_fsinfo.
  44  *
  45  * \param  qfs    - the qsd_fsinfo to be put
  46  */
  47 void qsd_put_fsinfo(struct qsd_fsinfo *qfs)
  48 {
  49         ENTRY;
  50         LASSERT(qfs != NULL);
  51
  52         spin_lock(&qfs_list_lock);
  53         LASSERT(qfs->qfs_ref > 0);
  54         qfs->qfs_ref--;
  55         if (qfs->qfs_ref == 0) {
  56                 LASSERT(list_empty(&qfs->qfs_qsd_list));
  57                 list_del(&qfs->qfs_link);
  58                 OBD_FREE_PTR(qfs);
  59         }
  60         spin_unlock(&qfs_list_lock);
  61         EXIT;
  62 }
  63
  64 /*
  65  * Find or create a qsd_fsinfo
  66  *
  67  * \param  name   - filesystem name
  68  * \param  create - when @create is non-zero, create new one if fail to
  69  *                  find existing qfs by @name
  70  *
  71  * \retval qsd_fsinfo - success
  72  * \retval NULL          - failure
  73  */
  74 struct qsd_fsinfo *qsd_get_fsinfo(char *name, bool create)
  75 {
  76         struct qsd_fsinfo       *qfs, *new = NULL;
  77         ENTRY;
  78
  79         if (name == NULL ||  strlen(name) >= MTI_NAME_MAXLEN)
  80                 RETURN(NULL);
  81
  82         if (create) {
  83                 /* pre-allocate a qsd_fsinfo in case there isn't one already.
  84                  * we can afford the extra cost since qsd_get_fsinfo() isn't
  85                  * called very often with create = true */
  86
  87                 OBD_ALLOC_PTR(new);
  88                 if (new == NULL)
  89                         RETURN(NULL);
  90
  91                 mutex_init(&new->qfs_mutex);
  92                 INIT_LIST_HEAD(&new->qfs_qsd_list);
  93                 strcpy(new->qfs_name, name);
  94                 new->qfs_ref = 1;
  95         }
  96
  97         /* search in the fsinfo list */
  98         spin_lock(&qfs_list_lock);
  99         list_for_each_entry(qfs, &qfs_list, qfs_link) {
 100                 if (!strcmp(qfs->qfs_name, name)) {
 101                         qfs->qfs_ref++;
 102                         goto out;
 103                 }
 104         }
 105
 106         qfs = NULL; /* not found */
 107
 108         if (new) {
 109                 /* not found, but we were asked to create a new one */
 110                 list_add_tail(&new->qfs_link, &qfs_list);
 111                 qfs = new;
 112                 new = NULL;
 113         }
 114 out:
 115         spin_unlock(&qfs_list_lock);
 116
 117         if (new)
 118                 OBD_FREE_PTR(new);
 119         RETURN(qfs);
 120 }
 121
 122 /*
 123  * Quota configuration handlers in charge of processing all per-filesystem quota
 124  * parameters set via conf_param.
 125  *
 126  * \param lcfg - quota configuration log to be processed
 127  */
 128 int qsd_process_config(struct lustre_cfg *lcfg)
 129 {
 130         struct qsd_fsinfo       *qfs;
 131         char                    *fsname = lustre_cfg_string(lcfg, 0);
 132         char                    *cfgstr = lustre_cfg_string(lcfg, 1);
 133         char                    *keystr, *valstr;
 134         int                      rc, pool, enabled = 0;
 135         bool                     reint = false;
 136         ENTRY;
 137
 138         CDEBUG(D_QUOTA, "processing quota parameter: fs:%s cfgstr:%s\n", fsname,
 139                cfgstr);
 140
 141         if (class_match_param(cfgstr, PARAM_QUOTA, &keystr) != 0)
 142                 RETURN(-EINVAL);
 143
 144         if (!class_match_param(keystr, QUOTA_METAPOOL_NAME, &valstr))
 145                 pool = LQUOTA_RES_MD;
 146         else if (!class_match_param(keystr, QUOTA_DATAPOOL_NAME, &valstr))
 147                 pool = LQUOTA_RES_DT;
 148         else
 149                 RETURN(-EINVAL);
 150
 151         qfs = qsd_get_fsinfo(fsname, 0);
 152         if (qfs == NULL) {
 153                 CERROR("failed to find quota filesystem information for %s\n",
 154                        fsname);
 155                 RETURN(-ENOENT);
 156         }
 157
 158         if (strchr(valstr, 'u'))
 159                 enabled |= 1 << USRQUOTA;
 160         if (strchr(valstr, 'g'))
 161                 enabled |= 1 << GRPQUOTA;
 162
 163         mutex_lock(&qfs->qfs_mutex);
 164         if (qfs->qfs_enabled[pool - LQUOTA_FIRST_RES] == enabled)
 165                 /* no change required */
 166                 GOTO(out, rc = 0);
 167
 168         if ((qfs->qfs_enabled[pool - LQUOTA_FIRST_RES] & enabled) != enabled)
 169                 reint = true;
 170
 171         qfs->qfs_enabled[pool - LQUOTA_FIRST_RES] = enabled;
 172
 173         /* trigger reintegration for all qsd */
 174         if (reint) {
 175                 struct qsd_instance     *qsd;
 176                 struct qsd_qtype_info   *qqi;
 177
 178                 list_for_each_entry(qsd, &qfs->qfs_qsd_list, qsd_link) {
 179                         bool    skip = false;
 180                         int     type;
 181
 182                         /* start reintegration only if qsd_prepare() was
 183                          * successfully called */
 184                         read_lock(&qsd->qsd_lock);
 185                         if (!qsd->qsd_prepared)
 186                                 skip = true;
 187                         read_unlock(&qsd->qsd_lock);
 188                         if (skip)
 189                                 continue;
 190
 191                         for (type = USRQUOTA; type < LL_MAXQUOTAS; type++) {
 192                                 qqi = qsd->qsd_type_array[type];
 193                                 if (qqi->qqi_acct_failed) {
 194                                         LCONSOLE_ERROR("%s: can't enable quota "
 195                                                        "enforcement since space "
 196                                                        "accounting isn't functional. "
 197                                                        "Please run tunefs.lustre "
 198                                                        "--quota on an unmounted "
 199                                                        "filesystem if not done already"
 200                                                        "\n", qsd->qsd_svname);
 201                                         continue;
 202                                 }
 203                                 qsd_start_reint_thread(qqi);
 204                         }
 205                 }
 206         }
 207 out:
 208         mutex_unlock(&qfs->qfs_mutex);
 209         qsd_put_fsinfo(qfs);
 210         RETURN(0);
 211 }