Build upon the C/R of file-locks to checkpoint file-leases. This patch
simply checkpoints the file-lease information. A follow-on patch
will use this checkpoint information to restorethe file leases.
C/R of file leases depends on whether the lease is currently being broken
(i.e F_INPROGRESS is set) or not. If the file-lease is not being broken,
checkpoint of file-lease is identical to checkpoint of file-locks.
But if the lease is being broken, we checkpoint additional information,
such as:
- the previous lease type,
- the time remaining in the lease, and
- whether we already notified the lease-holder about the lease-break
See follow-on patch ("Restore file-leases") for more details on how this
information is used while restoring file leases and for other semantics
relating to file-leases.
Changelog[v3]:
- [Oren Laadan, John Stultz]: Use ->jiffies_begin to compute
remaining lease
- Broke-up the draft-patch from previous version into smaller
patches and addressed comments from Oren Laadan.
Signed-off-by: Sukadev Bhattiprolu <sukadev@xxxxxxxxxxxxxxxxxx>
---
fs/checkpoint.c | 28 +++++++++++++++++++++++++---
include/linux/checkpoint_hdr.h | 3 +++
2 files changed, 28 insertions(+), 3 deletions(-)
diff --git a/fs/checkpoint.c b/fs/checkpoint.c
index d76b073..5e5d0c5 100644
--- a/fs/checkpoint.c
+++ b/fs/checkpoint.c
@@ -267,6 +267,17 @@ static int checkpoint_file(struct ckpt_ctx *ctx, void *ptr)
return ret;
}
+static int get_rem_lease(struct ckpt_ctx *ctx, struct file_lock *lock)
+{
+ int rem_lease;
+
+ rem_lease = 0;
+ if ((lock->fl_type & F_INPROGRESS))
+ rem_lease = (lock->fl_break_time - ctx->jiffies_begin) / HZ;
+
+ return rem_lease;
+}
+
static int checkpoint_one_file_lock(struct ckpt_ctx *ctx, struct file *file,
struct file_lock *lock)
{
@@ -280,8 +291,14 @@ static int checkpoint_one_file_lock(struct ckpt_ctx *ctx, struct file *file,
if (lock) {
h->fl_start = lock->fl_start;
h->fl_end = lock->fl_end;
+ /* checkpoint F_INPROGRESS also, if set */
h->fl_type = lock->fl_type;
+ h->fl_type_prev = lock->fl_type_prev;
h->fl_flags = lock->fl_flags;
+ if (IS_LEASE(lock)) {
+ h->fl_break_notified = lock->fl_break_notified;
+ h->fl_rem_lease = get_rem_lease(ctx, lock);
+ }
} else {
/* Checkpoint a dummy lock as a marker */
CKPT_HDR_SET_MARKER_FILE_LOCK(h);
@@ -307,14 +324,19 @@ checkpoint_file_locks(struct ckpt_ctx *ctx, struct files_struct *files,
inode = file->f_path.dentry->d_inode;
for_each_lock(inode, lockpp) {
lockp = *lockpp;
- ckpt_debug("Lock [%lld, %lld, %d, 0x%x]\n", lockp->fl_start,
- lockp->fl_end, lockp->fl_type, lockp->fl_flags);
+
+ ckpt_debug("Lock [%lld, %lld, %d, 0x%x], type_prev %d, "
+ "break-notified %d, rem-lease %d\n",
+ lockp->fl_start, lockp->fl_end, lockp->fl_type,
+ lockp->fl_flags, lockp->fl_type_prev,
+ lockp->fl_break_notified,
+ get_rem_lease(ctx, lockp));
if (lockp->fl_owner != files)
continue;
rc = -EBADF;
- if (IS_POSIX(lockp))
+ if (IS_POSIX(lockp) || IS_LEASE(lockp))
rc = checkpoint_one_file_lock(ctx, file, lockp);
if (rc < 0) {
diff --git a/include/linux/checkpoint_hdr.h b/include/linux/checkpoint_hdr.h
index ad08c8e..9526504 100644
--- a/include/linux/checkpoint_hdr.h
+++ b/include/linux/checkpoint_hdr.h
@@ -593,7 +593,10 @@ struct ckpt_hdr_file_lock {
__s64 fl_start;
__s64 fl_end;
__u8 fl_type;
+ __u8 fl_type_prev;
__u8 fl_flags;
+ __u8 fl_break_notified;
+ __s32 fl_rem_lease;
};
#define CKPT_HDR_SET_MARKER_FILE_LOCK(h) { \
--
1.6.0.4
--
To unsubscribe from this list: send the line "unsubscribe linux-fsdevel" in
the body of a message to majordomo@xxxxxxxxxxxxxxx
More majordomo info at http://vger.kernel.org/majordomo-info.html
