~awuerl/blitzortung-tracker/0.9

backported most of the 1.0 features

added added

removed removed

namespace blitzortung {

class DataThread {

class DataWorker {

public:

mutable Logger logger_;

//! prepare data for transmission

data::Events::AP prepareData();

data::Events::AP prepareData(int eventsPerSecond);

//! get string to be transmitted for every sample

std::string sampleToString(const data::Event& sample);

public:

//! create network transfer object

DataThread(Queue<data::Event>& sampleQueue, EventCountBuffer& eventCountBuffer, network::transfer::Base& transfer, output::Base&);

DataWorker(Queue<data::Event>& sampleQueue, EventCountBuffer& eventCountBuffer, network::transfer::Base& transfer, output::Base&);

//! delete nework transfer object

virtual ~DataThread();

virtual ~DataWorker();

//! set limit of average number of events per minute transmitted

void setEventRateLimit(const double eventRateLimit);

//! network transfer thread: wait for new samples and send them from time to time

void operator ()();

pt::ptime getSecond() const;

};

}