Commit 5e3ded1b authored by Yan, Zheng's avatar Yan, Zheng Committed by Ilya Dryomov
Browse files

ceph: pass filp to ceph_get_caps() 



Also change several other functions' arguments, no logical changes.
This is preparetion for later patch that checks filp error.

Signed-off-by: default avatar"Yan, Zheng" <zyan@redhat.com>
Reviewed-by: default avatarJeff Layton <jlayton@kernel.org>
Signed-off-by: default avatarIlya Dryomov <idryomov@gmail.com>
parent f4b97866

fs/ceph/addr.c

+9 −6
Original line number Diff line number Diff line
@@ -323,7 +323,8 @@ static int start_read(struct inode *inode, struct ceph_rw_context *rw_ctx, 
		/* caller of readpages does not hold buffer and read caps

		 * (fadvise, madvise and readahead cases) */

		int want = CEPH_CAP_FILE_CACHE;

		ret = ceph_try_get_caps(ci, CEPH_CAP_FILE_RD, want, true, &got);

		ret = ceph_try_get_caps(inode, CEPH_CAP_FILE_RD, want,

					true, &got);

		if (ret < 0) {

			dout("start_read %p, error getting cap\n", inode);

		} else if (!(got & want)) {
@@ -1452,7 +1453,8 @@ static vm_fault_t ceph_filemap_fault(struct vm_fault *vmf) 
		want = CEPH_CAP_FILE_CACHE;



	got = 0;

	err = ceph_get_caps(ci, CEPH_CAP_FILE_RD, want, -1, &got, &pinned_page);

	err = ceph_get_caps(vma->vm_file, CEPH_CAP_FILE_RD, want, -1,

			    &got, &pinned_page);

	if (err < 0)

		goto out_restore;
@@ -1568,7 +1570,7 @@ static vm_fault_t ceph_page_mkwrite(struct vm_fault *vmf) 
		want = CEPH_CAP_FILE_BUFFER;



	got = 0;

	err = ceph_get_caps(ci, CEPH_CAP_FILE_WR, want, off + len,

	err = ceph_get_caps(vma->vm_file, CEPH_CAP_FILE_WR, want, off + len,

			    &got, NULL);

	if (err < 0)

		goto out_free;
@@ -1989,10 +1991,11 @@ out: 
	return err;

}



int ceph_pool_perm_check(struct ceph_inode_info *ci, int need)

int ceph_pool_perm_check(struct inode *inode, int need)

{

	s64 pool;

	struct ceph_inode_info *ci = ceph_inode(inode);

	struct ceph_string *pool_ns;

	s64 pool;

	int ret, flags;



	if (ci->i_vino.snap != CEPH_NOSNAP) {
@@ -2004,7 +2007,7 @@ int ceph_pool_perm_check(struct ceph_inode_info *ci, int need) 
		return 0;

	}



	if (ceph_test_mount_opt(ceph_inode_to_client(&ci->vfs_inode),

	if (ceph_test_mount_opt(ceph_inode_to_client(inode),

				NOPOOLPERM))

		return 0;

fs/ceph/caps.c

+17 −15
Original line number Diff line number Diff line
@@ -2570,10 +2570,10 @@ static void __take_cap_refs(struct ceph_inode_info *ci, int got, 
 *

 * FIXME: how does a 0 return differ from -EAGAIN?

 */

static int try_get_cap_refs(struct ceph_inode_info *ci, int need, int want,

static int try_get_cap_refs(struct inode *inode, int need, int want,

			    loff_t endoff, bool nonblock, int *got)

{

	struct inode *inode = &ci->vfs_inode;

	struct ceph_inode_info *ci = ceph_inode(inode);

	struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc;

	int ret = 0;

	int have, implemented;
@@ -2741,18 +2741,18 @@ static void check_max_size(struct inode *inode, loff_t endoff) 
		ceph_check_caps(ci, CHECK_CAPS_AUTHONLY, NULL);

}



int ceph_try_get_caps(struct ceph_inode_info *ci, int need, int want,

int ceph_try_get_caps(struct inode *inode, int need, int want,

		      bool nonblock, int *got)

{

	int ret;



	BUG_ON(need & ~CEPH_CAP_FILE_RD);

	BUG_ON(want & ~(CEPH_CAP_FILE_CACHE|CEPH_CAP_FILE_LAZYIO|CEPH_CAP_FILE_SHARED));

	ret = ceph_pool_perm_check(ci, need);

	ret = ceph_pool_perm_check(inode, need);

	if (ret < 0)

		return ret;



	ret = try_get_cap_refs(ci, need, want, 0, nonblock, got);

	ret = try_get_cap_refs(inode, need, want, 0, nonblock, got);

	return ret == -EAGAIN ? 0 : ret;

}
@@ -2761,21 +2761,23 @@ int ceph_try_get_caps(struct ceph_inode_info *ci, int need, int want, 
 * due to a small max_size, make sure we check_max_size (and possibly

 * ask the mds) so we don't get hung up indefinitely.

 */

int ceph_get_caps(struct ceph_inode_info *ci, int need, int want,

int ceph_get_caps(struct file *filp, int need, int want,

		  loff_t endoff, int *got, struct page **pinned_page)

{

	struct inode *inode = file_inode(filp);

	struct ceph_inode_info *ci = ceph_inode(inode);

	int _got, ret;



	ret = ceph_pool_perm_check(ci, need);

	ret = ceph_pool_perm_check(inode, need);

	if (ret < 0)

		return ret;



	while (true) {

		if (endoff > 0)

			check_max_size(&ci->vfs_inode, endoff);

			check_max_size(inode, endoff);



		_got = 0;

		ret = try_get_cap_refs(ci, need, want, endoff,

		ret = try_get_cap_refs(inode, need, want, endoff,

				       false, &_got);

		if (ret == -EAGAIN)

			continue;
@@ -2783,8 +2785,8 @@ int ceph_get_caps(struct ceph_inode_info *ci, int need, int want, 
			DEFINE_WAIT_FUNC(wait, woken_wake_function);

			add_wait_queue(&ci->i_cap_wq, &wait);



			while (!(ret = try_get_cap_refs(ci, need, want, endoff,

							true, &_got))) {

			while (!(ret = try_get_cap_refs(inode, need, want,

							endoff, true, &_got))) {

				if (signal_pending(current)) {

					ret = -ERESTARTSYS;

					break;
@@ -2799,7 +2801,7 @@ int ceph_get_caps(struct ceph_inode_info *ci, int need, int want, 
		if (ret < 0) {

			if (ret == -ESTALE) {

				/* session was killed, try renew caps */

				ret = ceph_renew_caps(&ci->vfs_inode);

				ret = ceph_renew_caps(inode);

				if (ret == 0)

					continue;

			}
@@ -2808,9 +2810,9 @@ int ceph_get_caps(struct ceph_inode_info *ci, int need, int want, 


		if (ci->i_inline_version != CEPH_INLINE_NONE &&

		    (_got & (CEPH_CAP_FILE_CACHE|CEPH_CAP_FILE_LAZYIO)) &&

		    i_size_read(&ci->vfs_inode) > 0) {

		    i_size_read(inode) > 0) {

			struct page *page =

				find_get_page(ci->vfs_inode.i_mapping, 0);

				find_get_page(inode->i_mapping, 0);

			if (page) {

				if (PageUptodate(page)) {

					*pinned_page = page;
@@ -2829,7 +2831,7 @@ int ceph_get_caps(struct ceph_inode_info *ci, int need, int want, 
			 * getattr request will bring inline data into

			 * page cache

			 */

			ret = __ceph_do_getattr(&ci->vfs_inode, NULL,

			ret = __ceph_do_getattr(inode, NULL,

						CEPH_STAT_CAP_INLINE_DATA,

						true);

			if (ret < 0)

fs/ceph/file.c

+17 −18
Original line number Diff line number Diff line
@@ -1262,7 +1262,8 @@ again: 
		want = CEPH_CAP_FILE_CACHE | CEPH_CAP_FILE_LAZYIO;

	else

		want = CEPH_CAP_FILE_CACHE;

	ret = ceph_get_caps(ci, CEPH_CAP_FILE_RD, want, -1, &got, &pinned_page);

	ret = ceph_get_caps(filp, CEPH_CAP_FILE_RD, want, -1,

			    &got, &pinned_page);

	if (ret < 0)

		return ret;
@@ -1459,7 +1460,7 @@ retry_snap: 
	else

		want = CEPH_CAP_FILE_BUFFER;

	got = 0;

	err = ceph_get_caps(ci, CEPH_CAP_FILE_WR, want, pos + count,

	err = ceph_get_caps(file, CEPH_CAP_FILE_WR, want, pos + count,

			    &got, NULL);

	if (err < 0)

		goto out;
@@ -1783,7 +1784,7 @@ static long ceph_fallocate(struct file *file, int mode, 
	else

		want = CEPH_CAP_FILE_BUFFER;



	ret = ceph_get_caps(ci, CEPH_CAP_FILE_WR, want, endoff, &got, NULL);

	ret = ceph_get_caps(file, CEPH_CAP_FILE_WR, want, endoff, &got, NULL);

	if (ret < 0)

		goto unlock;
@@ -1812,16 +1813,15 @@ unlock: 
 * src_ci.  Two attempts are made to obtain both caps, and an error is return if

 * this fails; zero is returned on success.

 */

static int get_rd_wr_caps(struct ceph_inode_info *src_ci,

			  loff_t src_endoff, int *src_got,

			  struct ceph_inode_info *dst_ci,

static int get_rd_wr_caps(struct file *src_filp, int *src_got,

			  struct file *dst_filp,

			  loff_t dst_endoff, int *dst_got)

{

	int ret = 0;

	bool retrying = false;



retry_caps:

	ret = ceph_get_caps(dst_ci, CEPH_CAP_FILE_WR, CEPH_CAP_FILE_BUFFER,

	ret = ceph_get_caps(dst_filp, CEPH_CAP_FILE_WR, CEPH_CAP_FILE_BUFFER,

			    dst_endoff, dst_got, NULL);

	if (ret < 0)

		return ret;
@@ -1831,24 +1831,24 @@ retry_caps: 
	 * we would risk a deadlock by using ceph_get_caps.  Thus, we'll do some

	 * retry dance instead to try to get both capabilities.

	 */

	ret = ceph_try_get_caps(src_ci, CEPH_CAP_FILE_RD, CEPH_CAP_FILE_SHARED,

	ret = ceph_try_get_caps(file_inode(src_filp),

				CEPH_CAP_FILE_RD, CEPH_CAP_FILE_SHARED,

				false, src_got);

	if (ret <= 0) {

		/* Start by dropping dst_ci caps and getting src_ci caps */

		ceph_put_cap_refs(dst_ci, *dst_got);

		ceph_put_cap_refs(ceph_inode(file_inode(dst_filp)), *dst_got);

		if (retrying) {

			if (!ret)

				/* ceph_try_get_caps masks EAGAIN */

				ret = -EAGAIN;

			return ret;

		}

		ret = ceph_get_caps(src_ci, CEPH_CAP_FILE_RD,

				    CEPH_CAP_FILE_SHARED, src_endoff,

				    src_got, NULL);

		ret = ceph_get_caps(src_filp, CEPH_CAP_FILE_RD,

				    CEPH_CAP_FILE_SHARED, -1, src_got, NULL);

		if (ret < 0)

			return ret;

		/*... drop src_ci caps too, and retry */

		ceph_put_cap_refs(src_ci, *src_got);

		ceph_put_cap_refs(ceph_inode(file_inode(src_filp)), *src_got);

		retrying = true;

		goto retry_caps;

	}
@@ -1960,8 +1960,8 @@ static ssize_t __ceph_copy_file_range(struct file *src_file, loff_t src_off, 
	 * clients may have dirty data in their caches.  And OSDs know nothing

	 * about caps, so they can't safely do the remote object copies.

	 */

	err = get_rd_wr_caps(src_ci, (src_off + len), &src_got,

			     dst_ci, (dst_off + len), &dst_got);

	err = get_rd_wr_caps(src_file, &src_got,

			     dst_file, (dst_off + len), &dst_got);

	if (err < 0) {

		dout("get_rd_wr_caps returned %d\n", err);

		ret = -EOPNOTSUPP;
@@ -2018,9 +2018,8 @@ static ssize_t __ceph_copy_file_range(struct file *src_file, loff_t src_off, 
			goto out;

		}

		len -= ret;

		err = get_rd_wr_caps(src_ci, (src_off + len),

				     &src_got, dst_ci,

				     (dst_off + len), &dst_got);

		err = get_rd_wr_caps(src_file, &src_got,

				     dst_file, (dst_off + len), &dst_got);

		if (err < 0)

			goto out;

		err = is_file_size_ok(src_inode, dst_inode,

fs/ceph/super.h

+3 −3
Original line number Diff line number Diff line
@@ -1062,9 +1062,9 @@ extern int ceph_encode_dentry_release(void **p, struct dentry *dn, 
				      struct inode *dir,

				      int mds, int drop, int unless);



extern int ceph_get_caps(struct ceph_inode_info *ci, int need, int want,

extern int ceph_get_caps(struct file *filp, int need, int want,

			 loff_t endoff, int *got, struct page **pinned_page);

extern int ceph_try_get_caps(struct ceph_inode_info *ci,

extern int ceph_try_get_caps(struct inode *inode,

			     int need, int want, bool nonblock, int *got);



/* for counting open files by mode */
@@ -1075,7 +1075,7 @@ extern void ceph_put_fmode(struct ceph_inode_info *ci, int mode); 
extern const struct address_space_operations ceph_aops;

extern int ceph_mmap(struct file *file, struct vm_area_struct *vma);

extern int ceph_uninline_data(struct file *filp, struct page *locked_page);

extern int ceph_pool_perm_check(struct ceph_inode_info *ci, int need);

extern int ceph_pool_perm_check(struct inode *inode, int need);

extern void ceph_pool_perm_destroy(struct ceph_mds_client* mdsc);



/* file.c */

CRA Git | Maintained and supported by SUSTech CRA and CCSE