28 #ifndef NIDAS_CORE_SAMPLEARCHIVER_H
29 #define NIDAS_CORE_SAMPLEARCHIVER_H
36 namespace nidas {
namespace core {
93 void printStatus(std::ostream&,
float deltat,
int&) throw();
nidas::util::Mutex _filesetMutex
Mutex for controlling access to _filesets so that printStatus has valid pointers. ...
Definition: SampleArchiver.h:114
bool getRaw() const
Definition: SampleArchiver.h:68
std::list< const nidas::core::FileSet * > _filesets
If my SampleOutput* is a nidas::core::FileSet then save the pointer for use in by printStatus()...
Definition: SampleArchiver.h:108
void disconnectSource(SampleSource *)
Implementation of SampleIOProcessor::disconnectSource(SampleSource*).
Definition: SampleArchiver.cc:114
Implementation of an IOChannel using an nidas::util::FileSet.
Definition: FileSet.h:42
std::map< const nidas::core::FileSet *, long long > _nbytesLastByFileSet
Definition: SampleArchiver.h:126
Interface of an output stream of samples.
Definition: SampleOutput.h:47
Pure virtual interface for a source of Samples.
Definition: SampleSource.h:48
void connectSource(SampleSource *) override
Implementation of SampleIOProcessor::connectSource(SampleSource*).
Definition: SampleArchiver.cc:79
std::set< SampleOutput * > _connectedOutputs
Definition: SampleArchiver.h:101
long long _nbytesLast
Saved between calls to printStatus in order to compute data rates.
Definition: SampleArchiver.h:124
void flush()
Implementation of SampleSource::flush().
Definition: SampleArchiver.cc:214
void setRaw(bool val)
By default a SampleArchiver is used for archiving raw samples, and any SampleOutputs that connect wil...
Definition: SampleArchiver.h:63
Definition: SampleArchiver.h:38
void connect(SampleOutput *output)
Implementation of SampleConnectionRequester::connect(SampleOutput*).
Definition: SampleArchiver.cc:136
void printStatus(std::ostream &, float deltat, int &)
Definition: SampleArchiver.cc:225
size_t _nsampsLast
Saved between calls to printStatus in order to compute sample rates.
Definition: SampleArchiver.h:119
void disconnect(SampleOutput *output)
Implementation of SampleConnectionRequester::disconnect(SampleOutput*).
Definition: SampleArchiver.cc:169
Interface of a processor of samples.
Definition: SampleIOProcessor.h:49
virtual ~SampleArchiver()
Definition: SampleArchiver.cc:51
SampleArchiver()
Definition: SampleArchiver.cc:42
bool _rawArchive
Definition: SampleArchiver.h:128
nidas::util::Mutex _connectionMutex
Definition: SampleArchiver.h:97
std::set< SampleSource * > _connectedSources
Definition: SampleArchiver.h:99