From 4f3da9c1f73043145f825491ef573f180af10fc9 Mon Sep 17 00:00:00 2001 From: Florin Coras Date: Thu, 29 Feb 2024 18:19:30 -0800 Subject: session: add api cb for listen and unlisten Type: improvement Signed-off-by: Florin Coras Change-Id: I28ccebf4d2f0728dd174ab3ee77a0d7ad4b90951 --- src/vnet/session/session_input.c | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'src/vnet/session/session_input.c') 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); -- cgit 1.2.3-korg