From 2cba8533cc4444c4615903add9a8f20c7c87079c Mon Sep 17 00:00:00 2001 From: Florin Coras Date: Tue, 11 Sep 2018 16:33:36 -0700 Subject: vcl: add apis that expos fifo as buffer Change-Id: I4bd9c9f73499711e04b38d53daa5c917a4285bf5 Signed-off-by: Florin Coras --- src/svm/svm_fifo.c | 47 +++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 47 insertions(+) (limited to 'src/svm/svm_fifo.c') diff --git a/src/svm/svm_fifo.c b/src/svm/svm_fifo.c index 018827e0343..0c258b4259c 100644 --- a/src/svm/svm_fifo.c +++ b/src/svm/svm_fifo.c @@ -835,6 +835,53 @@ svm_fifo_dequeue_drop_all (svm_fifo_t * f) __sync_fetch_and_sub (&f->cursize, f->cursize); } +int +svm_fifo_segments (svm_fifo_t * f, svm_fifo_segment_t * fs) +{ + u32 cursize, nitems; + + /* read cursize, which can only increase while we're working */ + cursize = svm_fifo_max_dequeue (f); + if (PREDICT_FALSE (cursize == 0)) + return -2; + + nitems = f->nitems; + + fs[0].len = ((nitems - f->head) < cursize) ? (nitems - f->head) : cursize; + fs[0].data = f->data + f->head; + + if (fs[0].len < cursize) + { + fs[1].len = cursize - fs[0].len; + fs[1].data = f->data; + } + else + { + fs[1].len = 0; + fs[1].data = 0; + } + return cursize; +} + +void +svm_fifo_segments_free (svm_fifo_t * f, svm_fifo_segment_t * fs) +{ + u32 total_drop_bytes; + + ASSERT (fs[0].data == f->data + f->head); + if (fs[1].len) + { + f->head = fs[1].len; + total_drop_bytes = fs[0].len + fs[1].len; + } + else + { + f->head = (f->head + fs[0].len) % f->nitems; + total_drop_bytes = fs[0].len; + } + __sync_fetch_and_sub (&f->cursize, total_drop_bytes); +} + u32 svm_fifo_number_ooo_segments (svm_fifo_t * f) { -- cgit 1.2.3-korg