lustre/smfs/ost_kml.c

   1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
   2  * vim:expandtab:shiftwidth=8:tabstop=8:
   3  *
   4  *  lustre/smfs/super.c
   5  *  Lustre filesystem abstraction routines
   6  *
   7  *  Copyright (C) 2004 Cluster File Systems, Inc.
   8  *
   9  *   This file is part of Lustre, http://www.lustre.org.
  10  *
  11  *   Lustre is free software; you can redistribute it and/or
  12  *   modify it under the terms of version 2 of the GNU General Public
  13  *   License as published by the Free Software Foundation.
  14  *
  15  *   Lustre is distributed in the hope that it will be useful,
  16  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
  17  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  18  *   GNU General Public License for more details.
  19  *
  20  *   You should have received a copy of the GNU General Public License
  21  *   along with Lustre; if not, write to the Free Software
  22  *   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  23  */
  24
  25 #ifndef EXPORT_SYMTAB
  26 # define EXPORT_SYMTAB
  27 #endif
  28
  29 #define DEBUG_SUBSYSTEM S_SM
  30
  31 #include <linux/kmod.h>
  32 #include <linux/init.h>
  33 #include <linux/fs.h>
  34 #include <linux/slab.h>
  35 #include <linux/obd_class.h>
  36 #include <linux/obd_support.h>
  37 #include <linux/lustre_lib.h>
  38 #include <linux/lustre_idl.h>
  39 #include <linux/lustre_fsfilt.h>
  40 #include <linux/lustre_smfs.h>
  41 #include "smfs_internal.h"
  42
  43 static int smfs_ost_get_id(obd_id *id, char *data, int size)
  44 {
  45         /*for obdfilter obdid is the name of the filename*/
  46         char end;
  47         char *endp = &end;
  48         if (data)
  49                 *id = simple_strtoull(data, &endp, 10);
  50         else
  51                 return -EINVAL;
  52         return 0;
  53 }
  54 /* Group 0 is no longer a legal group, to catch uninitialized IDs */
  55 #define FILTER_MIN_GROUPS 3
  56 static int smfs_ost_get_group(struct dentry *dentry, struct obdo *oa)
  57 {
  58         struct smfs_super_info *sinfo = S2SMI(dentry->d_inode->i_sb);
  59         struct obd_device *obd = class_exp2obd(sinfo->smsi_exp);
  60         struct filter_obd *filter = &obd->u.filter;
  61         struct dentry *dparent_subdir = dentry->d_parent;
  62         struct dentry *dparent_group = dparent_subdir->d_parent;
  63         int i = 0;
  64
  65         if (dparent_group == NULL || dparent_group == dparent_subdir)
  66                 return -EINVAL;
  67
  68         for (i = 1; i < filter->fo_group_count; i++) {
  69                 if (filter->fo_groups[i] == dparent_group) {
  70                         oa->o_gr = i;
  71                         oa->o_valid |= OBD_MD_FLGROUP;
  72                         return 0;
  73                 }
  74         }
  75         return -EINVAL;
  76 }
  77
  78 static int ost_rec_create_pack(char *buffer, struct dentry *dentry,
  79                                struct inode *dir, void *data1, void *data2)
  80 {
  81         struct obdo *oa = NULL;
  82         int    rc = 0;
  83
  84         PACK_KML_REC_INIT(buffer, OST_CREATE);
  85         oa = (struct obdo*)buffer;
  86         oa->o_uid = 0; /* must have 0 uid / gid on OST */
  87         oa->o_gid = 0;
  88         oa->o_valid = OBD_MD_FLID | OBD_MD_FLGENER | OBD_MD_FLTYPE |
  89                 OBD_MD_FLMODE | OBD_MD_FLUID | OBD_MD_FLGID;
  90         oa->o_size = 0;
  91         obdo_from_inode(oa, dentry->d_inode, OBD_MD_FLTYPE|OBD_MD_FLATIME|
  92                         OBD_MD_FLMTIME| OBD_MD_FLCTIME);
  93         rc = smfs_ost_get_id(&oa->o_id, (char*)dentry->d_name.name,
  94                              dentry->d_name.len);
  95         if (rc) {
  96                 CERROR("Can not find id of node %lu\n", dentry->d_inode->i_ino);
  97                 GOTO(out, rc = -ENOMEM);
  98         }
  99
 100         rc = smfs_ost_get_group(dentry, oa);
 101         if (rc) {
 102                 CERROR("Can not find group node %lu\n", dentry->d_inode->i_ino);
 103                 GOTO(out, rc = -ENOMEM);
 104         }
 105         rc = sizeof(*oa) + sizeof(int);
 106 out:
 107         RETURN(rc);
 108 }
 109
 110 static int ost_rec_setattr_pack(char *buffer, struct dentry *dentry,
 111                                 struct inode *dir, void *data1, void *data2)
 112 {
 113         struct obdo *oa = NULL;
 114         struct iattr *attr = (struct iattr*)data1;
 115         int rc = 0;
 116
 117         PACK_KML_REC_INIT(buffer, OST_SETATTR);
 118         oa = (struct obdo*)buffer;
 119
 120         obdo_from_iattr(oa, attr, attr->ia_valid);
 121
 122         rc = smfs_ost_get_id(&oa->o_id, (char *)dentry->d_name.name,
 123                              dentry->d_name.len);
 124         if (rc)
 125                 GOTO(out, rc = -ENOMEM);
 126         rc = smfs_ost_get_group(dentry, oa);
 127         if (rc) {
 128                 CERROR("Can not find group node %lu\n", dentry->d_inode->i_ino);
 129                 GOTO(out, rc = -ENOMEM);
 130         }
 131
 132         rc = sizeof(*oa) + sizeof(int);
 133 out:
 134         RETURN(rc);
 135 }
 136 static int ost_rec_write_pack(char *buffer, struct dentry *dentry,
 137                               struct inode *dir, void *data1, void *data2)
 138 {
 139         struct obdo *oa = NULL;
 140          int        rc = 0;
 141
 142         PACK_KML_REC_INIT(buffer, OST_WRITE);
 143         oa = (struct obdo*)buffer;
 144
 145         rc = smfs_ost_get_id(&oa->o_id, (char*)dentry->d_name.name,
 146                              dentry->d_name.len);
 147         if (rc)
 148                 GOTO(out, rc = -ENOMEM);
 149         memcpy(oa->o_inline, &dentry->d_inode->i_ino, sizeof(unsigned long));
 150
 151         rc = smfs_ost_get_group(dentry, oa);
 152         if (rc) {
 153                 CERROR("Can not find group node %lu\n", dentry->d_inode->i_ino);
 154                 GOTO(out, rc = -ENOMEM);
 155         }
 156         rc = sizeof(*oa) + sizeof(int);
 157 out:
 158         RETURN(rc);
 159 }
 160 typedef int (*ost_pack_rec_func)(char *buffer, struct dentry *dentry,
 161                                  struct inode *dir, void *data1, void *data2);
 162 static ost_pack_rec_func ost_kml_pack[REINT_MAX + 1] = {
 163         [REINT_SETATTR] ost_rec_setattr_pack,
 164         [REINT_CREATE]  ost_rec_create_pack,
 165         [REINT_WRITE]   ost_rec_write_pack,
 166 };
 167
 168 int ost_rec_pack(char *buffer, struct dentry *dentry, struct inode *dir,
 169                  void *data1, void *data2, int op)
 170 {
 171         if (op == REINT_SETATTR || op == REINT_CREATE || op == REINT_WRITE) {
 172                 return ost_kml_pack[op](buffer, dentry, dir, data1, data2);
 173         }
 174         return 0;
 175 }
 176
 177 int ost_rec_pack_init(struct super_block *sb)
 178 {
 179         struct smfs_super_info *smsi = S2SMI(sb);
 180
 181         smsi->smsi_pack_rec[PACK_OST] = ost_rec_pack;
 182
 183         return 0;
 184 }