kaspar/RIOT
1
0
Fork 0
mirror of https://github.com/RIOT-OS/RIOT.git synced 2025-12-15 17:43:51 +01:00
Code Releases Activity

sys/tsrb: use turb.h for c-file implemetation

Browse Source
This commit is contained in:
Karl Fessel 2025-10-12 21:45:19 +02:00
parent 40cca9246d
commit 0099b623d9
1 changed files with 11 additions and 51 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
sys/tsrb/tsrb.c
View File

@ -19,100 +19,60 @@
#include "irq.h"
#include "tsrb.h"
static void _push(tsrb_t *rb, uint8_t c)
{
rb->buf[rb->writes++ & (rb->size - 1)] = c;
}
static uint8_t _pop(tsrb_t *rb)
{
return rb->buf[rb->reads++ & (rb->size - 1)];
}
static uint8_t _peek(tsrb_t *rb, unsigned int idx)
{
return rb->buf[(rb->reads + idx) & (rb->size - 1)];
}
#include "turb.h"
int tsrb_get_one(tsrb_t *rb)
{
int retval = -1;
unsigned irq_state = irq_disable();
if (!tsrb_empty(rb)) {
retval = _pop(rb);
}
int retval = turb_get_one(rb);
irq_restore(irq_state);
return retval;
}
int tsrb_peek_one(tsrb_t *rb)
{
int retval = -1;
unsigned irq_state = irq_disable();
if (!tsrb_empty(rb)) {
retval = _peek(rb, 0);
}
int retval = turb_peek_one(rb);
irq_restore(irq_state);
return retval;
}
int tsrb_get(tsrb_t *rb, uint8_t *dst, size_t n)
{
size_t tmp = n;
unsigned irq_state = irq_disable();
while (tmp && !tsrb_empty(rb)) {
*dst++ = _pop(rb);
tmp--;
}
int cnt = turb_get(rb, dst, n);
irq_restore(irq_state);
return (n - tmp);
return cnt;
}
int tsrb_peek(tsrb_t *rb, uint8_t *dst, size_t n)
{
size_t idx = 0;
unsigned irq_state = irq_disable();
unsigned int avail = tsrb_avail(rb);
while (idx < n && idx != avail) {
*dst++ = _peek(rb, idx++);
}
int idx = turb_peek(rb, dst, n);
irq_restore(irq_state);
return idx;
}
int tsrb_drop(tsrb_t *rb, size_t n)
{
size_t tmp = n;
unsigned irq_state = irq_disable();
while (tmp && !tsrb_empty(rb)) {
_pop(rb);
tmp--;
}
int cnt = turb_drop(rb, n);
irq_restore(irq_state);
return (n - tmp);
return cnt;
}
int tsrb_add_one(tsrb_t *rb, uint8_t c)
{
int retval = -1;
unsigned irq_state = irq_disable();
if (!tsrb_full(rb)) {
_push(rb, c);
retval = 0;
}
int retval = turb_add_one(rb, c);
irq_restore(irq_state);
return retval;
}
int tsrb_add(tsrb_t *rb, const uint8_t *src, size_t n)
{
size_t tmp = n;
unsigned irq_state = irq_disable();
while (tmp && !tsrb_full(rb)) {
_push(rb, *src++);
tmp--;
}
int cnt = turb_add(rb, src, n);
irq_restore(irq_state);
return (n - tmp);
return cnt;
}