提交 df53cd3b 编写于 作者: D Dong Fang 提交者: Linus Torvalds

ocfs2: use list_for_each_entry() instead of list_for_each()

[dan.carpenter@oracle.com: fix up some NULL dereference bugs]
Signed-off-by: NDong Fang <yp.fangdong@gmail.com>
Cc: Mark Fasheh <mfasheh@suse.com>
Cc: Joel Becker <jlbec@evilplan.org>
Cc: Jeff Liu <jeff.liu@oracle.com>
Signed-off-by: NDan Carpenter <dan.carpenter@oracle.com>
Signed-off-by: NAndrew Morton <akpm@linux-foundation.org>
Signed-off-by: NLinus Torvalds <torvalds@linux-foundation.org>
上级 8dd7903e
...@@ -628,11 +628,9 @@ static void o2hb_fire_callbacks(struct o2hb_callback *hbcall, ...@@ -628,11 +628,9 @@ static void o2hb_fire_callbacks(struct o2hb_callback *hbcall,
struct o2nm_node *node, struct o2nm_node *node,
int idx) int idx)
{ {
struct list_head *iter;
struct o2hb_callback_func *f; struct o2hb_callback_func *f;
list_for_each(iter, &hbcall->list) { list_for_each_entry(f, &hbcall->list, hc_item) {
f = list_entry(iter, struct o2hb_callback_func, hc_item);
mlog(ML_HEARTBEAT, "calling funcs %p\n", f); mlog(ML_HEARTBEAT, "calling funcs %p\n", f);
(f->hc_func)(node, idx, f->hc_data); (f->hc_func)(node, idx, f->hc_data);
} }
...@@ -2516,8 +2514,7 @@ void o2hb_region_dec_user(const char *region_uuid) ...@@ -2516,8 +2514,7 @@ void o2hb_region_dec_user(const char *region_uuid)
int o2hb_register_callback(const char *region_uuid, int o2hb_register_callback(const char *region_uuid,
struct o2hb_callback_func *hc) struct o2hb_callback_func *hc)
{ {
struct o2hb_callback_func *tmp; struct o2hb_callback_func *f;
struct list_head *iter;
struct o2hb_callback *hbcall; struct o2hb_callback *hbcall;
int ret; int ret;
...@@ -2540,10 +2537,9 @@ int o2hb_register_callback(const char *region_uuid, ...@@ -2540,10 +2537,9 @@ int o2hb_register_callback(const char *region_uuid,
down_write(&o2hb_callback_sem); down_write(&o2hb_callback_sem);
list_for_each(iter, &hbcall->list) { list_for_each_entry(f, &hbcall->list, hc_item) {
tmp = list_entry(iter, struct o2hb_callback_func, hc_item); if (hc->hc_priority < f->hc_priority) {
if (hc->hc_priority < tmp->hc_priority) { list_add_tail(&hc->hc_item, &f->hc_item);
list_add_tail(&hc->hc_item, iter);
break; break;
} }
} }
......
...@@ -292,7 +292,7 @@ int dlm_proxy_ast_handler(struct o2net_msg *msg, u32 len, void *data, ...@@ -292,7 +292,7 @@ int dlm_proxy_ast_handler(struct o2net_msg *msg, u32 len, void *data,
struct dlm_lock *lock = NULL; struct dlm_lock *lock = NULL;
struct dlm_proxy_ast *past = (struct dlm_proxy_ast *) msg->buf; struct dlm_proxy_ast *past = (struct dlm_proxy_ast *) msg->buf;
char *name; char *name;
struct list_head *iter, *head=NULL; struct list_head *head = NULL;
__be64 cookie; __be64 cookie;
u32 flags; u32 flags;
u8 node; u8 node;
...@@ -373,8 +373,7 @@ int dlm_proxy_ast_handler(struct o2net_msg *msg, u32 len, void *data, ...@@ -373,8 +373,7 @@ int dlm_proxy_ast_handler(struct o2net_msg *msg, u32 len, void *data,
/* try convert queue for both ast/bast */ /* try convert queue for both ast/bast */
head = &res->converting; head = &res->converting;
lock = NULL; lock = NULL;
list_for_each(iter, head) { list_for_each_entry(lock, head, list) {
lock = list_entry (iter, struct dlm_lock, list);
if (lock->ml.cookie == cookie) if (lock->ml.cookie == cookie)
goto do_ast; goto do_ast;
} }
...@@ -385,8 +384,7 @@ int dlm_proxy_ast_handler(struct o2net_msg *msg, u32 len, void *data, ...@@ -385,8 +384,7 @@ int dlm_proxy_ast_handler(struct o2net_msg *msg, u32 len, void *data,
else else
head = &res->granted; head = &res->granted;
list_for_each(iter, head) { list_for_each_entry(lock, head, list) {
lock = list_entry (iter, struct dlm_lock, list);
if (lock->ml.cookie == cookie) if (lock->ml.cookie == cookie)
goto do_ast; goto do_ast;
} }
......
...@@ -1079,11 +1079,9 @@ static inline int dlm_lock_compatible(int existing, int request) ...@@ -1079,11 +1079,9 @@ static inline int dlm_lock_compatible(int existing, int request)
static inline int dlm_lock_on_list(struct list_head *head, static inline int dlm_lock_on_list(struct list_head *head,
struct dlm_lock *lock) struct dlm_lock *lock)
{ {
struct list_head *iter;
struct dlm_lock *tmplock; struct dlm_lock *tmplock;
list_for_each(iter, head) { list_for_each_entry(tmplock, head, list) {
tmplock = list_entry(iter, struct dlm_lock, list);
if (tmplock == lock) if (tmplock == lock)
return 1; return 1;
} }
......
...@@ -123,7 +123,6 @@ static enum dlm_status __dlmconvert_master(struct dlm_ctxt *dlm, ...@@ -123,7 +123,6 @@ static enum dlm_status __dlmconvert_master(struct dlm_ctxt *dlm,
int *kick_thread) int *kick_thread)
{ {
enum dlm_status status = DLM_NORMAL; enum dlm_status status = DLM_NORMAL;
struct list_head *iter;
struct dlm_lock *tmplock=NULL; struct dlm_lock *tmplock=NULL;
assert_spin_locked(&res->spinlock); assert_spin_locked(&res->spinlock);
...@@ -185,16 +184,14 @@ static enum dlm_status __dlmconvert_master(struct dlm_ctxt *dlm, ...@@ -185,16 +184,14 @@ static enum dlm_status __dlmconvert_master(struct dlm_ctxt *dlm,
/* upconvert from here on */ /* upconvert from here on */
status = DLM_NORMAL; status = DLM_NORMAL;
list_for_each(iter, &res->granted) { list_for_each_entry(tmplock, &res->granted, list) {
tmplock = list_entry(iter, struct dlm_lock, list);
if (tmplock == lock) if (tmplock == lock)
continue; continue;
if (!dlm_lock_compatible(tmplock->ml.type, type)) if (!dlm_lock_compatible(tmplock->ml.type, type))
goto switch_queues; goto switch_queues;
} }
list_for_each(iter, &res->converting) { list_for_each_entry(tmplock, &res->converting, list) {
tmplock = list_entry(iter, struct dlm_lock, list);
if (!dlm_lock_compatible(tmplock->ml.type, type)) if (!dlm_lock_compatible(tmplock->ml.type, type))
goto switch_queues; goto switch_queues;
/* existing conversion requests take precedence */ /* existing conversion requests take precedence */
...@@ -424,8 +421,8 @@ int dlm_convert_lock_handler(struct o2net_msg *msg, u32 len, void *data, ...@@ -424,8 +421,8 @@ int dlm_convert_lock_handler(struct o2net_msg *msg, u32 len, void *data,
struct dlm_ctxt *dlm = data; struct dlm_ctxt *dlm = data;
struct dlm_convert_lock *cnv = (struct dlm_convert_lock *)msg->buf; struct dlm_convert_lock *cnv = (struct dlm_convert_lock *)msg->buf;
struct dlm_lock_resource *res = NULL; struct dlm_lock_resource *res = NULL;
struct list_head *iter;
struct dlm_lock *lock = NULL; struct dlm_lock *lock = NULL;
struct dlm_lock *tmp_lock;
struct dlm_lockstatus *lksb; struct dlm_lockstatus *lksb;
enum dlm_status status = DLM_NORMAL; enum dlm_status status = DLM_NORMAL;
u32 flags; u32 flags;
...@@ -471,14 +468,13 @@ int dlm_convert_lock_handler(struct o2net_msg *msg, u32 len, void *data, ...@@ -471,14 +468,13 @@ int dlm_convert_lock_handler(struct o2net_msg *msg, u32 len, void *data,
dlm_error(status); dlm_error(status);
goto leave; goto leave;
} }
list_for_each(iter, &res->granted) { list_for_each_entry(tmp_lock, &res->granted, list) {
lock = list_entry(iter, struct dlm_lock, list); if (tmp_lock->ml.cookie == cnv->cookie &&
if (lock->ml.cookie == cnv->cookie && tmp_lock->ml.node == cnv->node_idx) {
lock->ml.node == cnv->node_idx) { lock = tmp_lock;
dlm_lock_get(lock); dlm_lock_get(lock);
break; break;
} }
lock = NULL;
} }
spin_unlock(&res->spinlock); spin_unlock(&res->spinlock);
if (!lock) { if (!lock) {
......
...@@ -96,7 +96,6 @@ static void __dlm_print_lock(struct dlm_lock *lock) ...@@ -96,7 +96,6 @@ static void __dlm_print_lock(struct dlm_lock *lock)
void __dlm_print_one_lock_resource(struct dlm_lock_resource *res) void __dlm_print_one_lock_resource(struct dlm_lock_resource *res)
{ {
struct list_head *iter2;
struct dlm_lock *lock; struct dlm_lock *lock;
char buf[DLM_LOCKID_NAME_MAX]; char buf[DLM_LOCKID_NAME_MAX];
...@@ -118,18 +117,15 @@ void __dlm_print_one_lock_resource(struct dlm_lock_resource *res) ...@@ -118,18 +117,15 @@ void __dlm_print_one_lock_resource(struct dlm_lock_resource *res)
res->inflight_locks, atomic_read(&res->asts_reserved)); res->inflight_locks, atomic_read(&res->asts_reserved));
dlm_print_lockres_refmap(res); dlm_print_lockres_refmap(res);
printk(" granted queue:\n"); printk(" granted queue:\n");
list_for_each(iter2, &res->granted) { list_for_each_entry(lock, &res->granted, list) {
lock = list_entry(iter2, struct dlm_lock, list);
__dlm_print_lock(lock); __dlm_print_lock(lock);
} }
printk(" converting queue:\n"); printk(" converting queue:\n");
list_for_each(iter2, &res->converting) { list_for_each_entry(lock, &res->converting, list) {
lock = list_entry(iter2, struct dlm_lock, list);
__dlm_print_lock(lock); __dlm_print_lock(lock);
} }
printk(" blocked queue:\n"); printk(" blocked queue:\n");
list_for_each(iter2, &res->blocked) { list_for_each_entry(lock, &res->blocked, list) {
lock = list_entry(iter2, struct dlm_lock, list);
__dlm_print_lock(lock); __dlm_print_lock(lock);
} }
} }
...@@ -446,7 +442,6 @@ static int debug_mle_print(struct dlm_ctxt *dlm, char *buf, int len) ...@@ -446,7 +442,6 @@ static int debug_mle_print(struct dlm_ctxt *dlm, char *buf, int len)
{ {
struct dlm_master_list_entry *mle; struct dlm_master_list_entry *mle;
struct hlist_head *bucket; struct hlist_head *bucket;
struct hlist_node *list;
int i, out = 0; int i, out = 0;
unsigned long total = 0, longest = 0, bucket_count = 0; unsigned long total = 0, longest = 0, bucket_count = 0;
...@@ -456,9 +451,7 @@ static int debug_mle_print(struct dlm_ctxt *dlm, char *buf, int len) ...@@ -456,9 +451,7 @@ static int debug_mle_print(struct dlm_ctxt *dlm, char *buf, int len)
spin_lock(&dlm->master_lock); spin_lock(&dlm->master_lock);
for (i = 0; i < DLM_HASH_BUCKETS; i++) { for (i = 0; i < DLM_HASH_BUCKETS; i++) {
bucket = dlm_master_hash(dlm, i); bucket = dlm_master_hash(dlm, i);
hlist_for_each(list, bucket) { hlist_for_each_entry(mle, bucket, master_hash_node) {
mle = hlist_entry(list, struct dlm_master_list_entry,
master_hash_node);
++total; ++total;
++bucket_count; ++bucket_count;
if (len - out < 200) if (len - out < 200)
......
...@@ -193,7 +193,7 @@ struct dlm_lock_resource * __dlm_lookup_lockres_full(struct dlm_ctxt *dlm, ...@@ -193,7 +193,7 @@ struct dlm_lock_resource * __dlm_lookup_lockres_full(struct dlm_ctxt *dlm,
unsigned int hash) unsigned int hash)
{ {
struct hlist_head *bucket; struct hlist_head *bucket;
struct hlist_node *list; struct dlm_lock_resource *res;
mlog(0, "%.*s\n", len, name); mlog(0, "%.*s\n", len, name);
...@@ -201,9 +201,7 @@ struct dlm_lock_resource * __dlm_lookup_lockres_full(struct dlm_ctxt *dlm, ...@@ -201,9 +201,7 @@ struct dlm_lock_resource * __dlm_lookup_lockres_full(struct dlm_ctxt *dlm,
bucket = dlm_lockres_hash(dlm, hash); bucket = dlm_lockres_hash(dlm, hash);
hlist_for_each(list, bucket) { hlist_for_each_entry(res, bucket, hash_node) {
struct dlm_lock_resource *res = hlist_entry(list,
struct dlm_lock_resource, hash_node);
if (res->lockname.name[0] != name[0]) if (res->lockname.name[0] != name[0])
continue; continue;
if (unlikely(res->lockname.len != len)) if (unlikely(res->lockname.len != len))
...@@ -262,22 +260,19 @@ struct dlm_lock_resource * dlm_lookup_lockres(struct dlm_ctxt *dlm, ...@@ -262,22 +260,19 @@ struct dlm_lock_resource * dlm_lookup_lockres(struct dlm_ctxt *dlm,
static struct dlm_ctxt * __dlm_lookup_domain_full(const char *domain, int len) static struct dlm_ctxt * __dlm_lookup_domain_full(const char *domain, int len)
{ {
struct dlm_ctxt *tmp = NULL; struct dlm_ctxt *tmp;
struct list_head *iter;
assert_spin_locked(&dlm_domain_lock); assert_spin_locked(&dlm_domain_lock);
/* tmp->name here is always NULL terminated, /* tmp->name here is always NULL terminated,
* but domain may not be! */ * but domain may not be! */
list_for_each(iter, &dlm_domains) { list_for_each_entry(tmp, &dlm_domains, list) {
tmp = list_entry (iter, struct dlm_ctxt, list);
if (strlen(tmp->name) == len && if (strlen(tmp->name) == len &&
memcmp(tmp->name, domain, len)==0) memcmp(tmp->name, domain, len)==0)
break; return tmp;
tmp = NULL;
} }
return tmp; return NULL;
} }
/* For null terminated domain strings ONLY */ /* For null terminated domain strings ONLY */
...@@ -366,25 +361,22 @@ static void __dlm_get(struct dlm_ctxt *dlm) ...@@ -366,25 +361,22 @@ static void __dlm_get(struct dlm_ctxt *dlm)
* you shouldn't trust your pointer. */ * you shouldn't trust your pointer. */
struct dlm_ctxt *dlm_grab(struct dlm_ctxt *dlm) struct dlm_ctxt *dlm_grab(struct dlm_ctxt *dlm)
{ {
struct list_head *iter; struct dlm_ctxt *target;
struct dlm_ctxt *target = NULL; struct dlm_ctxt *ret = NULL;
spin_lock(&dlm_domain_lock); spin_lock(&dlm_domain_lock);
list_for_each(iter, &dlm_domains) { list_for_each_entry(target, &dlm_domains, list) {
target = list_entry (iter, struct dlm_ctxt, list);
if (target == dlm) { if (target == dlm) {
__dlm_get(target); __dlm_get(target);
ret = target;
break; break;
} }
target = NULL;
} }
spin_unlock(&dlm_domain_lock); spin_unlock(&dlm_domain_lock);
return target; return ret;
} }
int dlm_domain_fully_joined(struct dlm_ctxt *dlm) int dlm_domain_fully_joined(struct dlm_ctxt *dlm)
...@@ -2296,13 +2288,10 @@ static DECLARE_RWSEM(dlm_callback_sem); ...@@ -2296,13 +2288,10 @@ static DECLARE_RWSEM(dlm_callback_sem);
void dlm_fire_domain_eviction_callbacks(struct dlm_ctxt *dlm, void dlm_fire_domain_eviction_callbacks(struct dlm_ctxt *dlm,
int node_num) int node_num)
{ {
struct list_head *iter;
struct dlm_eviction_cb *cb; struct dlm_eviction_cb *cb;
down_read(&dlm_callback_sem); down_read(&dlm_callback_sem);
list_for_each(iter, &dlm->dlm_eviction_callbacks) { list_for_each_entry(cb, &dlm->dlm_eviction_callbacks, ec_item) {
cb = list_entry(iter, struct dlm_eviction_cb, ec_item);
cb->ec_func(node_num, cb->ec_data); cb->ec_func(node_num, cb->ec_data);
} }
up_read(&dlm_callback_sem); up_read(&dlm_callback_sem);
......
...@@ -91,19 +91,14 @@ void dlm_destroy_lock_cache(void) ...@@ -91,19 +91,14 @@ void dlm_destroy_lock_cache(void)
static int dlm_can_grant_new_lock(struct dlm_lock_resource *res, static int dlm_can_grant_new_lock(struct dlm_lock_resource *res,
struct dlm_lock *lock) struct dlm_lock *lock)
{ {
struct list_head *iter;
struct dlm_lock *tmplock; struct dlm_lock *tmplock;
list_for_each(iter, &res->granted) { list_for_each_entry(tmplock, &res->granted, list) {
tmplock = list_entry(iter, struct dlm_lock, list);
if (!dlm_lock_compatible(tmplock->ml.type, lock->ml.type)) if (!dlm_lock_compatible(tmplock->ml.type, lock->ml.type))
return 0; return 0;
} }
list_for_each(iter, &res->converting) { list_for_each_entry(tmplock, &res->converting, list) {
tmplock = list_entry(iter, struct dlm_lock, list);
if (!dlm_lock_compatible(tmplock->ml.type, lock->ml.type)) if (!dlm_lock_compatible(tmplock->ml.type, lock->ml.type))
return 0; return 0;
if (!dlm_lock_compatible(tmplock->ml.convert_type, if (!dlm_lock_compatible(tmplock->ml.convert_type,
......
...@@ -342,16 +342,13 @@ static int dlm_find_mle(struct dlm_ctxt *dlm, ...@@ -342,16 +342,13 @@ static int dlm_find_mle(struct dlm_ctxt *dlm,
{ {
struct dlm_master_list_entry *tmpmle; struct dlm_master_list_entry *tmpmle;
struct hlist_head *bucket; struct hlist_head *bucket;
struct hlist_node *list;
unsigned int hash; unsigned int hash;
assert_spin_locked(&dlm->master_lock); assert_spin_locked(&dlm->master_lock);
hash = dlm_lockid_hash(name, namelen); hash = dlm_lockid_hash(name, namelen);
bucket = dlm_master_hash(dlm, hash); bucket = dlm_master_hash(dlm, hash);
hlist_for_each(list, bucket) { hlist_for_each_entry(tmpmle, bucket, master_hash_node) {
tmpmle = hlist_entry(list, struct dlm_master_list_entry,
master_hash_node);
if (!dlm_mle_equal(dlm, tmpmle, name, namelen)) if (!dlm_mle_equal(dlm, tmpmle, name, namelen))
continue; continue;
dlm_get_mle(tmpmle); dlm_get_mle(tmpmle);
...@@ -3183,7 +3180,7 @@ void dlm_clean_master_list(struct dlm_ctxt *dlm, u8 dead_node) ...@@ -3183,7 +3180,7 @@ void dlm_clean_master_list(struct dlm_ctxt *dlm, u8 dead_node)
struct dlm_master_list_entry *mle; struct dlm_master_list_entry *mle;
struct dlm_lock_resource *res; struct dlm_lock_resource *res;
struct hlist_head *bucket; struct hlist_head *bucket;
struct hlist_node *list; struct hlist_node *tmp;
unsigned int i; unsigned int i;
mlog(0, "dlm=%s, dead node=%u\n", dlm->name, dead_node); mlog(0, "dlm=%s, dead node=%u\n", dlm->name, dead_node);
...@@ -3194,10 +3191,7 @@ void dlm_clean_master_list(struct dlm_ctxt *dlm, u8 dead_node) ...@@ -3194,10 +3191,7 @@ void dlm_clean_master_list(struct dlm_ctxt *dlm, u8 dead_node)
spin_lock(&dlm->master_lock); spin_lock(&dlm->master_lock);
for (i = 0; i < DLM_HASH_BUCKETS; i++) { for (i = 0; i < DLM_HASH_BUCKETS; i++) {
bucket = dlm_master_hash(dlm, i); bucket = dlm_master_hash(dlm, i);
hlist_for_each(list, bucket) { hlist_for_each_entry_safe(mle, tmp, bucket, master_hash_node) {
mle = hlist_entry(list, struct dlm_master_list_entry,
master_hash_node);
BUG_ON(mle->type != DLM_MLE_BLOCK && BUG_ON(mle->type != DLM_MLE_BLOCK &&
mle->type != DLM_MLE_MASTER && mle->type != DLM_MLE_MASTER &&
mle->type != DLM_MLE_MIGRATION); mle->type != DLM_MLE_MIGRATION);
...@@ -3378,7 +3372,7 @@ void dlm_force_free_mles(struct dlm_ctxt *dlm) ...@@ -3378,7 +3372,7 @@ void dlm_force_free_mles(struct dlm_ctxt *dlm)
int i; int i;
struct hlist_head *bucket; struct hlist_head *bucket;
struct dlm_master_list_entry *mle; struct dlm_master_list_entry *mle;
struct hlist_node *tmp, *list; struct hlist_node *tmp;
/* /*
* We notified all other nodes that we are exiting the domain and * We notified all other nodes that we are exiting the domain and
...@@ -3394,9 +3388,7 @@ void dlm_force_free_mles(struct dlm_ctxt *dlm) ...@@ -3394,9 +3388,7 @@ void dlm_force_free_mles(struct dlm_ctxt *dlm)
for (i = 0; i < DLM_HASH_BUCKETS; i++) { for (i = 0; i < DLM_HASH_BUCKETS; i++) {
bucket = dlm_master_hash(dlm, i); bucket = dlm_master_hash(dlm, i);
hlist_for_each_safe(list, tmp, bucket) { hlist_for_each_entry_safe(mle, tmp, bucket, master_hash_node) {
mle = hlist_entry(list, struct dlm_master_list_entry,
master_hash_node);
if (mle->type != DLM_MLE_BLOCK) { if (mle->type != DLM_MLE_BLOCK) {
mlog(ML_ERROR, "bad mle: %p\n", mle); mlog(ML_ERROR, "bad mle: %p\n", mle);
dlm_print_one_mle(mle); dlm_print_one_mle(mle);
......
...@@ -286,8 +286,6 @@ static void dlm_shuffle_lists(struct dlm_ctxt *dlm, ...@@ -286,8 +286,6 @@ static void dlm_shuffle_lists(struct dlm_ctxt *dlm,
struct dlm_lock_resource *res) struct dlm_lock_resource *res)
{ {
struct dlm_lock *lock, *target; struct dlm_lock *lock, *target;
struct list_head *iter;
struct list_head *head;
int can_grant = 1; int can_grant = 1;
/* /*
...@@ -314,9 +312,7 @@ static void dlm_shuffle_lists(struct dlm_ctxt *dlm, ...@@ -314,9 +312,7 @@ static void dlm_shuffle_lists(struct dlm_ctxt *dlm,
dlm->name, res->lockname.len, res->lockname.name); dlm->name, res->lockname.len, res->lockname.name);
BUG(); BUG();
} }
head = &res->granted; list_for_each_entry(lock, &res->granted, list) {
list_for_each(iter, head) {
lock = list_entry(iter, struct dlm_lock, list);
if (lock==target) if (lock==target)
continue; continue;
if (!dlm_lock_compatible(lock->ml.type, if (!dlm_lock_compatible(lock->ml.type,
...@@ -333,9 +329,8 @@ static void dlm_shuffle_lists(struct dlm_ctxt *dlm, ...@@ -333,9 +329,8 @@ static void dlm_shuffle_lists(struct dlm_ctxt *dlm,
target->ml.convert_type; target->ml.convert_type;
} }
} }
head = &res->converting;
list_for_each(iter, head) { list_for_each_entry(lock, &res->converting, list) {
lock = list_entry(iter, struct dlm_lock, list);
if (lock==target) if (lock==target)
continue; continue;
if (!dlm_lock_compatible(lock->ml.type, if (!dlm_lock_compatible(lock->ml.type,
...@@ -384,9 +379,7 @@ static void dlm_shuffle_lists(struct dlm_ctxt *dlm, ...@@ -384,9 +379,7 @@ static void dlm_shuffle_lists(struct dlm_ctxt *dlm,
goto leave; goto leave;
target = list_entry(res->blocked.next, struct dlm_lock, list); target = list_entry(res->blocked.next, struct dlm_lock, list);
head = &res->granted; list_for_each_entry(lock, &res->granted, list) {
list_for_each(iter, head) {
lock = list_entry(iter, struct dlm_lock, list);
if (lock==target) if (lock==target)
continue; continue;
if (!dlm_lock_compatible(lock->ml.type, target->ml.type)) { if (!dlm_lock_compatible(lock->ml.type, target->ml.type)) {
...@@ -400,9 +393,7 @@ static void dlm_shuffle_lists(struct dlm_ctxt *dlm, ...@@ -400,9 +393,7 @@ static void dlm_shuffle_lists(struct dlm_ctxt *dlm,
} }
} }
head = &res->converting; list_for_each_entry(lock, &res->converting, list) {
list_for_each(iter, head) {
lock = list_entry(iter, struct dlm_lock, list);
if (lock==target) if (lock==target)
continue; continue;
if (!dlm_lock_compatible(lock->ml.type, target->ml.type)) { if (!dlm_lock_compatible(lock->ml.type, target->ml.type)) {
......
...@@ -388,7 +388,6 @@ int dlm_unlock_lock_handler(struct o2net_msg *msg, u32 len, void *data, ...@@ -388,7 +388,6 @@ int dlm_unlock_lock_handler(struct o2net_msg *msg, u32 len, void *data,
struct dlm_ctxt *dlm = data; struct dlm_ctxt *dlm = data;
struct dlm_unlock_lock *unlock = (struct dlm_unlock_lock *)msg->buf; struct dlm_unlock_lock *unlock = (struct dlm_unlock_lock *)msg->buf;
struct dlm_lock_resource *res = NULL; struct dlm_lock_resource *res = NULL;
struct list_head *iter;
struct dlm_lock *lock = NULL; struct dlm_lock *lock = NULL;
enum dlm_status status = DLM_NORMAL; enum dlm_status status = DLM_NORMAL;
int found = 0, i; int found = 0, i;
...@@ -458,8 +457,7 @@ int dlm_unlock_lock_handler(struct o2net_msg *msg, u32 len, void *data, ...@@ -458,8 +457,7 @@ int dlm_unlock_lock_handler(struct o2net_msg *msg, u32 len, void *data,
} }
for (i=0; i<3; i++) { for (i=0; i<3; i++) {
list_for_each(iter, queue) { list_for_each_entry(lock, queue, list) {
lock = list_entry(iter, struct dlm_lock, list);
if (lock->ml.cookie == unlock->cookie && if (lock->ml.cookie == unlock->cookie &&
lock->ml.node == unlock->node_idx) { lock->ml.node == unlock->node_idx) {
dlm_lock_get(lock); dlm_lock_get(lock);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册