Commit 099d5adf authored by Emoly Liu's avatar Emoly Liu Committed by Greg Kroah-Hartman

staging: lustre: ldlm: improve ldlm_lock_create() return value

ldlm_lock_create() and ldlm_resource_get() always return NULL as
error reporting and "NULL" is interpretted as ENOMEM incorrectly
sometimes. This patch fixes this problem by using ERR_PTR() rather
than NULL.
Signed-off-by: default avatarEmoly Liu <emoly.liu@intel.com>
Intel-bug-id: https://jira.hpdd.intel.com/browse/LU-4524
Reviewed-on: http://review.whamcloud.com/9004Reviewed-by: default avatarBobi Jam <bobijam@gmail.com>
Reviewed-by: default avatarAndreas Dilger <andreas.dilger@intel.com>
Reviewed-by: default avatarJohn L. Hammond <john.hammond@intel.com>
Signed-off-by: default avatarJames Simmons <jsimmons@infradead.org>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent aa08b0e3
...@@ -339,10 +339,10 @@ static int ldlm_process_flock_lock(struct ldlm_lock *req, __u64 *flags, ...@@ -339,10 +339,10 @@ static int ldlm_process_flock_lock(struct ldlm_lock *req, __u64 *flags,
lock->l_granted_mode, &null_cbs, lock->l_granted_mode, &null_cbs,
NULL, 0, LVB_T_NONE); NULL, 0, LVB_T_NONE);
lock_res_and_lock(req); lock_res_and_lock(req);
if (!new2) { if (IS_ERR(new2)) {
ldlm_flock_destroy(req, lock->l_granted_mode, ldlm_flock_destroy(req, lock->l_granted_mode,
*flags); *flags);
*err = -ENOLCK; *err = PTR_ERR(new2);
return LDLM_ITER_STOP; return LDLM_ITER_STOP;
} }
goto reprocess; goto reprocess;
......
...@@ -481,8 +481,8 @@ int ldlm_lock_change_resource(struct ldlm_namespace *ns, struct ldlm_lock *lock, ...@@ -481,8 +481,8 @@ int ldlm_lock_change_resource(struct ldlm_namespace *ns, struct ldlm_lock *lock,
unlock_res_and_lock(lock); unlock_res_and_lock(lock);
newres = ldlm_resource_get(ns, NULL, new_resid, type, 1); newres = ldlm_resource_get(ns, NULL, new_resid, type, 1);
if (!newres) if (IS_ERR(newres))
return -ENOMEM; return PTR_ERR(newres);
lu_ref_add(&newres->lr_reference, "lock", lock); lu_ref_add(&newres->lr_reference, "lock", lock);
/* /*
...@@ -1227,7 +1227,7 @@ enum ldlm_mode ldlm_lock_match(struct ldlm_namespace *ns, __u64 flags, ...@@ -1227,7 +1227,7 @@ enum ldlm_mode ldlm_lock_match(struct ldlm_namespace *ns, __u64 flags,
} }
res = ldlm_resource_get(ns, NULL, res_id, type, 0); res = ldlm_resource_get(ns, NULL, res_id, type, 0);
if (!res) { if (IS_ERR(res)) {
LASSERT(!old_lock); LASSERT(!old_lock);
return 0; return 0;
} }
...@@ -1475,15 +1475,15 @@ struct ldlm_lock *ldlm_lock_create(struct ldlm_namespace *ns, ...@@ -1475,15 +1475,15 @@ struct ldlm_lock *ldlm_lock_create(struct ldlm_namespace *ns,
{ {
struct ldlm_lock *lock; struct ldlm_lock *lock;
struct ldlm_resource *res; struct ldlm_resource *res;
int rc;
res = ldlm_resource_get(ns, NULL, res_id, type, 1); res = ldlm_resource_get(ns, NULL, res_id, type, 1);
if (!res) if (IS_ERR(res))
return NULL; return ERR_CAST(res);
lock = ldlm_lock_new(res); lock = ldlm_lock_new(res);
if (!lock) if (!lock)
return NULL; return ERR_PTR(-ENOMEM);
lock->l_req_mode = mode; lock->l_req_mode = mode;
lock->l_ast_data = data; lock->l_ast_data = data;
...@@ -1497,27 +1497,33 @@ struct ldlm_lock *ldlm_lock_create(struct ldlm_namespace *ns, ...@@ -1497,27 +1497,33 @@ struct ldlm_lock *ldlm_lock_create(struct ldlm_namespace *ns,
lock->l_tree_node = NULL; lock->l_tree_node = NULL;
/* if this is the extent lock, allocate the interval tree node */ /* if this is the extent lock, allocate the interval tree node */
if (type == LDLM_EXTENT) { if (type == LDLM_EXTENT) {
if (!ldlm_interval_alloc(lock)) if (!ldlm_interval_alloc(lock)) {
rc = -ENOMEM;
goto out; goto out;
}
} }
if (lvb_len) { if (lvb_len) {
lock->l_lvb_len = lvb_len; lock->l_lvb_len = lvb_len;
lock->l_lvb_data = kzalloc(lvb_len, GFP_NOFS); lock->l_lvb_data = kzalloc(lvb_len, GFP_NOFS);
if (!lock->l_lvb_data) if (!lock->l_lvb_data) {
rc = -ENOMEM;
goto out; goto out;
}
} }
lock->l_lvb_type = lvb_type; lock->l_lvb_type = lvb_type;
if (OBD_FAIL_CHECK(OBD_FAIL_LDLM_NEW_LOCK)) if (OBD_FAIL_CHECK(OBD_FAIL_LDLM_NEW_LOCK)) {
rc = -ENOENT;
goto out; goto out;
}
return lock; return lock;
out: out:
ldlm_lock_destroy(lock); ldlm_lock_destroy(lock);
LDLM_LOCK_RELEASE(lock); LDLM_LOCK_RELEASE(lock);
return NULL; return ERR_PTR(rc);
} }
/** /**
......
...@@ -694,8 +694,8 @@ int ldlm_cli_enqueue(struct obd_export *exp, struct ptlrpc_request **reqp, ...@@ -694,8 +694,8 @@ int ldlm_cli_enqueue(struct obd_export *exp, struct ptlrpc_request **reqp,
lock = ldlm_lock_create(ns, res_id, einfo->ei_type, lock = ldlm_lock_create(ns, res_id, einfo->ei_type,
einfo->ei_mode, &cbs, einfo->ei_cbdata, einfo->ei_mode, &cbs, einfo->ei_cbdata,
lvb_len, lvb_type); lvb_len, lvb_type);
if (!lock) if (IS_ERR(lock))
return -ENOMEM; return PTR_ERR(lock);
/* for the local lock, add the reference */ /* for the local lock, add the reference */
ldlm_lock_addref_internal(lock, einfo->ei_mode); ldlm_lock_addref_internal(lock, einfo->ei_mode);
ldlm_lock2handle(lock, lockh); ldlm_lock2handle(lock, lockh);
...@@ -1658,7 +1658,7 @@ int ldlm_cli_cancel_unused_resource(struct ldlm_namespace *ns, ...@@ -1658,7 +1658,7 @@ int ldlm_cli_cancel_unused_resource(struct ldlm_namespace *ns,
int rc; int rc;
res = ldlm_resource_get(ns, NULL, res_id, 0, 0); res = ldlm_resource_get(ns, NULL, res_id, 0, 0);
if (!res) { if (IS_ERR(res)) {
/* This is not a problem. */ /* This is not a problem. */
CDEBUG(D_INFO, "No resource %llu\n", res_id->name[0]); CDEBUG(D_INFO, "No resource %llu\n", res_id->name[0]);
return 0; return 0;
...@@ -1809,13 +1809,10 @@ int ldlm_resource_iterate(struct ldlm_namespace *ns, ...@@ -1809,13 +1809,10 @@ int ldlm_resource_iterate(struct ldlm_namespace *ns,
struct ldlm_resource *res; struct ldlm_resource *res;
int rc; int rc;
if (!ns) { LASSERTF(ns, "must pass in namespace\n");
CERROR("must pass in namespace\n");
LBUG();
}
res = ldlm_resource_get(ns, NULL, res_id, 0, 0); res = ldlm_resource_get(ns, NULL, res_id, 0, 0);
if (!res) if (IS_ERR(res))
return 0; return 0;
LDLM_RESOURCE_ADDREF(res); LDLM_RESOURCE_ADDREF(res);
......
...@@ -1088,7 +1088,7 @@ ldlm_resource_get(struct ldlm_namespace *ns, struct ldlm_resource *parent, ...@@ -1088,7 +1088,7 @@ ldlm_resource_get(struct ldlm_namespace *ns, struct ldlm_resource *parent,
int create) int create)
{ {
struct hlist_node *hnode; struct hlist_node *hnode;
struct ldlm_resource *res; struct ldlm_resource *res = NULL;
struct cfs_hash_bd bd; struct cfs_hash_bd bd;
__u64 version; __u64 version;
int ns_refcount = 0; int ns_refcount = 0;
...@@ -1101,31 +1101,20 @@ ldlm_resource_get(struct ldlm_namespace *ns, struct ldlm_resource *parent, ...@@ -1101,31 +1101,20 @@ ldlm_resource_get(struct ldlm_namespace *ns, struct ldlm_resource *parent,
hnode = cfs_hash_bd_lookup_locked(ns->ns_rs_hash, &bd, (void *)name); hnode = cfs_hash_bd_lookup_locked(ns->ns_rs_hash, &bd, (void *)name);
if (hnode) { if (hnode) {
cfs_hash_bd_unlock(ns->ns_rs_hash, &bd, 0); cfs_hash_bd_unlock(ns->ns_rs_hash, &bd, 0);
res = hlist_entry(hnode, struct ldlm_resource, lr_hash); goto lvbo_init;
/* Synchronize with regard to resource creation. */
if (ns->ns_lvbo && ns->ns_lvbo->lvbo_init) {
mutex_lock(&res->lr_lvb_mutex);
mutex_unlock(&res->lr_lvb_mutex);
}
if (unlikely(res->lr_lvb_len < 0)) {
ldlm_resource_putref(res);
res = NULL;
}
return res;
} }
version = cfs_hash_bd_version_get(&bd); version = cfs_hash_bd_version_get(&bd);
cfs_hash_bd_unlock(ns->ns_rs_hash, &bd, 0); cfs_hash_bd_unlock(ns->ns_rs_hash, &bd, 0);
if (create == 0) if (create == 0)
return NULL; return ERR_PTR(-ENOENT);
LASSERTF(type >= LDLM_MIN_TYPE && type < LDLM_MAX_TYPE, LASSERTF(type >= LDLM_MIN_TYPE && type < LDLM_MAX_TYPE,
"type: %d\n", type); "type: %d\n", type);
res = ldlm_resource_new(); res = ldlm_resource_new();
if (!res) if (!res)
return NULL; return ERR_PTR(-ENOMEM);
res->lr_ns_bucket = cfs_hash_bd_extra_get(ns->ns_rs_hash, &bd); res->lr_ns_bucket = cfs_hash_bd_extra_get(ns->ns_rs_hash, &bd);
res->lr_name = *name; res->lr_name = *name;
...@@ -1143,7 +1132,7 @@ ldlm_resource_get(struct ldlm_namespace *ns, struct ldlm_resource *parent, ...@@ -1143,7 +1132,7 @@ ldlm_resource_get(struct ldlm_namespace *ns, struct ldlm_resource *parent,
/* We have taken lr_lvb_mutex. Drop it. */ /* We have taken lr_lvb_mutex. Drop it. */
mutex_unlock(&res->lr_lvb_mutex); mutex_unlock(&res->lr_lvb_mutex);
kmem_cache_free(ldlm_resource_slab, res); kmem_cache_free(ldlm_resource_slab, res);
lvbo_init:
res = hlist_entry(hnode, struct ldlm_resource, lr_hash); res = hlist_entry(hnode, struct ldlm_resource, lr_hash);
/* Synchronize with regard to resource creation. */ /* Synchronize with regard to resource creation. */
if (ns->ns_lvbo && ns->ns_lvbo->lvbo_init) { if (ns->ns_lvbo && ns->ns_lvbo->lvbo_init) {
...@@ -1153,7 +1142,7 @@ ldlm_resource_get(struct ldlm_namespace *ns, struct ldlm_resource *parent, ...@@ -1153,7 +1142,7 @@ ldlm_resource_get(struct ldlm_namespace *ns, struct ldlm_resource *parent,
if (unlikely(res->lr_lvb_len < 0)) { if (unlikely(res->lr_lvb_len < 0)) {
ldlm_resource_putref(res); ldlm_resource_putref(res);
res = NULL; res = ERR_PTR(res->lr_lvb_len);
} }
return res; return res;
} }
...@@ -1175,7 +1164,7 @@ ldlm_resource_get(struct ldlm_namespace *ns, struct ldlm_resource *parent, ...@@ -1175,7 +1164,7 @@ ldlm_resource_get(struct ldlm_namespace *ns, struct ldlm_resource *parent,
res->lr_lvb_len = rc; res->lr_lvb_len = rc;
mutex_unlock(&res->lr_lvb_mutex); mutex_unlock(&res->lr_lvb_mutex);
ldlm_resource_putref(res); ldlm_resource_putref(res);
return NULL; return ERR_PTR(rc);
} }
} }
......
...@@ -174,7 +174,7 @@ int mdc_null_inode(struct obd_export *exp, ...@@ -174,7 +174,7 @@ int mdc_null_inode(struct obd_export *exp,
fid_build_reg_res_name(fid, &res_id); fid_build_reg_res_name(fid, &res_id);
res = ldlm_resource_get(ns, NULL, &res_id, 0, 0); res = ldlm_resource_get(ns, NULL, &res_id, 0, 0);
if (!res) if (IS_ERR(res))
return 0; return 0;
lock_res(res); lock_res(res);
......
...@@ -86,7 +86,7 @@ int mdc_resource_get_unused(struct obd_export *exp, const struct lu_fid *fid, ...@@ -86,7 +86,7 @@ int mdc_resource_get_unused(struct obd_export *exp, const struct lu_fid *fid,
fid_build_reg_res_name(fid, &res_id); fid_build_reg_res_name(fid, &res_id);
res = ldlm_resource_get(exp->exp_obd->obd_namespace, res = ldlm_resource_get(exp->exp_obd->obd_namespace,
NULL, &res_id, 0, 0); NULL, &res_id, 0, 0);
if (!res) if (IS_ERR(res))
return 0; return 0;
LDLM_RESOURCE_ADDREF(res); LDLM_RESOURCE_ADDREF(res);
/* Initialize ibits lock policy. */ /* Initialize ibits lock policy. */
......
...@@ -650,7 +650,7 @@ static int osc_resource_get_unused(struct obd_export *exp, struct obdo *oa, ...@@ -650,7 +650,7 @@ static int osc_resource_get_unused(struct obd_export *exp, struct obdo *oa,
ostid_build_res_name(&oa->o_oi, &res_id); ostid_build_res_name(&oa->o_oi, &res_id);
res = ldlm_resource_get(ns, NULL, &res_id, 0, 0); res = ldlm_resource_get(ns, NULL, &res_id, 0, 0);
if (!res) if (IS_ERR(res))
return 0; return 0;
LDLM_RESOURCE_ADDREF(res); LDLM_RESOURCE_ADDREF(res);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment