X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Fquota%2Fqsd_request.c;h=152ba905a45d0a7d1dbab6f198930cae59430897;hb=ae9d3bed51df1dfee7209ba2c2bc235504bc98d0;hp=d1cd51579efa76548790efbe811cf6ed3e464753;hpb=0754bc8f2623bea184111af216f7567608db35b6;p=fs%2Flustre-release.git

diff --git a/lustre/quota/qsd_request.c b/lustre/quota/qsd_request.c
index d1cd515..152ba90 100644
--- a/lustre/quota/qsd_request.c
+++ b/lustre/quota/qsd_request.c
@@ -21,7 +21,7 @@
  * GPL HEADER END
  */
 /*
- * Copyright (c) 2012, 2015, Intel Corporation.
+ * Copyright (c) 2012, 2016, Intel Corporation.
  * Use is subject to license terms.
  *
  * Author: Johann Lombardi <johann.lombardi@intel.com>
@@ -158,27 +158,41 @@ static int qsd_intent_interpret(const struct lu_env *env,
 {
 	struct lustre_handle	 *lockh;
 	struct quota_body	 *rep_qbody = NULL, *req_qbody;
-	struct ldlm_intent	 *lit;
 	struct qsd_async_args	 *aa = (struct qsd_async_args *)arg;
+	struct ldlm_reply	 *lockrep;
 	__u64			  flags = LDLM_FL_HAS_INTENT;
 	ENTRY;
 
 	LASSERT(aa->aa_exp);
 	lockh = &aa->aa_lockh;
 	req_qbody = req_capsule_client_get(&req->rq_pill, &RMF_QUOTA_BODY);
-	lit = req_capsule_client_get(&req->rq_pill, &RMF_LDLM_INTENT);
+	req_capsule_client_get(&req->rq_pill, &RMF_LDLM_INTENT);
 
 	rc = ldlm_cli_enqueue_fini(aa->aa_exp, req, LDLM_PLAIN, 0, LCK_CR,
 				   &flags, (void *)aa->aa_lvb,
 				   sizeof(struct lquota_lvb), lockh, rc);
-	if (rc < 0)
+	if (rc < 0) {
 		/* the lock has been destroyed, forget about the lock handle */
 		memset(lockh, 0, sizeof(*lockh));
+		/*
+		 * To avoid the server being fullfilled by LDLM locks, server
+		 * may reject the locking request by returning -EINPROGRESS,
+		 * this is different from the -EINPROGRESS returned by quota
+		 * code.
+		 */
+		if (rc == -EINPROGRESS)
+			rc = -EAGAIN;
+		GOTO(out, rc);
+	}
+
+	lockrep = req_capsule_server_get(&req->rq_pill, &RMF_DLM_REP);
+	LASSERT(lockrep != NULL);
+	rc = ptlrpc_status_ntoh(lockrep->lock_policy_res2);
 
 	if (rc == 0 || rc == -EDQUOT || rc == -EINPROGRESS)
 		rep_qbody = req_capsule_server_get(&req->rq_pill,
 						   &RMF_QUOTA_BODY);
-
+out:
 	aa->aa_completion(env, aa->aa_qqi, req_qbody, rep_qbody, lockh,
 			  aa->aa_lvb, aa->aa_arg, rc);
 	RETURN(rc);
@@ -378,15 +392,13 @@ int qsd_fetch_index(const struct lu_env *env, struct obd_export *exp,
 				    PTLRPC_BULK_PUT_SINK | PTLRPC_BULK_BUF_KIOV,
 				    MDS_BULK_PORTAL,
 				    &ptlrpc_bulk_kiov_pin_ops);
-	if (desc == NULL) {
-		ptlrpc_request_free(req);
-		RETURN(-ENOMEM);
-	}
+	if (desc == NULL)
+		GOTO(out, rc = -ENOMEM);
 
 	/* req now owns desc and will free it when it gets freed */
 	for (i = 0; i < npages; i++)
 		desc->bd_frag_ops->add_kiov_frag(desc, pages[i], 0,
-						 PAGE_CACHE_SIZE);
+						 PAGE_SIZE);
 
 	/* pack index information in request */
 	req_ii = req_capsule_client_get(&req->rq_pill, &RMF_IDX_INFO);