d/numam-dpdk
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

net/octeontx: add Tx queue start and stop

Browse Source 
Mark "Queue start/stop" as P as its been implemented only for tx queue.

Signed-off-by: Jerin Jacob <jerin.jacob@caviumnetworks.com>
Signed-off-by: Santosh Shukla <santosh.shukla@caviumnetworks.com>
This commit is contained in:
Jerin Jacob 2017-10-08 18:14:24 +05:30 committed by Ferruh Yigit
parent 197438ee9f
commit 7fe7c98fec
3 changed files with 97 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
doc/guides/nics/features/octeontx.ini
View File

@ -7,6 +7,7 @@
Speed capabilities = Y
Link status = Y
Lock-free Tx queue = Y
Queue start/stop = P
Jumbo frame = Y
Promiscuous mode = Y
Unicast MAC filter = P

90
drivers/net/octeontx/octeontx_ethdev.c
View File

@ -160,6 +160,14 @@ octeontx_port_close(struct octeontx_nic *nic)
octeontx_log_dbg("port closed %d", nic->port_id);
}
static int
octeontx_port_stop(struct octeontx_nic *nic)
{
PMD_INIT_FUNC_TRACE();
return octeontx_bgx_port_stop(nic->port_id);
}
static void
octeontx_port_promisc_set(struct octeontx_nic *nic, int en)
{
@ -500,6 +508,86 @@ octeontx_dev_info(struct rte_eth_dev *dev,
dev_info->tx_offload_capa = DEV_TX_OFFLOAD_MT_LOCKFREE;
}
static void
octeontx_dq_info_getter(octeontx_dq_t *dq, void *out)
{
((octeontx_dq_t *)out)->lmtline_va = dq->lmtline_va;
((octeontx_dq_t *)out)->ioreg_va = dq->ioreg_va;
((octeontx_dq_t *)out)->fc_status_va = dq->fc_status_va;
}
static int
octeontx_vf_start_tx_queue(struct rte_eth_dev *dev, struct octeontx_nic *nic,
uint16_t qidx)
{
struct octeontx_txq *txq;
int res;
PMD_INIT_FUNC_TRACE();
if (dev->data->tx_queue_state[qidx] == RTE_ETH_QUEUE_STATE_STARTED)
return 0;
txq = dev->data->tx_queues[qidx];
res = octeontx_pko_channel_query_dqs(nic->base_ochan,
&txq->dq,
sizeof(octeontx_dq_t),
txq->queue_id,
octeontx_dq_info_getter);
if (res < 0) {
res = -EFAULT;
goto close_port;
}
dev->data->tx_queue_state[qidx] = RTE_ETH_QUEUE_STATE_STARTED;
return res;
close_port:
(void)octeontx_port_stop(nic);
octeontx_pko_channel_stop(nic->base_ochan);
octeontx_pko_channel_close(nic->base_ochan);
dev->data->tx_queue_state[qidx] = RTE_ETH_QUEUE_STATE_STOPPED;
return res;
}
static int
octeontx_dev_tx_queue_start(struct rte_eth_dev *dev, uint16_t qidx)
{
struct octeontx_nic *nic = octeontx_pmd_priv(dev);
PMD_INIT_FUNC_TRACE();
qidx = qidx % PKO_VF_NUM_DQ;
return octeontx_vf_start_tx_queue(dev, nic, qidx);
}
static inline int
octeontx_vf_stop_tx_queue(struct rte_eth_dev *dev, struct octeontx_nic *nic,
uint16_t qidx)
{
int ret = 0;
RTE_SET_USED(nic);
PMD_INIT_FUNC_TRACE();
if (dev->data->tx_queue_state[qidx] == RTE_ETH_QUEUE_STATE_STOPPED)
return 0;
dev->data->tx_queue_state[qidx] = RTE_ETH_QUEUE_STATE_STOPPED;
return ret;
}
static int
octeontx_dev_tx_queue_stop(struct rte_eth_dev *dev, uint16_t qidx)
{
struct octeontx_nic *nic = octeontx_pmd_priv(dev);
PMD_INIT_FUNC_TRACE();
qidx = qidx % PKO_VF_NUM_DQ;
return octeontx_vf_stop_tx_queue(dev, nic, qidx);
}
static int
octeontx_dev_rx_queue_setup(struct rte_eth_dev *dev, uint16_t qidx,
uint16_t nb_desc, unsigned int socket_id,
@ -676,6 +764,8 @@ static const struct eth_dev_ops octeontx_dev_ops = {
.stats_get = octeontx_dev_stats_get,
.stats_reset = octeontx_dev_stats_reset,
.mac_addr_set = octeontx_dev_default_mac_addr_set,
.tx_queue_start = octeontx_dev_tx_queue_start,
.tx_queue_stop = octeontx_dev_tx_queue_stop,
.rx_queue_setup = octeontx_dev_rx_queue_setup,
.rx_queue_release = octeontx_dev_rx_queue_release,
};

6
drivers/net/octeontx/octeontx_ethdev.h
View File

@ -91,6 +91,12 @@ struct octeontx_nic {
uint16_t ev_ports;
} __rte_cache_aligned;
struct octeontx_txq {
uint16_t queue_id;
octeontx_dq_t dq;
struct rte_eth_dev *eth_dev;
} __rte_cache_aligned;
struct octeontx_rxq {
uint16_t queue_id;
uint16_t port_id;