Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit c6bcda6f authored by Yan, Zheng's avatar Yan, Zheng
Browse files

ceph: queue vmtruncate if necessary when handing cap grant/revoke



cap grant/revoke message from non-auth MDS can update inode's size
and truncate_seq/truncate_size. (the message arrives before auth
MDS's cap trunc message)

Signed-off-by: default avatarYan, Zheng <zheng.z.yan@intel.com>
parent 979d4c18
Loading
Loading
Loading
Loading
+16 −10
Original line number Diff line number Diff line
@@ -2418,11 +2418,12 @@ static void handle_cap_grant(struct inode *inode, struct ceph_mds_caps *grant,
	u64 max_size = le64_to_cpu(grant->max_size);
	struct timespec mtime, atime, ctime;
	int check_caps = 0;
	int wake = 0;
	int writeback = 0;
	int queue_invalidate = 0;
	int deleted_inode = 0;
	int queue_revalidate = 0;
	bool wake = 0;
	bool writeback = 0;
	bool queue_trunc = 0;
	bool queue_invalidate = 0;
	bool queue_revalidate = 0;
	bool deleted_inode = 0;

	dout("handle_cap_grant inode %p cap %p mds%d seq %d %s\n",
	     inode, cap, mds, seq, ceph_cap_string(newcaps));
@@ -2512,9 +2513,10 @@ static void handle_cap_grant(struct inode *inode, struct ceph_mds_caps *grant,
		queue_revalidate = 1;

	/* size/ctime/mtime/atime? */
	ceph_fill_file_size(inode, issued,
	queue_trunc = ceph_fill_file_size(inode, issued,
					  le32_to_cpu(grant->truncate_seq),
			    le64_to_cpu(grant->truncate_size), size);
					  le64_to_cpu(grant->truncate_size),
					  size);
	ceph_decode_timespec(&mtime, &grant->mtime);
	ceph_decode_timespec(&atime, &grant->atime);
	ceph_decode_timespec(&ctime, &grant->ctime);
@@ -2595,6 +2597,12 @@ static void handle_cap_grant(struct inode *inode, struct ceph_mds_caps *grant,

	spin_unlock(&ci->i_ceph_lock);

	if (queue_trunc) {
		ceph_queue_vmtruncate(inode);
		ceph_queue_revalidate(inode);
	} else if (queue_revalidate)
		ceph_queue_revalidate(inode);

	if (writeback)
		/*
		 * queue inode for writeback: we can't actually call
@@ -2606,8 +2614,6 @@ static void handle_cap_grant(struct inode *inode, struct ceph_mds_caps *grant,
		ceph_queue_invalidate(inode);
	if (deleted_inode)
		invalidate_aliases(inode);
	if (queue_revalidate)
		ceph_queue_revalidate(inode);
	if (wake)
		wake_up_all(&ci->i_cap_wq);