Public Member Functions | |
LBDataProvider (const code::URL &lbName, bool readAllMessages) | |
Constructor: Will keep a lb in open mode and constanly read this lb using readData() method. | |
virtual | ~LBDataProvider () |
void | readAndProcessData (size_t msgId, int msgLen) |
Read msgLen data at msgId from lb. | |
virtual int | readData () |
Reads data from the linear buffer returns number of bytes read from one message. | |
Protected Attributes | |
code::LinearBuffer | lb |
code::URL | lbName |
bool | readEntireLB |
size_t | lastReadMsgId |
code::LBDataProvider::LBDataProvider | ( | const code::URL & | lbName, | |
bool | readAllMessages | |||
) |
Constructor: Will keep a lb in open mode and constanly read this lb using readData() method.
virtual code::LBDataProvider::~LBDataProvider | ( | ) | [virtual] |
void code::LBDataProvider::readAndProcessData | ( | size_t | msgId, | |
int | msgLen | |||
) |
Read msgLen data at msgId from lb.
Convert data to netcdf files.
virtual int code::LBDataProvider::readData | ( | ) | [virtual] |
Reads data from the linear buffer returns number of bytes read from one message.
Typically, you will keep calling readData() indefinitely in real-time, and until it returns zero for archive.
size_t code::LBDataProvider::lastReadMsgId [protected] |
code::LinearBuffer code::LBDataProvider::lb [protected] |
code::URL code::LBDataProvider::lbName [protected] |
bool code::LBDataProvider::readEntireLB [protected] |