1 /******************************************************************************
3 * Copyright (c) 2020 Intel.
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at
9 * http://www.apache.org/licenses/LICENSE-2.0
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
17 *******************************************************************************/
20 * @brief This file has all definitions for the Ethernet Data Interface Layer
22 * @ingroup group_lte_source_auxlib
23 * @author Intel Corporation
36 #include <rte_config.h>
39 #include <rte_timer.h>
41 /* comment this to enable PDUMP
42 * DPDK has to be compiled with
43 * CONFIG_RTE_LIBRTE_PMD_PCAP=y
44 * CONFIG_RTE_LIBRTE_PDUMP=y
46 #undef RTE_LIBRTE_PDUMP
48 #ifdef RTE_LIBRTE_PDUMP
49 #include <rte_pdump.h>
53 #include "xran_transport.h"
54 #include "xran_fh_o_du.h"
56 #define XRAN_THREAD_DEFAULT_PRIO (98)
57 #define XRAN_MAX_WORKERS 6 /**< max number of worker cores */
59 #define TX_TIMER_INTERVAL ((rte_get_timer_hz() / 1000000000L)*interval_us*1000) /* nanosec */
60 #define TX_RX_LOOP_TIME (rte_get_timer_hz() / 1)
62 typedef uint8_t lcoreid_t;
63 typedef uint16_t portid_t;
64 typedef uint16_t queueid_t;
65 typedef uint16_t streamid_t;
67 /* CAUTION: Keep in sync with the string table below. */
75 static char *const entity_names[] = {
80 typedef int (*PROCESS_CB)(void * arg);
82 extern queueid_t nb_rxq; /**< Number of RX queues per port. */
83 extern queueid_t nb_txq; /**< Number of TX queues per port. */
86 * Structure storing internal configuration of workers
88 struct xran_worker_config {
94 struct xran_ethdi_ctx {
95 struct xran_io_cfg io_cfg;
96 struct rte_ether_addr entities[XRAN_VF_MAX][ID_MAX];
97 uint16_t vf2xran_port[XRAN_VF_MAX];
98 uint16_t vf_and_q2pc_id[XRAN_VF_MAX][XRAN_VF_QUEUE_MAX];
99 struct xran_eaxc_info vf_and_q2cid[XRAN_VF_MAX][XRAN_VF_QUEUE_MAX];
100 uint16_t rxq_per_port[XRAN_VF_MAX];
102 struct rte_ring *tx_ring[XRAN_VF_MAX];
103 struct rte_ring *rx_ring[XRAN_VF_MAX][XRAN_VF_QUEUE_MAX];
105 struct rte_ring *up_dl_pkt_gen_ring[XRAN_PORTS_NUM];
107 struct xran_worker_config time_wrk_cfg; /**< core doing polling of time */
108 struct xran_worker_config pkt_wrk_cfg[RTE_MAX_LCORE]; /**< worker cores */
110 phy_encoder_poll_fn bbdev_enc; /**< call back to poll BBDev encoder */
111 phy_decoder_poll_fn bbdev_dec; /**< call back to poll BBDev decoder */
113 uint32_t pkt_proc_core_id; /**< core used for processing DPDK timer cb */
114 uint32_t num_workers; /**< number of workers */
115 uint32_t worker_core[XRAN_MAX_WORKERS]; /**< id of core used as worker */
117 uint64_t rx_vf_queue_cnt[XRAN_VF_MAX][XRAN_VF_QUEUE_MAX];
120 enum xran_mbuf_mem_op_id {
125 extern enum xran_if_state xran_if_current_state;
127 static inline struct xran_ethdi_ctx *xran_ethdi_get_ctx(void)
129 extern struct xran_ethdi_ctx g_ethdi_ctx;
132 typedef int (*xran_ethdi_handler)(struct rte_mbuf *, int sender, uint16_t vf_id);
134 typedef int (*ethertype_handler)(struct rte_mbuf* pkt_q[], uint16_t xport_id, struct xran_eaxc_info *p_cid, uint16_t num);
137 int32_t xran_register_ethertype_handler(uint16_t ethertype, ethertype_handler callback);
138 int32_t xran_ethdi_init_dpdk_io(char *name, const struct xran_io_cfg *io_cfg,
139 int32_t *lcore_id, struct rte_ether_addr *p_o_du_addr,
140 struct rte_ether_addr *p_ru_addr, uint32_t mtu);
142 struct rte_mbuf *xran_ethdi_mbuf_alloc(void);
143 struct rte_mbuf *xran_ethdi_mbuf_indir_alloc(void);
144 int32_t xran_ethdi_mbuf_send(struct rte_mbuf *mb, uint16_t ethertype, uint16_t vf_id);
145 int32_t xran_ethdi_mbuf_send_cp(struct rte_mbuf *mb, uint16_t ethertype, uint16_t vf_id);
146 int32_t xran_ethdi_filter_packet(struct rte_mbuf *pkt[], uint16_t vf_id, uint16_t q_id, uint16_t num);
147 int32_t process_dpdk_io(void* args);
148 int32_t process_dpdk_io_tx(void* args);
149 int32_t process_dpdk_io_rx(void* args);
151 struct rte_flow * generate_ecpri_flow(uint16_t port_id, uint16_t rx_q, uint16_t pc_id_be, struct rte_flow_error *error);
158 #endif /* #ifndef _ETHDI_H_ */