| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | /*
 | 
					
						
							|  |  |  |  *  linux/fs/9p/vfs_file.c | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  * This file contians vfs file ops for 9P2000. | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  *  Copyright (C) 2004 by Eric Van Hensbergen <ericvh@gmail.com> | 
					
						
							|  |  |  |  *  Copyright (C) 2002 by Ron Minnich <rminnich@lanl.gov> | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  *  This program is free software; you can redistribute it and/or modify | 
					
						
							| 
									
										
										
										
											2006-03-25 03:07:28 -08:00
										 |  |  |  *  it under the terms of the GNU General Public License version 2 | 
					
						
							|  |  |  |  *  as published by the Free Software Foundation. | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  |  * | 
					
						
							|  |  |  |  *  This program is distributed in the hope that it will be useful, | 
					
						
							|  |  |  |  *  but WITHOUT ANY WARRANTY; without even the implied warranty of | 
					
						
							|  |  |  |  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the | 
					
						
							|  |  |  |  *  GNU General Public License for more details. | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  *  You should have received a copy of the GNU General Public License | 
					
						
							|  |  |  |  *  along with this program; if not, write to: | 
					
						
							|  |  |  |  *  Free Software Foundation | 
					
						
							|  |  |  |  *  51 Franklin Street, Fifth Floor | 
					
						
							|  |  |  |  *  Boston, MA  02111-1301  USA | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | #include <linux/module.h>
 | 
					
						
							|  |  |  | #include <linux/errno.h>
 | 
					
						
							|  |  |  | #include <linux/fs.h>
 | 
					
						
							| 
									
										
										
										
											2006-10-18 13:55:46 -04:00
										 |  |  | #include <linux/sched.h>
 | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | #include <linux/file.h>
 | 
					
						
							|  |  |  | #include <linux/stat.h>
 | 
					
						
							|  |  |  | #include <linux/string.h>
 | 
					
						
							|  |  |  | #include <linux/inet.h>
 | 
					
						
							|  |  |  | #include <linux/list.h>
 | 
					
						
							| 
									
										
										
										
											2009-09-22 11:34:05 -05:00
										 |  |  | #include <linux/pagemap.h>
 | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | #include <linux/utsname.h>
 | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | #include <asm/uaccess.h>
 | 
					
						
							|  |  |  | #include <linux/idr.h>
 | 
					
						
							| 
									
										
										
										
											2007-07-10 17:57:28 -05:00
										 |  |  | #include <net/9p/9p.h>
 | 
					
						
							|  |  |  | #include <net/9p/client.h>
 | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 
 | 
					
						
							|  |  |  | #include "v9fs.h"
 | 
					
						
							|  |  |  | #include "v9fs_vfs.h"
 | 
					
						
							|  |  |  | #include "fid.h"
 | 
					
						
							| 
									
										
										
										
											2009-09-23 13:00:27 -05:00
										 |  |  | #include "cache.h"
 | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | static const struct vm_operations_struct v9fs_file_vm_ops; | 
					
						
							| 
									
										
										
										
											2014-01-10 13:44:09 +01:00
										 |  |  | static const struct vm_operations_struct v9fs_mmap_file_vm_ops; | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | /**
 | 
					
						
							|  |  |  |  * v9fs_file_open - open a file (or directory) | 
					
						
							|  |  |  |  * @inode: inode to be opened | 
					
						
							|  |  |  |  * @file: file being opened | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | int v9fs_file_open(struct inode *inode, struct file *file) | 
					
						
							|  |  |  | { | 
					
						
							| 
									
										
										
										
											2006-03-02 02:54:30 -08:00
										 |  |  | 	int err; | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:03 +05:30
										 |  |  | 	struct v9fs_inode *v9inode; | 
					
						
							| 
									
										
										
										
											2007-07-10 17:57:28 -05:00
										 |  |  | 	struct v9fs_session_info *v9ses; | 
					
						
							|  |  |  | 	struct p9_fid *fid; | 
					
						
							|  |  |  | 	int omode; | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-11-28 10:40:46 -08:00
										 |  |  | 	p9_debug(P9_DEBUG_VFS, "inode: %p file: %p\n", inode, file); | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:03 +05:30
										 |  |  | 	v9inode = V9FS_I(inode); | 
					
						
							| 
									
										
										
										
											2007-07-10 17:57:28 -05:00
										 |  |  | 	v9ses = v9fs_inode2v9ses(inode); | 
					
						
							| 
									
										
										
										
											2010-06-22 19:47:50 +05:30
										 |  |  | 	if (v9fs_proto_dotl(v9ses)) | 
					
						
							| 
									
										
										
										
											2011-08-03 19:55:32 +05:30
										 |  |  | 		omode = v9fs_open_to_dotl_flags(file->f_flags); | 
					
						
							| 
									
										
										
										
											2010-06-22 19:47:50 +05:30
										 |  |  | 	else | 
					
						
							|  |  |  | 		omode = v9fs_uflags2omode(file->f_flags, | 
					
						
							|  |  |  | 					v9fs_proto_dotu(v9ses)); | 
					
						
							| 
									
										
										
										
											2007-07-10 17:57:28 -05:00
										 |  |  | 	fid = file->private_data; | 
					
						
							|  |  |  | 	if (!fid) { | 
					
						
							|  |  |  | 		fid = v9fs_fid_clone(file->f_path.dentry); | 
					
						
							|  |  |  | 		if (IS_ERR(fid)) | 
					
						
							|  |  |  | 			return PTR_ERR(fid); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		err = p9_client_open(fid, omode); | 
					
						
							| 
									
										
										
										
											2007-07-13 13:01:27 -05:00
										 |  |  | 		if (err < 0) { | 
					
						
							| 
									
										
										
										
											2007-07-10 17:57:28 -05:00
										 |  |  | 			p9_client_clunk(fid); | 
					
						
							|  |  |  | 			return err; | 
					
						
							|  |  |  | 		} | 
					
						
							| 
									
										
										
										
											2010-06-22 19:47:50 +05:30
										 |  |  | 		if ((file->f_flags & O_APPEND) && | 
					
						
							|  |  |  | 			(!v9fs_proto_dotu(v9ses) && !v9fs_proto_dotl(v9ses))) | 
					
						
							| 
									
										
										
										
											2008-06-24 17:39:39 -05:00
										 |  |  | 			generic_file_llseek(file, 0, SEEK_END); | 
					
						
							| 
									
										
										
										
											2006-03-02 02:54:30 -08:00
										 |  |  | 	} | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2007-07-10 17:57:28 -05:00
										 |  |  | 	file->private_data = fid; | 
					
						
							| 
									
										
										
										
											2011-03-08 16:39:46 +05:30
										 |  |  | 	mutex_lock(&v9inode->v_mutex); | 
					
						
							| 
									
										
										
										
											2014-01-10 13:44:09 +01:00
										 |  |  | 	if ((v9ses->cache == CACHE_LOOSE || v9ses->cache == CACHE_FSCACHE) && | 
					
						
							|  |  |  | 	    !v9inode->writeback_fid && | 
					
						
							| 
									
										
										
										
											2011-03-08 16:39:49 +05:30
										 |  |  | 	    ((file->f_flags & O_ACCMODE) != O_RDONLY)) { | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:57 +05:30
										 |  |  | 		/*
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:03 +05:30
										 |  |  | 		 * clone a fid and add it to writeback_fid | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:57 +05:30
										 |  |  | 		 * we do it during open time instead of | 
					
						
							|  |  |  | 		 * page dirty time via write_begin/page_mkwrite | 
					
						
							|  |  |  | 		 * because we want write after unlink usecase | 
					
						
							|  |  |  | 		 * to work. | 
					
						
							|  |  |  | 		 */ | 
					
						
							|  |  |  | 		fid = v9fs_writeback_fid(file->f_path.dentry); | 
					
						
							|  |  |  | 		if (IS_ERR(fid)) { | 
					
						
							|  |  |  | 			err = PTR_ERR(fid); | 
					
						
							| 
									
										
										
										
											2011-03-08 16:39:46 +05:30
										 |  |  | 			mutex_unlock(&v9inode->v_mutex); | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:57 +05:30
										 |  |  | 			goto out_error; | 
					
						
							|  |  |  | 		} | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:03 +05:30
										 |  |  | 		v9inode->writeback_fid = (void *) fid; | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:57 +05:30
										 |  |  | 	} | 
					
						
							| 
									
										
										
										
											2011-03-08 16:39:46 +05:30
										 |  |  | 	mutex_unlock(&v9inode->v_mutex); | 
					
						
							| 
									
										
										
										
											2014-01-10 13:44:09 +01:00
										 |  |  | 	if (v9ses->cache == CACHE_LOOSE || v9ses->cache == CACHE_FSCACHE) | 
					
						
							| 
									
										
										
										
											2009-09-23 13:00:27 -05:00
										 |  |  | 		v9fs_cache_inode_set_cookie(inode, file); | 
					
						
							| 
									
										
										
										
											2006-03-02 02:54:30 -08:00
										 |  |  | 	return 0; | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:57 +05:30
										 |  |  | out_error: | 
					
						
							|  |  |  | 	p9_client_clunk(file->private_data); | 
					
						
							|  |  |  | 	file->private_data = NULL; | 
					
						
							|  |  |  | 	return err; | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | /**
 | 
					
						
							|  |  |  |  * v9fs_file_lock - lock a file (or directory) | 
					
						
							| 
									
										
										
										
											2008-03-05 07:08:09 -06:00
										 |  |  |  * @filp: file to be locked | 
					
						
							|  |  |  |  * @cmd: lock command | 
					
						
							|  |  |  |  * @fl: file lock structure | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  |  * | 
					
						
							| 
									
										
										
										
											2008-03-05 07:08:09 -06:00
										 |  |  |  * Bugs: this looks like a local only lock, we should extend into 9P | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  |  *       by using open exclusive | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | static int v9fs_file_lock(struct file *filp, int cmd, struct file_lock *fl) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	int res = 0; | 
					
						
							| 
									
										
										
										
											2013-01-23 17:07:38 -05:00
										 |  |  | 	struct inode *inode = file_inode(filp); | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-11-28 10:40:46 -08:00
										 |  |  | 	p9_debug(P9_DEBUG_VFS, "filp: %p lock: %p\n", filp, fl); | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 
 | 
					
						
							|  |  |  | 	/* No mandatory locks */ | 
					
						
							| 
									
										
										
										
											2010-03-13 09:03:55 -06:00
										 |  |  | 	if (__mandatory_lock(inode) && fl->fl_type != F_UNLCK) | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 		return -ENOLCK; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if ((IS_SETLK(cmd) || IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) { | 
					
						
							| 
									
										
											  
											
												[PATCH] Fix and add EXPORT_SYMBOL(filemap_write_and_wait)
This patch add EXPORT_SYMBOL(filemap_write_and_wait) and use it.
See mm/filemap.c:
And changes the filemap_write_and_wait() and filemap_write_and_wait_range().
Current filemap_write_and_wait() doesn't wait if filemap_fdatawrite()
returns error.  However, even if filemap_fdatawrite() returned an
error, it may have submitted the partially data pages to the device.
(e.g. in the case of -ENOSPC)
<quotation>
Andrew Morton writes,
If filemap_fdatawrite() returns an error, this might be due to some
I/O problem: dead disk, unplugged cable, etc.  Given the generally
crappy quality of the kernel's handling of such exceptions, there's a
good chance that the filemap_fdatawait() will get stuck in D state
forever.
</quotation>
So, this patch doesn't wait if filemap_fdatawrite() returns the -EIO.
Trond, could you please review the nfs part?  Especially I'm not sure,
nfs must use the "filemap_fdatawrite(inode->i_mapping) == 0", or not.
Acked-by: Trond Myklebust <trond.myklebust@fys.uio.no>
Signed-off-by: Andrew Morton <akpm@osdl.org>
Signed-off-by: Linus Torvalds <torvalds@osdl.org>
											
										 
											2006-01-08 01:02:14 -08:00
										 |  |  | 		filemap_write_and_wait(inode->i_mapping); | 
					
						
							| 
									
										
										
										
											2007-02-10 01:45:39 -08:00
										 |  |  | 		invalidate_mapping_pages(&inode->i_data, 0, -1); | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 	} | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	return res; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | static int v9fs_file_do_lock(struct file *filp, int cmd, struct file_lock *fl) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	struct p9_flock flock; | 
					
						
							|  |  |  | 	struct p9_fid *fid; | 
					
						
							|  |  |  | 	uint8_t status; | 
					
						
							|  |  |  | 	int res = 0; | 
					
						
							|  |  |  | 	unsigned char fl_type; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	fid = filp->private_data; | 
					
						
							|  |  |  | 	BUG_ON(fid == NULL); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if ((fl->fl_flags & FL_POSIX) != FL_POSIX) | 
					
						
							|  |  |  | 		BUG(); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	res = posix_lock_file_wait(filp, fl); | 
					
						
							|  |  |  | 	if (res < 0) | 
					
						
							|  |  |  | 		goto out; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	/* convert posix lock to p9 tlock args */ | 
					
						
							|  |  |  | 	memset(&flock, 0, sizeof(flock)); | 
					
						
							| 
									
										
										
										
											2011-08-21 00:21:18 +05:30
										 |  |  | 	/* map the lock type */ | 
					
						
							|  |  |  | 	switch (fl->fl_type) { | 
					
						
							|  |  |  | 	case F_RDLCK: | 
					
						
							|  |  |  | 		flock.type = P9_LOCK_TYPE_RDLCK; | 
					
						
							|  |  |  | 		break; | 
					
						
							|  |  |  | 	case F_WRLCK: | 
					
						
							|  |  |  | 		flock.type = P9_LOCK_TYPE_WRLCK; | 
					
						
							|  |  |  | 		break; | 
					
						
							|  |  |  | 	case F_UNLCK: | 
					
						
							|  |  |  | 		flock.type = P9_LOCK_TYPE_UNLCK; | 
					
						
							|  |  |  | 		break; | 
					
						
							|  |  |  | 	} | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | 	flock.start = fl->fl_start; | 
					
						
							|  |  |  | 	if (fl->fl_end == OFFSET_MAX) | 
					
						
							|  |  |  | 		flock.length = 0; | 
					
						
							|  |  |  | 	else | 
					
						
							|  |  |  | 		flock.length = fl->fl_end - fl->fl_start + 1; | 
					
						
							|  |  |  | 	flock.proc_id = fl->fl_pid; | 
					
						
							| 
									
										
										
										
											2013-08-21 18:24:47 +01:00
										 |  |  | 	flock.client_id = fid->clnt->name; | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | 	if (IS_SETLKW(cmd)) | 
					
						
							|  |  |  | 		flock.flags = P9_LOCK_FLAGS_BLOCK; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	/*
 | 
					
						
							|  |  |  | 	 * if its a blocked request and we get P9_LOCK_BLOCKED as the status | 
					
						
							|  |  |  | 	 * for lock request, keep on trying | 
					
						
							|  |  |  | 	 */ | 
					
						
							|  |  |  | 	for (;;) { | 
					
						
							|  |  |  | 		res = p9_client_lock_dotl(fid, &flock, &status); | 
					
						
							|  |  |  | 		if (res < 0) | 
					
						
							|  |  |  | 			break; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		if (status != P9_LOCK_BLOCKED) | 
					
						
							|  |  |  | 			break; | 
					
						
							|  |  |  | 		if (status == P9_LOCK_BLOCKED && !IS_SETLKW(cmd)) | 
					
						
							|  |  |  | 			break; | 
					
						
							| 
									
										
										
										
											2012-01-03 15:27:50 -06:00
										 |  |  | 		if (schedule_timeout_interruptible(P9_LOCK_TIMEOUT) != 0) | 
					
						
							|  |  |  | 			break; | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | 	} | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	/* map 9p status to VFS status */ | 
					
						
							|  |  |  | 	switch (status) { | 
					
						
							|  |  |  | 	case P9_LOCK_SUCCESS: | 
					
						
							|  |  |  | 		res = 0; | 
					
						
							|  |  |  | 		break; | 
					
						
							|  |  |  | 	case P9_LOCK_BLOCKED: | 
					
						
							|  |  |  | 		res = -EAGAIN; | 
					
						
							|  |  |  | 		break; | 
					
						
							|  |  |  | 	case P9_LOCK_ERROR: | 
					
						
							|  |  |  | 	case P9_LOCK_GRACE: | 
					
						
							|  |  |  | 		res = -ENOLCK; | 
					
						
							|  |  |  | 		break; | 
					
						
							|  |  |  | 	default: | 
					
						
							|  |  |  | 		BUG(); | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	/*
 | 
					
						
							|  |  |  | 	 * incase server returned error for lock request, revert | 
					
						
							|  |  |  | 	 * it locally | 
					
						
							|  |  |  | 	 */ | 
					
						
							|  |  |  | 	if (res < 0 && fl->fl_type != F_UNLCK) { | 
					
						
							|  |  |  | 		fl_type = fl->fl_type; | 
					
						
							|  |  |  | 		fl->fl_type = F_UNLCK; | 
					
						
							|  |  |  | 		res = posix_lock_file_wait(filp, fl); | 
					
						
							|  |  |  | 		fl->fl_type = fl_type; | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | out: | 
					
						
							|  |  |  | 	return res; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2010-09-27 12:22:13 +05:30
										 |  |  | static int v9fs_file_getlock(struct file *filp, struct file_lock *fl) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	struct p9_getlock glock; | 
					
						
							|  |  |  | 	struct p9_fid *fid; | 
					
						
							|  |  |  | 	int res = 0; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	fid = filp->private_data; | 
					
						
							|  |  |  | 	BUG_ON(fid == NULL); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	posix_test_lock(filp, fl); | 
					
						
							|  |  |  | 	/*
 | 
					
						
							|  |  |  | 	 * if we have a conflicting lock locally, no need to validate | 
					
						
							|  |  |  | 	 * with server | 
					
						
							|  |  |  | 	 */ | 
					
						
							|  |  |  | 	if (fl->fl_type != F_UNLCK) | 
					
						
							|  |  |  | 		return res; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	/* convert posix lock to p9 tgetlock args */ | 
					
						
							|  |  |  | 	memset(&glock, 0, sizeof(glock)); | 
					
						
							| 
									
										
										
										
											2011-08-21 00:21:18 +05:30
										 |  |  | 	glock.type  = P9_LOCK_TYPE_UNLCK; | 
					
						
							| 
									
										
										
										
											2010-09-27 12:22:13 +05:30
										 |  |  | 	glock.start = fl->fl_start; | 
					
						
							|  |  |  | 	if (fl->fl_end == OFFSET_MAX) | 
					
						
							|  |  |  | 		glock.length = 0; | 
					
						
							|  |  |  | 	else | 
					
						
							|  |  |  | 		glock.length = fl->fl_end - fl->fl_start + 1; | 
					
						
							|  |  |  | 	glock.proc_id = fl->fl_pid; | 
					
						
							| 
									
										
										
										
											2013-08-21 18:24:47 +01:00
										 |  |  | 	glock.client_id = fid->clnt->name; | 
					
						
							| 
									
										
										
										
											2010-09-27 12:22:13 +05:30
										 |  |  | 
 | 
					
						
							|  |  |  | 	res = p9_client_getlock_dotl(fid, &glock); | 
					
						
							|  |  |  | 	if (res < 0) | 
					
						
							|  |  |  | 		return res; | 
					
						
							| 
									
										
										
										
											2011-08-21 00:21:18 +05:30
										 |  |  | 	/* map 9p lock type to os lock type */ | 
					
						
							|  |  |  | 	switch (glock.type) { | 
					
						
							|  |  |  | 	case P9_LOCK_TYPE_RDLCK: | 
					
						
							|  |  |  | 		fl->fl_type = F_RDLCK; | 
					
						
							|  |  |  | 		break; | 
					
						
							|  |  |  | 	case P9_LOCK_TYPE_WRLCK: | 
					
						
							|  |  |  | 		fl->fl_type = F_WRLCK; | 
					
						
							|  |  |  | 		break; | 
					
						
							|  |  |  | 	case P9_LOCK_TYPE_UNLCK: | 
					
						
							|  |  |  | 		fl->fl_type = F_UNLCK; | 
					
						
							|  |  |  | 		break; | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	if (glock.type != P9_LOCK_TYPE_UNLCK) { | 
					
						
							| 
									
										
										
										
											2010-09-27 12:22:13 +05:30
										 |  |  | 		fl->fl_start = glock.start; | 
					
						
							|  |  |  | 		if (glock.length == 0) | 
					
						
							|  |  |  | 			fl->fl_end = OFFSET_MAX; | 
					
						
							|  |  |  | 		else | 
					
						
							|  |  |  | 			fl->fl_end = glock.start + glock.length - 1; | 
					
						
							|  |  |  | 		fl->fl_pid = glock.proc_id; | 
					
						
							| 
									
										
										
										
											2011-08-21 00:21:18 +05:30
										 |  |  | 	} | 
					
						
							| 
									
										
										
										
											2010-09-27 12:22:13 +05:30
										 |  |  | 	return res; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | /**
 | 
					
						
							|  |  |  |  * v9fs_file_lock_dotl - lock a file (or directory) | 
					
						
							|  |  |  |  * @filp: file to be locked | 
					
						
							|  |  |  |  * @cmd: lock command | 
					
						
							|  |  |  |  * @fl: file lock structure | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | static int v9fs_file_lock_dotl(struct file *filp, int cmd, struct file_lock *fl) | 
					
						
							|  |  |  | { | 
					
						
							| 
									
										
										
										
											2013-01-23 17:07:38 -05:00
										 |  |  | 	struct inode *inode = file_inode(filp); | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | 	int ret = -ENOLCK; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2014-08-19 20:17:38 -04:00
										 |  |  | 	p9_debug(P9_DEBUG_VFS, "filp: %p cmd:%d lock: %p name: %pD\n", | 
					
						
							|  |  |  | 		 filp, cmd, fl, filp); | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | 
 | 
					
						
							|  |  |  | 	/* No mandatory locks */ | 
					
						
							|  |  |  | 	if (__mandatory_lock(inode) && fl->fl_type != F_UNLCK) | 
					
						
							|  |  |  | 		goto out_err; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if ((IS_SETLK(cmd) || IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) { | 
					
						
							|  |  |  | 		filemap_write_and_wait(inode->i_mapping); | 
					
						
							|  |  |  | 		invalidate_mapping_pages(&inode->i_data, 0, -1); | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if (IS_SETLK(cmd) || IS_SETLKW(cmd)) | 
					
						
							|  |  |  | 		ret = v9fs_file_do_lock(filp, cmd, fl); | 
					
						
							| 
									
										
										
										
											2010-09-27 12:22:13 +05:30
										 |  |  | 	else if (IS_GETLK(cmd)) | 
					
						
							|  |  |  | 		ret = v9fs_file_getlock(filp, fl); | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | 	else | 
					
						
							|  |  |  | 		ret = -EINVAL; | 
					
						
							|  |  |  | out_err: | 
					
						
							|  |  |  | 	return ret; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | /**
 | 
					
						
							|  |  |  |  * v9fs_file_flock_dotl - lock a file | 
					
						
							|  |  |  |  * @filp: file to be locked | 
					
						
							|  |  |  |  * @cmd: lock command | 
					
						
							|  |  |  |  * @fl: file lock structure | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | static int v9fs_file_flock_dotl(struct file *filp, int cmd, | 
					
						
							|  |  |  | 	struct file_lock *fl) | 
					
						
							|  |  |  | { | 
					
						
							| 
									
										
										
										
											2013-01-23 17:07:38 -05:00
										 |  |  | 	struct inode *inode = file_inode(filp); | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | 	int ret = -ENOLCK; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2014-08-19 20:17:38 -04:00
										 |  |  | 	p9_debug(P9_DEBUG_VFS, "filp: %p cmd:%d lock: %p name: %pD\n", | 
					
						
							|  |  |  | 		 filp, cmd, fl, filp); | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | 
 | 
					
						
							|  |  |  | 	/* No mandatory locks */ | 
					
						
							|  |  |  | 	if (__mandatory_lock(inode) && fl->fl_type != F_UNLCK) | 
					
						
							|  |  |  | 		goto out_err; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if (!(fl->fl_flags & FL_FLOCK)) | 
					
						
							|  |  |  | 		goto out_err; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if ((IS_SETLK(cmd) || IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) { | 
					
						
							|  |  |  | 		filemap_write_and_wait(inode->i_mapping); | 
					
						
							|  |  |  | 		invalidate_mapping_pages(&inode->i_data, 0, -1); | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	/* Convert flock to posix lock */ | 
					
						
							|  |  |  | 	fl->fl_flags |= FL_POSIX; | 
					
						
							|  |  |  | 	fl->fl_flags ^= FL_FLOCK; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if (IS_SETLK(cmd) | IS_SETLKW(cmd)) | 
					
						
							|  |  |  | 		ret = v9fs_file_do_lock(filp, cmd, fl); | 
					
						
							|  |  |  | 	else | 
					
						
							|  |  |  | 		ret = -EINVAL; | 
					
						
							|  |  |  | out_err: | 
					
						
							|  |  |  | 	return ret; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | /**
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:56 +05:30
										 |  |  |  * v9fs_fid_readn - read from a fid | 
					
						
							|  |  |  |  * @fid: fid to read | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  |  * @data: data buffer to read data into | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  |  * @udata: user data buffer to read data into | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  |  * @count: size of buffer | 
					
						
							|  |  |  |  * @offset: offset at which to read data | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  */ | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | ssize_t | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:56 +05:30
										 |  |  | v9fs_fid_readn(struct p9_fid *fid, char *data, char __user *udata, u32 count, | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | 	       u64 offset) | 
					
						
							|  |  |  | { | 
					
						
							| 
									
										
										
										
											2010-06-04 11:59:07 +00:00
										 |  |  | 	int n, total, size; | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-11-28 10:40:46 -08:00
										 |  |  | 	p9_debug(P9_DEBUG_VFS, "fid %d offset %llu count %d\n", | 
					
						
							|  |  |  | 		 fid->fid, (long long unsigned)offset, count); | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | 	n = 0; | 
					
						
							|  |  |  | 	total = 0; | 
					
						
							| 
									
										
										
										
											2010-06-04 11:59:07 +00:00
										 |  |  | 	size = fid->iounit ? fid->iounit : fid->clnt->msize - P9_IOHDRSZ; | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | 	do { | 
					
						
							|  |  |  | 		n = p9_client_read(fid, data, udata, offset, count); | 
					
						
							|  |  |  | 		if (n <= 0) | 
					
						
							|  |  |  | 			break; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		if (data) | 
					
						
							|  |  |  | 			data += n; | 
					
						
							|  |  |  | 		if (udata) | 
					
						
							|  |  |  | 			udata += n; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		offset += n; | 
					
						
							|  |  |  | 		count -= n; | 
					
						
							|  |  |  | 		total += n; | 
					
						
							| 
									
										
										
										
											2010-06-04 11:59:07 +00:00
										 |  |  | 	} while (count > 0 && n == size); | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | 
 | 
					
						
							|  |  |  | 	if (n < 0) | 
					
						
							|  |  |  | 		total = n; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	return total; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:56 +05:30
										 |  |  | /**
 | 
					
						
							|  |  |  |  * v9fs_file_readn - read from a file | 
					
						
							|  |  |  |  * @filp: file pointer to read | 
					
						
							|  |  |  |  * @data: data buffer to read data into | 
					
						
							|  |  |  |  * @udata: user data buffer to read data into | 
					
						
							|  |  |  |  * @count: size of buffer | 
					
						
							|  |  |  |  * @offset: offset at which to read data | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | ssize_t | 
					
						
							|  |  |  | v9fs_file_readn(struct file *filp, char *data, char __user *udata, u32 count, | 
					
						
							|  |  |  | 	       u64 offset) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	return v9fs_fid_readn(filp->private_data, data, udata, count, offset); | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | /**
 | 
					
						
							|  |  |  |  * v9fs_file_read - read from a file | 
					
						
							|  |  |  |  * @filp: file pointer to read | 
					
						
							|  |  |  |  * @udata: user data buffer to read data into | 
					
						
							|  |  |  |  * @count: size of buffer | 
					
						
							|  |  |  |  * @offset: offset at which to read data | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | static ssize_t | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | v9fs_file_read(struct file *filp, char __user *udata, size_t count, | 
					
						
							| 
									
										
										
										
											2005-10-11 08:29:03 -07:00
										 |  |  | 	       loff_t * offset) | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2007-07-10 17:57:28 -05:00
										 |  |  | 	int ret; | 
					
						
							|  |  |  | 	struct p9_fid *fid; | 
					
						
							| 
									
										
										
										
											2010-06-04 11:59:07 +00:00
										 |  |  | 	size_t size; | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-11-28 10:40:46 -08:00
										 |  |  | 	p9_debug(P9_DEBUG_VFS, "count %zu offset %lld\n", count, *offset); | 
					
						
							| 
									
										
										
										
											2007-07-10 17:57:28 -05:00
										 |  |  | 	fid = filp->private_data; | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2010-06-04 11:59:07 +00:00
										 |  |  | 	size = fid->iounit ? fid->iounit : fid->clnt->msize - P9_IOHDRSZ; | 
					
						
							|  |  |  | 	if (count > size) | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | 		ret = v9fs_file_readn(filp, NULL, udata, count, *offset); | 
					
						
							|  |  |  | 	else | 
					
						
							|  |  |  | 		ret = p9_client_read(fid, NULL, udata, *offset, count); | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2007-07-10 17:57:28 -05:00
										 |  |  | 	if (ret > 0) | 
					
						
							|  |  |  | 		*offset += ret; | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2007-07-10 17:57:28 -05:00
										 |  |  | 	return ret; | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:56 +05:30
										 |  |  | ssize_t | 
					
						
							|  |  |  | v9fs_file_write_internal(struct inode *inode, struct p9_fid *fid, | 
					
						
							|  |  |  | 			 const char __user *data, size_t count, | 
					
						
							|  |  |  | 			 loff_t *offset, int invalidate) | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2010-08-30 13:23:20 -05:00
										 |  |  | 	int n; | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:04 +05:30
										 |  |  | 	loff_t i_size; | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:56 +05:30
										 |  |  | 	size_t total = 0; | 
					
						
							| 
									
										
										
										
											2010-03-08 22:07:02 +00:00
										 |  |  | 	loff_t origin = *offset; | 
					
						
							| 
									
										
										
										
											2009-09-22 11:34:05 -05:00
										 |  |  | 	unsigned long pg_start, pg_end; | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-11-28 10:40:46 -08:00
										 |  |  | 	p9_debug(P9_DEBUG_VFS, "data %p count %d offset %x\n", | 
					
						
							|  |  |  | 		 data, (int)count, (int)*offset); | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | 	do { | 
					
						
							| 
									
										
										
										
											2010-08-30 13:23:20 -05:00
										 |  |  | 		n = p9_client_write(fid, NULL, data+total, origin+total, count); | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | 		if (n <= 0) | 
					
						
							|  |  |  | 			break; | 
					
						
							|  |  |  | 		count -= n; | 
					
						
							|  |  |  | 		total += n; | 
					
						
							|  |  |  | 	} while (count > 0); | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:56 +05:30
										 |  |  | 	if (invalidate && (total > 0)) { | 
					
						
							| 
									
										
										
										
											2009-09-22 11:34:05 -05:00
										 |  |  | 		pg_start = origin >> PAGE_CACHE_SHIFT; | 
					
						
							|  |  |  | 		pg_end = (origin + total - 1) >> PAGE_CACHE_SHIFT; | 
					
						
							| 
									
										
										
										
											2009-09-23 13:00:27 -05:00
										 |  |  | 		if (inode->i_mapping && inode->i_mapping->nrpages) | 
					
						
							|  |  |  | 			invalidate_inode_pages2_range(inode->i_mapping, | 
					
						
							|  |  |  | 						      pg_start, pg_end); | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | 		*offset += total; | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:04 +05:30
										 |  |  | 		i_size = i_size_read(inode); | 
					
						
							|  |  |  | 		if (*offset > i_size) { | 
					
						
							|  |  |  | 			inode_add_bytes(inode, *offset - i_size); | 
					
						
							|  |  |  | 			i_size_write(inode, *offset); | 
					
						
							|  |  |  | 		} | 
					
						
							| 
									
										
										
										
											2007-07-13 13:01:27 -05:00
										 |  |  | 	} | 
					
						
							| 
									
										
										
										
											2008-10-13 20:36:16 -05:00
										 |  |  | 	if (n < 0) | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:56 +05:30
										 |  |  | 		return n; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	return total; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | /**
 | 
					
						
							|  |  |  |  * v9fs_file_write - write to a file | 
					
						
							|  |  |  |  * @filp: file pointer to write | 
					
						
							|  |  |  |  * @data: data buffer to write data from | 
					
						
							|  |  |  |  * @count: size of buffer | 
					
						
							|  |  |  |  * @offset: offset at which to write data | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | static ssize_t | 
					
						
							|  |  |  | v9fs_file_write(struct file *filp, const char __user * data, | 
					
						
							|  |  |  | 		size_t count, loff_t *offset) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	ssize_t retval = 0; | 
					
						
							|  |  |  | 	loff_t origin = *offset; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	retval = generic_write_checks(filp, &origin, &count, 0); | 
					
						
							|  |  |  | 	if (retval) | 
					
						
							|  |  |  | 		goto out; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	retval = -EINVAL; | 
					
						
							|  |  |  | 	if ((ssize_t) count < 0) | 
					
						
							|  |  |  | 		goto out; | 
					
						
							|  |  |  | 	retval = 0; | 
					
						
							|  |  |  | 	if (!count) | 
					
						
							|  |  |  | 		goto out; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2013-01-23 17:07:38 -05:00
										 |  |  | 	retval = v9fs_file_write_internal(file_inode(filp), | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:56 +05:30
										 |  |  | 					filp->private_data, | 
					
						
							| 
									
										
										
										
											2011-03-16 21:40:49 +05:30
										 |  |  | 					data, count, &origin, 1); | 
					
						
							|  |  |  | 	/* update offset on successful write */ | 
					
						
							|  |  |  | 	if (retval > 0) | 
					
						
							|  |  |  | 		*offset = origin; | 
					
						
							| 
									
										
										
										
											2010-08-03 11:55:40 +00:00
										 |  |  | out: | 
					
						
							|  |  |  | 	return retval; | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-07-16 20:44:56 -04:00
										 |  |  | static int v9fs_file_fsync(struct file *filp, loff_t start, loff_t end, | 
					
						
							|  |  |  | 			   int datasync) | 
					
						
							| 
									
										
										
										
											2010-02-08 15:36:48 -06:00
										 |  |  | { | 
					
						
							|  |  |  | 	struct p9_fid *fid; | 
					
						
							| 
									
										
										
										
											2011-07-16 20:44:56 -04:00
										 |  |  | 	struct inode *inode = filp->f_mapping->host; | 
					
						
							| 
									
										
										
										
											2010-02-08 15:36:48 -06:00
										 |  |  | 	struct p9_wstat wstat; | 
					
						
							|  |  |  | 	int retval; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-07-16 20:44:56 -04:00
										 |  |  | 	retval = filemap_write_and_wait_range(inode->i_mapping, start, end); | 
					
						
							|  |  |  | 	if (retval) | 
					
						
							|  |  |  | 		return retval; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	mutex_lock(&inode->i_mutex); | 
					
						
							| 
									
										
										
										
											2011-11-28 10:40:46 -08:00
										 |  |  | 	p9_debug(P9_DEBUG_VFS, "filp %p datasync %x\n", filp, datasync); | 
					
						
							| 
									
										
										
										
											2010-02-08 15:36:48 -06:00
										 |  |  | 
 | 
					
						
							|  |  |  | 	fid = filp->private_data; | 
					
						
							|  |  |  | 	v9fs_blank_wstat(&wstat); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	retval = p9_client_wstat(fid, &wstat); | 
					
						
							| 
									
										
										
										
											2011-07-16 20:44:56 -04:00
										 |  |  | 	mutex_unlock(&inode->i_mutex); | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2010-02-08 15:36:48 -06:00
										 |  |  | 	return retval; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-07-16 20:44:56 -04:00
										 |  |  | int v9fs_file_fsync_dotl(struct file *filp, loff_t start, loff_t end, | 
					
						
							|  |  |  | 			 int datasync) | 
					
						
							| 
									
										
										
										
											2010-09-22 17:19:19 -07:00
										 |  |  | { | 
					
						
							|  |  |  | 	struct p9_fid *fid; | 
					
						
							| 
									
										
										
										
											2011-07-16 20:44:56 -04:00
										 |  |  | 	struct inode *inode = filp->f_mapping->host; | 
					
						
							| 
									
										
										
										
											2010-09-22 17:19:19 -07:00
										 |  |  | 	int retval; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-07-16 20:44:56 -04:00
										 |  |  | 	retval = filemap_write_and_wait_range(inode->i_mapping, start, end); | 
					
						
							|  |  |  | 	if (retval) | 
					
						
							|  |  |  | 		return retval; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	mutex_lock(&inode->i_mutex); | 
					
						
							| 
									
										
										
										
											2011-11-28 10:40:46 -08:00
										 |  |  | 	p9_debug(P9_DEBUG_VFS, "filp %p datasync %x\n", filp, datasync); | 
					
						
							| 
									
										
										
										
											2010-09-22 17:19:19 -07:00
										 |  |  | 
 | 
					
						
							|  |  |  | 	fid = filp->private_data; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2010-10-22 10:13:12 -07:00
										 |  |  | 	retval = p9_client_fsync(fid, datasync); | 
					
						
							| 
									
										
										
										
											2011-07-16 20:44:56 -04:00
										 |  |  | 	mutex_unlock(&inode->i_mutex); | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2010-09-22 17:19:19 -07:00
										 |  |  | 	return retval; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | static int | 
					
						
							| 
									
										
										
										
											2014-01-10 13:44:09 +01:00
										 |  |  | v9fs_file_mmap(struct file *filp, struct vm_area_struct *vma) | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | { | 
					
						
							|  |  |  | 	int retval; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2014-01-10 13:44:09 +01:00
										 |  |  | 
 | 
					
						
							|  |  |  | 	retval = generic_file_mmap(filp, vma); | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | 	if (!retval) | 
					
						
							|  |  |  | 		vma->vm_ops = &v9fs_file_vm_ops; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	return retval; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2014-01-10 13:44:09 +01:00
										 |  |  | static int | 
					
						
							|  |  |  | v9fs_mmap_file_mmap(struct file *filp, struct vm_area_struct *vma) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	int retval; | 
					
						
							|  |  |  | 	struct inode *inode; | 
					
						
							|  |  |  | 	struct v9fs_inode *v9inode; | 
					
						
							|  |  |  | 	struct p9_fid *fid; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	inode = file_inode(filp); | 
					
						
							|  |  |  | 	v9inode = V9FS_I(inode); | 
					
						
							|  |  |  | 	mutex_lock(&v9inode->v_mutex); | 
					
						
							|  |  |  | 	if (!v9inode->writeback_fid && | 
					
						
							|  |  |  | 	    (vma->vm_flags & VM_WRITE)) { | 
					
						
							|  |  |  | 		/*
 | 
					
						
							|  |  |  | 		 * clone a fid and add it to writeback_fid | 
					
						
							|  |  |  | 		 * we do it during mmap instead of | 
					
						
							|  |  |  | 		 * page dirty time via write_begin/page_mkwrite | 
					
						
							|  |  |  | 		 * because we want write after unlink usecase | 
					
						
							|  |  |  | 		 * to work. | 
					
						
							|  |  |  | 		 */ | 
					
						
							|  |  |  | 		fid = v9fs_writeback_fid(filp->f_path.dentry); | 
					
						
							|  |  |  | 		if (IS_ERR(fid)) { | 
					
						
							|  |  |  | 			retval = PTR_ERR(fid); | 
					
						
							|  |  |  | 			mutex_unlock(&v9inode->v_mutex); | 
					
						
							|  |  |  | 			return retval; | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 		v9inode->writeback_fid = (void *) fid; | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	mutex_unlock(&v9inode->v_mutex); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	retval = generic_file_mmap(filp, vma); | 
					
						
							|  |  |  | 	if (!retval) | 
					
						
							|  |  |  | 		vma->vm_ops = &v9fs_mmap_file_vm_ops; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	return retval; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | static int | 
					
						
							|  |  |  | v9fs_vm_page_mkwrite(struct vm_area_struct *vma, struct vm_fault *vmf) | 
					
						
							|  |  |  | { | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:03 +05:30
										 |  |  | 	struct v9fs_inode *v9inode; | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | 	struct page *page = vmf->page; | 
					
						
							|  |  |  | 	struct file *filp = vma->vm_file; | 
					
						
							| 
									
										
										
										
											2013-01-23 17:07:38 -05:00
										 |  |  | 	struct inode *inode = file_inode(filp); | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | 
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-11-28 10:40:46 -08:00
										 |  |  | 	p9_debug(P9_DEBUG_VFS, "page %p fid %lx\n", | 
					
						
							|  |  |  | 		 page, (unsigned long)filp->private_data); | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2012-06-12 16:20:25 +02:00
										 |  |  | 	/* Update file times before taking page lock */ | 
					
						
							|  |  |  | 	file_update_time(filp); | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:03 +05:30
										 |  |  | 	v9inode = V9FS_I(inode); | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | 	/* make sure the cache has finished storing the page */ | 
					
						
							|  |  |  | 	v9fs_fscache_wait_on_page_write(inode, page); | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:03 +05:30
										 |  |  | 	BUG_ON(!v9inode->writeback_fid); | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | 	lock_page(page); | 
					
						
							|  |  |  | 	if (page->mapping != inode->i_mapping) | 
					
						
							|  |  |  | 		goto out_unlock; | 
					
						
							| 
									
										
										
										
											2013-02-21 16:42:53 -08:00
										 |  |  | 	wait_for_stable_page(page); | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | 
 | 
					
						
							|  |  |  | 	return VM_FAULT_LOCKED; | 
					
						
							|  |  |  | out_unlock: | 
					
						
							|  |  |  | 	unlock_page(page); | 
					
						
							|  |  |  | 	return VM_FAULT_NOPAGE; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:04 +05:30
										 |  |  | static ssize_t | 
					
						
							|  |  |  | v9fs_direct_read(struct file *filp, char __user *udata, size_t count, | 
					
						
							|  |  |  | 		 loff_t *offsetp) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	loff_t size, offset; | 
					
						
							|  |  |  | 	struct inode *inode; | 
					
						
							|  |  |  | 	struct address_space *mapping; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	offset = *offsetp; | 
					
						
							|  |  |  | 	mapping = filp->f_mapping; | 
					
						
							|  |  |  | 	inode = mapping->host; | 
					
						
							|  |  |  | 	if (!count) | 
					
						
							|  |  |  | 		return 0; | 
					
						
							|  |  |  | 	size = i_size_read(inode); | 
					
						
							|  |  |  | 	if (offset < size) | 
					
						
							|  |  |  | 		filemap_write_and_wait_range(mapping, offset, | 
					
						
							|  |  |  | 					     offset + count - 1); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	return v9fs_file_read(filp, udata, count, offsetp); | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | /**
 | 
					
						
							|  |  |  |  * v9fs_cached_file_read - read from a file | 
					
						
							|  |  |  |  * @filp: file pointer to read | 
					
						
							| 
									
										
										
										
											2014-06-04 16:06:26 -07:00
										 |  |  |  * @data: user data buffer to read data into | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:04 +05:30
										 |  |  |  * @count: size of buffer | 
					
						
							|  |  |  |  * @offset: offset at which to read data | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | static ssize_t | 
					
						
							|  |  |  | v9fs_cached_file_read(struct file *filp, char __user *data, size_t count, | 
					
						
							|  |  |  | 		      loff_t *offset) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	if (filp->f_flags & O_DIRECT) | 
					
						
							|  |  |  | 		return v9fs_direct_read(filp, data, count, offset); | 
					
						
							| 
									
										
										
										
											2014-04-02 14:33:16 -04:00
										 |  |  | 	return new_sync_read(filp, data, count, offset); | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:04 +05:30
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2014-01-10 13:44:09 +01:00
										 |  |  | /**
 | 
					
						
							|  |  |  |  * v9fs_mmap_file_read - read from a file | 
					
						
							|  |  |  |  * @filp: file pointer to read | 
					
						
							| 
									
										
										
										
											2014-06-04 16:06:26 -07:00
										 |  |  |  * @data: user data buffer to read data into | 
					
						
							| 
									
										
										
										
											2014-01-10 13:44:09 +01:00
										 |  |  |  * @count: size of buffer | 
					
						
							|  |  |  |  * @offset: offset at which to read data | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | static ssize_t | 
					
						
							|  |  |  | v9fs_mmap_file_read(struct file *filp, char __user *data, size_t count, | 
					
						
							|  |  |  | 		      loff_t *offset) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	/* TODO: Check if there are dirty pages */ | 
					
						
							|  |  |  | 	return v9fs_file_read(filp, data, count, offset); | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:04 +05:30
										 |  |  | static ssize_t | 
					
						
							|  |  |  | v9fs_direct_write(struct file *filp, const char __user * data, | 
					
						
							|  |  |  | 		  size_t count, loff_t *offsetp) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	loff_t offset; | 
					
						
							|  |  |  | 	ssize_t retval; | 
					
						
							|  |  |  | 	struct inode *inode; | 
					
						
							|  |  |  | 	struct address_space *mapping; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	offset = *offsetp; | 
					
						
							|  |  |  | 	mapping = filp->f_mapping; | 
					
						
							|  |  |  | 	inode = mapping->host; | 
					
						
							|  |  |  | 	if (!count) | 
					
						
							|  |  |  | 		return 0; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	mutex_lock(&inode->i_mutex); | 
					
						
							|  |  |  | 	retval = filemap_write_and_wait_range(mapping, offset, | 
					
						
							|  |  |  | 					      offset + count - 1); | 
					
						
							|  |  |  | 	if (retval) | 
					
						
							|  |  |  | 		goto err_out; | 
					
						
							|  |  |  | 	/*
 | 
					
						
							|  |  |  | 	 * After a write we want buffered reads to be sure to go to disk to get | 
					
						
							|  |  |  | 	 * the new data.  We invalidate clean cached page from the region we're | 
					
						
							|  |  |  | 	 * about to write.  We do this *before* the write so that if we fail | 
					
						
							|  |  |  | 	 * here we fall back to buffered write | 
					
						
							|  |  |  | 	 */ | 
					
						
							|  |  |  | 	if (mapping->nrpages) { | 
					
						
							|  |  |  | 		pgoff_t pg_start = offset >> PAGE_CACHE_SHIFT; | 
					
						
							|  |  |  | 		pgoff_t pg_end   = (offset + count - 1) >> PAGE_CACHE_SHIFT; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		retval = invalidate_inode_pages2_range(mapping, | 
					
						
							|  |  |  | 							pg_start, pg_end); | 
					
						
							|  |  |  | 		/*
 | 
					
						
							|  |  |  | 		 * If a page can not be invalidated, fall back | 
					
						
							|  |  |  | 		 * to buffered write. | 
					
						
							|  |  |  | 		 */ | 
					
						
							|  |  |  | 		if (retval) { | 
					
						
							|  |  |  | 			if (retval == -EBUSY) | 
					
						
							|  |  |  | 				goto buff_write; | 
					
						
							|  |  |  | 			goto err_out; | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	retval = v9fs_file_write(filp, data, count, offsetp); | 
					
						
							|  |  |  | err_out: | 
					
						
							|  |  |  | 	mutex_unlock(&inode->i_mutex); | 
					
						
							|  |  |  | 	return retval; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | buff_write: | 
					
						
							|  |  |  | 	mutex_unlock(&inode->i_mutex); | 
					
						
							| 
									
										
										
										
											2014-04-03 03:17:43 -04:00
										 |  |  | 	return new_sync_write(filp, data, count, offsetp); | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:04 +05:30
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | /**
 | 
					
						
							|  |  |  |  * v9fs_cached_file_write - write to a file | 
					
						
							|  |  |  |  * @filp: file pointer to write | 
					
						
							|  |  |  |  * @data: data buffer to write data from | 
					
						
							|  |  |  |  * @count: size of buffer | 
					
						
							|  |  |  |  * @offset: offset at which to write data | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | static ssize_t | 
					
						
							|  |  |  | v9fs_cached_file_write(struct file *filp, const char __user * data, | 
					
						
							|  |  |  | 		       size_t count, loff_t *offset) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if (filp->f_flags & O_DIRECT) | 
					
						
							|  |  |  | 		return v9fs_direct_write(filp, data, count, offset); | 
					
						
							| 
									
										
										
										
											2014-04-03 03:17:43 -04:00
										 |  |  | 	return new_sync_write(filp, data, count, offset); | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:04 +05:30
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2014-01-10 13:44:09 +01:00
										 |  |  | 
 | 
					
						
							|  |  |  | /**
 | 
					
						
							|  |  |  |  * v9fs_mmap_file_write - write to a file | 
					
						
							|  |  |  |  * @filp: file pointer to write | 
					
						
							|  |  |  |  * @data: data buffer to write data from | 
					
						
							|  |  |  |  * @count: size of buffer | 
					
						
							|  |  |  |  * @offset: offset at which to write data | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | static ssize_t | 
					
						
							|  |  |  | v9fs_mmap_file_write(struct file *filp, const char __user *data, | 
					
						
							|  |  |  | 		       size_t count, loff_t *offset) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	/*
 | 
					
						
							|  |  |  | 	 * TODO: invalidate mmaps on filp's inode between | 
					
						
							|  |  |  | 	 * offset and offset+count | 
					
						
							|  |  |  | 	 */ | 
					
						
							|  |  |  | 	return v9fs_file_write(filp, data, count, offset); | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | static void v9fs_mmap_vm_close(struct vm_area_struct *vma) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	struct inode *inode; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	struct writeback_control wbc = { | 
					
						
							|  |  |  | 		.nr_to_write = LONG_MAX, | 
					
						
							|  |  |  | 		.sync_mode = WB_SYNC_ALL, | 
					
						
							|  |  |  | 		.range_start = vma->vm_pgoff * PAGE_SIZE, | 
					
						
							|  |  |  | 		 /* absolute end, byte at end included */ | 
					
						
							|  |  |  | 		.range_end = vma->vm_pgoff * PAGE_SIZE + | 
					
						
							|  |  |  | 			(vma->vm_end - vma->vm_start - 1), | 
					
						
							|  |  |  | 	}; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	p9_debug(P9_DEBUG_VFS, "9p VMA close, %p, flushing", vma); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	inode = file_inode(vma->vm_file); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if (!mapping_cap_writeback_dirty(inode->i_mapping)) | 
					
						
							|  |  |  | 		wbc.nr_to_write = 0; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	might_sleep(); | 
					
						
							|  |  |  | 	sync_inode(inode, &wbc); | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | static const struct vm_operations_struct v9fs_file_vm_ops = { | 
					
						
							|  |  |  | 	.fault = filemap_fault, | 
					
						
							| 
									
										
										
										
											2014-04-07 15:37:19 -07:00
										 |  |  | 	.map_pages = filemap_map_pages, | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | 	.page_mkwrite = v9fs_vm_page_mkwrite, | 
					
						
							| 
									
										
										
										
											2012-10-08 16:28:46 -07:00
										 |  |  | 	.remap_pages = generic_file_remap_pages, | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2014-01-10 13:44:09 +01:00
										 |  |  | static const struct vm_operations_struct v9fs_mmap_file_vm_ops = { | 
					
						
							|  |  |  | 	.close = v9fs_mmap_vm_close, | 
					
						
							|  |  |  | 	.fault = filemap_fault, | 
					
						
							| 
									
										
										
										
											2014-04-07 15:37:19 -07:00
										 |  |  | 	.map_pages = filemap_map_pages, | 
					
						
							| 
									
										
										
										
											2014-01-10 13:44:09 +01:00
										 |  |  | 	.page_mkwrite = v9fs_vm_page_mkwrite, | 
					
						
							|  |  |  | 	.remap_pages = generic_file_remap_pages, | 
					
						
							|  |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:04 +05:30
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:54 +05:30
										 |  |  | const struct file_operations v9fs_cached_file_operations = { | 
					
						
							| 
									
										
										
										
											2007-02-11 13:21:39 -06:00
										 |  |  | 	.llseek = generic_file_llseek, | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:04 +05:30
										 |  |  | 	.read = v9fs_cached_file_read, | 
					
						
							|  |  |  | 	.write = v9fs_cached_file_write, | 
					
						
							| 
									
										
										
										
											2014-04-02 14:33:16 -04:00
										 |  |  | 	.read_iter = generic_file_read_iter, | 
					
						
							| 
									
										
										
										
											2014-04-03 03:17:43 -04:00
										 |  |  | 	.write_iter = generic_file_write_iter, | 
					
						
							| 
									
										
										
										
											2007-02-11 13:21:39 -06:00
										 |  |  | 	.open = v9fs_file_open, | 
					
						
							|  |  |  | 	.release = v9fs_dir_release, | 
					
						
							|  |  |  | 	.lock = v9fs_file_lock, | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | 	.mmap = v9fs_file_mmap, | 
					
						
							| 
									
										
										
										
											2010-02-08 15:36:48 -06:00
										 |  |  | 	.fsync = v9fs_file_fsync, | 
					
						
							| 
									
										
										
										
											2007-02-11 13:21:39 -06:00
										 |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:54 +05:30
										 |  |  | const struct file_operations v9fs_cached_file_operations_dotl = { | 
					
						
							| 
									
										
										
										
											2010-09-22 16:30:52 -07:00
										 |  |  | 	.llseek = generic_file_llseek, | 
					
						
							| 
									
										
										
										
											2011-02-28 17:04:04 +05:30
										 |  |  | 	.read = v9fs_cached_file_read, | 
					
						
							|  |  |  | 	.write = v9fs_cached_file_write, | 
					
						
							| 
									
										
										
										
											2014-04-02 14:33:16 -04:00
										 |  |  | 	.read_iter = generic_file_read_iter, | 
					
						
							| 
									
										
										
										
											2014-04-03 03:17:43 -04:00
										 |  |  | 	.write_iter = generic_file_write_iter, | 
					
						
							| 
									
										
										
										
											2010-09-22 16:30:52 -07:00
										 |  |  | 	.open = v9fs_file_open, | 
					
						
							|  |  |  | 	.release = v9fs_dir_release, | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | 	.lock = v9fs_file_lock_dotl, | 
					
						
							|  |  |  | 	.flock = v9fs_file_flock_dotl, | 
					
						
							| 
									
										
										
										
											2011-02-28 17:03:58 +05:30
										 |  |  | 	.mmap = v9fs_file_mmap, | 
					
						
							| 
									
										
										
										
											2010-09-22 17:19:19 -07:00
										 |  |  | 	.fsync = v9fs_file_fsync_dotl, | 
					
						
							| 
									
										
										
										
											2010-09-22 16:30:52 -07:00
										 |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2006-03-28 01:56:42 -08:00
										 |  |  | const struct file_operations v9fs_file_operations = { | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | 	.llseek = generic_file_llseek, | 
					
						
							|  |  |  | 	.read = v9fs_file_read, | 
					
						
							|  |  |  | 	.write = v9fs_file_write, | 
					
						
							|  |  |  | 	.open = v9fs_file_open, | 
					
						
							|  |  |  | 	.release = v9fs_dir_release, | 
					
						
							|  |  |  | 	.lock = v9fs_file_lock, | 
					
						
							| 
									
										
										
										
											2008-02-06 19:25:05 -06:00
										 |  |  | 	.mmap = generic_file_readonly_mmap, | 
					
						
							| 
									
										
										
										
											2010-02-08 15:36:48 -06:00
										 |  |  | 	.fsync = v9fs_file_fsync, | 
					
						
							| 
									
										
										
										
											2005-09-09 13:04:18 -07:00
										 |  |  | }; | 
					
						
							| 
									
										
										
										
											2010-03-25 12:41:54 +00:00
										 |  |  | 
 | 
					
						
							|  |  |  | const struct file_operations v9fs_file_operations_dotl = { | 
					
						
							|  |  |  | 	.llseek = generic_file_llseek, | 
					
						
							|  |  |  | 	.read = v9fs_file_read, | 
					
						
							|  |  |  | 	.write = v9fs_file_write, | 
					
						
							|  |  |  | 	.open = v9fs_file_open, | 
					
						
							|  |  |  | 	.release = v9fs_dir_release, | 
					
						
							| 
									
										
											  
											
												9p: Implement TLOCK
Synopsis
    size[4] TLock tag[2] fid[4] flock[n]
    size[4] RLock tag[2] status[1]
Description
Tlock is used to acquire/release byte range posix locks on a file
identified by given fid. The reply contains status of the lock request
    flock structure:
        type[1] - Type of lock: F_RDLCK, F_WRLCK, F_UNLCK
        flags[4] - Flags could be either of
          P9_LOCK_FLAGS_BLOCK - Blocked lock request, if there is a
            conflicting lock exists, wait for that lock to be released.
          P9_LOCK_FLAGS_RECLAIM - Reclaim lock request, used when client is
            trying to reclaim a lock after a server restrart (due to crash)
        start[8] - Starting offset for lock
        length[8] - Number of bytes to lock
          If length is 0, lock all bytes starting at the location 'start'
          through to the end of file
        pid[4] - PID of the process that wants to take lock
        client_id[4] - Unique client id
        status[1] - Status of the lock request, can be
          P9_LOCK_SUCCESS(0), P9_LOCK_BLOCKED(1), P9_LOCK_ERROR(2) or
          P9_LOCK_GRACE(3)
          P9_LOCK_SUCCESS - Request was successful
          P9_LOCK_BLOCKED - A conflicting lock is held by another process
          P9_LOCK_ERROR - Error while processing the lock request
          P9_LOCK_GRACE - Server is in grace period, it can't accept new lock
            requests in this period (except locks with
            P9_LOCK_FLAGS_RECLAIM flag set)
Signed-off-by: M. Mohan Kumar <mohan@in.ibm.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
											
										 
											2010-09-27 11:34:24 +05:30
										 |  |  | 	.lock = v9fs_file_lock_dotl, | 
					
						
							|  |  |  | 	.flock = v9fs_file_flock_dotl, | 
					
						
							| 
									
										
										
										
											2010-03-25 12:41:54 +00:00
										 |  |  | 	.mmap = generic_file_readonly_mmap, | 
					
						
							| 
									
										
										
										
											2010-09-22 17:19:19 -07:00
										 |  |  | 	.fsync = v9fs_file_fsync_dotl, | 
					
						
							| 
									
										
										
										
											2010-03-25 12:41:54 +00:00
										 |  |  | }; | 
					
						
							| 
									
										
										
										
											2014-01-10 13:44:09 +01:00
										 |  |  | 
 | 
					
						
							|  |  |  | const struct file_operations v9fs_mmap_file_operations = { | 
					
						
							|  |  |  | 	.llseek = generic_file_llseek, | 
					
						
							|  |  |  | 	.read = v9fs_mmap_file_read, | 
					
						
							|  |  |  | 	.write = v9fs_mmap_file_write, | 
					
						
							|  |  |  | 	.open = v9fs_file_open, | 
					
						
							|  |  |  | 	.release = v9fs_dir_release, | 
					
						
							|  |  |  | 	.lock = v9fs_file_lock, | 
					
						
							|  |  |  | 	.mmap = v9fs_mmap_file_mmap, | 
					
						
							|  |  |  | 	.fsync = v9fs_file_fsync, | 
					
						
							|  |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | const struct file_operations v9fs_mmap_file_operations_dotl = { | 
					
						
							|  |  |  | 	.llseek = generic_file_llseek, | 
					
						
							|  |  |  | 	.read = v9fs_mmap_file_read, | 
					
						
							|  |  |  | 	.write = v9fs_mmap_file_write, | 
					
						
							|  |  |  | 	.open = v9fs_file_open, | 
					
						
							|  |  |  | 	.release = v9fs_dir_release, | 
					
						
							|  |  |  | 	.lock = v9fs_file_lock_dotl, | 
					
						
							|  |  |  | 	.flock = v9fs_file_flock_dotl, | 
					
						
							|  |  |  | 	.mmap = v9fs_mmap_file_mmap, | 
					
						
							|  |  |  | 	.fsync = v9fs_file_fsync_dotl, | 
					
						
							|  |  |  | }; |