ligang/vpp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

quic: initialize ooo lookup on fifos

Browse Source 
Type: fix

Signed-off-by: Florin Coras <fcoras@cisco.com>
Change-Id: I6a0493834c5b60bdb42865112c453157fdfeb87c
This commit is contained in:
Florin Coras
2024-06-07 16:06:51 -07:00
committed by Dave Wallace
parent 2d1f0e6c73
commit 3def24bc48
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/plugins/quic/quic.c
View File

@ -1058,6 +1058,8 @@ quic_on_stream_open (quicly_stream_open_t * self, quicly_stream_t * stream)
svm_fifo_add_want_deq_ntf (stream_session->rx_fifo,
SVM_FIFO_WANT_DEQ_NOTIF_IF_FULL |
SVM_FIFO_WANT_DEQ_NOTIF_IF_EMPTY);
svm_fifo_init_ooo_lookup (stream_session->rx_fifo, 0 /* ooo enq */);
svm_fifo_init_ooo_lookup (stream_session->tx_fifo, 1 /* ooo deq */);
stream_session->session_state = SESSION_STATE_ACCEPTING;
if ((rv = app_worker_accept_notify (app_wrk, stream_session)))
@ -1302,6 +1304,8 @@ quic_connect_stream (session_t * quic_session, session_endpoint_cfg_t * sep)
return app_worker_connect_notify (app_wrk, NULL, rv, sep->opaque);
}
svm_fifo_init_ooo_lookup (stream_session->rx_fifo, 0 /* ooo enq */);
svm_fifo_init_ooo_lookup (stream_session->tx_fifo, 1 /* ooo deq */);
svm_fifo_add_want_deq_ntf (stream_session->rx_fifo,
SVM_FIFO_WANT_DEQ_NOTIF_IF_FULL |
SVM_FIFO_WANT_DEQ_NOTIF_IF_EMPTY);
@ -1679,6 +1683,9 @@ quic_on_quic_session_connected (quic_ctx_t * ctx)
return;
}
svm_fifo_init_ooo_lookup (quic_session->rx_fifo, 0 /* ooo enq */);
svm_fifo_init_ooo_lookup (quic_session->tx_fifo, 1 /* ooo deq */);
quic_session->session_state = SESSION_STATE_CONNECTING;
if ((rv = app_worker_connect_notify (app_wrk, quic_session,
SESSION_E_NONE, ctx->client_opaque)))
@ -2137,6 +2144,9 @@ quic_accept_connection (quic_rx_packet_ctx_t * pctx)
return;
}
svm_fifo_init_ooo_lookup (quic_session->rx_fifo, 0 /* ooo enq */);
svm_fifo_init_ooo_lookup (quic_session->tx_fifo, 1 /* ooo deq */);
app_wrk = app_worker_get (quic_session->app_wrk_index);
quic_session->session_state = SESSION_STATE_ACCEPTING;
if ((rv = app_worker_accept_notify (app_wrk, quic_session)))