lustre/mdd/mdd_device.c

   1 /* -*- MODE: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
   2  * vim:expandtab:shiftwidth=8:tabstop=8:
   3  *
   4  *  mdd/mdd_handler.c
   5  *  Lustre Metadata Server (mdd) routines
   6  *
   7  *  Copyright (C) 2006 Cluster File Systems, Inc.
   8  *   Author: Wang Di <wangdi@clusterfs.com>
   9  *
  10  *   This file is part of the Lustre file system, http://www.lustre.org
  11  *   Lustre is a trademark of Cluster File Systems, Inc.
  12  *
  13  *   You may have signed or agreed to another license before downloading
  14  *   this software.  If so, you are bound by the terms and conditions
  15  *   of that agreement, and the following does not apply to you.  See the
  16  *   LICENSE file included with this distribution for more information.
  17  *
  18  *   If you did not agree to a different license, then this copy of Lustre
  19  *   is open source software; you can redistribute it and/or modify it
  20  *   under the terms of version 2 of the GNU General Public License as
  21  *   published by the Free Software Foundation.
  22  *
  23  *   In either case, Lustre is distributed in the hope that it will be
  24  *   useful, but WITHOUT ANY WARRANTY; without even the implied warranty
  25  *   of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  26  *   license text for more details.
  27  */
  28 #ifndef EXPORT_SYMTAB
  29 # define EXPORT_SYMTAB
  30 #endif
  31 #define DEBUG_SUBSYSTEM S_MDS
  32
  33 #include <linux/module.h>
  34 #include <linux/jbd.h>
  35 #include <obd.h>
  36 #include <obd_class.h>
  37 #include <lustre_ver.h>
  38 #include <obd_support.h>
  39 #include <lprocfs_status.h>
  40
  41 #include <linux/ldiskfs_fs.h>
  42 #include <lustre_mds.h>
  43 #include <lustre/lustre_idl.h>
  44
  45 #include "mdd_internal.h"
  46
  47 struct md_device_operations mdd_ops;
  48
  49 static const char *mdd_root_dir_name = "root";
  50 static int mdd_device_init(const struct lu_env *env, struct lu_device *d,
  51                            const char *name, struct lu_device *next)
  52 {
  53         struct mdd_device *mdd = lu2mdd_dev(d);
  54         struct dt_device  *dt;
  55         int rc = 0;
  56         ENTRY;
  57
  58         mdd->mdd_child = lu2dt_dev(next);
  59         dt = mdd->mdd_child;
  60
  61         /* Prepare transactions callbacks. */
  62         mdd->mdd_txn_cb.dtc_txn_start = mdd_txn_start_cb;
  63         mdd->mdd_txn_cb.dtc_txn_stop = mdd_txn_stop_cb;
  64         mdd->mdd_txn_cb.dtc_txn_commit = mdd_txn_commit_cb;
  65         mdd->mdd_txn_cb.dtc_cookie = mdd;
  66         INIT_LIST_HEAD(&mdd->mdd_txn_cb.dtc_linkage);
  67         rc = mdd_procfs_init(mdd, name);
  68         RETURN(rc);
  69 }
  70
  71 static struct lu_device *mdd_device_fini(const struct lu_env *env,
  72                                          struct lu_device *d)
  73 {
  74         struct mdd_device *mdd = lu2mdd_dev(d);
  75         struct lu_device *next = &mdd->mdd_child->dd_lu_dev;
  76         int rc;
  77
  78         rc = mdd_procfs_fini(mdd);
  79         if (rc) {
  80                 CERROR("proc fini error %d \n", rc);
  81                 return ERR_PTR(rc);
  82         }
  83         return next;
  84 }
  85
  86 static int mdd_mount(const struct lu_env *env, struct mdd_device *mdd)
  87 {
  88         int rc;
  89         struct dt_object *root;
  90         ENTRY;
  91
  92         dt_txn_callback_add(mdd->mdd_child, &mdd->mdd_txn_cb);
  93         root = dt_store_open(env, mdd->mdd_child, mdd_root_dir_name,
  94                              &mdd->mdd_root_fid);
  95         if (!IS_ERR(root)) {
  96                 LASSERT(root != NULL);
  97                 lu_object_put(env, &root->do_lu);
  98                 rc = orph_index_init(env, mdd);
  99         } else
 100                 rc = PTR_ERR(root);
 101
 102         RETURN(rc);
 103 }
 104
 105 static void mdd_device_shutdown(const struct lu_env *env,
 106                                 struct mdd_device *m)
 107 {
 108         dt_txn_callback_del(m->mdd_child, &m->mdd_txn_cb);
 109         if (m->mdd_obd_dev)
 110                 mdd_fini_obd(env, m);
 111         orph_index_fini(env, m);
 112 }
 113
 114 static int mdd_process_config(const struct lu_env *env,
 115                               struct lu_device *d, struct lustre_cfg *cfg)
 116 {
 117         struct mdd_device *m    = lu2mdd_dev(d);
 118         struct dt_device  *dt   = m->mdd_child;
 119         struct lu_device  *next = &dt->dd_lu_dev;
 120         int rc;
 121         ENTRY;
 122
 123         switch (cfg->lcfg_command) {
 124         case LCFG_SETUP:
 125                 rc = next->ld_ops->ldo_process_config(env, next, cfg);
 126                 if (rc)
 127                         GOTO(out, rc);
 128                 dt->dd_ops->dt_conf_get(env, dt, &m->mdd_dt_conf);
 129
 130                 rc = mdd_init_obd(env, m, cfg);
 131                 if (rc) {
 132                         CERROR("lov init error %d \n", rc);
 133                         GOTO(out, rc);
 134                 }
 135                 rc = mdd_mount(env, m);
 136                 if (rc)
 137                         GOTO(out, rc);
 138                 rc = mdd_txn_init_credits(env, m);
 139                 break;
 140         case LCFG_CLEANUP:
 141                 mdd_device_shutdown(env, m);
 142         default:
 143                 rc = next->ld_ops->ldo_process_config(env, next, cfg);
 144                 break;
 145         }
 146 out:
 147         RETURN(rc);
 148 }
 149 #if 0
 150 static int mdd_lov_set_nextid(const struct lu_env *env,
 151                               struct mdd_device *mdd)
 152 {
 153         struct mds_obd *mds = &mdd->mdd_obd_dev->u.mds;
 154         int rc;
 155         ENTRY;
 156
 157         LASSERT(mds->mds_lov_objids != NULL);
 158         rc = obd_set_info_async(mds->mds_osc_exp, strlen(KEY_NEXT_ID),
 159                                 KEY_NEXT_ID, mds->mds_lov_desc.ld_tgt_count,
 160                                 mds->mds_lov_objids, NULL);
 161
 162         RETURN(rc);
 163 }
 164
 165 static int mdd_cleanup_unlink_llog(const struct lu_env *env,
 166                                    struct mdd_device *mdd)
 167 {
 168         /* XXX: to be implemented! */
 169         return 0;
 170 }
 171 #endif
 172
 173 static int mdd_recovery_complete(const struct lu_env *env,
 174                                  struct lu_device *d)
 175 {
 176         struct mdd_device *mdd = lu2mdd_dev(d);
 177         struct lu_device *next = &mdd->mdd_child->dd_lu_dev;
 178         struct obd_device *obd = mdd2obd_dev(mdd);
 179         int rc;
 180         ENTRY;
 181
 182         LASSERT(mdd != NULL);
 183         LASSERT(obd != NULL);
 184 #if 0
 185         /* XXX: Do we need this in new stack? */
 186         rc = mdd_lov_set_nextid(env, mdd);
 187         if (rc) {
 188                 CERROR("mdd_lov_set_nextid() failed %d\n",
 189                        rc);
 190                 RETURN(rc);
 191         }
 192
 193         /* XXX: cleanup unlink. */
 194         rc = mdd_cleanup_unlink_llog(env, mdd);
 195         if (rc) {
 196                 CERROR("mdd_cleanup_unlink_llog() failed %d\n",
 197                        rc);
 198                 RETURN(rc);
 199         }
 200 #endif
 201         obd_notify(obd->u.mds.mds_osc_obd, NULL,
 202                    (obd->obd_async_recov ?
 203                     OBD_NOTIFY_SYNC_NONBLOCK :
 204                     OBD_NOTIFY_SYNC), NULL);
 205
 206         obd->obd_recovering = 0;
 207         obd->obd_type->typ_dt_ops->o_postrecov(obd);
 208
 209         /* XXX: orphans handling. */
 210         __mdd_orphan_cleanup(env, mdd);
 211         rc = next->ld_ops->ldo_recovery_complete(env, next);
 212
 213         RETURN(rc);
 214 }
 215
 216 struct lu_device_operations mdd_lu_ops = {
 217         .ldo_object_alloc      = mdd_object_alloc,
 218         .ldo_process_config    = mdd_process_config,
 219         .ldo_recovery_complete = mdd_recovery_complete
 220 };
 221
 222 /*
 223  * No permission check is needed.
 224  */
 225 static int mdd_root_get(const struct lu_env *env,
 226                         struct md_device *m, struct lu_fid *f)
 227 {
 228         struct mdd_device *mdd = lu2mdd_dev(&m->md_lu_dev);
 229
 230         ENTRY;
 231         *f = mdd->mdd_root_fid;
 232         RETURN(0);
 233 }
 234
 235 /*
 236  * No permission check is needed.
 237  */
 238 static int mdd_statfs(const struct lu_env *env, struct md_device *m,
 239                       struct kstatfs *sfs)
 240 {
 241         struct mdd_device *mdd = lu2mdd_dev(&m->md_lu_dev);
 242         int rc;
 243
 244         ENTRY;
 245
 246         rc = mdd_child_ops(mdd)->dt_statfs(env, mdd->mdd_child, sfs);
 247
 248         RETURN(rc);
 249 }
 250
 251 /*
 252  * No permission check is needed.
 253  */
 254 static int mdd_maxsize_get(const struct lu_env *env, struct md_device *m,
 255                            int *md_size, int *cookie_size)
 256 {
 257         struct mdd_device *mdd = lu2mdd_dev(&m->md_lu_dev);
 258         ENTRY;
 259
 260         *md_size = mdd_lov_mdsize(env, mdd);
 261         *cookie_size = mdd_lov_cookiesize(env, mdd);
 262
 263         RETURN(0);
 264 }
 265
 266 static int mdd_init_capa_ctxt(const struct lu_env *env, struct md_device *m,
 267                               int mode, unsigned long timeout, __u32 alg,
 268                               struct lustre_capa_key *keys)
 269 {
 270         struct mdd_device *mdd = lu2mdd_dev(&m->md_lu_dev);
 271         struct mds_obd    *mds = &mdd2obd_dev(mdd)->u.mds;
 272         int rc;
 273         ENTRY;
 274
 275         mds->mds_capa_keys = keys;
 276         rc = mdd_child_ops(mdd)->dt_init_capa_ctxt(env, mdd->mdd_child, mode,
 277                                                    timeout, alg, keys);
 278         RETURN(rc);
 279 }
 280
 281 static int mdd_update_capa_key(const struct lu_env *env,
 282                                struct md_device *m,
 283                                struct lustre_capa_key *key)
 284 {
 285         struct mdd_device *mdd = lu2mdd_dev(&m->md_lu_dev);
 286         struct obd_export *lov_exp = mdd2obd_dev(mdd)->u.mds.mds_osc_exp;
 287         int rc;
 288         ENTRY;
 289
 290         rc = obd_set_info_async(lov_exp, strlen(KEY_CAPA_KEY), KEY_CAPA_KEY,
 291                                 sizeof(*key), key, NULL);
 292         RETURN(rc);
 293 }
 294
 295 static struct lu_device *mdd_device_alloc(const struct lu_env *env,
 296                                           struct lu_device_type *t,
 297                                           struct lustre_cfg *lcfg)
 298 {
 299         struct lu_device  *l;
 300         struct mdd_device *m;
 301
 302         OBD_ALLOC_PTR(m);
 303         if (m == NULL) {
 304                 l = ERR_PTR(-ENOMEM);
 305         } else {
 306                 md_device_init(&m->mdd_md_dev, t);
 307                 l = mdd2lu_dev(m);
 308                 l->ld_ops = &mdd_lu_ops;
 309                 m->mdd_md_dev.md_ops = &mdd_ops;
 310         }
 311
 312         return l;
 313 }
 314
 315 static void mdd_device_free(const struct lu_env *env,
 316                             struct lu_device *lu)
 317 {
 318         struct mdd_device *m = lu2mdd_dev(lu);
 319
 320         LASSERT(atomic_read(&lu->ld_ref) == 0);
 321         md_device_fini(&m->mdd_md_dev);
 322         OBD_FREE_PTR(m);
 323 }
 324
 325 static struct obd_ops mdd_obd_device_ops = {
 326         .o_owner = THIS_MODULE
 327 };
 328
 329 static void *mdd_ucred_key_init(const struct lu_context *ctx,
 330                                 struct lu_context_key *key)
 331 {
 332         struct md_ucred *uc;
 333
 334         OBD_ALLOC_PTR(uc);
 335         if (uc == NULL)
 336                 uc = ERR_PTR(-ENOMEM);
 337         return uc;
 338 }
 339
 340 static void mdd_ucred_key_fini(const struct lu_context *ctx,
 341                              struct lu_context_key *key, void *data)
 342 {
 343         struct md_ucred *uc = data;
 344         OBD_FREE_PTR(uc);
 345 }
 346
 347 static struct lu_context_key mdd_ucred_key = {
 348         .lct_tags = LCT_SESSION,
 349         .lct_init = mdd_ucred_key_init,
 350         .lct_fini = mdd_ucred_key_fini
 351 };
 352
 353 struct md_ucred *md_ucred(const struct lu_env *env)
 354 {
 355         LASSERT(env->le_ses != NULL);
 356         return lu_context_key_get(env->le_ses, &mdd_ucred_key);
 357 }
 358 EXPORT_SYMBOL(md_ucred);
 359
 360 static void *mdd_capainfo_key_init(const struct lu_context *ctx,
 361                                    struct lu_context_key *key)
 362 {
 363         struct md_capainfo *ci;
 364
 365         OBD_ALLOC_PTR(ci);
 366         if (ci == NULL)
 367                 ci = ERR_PTR(-ENOMEM);
 368         return ci;
 369 }
 370
 371 static void mdd_capainfo_key_fini(const struct lu_context *ctx,
 372                                   struct lu_context_key *key, void *data)
 373 {
 374         struct md_capainfo *ci = data;
 375         OBD_FREE_PTR(ci);
 376 }
 377
 378 struct lu_context_key mdd_capainfo_key = {
 379         .lct_tags = LCT_SESSION,
 380         .lct_init = mdd_capainfo_key_init,
 381         .lct_fini = mdd_capainfo_key_fini
 382 };
 383
 384 struct md_capainfo *md_capainfo(const struct lu_env *env)
 385 {
 386         /* NB, in mdt_init0 */
 387         if (env->le_ses == NULL)
 388                 return NULL;
 389         return lu_context_key_get(env->le_ses, &mdd_capainfo_key);
 390 }
 391 EXPORT_SYMBOL(md_capainfo);
 392
 393 static int mdd_type_init(struct lu_device_type *t)
 394 {
 395         int result;
 396
 397         result = lu_context_key_register(&mdd_thread_key);
 398         if (result == 0)
 399                 result = lu_context_key_register(&mdd_ucred_key);
 400         if (result == 0)
 401                 result = lu_context_key_register(&mdd_capainfo_key);
 402         return result;
 403 }
 404
 405 static void mdd_type_fini(struct lu_device_type *t)
 406 {
 407         lu_context_key_degister(&mdd_capainfo_key);
 408         lu_context_key_degister(&mdd_ucred_key);
 409         lu_context_key_degister(&mdd_thread_key);
 410 }
 411
 412 struct md_device_operations mdd_ops = {
 413         .mdo_statfs         = mdd_statfs,
 414         .mdo_root_get       = mdd_root_get,
 415         .mdo_maxsize_get    = mdd_maxsize_get,
 416         .mdo_init_capa_ctxt = mdd_init_capa_ctxt,
 417         .mdo_update_capa_key= mdd_update_capa_key,
 418 };
 419
 420 static struct lu_device_type_operations mdd_device_type_ops = {
 421         .ldto_init = mdd_type_init,
 422         .ldto_fini = mdd_type_fini,
 423
 424         .ldto_device_alloc = mdd_device_alloc,
 425         .ldto_device_free  = mdd_device_free,
 426
 427         .ldto_device_init    = mdd_device_init,
 428         .ldto_device_fini    = mdd_device_fini
 429 };
 430
 431 static struct lu_device_type mdd_device_type = {
 432         .ldt_tags     = LU_DEVICE_MD,
 433         .ldt_name     = LUSTRE_MDD_NAME,
 434         .ldt_ops      = &mdd_device_type_ops,
 435         .ldt_ctx_tags = LCT_MD_THREAD
 436 };
 437
 438 static void *mdd_key_init(const struct lu_context *ctx,
 439                           struct lu_context_key *key)
 440 {
 441         struct mdd_thread_info *info;
 442
 443         OBD_ALLOC_PTR(info);
 444         if (info == NULL)
 445                 info = ERR_PTR(-ENOMEM);
 446         return info;
 447 }
 448
 449 static void mdd_key_fini(const struct lu_context *ctx,
 450                          struct lu_context_key *key, void *data)
 451 {
 452         struct mdd_thread_info *info = data;
 453         OBD_FREE_PTR(info);
 454 }
 455
 456 struct lu_context_key mdd_thread_key = {
 457         .lct_tags = LCT_MD_THREAD,
 458         .lct_init = mdd_key_init,
 459         .lct_fini = mdd_key_fini
 460 };
 461
 462 struct lprocfs_vars lprocfs_mdd_obd_vars[] = {
 463         { 0 }
 464 };
 465
 466 struct lprocfs_vars lprocfs_mdd_module_vars[] = {
 467         { 0 }
 468 };
 469
 470 LPROCFS_INIT_VARS(mdd, lprocfs_mdd_module_vars, lprocfs_mdd_obd_vars);
 471
 472 static int __init mdd_mod_init(void)
 473 {
 474         struct lprocfs_static_vars lvars;
 475         lprocfs_init_vars(mdd, &lvars);
 476         return class_register_type(&mdd_obd_device_ops, NULL, lvars.module_vars,
 477                                    LUSTRE_MDD_NAME, &mdd_device_type);
 478 }
 479
 480 static void __exit mdd_mod_exit(void)
 481 {
 482         class_unregister_type(LUSTRE_MDD_NAME);
 483 }
 484
 485 MODULE_AUTHOR("Cluster File Systems, Inc. <info@clusterfs.com>");
 486 MODULE_DESCRIPTION("Lustre Meta-data Device Prototype ("LUSTRE_MDD_NAME")");
 487 MODULE_LICENSE("GPL");
 488
 489 cfs_module(mdd, "0.1.0", mdd_mod_init, mdd_mod_exit);