58 lines
1.5 KiB
C++
58 lines
1.5 KiB
C++
#ifndef _GWBUFFER_H
|
|
#define _GWBUFFER_H
|
|
#include <string.h>
|
|
#include <stdint.h>
|
|
#include "GwLog.h"
|
|
|
|
class GwBufferWriter{
|
|
public:
|
|
int id=0; //can be set be users
|
|
virtual int write(const uint8_t *buffer,size_t len)=0;
|
|
virtual ~GwBufferWriter(){};
|
|
};
|
|
|
|
/**
|
|
* an implementation of a
|
|
* buffer to safely inserte data if it fits
|
|
* and to write out data if possible
|
|
*/
|
|
class GwBuffer{
|
|
public:
|
|
static const size_t BUFFER_SIZE=1620; // app. 20 NMEA messages
|
|
typedef enum {
|
|
OK,
|
|
ERROR,
|
|
AGAIN
|
|
} WriteStatus;
|
|
private:
|
|
size_t bufferSize;
|
|
bool rotate;
|
|
uint8_t *buffer;
|
|
uint8_t *writePointer;
|
|
uint8_t *readPointer;
|
|
size_t offset(uint8_t* ptr){
|
|
return (size_t)(ptr-buffer);
|
|
}
|
|
GwLog *logger;
|
|
void lp(const char *fkt,int p=0);
|
|
/**
|
|
* find the first occurance of x in the buffer, -1 if not found
|
|
*/
|
|
int findChar(char x);
|
|
public:
|
|
GwBuffer(GwLog *logger,size_t bufferSize,bool rotate=true);
|
|
~GwBuffer();
|
|
void reset();
|
|
size_t freeSpace();
|
|
size_t usedSpace();
|
|
size_t addData(const uint8_t *data,size_t len);
|
|
/**
|
|
* write some data to the buffer writer
|
|
* return an error if the buffer writer returned < 0
|
|
*/
|
|
WriteStatus fetchData(GwBufferWriter *writer, int maxLen=-1,bool errorIf0 = true);
|
|
|
|
WriteStatus fetchMessage(GwBufferWriter *writer,char delimiter,bool emptyIfFull=true);
|
|
};
|
|
|
|
#endif |