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

eventdev: add caps API and PMD callbacks for eth Tx adapter

Browse Source 
The caps API allows the application to query if the transmit
stage is implemented in the eventdev PMD or uses the common
rte_service function. The PMD callbacks support the
eventdev PMD implementation of the adapter.

Signed-off-by: Nikhil Rao <nikhil.rao@intel.com>
Acked-by: Jerin Jacob <jerin.jacob@caviumnetworks.com>
This commit is contained in:
Nikhil Rao 2018-09-20 23:11:13 +05:30 committed by Jerin Jacob
parent c9bf83947e
commit c662a950f4
4 changed files with 272 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/librte_eventdev/rte_event_eth_tx_adapter.h
View File

@ -39,14 +39,14 @@
* rte_event_eth_tx_adapter_create() or rte_event_eth_tx_adapter_create_ext().
*
* The adapter will use the common implementation when the eventdev PMD
* does not have the RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT capability.
* does not have the #RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT capability.
* The common implementation uses an event port that is created using the port
* configuration parameter passed to rte_event_eth_tx_adapter_create(). The
* application can get the port identifier using
* rte_event_eth_tx_adapter_event_port_get() and must link an event queue to
* this port.
*
* If the eventdev PMD has the RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT
* If the eventdev PMD has the #RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT
* flags set, Tx adapter events should be enqueued using the
* rte_event_eth_tx_adapter_enqueue() function, else the application should
* use rte_event_enqueue_burst().
@ -329,7 +329,7 @@ rte_event_eth_tx_adapter_txq_get(struct rte_mbuf *pkt)
* @b EXPERIMENTAL: this API may change without prior notice
*
* Retrieve the adapter event port. The adapter creates an event port if
* the RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT is not set in the
* the #RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT is not set in the
* ethernet Tx capabilities of the event device.
*
* @param id
@ -347,7 +347,7 @@ rte_event_eth_tx_adapter_event_port_get(uint8_t id, uint8_t *event_port_id);
* Enqueue a burst of events objects or an event object supplied in *rte_event*
* structure on an event device designated by its *dev_id* through the event
* port specified by *port_id*. This function is supported if the eventdev PMD
* has the RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT capability flag set.
* has the #RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT capability flag set.
*
* The *nb_events* parameter is the number of event objects to enqueue which are
* supplied in the *ev* array of *rte_event* structure.

36
lib/librte_eventdev/rte_eventdev.c
View File

@ -175,6 +175,31 @@ rte_event_crypto_adapter_caps_get(uint8_t dev_id, uint8_t cdev_id,
(dev, cdev, caps) : -ENOTSUP;
}
int __rte_experimental
rte_event_eth_tx_adapter_caps_get(uint8_t dev_id, uint16_t eth_port_id,
uint32_t *caps)
{
struct rte_eventdev *dev;
struct rte_eth_dev *eth_dev;
RTE_EVENTDEV_VALID_DEVID_OR_ERR_RET(dev_id, -EINVAL);
RTE_ETH_VALID_PORTID_OR_ERR_RET(eth_port_id, -EINVAL);
dev = &rte_eventdevs[dev_id];
eth_dev = &rte_eth_devices[eth_port_id];
if (caps == NULL)
return -EINVAL;
*caps = 0;
return dev->dev_ops->eth_tx_adapter_caps_get ?
(*dev->dev_ops->eth_tx_adapter_caps_get)(dev,
eth_dev,
caps)
: 0;
}
static inline int
rte_event_dev_queue_config(struct rte_eventdev *dev, uint8_t nb_queues)
{
@ -1297,6 +1322,15 @@ rte_eventdev_find_free_device_index(void)
return RTE_EVENT_MAX_DEVS;
}
static uint16_t
rte_event_tx_adapter_enqueue(__rte_unused void *port,
__rte_unused struct rte_event ev[],
__rte_unused uint16_t nb_events)
{
rte_errno = ENOTSUP;
return 0;
}
struct rte_eventdev *
rte_event_pmd_allocate(const char *name, int socket_id)
{
@ -1317,6 +1351,8 @@ rte_event_pmd_allocate(const char *name, int socket_id)
eventdev = &rte_eventdevs[dev_id];
eventdev->txa_enqueue = rte_event_tx_adapter_enqueue;
if (eventdev->data == NULL) {
struct rte_eventdev_data *eventdev_data = NULL;

33
lib/librte_eventdev/rte_eventdev.h
View File

@ -1186,6 +1186,32 @@ int __rte_experimental
rte_event_crypto_adapter_caps_get(uint8_t dev_id, uint8_t cdev_id,
uint32_t *caps);
/* Ethdev Tx adapter capability bitmap flags */
#define RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT 0x1
/**< This flag is sent when the PMD supports a packet transmit callback
*/
/**
* Retrieve the event device's eth Tx adapter capabilities
*
* @param dev_id
* The identifier of the device.
*
* @param eth_port_id
* The identifier of the ethernet device.
*
* @param[out] caps
* A pointer to memory filled with eth Tx adapter capabilities.
*
* @return
* - 0: Success, driver provides eth Tx adapter capabilities.
* - <0: Error code returned by the driver function.
*
*/
int __rte_experimental
rte_event_eth_tx_adapter_caps_get(uint8_t dev_id, uint16_t eth_port_id,
uint32_t *caps);
struct rte_eventdev_ops;
struct rte_eventdev;
@ -1204,6 +1230,10 @@ typedef uint16_t (*event_dequeue_burst_t)(void *port, struct rte_event ev[],
uint16_t nb_events, uint64_t timeout_ticks);
/**< @internal Dequeue burst of events from port of a device */
typedef uint16_t (*event_tx_adapter_enqueue)(void *port,
struct rte_event ev[], uint16_t nb_events);
/**< @internal Enqueue burst of events on port of a device */
#define RTE_EVENTDEV_NAME_MAX_LEN (64)
/**< @internal Max length of name of event PMD */
@ -1266,7 +1296,8 @@ struct rte_eventdev {
/**< Pointer to PMD dequeue function. */
event_dequeue_burst_t dequeue_burst;
/**< Pointer to PMD dequeue burst function. */
event_tx_adapter_enqueue txa_enqueue;
/**< Pointer to PMD eth Tx adapter enqueue function. */
struct rte_eventdev_data *data;
/**< Pointer to device data */
struct rte_eventdev_ops *dev_ops;

200
lib/librte_eventdev/rte_eventdev_pmd.h
View File

@ -806,6 +806,186 @@ typedef int (*eventdev_crypto_adapter_stats_reset)
(const struct rte_eventdev *dev,
const struct rte_cryptodev *cdev);
/**
* Retrieve the event device's eth Tx adapter capabilities.
*
* @param dev
* Event device pointer
*
* @param eth_dev
* Ethernet device pointer
*
* @param[out] caps
* A pointer to memory filled with eth Tx adapter capabilities.
*
* @return
* - 0: Success, driver provides eth Tx adapter capabilities
* - <0: Error code returned by the driver function.
*
*/
typedef int (*eventdev_eth_tx_adapter_caps_get_t)
(const struct rte_eventdev *dev,
const struct rte_eth_dev *eth_dev,
uint32_t *caps);
/**
* Create adapter callback.
*
* @param id
* Adapter identifier
*
* @param dev
* Event device pointer
*
* @return
* - 0: Success.
* - <0: Error code on failure.
*/
typedef int (*eventdev_eth_tx_adapter_create_t)(uint8_t id,
const struct rte_eventdev *dev);
/**
* Free adapter callback.
*
* @param id
* Adapter identifier
*
* @param dev
* Event device pointer
*
* @return
* - 0: Success.
* - <0: Error code on failure.
*/
typedef int (*eventdev_eth_tx_adapter_free_t)(uint8_t id,
const struct rte_eventdev *dev);
/**
* Add a Tx queue to the adapter.
* A queue value of -1 is used to indicate all
* queues within the device.
*
* @param id
* Adapter identifier
*
* @param dev
* Event device pointer
*
* @param eth_dev
* Ethernet device pointer
*
* @param tx_queue_id
* Transmt queue index
*
* @return
* - 0: Success.
* - <0: Error code on failure.
*/
typedef int (*eventdev_eth_tx_adapter_queue_add_t)(
uint8_t id,
const struct rte_eventdev *dev,
const struct rte_eth_dev *eth_dev,
int32_t tx_queue_id);
/**
* Delete a Tx queue from the adapter.
* A queue value of -1 is used to indicate all
* queues within the device, that have been added to this
* adapter.
*
* @param id
* Adapter identifier
*
* @param dev
* Event device pointer
*
* @param eth_dev
* Ethernet device pointer
*
* @param tx_queue_id
* Transmit queue index
*
* @return
* - 0: Success, Queues deleted successfully.
* - <0: Error code on failure.
*/
typedef int (*eventdev_eth_tx_adapter_queue_del_t)(
uint8_t id,
const struct rte_eventdev *dev,
const struct rte_eth_dev *eth_dev,
int32_t tx_queue_id);
/**
* Start the adapter.
*
* @param id
* Adapter identifier
*
* @param dev
* Event device pointer
*
* @return
* - 0: Success, Adapter started correctly.
* - <0: Error code on failure.
*/
typedef int (*eventdev_eth_tx_adapter_start_t)(uint8_t id,
const struct rte_eventdev *dev);
/**
* Stop the adapter.
*
* @param id
* Adapter identifier
*
* @param dev
* Event device pointer
*
* @return
* - 0: Success.
* - <0: Error code on failure.
*/
typedef int (*eventdev_eth_tx_adapter_stop_t)(uint8_t id,
const struct rte_eventdev *dev);
struct rte_event_eth_tx_adapter_stats;
/**
* Retrieve statistics for an adapter
*
* @param id
* Adapter identifier
*
* @param dev
* Event device pointer
*
* @param [out] stats
* A pointer to structure used to retrieve statistics for an adapter
*
* @return
* - 0: Success, statistics retrieved successfully.
* - <0: Error code on failure.
*/
typedef int (*eventdev_eth_tx_adapter_stats_get_t)(
uint8_t id,
const struct rte_eventdev *dev,
struct rte_event_eth_tx_adapter_stats *stats);
/**
* Reset statistics for an adapter
*
* @param id
* Adapter identifier
*
* @param dev
* Event device pointer
*
* @return
* - 0: Success, statistics retrieved successfully.
* - <0: Error code on failure.
*/
typedef int (*eventdev_eth_tx_adapter_stats_reset_t)(uint8_t id,
const struct rte_eventdev *dev);
/** Event device operations function pointer table */
struct rte_eventdev_ops {
eventdev_info_get_t dev_infos_get; /**< Get device info. */
@ -881,6 +1061,26 @@ struct rte_eventdev_ops {
eventdev_crypto_adapter_stats_reset crypto_adapter_stats_reset;
/**< Reset crypto stats */
eventdev_eth_tx_adapter_caps_get_t eth_tx_adapter_caps_get;
/**< Get ethernet Tx adapter capabilities */
eventdev_eth_tx_adapter_create_t eth_tx_adapter_create;
/**< Create adapter callback */
eventdev_eth_tx_adapter_free_t eth_tx_adapter_free;
/**< Free adapter callback */
eventdev_eth_tx_adapter_queue_add_t eth_tx_adapter_queue_add;
/**< Add Tx queues to the eth Tx adapter */
eventdev_eth_tx_adapter_queue_del_t eth_tx_adapter_queue_del;
/**< Delete Tx queues from the eth Tx adapter */
eventdev_eth_tx_adapter_start_t eth_tx_adapter_start;
/**< Start eth Tx adapter */
eventdev_eth_tx_adapter_stop_t eth_tx_adapter_stop;
/**< Stop eth Tx adapter */
eventdev_eth_tx_adapter_stats_get_t eth_tx_adapter_stats_get;
/**< Get eth Tx adapter statistics */
eventdev_eth_tx_adapter_stats_reset_t eth_tx_adapter_stats_reset;
/**< Reset eth Tx adapter statistics */
eventdev_selftest dev_selftest;
/**< Start eventdev Selftest */