* Re: [RFC][cr][PATCH 4/6] Restore file-locks [not found] ` <1273023883-19264-4-git-send-email-Sukadev> @ 2010-05-05 2:49 ` Matt Helsley 0 siblings, 0 replies; 5+ messages in thread From: Matt Helsley @ 2010-05-05 2:49 UTC (permalink / raw) To: sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8 Cc: containers-qjLDD68F18O7TbgM5vRIOg, Oren-npbjlsIvGkV82hYKe6nXyg On Tue, May 04, 2010 at 06:44:41PM -0700, sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8@public.gmane.org wrote: > From: Sukadev Bhattiprolu <sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8@public.gmane.org> > > Restore POSIX file-locks of an application from its checkpoint image. > > Read the saved file-locks from the checkpoint image and for each POSIX > lock, call flock_set() to set the lock on the file. > > As pointed out by Matt Helsley, no special handling is necessary for a > process P2 in the checkpointed container that is blocked on a lock, L1 Which was inspired by Dave Hansen's explanation of c/r of futex locking :). Cheers, -Matt ^ permalink raw reply [flat|nested] 5+ messages in thread
[parent not found: <1273023883-19264-2-git-send-email-Sukadev>]
* Re: [RFC][cr][PATCH 2/6] Checkpoint file-locks [not found] ` <1273023883-19264-2-git-send-email-Sukadev> @ 2010-05-05 3:12 ` Matt Helsley [not found] ` <20100505031256.GJ31830-52DBMbEzqgQ/wnmkkaCWp/UQ3DHhIser@public.gmane.org> 0 siblings, 1 reply; 5+ messages in thread From: Matt Helsley @ 2010-05-05 3:12 UTC (permalink / raw) To: sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8 Cc: containers-qjLDD68F18O7TbgM5vRIOg On Tue, May 04, 2010 at 06:44:39PM -0700, sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8@public.gmane.org wrote: > From: Sukadev Bhattiprolu <sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8@public.gmane.org> > > While checkpointing each file-descriptor, find all the locks on the > file and save information about the lock in the checkpoint-image. > A follow-on patch will use this informaiton to restore the file-locks. > > Signed-off-by: Sukadev Bhattiprolu <sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8@public.gmane.org> > --- > fs/checkpoint.c | 98 ++++++++++++++++++++++++++++++++++----- > include/linux/checkpoint_hdr.h | 10 ++++ > 2 files changed, 95 insertions(+), 13 deletions(-) > > diff --git a/fs/checkpoint.c b/fs/checkpoint.c > index e036a7a..180302e 100644 > --- a/fs/checkpoint.c > +++ b/fs/checkpoint.c > @@ -26,6 +26,7 @@ > #include <linux/checkpoint.h> > #include <linux/eventpoll.h> > #include <linux/eventfd.h> > +#include <linux/smp_lock.h> > #include <net/sock.h> > > /************************************************************************** > @@ -249,8 +250,86 @@ static int checkpoint_file(struct ckpt_ctx *ctx, void *ptr) > return ret; > } > > +static int checkpoint_one_file_lock(struct ckpt_ctx *ctx, struct file *file, > + int fd, struct file_lock *lock) fd is only used for debugging info. Probably ought to remove it. > +{ > + int rc; > + struct ckpt_hdr_file_lock *h; > + > + h = ckpt_hdr_get_type(ctx, sizeof(*h), CKPT_HDR_FILE_LOCK); > + if (!h) > + return -ENOMEM; > + > + h->fl_start = lock->fl_start; > + h->fl_end = lock->fl_end; > + h->fl_type = lock->fl_type; > + h->fl_flags = lock->fl_flags; > + > + rc = ckpt_write_obj(ctx, &h->h); > + > + ckpt_hdr_put(ctx, h); > + > + ckpt_debug("Lock [%lld, %lld, %d, 0x%x] fd %d, rc %d\n", lock->fl_start, > + lock->fl_end, lock->fl_type, lock->fl_flags, fd, rc); > + > + return rc; > +} > + > +int > +checkpoint_file_locks(struct ckpt_ctx *ctx, struct files_struct *files, > + struct file *file, int fd) > +{ > + int rc; > + struct inode *inode; > + struct file_lock **lockpp; > + struct file_lock *lockp; > + struct file_lock last_lock; > + > + lock_kernel(); Eep. What are the current standards as far as adding "new" uses of the BKL? Arnd/anti-BKL-ninjas might be good folks to Cc on the next round if this is still here. Regardless, I'd think some good comments about the kernel-locking are in order so that when this BKL use is being removed those involved can easily know what it's meant to protect. > + inode = file->f_path.dentry->d_inode; > + for_each_lock(inode, lockpp) { > + lockp = *lockpp; > + ckpt_debug("Found lock [%lld, %lld, %d, 0x%x]\n", > + lockp->fl_start, lockp->fl_end, > + lockp->fl_type, lockp->fl_flags); > + > + if (lockp->fl_owner != files) > + continue; > + Maybe a stupid idea: rc = -EBADF; > + if (IS_POSIX(lockp)) { > + rc = checkpoint_one_file_lock(ctx, file, fd, lockp); Remove the other contents of this block. > + if (rc < 0) { > + ckpt_err(ctx, rc, "%(T)fd %d, checkpoint " > + "lock failed\n", fd); > + goto out; > + } > + } else { if (rc < 0) { > + ckpt_err(ctx, rc, "%(T)fd %d has unsupported file " > + "lock type, flags 0x%x\n", fd, > + lockp->fl_flags); > + goto out; > + } > + } I say maybe stupid because it may not follow accepted patterns and coalesces two ckpt_err() reports into something more complex or ambiguous. > + > + /* > + * Checkpoint a dummy file-lock to mark the end of file-locks > + * for this fd. > + */ > + memset(&last_lock, 0, sizeof(struct file_lock)); > + last_lock.fl_start = -1; > + last_lock.fl_flags = FL_POSIX; > + rc = checkpoint_one_file_lock(ctx, file, fd, &last_lock); Seems like you could just pull allocation of h out of checkpoint_one_file_lock, pass it as a parameter to that function, then outside the loop fill out the "dummy" here, and call: rc = ckpt_write_obj(ctx, &h->h); directly instead of inventing a last_lock struct. > + if (rc < 0) > + ckpt_err(ctx, rc, "%(T)fd %d, checkpoint last-lock failed\n", > + fd); > +out: > + unlock_kernel(); > + return rc; > +} > + > /** > - * ckpt_write_file_desc - dump the state of a given file descriptor > + * checkpoint_file_desc - dump the state of a given file descriptor > * @ctx: checkpoint context > * @files: files_struct pointer > * @fd: file descriptor > @@ -282,18 +361,6 @@ static int checkpoint_file_desc(struct ckpt_ctx *ctx, > } > rcu_read_unlock(); > > - ret = find_locks_with_owner(file, files); > - /* > - * find_locks_with_owner() returns an error when there > - * are no locks found, so we *want* it to return an error > - * code. Its success means we have to fail the checkpoint. > - */ > - if (!ret) { > - ret = -EBADF; > - ckpt_err(ctx, ret, "%(T)fd %d has file lock or lease\n", fd); > - goto out; > - } > - > /* sanity check (although this shouldn't happen) */ > ret = -EBADF; > if (!file) { > @@ -328,6 +395,11 @@ static int checkpoint_file_desc(struct ckpt_ctx *ctx, > h->fd_close_on_exec = coe; > > ret = ckpt_write_obj(ctx, &h->h); > + if (ret < 0) > + goto out; > + > + ret = checkpoint_file_locks(ctx, files, file, fd); > + > out: > ckpt_hdr_put(ctx, h); > if (file) > diff --git a/include/linux/checkpoint_hdr.h b/include/linux/checkpoint_hdr.h > index 790214f..d2a0fcd 100644 > --- a/include/linux/checkpoint_hdr.h > +++ b/include/linux/checkpoint_hdr.h > @@ -144,6 +144,8 @@ enum { > #define CKPT_HDR_TTY_LDISC CKPT_HDR_TTY_LDISC > CKPT_HDR_EPOLL_ITEMS, /* must be after file-table */ > #define CKPT_HDR_EPOLL_ITEMS CKPT_HDR_EPOLL_ITEMS > + CKPT_HDR_FILE_LOCK, > +#define CKPT_HDR_FILE_LOCK CKPT_HDR_FILE_LOCK > > CKPT_HDR_MM = 401, > #define CKPT_HDR_MM CKPT_HDR_MM > @@ -576,6 +578,14 @@ struct ckpt_hdr_file_generic { > struct ckpt_hdr_file common; > } __attribute__((aligned(8))); > > +struct ckpt_hdr_file_lock { > + struct ckpt_hdr h; > + loff_t fl_start; > + loff_t fl_end; fl_start and fl_end are file positions, aren't they? loff_t is, unfortunately, a notoriously ambiguous type -- it doesn't meet our standards for a biarch-safe checkpoint image. I think a u64, like ckpt_hdr_file's f_pos field, is called for. Cheers, -Matt Helsley ^ permalink raw reply [flat|nested] 5+ messages in thread
[parent not found: <20100505031256.GJ31830-52DBMbEzqgQ/wnmkkaCWp/UQ3DHhIser@public.gmane.org>]
* Re: [RFC][cr][PATCH 2/6] Checkpoint file-locks [not found] ` <20100505031256.GJ31830-52DBMbEzqgQ/wnmkkaCWp/UQ3DHhIser@public.gmane.org> @ 2010-05-05 14:56 ` Serge E. Hallyn 0 siblings, 0 replies; 5+ messages in thread From: Serge E. Hallyn @ 2010-05-05 14:56 UTC (permalink / raw) To: Matt Helsley Cc: containers-qjLDD68F18O7TbgM5vRIOg, sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8 Quoting Matt Helsley (matthltc-r/Jw6+rmf7HQT0dZR+AlfA@public.gmane.org): > On Tue, May 04, 2010 at 06:44:39PM -0700, sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8@public.gmane.org wrote: > > From: Sukadev Bhattiprolu <sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8@public.gmane.org> > > +int > > +checkpoint_file_locks(struct ckpt_ctx *ctx, struct files_struct *files, > > + struct file *file, int fd) > > +{ > > + int rc; > > + struct inode *inode; > > + struct file_lock **lockpp; > > + struct file_lock *lockp; > > + struct file_lock last_lock; > > + > > + lock_kernel(); > > Eep. What are the current standards as far as adding "new" uses of the BKL? > Arnd/anti-BKL-ninjas might be good folks to Cc on the next round if this > is still here. I'd say 1. look at Arnd's tree just to be ready to switch to it's locking method (see http://git.kernel.org/gitweb.cgi?p=linux/kernel/git/arnd/playground.git;a=commit;h=8dd5597e27d8c055376719434de6fa630da1b9f7) Heck, maybe even use 'lock_flocks()' and just #define it to lock_kernel for now. 2. put this code straight into fs/locks.c, so that the related uses of lock_kernel() are localized. ^ permalink raw reply [flat|nested] 5+ messages in thread
* [RFC][PATCH 0/6][cr]: Checkpoint/restart file locks and leases
@ 2010-05-05 5:30 Sukadev Bhattiprolu
[not found] ` <20100505053016.GA20483-r/Jw6+rmf7HQT0dZR+AlfA@public.gmane.org>
2010-05-05 5:31 ` Sukadev Bhattiprolu
0 siblings, 2 replies; 5+ messages in thread
From: Sukadev Bhattiprolu @ 2010-05-05 5:30 UTC (permalink / raw)
To: Oren Laadan; +Cc: Containers, linux-fsdevel, serue, matthltc, sukadev
This patchset is an early draft of checkpoint/restart of file-locks/leases.
This patchset applies on top of the ckpt-v21-rc7 branch of the Checkpoint/
restart git tree (see http://ckpt.wiki.kernel.org for details).
To checkpoint/restart file-locks and leases we find each lock/lease held
by each fd of the process and save the information about the lock/lease
in the checkpoint-image. When restarting, each process reacquires the
locks it held at checkpoint. When all processes have acquired the locks
one-by-one, the entire process tree is allowed to execute. Any processes
blocked on a lock at the time of checkpoint, restart their system call
and end up blocking on the lock again after the restart.
Checkpoint/restart of file-leases, specially the leases that are being
revoked appear to be more tricky - Patch 6/6 has the details.
[PATCH 1/6] Move file_lock macros into linux/fs.h
[PATCH 2/6] Checkpoint file-locks
[PATCH 3/6] Define flock_set()
[PATCH 4/6] Restore file-locks
[PATCH 5/6] Define do_setlease()
[PATCH 6/6] Checkpoint/restart file leases
This patchset has been gently tested with a few C/R testcases and needs
more testing. Pls let me know your comments or if there are semantics that
might change. Patch 6 identifies a couple of semantics for leases and
suggests a way to preserve them. But maybe there is a cleaner/easier way
to do so.
Note:
For consistency with current uses of for_each_lock(), this patchset
uses lock_kernel(), but not sure yet if it is required.
Signed-off-by: Sukadev Bhattiprolu <sukadev@linux.vnet.ibm.com>
^ permalink raw reply [flat|nested] 5+ messages in thread[parent not found: <20100505053016.GA20483-r/Jw6+rmf7HQT0dZR+AlfA@public.gmane.org>]
* [RFC][cr][PATCH 2/6] Checkpoint file-locks [not found] ` <20100505053016.GA20483-r/Jw6+rmf7HQT0dZR+AlfA@public.gmane.org> @ 2010-05-05 5:31 ` Sukadev Bhattiprolu 0 siblings, 0 replies; 5+ messages in thread From: Sukadev Bhattiprolu @ 2010-05-05 5:31 UTC (permalink / raw) To: Oren Laadan; +Cc: linux-fsdevel-u79uwXL29TY76Z2rM5mHXA, Containers From 46f8a088d15eda817f537cbb17574253a3af4e8c Mon Sep 17 00:00:00 2001 From: Sukadev Bhattiprolu <sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8@public.gmane.org> Date: Thu, 29 Apr 2010 23:43:46 -0700 Subject: [RFC][cr][PATCH 2/6] Checkpoint file-locks While checkpointing each file-descriptor, find all the locks on the file and save information about the lock in the checkpoint-image. A follow-on patch will use this informaiton to restore the file-locks. Signed-off-by: Sukadev Bhattiprolu <sukadev-23VcF4HTsmIX0ybBhKVfKdBPR1lH4CV8@public.gmane.org> --- fs/checkpoint.c | 98 ++++++++++++++++++++++++++++++++++----- include/linux/checkpoint_hdr.h | 10 ++++ 2 files changed, 95 insertions(+), 13 deletions(-) diff --git a/fs/checkpoint.c b/fs/checkpoint.c index e036a7a..180302e 100644 --- a/fs/checkpoint.c +++ b/fs/checkpoint.c @@ -26,6 +26,7 @@ #include <linux/checkpoint.h> #include <linux/eventpoll.h> #include <linux/eventfd.h> +#include <linux/smp_lock.h> #include <net/sock.h> /************************************************************************** @@ -249,8 +250,86 @@ static int checkpoint_file(struct ckpt_ctx *ctx, void *ptr) return ret; } +static int checkpoint_one_file_lock(struct ckpt_ctx *ctx, struct file *file, + int fd, struct file_lock *lock) +{ + int rc; + struct ckpt_hdr_file_lock *h; + + h = ckpt_hdr_get_type(ctx, sizeof(*h), CKPT_HDR_FILE_LOCK); + if (!h) + return -ENOMEM; + + h->fl_start = lock->fl_start; + h->fl_end = lock->fl_end; + h->fl_type = lock->fl_type; + h->fl_flags = lock->fl_flags; + + rc = ckpt_write_obj(ctx, &h->h); + + ckpt_hdr_put(ctx, h); + + ckpt_debug("Lock [%lld, %lld, %d, 0x%x] fd %d, rc %d\n", lock->fl_start, + lock->fl_end, lock->fl_type, lock->fl_flags, fd, rc); + + return rc; +} + +int +checkpoint_file_locks(struct ckpt_ctx *ctx, struct files_struct *files, + struct file *file, int fd) +{ + int rc; + struct inode *inode; + struct file_lock **lockpp; + struct file_lock *lockp; + struct file_lock last_lock; + + lock_kernel(); + inode = file->f_path.dentry->d_inode; + for_each_lock(inode, lockpp) { + lockp = *lockpp; + ckpt_debug("Found lock [%lld, %lld, %d, 0x%x]\n", + lockp->fl_start, lockp->fl_end, + lockp->fl_type, lockp->fl_flags); + + if (lockp->fl_owner != files) + continue; + + if (IS_POSIX(lockp)) { + rc = checkpoint_one_file_lock(ctx, file, fd, lockp); + if (rc < 0) { + ckpt_err(ctx, rc, "%(T)fd %d, checkpoint " + "lock failed\n", fd); + goto out; + } + } else { + rc = -EBADF; + ckpt_err(ctx, rc, "%(T)fd %d has unsupported file " + "lock type, flags 0x%x\n", fd, + lockp->fl_flags); + goto out; + } + } + + /* + * Checkpoint a dummy file-lock to mark the end of file-locks + * for this fd. + */ + memset(&last_lock, 0, sizeof(struct file_lock)); + last_lock.fl_start = -1; + last_lock.fl_flags = FL_POSIX; + rc = checkpoint_one_file_lock(ctx, file, fd, &last_lock); + if (rc < 0) + ckpt_err(ctx, rc, "%(T)fd %d, checkpoint last-lock failed\n", + fd); +out: + unlock_kernel(); + return rc; +} + /** - * ckpt_write_file_desc - dump the state of a given file descriptor + * checkpoint_file_desc - dump the state of a given file descriptor * @ctx: checkpoint context * @files: files_struct pointer * @fd: file descriptor @@ -282,18 +361,6 @@ static int checkpoint_file_desc(struct ckpt_ctx *ctx, } rcu_read_unlock(); - ret = find_locks_with_owner(file, files); - /* - * find_locks_with_owner() returns an error when there - * are no locks found, so we *want* it to return an error - * code. Its success means we have to fail the checkpoint. - */ - if (!ret) { - ret = -EBADF; - ckpt_err(ctx, ret, "%(T)fd %d has file lock or lease\n", fd); - goto out; - } - /* sanity check (although this shouldn't happen) */ ret = -EBADF; if (!file) { @@ -328,6 +395,11 @@ static int checkpoint_file_desc(struct ckpt_ctx *ctx, h->fd_close_on_exec = coe; ret = ckpt_write_obj(ctx, &h->h); + if (ret < 0) + goto out; + + ret = checkpoint_file_locks(ctx, files, file, fd); + out: ckpt_hdr_put(ctx, h); if (file) diff --git a/include/linux/checkpoint_hdr.h b/include/linux/checkpoint_hdr.h index 790214f..d2a0fcd 100644 --- a/include/linux/checkpoint_hdr.h +++ b/include/linux/checkpoint_hdr.h @@ -144,6 +144,8 @@ enum { #define CKPT_HDR_TTY_LDISC CKPT_HDR_TTY_LDISC CKPT_HDR_EPOLL_ITEMS, /* must be after file-table */ #define CKPT_HDR_EPOLL_ITEMS CKPT_HDR_EPOLL_ITEMS + CKPT_HDR_FILE_LOCK, +#define CKPT_HDR_FILE_LOCK CKPT_HDR_FILE_LOCK CKPT_HDR_MM = 401, #define CKPT_HDR_MM CKPT_HDR_MM @@ -576,6 +578,14 @@ struct ckpt_hdr_file_generic { struct ckpt_hdr_file common; } __attribute__((aligned(8))); +struct ckpt_hdr_file_lock { + struct ckpt_hdr h; + loff_t fl_start; + loff_t fl_end; + __u8 fl_type; + __u8 fl_flags; +}; + struct ckpt_hdr_file_pipe { struct ckpt_hdr_file common; __s32 pipe_objref; -- 1.6.0.4 ^ permalink raw reply related [flat|nested] 5+ messages in thread
* [RFC][cr][PATCH 2/6] Checkpoint file-locks 2010-05-05 5:30 [RFC][PATCH 0/6][cr]: Checkpoint/restart file locks and leases Sukadev Bhattiprolu [not found] ` <20100505053016.GA20483-r/Jw6+rmf7HQT0dZR+AlfA@public.gmane.org> @ 2010-05-05 5:31 ` Sukadev Bhattiprolu 1 sibling, 0 replies; 5+ messages in thread From: Sukadev Bhattiprolu @ 2010-05-05 5:31 UTC (permalink / raw) To: Oren Laadan; +Cc: Containers, linux-fsdevel, serue, matthltc, sukadev >From 46f8a088d15eda817f537cbb17574253a3af4e8c Mon Sep 17 00:00:00 2001 From: Sukadev Bhattiprolu <sukadev@linux.vnet.ibm.com> Date: Thu, 29 Apr 2010 23:43:46 -0700 Subject: [RFC][cr][PATCH 2/6] Checkpoint file-locks While checkpointing each file-descriptor, find all the locks on the file and save information about the lock in the checkpoint-image. A follow-on patch will use this informaiton to restore the file-locks. Signed-off-by: Sukadev Bhattiprolu <sukadev@linux.vnet.ibm.com> --- fs/checkpoint.c | 98 ++++++++++++++++++++++++++++++++++----- include/linux/checkpoint_hdr.h | 10 ++++ 2 files changed, 95 insertions(+), 13 deletions(-) diff --git a/fs/checkpoint.c b/fs/checkpoint.c index e036a7a..180302e 100644 --- a/fs/checkpoint.c +++ b/fs/checkpoint.c @@ -26,6 +26,7 @@ #include <linux/checkpoint.h> #include <linux/eventpoll.h> #include <linux/eventfd.h> +#include <linux/smp_lock.h> #include <net/sock.h> /************************************************************************** @@ -249,8 +250,86 @@ static int checkpoint_file(struct ckpt_ctx *ctx, void *ptr) return ret; } +static int checkpoint_one_file_lock(struct ckpt_ctx *ctx, struct file *file, + int fd, struct file_lock *lock) +{ + int rc; + struct ckpt_hdr_file_lock *h; + + h = ckpt_hdr_get_type(ctx, sizeof(*h), CKPT_HDR_FILE_LOCK); + if (!h) + return -ENOMEM; + + h->fl_start = lock->fl_start; + h->fl_end = lock->fl_end; + h->fl_type = lock->fl_type; + h->fl_flags = lock->fl_flags; + + rc = ckpt_write_obj(ctx, &h->h); + + ckpt_hdr_put(ctx, h); + + ckpt_debug("Lock [%lld, %lld, %d, 0x%x] fd %d, rc %d\n", lock->fl_start, + lock->fl_end, lock->fl_type, lock->fl_flags, fd, rc); + + return rc; +} + +int +checkpoint_file_locks(struct ckpt_ctx *ctx, struct files_struct *files, + struct file *file, int fd) +{ + int rc; + struct inode *inode; + struct file_lock **lockpp; + struct file_lock *lockp; + struct file_lock last_lock; + + lock_kernel(); + inode = file->f_path.dentry->d_inode; + for_each_lock(inode, lockpp) { + lockp = *lockpp; + ckpt_debug("Found lock [%lld, %lld, %d, 0x%x]\n", + lockp->fl_start, lockp->fl_end, + lockp->fl_type, lockp->fl_flags); + + if (lockp->fl_owner != files) + continue; + + if (IS_POSIX(lockp)) { + rc = checkpoint_one_file_lock(ctx, file, fd, lockp); + if (rc < 0) { + ckpt_err(ctx, rc, "%(T)fd %d, checkpoint " + "lock failed\n", fd); + goto out; + } + } else { + rc = -EBADF; + ckpt_err(ctx, rc, "%(T)fd %d has unsupported file " + "lock type, flags 0x%x\n", fd, + lockp->fl_flags); + goto out; + } + } + + /* + * Checkpoint a dummy file-lock to mark the end of file-locks + * for this fd. + */ + memset(&last_lock, 0, sizeof(struct file_lock)); + last_lock.fl_start = -1; + last_lock.fl_flags = FL_POSIX; + rc = checkpoint_one_file_lock(ctx, file, fd, &last_lock); + if (rc < 0) + ckpt_err(ctx, rc, "%(T)fd %d, checkpoint last-lock failed\n", + fd); +out: + unlock_kernel(); + return rc; +} + /** - * ckpt_write_file_desc - dump the state of a given file descriptor + * checkpoint_file_desc - dump the state of a given file descriptor * @ctx: checkpoint context * @files: files_struct pointer * @fd: file descriptor @@ -282,18 +361,6 @@ static int checkpoint_file_desc(struct ckpt_ctx *ctx, } rcu_read_unlock(); - ret = find_locks_with_owner(file, files); - /* - * find_locks_with_owner() returns an error when there - * are no locks found, so we *want* it to return an error - * code. Its success means we have to fail the checkpoint. - */ - if (!ret) { - ret = -EBADF; - ckpt_err(ctx, ret, "%(T)fd %d has file lock or lease\n", fd); - goto out; - } - /* sanity check (although this shouldn't happen) */ ret = -EBADF; if (!file) { @@ -328,6 +395,11 @@ static int checkpoint_file_desc(struct ckpt_ctx *ctx, h->fd_close_on_exec = coe; ret = ckpt_write_obj(ctx, &h->h); + if (ret < 0) + goto out; + + ret = checkpoint_file_locks(ctx, files, file, fd); + out: ckpt_hdr_put(ctx, h); if (file) diff --git a/include/linux/checkpoint_hdr.h b/include/linux/checkpoint_hdr.h index 790214f..d2a0fcd 100644 --- a/include/linux/checkpoint_hdr.h +++ b/include/linux/checkpoint_hdr.h @@ -144,6 +144,8 @@ enum { #define CKPT_HDR_TTY_LDISC CKPT_HDR_TTY_LDISC CKPT_HDR_EPOLL_ITEMS, /* must be after file-table */ #define CKPT_HDR_EPOLL_ITEMS CKPT_HDR_EPOLL_ITEMS + CKPT_HDR_FILE_LOCK, +#define CKPT_HDR_FILE_LOCK CKPT_HDR_FILE_LOCK CKPT_HDR_MM = 401, #define CKPT_HDR_MM CKPT_HDR_MM @@ -576,6 +578,14 @@ struct ckpt_hdr_file_generic { struct ckpt_hdr_file common; } __attribute__((aligned(8))); +struct ckpt_hdr_file_lock { + struct ckpt_hdr h; + loff_t fl_start; + loff_t fl_end; + __u8 fl_type; + __u8 fl_flags; +}; + struct ckpt_hdr_file_pipe { struct ckpt_hdr_file common; __s32 pipe_objref; -- 1.6.0.4 ^ permalink raw reply related [flat|nested] 5+ messages in thread
end of thread, other threads:[~2010-05-05 14:56 UTC | newest]
Thread overview: 5+ messages (download: mbox.gz follow: Atom feed
-- links below jump to the message on this page --
[not found] <1273023883-19264-1-git-send-email-Sukadev>
[not found] ` <1273023883-19264-4-git-send-email-Sukadev>
2010-05-05 2:49 ` [RFC][cr][PATCH 4/6] Restore file-locks Matt Helsley
[not found] ` <1273023883-19264-2-git-send-email-Sukadev>
2010-05-05 3:12 ` [RFC][cr][PATCH 2/6] Checkpoint file-locks Matt Helsley
[not found] ` <20100505031256.GJ31830-52DBMbEzqgQ/wnmkkaCWp/UQ3DHhIser@public.gmane.org>
2010-05-05 14:56 ` Serge E. Hallyn
2010-05-05 5:30 [RFC][PATCH 0/6][cr]: Checkpoint/restart file locks and leases Sukadev Bhattiprolu
[not found] ` <20100505053016.GA20483-r/Jw6+rmf7HQT0dZR+AlfA@public.gmane.org>
2010-05-05 5:31 ` [RFC][cr][PATCH 2/6] Checkpoint file-locks Sukadev Bhattiprolu
2010-05-05 5:31 ` Sukadev Bhattiprolu
This is an external index of several public inboxes, see mirroring instructions on how to clone and mirror all data and code used by this external index.