lustre/mds/mds_fs.c

   1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
   2  * vim:expandtab:shiftwidth=8:tabstop=8:
   3  *
   4  * GPL HEADER START
   5  *
   6  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   7  *
   8  * This program is free software; you can redistribute it and/or modify
   9  * it under the terms of the GNU General Public License version 2 only,
  10  * as published by the Free Software Foundation.
  11  *
  12  * This program is distributed in the hope that it will be useful, but
  13  * WITHOUT ANY WARRANTY; without even the implied warranty of
  14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  15  * General Public License version 2 for more details (a copy is included
  16  * in the LICENSE file that accompanied this code).
  17  *
  18  * You should have received a copy of the GNU General Public License
  19  * version 2 along with this program; If not, see
  20  * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
  21  *
  22  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
  23  * CA 95054 USA or visit www.sun.com if you need additional information or
  24  * have any questions.
  25  *
  26  * GPL HEADER END
  27  */
  28 /*
  29  * Copyright  2008 Sun Microsystems, Inc. All rights reserved
  30  * Use is subject to license terms.
  31  */
  32 /*
  33  * This file is part of Lustre, http://www.lustre.org/
  34  * Lustre is a trademark of Sun Microsystems, Inc.
  35  *
  36  * lustre/mds/mds_fs.c
  37  *
  38  * Lustre Metadata Server (MDS) filesystem interface code
  39  *
  40  * Author: Andreas Dilger <adilger@clusterfs.com>
  41  */
  42
  43 #define DEBUG_SUBSYSTEM S_MDS
  44
  45 #include <linux/module.h>
  46 #include <linux/kmod.h>
  47 #include <linux/version.h>
  48 #include <linux/sched.h>
  49 #include <linux/mount.h>
  50 #include <lustre_mds.h>
  51 #include <obd_class.h>
  52 #include <obd_support.h>
  53 #include <lustre_lib.h>
  54 #include <lustre_fsfilt.h>
  55 #include <lustre_disk.h>
  56 #include <libcfs/list.h>
  57
  58 #include "mds_internal.h"
  59
  60
  61 /* Creates an object with the same name as its fid.  Because this is not at all
  62  * performance sensitive, it is accomplished by creating a file, checking the
  63  * fid, and renaming it. */
  64 int mds_obd_create(struct obd_export *exp, struct obdo *oa,
  65                    struct lov_stripe_md **ea, struct obd_trans_info *oti)
  66 {
  67         struct mds_obd *mds = &exp->exp_obd->u.mds;
  68         struct inode *parent_inode = mds->mds_objects_dir->d_inode;
  69         unsigned int tmpname = ll_rand();
  70         struct file *filp;
  71         struct dentry *new_child;
  72         struct lvfs_run_ctxt saved;
  73         char fidname[LL_FID_NAMELEN];
  74         void *handle;
  75         struct lvfs_ucred ucred = { 0 };
  76         int rc = 0, err, namelen;
  77         ENTRY;
  78
  79         /* the owner of object file should always be root */
  80         cap_raise(ucred.luc_cap, CAP_SYS_RESOURCE);
  81
  82         if (strncmp(exp->exp_obd->obd_name, MDD_OBD_NAME,
  83                                    strlen(MDD_OBD_NAME))) {
  84                 RETURN(0);
  85         }
  86
  87         push_ctxt(&saved, &exp->exp_obd->obd_lvfs_ctxt, &ucred);
  88
  89         sprintf(fidname, "OBJECTS/%u.%u", tmpname, current->pid);
  90         filp = filp_open(fidname, O_CREAT | O_EXCL, 0666);
  91         if (IS_ERR(filp)) {
  92                 rc = PTR_ERR(filp);
  93                 if (rc == -EEXIST) {
  94                         CERROR("impossible object name collision %u\n",
  95                                tmpname);
  96                         LBUG();
  97                 }
  98                 CERROR("error creating tmp object %u: rc %d\n", tmpname, rc);
  99                 GOTO(out_pop, rc);
 100         }
 101
 102         LASSERT(mds->mds_objects_dir == filp->f_dentry->d_parent);
 103
 104         oa->o_id = filp->f_dentry->d_inode->i_ino;
 105         oa->o_generation = filp->f_dentry->d_inode->i_generation;
 106         namelen = ll_fid2str(fidname, oa->o_id, oa->o_generation);
 107
 108         LOCK_INODE_MUTEX_PARENT(parent_inode);
 109         new_child = lookup_one_len(fidname, mds->mds_objects_dir, namelen);
 110
 111         if (IS_ERR(new_child)) {
 112                 CERROR("getting neg dentry for obj rename: %d\n", rc);
 113                 GOTO(out_close, rc = PTR_ERR(new_child));
 114         }
 115         if (new_child->d_inode != NULL) {
 116                 CERROR("impossible non-negative obj dentry " LPU64":%u!\n",
 117                        oa->o_id, oa->o_generation);
 118                 LBUG();
 119         }
 120
 121         handle = fsfilt_start(exp->exp_obd, mds->mds_objects_dir->d_inode,
 122                               FSFILT_OP_RENAME, NULL);
 123         if (IS_ERR(handle))
 124                 GOTO(out_dput, rc = PTR_ERR(handle));
 125
 126         rc = ll_vfs_rename(mds->mds_objects_dir->d_inode, filp->f_dentry,
 127                            filp->f_vfsmnt, mds->mds_objects_dir->d_inode,
 128                            new_child, filp->f_vfsmnt);
 129
 130         if (rc)
 131                 CERROR("error renaming new object "LPU64":%u: rc %d\n",
 132                        oa->o_id, oa->o_generation, rc);
 133
 134         err = fsfilt_commit(exp->exp_obd, mds->mds_objects_dir->d_inode,
 135                             handle, 0);
 136         if (!err) {
 137                 oa->o_gr = mdt_to_obd_objgrp(mds->mds_id);
 138                 oa->o_valid |= OBD_MD_FLID | OBD_MD_FLGENER | OBD_MD_FLGROUP;
 139         } else if (!rc)
 140                 rc = err;
 141 out_dput:
 142         dput(new_child);
 143 out_close:
 144         UNLOCK_INODE_MUTEX(parent_inode);
 145         err = filp_close(filp, 0);
 146         if (err) {
 147                 CERROR("closing tmpfile %u: rc %d\n", tmpname, rc);
 148                 if (!rc)
 149                         rc = err;
 150         }
 151 out_pop:
 152         pop_ctxt(&saved, &exp->exp_obd->obd_lvfs_ctxt, &ucred);
 153         RETURN(rc);
 154 }
 155
 156 int mds_obd_destroy(struct obd_export *exp, struct obdo *oa,
 157                     struct lov_stripe_md *ea, struct obd_trans_info *oti,
 158                     struct obd_export *md_exp, void *capa)
 159 {
 160         struct mds_obd *mds = &exp->exp_obd->u.mds;
 161         struct inode *parent_inode = mds->mds_objects_dir->d_inode;
 162         struct obd_device *obd = exp->exp_obd;
 163         struct lvfs_run_ctxt saved;
 164         struct lvfs_ucred ucred = { 0 };
 165         char fidname[LL_FID_NAMELEN];
 166         struct inode *inode = NULL;
 167         struct dentry *de;
 168         void *handle;
 169         int err, namelen, rc = 0;
 170         ENTRY;
 171
 172         cap_raise(ucred.luc_cap, CAP_SYS_RESOURCE);
 173         push_ctxt(&saved, &obd->obd_lvfs_ctxt, &ucred);
 174
 175         namelen = ll_fid2str(fidname, oa->o_id, oa->o_generation);
 176
 177         LOCK_INODE_MUTEX_PARENT(parent_inode);
 178         de = lookup_one_len(fidname, mds->mds_objects_dir, namelen);
 179         if (IS_ERR(de)) {
 180                 rc = IS_ERR(de);
 181                 de = NULL;
 182                 CERROR("error looking up object "LPU64" %s: rc %d\n",
 183                        oa->o_id, fidname, rc);
 184                 GOTO(out_dput, rc);
 185         }
 186         if (de->d_inode == NULL) {
 187                 CERROR("destroying non-existent object "LPU64" %s: rc %d\n",
 188                        oa->o_id, fidname, rc);
 189                 GOTO(out_dput, rc = -ENOENT);
 190         }
 191
 192         /* Stripe count is 1 here since this is some MDS specific stuff
 193            that is unlinked, not spanned across multiple OSTs */
 194         handle = fsfilt_start_log(obd, mds->mds_objects_dir->d_inode,
 195                                   FSFILT_OP_UNLINK, oti, 1);
 196
 197         if (IS_ERR(handle))
 198                 GOTO(out_dput, rc = PTR_ERR(handle));
 199
 200         /* take a reference to protect inode from truncation within
 201            vfs_unlink() context. bug 10409 */
 202         inode = de->d_inode;
 203         atomic_inc(&inode->i_count);
 204         rc = ll_vfs_unlink(mds->mds_objects_dir->d_inode, de, mds->mds_vfsmnt);
 205         if (rc)
 206                 CERROR("error destroying object "LPU64":%u: rc %d\n",
 207                        oa->o_id, oa->o_generation, rc);
 208
 209         err = fsfilt_commit(obd, mds->mds_objects_dir->d_inode, handle, 0);
 210         if (err && !rc)
 211                 rc = err;
 212 out_dput:
 213         if (de != NULL)
 214                 l_dput(de);
 215         UNLOCK_INODE_MUTEX(parent_inode);
 216
 217         if (inode)
 218                 iput(inode);
 219
 220         pop_ctxt(&saved, &obd->obd_lvfs_ctxt, &ucred);
 221         RETURN(rc);
 222 }