git.droids-corp.org
/
dpdk.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
net/mlx5: handle Rx CQE compression
[dpdk.git]
/
examples
/
l2fwd-keepalive
/
main.c
diff --git
a/examples/l2fwd-keepalive/main.c
b/examples/l2fwd-keepalive/main.c
index
4a0d9b6
..
84a59eb
100644
(file)
--- a/
examples/l2fwd-keepalive/main.c
+++ b/
examples/l2fwd-keepalive/main.c
@@
-72,6
+72,8
@@
#include <rte_timer.h>
#include <rte_keepalive.h>
#include <rte_timer.h>
#include <rte_keepalive.h>
+#include "shm.h"
+
#define RTE_LOGTYPE_L2FWD RTE_LOGTYPE_USER1
#define NB_MBUF 8192
#define RTE_LOGTYPE_L2FWD RTE_LOGTYPE_USER1
#define NB_MBUF 8192
@@
-523,7
+525,7
@@
check_all_ports_link_status(uint8_t port_num, uint32_t port_mask)
}
static void
}
static void
-dead_core(__
attribute__((unused))
void *ptr_data, const int id_core)
+dead_core(__
rte_unused
void *ptr_data, const int id_core)
{
printf("Dead core %i - restarting..\n", id_core);
if (rte_eal_get_lcore_state(id_core) == FINISHED) {
{
printf("Dead core %i - restarting..\n", id_core);
if (rte_eal_get_lcore_state(id_core) == FINISHED) {
@@
-534,6
+536,14
@@
dead_core(__attribute__((unused)) void *ptr_data, const int id_core)
}
}
}
}
+static void
+relay_core_state(void *ptr_data, const int id_core,
+ const enum rte_keepalive_state core_state, uint64_t last_alive)
+{
+ rte_keepalive_relayed_state((struct rte_keepalive_shm *)ptr_data,
+ id_core, core_state, last_alive);
+}
+
int
main(int argc, char **argv)
{
int
main(int argc, char **argv)
{
@@
-722,10
+732,18
@@
main(int argc, char **argv)
rte_timer_init(&stats_timer);
if (check_period > 0) {
rte_timer_init(&stats_timer);
if (check_period > 0) {
+ struct rte_keepalive_shm *ka_shm;
+
+ ka_shm = rte_keepalive_shm_create();
+ if (ka_shm == NULL)
+ rte_exit(EXIT_FAILURE,
+ "rte_keepalive_shm_create() failed");
rte_global_keepalive_info =
rte_global_keepalive_info =
- rte_keepalive_create(&dead_core,
NULL
);
+ rte_keepalive_create(&dead_core,
ka_shm
);
if (rte_global_keepalive_info == NULL)
rte_exit(EXIT_FAILURE, "init_keep_alive() failed");
if (rte_global_keepalive_info == NULL)
rte_exit(EXIT_FAILURE, "init_keep_alive() failed");
+ rte_keepalive_register_relay_callback(rte_global_keepalive_info,
+ relay_core_state, ka_shm);
rte_timer_init(&hb_timer);
if (rte_timer_reset(&hb_timer,
(check_period * rte_get_timer_hz()) / 1000,
rte_timer_init(&hb_timer);
if (rte_timer_reset(&hb_timer,
(check_period * rte_get_timer_hz()) / 1000,