diff options
| author |   Florin Coras <fcoras@cisco.com> | 2019-04-28 21:16:30 -0700 |
|---|---|---|
| committer |   Dave Barach <openvpp@barachs.net> | 2019-04-30 16:59:49 +0000 |
| commit | 87b15cebdaca21f6725637abeceec0f19f4eec51 (patch) | |
| tree | 3b6063188bc64972bdc359526dd8c0823bcd9fc9 /src/plugins/quic/quic.c | |
| parent | c6eb5bc967d3d70016b4e4e182b3d68b1e558f60 (diff) | |
svm: more fifo refactor/cleanup
Change-Id: Ie76c69641c8598164d0d00fd498018037258fd86
Signed-off-by: Florin Coras <fcoras@cisco.com>
Diffstat (limited to 'src/plugins/quic/quic.c')
| -rw-r--r-- | src/plugins/quic/quic.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/plugins/quic/quic.c b/src/plugins/quic/quic.c index 5ff962d8102..e2c2514858c 100644 --- a/src/plugins/quic/quic.c +++ b/src/plugins/quic/quic.c @@ -138,9 +138,9 @@ quic_send_datagram (session_t * udp_session, quicly_datagram_t * packet) clib_memcpy (&hdr.rmt_ip.ip6, &sa6->sin6_addr, 16); } - rv = svm_fifo_enqueue_nowait (f, sizeof (hdr), (u8 *) & hdr); + rv = svm_fifo_enqueue (f, sizeof (hdr), (u8 *) & hdr); ASSERT (rv == sizeof (hdr)); - if (svm_fifo_enqueue_nowait (f, len, packet->data.base) != len) + if (svm_fifo_enqueue (f, len, packet->data.base) != len) return 1; return 0; } @@ -242,7 +242,7 @@ quic_on_receive (quicly_stream_t * stream, size_t off, const void *src, to_enqueue = len; // TODO what happens to the excess bytes? - svm_fifo_enqueue_nowait (rx_fifo, to_enqueue, src); + svm_fifo_enqueue (rx_fifo, to_enqueue, src); // Notify app app_wrk = app_worker_get_if_valid (stream_session->app_wrk_index); |