gfs2: Clean up waiting on glocks
The prepare_to_wait_on_glock and finish_wait_on_glock functions introduced in commit 56a365be "gfs2: gfs2_glock_get: Wait on freeing glocks" are better removed, resulting in cleaner code. Signed-off-by: Andreas Gruenbacher <agruenba@redhat.com> Signed-off-by: Bob Peterson <rpeterso@redhat.com>
This commit is contained in:

committed by
Bob Peterson

parent
6a1c8f6dcf
commit
a91323e255
@@ -112,23 +112,6 @@ static wait_queue_head_t *glock_waitqueue(struct lm_lockname *name)
|
|||||||
return glock_wait_table + hash_32(hash, GLOCK_WAIT_TABLE_BITS);
|
return glock_wait_table + hash_32(hash, GLOCK_WAIT_TABLE_BITS);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void prepare_to_wait_on_glock(wait_queue_head_t **wq,
|
|
||||||
struct wait_glock_queue *wait,
|
|
||||||
struct lm_lockname *name)
|
|
||||||
{
|
|
||||||
wait->name = name;
|
|
||||||
init_wait(&wait->wait);
|
|
||||||
wait->wait.func = glock_wake_function;
|
|
||||||
*wq = glock_waitqueue(name);
|
|
||||||
prepare_to_wait(*wq, &wait->wait, TASK_UNINTERRUPTIBLE);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void finish_wait_on_glock(wait_queue_head_t *wq,
|
|
||||||
struct wait_glock_queue *wait)
|
|
||||||
{
|
|
||||||
finish_wait(wq, &wait->wait);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* wake_up_glock - Wake up waiters on a glock
|
* wake_up_glock - Wake up waiters on a glock
|
||||||
* @gl: the glock
|
* @gl: the glock
|
||||||
@@ -754,11 +737,15 @@ static struct gfs2_glock *find_insert_glock(struct lm_lockname *name,
|
|||||||
struct gfs2_glock *new)
|
struct gfs2_glock *new)
|
||||||
{
|
{
|
||||||
struct wait_glock_queue wait;
|
struct wait_glock_queue wait;
|
||||||
wait_queue_head_t *wq;
|
wait_queue_head_t *wq = glock_waitqueue(name);
|
||||||
struct gfs2_glock *gl;
|
struct gfs2_glock *gl;
|
||||||
|
|
||||||
|
wait.name = name;
|
||||||
|
init_wait(&wait.wait);
|
||||||
|
wait.wait.func = glock_wake_function;
|
||||||
|
|
||||||
again:
|
again:
|
||||||
prepare_to_wait_on_glock(&wq, &wait, name);
|
prepare_to_wait(wq, &wait.wait, TASK_UNINTERRUPTIBLE);
|
||||||
rcu_read_lock();
|
rcu_read_lock();
|
||||||
if (new) {
|
if (new) {
|
||||||
gl = rhashtable_lookup_get_insert_fast(&gl_hash_table,
|
gl = rhashtable_lookup_get_insert_fast(&gl_hash_table,
|
||||||
@@ -776,7 +763,7 @@ again:
|
|||||||
}
|
}
|
||||||
out:
|
out:
|
||||||
rcu_read_unlock();
|
rcu_read_unlock();
|
||||||
finish_wait_on_glock(wq, &wait);
|
finish_wait(wq, &wait.wait);
|
||||||
return gl;
|
return gl;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user