ringbuffer.h

Go to the documentation of this file.

// SPDX-License-Identifier: AGPL-3.0-or-later
 
#ifndef __SOFTHDRINGBUFFER_H
#define __SOFTHDRINGBUFFER_H
 
#include <cstddef>
 
typedef volatile int atomic_t;  
 
#define atomic_set(ptr, val) __atomic_store_n(ptr, val, __ATOMIC_SEQ_CST)
#define atomic_read(ptr) __atomic_load_n(ptr, __ATOMIC_SEQ_CST)
#define atomic_inc(ptr) __atomic_add_fetch(ptr, 1, __ATOMIC_SEQ_CST)
#define atomic_dec(ptr) __atomic_sub_fetch(ptr, 1, __ATOMIC_SEQ_CST)
#define atomic_add(val, ptr) __atomic_add_fetch(ptr, val, __ATOMIC_SEQ_CST)
#define atomic_sub(val, ptr) __atomic_sub_fetch(ptr, val, __ATOMIC_SEQ_CST)
 
class cSoftHdRingbuffer {
public:
    cSoftHdRingbuffer(size_t);
    ~cSoftHdRingbuffer(void);
    void Reset(void);
    size_t Write(const void *, size_t);
    size_t GetWritePointer(void **);
    size_t WriteAdvance(size_t);
    size_t Read(void *, size_t);
    size_t GetReadPointer(const void **);
    size_t ReadAdvance(size_t);
    size_t FreeBytes(void);
    size_t UsedBytes(void);
 
private:
    char *m_pBuffer;              
    const char *m_pBufferEnd;     
    size_t m_size;                
    const char *m_pReadPointer;   
    char *m_pWritePointer;        
 
    // The only thing modified by both
    atomic_t m_filled;            
};
 
#endif