LU-1302 llog: llog over OSD primitives

[fs/lustre-release.git] / lustre / obdclass / local_storage.c

diff --git a/lustre/obdclass/local_storage.c b/lustre/obdclass/local_storage.c
index 26d6e18..9852dfd 100644 (file)
--- a/lustre/obdclass/local_storage.c
+++ b/lustre/obdclass/local_storage.c
@@ -139,8 +139,7 @@ static struct lu_device_type ls_lu_type = {
        .ldt_ops  = &ls_device_type_ops,
 };
 
-static struct ls_device *ls_device_get(const struct lu_env *env,
-                                      struct dt_device *dev)
+struct ls_device *ls_device_get(struct dt_device *dev)
 {
        struct ls_device *ls;
 
@@ -174,7 +173,7 @@ out_ls:
        RETURN(ls);
 }
 
-static void ls_device_put(const struct lu_env *env, struct ls_device *ls)
+void ls_device_put(const struct lu_env *env, struct ls_device *ls)
 {
        LASSERT(env);
        if (!cfs_atomic_dec_and_test(&ls->ls_refcount))
@@ -461,7 +460,7 @@ struct dt_object *local_file_find_or_create_with_fid(const struct lu_env *env,
        } else {
                struct ls_device *ls;
 
-               ls = ls_device_get(env, dt);
+               ls = ls_device_get(dt);
                if (IS_ERR(ls)) {
                        dto = ERR_PTR(PTR_ERR(ls));
                } else {
@@ -555,7 +554,7 @@ local_index_find_or_create_with_fid(const struct lu_env *env,
        } else {
                struct ls_device *ls;
 
-               ls = ls_device_get(env, dt);
+               ls = ls_device_get(dt);
                if (IS_ERR(ls)) {
                        dto = ERR_PTR(PTR_ERR(ls));
                } else {
@@ -581,7 +580,7 @@ local_index_find_or_create_with_fid(const struct lu_env *env,
 }
 EXPORT_SYMBOL(local_index_find_or_create_with_fid);
 
-static struct local_oid_storage *dt_los_find(struct ls_device *ls, __u64 seq)
+struct local_oid_storage *dt_los_find(struct ls_device *ls, __u64 seq)
 {
        struct local_oid_storage *los, *ret = NULL;
 
@@ -595,6 +594,15 @@ static struct local_oid_storage *dt_los_find(struct ls_device *ls, __u64 seq)
        return ret;
 }
 
+void dt_los_put(struct local_oid_storage *los)
+{
+       if (cfs_atomic_dec_and_test(&los->los_refcount))
+               /* should never happen, only local_oid_storage_fini should
+                * drop refcount to zero */
+               LBUG();
+       return;
+}
+
 /**
  * Initialize local OID storage for required sequence.
  * That may be needed for services that uses local files and requires
@@ -626,7 +634,7 @@ int local_oid_storage_init(const struct lu_env *env, struct dt_device *dev,
 
        ENTRY;
 
-       ls = ls_device_get(env, dev);
+       ls = ls_device_get(dev);
        if (IS_ERR(ls))
                RETURN(PTR_ERR(ls));