RingBuffer.cpp

Go to the documentation of this file.

 
#include  "RingBuffer.h"
 
 
using namespace jbxl;
 
 
void  CRingBuffer::init_data(void)
{
    buf     = NULL;
    bufsz   = 0;
    datasz  = 0;
    spoint  = 0;
    epoint  = 0;
    datano  = 0;
    state   = 0;
    enable  = FALSE;
}
 
 
BOOL  CRingBuffer::init(int ring_size, int data_size)
{
    init_data();
 
    buf = (void**)malloc(ring_size*sizeof(void*));
    if (buf==NULL) return FALSE;
    memset(buf, 0, ring_size*sizeof(void*));
    bufsz  = ring_size;
    datasz = data_size;
 
    BOOL ret = TRUE;
    for (int i=0; i<bufsz; i++) {
        buf[i] = (void*)malloc(datasz);
        if (buf[i]==NULL) {
            this->free();
            ret = FALSE;
            state = -1;
            break;
        }
        memset(buf[i], 0, datasz);
    }
 
    if (ret) enable = TRUE;
    return ret;
}
 
 
void  CRingBuffer::free(void)
{
    if (!isNull(buf)) {
        for (int i=0; i<bufsz; i++) {
            if (!isNull(buf[i])) {
                ::free(buf[i]);
            }
        }
        ::free(buf);
    }    
    init_data();
 
    return;
}
 
 
void  CRingBuffer::clear(void)
{
    for (int i=0; i<bufsz; i++) {
        memset(buf[i], 0, datasz);
    }
    spoint  = 0;
    epoint  = 0;
    datano  = 0;
    state   = 0;
 
    return;
}
 
 
void* CRingBuffer::get(void)
{
    void* ptr = NULL;
 
    if (datano>0) {
        ptr = buf[spoint];
        spoint++;
        if (spoint==bufsz) spoint = 0;
        datano--;
    }
 
    return ptr;
}
 
 
void* CRingBuffer::get(int pos)
{
    pos = epoint + pos;
    if (pos<0) pos = bufsz + pos % bufsz;
    else       pos = pos % bufsz;
 
    return buf[pos];
}
 
 
void  CRingBuffer::put(void* ptr)
{
    memcpy(buf[epoint], ptr, datasz);
    epoint++;
    if (epoint==bufsz) epoint = 0;
    if (datano<bufsz)  datano++;
 
    return;
}
 
 
void  CRingBuffer::put(void* ptr, int pos)
{
    pos = epoint + pos;
    if (pos<0) pos = bufsz + pos % bufsz;
    else       pos = pos % bufsz;
 
    memcpy(buf[pos], ptr, datasz);
 
    return;
}