1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright(C) 2019 Marvell International Ltd.
5 #include "otx2_evdev.h"
8 otx2_sso_rx_adapter_caps_get(const struct rte_eventdev *event_dev,
9 const struct rte_eth_dev *eth_dev, uint32_t *caps)
13 RTE_SET_USED(event_dev);
14 rc = strncmp(eth_dev->device->driver->name, "net_octeontx2", 13);
16 *caps = RTE_EVENT_ETH_RX_ADAPTER_SW_CAP;
18 *caps = RTE_EVENT_ETH_RX_ADAPTER_CAP_INTERNAL_PORT;
24 sso_rxq_enable(struct otx2_eth_dev *dev, uint16_t qid, uint8_t tt, uint8_t ggrp,
27 struct otx2_mbox *mbox = dev->mbox;
28 struct nix_aq_enq_req *aq;
31 aq = otx2_mbox_alloc_msg_nix_aq_enq(mbox);
33 aq->ctype = NIX_AQ_CTYPE_CQ;
34 aq->op = NIX_AQ_INSTOP_WRITE;
39 otx2_mbox_memset(&aq->cq_mask, 0, sizeof(struct nix_cq_ctx_s));
40 aq->cq_mask.ena = ~(aq->cq_mask.ena);
41 aq->cq_mask.caching = ~(aq->cq_mask.caching);
43 rc = otx2_mbox_process(mbox);
45 otx2_err("Failed to disable cq context");
49 aq = otx2_mbox_alloc_msg_nix_aq_enq(mbox);
51 aq->ctype = NIX_AQ_CTYPE_RQ;
52 aq->op = NIX_AQ_INSTOP_WRITE;
56 aq->rq.sso_grp = ggrp;
58 /* Mbuf Header generation :
59 * > FIRST_SKIP is a super set of WQE_SKIP, dont modify first skip as
60 * it already has data related to mbuf size, headroom, private area.
61 * > Using WQE_SKIP we can directly assign
62 * mbuf = wqe - sizeof(struct mbuf);
63 * so that mbuf header will not have unpredicted values while headroom
64 * and private data starts at the beginning of wqe_data.
67 aq->rq.wqe_caching = 1;
69 aq->rq.flow_tagw = 20; /* 20-bits */
71 /* Flow Tag calculation :
73 * rq_tag <31:24> = good/bad_tag<8:0>;
74 * rq_tag <23:0> = [ltag]
76 * flow_tag_mask<31:0> = (1 << flow_tagw) - 1; <31:20>
77 * tag<31:0> = (~flow_tag_mask & rq_tag) | (flow_tag_mask & flow_tag);
80 * ltag<23:0> = (eth_port_id & 0xF) << 20;
82 * ((eth_port_id >> 4) & 0xF) | (RTE_EVENT_TYPE_ETHDEV << 4);
84 * TAG<31:0> on getwork = <31:28>(RTE_EVENT_TYPE_ETHDEV) |
85 * <27:20> (eth_port_id) | <20:0> [TAG]
88 aq->rq.ltag = (eth_port_id & 0xF) << 20;
89 aq->rq.good_utag = ((eth_port_id >> 4) & 0xF) |
90 (RTE_EVENT_TYPE_ETHDEV << 4);
91 aq->rq.bad_utag = aq->rq.good_utag;
93 aq->rq.ena = 0; /* Don't enable RQ yet */
94 aq->rq.pb_caching = 0x2; /* First cache aligned block to LLC */
95 aq->rq.xqe_imm_size = 0; /* No pkt data copy to CQE */
97 otx2_mbox_memset(&aq->rq_mask, 0, sizeof(struct nix_rq_ctx_s));
98 /* mask the bits to write. */
99 aq->rq_mask.sso_ena = ~(aq->rq_mask.sso_ena);
100 aq->rq_mask.sso_tt = ~(aq->rq_mask.sso_tt);
101 aq->rq_mask.sso_grp = ~(aq->rq_mask.sso_grp);
102 aq->rq_mask.ena_wqwd = ~(aq->rq_mask.ena_wqwd);
103 aq->rq_mask.wqe_skip = ~(aq->rq_mask.wqe_skip);
104 aq->rq_mask.wqe_caching = ~(aq->rq_mask.wqe_caching);
105 aq->rq_mask.spb_ena = ~(aq->rq_mask.spb_ena);
106 aq->rq_mask.flow_tagw = ~(aq->rq_mask.flow_tagw);
107 aq->rq_mask.ltag = ~(aq->rq_mask.ltag);
108 aq->rq_mask.good_utag = ~(aq->rq_mask.good_utag);
109 aq->rq_mask.bad_utag = ~(aq->rq_mask.bad_utag);
110 aq->rq_mask.ena = ~(aq->rq_mask.ena);
111 aq->rq_mask.pb_caching = ~(aq->rq_mask.pb_caching);
112 aq->rq_mask.xqe_imm_size = ~(aq->rq_mask.xqe_imm_size);
114 rc = otx2_mbox_process(mbox);
116 otx2_err("Failed to init rx adapter context");
126 sso_rxq_disable(struct otx2_eth_dev *dev, uint16_t qid)
128 struct otx2_mbox *mbox = dev->mbox;
129 struct nix_aq_enq_req *aq;
132 aq = otx2_mbox_alloc_msg_nix_aq_enq(mbox);
134 aq->ctype = NIX_AQ_CTYPE_CQ;
135 aq->op = NIX_AQ_INSTOP_INIT;
140 otx2_mbox_memset(&aq->cq_mask, 0, sizeof(struct nix_cq_ctx_s));
141 aq->cq_mask.ena = ~(aq->cq_mask.ena);
142 aq->cq_mask.caching = ~(aq->cq_mask.caching);
144 rc = otx2_mbox_process(mbox);
146 otx2_err("Failed to init cq context");
150 aq = otx2_mbox_alloc_msg_nix_aq_enq(mbox);
152 aq->ctype = NIX_AQ_CTYPE_RQ;
153 aq->op = NIX_AQ_INSTOP_WRITE;
156 aq->rq.sso_tt = SSO_TT_UNTAGGED;
159 aq->rq.wqe_caching = 0;
162 aq->rq.flow_tagw = 0x20;
164 aq->rq.good_utag = 0;
167 aq->rq.pb_caching = 0x2; /* First cache aligned block to LLC */
168 aq->rq.xqe_imm_size = 0; /* No pkt data copy to CQE */
170 otx2_mbox_memset(&aq->rq_mask, 0, sizeof(struct nix_rq_ctx_s));
171 /* mask the bits to write. */
172 aq->rq_mask.sso_ena = ~(aq->rq_mask.sso_ena);
173 aq->rq_mask.sso_tt = ~(aq->rq_mask.sso_tt);
174 aq->rq_mask.sso_grp = ~(aq->rq_mask.sso_grp);
175 aq->rq_mask.ena_wqwd = ~(aq->rq_mask.ena_wqwd);
176 aq->rq_mask.wqe_caching = ~(aq->rq_mask.wqe_caching);
177 aq->rq_mask.wqe_skip = ~(aq->rq_mask.wqe_skip);
178 aq->rq_mask.spb_ena = ~(aq->rq_mask.spb_ena);
179 aq->rq_mask.flow_tagw = ~(aq->rq_mask.flow_tagw);
180 aq->rq_mask.ltag = ~(aq->rq_mask.ltag);
181 aq->rq_mask.good_utag = ~(aq->rq_mask.good_utag);
182 aq->rq_mask.bad_utag = ~(aq->rq_mask.bad_utag);
183 aq->rq_mask.ena = ~(aq->rq_mask.ena);
184 aq->rq_mask.pb_caching = ~(aq->rq_mask.pb_caching);
185 aq->rq_mask.xqe_imm_size = ~(aq->rq_mask.xqe_imm_size);
187 rc = otx2_mbox_process(mbox);
189 otx2_err("Failed to clear rx adapter context");
199 sso_updt_xae_cnt(struct otx2_sso_evdev *dev, void *data, uint32_t event_type)
201 switch (event_type) {
202 case RTE_EVENT_TYPE_TIMER:
204 dev->adptr_xae_cnt += (*(uint64_t *)data);
213 otx2_sso_rx_adapter_queue_add(const struct rte_eventdev *event_dev,
214 const struct rte_eth_dev *eth_dev,
216 const struct rte_event_eth_rx_adapter_queue_conf *queue_conf)
218 struct otx2_eth_dev *otx2_eth_dev = eth_dev->data->dev_private;
219 uint16_t port = eth_dev->data->port_id;
222 RTE_SET_USED(event_dev);
223 rc = strncmp(eth_dev->device->driver->name, "net_octeontx2", 13);
227 if (rx_queue_id < 0) {
228 for (i = 0 ; i < eth_dev->data->nb_rx_queues; i++) {
229 rc |= sso_rxq_enable(otx2_eth_dev, i,
230 queue_conf->ev.sched_type,
231 queue_conf->ev.queue_id, port);
234 rc |= sso_rxq_enable(otx2_eth_dev, (uint16_t)rx_queue_id,
235 queue_conf->ev.sched_type,
236 queue_conf->ev.queue_id, port);
240 otx2_err("Failed to configure Rx adapter port=%d, q=%d", port,
241 queue_conf->ev.queue_id);
249 otx2_sso_rx_adapter_queue_del(const struct rte_eventdev *event_dev,
250 const struct rte_eth_dev *eth_dev,
253 struct otx2_eth_dev *dev = eth_dev->data->dev_private;
256 RTE_SET_USED(event_dev);
257 rc = strncmp(eth_dev->device->driver->name, "net_octeontx2", 13);
261 if (rx_queue_id < 0) {
262 for (i = 0 ; i < eth_dev->data->nb_rx_queues; i++)
263 rc = sso_rxq_disable(dev, i);
265 rc = sso_rxq_disable(dev, (uint16_t)rx_queue_id);
269 otx2_err("Failed to clear Rx adapter config port=%d, q=%d",
270 eth_dev->data->port_id, rx_queue_id);