coco
57 lines
1.2 KiB
C++
57 lines
1.2 KiB
C++
#pragma once
|
|
|
|
#include <map>
|
|
#include <string>
|
|
#include <vector>
|
|
|
|
enum RINGBUFFER_WORK_STATUS
|
|
{
|
|
RINGBUFFER_NORMAL,
|
|
RINGBUFFER_CLOSEWAIT,
|
|
RINGBUFFER_CLOSEACK,
|
|
RINGBUFFER_STOP,
|
|
RINGBUFFER_END //guard status
|
|
};
|
|
|
|
class RingBuffer
|
|
{
|
|
|
|
public:
|
|
RingBuffer();
|
|
RingBuffer(unsigned bufferSize);
|
|
//use pBufferOutside
|
|
RingBuffer(unsigned bufferSize, char* pBuffer);
|
|
virtual ~RingBuffer();
|
|
private:
|
|
volatile int m_iWidx;
|
|
volatile int m_iRIdx;
|
|
char* m_pBuffer;
|
|
unsigned m_uBufferSize;
|
|
|
|
RINGBUFFER_WORK_STATUS m_iWorkStatus;
|
|
//for bufpool
|
|
bool m_bOutsideBuf;
|
|
|
|
int ReadToWidx(unsigned char* pBuf, int iWidx);
|
|
int GetFreeBufferBytes(int iRidx, int iWidx);
|
|
|
|
CRITICAL_SECTION m_csBufMutex;
|
|
|
|
public:
|
|
virtual void Init();
|
|
virtual int Read(unsigned char* pBuf, unsigned readLen);
|
|
virtual int ReadAll(unsigned char* pBuf);
|
|
virtual int Write(const unsigned char* pBuf, unsigned writeLen);
|
|
virtual int Analyze();
|
|
virtual void Stop();
|
|
int GetFreeBufferBytes();
|
|
int GetDataBytes();
|
|
void SetRingBufferSize(unsigned bufferSize);
|
|
char* GetBufferAddr();
|
|
RINGBUFFER_WORK_STATUS GetStatus();
|
|
int SetStatus(RINGBUFFER_WORK_STATUS status);
|
|
void Lock();
|
|
void UnLock();
|
|
int GetBufferSize();
|
|
|
|
}; |