aboutsummaryrefslogtreecommitdiffstats
path: root/src/vnet/session/session_input.c
diff options
context:
space:
mode:
authorFlorin Coras <fcoras@cisco.com>2024-02-29 18:19:30 -0800
committerDave Barach <vpp@barachs.net>2024-03-01 22:22:53 +0000
commit4f3da9c1f73043145f825491ef573f180af10fc9 (patch)
tree649810f1b98c5cee3f335b2362c5e14907b4922d /src/vnet/session/session_input.c
parent242fe13c62fe75fff0fa4d9ade0af0eec740d30f (diff)
session: add api cb for listen and unlisten
Type: improvement Signed-off-by: Florin Coras <fcoras@cisco.com> Change-Id: I28ccebf4d2f0728dd174ab3ee77a0d7ad4b90951
Diffstat (limited to 'src/vnet/session/session_input.c')
-rw-r--r--src/vnet/session/session_input.c12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/vnet/session/session_input.c b/src/vnet/session/session_input.c
index b403f7ddc4c..41e8beb8abc 100644
--- a/src/vnet/session/session_input.c
+++ b/src/vnet/session/session_input.c
@@ -145,9 +145,9 @@ app_worker_flush_events_inline (app_worker_t *app_wrk, u32 thread_index,
/* No app cb function currently */
if (is_builtin)
break;
- mq_send_session_bound_cb (app_wrk->wrk_index, evt->as_u64[1] >> 32,
- evt->session_handle,
- evt->as_u64[1] & 0xffffffff);
+ app->cb_fns.session_listened_callback (
+ app_wrk->wrk_index, evt->as_u64[1] >> 32, evt->session_handle,
+ evt->as_u64[1] & 0xffffffff);
break;
case SESSION_CTRL_EVT_ACCEPTED:
s = session_get (evt->session_index, thread_index);
@@ -208,9 +208,9 @@ app_worker_flush_events_inline (app_worker_t *app_wrk, u32 thread_index,
case SESSION_CTRL_EVT_UNLISTEN_REPLY:
if (is_builtin)
break;
- mq_send_unlisten_reply (app_wrk, evt->session_handle,
- evt->as_u64[1] >> 32,
- evt->as_u64[1] & 0xffffffff);
+ app->cb_fns.session_unlistened_callback (
+ app_wrk->wrk_index, evt->session_handle, evt->as_u64[1] >> 32,
+ evt->as_u64[1] & 0xffffffff);
break;
case SESSION_CTRL_EVT_MIGRATED:
s = session_get (evt->session_index, thread_index);