libxscale: Add support for posting verbs

This patch adds support for post_send and post_recv routines.

Signed-off-by: Tian Xin <[email protected]>
Signed-off-by: Wei Honggang <[email protected]>
Signed-off-by: Zhao Qianwei <[email protected]>
Signed-off-by: Li Qiang <[email protected]>
Signed-off-by: Yan Lei <[email protected]>

Author: tianx666

providers/xscale/cq.c

@@ -112,11 +112,6 @@ static void *get_sw_cqe(struct xsc_cq *cq, int n)
 		return NULL;
 }
 
-void *xsc_get_send_wqe(struct xsc_qp *qp, int n)
-{
-	return qp->sq_start + (n << qp->sq.wqe_shift);
-}
-
 static void update_cons_index(struct xsc_cq *cq)
 {
 	struct xsc_context *ctx =
@@ -520,38 +515,11 @@ int xsc_free_cq_buf(struct xsc_context *ctx, struct xsc_buf *buf)
 	return xsc_free_actual_buf(ctx, buf);
 }
 
-static int is_equal_rsn(struct xsc_cqe64 *cqe64, uint32_t rsn)
-{
-	return rsn == (be32toh(cqe64->sop_drop_qpn) & 0xffffff);
-}
-
-static inline int is_equal_uidx(struct xsc_cqe64 *cqe64, uint32_t uidx)
-{
-	return uidx == (be32toh(cqe64->srqn_uidx) & 0xffffff);
-}
-
-static inline int free_res_cqe(struct xsc_cqe64 *cqe64, uint32_t rsn,
-			       int cqe_version)
-{
-	if (cqe_version) {
-		if (is_equal_uidx(cqe64, rsn))
-			return 1;
-	} else {
-		if (is_equal_rsn(cqe64, rsn))
-			return 1;
-	}
-
-	return 0;
-}
-
-void __xsc_cq_clean(struct xsc_cq *cq, u32 rsn)
+void __xsc_cq_clean(struct xsc_cq *cq, u32 qpn)
 {
 	u32 prod_index;
 	int nfreed = 0;
-	struct xsc_cqe64 *cqe64, *dest64;
 	void *cqe, *dest;
-	u8 owner_bit;
-	int cqe_version;
 
 	if (!cq || cq->flags & XSC_CQ_FLAGS_DV_OWNED)
 		return;
@@ -573,21 +541,20 @@ void __xsc_cq_clean(struct xsc_cq *cq, u32 rsn)
 	 * Now sweep backwards through the CQ, removing CQ entries
 	 * that match our QP by copying older entries on top of them.
 	 */
-	cqe_version = (to_xctx(cq->verbs_cq.cq_ex.context))->cqe_version;
 	while ((int)(--prod_index) - (int)cq->cons_index >= 0) {
+		u16 qp_id_combined;
+		u32 qp_id;
+
 		cqe = get_cqe(cq, prod_index & (cq->verbs_cq.cq_ex.cqe - 1));
-		cqe64 = (cq->cqe_sz == 64) ? cqe : cqe + 64;
-		if (free_res_cqe(cqe64, rsn, cqe_version)) {
+		qp_id_combined = __le16_to_cpu(*(u16 *)((void *)cqe + 1));
+		qp_id = qp_id_combined & 0x7fff;
+		if (qpn == qp_id) {
 			++nfreed;
 		} else if (nfreed) {
 			dest = get_cqe(cq,
 				       (prod_index + nfreed) &
 					       (cq->verbs_cq.cq_ex.cqe - 1));
-			dest64 = (cq->cqe_sz == 64) ? dest : dest + 64;
-			owner_bit = dest64->op_own & XSC_CQE_OWNER_MASK;
 			memcpy(dest, cqe, cq->cqe_sz);
-			dest64->op_own = owner_bit |
-					 (dest64->op_own & ~XSC_CQE_OWNER_MASK);
 		}
 	}