git.droids-corp.org / dpdk.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
common/cnxk: support priority flow control
[dpdk.git] / drivers / common / cnxk / roc_nix_fc.c
diff --git a/drivers/common/cnxk/roc_nix_fc.c b/drivers/common/cnxk/roc_nix_fc.c
index ef46842..8e31443 100644 (file)
--- a/drivers/common/cnxk/roc_nix_fc.c
+++ b/drivers/common/cnxk/roc_nix_fc.c
@@ -24,7 +24,7 @@ nix_fc_rxchan_bpid_get(struct roc_nix *roc_nix, struct roc_nix_fc_cfg *fc_cfg)
        else
                fc_cfg->rxchan_cfg.enable = false;
 
-       fc_cfg->cq_cfg_valid = false;
+       fc_cfg->type = ROC_NIX_FC_RXCHAN_CFG;
 
        return 0;
 }
@@ -36,7 +36,7 @@ nix_fc_rxchan_bpid_set(struct roc_nix *roc_nix, bool enable)
        struct mbox *mbox = get_mbox(roc_nix);
        struct nix_bp_cfg_req *req;
        struct nix_bp_cfg_rsp *rsp;
-       int rc = -ENOSPC;
+       int rc = -ENOSPC, i;
 
        if (roc_nix_is_sdp(roc_nix))
                return 0;
@@ -45,22 +45,28 @@ nix_fc_rxchan_bpid_set(struct roc_nix *roc_nix, bool enable)
                req = mbox_alloc_msg_nix_bp_enable(mbox);
                if (req == NULL)
                        return rc;
+
                req->chan_base = 0;
-               req->chan_cnt = 1;
-               req->bpid_per_chan = 0;
+               if (roc_nix_is_lbk(roc_nix))
+                       req->chan_cnt = NIX_LBK_MAX_CHAN;
+               else
+                       req->chan_cnt = NIX_CGX_MAX_CHAN;
+
+               req->bpid_per_chan = true;
 
                rc = mbox_process_msg(mbox, (void *)&rsp);
                if (rc || (req->chan_cnt != rsp->chan_cnt))
                        goto exit;
 
-               nix->bpid[0] = rsp->chan_bpid[0];
                nix->chan_cnt = rsp->chan_cnt;
+               for (i = 0; i < rsp->chan_cnt; i++)
+                       nix->bpid[i] = rsp->chan_bpid[i] & 0x1FF;
        } else {
                req = mbox_alloc_msg_nix_bp_disable(mbox);
                if (req == NULL)
                        return rc;
                req->chan_base = 0;
-               req->chan_cnt = 1;
+               req->chan_cnt = nix->chan_cnt;
 
                rc = mbox_process(mbox);
                if (rc)
@@ -70,6 +76,34 @@ nix_fc_rxchan_bpid_set(struct roc_nix *roc_nix, bool enable)
                nix->chan_cnt = 0;
        }
 
+       if (roc_model_is_cn9k())
+               goto exit;
+
+       /* Enable backpressure on CPT if inline inb is enabled */
+       if (enable && roc_nix_inl_inb_is_enabled(roc_nix)) {
+               req = mbox_alloc_msg_nix_cpt_bp_enable(mbox);
+               if (req == NULL)
+                       return rc;
+               req->chan_base = 0;
+               req->chan_cnt = 1;
+               req->bpid_per_chan = 0;
+
+               rc = mbox_process_msg(mbox, (void *)&rsp);
+               if (rc)
+                       goto exit;
+       } else {
+               req = mbox_alloc_msg_nix_cpt_bp_disable(mbox);
+               if (req == NULL)
+                       return rc;
+               req->chan_base = 0;
+               req->chan_cnt = 1;
+               req->bpid_per_chan = 0;
+
+               rc = mbox_process_msg(mbox, (void *)&rsp);
+               if (rc)
+                       goto exit;
+       }
+
 exit:
        return rc;
 }
@@ -85,6 +119,9 @@ nix_fc_cq_config_get(struct roc_nix *roc_nix, struct roc_nix_fc_cfg *fc_cfg)
                struct nix_aq_enq_req *aq;
 
                aq = mbox_alloc_msg_nix_aq_enq(mbox);
+               if (!aq)
+                       return -ENOSPC;
+
                aq->qidx = fc_cfg->cq_cfg.rq;
                aq->ctype = NIX_AQ_CTYPE_CQ;
                aq->op = NIX_AQ_INSTOP_READ;
@@ -92,6 +129,9 @@ nix_fc_cq_config_get(struct roc_nix *roc_nix, struct roc_nix_fc_cfg *fc_cfg)
                struct nix_cn10k_aq_enq_req *aq;
 
                aq = mbox_alloc_msg_nix_cn10k_aq_enq(mbox);
+               if (!aq)
+                       return -ENOSPC;
+
                aq->qidx = fc_cfg->cq_cfg.rq;
                aq->ctype = NIX_AQ_CTYPE_CQ;
                aq->op = NIX_AQ_INSTOP_READ;
@@ -103,7 +143,7 @@ nix_fc_cq_config_get(struct roc_nix *roc_nix, struct roc_nix_fc_cfg *fc_cfg)
 
        fc_cfg->cq_cfg.cq_drop = rsp->cq.bp;
        fc_cfg->cq_cfg.enable = rsp->cq.bp_ena;
-       fc_cfg->cq_cfg_valid = true;
+       fc_cfg->type = ROC_NIX_FC_CQ_CFG;
 
 exit:
        return rc;
@@ -119,12 +159,15 @@ nix_fc_cq_config_set(struct roc_nix *roc_nix, struct roc_nix_fc_cfg *fc_cfg)
                struct nix_aq_enq_req *aq;
 
                aq = mbox_alloc_msg_nix_aq_enq(mbox);
+               if (!aq)
+                       return -ENOSPC;
+
                aq->qidx = fc_cfg->cq_cfg.rq;
                aq->ctype = NIX_AQ_CTYPE_CQ;
                aq->op = NIX_AQ_INSTOP_WRITE;
 
                if (fc_cfg->cq_cfg.enable) {
-                       aq->cq.bpid = nix->bpid[0];
+                       aq->cq.bpid = nix->bpid[fc_cfg->cq_cfg.tc];
                        aq->cq_mask.bpid = ~(aq->cq_mask.bpid);
                        aq->cq.bp = fc_cfg->cq_cfg.cq_drop;
                        aq->cq_mask.bp = ~(aq->cq_mask.bp);
@@ -136,12 +179,15 @@ nix_fc_cq_config_set(struct roc_nix *roc_nix, struct roc_nix_fc_cfg *fc_cfg)
                struct nix_cn10k_aq_enq_req *aq;
 
                aq = mbox_alloc_msg_nix_cn10k_aq_enq(mbox);
+               if (!aq)
+                       return -ENOSPC;
+
                aq->qidx = fc_cfg->cq_cfg.rq;
                aq->ctype = NIX_AQ_CTYPE_CQ;
                aq->op = NIX_AQ_INSTOP_WRITE;
 
                if (fc_cfg->cq_cfg.enable) {
-                       aq->cq.bpid = nix->bpid[0];
+                       aq->cq.bpid = nix->bpid[fc_cfg->cq_cfg.tc];
                        aq->cq_mask.bpid = ~(aq->cq_mask.bpid);
                        aq->cq.bp = fc_cfg->cq_cfg.cq_drop;
                        aq->cq_mask.bp = ~(aq->cq_mask.bp);
@@ -160,10 +206,14 @@ roc_nix_fc_config_get(struct roc_nix *roc_nix, struct roc_nix_fc_cfg *fc_cfg)
        if (roc_nix_is_vf_or_sdp(roc_nix) && !roc_nix_is_lbk(roc_nix))
                return 0;
 
-       if (fc_cfg->cq_cfg_valid)
+       if (fc_cfg->type == ROC_NIX_FC_CQ_CFG)
                return nix_fc_cq_config_get(roc_nix, fc_cfg);
-       else
+       else if (fc_cfg->type == ROC_NIX_FC_RXCHAN_CFG)
                return nix_fc_rxchan_bpid_get(roc_nix, fc_cfg);
+       else if (fc_cfg->type == ROC_NIX_FC_TM_CFG)
+               return nix_tm_bp_config_get(roc_nix, &fc_cfg->tm_cfg.enable);
+
+       return -EINVAL;
 }
 
 int
@@ -172,11 +222,17 @@ roc_nix_fc_config_set(struct roc_nix *roc_nix, struct roc_nix_fc_cfg *fc_cfg)
        if (roc_nix_is_vf_or_sdp(roc_nix) && !roc_nix_is_lbk(roc_nix))
                return 0;
 
-       if (fc_cfg->cq_cfg_valid)
+       if (fc_cfg->type == ROC_NIX_FC_CQ_CFG)
                return nix_fc_cq_config_set(roc_nix, fc_cfg);
-       else
+       else if (fc_cfg->type == ROC_NIX_FC_RXCHAN_CFG)
                return nix_fc_rxchan_bpid_set(roc_nix,
                                              fc_cfg->rxchan_cfg.enable);
+       else if (fc_cfg->type == ROC_NIX_FC_TM_CFG)
+               return nix_tm_bp_config_set(roc_nix, fc_cfg->tm_cfg.sq,
+                                           fc_cfg->tm_cfg.tc,
+                                           fc_cfg->tm_cfg.enable);
+
+       return -EINVAL;
 }
 
 enum roc_nix_fc_mode
@@ -355,3 +411,74 @@ rox_nix_fc_npa_bp_cfg(struct roc_nix *roc_nix, uint64_t pool_id, uint8_t ena,
 
        mbox_process(mbox);
 }
+
+int
+roc_nix_pfc_mode_set(struct roc_nix *roc_nix, struct roc_nix_pfc_cfg *pfc_cfg)
+{
+       struct nix *nix = roc_nix_to_nix_priv(roc_nix);
+       struct mbox *mbox = get_mbox(roc_nix);
+       uint8_t tx_pause, rx_pause;
+       struct cgx_pfc_cfg *req;
+       struct cgx_pfc_rsp *rsp;
+       int rc = -ENOSPC;
+
+       if (roc_nix_is_lbk(roc_nix))
+               return NIX_ERR_OP_NOTSUP;
+
+       rx_pause = (pfc_cfg->mode == ROC_NIX_FC_FULL) ||
+                  (pfc_cfg->mode == ROC_NIX_FC_RX);
+       tx_pause = (pfc_cfg->mode == ROC_NIX_FC_FULL) ||
+                  (pfc_cfg->mode == ROC_NIX_FC_TX);
+
+       req = mbox_alloc_msg_cgx_prio_flow_ctrl_cfg(mbox);
+       if (req == NULL)
+               goto exit;
+
+       req->pfc_en = pfc_cfg->tc;
+       req->rx_pause = rx_pause;
+       req->tx_pause = tx_pause;
+
+       rc = mbox_process_msg(mbox, (void *)&rsp);
+       if (rc)
+               goto exit;
+
+       nix->rx_pause = rsp->rx_pause;
+       nix->tx_pause = rsp->tx_pause;
+       if (rsp->tx_pause)
+               nix->cev |= BIT(pfc_cfg->tc);
+       else
+               nix->cev &= ~BIT(pfc_cfg->tc);
+
+exit:
+       return rc;
+}
+
+int
+roc_nix_pfc_mode_get(struct roc_nix *roc_nix, struct roc_nix_pfc_cfg *pfc_cfg)
+{
+       struct nix *nix = roc_nix_to_nix_priv(roc_nix);
+
+       if (roc_nix_is_lbk(roc_nix))
+               return NIX_ERR_OP_NOTSUP;
+
+       pfc_cfg->tc = nix->cev;
+
+       if (nix->rx_pause && nix->tx_pause)
+               pfc_cfg->mode = ROC_NIX_FC_FULL;
+       else if (nix->rx_pause)
+               pfc_cfg->mode = ROC_NIX_FC_RX;
+       else if (nix->tx_pause)
+               pfc_cfg->mode = ROC_NIX_FC_TX;
+       else
+               pfc_cfg->mode = ROC_NIX_FC_NONE;
+
+       return 0;
+}
+
+uint16_t
+roc_nix_chan_count_get(struct roc_nix *roc_nix)
+{
+       struct nix *nix = roc_nix_to_nix_priv(roc_nix);
+
+       return nix->chan_cnt;
+}
DPDK repo used for reviews