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
  55 /* Group 0 is no longer a legal group, to catch uninitialized IDs */
  56 #define FILTER_MIN_GROUPS 3
  57 static int smfs_ost_get_group(struct dentry *dentry, struct obdo *oa)
  58 {
  59         struct smfs_super_info *sinfo = S2SMI(dentry->d_inode->i_sb);
  60         struct obd_device *obd = class_exp2obd(sinfo->smsi_exp);
  61         struct filter_obd *filter = &obd->u.filter;
  62         struct dentry *dparent_subdir = dentry->d_parent;
  63         struct dentry *dparent_group = dparent_subdir->d_parent;
  64         int i = 0;
  65
  66         if (dparent_group == NULL || dparent_group == dparent_subdir)
  67                 return -EINVAL;
  68
  69         for (i = 1; i < filter->fo_group_count; i++) {
  70                 if (filter->fo_groups[i] == dparent_group) {
  71                         oa->o_gr = i;
  72                         oa->o_valid |= OBD_MD_FLGROUP;
  73                         return 0;
  74                 }
  75         }
  76         return -EINVAL;
  77 }
  78
  79 static int ost_rec_create_pack(char *buffer, struct dentry *dentry,
  80                                struct inode *dir, void *data1, void *data2)
  81 {
  82         struct obdo *oa = NULL;
  83         int    rc = 0;
  84
  85         PACK_KML_REC_INIT(buffer, OST_CREATE);
  86         oa = (struct obdo*)buffer;
  87         if (data1 && data2) {
  88                 struct obdo *create_oa = (struct obdo *)data2;
  89                 int    num = *((int *)data1);
  90
  91                 memcpy(oa, create_oa, sizeof(*oa));
  92                 memcpy(oa->o_inline, &num, sizeof(int));
  93                 oa->o_valid |= OBD_MD_REINT;
  94         } else {
  95                 oa->o_uid = 0; /* must have 0 uid / gid on OST */
  96                 oa->o_gid = 0;
  97                 oa->o_valid = OBD_MD_FLID | OBD_MD_FLGENER | OBD_MD_FLTYPE |
  98                         OBD_MD_FLMODE | OBD_MD_FLUID | OBD_MD_FLGID;
  99                 oa->o_size = 0;
 100                 obdo_from_inode(oa, dentry->d_inode, OBD_MD_FLTYPE|OBD_MD_FLATIME|
 101                                 OBD_MD_FLMTIME| OBD_MD_FLCTIME);
 102                 rc = smfs_ost_get_id(&oa->o_id, (char*)dentry->d_name.name,
 103                                      dentry->d_name.len);
 104                 if (rc) {
 105                         CERROR("Can not find id of node %lu\n", dentry->d_inode->i_ino);
 106                         GOTO(out, rc = -ENOMEM);
 107                 }
 108                 rc = smfs_ost_get_group(dentry, oa);
 109                 if (rc) {
 110                         CERROR("Can not find group node %lu\n", dentry->d_inode->i_ino);
 111                         GOTO(out, rc = -ENOMEM);
 112                 }
 113         }
 114         rc = sizeof(*oa) + sizeof(int);
 115 out:
 116         RETURN(rc);
 117 }
 118
 119 static int ost_rec_setattr_pack(char *buffer, struct dentry *dentry,
 120                                 struct inode *dir, void *data1, void *data2)
 121 {
 122         struct obdo *oa = NULL;
 123         struct iattr *attr = (struct iattr*)data1;
 124         int rc = 0;
 125
 126         PACK_KML_REC_INIT(buffer, OST_SETATTR);
 127         oa = (struct obdo*)buffer;
 128
 129         obdo_from_iattr(oa, attr, attr->ia_valid);
 130
 131         rc = smfs_ost_get_id(&oa->o_id, (char *)dentry->d_name.name,
 132                              dentry->d_name.len);
 133         if (rc)
 134                 GOTO(out, rc = -ENOMEM);
 135         rc = smfs_ost_get_group(dentry, oa);
 136         if (rc) {
 137                 CERROR("Can not find group node %lu\n", dentry->d_inode->i_ino);
 138                 GOTO(out, rc = -ENOMEM);
 139         }
 140
 141         rc = sizeof(*oa) + sizeof(int);
 142 out:
 143         RETURN(rc);
 144 }
 145
 146 static int ost_rec_write_pack(char *buffer, struct dentry *dentry,
 147                               struct inode *dir, void *data1, void *data2)
 148 {
 149         struct obdo *oa = NULL;
 150         int          rc = 0;
 151
 152         PACK_KML_REC_INIT(buffer, OST_WRITE);
 153         oa = (struct obdo*)buffer;
 154
 155         rc = smfs_ost_get_id(&oa->o_id, (char*)dentry->d_name.name,
 156                              dentry->d_name.len);
 157         if (rc)
 158                 GOTO(out, rc = -ENOMEM);
 159         memcpy(oa->o_inline, &dentry->d_inode->i_ino, sizeof(unsigned long));
 160
 161         rc = smfs_ost_get_group(dentry, oa);
 162         if (rc) {
 163                 CERROR("Can not find group node %lu\n", dentry->d_inode->i_ino);
 164                 GOTO(out, rc = -ENOMEM);
 165         }
 166         rc = sizeof(*oa) + sizeof(int);
 167 out:
 168         RETURN(rc);
 169 }
 170
 171 typedef int (*ost_pack_rec_func)(char *buffer, struct dentry *dentry,
 172                                  struct inode *dir, void *data1, void *data2);
 173 static ost_pack_rec_func ost_kml_pack[REINT_MAX + 1] = {
 174         [REINT_SETATTR] ost_rec_setattr_pack,
 175         [REINT_CREATE]  ost_rec_create_pack,
 176         [REINT_WRITE]   ost_rec_write_pack,
 177 };
 178
 179 int ost_rec_pack(char *buffer, struct dentry *dentry, struct inode *dir,
 180                  void *data1, void *data2, int op)
 181 {
 182         if (op == REINT_SETATTR || op == REINT_CREATE || op == REINT_WRITE) {
 183                 return ost_kml_pack[op](buffer, dentry, dir, data1, data2);
 184         }
 185         return 0;
 186 }
 187
 188 int ost_rec_pack_init(struct smfs_super_info *smsi)
 189 {
 190
 191         smsi->smsi_pack_rec[PACK_OST] = ost_rec_pack;
 192         return 0;
 193 }