nidas::core::SampleArchiver Class Reference

#include <SampleArchiver.h>

Inheritance diagram for nidas::core::SampleArchiver:

Public Member Functions
	SampleArchiver ()
virtual	~SampleArchiver ()
void	flush () throw ()
	Implementation of SampleSource::flush().
void	setRaw (bool val)
	By default a SampleArchiver is used for archiving raw samples, and any SampleOutputs that connect will receive samples from source->getRawSampleSource(), even if the output->isRaw() method returns false.
bool	getRaw () const
void	connectSource (SampleSource *) override
	Implementation of SampleIOProcessor::connectSource(SampleSource*).
void	disconnectSource (SampleSource *) throw ()
	Implementation of SampleIOProcessor::disconnectSource(SampleSource*).
void	connect (SampleOutput *output) throw ()
	Implementation of SampleConnectionRequester::connect(SampleOutput*).
void	disconnect (SampleOutput *output) throw ()
	Implementation of SampleConnectionRequester::disconnect(SampleOutput*).
void	printStatus (std::ostream &, float deltat, int &) throw ()
virtual const std::string &	getName () const
virtual void	setName (const std::string &val)
virtual void	setOptional (bool val)
virtual bool	isOptional () const
virtual const DSMService *	getService () const
	What DSMService am I associated with?
virtual void	setService (const DSMService *val)
virtual const DSMConfig *	getDSMConfig () const
	What DSM am I associated with?
virtual void	setDSMConfig (const DSMConfig *val)
dsm_sample_id_t	getId () const
void	setSampleId (int val)
unsigned int	getSampleId () const
SampleSource *	getRawSampleSource ()
	Several objects in NIDAS can be both a SampleSource of raw Samples and processed Samples.
SampleSource *	getProcessedSampleSource ()
	Several objects in NIDAS can be both a SampleSource of raw Samples and processed Samples.
virtual void	addRequestedSampleTag (SampleTag *tag)
	Add a request for a SampleTag from this SampleIOProcessor.
virtual std::list< const SampleTag * >	getRequestedSampleTags () const
void	addSampleTag (const SampleTag *tag) throw ()
	Implementation of SampleSource::addSampleTag().
void	removeSampleTag (const SampleTag *tag) throw ()
std::list< const SampleTag * >	getSampleTags () const
	Implementation of SampleSource::getSampleTags().
SampleTagIterator	getSampleTagIterator () const
	Implementation of SampleSource::getSampleTagIterator().
void	addSampleClient (SampleClient *client) throw ()
	Implementation of SampleSource::addSampleClient().
void	removeSampleClient (SampleClient *client) throw ()
	Remove a SampleClient from this SampleSource.
void	addSampleClientForTag (SampleClient *client, const SampleTag *tag) throw ()
	Add a Client for a given SampleTag.
void	removeSampleClientForTag (SampleClient *client, const SampleTag *tag) throw ()
	Remove a SampleClient for a given SampleTag from this SampleSource.
int	getClientCount () const throw ()
	How many SampleClients are currently in my list.
const SampleStats &	getSampleStats () const
virtual void	addOutput (SampleOutput *val)
	Add an SampleOutput to this SampleIOProcessor.
virtual const std::list< SampleOutput * > &	getOutputs () const
void	addParameter (Parameter *val)
	Add a parameter to this SampleIOProcessor, which will then own the pointer and will delete it in its destructor.
const std::list< const Parameter * > &	getParameters () const
	Get list of parameters.
void	fromDOMElement (const xercesc::DOMElement *node)
virtual void	init (dsm_time_t) throw ()
virtual xercesc::DOMElement *	toDOMParent (xercesc::DOMElement *parent, bool complete) const
	Create a DOMElement and append it to the parent.
virtual xercesc::DOMElement *	toDOMElement (xercesc::DOMElement *node, bool complete) const
	Add my content into a DOMElement.

Static Public Member Functions
static const XMLCh *	getNamespaceURI ()

Protected Member Functions
void	removeRequestedSampleTag (SampleTag *tag)
	Allow subclasses to remove requested SampleTags.

Protected Attributes
SampleSourceSupport	_source
nidas::util::Mutex	_tagsMutex
std::list< SampleTag * >	_requestedTags

Private Member Functions
	SampleArchiver (const SampleArchiver &x)
	Copy not supported.
SampleArchiver &	operator= (const SampleArchiver &x)
	Assignment not supported.

Private Attributes
nidas::util::Mutex	_connectionMutex
std::set< SampleSource * >	_connectedSources
std::set< SampleOutput * >	_connectedOutputs
std::list< const nidas::core::FileSet * >	_filesets
	If my SampleOutput* is a nidas::core::FileSet then save the pointer for use in by printStatus(), so that the status output will contain things like the file size.
nidas::util::Mutex	_filesetMutex
	Mutex for controlling access to _filesets so that printStatus has valid pointers.
size_t	_nsampsLast
	Saved between calls to printStatus in order to compute sample rates.
long long	_nbytesLast
	Saved between calls to printStatus in order to compute data rates.
std::map< const nidas::core::FileSet *, long long >	_nbytesLastByFileSet
bool	_rawArchive
std::string	_name
dsm_sample_id_t	_id
std::list< const SampleTag * >	_constRequestedTags
std::list< SampleOutput * >	_origOutputs
bool	_optional
const DSMService *	_service
	What service am I a part of?
const DSMConfig *	_dsm
	Or, what DSM am I a part of?
std::list< Parameter * >	_parameters
std::list< const Parameter * >	_constParameters

Static Private Attributes
static XMLCh *	namespaceURI = 0

Constructor & Destructor Documentation

SampleArchiver() [1/2]

SampleArchiver::SampleArchiver

(

)

References nidas::core::SampleIOProcessor::setName().

~SampleArchiver()

SampleArchiver::~SampleArchiver ( )

virtual

References _connectedOutputs, _connectedSources, _connectionMutex, nidas::core::SampleOutput::close(), nidas::core::SampleClient::flush(), nidas::core::SampleOutput::getName(), nidas::core::SampleOutput::getOriginal(), nidas::core::getSample(), nidas::util::Mutex::lock(), LOG_ERR, nidas::core::SampleSource::removeSampleClient(), and nidas::util::Mutex::unlock().

SampleArchiver() [2/2]

nidas::core::SampleArchiver::SampleArchiver ( const SampleArchiver & x )

private

Copy not supported.

Member Function Documentation

addOutput()

virtual void nidas::core::SampleIOProcessor::addOutput ( SampleOutput * val )

inlinevirtualinherited

Add an SampleOutput to this SampleIOProcessor.

This is used to add a desired SampleOutput to this SampleIOProcessor. SampleIOProcessor will own the SampleOutput. Once a SampleSource has connected, then SampleIOProcessor is responsible for do SampleOutput::requestConnection, or SampleOutputRequestThread::addConnectRequest() on all these as-yet disconnected outputs.

References nidas::core::SampleIOProcessor::_origOutputs.

Referenced by nidas::core::SampleIOProcessor::fromDOMElement().

addParameter()

void SampleIOProcessor::addParameter ( Parameter * val )

inherited

Add a parameter to this SampleIOProcessor, which will then own the pointer and will delete it in its destructor.

If a Parameter exists with the same name, it will be replaced with the new Parameter.

Exceptions

nidas::util::InvalidParameterException

References nidas::core::SampleIOProcessor::_constParameters, and nidas::core::SampleIOProcessor::_parameters.

Referenced by nidas::core::SampleIOProcessor::fromDOMElement().

addRequestedSampleTag()

void SampleIOProcessor::addRequestedSampleTag ( SampleTag * tag )

virtualinherited

Add a request for a SampleTag from this SampleIOProcessor.

This SampleIOProcessor will own the SampleTag.

Exceptions

nidas::util::InvalidParameterException

Reimplemented in nidas::dynld::raf::CVIProcessor, and nidas::dynld::StatisticsProcessor.

References nidas::core::SampleIOProcessor::_constRequestedTags, nidas::core::SampleIOProcessor::_requestedTags, nidas::core::SampleIOProcessor::_tagsMutex, and nidas::core::getSample().

Referenced by nidas::dynld::raf::CVIProcessor::addRequestedSampleTag(), nidas::dynld::StatisticsProcessor::addRequestedSampleTag(), and nidas::core::SampleIOProcessor::fromDOMElement().

addSampleClient()

void nidas::core::SampleIOProcessor::addSampleClient ( SampleClient * client ) throw (  )

inlinevirtualinherited

Implementation of SampleSource::addSampleClient().

Implements nidas::core::SampleSource.

Reimplemented in nidas::dynld::raf::SyncRecordGenerator.

References nidas::core::SampleIOProcessor::_source, and nidas::core::SampleSourceSupport::addSampleClient().

addSampleClientForTag()

void nidas::core::SampleIOProcessor::addSampleClientForTag ( SampleClient * client, const SampleTag * tag ) throw (  )

inlinevirtualinherited

Add a Client for a given SampleTag.

Implementation of SampleSource::addSampleClient().

Implements nidas::core::SampleSource.

Reimplemented in nidas::dynld::raf::SyncRecordGenerator.

References nidas::core::SampleIOProcessor::_source, and nidas::core::SampleSourceSupport::addSampleClientForTag().

addSampleTag()

void SampleIOProcessor::addSampleTag ( const SampleTag * tag ) throw (  )

virtualinherited

Implementation of SampleSource::addSampleTag().

Implements nidas::core::SampleSource.

Referenced by nidas::dynld::raf::CVIProcessor::addRequestedSampleTag(), and nidas::dynld::StatisticsProcessor::connectSource().

connect()

void SampleArchiver::connect ( SampleOutput * output ) throw (  )

virtual

Implementation of SampleConnectionRequester::connect(SampleOutput*).

Implements nidas::core::SampleConnectionRequester.

References nidas::core::SampleSource::addSampleClient(), nidas::core::getSample(), ILOG, VLOG, and WLOG.

connectSource()

void SampleArchiver::connectSource ( SampleSource * source )

overridevirtual

Implementation of SampleIOProcessor::connectSource(SampleSource*).

Implements nidas::core::SampleIOProcessor.

References _connectedOutputs, _connectedSources, _connectionMutex, nidas::core::SampleSource::addSampleClient(), nidas::core::SampleOutput::addSourceSampleTags(), nidas::core::SampleOutputRequestThread::getInstance(), nidas::core::SampleIOProcessor::getOutputs(), nidas::core::SampleSource::getProcessedSampleSource(), getRaw(), nidas::core::SampleSource::getRawSampleSource(), nidas::core::getSample(), and nidas::core::SampleSource::getSampleTags().

disconnect()

void SampleArchiver::disconnect ( SampleOutput * output ) throw (  )

virtual

Implementation of SampleConnectionRequester::disconnect(SampleOutput*).

Implements nidas::core::SampleConnectionRequester.

References nidas::core::SampleOutputRequestThread::getInstance(), nidas::core::SampleOutput::getOriginal(), nidas::core::getSample(), ILOG, LOG_ERR, and nidas::core::SampleSource::removeSampleClient().

disconnectSource()

void SampleArchiver::disconnectSource ( SampleSource * source ) throw (  )

virtual

Implementation of SampleIOProcessor::disconnectSource(SampleSource*).

Implements nidas::core::SampleIOProcessor.

References nidas::core::SampleSource::getProcessedSampleSource(), nidas::core::SampleSource::getRawSampleSource(), and nidas::core::getSample().

flush()

void SampleArchiver::flush ( ) throw (  )

virtual

Implementation of SampleSource::flush().

Implements nidas::core::SampleSource.

References _connectedOutputs, _connectionMutex, nidas::core::SampleClient::flush(), and nidas::core::getSample().

fromDOMElement()

void SampleIOProcessor::fromDOMElement ( const xercesc::DOMElement * node )

virtualinherited

Exceptions

nidas::util::InvalidParameterException

Implements nidas::core::DOMable.

References nidas::core::SampleIOProcessor::_origOutputs, nidas::core::SampleIOProcessor::addOutput(), nidas::core::SampleIOProcessor::addParameter(), nidas::core::SampleIOProcessor::addRequestedSampleTag(), nidas::core::DOMObjectFactory::createObject(), nidas::core::Parameter::createParameter(), nidas::core::SampleTag::fromDOMElement(), nidas::core::DOMable::fromDOMElement(), nidas::core::SampleIOProcessor::getId(), nidas::core::Project::getInstance(), nidas::core::SampleIOProcessor::getRequestedSampleTags(), nidas::core::getSample(), nidas::core::SampleTag::getSampleId(), nidas::core::SampleIOProcessor::setOptional(), nidas::core::SampleIOProcessor::setSampleId(), nidas::core::SampleTag::setSampleId(), nidas::core::SampleTag::setSensorId(), and WLOG.

Referenced by nidas::dynld::raf::CVIProcessor::fromDOMElement().

getClientCount()

int nidas::core::SampleIOProcessor::getClientCount ( ) const throw (  )

inlinevirtualinherited

How many SampleClients are currently in my list.

Exceptions

)

Implements nidas::core::SampleSource.

Reimplemented in nidas::dynld::raf::SyncRecordGenerator.

References nidas::core::SampleIOProcessor::_source, and nidas::core::SampleSourceSupport::getClientCount().

getDSMConfig()

virtual const DSMConfig * nidas::core::SampleIOProcessor::getDSMConfig ( ) const

inlinevirtualinherited

What DSM am I associated with?

References nidas::core::SampleIOProcessor::_dsm.

Referenced by nidas::dynld::raf::CVIProcessor::addRequestedSampleTag().

getId()

dsm_sample_id_t nidas::core::SampleIOProcessor::getId ( ) const

inlineinherited

References nidas::core::SampleIOProcessor::_id, and GET_FULL_ID.

Referenced by nidas::core::SampleIOProcessor::fromDOMElement().

getName()

const std::string & SampleIOProcessor::getName ( ) const

virtualinherited

References nidas::core::SampleIOProcessor::_name.

Referenced by nidas::dynld::StatisticsProcessor::addRequestedSampleTag(), nidas::dynld::StatisticsProcessor::connectSource(), nidas::dynld::raf::CVIProcessor::fromDOMElement(), nidas::dynld::raf::CVIProcessor::~CVIProcessor(), and nidas::dynld::StatisticsProcessor::~StatisticsProcessor().

getNamespaceURI()

static const XMLCh * nidas::core::DOMable::getNamespaceURI ( )

inlinestaticinherited

References nidas::core::DOMable::namespaceURI.

Referenced by nidas::dynld::UDPSampleOutput::getProjectDOM(), nidas::core::Dataset::toDOMElement(), nidas::core::ProjectConfig::toDOMElement(), nidas::core::Dataset::toDOMParent(), nidas::core::Datasets::toDOMParent(), nidas::core::ProjectConfig::toDOMParent(), nidas::core::ProjectConfigs::toDOMParent(), nidas::core::DSMConfig::toDOMParent(), nidas::core::DSMSensor::toDOMParent(), nidas::core::Project::toDOMParent(), nidas::core::SampleTag::toDOMParent(), nidas::core::Site::toDOMParent(), nidas::core::ServerSocket::toDOMParent(), nidas::core::Variable::toDOMParent(), nidas::core::Datasets::writeXML(), and nidas::core::ProjectConfigs::writeXML().

getOutputs()

virtual const std::list< SampleOutput * > & nidas::core::SampleIOProcessor::getOutputs ( ) const

inlinevirtualinherited

References nidas::core::SampleIOProcessor::_origOutputs.

Referenced by connectSource(), nidas::dynld::raf::CVIProcessor::connectSource(), nidas::dynld::SampleProcessor::connectSource(), nidas::dynld::StatisticsProcessor::connectSource(), nidas::dynld::raf::SyncRecordGenerator::connectSource(), and nidas::core::Project::findServerSampleOutputStreamFileSets().

getParameters()

const std::list< const Parameter * > & nidas::core::SampleIOProcessor::getParameters ( ) const

inlineinherited

Get list of parameters.

References nidas::core::SampleIOProcessor::_constParameters.

Referenced by nidas::dynld::raf::CVIProcessor::fromDOMElement().

getProcessedSampleSource()

SampleSource * nidas::core::SampleIOProcessor::getProcessedSampleSource ( )

inlinevirtualinherited

Several objects in NIDAS can be both a SampleSource of raw Samples and processed Samples.

SampleClients use this method to get a pointer to whatever sample source they are interested in. Derived classes can return NULL if they are not a SampleSource of processed samples.

Implements nidas::core::SampleSource.

References nidas::core::SampleIOProcessor::_source.

getRaw()

bool nidas::core::SampleArchiver::getRaw ( ) const

inline

References _rawArchive.

Referenced by connectSource().

getRawSampleSource()

SampleSource * nidas::core::SampleIOProcessor::getRawSampleSource ( )

inlinevirtualinherited

Several objects in NIDAS can be both a SampleSource of raw Samples and processed Samples.

SampleClients use this method to get a pointer to whatever sample source they are interested in. Derived classes can return NULL if they are not a SampleSource of raw samples.

Implements nidas::core::SampleSource.

getRequestedSampleTags()

std::list< const SampleTag * > SampleIOProcessor::getRequestedSampleTags ( ) const

virtualinherited

References nidas::core::SampleIOProcessor::_constRequestedTags, nidas::core::SampleIOProcessor::_tagsMutex, and nidas::core::getSample().

Referenced by nidas::dynld::StatisticsProcessor::addRequestedSampleTag(), nidas::dynld::StatisticsProcessor::connectSource(), nidas::core::SampleIOProcessor::fromDOMElement(), and nidas::core::SampleTagIterator::hasNext().

getSampleId()

unsigned int nidas::core::SampleIOProcessor::getSampleId ( ) const

inlineinherited

References nidas::core::SampleIOProcessor::_id, and GET_SPS_ID.

Referenced by nidas::dynld::StatisticsProcessor::selectRequestedSampleTags().

getSampleStats()

const SampleStats & nidas::core::SampleIOProcessor::getSampleStats ( ) const

inlinevirtualinherited

Implements nidas::core::SampleSource.

Reimplemented in nidas::dynld::raf::SyncRecordGenerator.

References nidas::core::SampleIOProcessor::_source, and nidas::core::SampleSourceSupport::getSampleStats().

getSampleTagIterator()

SampleTagIterator nidas::core::SampleIOProcessor::getSampleTagIterator ( ) const

inlinevirtualinherited

Implementation of SampleSource::getSampleTagIterator().

Implements nidas::core::SampleSource.

Reimplemented in nidas::dynld::raf::SyncRecordGenerator.

References nidas::core::SampleIOProcessor::_source, and nidas::core::SampleSourceSupport::getSampleTagIterator().

getSampleTags()

std::list< const SampleTag * > nidas::core::SampleIOProcessor::getSampleTags ( ) const

inlinevirtualinherited

Implementation of SampleSource::getSampleTags().

Implements nidas::core::SampleSource.

Reimplemented in nidas::dynld::raf::SyncRecordGenerator.

References nidas::core::SampleIOProcessor::_source, and nidas::core::SampleSourceSupport::getSampleTags().

Referenced by nidas::dynld::raf::CVIProcessor::addRequestedSampleTag(), nidas::dynld::raf::CVIProcessor::connectSource(), and nidas::dynld::StatisticsProcessor::connectSource().

getService()

virtual const DSMService * nidas::core::SampleIOProcessor::getService ( ) const

inlinevirtualinherited

What DSMService am I associated with?

References nidas::core::SampleIOProcessor::_service.

init()

virtual void nidas::core::SampleIOProcessor::init ( dsm_time_t ) throw (  )

inlinevirtualinherited

Reimplemented in nidas::dynld::raf::SyncRecordGenerator.

isOptional()

virtual bool nidas::core::SampleIOProcessor::isOptional ( ) const

inlinevirtualinherited

References nidas::core::SampleIOProcessor::_optional.

operator=()

SampleArchiver & nidas::core::SampleArchiver::operator= ( const SampleArchiver & x )

private

Assignment not supported.

printStatus()

void SampleArchiver::printStatus ( std::ostream & , float deltat, int &  ) throw (  )

virtual

Reimplemented from nidas::core::SampleIOProcessor.

References err, nidas::util::UTime::format(), nidas::core::getSample(), and nidas::core::SampleSource::getSampleStats().

removeRequestedSampleTag()

void SampleIOProcessor::removeRequestedSampleTag ( SampleTag * tag )

protectedinherited

Allow subclasses to remove requested SampleTags.

The tag will be deleted.

References nidas::core::SampleIOProcessor::_constRequestedTags, nidas::core::SampleIOProcessor::_requestedTags, nidas::core::SampleIOProcessor::_tagsMutex, and nidas::core::getSample().

Referenced by nidas::dynld::StatisticsProcessor::selectRequestedSampleTags().

removeSampleClient()

void nidas::core::SampleIOProcessor::removeSampleClient ( SampleClient * c ) throw (  )

inlinevirtualinherited

Remove a SampleClient from this SampleSource.

Exceptions

)

Implements nidas::core::SampleSource.

Reimplemented in nidas::dynld::raf::SyncRecordGenerator.

References nidas::core::SampleIOProcessor::_source, and nidas::core::SampleSourceSupport::removeSampleClient().

removeSampleClientForTag()

void nidas::core::SampleIOProcessor::removeSampleClientForTag ( SampleClient * c, const SampleTag *  ) throw (  )

inlinevirtualinherited

Remove a SampleClient for a given SampleTag from this SampleSource.

The pointer to the SampleClient must remain valid, until after it is removed.

Exceptions

)

Implements nidas::core::SampleSource.

Reimplemented in nidas::dynld::raf::SyncRecordGenerator.

References nidas::core::SampleIOProcessor::_source, and nidas::core::SampleSourceSupport::removeSampleClientForTag().

removeSampleTag()

void SampleIOProcessor::removeSampleTag ( const SampleTag * ) throw (  )

virtualinherited

Exceptions

)

Implements nidas::core::SampleSource.

setDSMConfig()

virtual void nidas::core::SampleIOProcessor::setDSMConfig ( const DSMConfig * val )

inlinevirtualinherited

References nidas::core::SampleIOProcessor::_dsm, and nidas::core::getSample().

setName()

void SampleIOProcessor::setName ( const std::string & val )

virtualinherited

References nidas::core::SampleIOProcessor::_name, and nidas::core::getSample().

Referenced by SampleArchiver(), nidas::dynld::StatisticsProcessor::StatisticsProcessor(), and nidas::dynld::raf::SyncRecordGenerator::SyncRecordGenerator().

setOptional()

virtual void nidas::core::SampleIOProcessor::setOptional ( bool val )

inlinevirtualinherited

References nidas::core::SampleIOProcessor::_optional, and nidas::core::getSample().

Referenced by nidas::core::SampleIOProcessor::fromDOMElement().

setRaw()

void nidas::core::SampleArchiver::setRaw ( bool val )

inline

By default a SampleArchiver is used for archiving raw samples, and any SampleOutputs that connect will receive samples from source->getRawSampleSource(), even if the output->isRaw() method returns false.

This is to correct possible human errors in the configuation. If setRaw(false), then this SampleArchiver will archive processed samples, by connecting outputs to source->getProcessedSampleSource(). If the value of an output->isRaw() disgrees with getRaw() of this SampleArchive, a warning message is logged.

References _rawArchive, and nidas::core::getSample().

setSampleId()

void nidas::core::SampleIOProcessor::setSampleId ( int val )

inlineinherited

References nidas::core::SampleIOProcessor::_id, and SET_SPS_ID.

Referenced by nidas::core::SampleIOProcessor::fromDOMElement().

setService()

virtual void nidas::core::SampleIOProcessor::setService ( const DSMService * val )

inlinevirtualinherited

References nidas::core::SampleIOProcessor::_service, and nidas::core::getSample().

toDOMElement()

xercesc::DOMElement * DOMable::toDOMElement ( xercesc::DOMElement * node, bool complete ) const

virtualinherited

Add my content into a DOMElement.

Exceptions

xercesc::DOMException

Reimplemented in nidas::core::DSMConfig, nidas::core::DSMSensor, nidas::core::Project, nidas::core::SampleTag, nidas::core::Site, nidas::core::ServerSocket, and nidas::core::Variable.

Referenced by nidas::core::ServerSocket::toDOMParent().

toDOMParent()

xercesc::DOMElement * DOMable::toDOMParent ( xercesc::DOMElement * parent, bool complete ) const

virtualinherited

Create a DOMElement and append it to the parent.

Exceptions

xercesc::DOMException

Reimplemented in nidas::core::DSMConfig, nidas::core::DSMSensor, nidas::core::Project, nidas::core::SampleTag, nidas::core::Site, nidas::core::ServerSocket, and nidas::core::Variable.

Member Data Documentation

_connectedOutputs

std::set<SampleOutput*> nidas::core::SampleArchiver::_connectedOutputs

private

Referenced by connectSource(), flush(), and ~SampleArchiver().

_connectedSources

std::set<SampleSource*> nidas::core::SampleArchiver::_connectedSources

private

Referenced by connectSource(), and ~SampleArchiver().

_connectionMutex

nidas::util::Mutex nidas::core::SampleArchiver::_connectionMutex

private

Referenced by connectSource(), flush(), and ~SampleArchiver().

_constParameters

std::list<const Parameter*> nidas::core::SampleIOProcessor::_constParameters

privateinherited

Referenced by nidas::core::SampleIOProcessor::addParameter(), and nidas::core::SampleIOProcessor::getParameters().

_constRequestedTags

std::list<const SampleTag*> nidas::core::SampleIOProcessor::_constRequestedTags

privateinherited

Referenced by nidas::core::SampleIOProcessor::addRequestedSampleTag(), nidas::core::SampleIOProcessor::getRequestedSampleTags(), and nidas::core::SampleIOProcessor::removeRequestedSampleTag().

_dsm

const DSMConfig* nidas::core::SampleIOProcessor::_dsm

privateinherited

Or, what DSM am I a part of?

Referenced by nidas::core::SampleIOProcessor::getDSMConfig(), and nidas::core::SampleIOProcessor::setDSMConfig().

_filesetMutex

nidas::util::Mutex nidas::core::SampleArchiver::_filesetMutex

private

Mutex for controlling access to _filesets so that printStatus has valid pointers.

_filesets

std::list<const nidas::core::FileSet*> nidas::core::SampleArchiver::_filesets

private

If my SampleOutput* is a nidas::core::FileSet then save the pointer for use in by printStatus(), so that the status output will contain things like the file size.

_id

dsm_sample_id_t nidas::core::SampleIOProcessor::_id

privateinherited

Referenced by nidas::core::SampleIOProcessor::getId(), nidas::core::SampleIOProcessor::getSampleId(), and nidas::core::SampleIOProcessor::setSampleId().

_name

std::string nidas::core::SampleIOProcessor::_name

privateinherited

Referenced by nidas::core::SampleIOProcessor::getName(), and nidas::core::SampleIOProcessor::setName().

_nbytesLast

long long nidas::core::SampleArchiver::_nbytesLast

private

Saved between calls to printStatus in order to compute data rates.

_nbytesLastByFileSet

std::map<const nidas::core::FileSet*,long long> nidas::core::SampleArchiver::_nbytesLastByFileSet

private

_nsampsLast

size_t nidas::core::SampleArchiver::_nsampsLast

private

Saved between calls to printStatus in order to compute sample rates.

_optional

bool nidas::core::SampleIOProcessor::_optional

privateinherited

Referenced by nidas::core::SampleIOProcessor::isOptional(), and nidas::core::SampleIOProcessor::setOptional().

_origOutputs

std::list<SampleOutput*> nidas::core::SampleIOProcessor::_origOutputs

privateinherited

Referenced by nidas::core::SampleIOProcessor::addOutput(), nidas::core::SampleIOProcessor::fromDOMElement(), nidas::core::SampleIOProcessor::getOutputs(), and nidas::core::SampleIOProcessor::~SampleIOProcessor().

_parameters

std::list<Parameter*> nidas::core::SampleIOProcessor::_parameters

privateinherited

Referenced by nidas::core::SampleIOProcessor::addParameter(), and nidas::core::SampleIOProcessor::~SampleIOProcessor().

_rawArchive

bool nidas::core::SampleArchiver::_rawArchive

private

Referenced by getRaw(), and setRaw().

_requestedTags

std::list<SampleTag*> nidas::core::SampleIOProcessor::_requestedTags

protectedinherited

Referenced by nidas::core::SampleIOProcessor::addRequestedSampleTag(), nidas::core::SampleIOProcessor::removeRequestedSampleTag(), nidas::dynld::StatisticsProcessor::selectRequestedSampleTags(), and nidas::core::SampleIOProcessor::~SampleIOProcessor().

_service

const DSMService* nidas::core::SampleIOProcessor::_service

privateinherited

What service am I a part of?

Referenced by nidas::core::SampleIOProcessor::getService(), and nidas::core::SampleIOProcessor::setService().

_source

SampleSourceSupport nidas::core::SampleIOProcessor::_source

protectedinherited

Referenced by nidas::core::SampleIOProcessor::addSampleClient(), nidas::core::SampleIOProcessor::addSampleClientForTag(), nidas::core::SampleIOProcessor::getClientCount(), nidas::core::SampleIOProcessor::getProcessedSampleSource(), nidas::core::SampleIOProcessor::getSampleStats(), nidas::core::SampleIOProcessor::getSampleTagIterator(), nidas::core::SampleIOProcessor::getSampleTags(), nidas::core::SampleIOProcessor::removeSampleClient(), and nidas::core::SampleIOProcessor::removeSampleClientForTag().

_tagsMutex

nidas::util::Mutex nidas::core::SampleIOProcessor::_tagsMutex

mutableprotectedinherited

Referenced by nidas::core::SampleIOProcessor::addRequestedSampleTag(), nidas::core::SampleIOProcessor::getRequestedSampleTags(), nidas::core::SampleIOProcessor::removeRequestedSampleTag(), and nidas::dynld::StatisticsProcessor::selectRequestedSampleTags().

namespaceURI

XMLCh * DOMable::namespaceURI = 0

staticprivateinherited

Referenced by nidas::core::DOMable::getNamespaceURI().

---

The documentation for this class was generated from the following files:

• nidas/core/SampleArchiver.h
• nidas/core/SampleArchiver.cc