Commit 269a6194 authored by Jeff Layton's avatar Jeff Layton Committed by Christian Brauner

filelock: reorganize locks_delete_block and __locks_insert_block

Rename the old __locks_delete_block to __locks_unlink_lock. Rename
change old locks_delete_block function to __locks_delete_block and
have it take a file_lock_core. Make locks_delete_block a simple wrapper
around __locks_delete_block.

Also, change __locks_insert_block to take struct file_lock_core, and
fix up its callers.
Signed-off-by: default avatarJeff Layton <jlayton@kernel.org>
Link: https://lore.kernel.org/r/20240131-flsplit-v3-28-c6129007ee8d@kernel.orgReviewed-by: default avatarNeilBrown <neilb@suse.de>
Signed-off-by: default avatarChristian Brauner <brauner@kernel.org>
parent e8a166cf
...@@ -659,7 +659,7 @@ static void locks_delete_global_blocked(struct file_lock_core *waiter) ...@@ -659,7 +659,7 @@ static void locks_delete_global_blocked(struct file_lock_core *waiter)
* *
* Must be called with blocked_lock_lock held. * Must be called with blocked_lock_lock held.
*/ */
static void __locks_delete_block(struct file_lock_core *waiter) static void __locks_unlink_block(struct file_lock_core *waiter)
{ {
locks_delete_global_blocked(waiter); locks_delete_global_blocked(waiter);
list_del_init(&waiter->flc_blocked_member); list_del_init(&waiter->flc_blocked_member);
...@@ -675,7 +675,7 @@ static void __locks_wake_up_blocks(struct file_lock_core *blocker) ...@@ -675,7 +675,7 @@ static void __locks_wake_up_blocks(struct file_lock_core *blocker)
struct file_lock_core, flc_blocked_member); struct file_lock_core, flc_blocked_member);
fl = file_lock(waiter); fl = file_lock(waiter);
__locks_delete_block(waiter); __locks_unlink_block(waiter);
if ((waiter->flc_flags & (FL_POSIX | FL_FLOCK)) && if ((waiter->flc_flags & (FL_POSIX | FL_FLOCK)) &&
fl->fl_lmops && fl->fl_lmops->lm_notify) fl->fl_lmops && fl->fl_lmops->lm_notify)
fl->fl_lmops->lm_notify(fl); fl->fl_lmops->lm_notify(fl);
...@@ -691,16 +691,9 @@ static void __locks_wake_up_blocks(struct file_lock_core *blocker) ...@@ -691,16 +691,9 @@ static void __locks_wake_up_blocks(struct file_lock_core *blocker)
} }
} }
/** static int __locks_delete_block(struct file_lock_core *waiter)
* locks_delete_block - stop waiting for a file lock
* @waiter: the lock which was waiting
*
* lockd/nfsd need to disconnect the lock while working on it.
*/
int locks_delete_block(struct file_lock *waiter_fl)
{ {
int status = -ENOENT; int status = -ENOENT;
struct file_lock_core *waiter = &waiter_fl->c;
/* /*
* If fl_blocker is NULL, it won't be set again as this thread "owns" * If fl_blocker is NULL, it won't be set again as this thread "owns"
...@@ -731,7 +724,7 @@ int locks_delete_block(struct file_lock *waiter_fl) ...@@ -731,7 +724,7 @@ int locks_delete_block(struct file_lock *waiter_fl)
if (waiter->flc_blocker) if (waiter->flc_blocker)
status = 0; status = 0;
__locks_wake_up_blocks(waiter); __locks_wake_up_blocks(waiter);
__locks_delete_block(waiter); __locks_unlink_block(waiter);
/* /*
* The setting of fl_blocker to NULL marks the "done" point in deleting * The setting of fl_blocker to NULL marks the "done" point in deleting
...@@ -741,6 +734,17 @@ int locks_delete_block(struct file_lock *waiter_fl) ...@@ -741,6 +734,17 @@ int locks_delete_block(struct file_lock *waiter_fl)
spin_unlock(&blocked_lock_lock); spin_unlock(&blocked_lock_lock);
return status; return status;
} }
/**
* locks_delete_block - stop waiting for a file lock
* @waiter: the lock which was waiting
*
* lockd/nfsd need to disconnect the lock while working on it.
*/
int locks_delete_block(struct file_lock *waiter)
{
return __locks_delete_block(&waiter->c);
}
EXPORT_SYMBOL(locks_delete_block); EXPORT_SYMBOL(locks_delete_block);
/* Insert waiter into blocker's block list. /* Insert waiter into blocker's block list.
...@@ -758,13 +762,11 @@ EXPORT_SYMBOL(locks_delete_block); ...@@ -758,13 +762,11 @@ EXPORT_SYMBOL(locks_delete_block);
* waiters, and add beneath any waiter that blocks the new waiter. * waiters, and add beneath any waiter that blocks the new waiter.
* Thus wakeups don't happen until needed. * Thus wakeups don't happen until needed.
*/ */
static void __locks_insert_block(struct file_lock *blocker_fl, static void __locks_insert_block(struct file_lock_core *blocker,
struct file_lock *waiter_fl, struct file_lock_core *waiter,
bool conflict(struct file_lock_core *, bool conflict(struct file_lock_core *,
struct file_lock_core *)) struct file_lock_core *))
{ {
struct file_lock_core *blocker = &blocker_fl->c;
struct file_lock_core *waiter = &waiter_fl->c;
struct file_lock_core *flc; struct file_lock_core *flc;
BUG_ON(!list_empty(&waiter->flc_blocked_member)); BUG_ON(!list_empty(&waiter->flc_blocked_member));
...@@ -789,8 +791,8 @@ static void __locks_insert_block(struct file_lock *blocker_fl, ...@@ -789,8 +791,8 @@ static void __locks_insert_block(struct file_lock *blocker_fl,
} }
/* Must be called with flc_lock held. */ /* Must be called with flc_lock held. */
static void locks_insert_block(struct file_lock *blocker, static void locks_insert_block(struct file_lock_core *blocker,
struct file_lock *waiter, struct file_lock_core *waiter,
bool conflict(struct file_lock_core *, bool conflict(struct file_lock_core *,
struct file_lock_core *)) struct file_lock_core *))
{ {
...@@ -1088,7 +1090,7 @@ static int flock_lock_inode(struct inode *inode, struct file_lock *request) ...@@ -1088,7 +1090,7 @@ static int flock_lock_inode(struct inode *inode, struct file_lock *request)
if (!(request->c.flc_flags & FL_SLEEP)) if (!(request->c.flc_flags & FL_SLEEP))
goto out; goto out;
error = FILE_LOCK_DEFERRED; error = FILE_LOCK_DEFERRED;
locks_insert_block(fl, request, flock_locks_conflict); locks_insert_block(&fl->c, &request->c, flock_locks_conflict);
goto out; goto out;
} }
if (request->c.flc_flags & FL_ACCESS) if (request->c.flc_flags & FL_ACCESS)
...@@ -1182,7 +1184,7 @@ static int posix_lock_inode(struct inode *inode, struct file_lock *request, ...@@ -1182,7 +1184,7 @@ static int posix_lock_inode(struct inode *inode, struct file_lock *request,
__locks_wake_up_blocks(&request->c); __locks_wake_up_blocks(&request->c);
if (likely(!posix_locks_deadlock(request, fl))) { if (likely(!posix_locks_deadlock(request, fl))) {
error = FILE_LOCK_DEFERRED; error = FILE_LOCK_DEFERRED;
__locks_insert_block(fl, request, __locks_insert_block(&fl->c, &request->c,
posix_locks_conflict); posix_locks_conflict);
} }
spin_unlock(&blocked_lock_lock); spin_unlock(&blocked_lock_lock);
...@@ -1575,7 +1577,7 @@ int __break_lease(struct inode *inode, unsigned int mode, unsigned int type) ...@@ -1575,7 +1577,7 @@ int __break_lease(struct inode *inode, unsigned int mode, unsigned int type)
break_time -= jiffies; break_time -= jiffies;
if (break_time == 0) if (break_time == 0)
break_time++; break_time++;
locks_insert_block(fl, new_fl, leases_conflict); locks_insert_block(&fl->c, &new_fl->c, leases_conflict);
trace_break_lease_block(inode, new_fl); trace_break_lease_block(inode, new_fl);
spin_unlock(&ctx->flc_lock); spin_unlock(&ctx->flc_lock);
percpu_up_read(&file_rwsem); percpu_up_read(&file_rwsem);
......
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