一个简单的ringbuffer (circular buffer) 程序(C语言)

最近需要在使用一个ringbuffer，用于缓冲音频数据。
数据在两个线程之间传递。按说是很简单的功能，但合用的C库还不太好找。
找了一下，看到合适一点的库也是GPL的，不太适合我用在闭源工程中，于是自己重新写了一个简单的，以LGPL方式发行。

功能比较简单，数据分块，每次读或写一个块。
块大小和块数量在ringbuffer初始化时设定。
同时仅支持一个reader和一个writer。

测试环境：
ARM Linux, gcc 4.1.1, uClibc

代码附在后面，其使用方法：

initialize:

    rb_t *rbuf = rb_open(chunk_size, chunk_count);

reader:

    while(rb_read_ok(rb,buf)==false){

        idle_task();

    }

writer:

    while(rb_write_ok(rb,buf)==false){

        idle_task();

    }

deinitialize:

    rb_close(rbuf);

 
ringbuf.h:
#pragma once
#include <stdint.h>
#include <stdbool.h>

struct rb_s;
typedef struct rb_s rb_t;

rb_t *rb_open(unsigned int size, unsigned int count);
void rb_reset(rb_t *rb);
void rb_close(rb_t *rb);
bool rb_writable(rb_t *rb);
bool rb_readable(rb_t *rb);
bool rb_write_ok(rb_t *rb, const void *data);
bool rb_read_ok(rb_t *rb, void *buf);


ringbuf.c:

#include <malloc.h>
#include <string.h>
#include "ringbuf.h"
struct rb_s{
    unsigned int size;
    unsigned int count;
    unsigned int rptr, wptr;
    unsigned char *buf;
};

rb_t *rb_open(unsigned int size, unsigned int count)
{
    rb_t *rb = calloc(1, sizeof(rb_t));
    rb->buf = calloc(count, size);
    if(rb->buf==NULL){
        free(rb);
        return NULL;
    }
    rb->size = size;
    rb->count = count;
    return rb;
}
void rb_reset(rb_t *rb)
{
    rb->wptr = 0;
    rb->rptr = 0;
}

void rb_close(rb_t *rb)
{
    if(rb){
        free(rb->buf);
        memset(rb,0, sizeof(rb_t));
        free(rb);
    }
}

bool rb_writable(rb_t *rb)
{
    unsigned int wptr = rb->wptr;
    wptr++;
    if(wptr>=rb->count) wptr = 0;
    if(wptr == rb->rptr) return false;
    return true;
}

bool rb_readable(rb_t *rb)
{
    if(rb->wptr==rb->rptr) return false;
    return true;
}

bool rb_write_ok(rb_t *rb, const void *data)
{
    if(rb_writable(rb)){
        memcpy(rb->buf+rb->size*rb->wptr,data, rb->size);
        rb->wptr++;
        if(rb->wptr == rb->count) rb->wptr = 0;
        return true;
    }
    return false;
}

bool rb_read_ok(rb_t *rb, void *buf)
{
    if(rb_readable(rb)){
        memcpy(buf, rb->buf+rb->size*rb->rptr, rb->size);
        rb->rptr++;
        if(rb->rptr == rb->count) rb->rptr = 0;
        return true;
    }
    return false;
}