Commit 8d400b81 authored by Sunil Mushran's avatar Sunil Mushran

ocfs2/dlm: Clean up refmap helpers

Patch cleans up helpers that set/clear refmap bits and grab/drop inflight lock
ref counts.
Signed-off-by: default avatarSunil Mushran <sunil.mushran@oracle.com>
parent 0afbba13
...@@ -902,46 +902,15 @@ struct dlm_lock_resource *dlm_new_lockres(struct dlm_ctxt *dlm, ...@@ -902,46 +902,15 @@ struct dlm_lock_resource *dlm_new_lockres(struct dlm_ctxt *dlm,
const char *name, const char *name,
unsigned int namelen); unsigned int namelen);
#define dlm_lockres_set_refmap_bit(bit,res) \ void dlm_lockres_set_refmap_bit(struct dlm_ctxt *dlm,
__dlm_lockres_set_refmap_bit(bit,res,__FILE__,__LINE__) struct dlm_lock_resource *res, int bit);
#define dlm_lockres_clear_refmap_bit(bit,res) \ void dlm_lockres_clear_refmap_bit(struct dlm_ctxt *dlm,
__dlm_lockres_clear_refmap_bit(bit,res,__FILE__,__LINE__) struct dlm_lock_resource *res, int bit);
static inline void __dlm_lockres_set_refmap_bit(int bit, void dlm_lockres_drop_inflight_ref(struct dlm_ctxt *dlm,
struct dlm_lock_resource *res, struct dlm_lock_resource *res);
const char *file, void dlm_lockres_grab_inflight_ref(struct dlm_ctxt *dlm,
int line) struct dlm_lock_resource *res);
{
//printk("%s:%d:%.*s: setting bit %d\n", file, line,
// res->lockname.len, res->lockname.name, bit);
set_bit(bit, res->refmap);
}
static inline void __dlm_lockres_clear_refmap_bit(int bit,
struct dlm_lock_resource *res,
const char *file,
int line)
{
//printk("%s:%d:%.*s: clearing bit %d\n", file, line,
// res->lockname.len, res->lockname.name, bit);
clear_bit(bit, res->refmap);
}
void __dlm_lockres_drop_inflight_ref(struct dlm_ctxt *dlm,
struct dlm_lock_resource *res,
const char *file,
int line);
void __dlm_lockres_grab_inflight_ref(struct dlm_ctxt *dlm,
struct dlm_lock_resource *res,
int new_lockres,
const char *file,
int line);
#define dlm_lockres_drop_inflight_ref(d,r) \
__dlm_lockres_drop_inflight_ref(d,r,__FILE__,__LINE__)
#define dlm_lockres_grab_inflight_ref(d,r) \
__dlm_lockres_grab_inflight_ref(d,r,0,__FILE__,__LINE__)
#define dlm_lockres_grab_inflight_ref_new(d,r) \
__dlm_lockres_grab_inflight_ref(d,r,1,__FILE__,__LINE__)
void dlm_queue_ast(struct dlm_ctxt *dlm, struct dlm_lock *lock); void dlm_queue_ast(struct dlm_ctxt *dlm, struct dlm_lock *lock);
void dlm_queue_bast(struct dlm_ctxt *dlm, struct dlm_lock *lock); void dlm_queue_bast(struct dlm_ctxt *dlm, struct dlm_lock *lock);
......
...@@ -631,39 +631,58 @@ struct dlm_lock_resource *dlm_new_lockres(struct dlm_ctxt *dlm, ...@@ -631,39 +631,58 @@ struct dlm_lock_resource *dlm_new_lockres(struct dlm_ctxt *dlm,
return NULL; return NULL;
} }
void __dlm_lockres_grab_inflight_ref(struct dlm_ctxt *dlm, void dlm_lockres_set_refmap_bit(struct dlm_ctxt *dlm,
struct dlm_lock_resource *res, struct dlm_lock_resource *res, int bit)
int new_lockres, {
const char *file, assert_spin_locked(&res->spinlock);
int line)
mlog(0, "res %.*s, set node %u, %ps()\n", res->lockname.len,
res->lockname.name, bit, __builtin_return_address(0));
set_bit(bit, res->refmap);
}
void dlm_lockres_clear_refmap_bit(struct dlm_ctxt *dlm,
struct dlm_lock_resource *res, int bit)
{
assert_spin_locked(&res->spinlock);
mlog(0, "res %.*s, clr node %u, %ps()\n", res->lockname.len,
res->lockname.name, bit, __builtin_return_address(0));
clear_bit(bit, res->refmap);
}
void dlm_lockres_grab_inflight_ref(struct dlm_ctxt *dlm,
struct dlm_lock_resource *res)
{ {
if (!new_lockres)
assert_spin_locked(&res->spinlock); assert_spin_locked(&res->spinlock);
if (!test_bit(dlm->node_num, res->refmap)) { if (!test_bit(dlm->node_num, res->refmap)) {
BUG_ON(res->inflight_locks != 0); BUG_ON(res->inflight_locks != 0);
dlm_lockres_set_refmap_bit(dlm->node_num, res); dlm_lockres_set_refmap_bit(dlm, res, dlm->node_num);
} }
res->inflight_locks++; res->inflight_locks++;
mlog(0, "%s:%.*s: inflight++: now %u\n", mlog(0, "%s: res %.*s, inflight++: now %u, %ps()\n", dlm->name,
dlm->name, res->lockname.len, res->lockname.name, res->lockname.len, res->lockname.name, res->inflight_locks,
res->inflight_locks); __builtin_return_address(0));
} }
void __dlm_lockres_drop_inflight_ref(struct dlm_ctxt *dlm, void dlm_lockres_drop_inflight_ref(struct dlm_ctxt *dlm,
struct dlm_lock_resource *res, struct dlm_lock_resource *res)
const char *file,
int line)
{ {
assert_spin_locked(&res->spinlock); assert_spin_locked(&res->spinlock);
BUG_ON(res->inflight_locks == 0); BUG_ON(res->inflight_locks == 0);
res->inflight_locks--; res->inflight_locks--;
mlog(0, "%s:%.*s: inflight--: now %u\n", mlog(0, "%s: res %.*s, inflight--: now %u, %ps()\n", dlm->name,
dlm->name, res->lockname.len, res->lockname.name, res->lockname.len, res->lockname.name, res->inflight_locks,
res->inflight_locks); __builtin_return_address(0));
if (res->inflight_locks == 0) if (res->inflight_locks == 0)
dlm_lockres_clear_refmap_bit(dlm->node_num, res); dlm_lockres_clear_refmap_bit(dlm, res, dlm->node_num);
wake_up(&res->wq); wake_up(&res->wq);
} }
...@@ -843,8 +862,10 @@ struct dlm_lock_resource * dlm_get_lock_resource(struct dlm_ctxt *dlm, ...@@ -843,8 +862,10 @@ struct dlm_lock_resource * dlm_get_lock_resource(struct dlm_ctxt *dlm,
/* finally add the lockres to its hash bucket */ /* finally add the lockres to its hash bucket */
__dlm_insert_lockres(dlm, res); __dlm_insert_lockres(dlm, res);
/* since this lockres is new it doesn't not require the spinlock */
dlm_lockres_grab_inflight_ref_new(dlm, res); spin_lock(&res->spinlock);
dlm_lockres_grab_inflight_ref(dlm, res);
spin_unlock(&res->spinlock);
/* if this node does not become the master make sure to drop /* if this node does not become the master make sure to drop
* this inflight reference below */ * this inflight reference below */
...@@ -1426,9 +1447,7 @@ int dlm_master_request_handler(struct o2net_msg *msg, u32 len, void *data, ...@@ -1426,9 +1447,7 @@ int dlm_master_request_handler(struct o2net_msg *msg, u32 len, void *data,
} }
if (res->owner == dlm->node_num) { if (res->owner == dlm->node_num) {
mlog(0, "%s:%.*s: setting bit %u in refmap\n", dlm_lockres_set_refmap_bit(dlm, res, request->node_idx);
dlm->name, namelen, name, request->node_idx);
dlm_lockres_set_refmap_bit(request->node_idx, res);
spin_unlock(&res->spinlock); spin_unlock(&res->spinlock);
response = DLM_MASTER_RESP_YES; response = DLM_MASTER_RESP_YES;
if (mle) if (mle)
...@@ -1493,9 +1512,7 @@ int dlm_master_request_handler(struct o2net_msg *msg, u32 len, void *data, ...@@ -1493,9 +1512,7 @@ int dlm_master_request_handler(struct o2net_msg *msg, u32 len, void *data,
* go back and clean the mles on any * go back and clean the mles on any
* other nodes */ * other nodes */
dispatch_assert = 1; dispatch_assert = 1;
dlm_lockres_set_refmap_bit(request->node_idx, res); dlm_lockres_set_refmap_bit(dlm, res,
mlog(0, "%s:%.*s: setting bit %u in refmap\n",
dlm->name, namelen, name,
request->node_idx); request->node_idx);
} else } else
response = DLM_MASTER_RESP_NO; response = DLM_MASTER_RESP_NO;
...@@ -1702,7 +1719,7 @@ static int dlm_do_assert_master(struct dlm_ctxt *dlm, ...@@ -1702,7 +1719,7 @@ static int dlm_do_assert_master(struct dlm_ctxt *dlm,
"lockres, set the bit in the refmap\n", "lockres, set the bit in the refmap\n",
namelen, lockname, to); namelen, lockname, to);
spin_lock(&res->spinlock); spin_lock(&res->spinlock);
dlm_lockres_set_refmap_bit(to, res); dlm_lockres_set_refmap_bit(dlm, res, to);
spin_unlock(&res->spinlock); spin_unlock(&res->spinlock);
} }
} }
...@@ -2256,7 +2273,7 @@ int dlm_deref_lockres_handler(struct o2net_msg *msg, u32 len, void *data, ...@@ -2256,7 +2273,7 @@ int dlm_deref_lockres_handler(struct o2net_msg *msg, u32 len, void *data,
else { else {
BUG_ON(res->state & DLM_LOCK_RES_DROPPING_REF); BUG_ON(res->state & DLM_LOCK_RES_DROPPING_REF);
if (test_bit(node, res->refmap)) { if (test_bit(node, res->refmap)) {
dlm_lockres_clear_refmap_bit(node, res); dlm_lockres_clear_refmap_bit(dlm, res, node);
cleared = 1; cleared = 1;
} }
} }
...@@ -2316,7 +2333,7 @@ static void dlm_deref_lockres_worker(struct dlm_work_item *item, void *data) ...@@ -2316,7 +2333,7 @@ static void dlm_deref_lockres_worker(struct dlm_work_item *item, void *data)
BUG_ON(res->state & DLM_LOCK_RES_DROPPING_REF); BUG_ON(res->state & DLM_LOCK_RES_DROPPING_REF);
if (test_bit(node, res->refmap)) { if (test_bit(node, res->refmap)) {
__dlm_wait_on_lockres_flags(res, DLM_LOCK_RES_SETREF_INPROG); __dlm_wait_on_lockres_flags(res, DLM_LOCK_RES_SETREF_INPROG);
dlm_lockres_clear_refmap_bit(node, res); dlm_lockres_clear_refmap_bit(dlm, res, node);
cleared = 1; cleared = 1;
} }
spin_unlock(&res->spinlock); spin_unlock(&res->spinlock);
...@@ -2798,7 +2815,8 @@ static void dlm_remove_nonlocal_locks(struct dlm_ctxt *dlm, ...@@ -2798,7 +2815,8 @@ static void dlm_remove_nonlocal_locks(struct dlm_ctxt *dlm,
BUG_ON(!list_empty(&lock->bast_list)); BUG_ON(!list_empty(&lock->bast_list));
BUG_ON(lock->ast_pending); BUG_ON(lock->ast_pending);
BUG_ON(lock->bast_pending); BUG_ON(lock->bast_pending);
dlm_lockres_clear_refmap_bit(lock->ml.node, res); dlm_lockres_clear_refmap_bit(dlm, res,
lock->ml.node);
list_del_init(&lock->list); list_del_init(&lock->list);
dlm_lock_put(lock); dlm_lock_put(lock);
/* In a normal unlock, we would have added a /* In a normal unlock, we would have added a
...@@ -2819,7 +2837,7 @@ static void dlm_remove_nonlocal_locks(struct dlm_ctxt *dlm, ...@@ -2819,7 +2837,7 @@ static void dlm_remove_nonlocal_locks(struct dlm_ctxt *dlm,
mlog(0, "%s:%.*s: node %u had a ref to this " mlog(0, "%s:%.*s: node %u had a ref to this "
"migrating lockres, clearing\n", dlm->name, "migrating lockres, clearing\n", dlm->name,
res->lockname.len, res->lockname.name, bit); res->lockname.len, res->lockname.name, bit);
dlm_lockres_clear_refmap_bit(bit, res); dlm_lockres_clear_refmap_bit(dlm, res, bit);
} }
bit++; bit++;
} }
...@@ -2933,7 +2951,7 @@ static int dlm_do_migrate_request(struct dlm_ctxt *dlm, ...@@ -2933,7 +2951,7 @@ static int dlm_do_migrate_request(struct dlm_ctxt *dlm,
dlm->name, res->lockname.len, res->lockname.name, dlm->name, res->lockname.len, res->lockname.name,
nodenum); nodenum);
spin_lock(&res->spinlock); spin_lock(&res->spinlock);
dlm_lockres_set_refmap_bit(nodenum, res); dlm_lockres_set_refmap_bit(dlm, res, nodenum);
spin_unlock(&res->spinlock); spin_unlock(&res->spinlock);
} }
} }
...@@ -3267,7 +3285,7 @@ int dlm_finish_migration(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, ...@@ -3267,7 +3285,7 @@ int dlm_finish_migration(struct dlm_ctxt *dlm, struct dlm_lock_resource *res,
* mastery reference here since old_master will briefly have * mastery reference here since old_master will briefly have
* a reference after the migration completes */ * a reference after the migration completes */
spin_lock(&res->spinlock); spin_lock(&res->spinlock);
dlm_lockres_set_refmap_bit(old_master, res); dlm_lockres_set_refmap_bit(dlm, res, old_master);
spin_unlock(&res->spinlock); spin_unlock(&res->spinlock);
mlog(0, "now time to do a migrate request to other nodes\n"); mlog(0, "now time to do a migrate request to other nodes\n");
......
...@@ -1776,7 +1776,7 @@ static int dlm_process_recovery_data(struct dlm_ctxt *dlm, ...@@ -1776,7 +1776,7 @@ static int dlm_process_recovery_data(struct dlm_ctxt *dlm,
dlm->name, mres->lockname_len, mres->lockname, dlm->name, mres->lockname_len, mres->lockname,
from); from);
spin_lock(&res->spinlock); spin_lock(&res->spinlock);
dlm_lockres_set_refmap_bit(from, res); dlm_lockres_set_refmap_bit(dlm, res, from);
spin_unlock(&res->spinlock); spin_unlock(&res->spinlock);
added++; added++;
break; break;
...@@ -1974,7 +1974,7 @@ static int dlm_process_recovery_data(struct dlm_ctxt *dlm, ...@@ -1974,7 +1974,7 @@ static int dlm_process_recovery_data(struct dlm_ctxt *dlm,
mlog(0, "%s:%.*s: added lock for node %u, " mlog(0, "%s:%.*s: added lock for node %u, "
"setting refmap bit\n", dlm->name, "setting refmap bit\n", dlm->name,
res->lockname.len, res->lockname.name, ml->node); res->lockname.len, res->lockname.name, ml->node);
dlm_lockres_set_refmap_bit(ml->node, res); dlm_lockres_set_refmap_bit(dlm, res, ml->node);
added++; added++;
} }
spin_unlock(&res->spinlock); spin_unlock(&res->spinlock);
...@@ -2254,12 +2254,12 @@ static void dlm_free_dead_locks(struct dlm_ctxt *dlm, ...@@ -2254,12 +2254,12 @@ static void dlm_free_dead_locks(struct dlm_ctxt *dlm,
res->lockname.len, res->lockname.name, freed, dead_node); res->lockname.len, res->lockname.name, freed, dead_node);
__dlm_print_one_lock_resource(res); __dlm_print_one_lock_resource(res);
} }
dlm_lockres_clear_refmap_bit(dead_node, res); dlm_lockres_clear_refmap_bit(dlm, res, dead_node);
} else if (test_bit(dead_node, res->refmap)) { } else if (test_bit(dead_node, res->refmap)) {
mlog(0, "%s:%.*s: dead node %u had a ref, but had " mlog(0, "%s:%.*s: dead node %u had a ref, but had "
"no locks and had not purged before dying\n", dlm->name, "no locks and had not purged before dying\n", dlm->name,
res->lockname.len, res->lockname.name, dead_node); res->lockname.len, res->lockname.name, dead_node);
dlm_lockres_clear_refmap_bit(dead_node, res); dlm_lockres_clear_refmap_bit(dlm, res, dead_node);
} }
/* do not kick thread yet */ /* do not kick thread yet */
......
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