Commit 778fc546 authored by J. Bruce Fields's avatar J. Bruce Fields

locks: fix tracking of inprogress lease breaks

We currently use a bit in fl_flags to record whether a lease is being
broken, and set fl_type to the type (RDLCK or UNLCK) that it will
eventually have.  This means that once the lease break starts, we forget
what the lease's type *used* to be.  Breaking a read lease will then
result in blocking read opens, even though there's no conflict--because
the lease type is now F_UNLCK and we can no longer tell whether it was
previously a read or write lease.

So, instead keep fl_type as the original type (the type which we
enforce), and keep track of whether we're unlocking or merely
downgrading by replacing the single FL_INPROGRESS flag by
FL_UNLOCK_PENDING and FL_DOWNGRADE_PENDING flags.

To get this right we also need to track separate downgrade and break
times, to handle the case where a write-leased file gets conflicting
opens first for read, then later for write.

(I first considered just eliminating the downgrade behavior
completely--nfsv4 doesn't need it, and nobody as far as I can tell
actually uses it currently--but Jeremy Allison tells me that Windows
oplocks do behave this way, so Samba will probably use this some day.)
Reviewed-by: default avatarJeff Layton <jlayton@redhat.com>
Signed-off-by: default avatarJ. Bruce Fields <bfields@redhat.com>
parent 710b7216
...@@ -135,7 +135,16 @@ ...@@ -135,7 +135,16 @@
static bool lease_breaking(struct file_lock *fl) static bool lease_breaking(struct file_lock *fl)
{ {
return fl->fl_flags & FL_INPROGRESS; return fl->fl_flags & (FL_UNLOCK_PENDING | FL_DOWNGRADE_PENDING);
}
static int target_leasetype(struct file_lock *fl)
{
if (fl->fl_flags & FL_UNLOCK_PENDING)
return F_UNLCK;
if (fl->fl_flags & FL_DOWNGRADE_PENDING)
return F_RDLCK;
return fl->fl_type;
} }
int leases_enable = 1; int leases_enable = 1;
...@@ -1124,6 +1133,17 @@ int locks_mandatory_area(int read_write, struct inode *inode, ...@@ -1124,6 +1133,17 @@ int locks_mandatory_area(int read_write, struct inode *inode,
EXPORT_SYMBOL(locks_mandatory_area); EXPORT_SYMBOL(locks_mandatory_area);
static void lease_clear_pending(struct file_lock *fl, int arg)
{
switch (arg) {
case F_UNLCK:
fl->fl_flags &= ~FL_UNLOCK_PENDING;
/* fall through: */
case F_RDLCK:
fl->fl_flags &= ~FL_DOWNGRADE_PENDING;
}
}
/* We already had a lease on this file; just change its type */ /* We already had a lease on this file; just change its type */
int lease_modify(struct file_lock **before, int arg) int lease_modify(struct file_lock **before, int arg)
{ {
...@@ -1132,7 +1152,7 @@ int lease_modify(struct file_lock **before, int arg) ...@@ -1132,7 +1152,7 @@ int lease_modify(struct file_lock **before, int arg)
if (error) if (error)
return error; return error;
fl->fl_flags &= ~FL_INPROGRESS; lease_clear_pending(fl, arg);
locks_wake_up_blocks(fl); locks_wake_up_blocks(fl);
if (arg == F_UNLCK) if (arg == F_UNLCK)
locks_delete_lock(before); locks_delete_lock(before);
...@@ -1141,6 +1161,14 @@ int lease_modify(struct file_lock **before, int arg) ...@@ -1141,6 +1161,14 @@ int lease_modify(struct file_lock **before, int arg)
EXPORT_SYMBOL(lease_modify); EXPORT_SYMBOL(lease_modify);
static bool past_time(unsigned long then)
{
if (!then)
/* 0 is a special value meaning "this never expires": */
return false;
return time_after(jiffies, then);
}
static void time_out_leases(struct inode *inode) static void time_out_leases(struct inode *inode)
{ {
struct file_lock **before; struct file_lock **before;
...@@ -1148,12 +1176,10 @@ static void time_out_leases(struct inode *inode) ...@@ -1148,12 +1176,10 @@ static void time_out_leases(struct inode *inode)
before = &inode->i_flock; before = &inode->i_flock;
while ((fl = *before) && IS_LEASE(fl) && lease_breaking(fl)) { while ((fl = *before) && IS_LEASE(fl) && lease_breaking(fl)) {
if ((fl->fl_break_time == 0) if (past_time(fl->fl_downgrade_time))
|| time_before(jiffies, fl->fl_break_time)) { lease_modify(before, F_RDLCK);
before = &fl->fl_next; if (past_time(fl->fl_break_time))
continue; lease_modify(before, F_UNLCK);
}
lease_modify(before, fl->fl_type);
if (fl == *before) /* lease_modify may have freed fl */ if (fl == *before) /* lease_modify may have freed fl */
before = &fl->fl_next; before = &fl->fl_next;
} }
...@@ -1171,7 +1197,7 @@ static void time_out_leases(struct inode *inode) ...@@ -1171,7 +1197,7 @@ static void time_out_leases(struct inode *inode)
*/ */
int __break_lease(struct inode *inode, unsigned int mode) int __break_lease(struct inode *inode, unsigned int mode)
{ {
int error = 0, future; int error = 0;
struct file_lock *new_fl, *flock; struct file_lock *new_fl, *flock;
struct file_lock *fl; struct file_lock *fl;
unsigned long break_time; unsigned long break_time;
...@@ -1188,24 +1214,13 @@ int __break_lease(struct inode *inode, unsigned int mode) ...@@ -1188,24 +1214,13 @@ int __break_lease(struct inode *inode, unsigned int mode)
if ((flock == NULL) || !IS_LEASE(flock)) if ((flock == NULL) || !IS_LEASE(flock))
goto out; goto out;
if (!locks_conflict(flock, new_fl))
goto out;
for (fl = flock; fl && IS_LEASE(fl); fl = fl->fl_next) for (fl = flock; fl && IS_LEASE(fl); fl = fl->fl_next)
if (fl->fl_owner == current->files) if (fl->fl_owner == current->files)
i_have_this_lease = 1; i_have_this_lease = 1;
if (want_write) {
/* If we want write access, we have to revoke any lease. */
future = F_UNLCK;
} else if (lease_breaking(flock)) {
/* If the lease is already being broken, we just leave it */
future = flock->fl_type;
} else if (flock->fl_type & F_WRLCK) {
/* Downgrade the exclusive lease to a read-only lease. */
future = F_RDLCK;
} else {
/* the existing lease was read-only, so we can read too. */
goto out;
}
if (IS_ERR(new_fl) && !i_have_this_lease if (IS_ERR(new_fl) && !i_have_this_lease
&& ((mode & O_NONBLOCK) == 0)) { && ((mode & O_NONBLOCK) == 0)) {
error = PTR_ERR(new_fl); error = PTR_ERR(new_fl);
...@@ -1220,13 +1235,18 @@ int __break_lease(struct inode *inode, unsigned int mode) ...@@ -1220,13 +1235,18 @@ int __break_lease(struct inode *inode, unsigned int mode)
} }
for (fl = flock; fl && IS_LEASE(fl); fl = fl->fl_next) { for (fl = flock; fl && IS_LEASE(fl); fl = fl->fl_next) {
if (fl->fl_type != future) { if (want_write) {
fl->fl_type = future; if (fl->fl_flags & FL_UNLOCK_PENDING)
fl->fl_flags |= FL_INPROGRESS; continue;
fl->fl_flags |= FL_UNLOCK_PENDING;
fl->fl_break_time = break_time; fl->fl_break_time = break_time;
/* lease must have lmops break callback */ } else {
fl->fl_lmops->lm_break(fl); if (lease_breaking(flock))
continue;
fl->fl_flags |= FL_DOWNGRADE_PENDING;
fl->fl_downgrade_time = break_time;
} }
fl->fl_lmops->lm_break(fl);
} }
if (i_have_this_lease || (mode & O_NONBLOCK)) { if (i_have_this_lease || (mode & O_NONBLOCK)) {
...@@ -1250,10 +1270,13 @@ int __break_lease(struct inode *inode, unsigned int mode) ...@@ -1250,10 +1270,13 @@ int __break_lease(struct inode *inode, unsigned int mode)
if (error >= 0) { if (error >= 0) {
if (error == 0) if (error == 0)
time_out_leases(inode); time_out_leases(inode);
/* Wait for the next lease that has not been broken yet */ /*
* Wait for the next conflicting lease that has not been
* broken yet
*/
for (flock = inode->i_flock; flock && IS_LEASE(flock); for (flock = inode->i_flock; flock && IS_LEASE(flock);
flock = flock->fl_next) { flock = flock->fl_next) {
if (lease_breaking(flock)) if (locks_conflict(new_fl, flock))
goto restart; goto restart;
} }
error = 0; error = 0;
...@@ -1321,7 +1344,7 @@ int fcntl_getlease(struct file *filp) ...@@ -1321,7 +1344,7 @@ int fcntl_getlease(struct file *filp)
for (fl = filp->f_path.dentry->d_inode->i_flock; fl && IS_LEASE(fl); for (fl = filp->f_path.dentry->d_inode->i_flock; fl && IS_LEASE(fl);
fl = fl->fl_next) { fl = fl->fl_next) {
if (fl->fl_file == filp) { if (fl->fl_file == filp) {
type = fl->fl_type; type = target_leasetype(fl);
break; break;
} }
} }
...@@ -1386,7 +1409,7 @@ int generic_setlease(struct file *filp, long arg, struct file_lock **flp) ...@@ -1386,7 +1409,7 @@ int generic_setlease(struct file *filp, long arg, struct file_lock **flp)
before = &fl->fl_next) { before = &fl->fl_next) {
if (fl->fl_file == filp) if (fl->fl_file == filp)
my_before = before; my_before = before;
else if ((fl->fl_type == F_UNLCK) && lease_breaking(fl)) else if (fl->fl_flags & FL_UNLOCK_PENDING)
/* /*
* Someone is in the process of opening this * Someone is in the process of opening this
* file for writing so we may not take an * file for writing so we may not take an
......
...@@ -1065,7 +1065,8 @@ static inline int file_check_writeable(struct file *filp) ...@@ -1065,7 +1065,8 @@ static inline int file_check_writeable(struct file *filp)
#define FL_LEASE 32 /* lease held on this file */ #define FL_LEASE 32 /* lease held on this file */
#define FL_CLOSE 64 /* unlock on close */ #define FL_CLOSE 64 /* unlock on close */
#define FL_SLEEP 128 /* A blocking lock */ #define FL_SLEEP 128 /* A blocking lock */
#define FL_INPROGRESS 256 /* Lease is being broken */ #define FL_DOWNGRADE_PENDING 256 /* Lease is being downgraded */
#define FL_UNLOCK_PENDING 512 /* Lease is being broken */
/* /*
* Special return value from posix_lock_file() and vfs_lock_file() for * Special return value from posix_lock_file() and vfs_lock_file() for
...@@ -1122,7 +1123,9 @@ struct file_lock { ...@@ -1122,7 +1123,9 @@ struct file_lock {
loff_t fl_end; loff_t fl_end;
struct fasync_struct * fl_fasync; /* for lease break notifications */ struct fasync_struct * fl_fasync; /* for lease break notifications */
unsigned long fl_break_time; /* for nonblocking lease breaks */ /* for lease breaks: */
unsigned long fl_break_time;
unsigned long fl_downgrade_time;
const struct file_lock_operations *fl_ops; /* Callbacks for filesystems */ const struct file_lock_operations *fl_ops; /* Callbacks for filesystems */
const struct lock_manager_operations *fl_lmops; /* Callbacks for lockmanagers */ const struct lock_manager_operations *fl_lmops; /* Callbacks for lockmanagers */
......
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