summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorFlorin Coras <fcoras@cisco.com>2021-03-31 21:05:24 -0700
committerDave Barach <openvpp@barachs.net>2021-04-01 15:17:34 +0000
commit87d81ae60c45d422e9b29343ad7cec881c3eb470 (patch)
treed07bbf807fa1ed1aabe94724a384c47806d204ca
parenta1510f592bf4c91ec68c5e217e112f0c1f756035 (diff)
session: always clean rx mqs on app detach
Type: fix Signed-off-by: Florin Coras <fcoras@cisco.com> Change-Id: I47b5b1ad693d131cfc332f6942c86967687a3f2b
-rw-r--r--src/vnet/session/application.c7
1 files changed, 3 insertions, 4 deletions
diff --git a/src/vnet/session/application.c b/src/vnet/session/application.c
index b055ab49f3c..16acc9c997d 100644
--- a/src/vnet/session/application.c
+++ b/src/vnet/session/application.c
@@ -574,11 +574,10 @@ app_rx_mqs_epoll_del (application_t *app, app_rx_mq_elt_t *mqe)
aw = &am->wrk[thread_index];
+ session_wrk_handle_mq (session_main_get_worker (thread_index), mqe->mq);
+
if (mqe->flags & APP_RX_MQ_F_PENDING)
- {
- session_wrk_handle_mq (session_main_get_worker (thread_index), mqe->mq);
- appsl_pending_rx_mqs_del (aw, mqe);
- }
+ appsl_pending_rx_mqs_del (aw, mqe);
clib_file_del_by_index (&file_main, mqe->file_index);
}