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

app/testpmd: add generic event handler

Browse Source 
This is a rather simple handler that prints a message with the name of
the current event. It can be used to check PMD callback registration and
triggers.

Signed-off-by: Gaetan Rivet <gaetan.rivet@6wind.com>
This commit is contained in:
Gaetan Rivet 2017-04-18 14:17:40 +02:00 committed by Thomas Monjalon
parent 6dd7b7056d
commit 76ad4a2d82
1 changed files with 47 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
app/test-pmd/testpmd.c
View File

@ -351,6 +351,9 @@ struct rte_stats_bitrates *bitrate_data;
/* Forward function declarations */
static void map_port_queue_stats_mapping_registers(uint8_t pi, struct rte_port *port);
static void check_all_ports_link_status(uint32_t port_mask);
static void eth_event_callback(uint8_t port_id,
enum rte_eth_event_type type,
void *param);
/*
* Check if all the ports are started.
@ -1347,6 +1350,7 @@ start_port(portid_t pid)
queueid_t qi;
struct rte_port *port;
struct ether_addr mac_addr;
enum rte_eth_event_type event_type;
if (port_id_is_invalid(pid, ENABLED_WARN))
return 0;
@ -1458,6 +1462,21 @@ start_port(portid_t pid)
return -1;
}
}
for (event_type = RTE_ETH_EVENT_UNKNOWN;
event_type < RTE_ETH_EVENT_MAX;
event_type++) {
diag = rte_eth_dev_callback_register(pi,
event_type,
eth_event_callback,
NULL);
if (diag) {
printf("Failed to setup even callback for event %d\n",
event_type);
return -1;
}
}
/* start port */
if (rte_eth_dev_start(pi) < 0) {
printf("Fail to start port %d\n", pi);
@ -1730,6 +1749,34 @@ check_all_ports_link_status(uint32_t port_mask)
}
}
/* This function is used by the interrupt thread */
static void
eth_event_callback(uint8_t port_id, enum rte_eth_event_type type, void *param)
{
static const char * const event_desc[] = {
[RTE_ETH_EVENT_UNKNOWN] = "Unknown",
[RTE_ETH_EVENT_INTR_LSC] = "LSC",
[RTE_ETH_EVENT_QUEUE_STATE] = "Queue state",
[RTE_ETH_EVENT_INTR_RESET] = "Interrupt reset",
[RTE_ETH_EVENT_VF_MBOX] = "VF Mbox",
[RTE_ETH_EVENT_MACSEC] = "MACsec",
[RTE_ETH_EVENT_INTR_RMV] = "device removal",
[RTE_ETH_EVENT_MAX] = NULL,
};
RTE_SET_USED(param);
if (type >= RTE_ETH_EVENT_MAX) {
fprintf(stderr, "\nPort %" PRIu8 ": %s called upon invalid event %d\n",
port_id, __func__, type);
fflush(stderr);
} else {
printf("\nPort %" PRIu8 ": %s event\n", port_id,
event_desc[type]);
fflush(stdout);
}
}
static int
set_tx_queue_stats_mapping_registers(uint8_t port_id, struct rte_port *port)
{