From 36d49391aadeb10b9f3626b62c5c019c4fddf5ed Mon Sep 17 00:00:00 2001 From: Florin Coras Date: Fri, 24 Apr 2020 23:00:11 +0000 Subject: session vcl: propagate transport cleanup notifications Type: improvement Can be used to force app to close a connection on which it still waits for data. Signed-off-by: Florin Coras Change-Id: I7c3a8245cbbc23728e4408feb63a659a11f718ed --- src/vnet/session/session_api.c | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'src/vnet/session/session_api.c') diff --git a/src/vnet/session/session_api.c b/src/vnet/session/session_api.c index 39545375e62..cfeb7bcc349 100644 --- a/src/vnet/session/session_api.c +++ b/src/vnet/session/session_api.c @@ -550,8 +550,9 @@ mq_send_session_cleanup_cb (session_t * s, session_cleanup_ntf_t ntf) session_event_t *evt; app_worker_t *app_wrk; - /* Only propagate session cleanup notification */ - if (ntf == SESSION_CLEANUP_TRANSPORT) + /* Propagate transport cleanup notifications only if app didn't close */ + if (ntf == SESSION_CLEANUP_TRANSPORT + && s->session_state != SESSION_STATE_TRANSPORT_DELETED) return; app_wrk = app_worker_get_if_valid (s->app_wrk_index); @@ -567,6 +568,7 @@ mq_send_session_cleanup_cb (session_t * s, session_cleanup_ntf_t ntf) evt->event_type = SESSION_CTRL_EVT_CLEANUP; mp = (session_cleanup_msg_t *) evt->data; mp->handle = session_handle (s); + mp->type = ntf; svm_msg_q_add_and_unlock (app_mq, msg); } -- cgit 1.2.3-korg