Unverified Commit 95b978e1 authored by openeuler-ci-bot's avatar openeuler-ci-bot Committed by Gitee
Browse files

!12461 NFSD: Limit the number of concurrent async COPY operations 

Merge Pull Request from: @ci-robot 
 
PR sync from: Li Lingfeng <lilingfeng3@huawei.com>
https://mailweb.openeuler.org/hyperkitty/list/kernel@openeuler.org/message/BBGZ6L2GT3VA5M4OCM5AUDLU62TKVO6A/ 
 
https://gitee.com/src-openeuler/kernel/issues/IAYR9C 
 
Link:https://gitee.com/openeuler/kernel/pulls/12461

 

Reviewed-by: default avatarZhang Peng <zhangpeng362@huawei.com>
Signed-off-by: default avatarZhang Peng <zhangpeng362@huawei.com>
parents f24a5c8c 0d27eb5c

fs/nfsd/netns.h

+1 −0
Original line number Diff line number Diff line
@@ -153,6 +153,7 @@ struct nfsd_net { 
	u32		s2s_cp_cl_id;

	struct idr	s2s_cp_stateids;

	spinlock_t	s2s_cp_lock;

	atomic_t	pending_async_copies;



	/*

	 * Version information

fs/nfsd/nfs4proc.c

+9 −2
Original line number Diff line number Diff line
@@ -1282,6 +1282,7 @@ static void nfs4_put_copy(struct nfsd4_copy *copy) 
{

	if (!refcount_dec_and_test(&copy->refcount))

		return;

	atomic_dec(&copy->cp_nn->pending_async_copies);

	kfree(copy->cp_src);

	kfree(copy);

}
@@ -1818,10 +1819,16 @@ nfsd4_copy(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate, 
	if (nfsd4_copy_is_async(copy)) {

		struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id);



		status = nfserrno(-ENOMEM);

		async_copy = kzalloc(sizeof(struct nfsd4_copy), GFP_KERNEL);

		if (!async_copy)

			goto out_err;

		async_copy->cp_nn = nn;

		/* Arbitrary cap on number of pending async copy operations */

		if (atomic_inc_return(&nn->pending_async_copies) >

			(int)rqstp->rq_pool->sp_nrthreads) {

			atomic_dec(&nn->pending_async_copies);

			goto out_err;

		}

		INIT_LIST_HEAD(&async_copy->copies);

		refcount_set(&async_copy->refcount, 1);

		async_copy->cp_src = kmalloc(sizeof(*async_copy->cp_src), GFP_KERNEL);
@@ -1860,7 +1867,7 @@ nfsd4_copy(struct svc_rqst *rqstp, struct nfsd4_compound_state *cstate, 
	}

	if (async_copy)

		cleanup_async_copy(async_copy);

	status = nfserrno(-ENOMEM);

	status = nfserr_jukebox;

	goto out;

}

fs/nfsd/nfs4state.c

+1 −0
Original line number Diff line number Diff line
@@ -8141,6 +8141,7 @@ static int nfs4_state_create_net(struct net *net) 
	spin_lock_init(&nn->client_lock);

	spin_lock_init(&nn->s2s_cp_lock);

	idr_init(&nn->s2s_cp_stateids);

	atomic_set(&nn->pending_async_copies, 0);



	spin_lock_init(&nn->blocked_locks_lock);

	INIT_LIST_HEAD(&nn->blocked_locks_lru);

fs/nfsd/xdr4.h

+1 −0
Original line number Diff line number Diff line
@@ -574,6 +574,7 @@ struct nfsd4_copy { 
	struct nfsd4_ssc_umount_item *ss_nsui;

	struct nfs_fh		c_fh;

	nfs4_stateid		stateid;

	struct nfsd_net		*cp_nn;

};



static inline void nfsd4_copy_set_sync(struct nfsd4_copy *copy, bool sync)