diff options
| author |   Florin Coras <fcoras@cisco.com> | 2019-02-20 19:48:31 -0800 |
|---|---|---|
| committer |   Damjan Marion <dmarion@me.com> | 2019-02-21 12:27:03 +0000 |
| commit | 565115edf0d6689a3f362c69240c160b49807156 (patch) | |
| tree | cb0dd4a6299fc6ec4fdade0f71fb2f21ac9e33c6 /src/vnet/session | |
| parent | 0964985cdd99cf769582e0d9393de68a95b121b9 (diff) | |
tcp: drop outstanding data when entering closing state
Change-Id: I92a009b9630b0d882ea3c5c99aad88ed6f5109a0
Signed-off-by: Florin Coras <fcoras@cisco.com>
Diffstat (limited to 'src/vnet/session')
| -rw-r--r-- | src/vnet/session/application_worker.c | 1 | ||||
| -rw-r--r-- | src/vnet/session/session.c | 2 | ||||
| -rw-r--r-- | src/vnet/session/session.h | 2 |
3 files changed, 3 insertions, 2 deletions
diff --git a/src/vnet/session/application_worker.c b/src/vnet/session/application_worker.c index 3bab3564ad9..5423733b231 100644 --- a/src/vnet/session/application_worker.c +++ b/src/vnet/session/application_worker.c @@ -199,6 +199,7 @@ app_worker_free (app_worker_t * app_wrk) { sm = segment_manager_get (app_wrk->connects_seg_manager); sm->app_wrk_index = SEGMENT_MANAGER_INVALID_APP_INDEX; + sm->first_is_protected = 0; segment_manager_init_del (sm); } diff --git a/src/vnet/session/session.c b/src/vnet/session/session.c index 606f71739bd..83c889c715a 100644 --- a/src/vnet/session/session.c +++ b/src/vnet/session/session.c @@ -462,7 +462,7 @@ stream_session_peek_bytes (transport_connection_t * tc, u8 * buffer, } u32 -stream_session_dequeue_drop (transport_connection_t * tc, u32 max_bytes) +session_dequeue_drop (transport_connection_t * tc, u32 max_bytes) { session_t *s = session_get (tc->s_index, tc->thread_index); return svm_fifo_dequeue_drop (s->tx_fifo, max_bytes); diff --git a/src/vnet/session/session.h b/src/vnet/session/session.h index 4de7642d29a..f20e0db1d04 100644 --- a/src/vnet/session/session.h +++ b/src/vnet/session/session.h @@ -375,7 +375,7 @@ int session_enqueue_dgram_connection (session_t * s, u8 queue_event); int stream_session_peek_bytes (transport_connection_t * tc, u8 * buffer, u32 offset, u32 max_bytes); -u32 stream_session_dequeue_drop (transport_connection_t * tc, u32 max_bytes); +u32 session_dequeue_drop (transport_connection_t * tc, u32 max_bytes); int session_stream_connect_notify (transport_connection_t * tc, u8 is_fail); int session_dgram_connect_notify (transport_connection_t * tc, |