diff options
Diffstat (limited to 'src/plugins/ping/ping.h')
| -rw-r--r-- | src/plugins/ping/ping.h | 75 |
1 files changed, 73 insertions, 2 deletions
diff --git a/src/plugins/ping/ping.h b/src/plugins/ping/ping.h index 7826945ea8b..fdccd07b57d 100644 --- a/src/plugins/ping/ping.h +++ b/src/plugins/ping/ping.h @@ -52,6 +52,9 @@ typedef struct ping_run_t typedef struct ping_main_t { + /* API message ID base */ + u16 msg_id_base; + ip6_main_t *ip6_main; ip4_main_t *ip4_main; /* a vector of current ping runs. */ @@ -69,7 +72,6 @@ extern ping_main_t ping_main; #define PING_CLI_UNKNOWN_NODE (~0) -/* *INDENT-OFF* */ typedef CLIB_PACKED (struct { u16 id; @@ -78,7 +80,6 @@ typedef CLIB_PACKED (struct { u8 data[0]; }) icmp46_echo_request_t; -/* *INDENT-ON* */ typedef enum @@ -88,4 +89,74 @@ typedef enum ICMP46_ECHO_REPLY_N_NEXT, } icmp46_echo_reply_next_t; +static_always_inline uword +get_cli_process_id_by_icmp_id_mt (vlib_main_t *vm, u16 icmp_id) +{ + ping_main_t *pm = &ping_main; + uword cli_process_id = PING_CLI_UNKNOWN_NODE; + ping_run_t *pr; + + clib_spinlock_lock_if_init (&pm->ping_run_check_lock); + vec_foreach (pr, pm->active_ping_runs) + { + if (pr->icmp_id == icmp_id) + { + cli_process_id = pr->cli_process_id; + break; + } + } + clib_spinlock_unlock_if_init (&pm->ping_run_check_lock); + return cli_process_id; +} + +static_always_inline void +set_cli_process_id_by_icmp_id_mt (vlib_main_t *vm, u16 icmp_id, + uword cli_process_id) +{ + ping_main_t *pm = &ping_main; + ping_run_t *pr; + + clib_spinlock_lock_if_init (&pm->ping_run_check_lock); + vec_foreach (pr, pm->active_ping_runs) + { + if (pr->icmp_id == icmp_id) + { + pr->cli_process_id = cli_process_id; + goto have_found_and_set; + } + } + /* no such key yet - add a new one */ + ping_run_t new_pr = { .icmp_id = icmp_id, .cli_process_id = cli_process_id }; + vec_add1 (pm->active_ping_runs, new_pr); +have_found_and_set: + clib_spinlock_unlock_if_init (&pm->ping_run_check_lock); +} + +static_always_inline void +clear_cli_process_id_by_icmp_id_mt (vlib_main_t *vm, u16 icmp_id) +{ + ping_main_t *pm = &ping_main; + ping_run_t *pr; + + clib_spinlock_lock_if_init (&pm->ping_run_check_lock); + vec_foreach (pr, pm->active_ping_runs) + { + if (pr->icmp_id == icmp_id) + { + vec_del1 (pm->active_ping_runs, pr - pm->active_ping_runs); + break; + } + } + clib_spinlock_unlock_if_init (&pm->ping_run_check_lock); +} +clib_error_t *ping_plugin_api_hookup (vlib_main_t *vm); +send_ip46_ping_result_t send_ip4_ping (vlib_main_t *vm, u32 table_id, + ip4_address_t *pa4, u32 sw_if_index, + u16 seq_host, u16 id_host, u16 data_len, + u32 burst, u8 verbose); +send_ip46_ping_result_t send_ip6_ping (vlib_main_t *vm, u32 table_id, + ip6_address_t *pa6, u32 sw_if_index, + u16 seq_host, u16 id_host, u16 data_len, + u32 burst, u8 verbose); + #endif /* included_ping_ping_h */ |