27 #ifndef NIDAS_DYNLD_RAF_SYNCRECORDGENERATOR_H
28 #define NIDAS_DYNLD_RAF_SYNCRECORDGENERATOR_H
33 namespace nidas {
namespace dynld {
namespace raf {
35 using namespace nidas::core;
78 return _syncRecSource.getSampleTags();
86 return _syncRecSource.getSampleTagIterator();
96 _syncRecSource.removeSampleClient(client);
105 _syncRecSource.addSampleClientForTag(client,tag);
110 _syncRecSource.removeSampleClientForTag(client,tag);
115 return _syncRecSource.getClientCount();
123 _syncRecSource.flush();
128 return _syncRecSource.getSampleStats();
131 void printStatus(std::ostream&,
float deltat,
int&) throw();
134 getSyncRecordSource()
136 return &_syncRecSource;
141 void scanSensors(
const std::list<DSMSensor*>& sensors);
size_t _numInputSampsLast
Definition: SyncRecordGenerator.h:155
size_t _numOutputSampsLast
Definition: SyncRecordGenerator.h:157
nidas::util::Mutex _connectionMutex
Definition: SyncRecordGenerator.h:147
Interface of an output stream of samples.
Definition: SampleOutput.h:47
long long dsm_time_t
Posix time in microseconds, the number of non-leap microseconds since 1970 Jan 1 00:00 UTC...
Definition: Sample.h:61
Pure virtual interface for a source of Samples.
Definition: SampleSource.h:48
SampleTagIterator getSampleTagIterator() const
Implementation of SampleSource::getSampleTagIterator().
Definition: SyncRecordGenerator.h:84
std::set< SampleOutput * > _connectedOutputs
Definition: SyncRecordGenerator.h:151
Pure virtual interface of a client of Samples.
Definition: SampleClient.h:38
Definition: SyncRecordSource.h:55
std::set< SampleSource * > _connectedSources
Definition: SyncRecordGenerator.h:149
void removeSampleClientForTag(SampleClient *client, const SampleTag *tag)
Remove a SampleClient for a given SampleTag from this SampleSource.
Definition: SyncRecordGenerator.h:108
int getClientCount() const
How many SampleClients are currently in my list.
Definition: SyncRecordGenerator.h:113
SyncRecordSource _syncRecSource
Definition: SyncRecordGenerator.h:153
Definition: SyncRecordGenerator.h:37
long long _numOutputBytesLast
Definition: SyncRecordGenerator.h:161
Definition: IOException.h:37
Class for iterating over the SampleTags of a Project, Site, DSMConfig, or a SampleSource.
Definition: NidsIterators.h:217
void addSampleClientForTag(SampleClient *client, const SampleTag *tag)
Add a Client for a given SampleTag.
Definition: SyncRecordGenerator.h:103
Class describing a group of variables that are sampled and handled together.
Definition: SampleTag.h:87
Interface of a processor of samples.
Definition: SampleIOProcessor.h:49
std::list< const SampleTag * > getSampleTags() const
Implementation of SampleSource::getSampleTags().
Definition: SyncRecordGenerator.h:76
const SampleStats & getSampleStats() const
Definition: SyncRecordGenerator.h:126
A source of samples.
Definition: SampleStats.h:41
void flush()
Implementation of SampleSource::flush().
Definition: SyncRecordGenerator.h:121
A C++ wrapper for a POSIX mutex.
Definition: ThreadSupport.h:154
void removeSampleClient(SampleClient *client)
Remove a SampleClient from this SampleSource.
Definition: SyncRecordGenerator.h:94
long long _numInputBytesLast
Definition: SyncRecordGenerator.h:159