diff options
| author |   NikitaSkrynnik <nikita.skrynnik@xored.com> | 2023-09-14 16:00:38 +0700 |
|---|---|---|
| committer |   Dave Wallace <dwallacelf@gmail.com> | 2023-09-26 20:45:28 +0000 |
| commit | bb1cde678e3b7639490cbbd68fe312af171c0a41 (patch) | |
| tree | a59e173a65168360b37071253ffa929717f8bc85 /src/plugins/ping/ping.h | |
| parent | 40242b88e9d4548c4e76a69b00c87c0151218d03 (diff) | |
ping: Simple binary API for running ping based on events
Type: improvement
Change-Id: I02846a2420637470cb0f9472c86471b6a3421a75
Signed-off-by: NikitaSkrynnik <nikita.skrynnik@xored.com>
Diffstat (limited to 'src/plugins/ping/ping.h')
| -rw-r--r-- | src/plugins/ping/ping.h | 73 |
1 files changed, 73 insertions, 0 deletions
diff --git a/src/plugins/ping/ping.h b/src/plugins/ping/ping.h index 7826945ea8b..e789300acd6 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. */ @@ -88,4 +91,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 */ |