StarMirror/toxcore
1
0
Fork 0
mirror of https://github.com/irungentoo/toxcore.git synced 2024-03-22 13:30:51 +08:00
Code Issues Projects Releases Wiki Activity

Add comment from #629 in ring_buffer.c.

Browse Source
This commit is contained in:
iphydf 2018-01-21 17:42:19 +00:00
parent 1cecb6c87a
commit 6c98791563
No known key found for this signature in database
GPG Key ID: 3855DBA2D74403C9
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
toxav/ring_buffer.c
View File

@ -34,10 +34,16 @@ bool rb_full(const RingBuffer *b)
{ {
return (b->end + 1) % b->size == b->start; return (b->end + 1) % b->size == b->start;
} }
bool rb_empty(const RingBuffer *b) bool rb_empty(const RingBuffer *b)
{ {
return b->end == b->start; return b->end == b->start;
} }
/*
* returns: NULL on success
* input value "p" on FAILURE -> caller can free on failed rb_write
*/
void *rb_write(RingBuffer *b, void *p) void *rb_write(RingBuffer *b, void *p)
{ {
void *rc = NULL; void *rc = NULL;
@ -55,6 +61,7 @@ void *rb_write(RingBuffer *b, void *p)
return rc; return rc;
} }
bool rb_read(RingBuffer *b, void **p) bool rb_read(RingBuffer *b, void **p)
{ {
if (b->end == b->start) { /* Empty */ if (b->end == b->start) { /* Empty */
@ -66,6 +73,7 @@ bool rb_read(RingBuffer *b, void **p)
b->start = (b->start + 1) % b->size; b->start = (b->start + 1) % b->size;
return true; return true;
} }
RingBuffer *rb_new(int size) RingBuffer *rb_new(int size)
{ {
RingBuffer *buf = (RingBuffer *)calloc(sizeof(RingBuffer), 1); RingBuffer *buf = (RingBuffer *)calloc(sizeof(RingBuffer), 1);
@ -83,6 +91,7 @@ RingBuffer *rb_new(int size)
return buf; return buf;
} }
void rb_kill(RingBuffer *b) void rb_kill(RingBuffer *b)
{ {
if (b) { if (b) {
@ -90,6 +99,7 @@ void rb_kill(RingBuffer *b)
free(b); free(b);
} }
} }
uint16_t rb_size(const RingBuffer *b) uint16_t rb_size(const RingBuffer *b)
{ {
if (rb_empty(b)) { if (rb_empty(b)) {
@ -101,6 +111,7 @@ uint16_t rb_size(const RingBuffer *b)
b->end - b->start : b->end - b->start :
(b->size - b->start) + b->end; (b->size - b->start) + b->end;
} }
uint16_t rb_data(const RingBuffer *b, void **dest) uint16_t rb_data(const RingBuffer *b, void **dest)
{ {
uint16_t i = 0; uint16_t i = 0;