1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
2 * vim:expandtab:shiftwidth=8:tabstop=8:
4 * lustre/osd/osd_handler.c
5 * Top-level entry points into osd module
7 * Copyright (c) 2006 Cluster File Systems, Inc.
8 * Author: Nikita Danilov <nikita@clusterfs.com>
10 * This file is part of the Lustre file system, http://www.lustre.org
11 * Lustre is a trademark of Cluster File Systems, Inc.
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.
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.
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.
30 # define EXPORT_SYMTAB
32 #define DEBUG_SUBSYSTEM S_MDS
34 #include <linux/module.h>
36 /* LUSTRE_VERSION_CODE */
37 #include <linux/lustre_ver.h>
39 * struct OBD_{ALLOC,FREE}*()
42 #include <linux/obd_support.h>
43 /* struct ptlrpc_thread */
44 #include <linux/lustre_net.h>
45 /* LUSTRE_OSD0_NAME */
46 #include <linux/obd.h>
47 /* class_register_type(), class_unregister_type(), class_get_type() */
48 #include <linux/obd_class.h>
49 #include <linux/lustre_disk.h>
52 #include <linux/lustre_fid.h>
54 #include "osd_internal.h"
56 static int osd_root_get (struct lu_context *ctxt,
57 struct dt_device *dev, struct lu_fid *f);
58 static int osd_statfs (struct lu_context *ctxt,
59 struct dt_device *dev, struct kstatfs *sfs);
61 static int lu_device_is_osd (const struct lu_device *d);
62 static void osd_mod_exit (void) __exit;
63 static int osd_mod_init (void) __init;
64 static int osd_type_init (struct lu_device_type *t);
65 static void osd_type_fini (struct lu_device_type *t);
66 static int osd_object_init (struct lu_context *ctxt, struct lu_object *l);
67 static void osd_object_release(struct lu_context *ctxt, struct lu_object *l);
68 static int osd_object_print (struct lu_context *ctx,
69 struct seq_file *f, const struct lu_object *o);
70 static void osd_device_free (struct lu_device *m);
71 static struct lu_device *osd_device_fini (struct lu_device *d);
72 static int osd_device_init (struct lu_device *d, struct lu_device *);
73 static void *osd_key_init (struct lu_context *ctx);
74 static void osd_key_fini (struct lu_context *ctx, void *data);
75 static int osd_fid_lookup (struct lu_context *ctx, struct osd_object *obj,
76 const struct lu_fid *fid);
77 static int osd_inode_getattr (struct lu_context *ctx,
78 struct inode *inode, struct lu_attr *attr);
80 static struct osd_object *osd_obj (const struct lu_object *o);
81 static struct osd_device *osd_dev (const struct lu_device *d);
82 static struct osd_device *osd_dt_dev (const struct dt_device *d);
83 static struct lu_device *osd_device_alloc (struct lu_device_type *t,
84 struct lustre_cfg *cfg);
85 static struct lu_object *osd_object_alloc (struct lu_context *ctx,
87 static struct inode *osd_iget (struct osd_thread_info *info,
88 struct osd_device *dev,
89 const struct osd_inode_id *id);
90 static struct super_block *osd_sb (const struct osd_device *dev);
91 static struct lu_fid *osd_inode_get_fid(const struct inode *inode,
94 static struct lu_device_type_operations osd_device_type_ops;
95 static struct lu_device_type osd_device_type;
96 static struct obd_ops osd_obd_device_ops;
97 static struct lprocfs_vars lprocfs_osd_module_vars[];
98 static struct lprocfs_vars lprocfs_osd_obd_vars[];
99 static struct lu_device_operations osd_lu_ops;
100 static struct lu_context_key osd_key;
101 static struct dt_object_operations osd_obj_ops;
106 static int osd_root_get(struct lu_context *ctx,
107 struct dt_device *dev, struct lu_fid *f)
109 osd_inode_get_fid(osd_dt_dev(dev)->od_root_dir->d_inode, f);
115 * OSD object methods.
118 static struct lu_object *osd_object_alloc(struct lu_context *ctx,
121 struct osd_object *mo;
127 l = &mo->oo_dt.do_lu;
128 lu_object_init(l, NULL, d);
129 mo->oo_dt.do_ops = &osd_obj_ops;
135 static int osd_object_init(struct lu_context *ctxt, struct lu_object *l)
137 return osd_fid_lookup(ctxt, osd_obj(l), lu_object_fid(l));
140 static void osd_object_free(struct lu_context *ctx, struct lu_object *l)
142 struct osd_object *obj = osd_obj(l);
146 static void osd_object_delete(struct lu_context *ctx, struct lu_object *l)
148 struct osd_object *o = osd_obj(l);
150 if (o->oo_inode != NULL)
154 static int osd_inode_unlinked(const struct inode *inode)
156 return inode->i_nlink == !!S_ISDIR(inode->i_mode);
159 static void osd_object_release(struct lu_context *ctxt, struct lu_object *l)
161 struct osd_object *o = osd_obj(l);
163 if (o->oo_inode != NULL && osd_inode_unlinked(o->oo_inode))
164 set_bit(LU_OBJECT_HEARD_BANSHEE, &l->lo_header->loh_flags);
167 static int osd_object_print(struct lu_context *ctx,
168 struct seq_file *f, const struct lu_object *l)
170 struct osd_object *o = osd_obj(l);
172 return seq_printf(f, LUSTRE_OSD0_NAME"-object@%p(i:%p:%lu/%u)",
174 o->oo_inode ? o->oo_inode->i_ino : 0UL,
175 o->oo_inode ? o->oo_inode->i_generation : 0);
178 static int osd_config(struct lu_context *ctx,
179 struct dt_device *d, const char *name,
180 void *buf, int size, int mode)
182 if (mode == LUSTRE_CONFIG_GET) {
183 /* to be continued */
186 /* to be continued */
191 static int osd_statfs(struct lu_context *ctx,
192 struct dt_device *d, struct kstatfs *sfs)
194 struct osd_device *osd = dt2osd_dev(d);
195 struct super_block *sb = osd_sb(osd);
200 memset(sfs, 0, sizeof(*sfs));
201 result = sb->s_op->statfs(sb, sfs);
206 static int osd_attr_get(struct lu_context *ctxt, struct dt_object *dt,
207 struct lu_attr *attr)
209 return osd_inode_getattr(ctxt, dt2osd_obj(dt)->oo_inode, attr);
212 static struct dt_object_operations osd_obj_ops = {
213 .do_attr_get = osd_attr_get
216 static struct dt_device_operations osd_dt_ops = {
217 .dt_root_get = osd_root_get,
218 .dt_config = osd_config,
219 .dt_statfs = osd_statfs
223 * OSD device type methods
225 static int osd_type_init(struct lu_device_type *t)
227 return lu_context_key_register(&osd_key);
230 static void osd_type_fini(struct lu_device_type *t)
232 lu_context_key_degister(&osd_key);
235 static struct lu_context_key osd_key = {
236 .lct_init = osd_key_init,
237 .lct_fini = osd_key_fini
240 static void *osd_key_init(struct lu_context *ctx)
242 struct osd_thread_info *info;
246 info = ERR_PTR(-ENOMEM);
250 static void osd_key_fini(struct lu_context *ctx, void *data)
252 struct osd_thread_info *info = data;
256 static int osd_device_init(struct lu_device *d, struct lu_device *next)
261 static int osd_mount(struct osd_device *o, struct lustre_cfg *cfg)
263 struct lustre_mount_info *lmi;
264 const char *dev = lustre_cfg_string(cfg, 0);
270 lmi = server_get_mount(dev);
272 CERROR("Cannot get mount info for %s!\n", dev);
276 LASSERT(lmi != NULL);
277 /* save lustre_mount_info in dt_device */
279 result = osd_oi_init(&o->od_oi, osd_sb(o)->s_root,
280 o->od_dt_dev.dd_lu_dev.ld_site);
283 o->od_root_dir = osd_open(osd_sb(o)->s_root,
285 if (IS_ERR(o->od_root_dir)) {
286 result = PTR_ERR(o->od_root_dir);
287 o->od_root_dir = NULL;
294 static struct lu_device *osd_device_fini(struct lu_device *d)
296 struct osd_device *o = osd_dev(d);
298 if (o->od_root_dir != NULL) {
299 dput(o->od_root_dir);
300 o->od_root_dir = NULL;
302 osd_oi_fini(&o->od_oi);
305 server_put_mount(o->od_mount->lmi_name, o->od_mount->lmi_mnt);
312 static struct lu_device *osd_device_alloc(struct lu_device_type *t,
313 struct lustre_cfg *cfg)
316 struct osd_device *o;
320 l = &o->od_dt_dev.dd_lu_dev;
321 lu_device_init(&o->od_dt_dev.dd_lu_dev, t);
322 o->od_dt_dev.dd_lu_dev.ld_ops = &osd_lu_ops;
323 o->od_dt_dev.dd_ops = &osd_dt_ops;
325 l = ERR_PTR(-ENOMEM);
329 static void osd_device_free(struct lu_device *d)
331 struct osd_device *o = osd_dev(d);
337 static int osd_process_config(struct lu_device *d, struct lustre_cfg *cfg)
339 struct osd_device *o = lu2osd_dev(d);
342 switch(cfg->lcfg_command) {
344 err = osd_mount(o, cfg);
351 * fid<->inode<->object functions.
354 static struct lu_fid *osd_inode_get_fid(const struct inode *inode,
358 * XXX: Should return fid stored together with inode in memory.
360 fid->f_seq = inode->i_ino;
361 fid->f_oid = inode->i_generation;
365 struct dentry *osd_open(struct dentry *parent, const char *name, mode_t mode)
367 struct dentry *dentry;
368 struct dentry *result;
370 result = dentry = osd_lookup(parent, name);
371 if (IS_ERR(dentry)) {
372 CERROR("Error opening %s: %ld\n", name, PTR_ERR(dentry));
373 dentry = NULL; /* dput(NULL) below is OK */
374 } else if (dentry->d_inode == NULL) {
375 CERROR("Not found: %s\n", name);
376 result = ERR_PTR(-ENOENT);
377 } else if ((dentry->d_inode->i_mode & S_IFMT) != mode) {
378 CERROR("Wrong mode: %s: %o != %o\n", name,
379 dentry->d_inode->i_mode, mode);
380 result = ERR_PTR(mode == S_IFDIR ? -ENOTDIR : -EISDIR);
388 struct dentry *osd_lookup(struct dentry *parent, const char *name)
390 struct dentry *dentry;
392 CDEBUG(D_INODE, "looking up object %s\n", name);
393 down(&parent->d_inode->i_sem);
394 dentry = lookup_one_len(name, parent, strlen(name));
395 up(&parent->d_inode->i_sem);
397 if (IS_ERR(dentry)) {
398 CERROR("error getting %s: %ld\n", name, PTR_ERR(dentry));
399 } else if (dentry->d_inode != NULL && is_bad_inode(dentry->d_inode)) {
400 CERROR("got bad object %s inode %lu\n",
401 name, dentry->d_inode->i_ino);
403 dentry = ERR_PTR(-ENOENT);
408 static struct inode *osd_iget(struct osd_thread_info *info,
409 struct osd_device *dev,
410 const struct osd_inode_id *id)
414 inode = iget(osd_sb(dev), id->oii_ino);
416 CERROR("no inode\n");
417 inode = ERR_PTR(-EACCES);
418 } else if (is_bad_inode(inode)) {
419 CERROR("bad inode\n");
421 inode = ERR_PTR(-ENOENT);
422 } else if (inode->i_generation != id->oii_gen &&
423 id->oii_gen != OSD_GEN_IGNORE) {
424 CERROR("stale inode\n");
426 inode = ERR_PTR(-ESTALE);
432 static int osd_fid_lookup(struct lu_context *ctx,
433 struct osd_object *obj, const struct lu_fid *fid)
435 struct osd_thread_info *info;
436 struct lu_device *ldev = obj->oo_dt.do_lu.lo_dev;
437 struct osd_device *dev;
438 struct osd_inode_id id;
442 LASSERT(obj->oo_inode == NULL);
443 LASSERT(fid_is_sane(fid));
444 LASSERT(fid_is_local(ldev->ld_site, fid));
448 info = lu_context_key_get(ctx, &osd_key);
451 if (OBD_FAIL_CHECK(OBD_FAIL_OST_ENOENT))
454 osd_oi_read_lock(&dev->od_oi);
455 result = osd_oi_lookup(info, &dev->od_oi, fid, &id);
457 inode = osd_iget(info, dev, &id);
458 if (!IS_ERR(inode)) {
459 obj->oo_inode = inode;
462 result = PTR_ERR(inode);
464 osd_oi_read_unlock(&dev->od_oi);
468 static int osd_inode_getattr(struct lu_context *ctx,
469 struct inode *inode, struct lu_attr *attr)
471 //attr->la_atime = inode->i_atime;
472 //attr->la_mtime = inode->i_mtime;
473 //attr->la_ctime = inode->i_ctime;
474 attr->la_mode = inode->i_mode;
475 attr->la_size = inode->i_size;
476 attr->la_blocks = inode->i_blocks;
477 attr->la_uid = inode->i_uid;
478 attr->la_gid = inode->i_gid;
479 attr->la_flags = inode->i_flags;
480 attr->la_nlink = inode->i_nlink;
488 static int lu_device_is_osd(const struct lu_device *d)
491 * XXX for now. Tags in lu_device_type->ldt_something are needed.
493 return ergo(d->ld_ops != NULL, d->ld_ops == &osd_lu_ops);
496 static struct osd_object *osd_obj(const struct lu_object *o)
498 LASSERT(lu_device_is_osd(o->lo_dev));
499 return container_of(o, struct osd_object, oo_dt.do_lu);
502 static struct osd_device *osd_dt_dev(const struct dt_device *d)
504 LASSERT(lu_device_is_osd(&d->dd_lu_dev));
505 return container_of(d, struct osd_device, od_dt_dev);
508 static struct osd_device *osd_dev(const struct lu_device *d)
510 LASSERT(lu_device_is_osd(d));
511 return osd_dt_dev(container_of(d, struct dt_device, dd_lu_dev));
514 static struct super_block *osd_sb(const struct osd_device *dev)
516 return dev->od_mount->lmi_mnt->mnt_sb;
519 static struct lu_device_operations osd_lu_ops = {
520 .ldo_object_alloc = osd_object_alloc,
521 .ldo_object_init = osd_object_init,
522 .ldo_object_free = osd_object_free,
523 .ldo_object_release = osd_object_release,
524 .ldo_object_delete = osd_object_delete,
525 .ldo_object_print = osd_object_print,
526 .ldo_process_config = osd_process_config
529 static struct lu_device_type_operations osd_device_type_ops = {
530 .ldto_init = osd_type_init,
531 .ldto_fini = osd_type_fini,
533 .ldto_device_alloc = osd_device_alloc,
534 .ldto_device_free = osd_device_free,
536 .ldto_device_init = osd_device_init,
537 .ldto_device_fini = osd_device_fini
540 static struct lu_device_type osd_device_type = {
541 .ldt_tags = LU_DEVICE_DT,
542 .ldt_name = LUSTRE_OSD0_NAME,
543 .ldt_ops = &osd_device_type_ops
547 * lprocfs legacy support.
549 static struct lprocfs_vars lprocfs_osd_obd_vars[] = {
553 static struct lprocfs_vars lprocfs_osd_module_vars[] = {
557 static struct obd_ops osd_obd_device_ops = {
558 .o_owner = THIS_MODULE
561 LPROCFS_INIT_VARS(osd, lprocfs_osd_module_vars, lprocfs_osd_obd_vars);
563 static int __init osd_mod_init(void)
565 struct lprocfs_static_vars lvars;
567 lprocfs_init_vars(osd, &lvars);
568 return class_register_type(&osd_obd_device_ops, NULL, lvars.module_vars,
569 LUSTRE_OSD0_NAME, &osd_device_type);
572 static void __exit osd_mod_exit(void)
574 class_unregister_type(LUSTRE_OSD0_NAME);
577 MODULE_AUTHOR("Cluster File Systems, Inc. <info@clusterfs.com>");
578 MODULE_DESCRIPTION("Lustre Object Storage Device ("LUSTRE_OSD0_NAME")");
579 MODULE_LICENSE("GPL");
581 cfs_module(osd, "0.0.2", osd_mod_init, osd_mod_exit);