diff options
| author |   Florin Coras <fcoras@cisco.com> | 2024-02-14 16:14:46 -0800 |
|---|---|---|
| committer |   Dave Barach <vpp@barachs.net> | 2024-02-15 17:20:41 +0000 |
| commit | e439b1e70e4e6ca3c98264512a78a1fc741d74ac (patch) | |
| tree | c7ef7870f8ed49ff111a26a544c2ca65131c4db6 /src/vnet/session/application_local.c | |
| parent | a421d564cd113a63a677521a89dc16f184ccee11 (diff) | |
session: postpone ct cleanup if rx evt pending
Type: fix
Change-Id: I8cfaa62abd38d5356263b0ffd428638d1a027617
Signed-off-by: Florin Coras <fcoras@cisco.com>
Diffstat (limited to 'src/vnet/session/application_local.c')
| -rw-r--r-- | src/vnet/session/application_local.c | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/vnet/session/application_local.c b/src/vnet/session/application_local.c index 8c6cf8a93fa..5bd1471b6fc 100644 --- a/src/vnet/session/application_local.c +++ b/src/vnet/session/application_local.c @@ -1132,10 +1132,10 @@ ct_handle_cleanups (void *args) clib_fifo_sub2 (wrk->pending_cleanups, req); ct = ct_connection_get (req->ct_index, thread_index); s = session_get (ct->c_s_index, ct->c_thread_index); - if (!svm_fifo_has_event (s->tx_fifo)) - ct_session_postponed_cleanup (ct); - else + if (svm_fifo_has_event (s->tx_fifo) || (s->flags & SESSION_F_RX_EVT)) clib_fifo_add1 (wrk->pending_cleanups, *req); + else + ct_session_postponed_cleanup (ct); n_to_handle -= 1; } @@ -1411,6 +1411,7 @@ ct_session_tx (session_t * s) peer_s = session_get (peer_ct->c_s_index, peer_ct->c_thread_index); if (peer_s->session_state >= SESSION_STATE_TRANSPORT_CLOSING) return 0; + peer_s->flags |= SESSION_F_RX_EVT; return session_enqueue_notify (peer_s); } |