Whamcloud - gitweb
git://git.whamcloud.com
/
fs
/
lustre-release.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
| inline |
side by side
LU-8066 obd: collect all resource releasing for obj_type.
[fs/lustre-release.git]
/
lustre
/
obdclass
/
genops.c
diff --git
a/lustre/obdclass/genops.c
b/lustre/obdclass/genops.c
index
9508495
..
c5404d8
100644
(file)
--- a/
lustre/obdclass/genops.c
+++ b/
lustre/obdclass/genops.c
@@
-162,6
+162,32
@@
static void class_sysfs_release(struct kobject *kobj)
{
struct obd_type *type = container_of(kobj, struct obd_type, typ_kobj);
+#ifdef HAVE_SERVER_SUPPORT
+ if (type->typ_sym_filter)
+ type->typ_debugfs_entry = NULL;
+#endif
+ debugfs_remove_recursive(type->typ_debugfs_entry);
+ type->typ_debugfs_entry = NULL;
+
+ if (type->typ_lu)
+ lu_device_type_fini(type->typ_lu);
+
+ spin_lock(&obd_types_lock);
+ list_del(&type->typ_chain);
+ spin_unlock(&obd_types_lock);
+
+ if (type->typ_name) {
+#ifdef CONFIG_PROC_FS
+ if (type->typ_procroot)
+ remove_proc_subtree(type->typ_name, proc_lustre_root);
+#endif
+ OBD_FREE(type->typ_name, strlen(type->typ_name) + 1);
+ }
+ if (type->typ_md_ops)
+ OBD_FREE_PTR(type->typ_md_ops);
+ if (type->typ_dt_ops)
+ OBD_FREE_PTR(type->typ_dt_ops);
+
OBD_FREE(type, sizeof(*type));
}
@@
-171,8
+197,9
@@
static struct kobj_type class_ktype = {
};
#ifdef HAVE_SERVER_SUPPORT
-struct obd_type *class_
setup_tunables(const char *name
)
+struct obd_type *class_
add_symlinks(const char *name, bool enable_proc
)
{
+ struct dentry *symlink;
struct obd_type *type;
struct kobject *kobj;
int rc;
@@
-187,16
+214,36
@@
struct obd_type *class_setup_tunables(const char *name)
if (!type)
return ERR_PTR(-ENOMEM);
+ INIT_LIST_HEAD(&type->typ_chain);
+
type->typ_kobj.kset = lustre_kset;
- kobject_init(&type->typ_kobj, &class_ktype);
- rc = kobject_add(&type->typ_kobj, &lustre_kset->kobj, "%s", name);
- if (rc) {
+ rc = kobject_init_and_add(&type->typ_kobj, &class_ktype,
+ &lustre_kset->kobj, "%s", name);
+ if (rc)
+ return ERR_PTR(rc);
+
+ symlink = debugfs_create_dir(name, debugfs_lustre_root);
+ if (IS_ERR_OR_NULL(symlink)) {
+ rc = symlink ? PTR_ERR(symlink) : -ENOMEM;
kobject_put(&type->typ_kobj);
return ERR_PTR(rc);
}
+ type->typ_debugfs_entry = symlink;
+ type->typ_sym_filter = true;
+
+ if (enable_proc) {
+ type->typ_procroot = lprocfs_register(name, proc_lustre_root,
+ NULL, NULL);
+ if (IS_ERR(type->typ_procroot)) {
+ CERROR("%s: can't create compat proc entry: %d\n",
+ name, (int)PTR_ERR(type->typ_procroot));
+ type->typ_procroot = NULL;
+ }
+ }
+
return type;
}
-EXPORT_SYMBOL(class_
setup_tunable
s);
+EXPORT_SYMBOL(class_
add_symlink
s);
#endif /* HAVE_SERVER_SUPPORT */
#define CLASS_MAX_NAME 1024
@@
-206,9
+253,6
@@
int class_register_type(struct obd_ops *dt_ops, struct md_ops *md_ops,
const char *name, struct lu_device_type *ldt)
{
struct obd_type *type;
-#ifdef HAVE_SERVER_SUPPORT
- struct kobject *kobj;
-#endif /* HAVE_SERVER_SUPPORT */
int rc;
ENTRY;
@@
-216,37
+260,30
@@
int class_register_type(struct obd_ops *dt_ops, struct md_ops *md_ops,
LASSERT(strnlen(name, CLASS_MAX_NAME) < CLASS_MAX_NAME);
if (class_search_type(name)) {
+#ifdef HAVE_SERVER_SUPPORT
+ if (strcmp(name, LUSTRE_LOV_NAME) == 0 ||
+ strcmp(name, LUSTRE_OSC_NAME) == 0) {
+ struct kobject *kobj;
+
+ kobj = kset_find_obj(lustre_kset, name);
+ if (kobj) {
+ type = container_of(kobj, struct obd_type,
+ typ_kobj);
+ goto dir_exist;
+ }
+ }
+#endif /* HAVE_SERVER_SUPPORT */
CDEBUG(D_IOCTL, "Type %s already registered\n", name);
RETURN(-EEXIST);
}
-#ifdef HAVE_SERVER_SUPPORT
- kobj = kset_find_obj(lustre_kset, name);
- if (kobj) {
- type = container_of(kobj, struct obd_type, typ_kobj);
-
- goto dir_exist;
- }
-#endif /* HAVE_SERVER_SUPPORT */
-
OBD_ALLOC(type, sizeof(*type));
if (type == NULL)
RETURN(-ENOMEM);
+ INIT_LIST_HEAD(&type->typ_chain);
type->typ_kobj.kset = lustre_kset;
- rc = kobject_init_and_add(&type->typ_kobj, &class_ktype,
- &lustre_kset->kobj, "%s", name);
- if (rc)
- GOTO(failed, rc);
-
- type->typ_debugfs_entry = ldebugfs_register(name, debugfs_lustre_root,
- vars, type);
- if (IS_ERR_OR_NULL(type->typ_debugfs_entry)) {
- rc = type->typ_debugfs_entry ? PTR_ERR(type->typ_debugfs_entry)
- : -ENOMEM;
- type->typ_debugfs_entry = NULL;
- GOTO(failed, rc);
- }
+ kobject_init(&type->typ_kobj, &class_ktype);
#ifdef HAVE_SERVER_SUPPORT
dir_exist:
#endif /* HAVE_SERVER_SUPPORT */
@@
-257,7
+294,7
@@
dir_exist:
if (type->typ_dt_ops == NULL ||
type->typ_md_ops == NULL ||
type->typ_name == NULL)
-
GOTO (failed, rc
);
+
GOTO (failed, rc = -ENOMEM
);
*(type->typ_dt_ops) = *dt_ops;
/* md_ops is optional */
@@
-266,6
+303,10
@@
dir_exist:
strcpy(type->typ_name, name);
spin_lock_init(&type->obd_type_lock);
+#ifdef HAVE_SERVER_SUPPORT
+ if (type->typ_sym_filter)
+ goto setup_ldt;
+#endif
#ifdef CONFIG_PROC_FS
if (enable_proc && !type->typ_procroot) {
type->typ_procroot = lprocfs_register(type->typ_name,
@@
-278,6
+319,21
@@
dir_exist:
}
}
#endif
+ type->typ_debugfs_entry = ldebugfs_register(name, debugfs_lustre_root,
+ vars, type);
+ if (IS_ERR_OR_NULL(type->typ_debugfs_entry)) {
+ rc = type->typ_debugfs_entry ? PTR_ERR(type->typ_debugfs_entry)
+ : -ENOMEM;
+ type->typ_debugfs_entry = NULL;
+ GOTO(failed, rc);
+ }
+
+ rc = kobject_add(&type->typ_kobj, &lustre_kset->kobj, "%s", name);
+ if (rc)
+ GOTO(failed, rc);
+#ifdef HAVE_SERVER_SUPPORT
+setup_ldt:
+#endif
if (ldt) {
type->typ_lu = ldt;
rc = lu_device_type_init(ldt);
@@
-292,23
+348,6
@@
dir_exist:
RETURN(0);
failed:
-#ifdef HAVE_SERVER_SUPPORT
- if (type->typ_sym_filter)
- type->typ_debugfs_entry = NULL;
-#endif
- if (!IS_ERR_OR_NULL(type->typ_debugfs_entry))
- ldebugfs_remove(&type->typ_debugfs_entry);
- if (type->typ_name != NULL) {
-#ifdef CONFIG_PROC_FS
- if (type->typ_procroot != NULL)
- remove_proc_subtree(type->typ_name, proc_lustre_root);
-#endif
- OBD_FREE(type->typ_name, strlen(name) + 1);
- }
- if (type->typ_md_ops != NULL)
- OBD_FREE_PTR(type->typ_md_ops);
- if (type->typ_dt_ops != NULL)
- OBD_FREE_PTR(type->typ_dt_ops);
kobject_put(&type->typ_kobj);
RETURN(rc);
@@
-334,34
+373,6
@@
int class_unregister_type(const char *name)
RETURN(-EBUSY);
}
- /* we do not use type->typ_procroot as for compatibility purposes
- * other modules can share names (i.e. lod can use lov entry). so
- * we can't reference pointer as it can get invalided when another
- * module removes the entry */
-#ifdef CONFIG_PROC_FS
- if (type->typ_procroot != NULL)
- remove_proc_subtree(type->typ_name, proc_lustre_root);
- if (type->typ_procsym != NULL)
- lprocfs_remove(&type->typ_procsym);
-#endif
-#ifdef HAVE_SERVER_SUPPORT
- if (type->typ_sym_filter)
- type->typ_debugfs_entry = NULL;
-#endif
- if (!IS_ERR_OR_NULL(type->typ_debugfs_entry))
- ldebugfs_remove(&type->typ_debugfs_entry);
-
- if (type->typ_lu)
- lu_device_type_fini(type->typ_lu);
-
- spin_lock(&obd_types_lock);
- list_del(&type->typ_chain);
- spin_unlock(&obd_types_lock);
- OBD_FREE(type->typ_name, strlen(name) + 1);
- if (type->typ_dt_ops != NULL)
- OBD_FREE_PTR(type->typ_dt_ops);
- if (type->typ_md_ops != NULL)
- OBD_FREE_PTR(type->typ_md_ops);
kobject_put(&type->typ_kobj);
RETURN(0);