Transports::DataStore::DataStore Class Reference

Detailed Description

This class is used to store samples locally until they are forwarded to other node.

Public Member Functions
	DataStore (Task *task)
	~DataStore (void)
void	addSample (DataSample *sample)
void	addData (const IMC::HistoricData *data)
IMC::HistoricData *	pollCommands (int destination, int size)
IMC::HistoricData *	pollSamples (int size)

Constructor & Destructor Documentation

Transports::DataStore::DataStore::DataStore ( Task *  task )

inline

Transports::DataStore::DataStore::~DataStore ( void  )

inline

Member Function Documentation

void Transports::DataStore::DataStore::addData ( const IMC::HistoricData *  data )

inline

Add a series of historic samples packed as an HistoricData message.

References addSample(), DUNE::Tasks::Task::debug(), DUNE::Tasks::Task::dispatch(), DUNE::Tasks::Task::getSystemId(), Transports::DataStore::parse(), and DUNE::Tasks::Task::resolveSystemId().

Referenced by Transports::DataStore::Task::acousticRouting(), Transports::DataStore::Task::process(), and Transports::DataStore::Task::wifiRouting().

void Transports::DataStore::DataStore::addSample ( DataSample *  sample )

inline

Add sample to this store.

References DUNE::Tasks::Task::debug(), Transports::DataStore::DataSample::sample, and Transports::DataStore::DataSample::timestamp.

Referenced by addData(), and Transports::DataStore::Task::consume().

IMC::HistoricData* Transports::DataStore::DataStore::pollCommands ( int  destination, int  size  )

inline

Retrieve a series of commands that take up to 'size'.

IMC::HistoricData* Transports::DataStore::DataStore::pollSamples ( int  size )

inline

Retrieve a series of sample that take up to 'size'.

References Transports::DataStore::parse(), and Transports::DataStore::DataSample::serializationSize().

Referenced by Transports::DataStore::Task::acousticRouting(), Transports::DataStore::Task::process(), and Transports::DataStore::Task::wifiRouting().

Collaboration diagram for Transports::DataStore::DataStore: