Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 4321e01e authored by Matthew Wilcox's avatar Matthew Wilcox Committed by J. Bruce Fields
Browse files

file locks: Use wait_event_interruptible_timeout() 



interruptible_sleep_on_locked() is just an open-coded
wait_event_interruptible_timeout(), with the one difference that
interruptible_sleep_on_locked() doesn't bother to check the condition on
which it is waiting, depending instead on the BKL to avoid the case
where it blocks after the wakeup has already been called.

locks_block_on_timeout() is only used in one place, so it's actually
simpler to inline it into its caller.

Signed-off-by: default avatarMatthew Wilcox <willy@linux.intel.com>
Signed-off-by: default avatarJ. Bruce Fields <bfields@citi.umich.edu>
parent b533184f

fs/locks.c

+4 −28
Original line number Diff line number Diff line
@@ -634,33 +634,6 @@ static int flock_locks_conflict(struct file_lock *caller_fl, struct file_lock *s 
	return (locks_conflict(caller_fl, sys_fl));

}



static int interruptible_sleep_on_locked(wait_queue_head_t *fl_wait, int timeout)

{

	int result = 0;

	DECLARE_WAITQUEUE(wait, current);



	__set_current_state(TASK_INTERRUPTIBLE);

	add_wait_queue(fl_wait, &wait);

	if (timeout == 0)

		schedule();

	else

		result = schedule_timeout(timeout);

	if (signal_pending(current))

		result = -ERESTARTSYS;

	remove_wait_queue(fl_wait, &wait);

	__set_current_state(TASK_RUNNING);

	return result;

}



static int locks_block_on_timeout(struct file_lock *blocker, struct file_lock *waiter, int time)

{

	int result;

	locks_insert_block(blocker, waiter);

	result = interruptible_sleep_on_locked(&waiter->fl_wait, time);

	__locks_delete_block(waiter);

	return result;

}



void

posix_test_lock(struct file *filp, struct file_lock *fl)

{
@@ -1266,7 +1239,10 @@ int __break_lease(struct inode *inode, unsigned int mode) 
		if (break_time == 0)

			break_time++;

	}

	error = locks_block_on_timeout(flock, new_fl, break_time);

	locks_insert_block(flock, new_fl);

	error = wait_event_interruptible_timeout(new_fl->fl_wait,

						!new_fl->fl_next, break_time);

	__locks_delete_block(new_fl);

	if (error >= 0) {

		if (error == 0)

			time_out_leases(inode);