Implementation of portions of SampleOutput. More...

#include <SampleOutput.h>

Inheritance diagram for nidas::core::SampleOutputBase:

[legend]

Public Member Functions
	SampleOutputBase ()

	SampleOutputBase (IOChannel iochan, SampleConnectionRequester rqstr=0)
	Create a SampleOutput with a connected IOChannel.

	~SampleOutputBase ()

virtual void	setIOChannel (IOChannel *val)
	Set the IOChannel for this SampleOutput.

SampleOutput *	getOriginal () const
	Get pointer to SampleOutput that was cloned.

void	setName (const std::string &val)

const std::string &	getName () const

bool	isRaw () const

void	addRequestedSampleTag (SampleTag *tag)

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

void	addSourceSampleTag (const SampleTag *tag)

void	addSourceSampleTags (const std::list< const SampleTag * > &tags)

std::list< const SampleTag * >	getSourceSampleTags () const

void	requestConnection (SampleConnectionRequester *)
	Request a connection, but don't wait for it.

SampleOutput *	connected (IOChannel *ochan)
	Implementation of IOChannelRequester::connected().

int	getReconnectDelaySecs () const
	Base class implementation.

void	setReconnectDelaySecs (int val)

int	getFd () const

void	close ()

dsm_time_t	getNextFileTime () const

void	createNextFile (dsm_time_t)

size_t	write (const void *buf, size_t len)
	Raw write method, typically used to write the initial header.

void	fromDOMElement (const xercesc::DOMElement *node)

IOChannel *	getIOChannel () const

void	setHeaderSource (HeaderSource *val)

void	setDSMConfig (const DSMConfig *val)

const DSMConfig *	getDSMConfig () const

size_t	getNumDiscardedSamples () const

void	addParameter (Parameter *val)
	Add a parameter to this DSMSensor.

const std::list< const Parameter * > &	getParameters () const
	Get list of parameters.

const Parameter *	getParameter (const std::string &name) const
	Fetch a parameter by name.

void	setLatency (float val)
	Set desired latency, providing some control over the response time vs buffer efficiency tradeoff.

float	getLatency () const

void	setTimeClippingWindow (const nidas::util::UTime &startTime, const nidas::util::UTime &endTime)
	The sample output can have a time window which clips the samples outside the window.

bool	receive (const Sample *s)
	Return true if SampleOutputBase considers the sample handled, such as if it is outside the clipping window.

virtual void	flush ()=0
	Ask that this SampleClient send out any buffered Samples that it may be holding.

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
	SampleOutputBase (SampleOutputBase &, IOChannel *)
	Protected copy constructor, with a new, connected IOChannel.

size_t	incrementDiscardedSamples ()

SampleConnectionRequester *	getSampleConnectionRequester ()

void	disconnect ()
	Close the IOChannel and notify whoever did the requestConnection that it is time to disconnect, perhaps because of an IOException.

virtual SampleOutput *	clone (IOChannel *iochannel)=0

Protected Attributes
std::string	_name

Private Member Functions
	SampleOutputBase (const SampleOutputBase &)
	No copy.

SampleOutputBase &	operator= (const SampleOutputBase &)
	No assignment.

Private Attributes
nidas::util::Mutex	_tagsMutex

std::list< SampleTag * >	_requestedTags

std::list< const SampleTag * >	_constRequestedTags

IOChannel *	_iochan

SampleConnectionRequester *	_connectionRequester

dsm_time_t	_nextFileTime

HeaderSource *	_headerSource

const DSMConfig *	_dsm

size_t	_nsamplesDiscarded

std::map< std::string, Parameter * >	_parameters
	Map of parameters by name.

std::list< const Parameter * >	_constParameters
	List of const pointers to Parameters for providing via getParameters().

std::list< const SampleTag * >	_sourceTags

SampleOutput *	_original
	Pointer to the SampleOutput that I was cloned from.

float	_latency

int	_reconnectDelaySecs

dsm_time_t	_startTime
	Clipping time window.

dsm_time_t	_endTime

Static Private Attributes
static XMLCh *	namespaceURI = 0

Detailed Description

Implementation of portions of SampleOutput.

Constructor & Destructor Documentation

◆ SampleOutputBase() [1/4]

SampleOutputBase::SampleOutputBase ( )

◆ SampleOutputBase() [2/4]

SampleOutputBase::SampleOutputBase	(	IOChannel *	iochan,
		SampleConnectionRequester *	rqstr = 0 )

Create a SampleOutput with a connected IOChannel.

Parameters

rqstr If non-NULL, who to call to notify that the connection has dropped.

◆ ~SampleOutputBase()

SampleOutputBase::~SampleOutputBase ( )

References _iochan, _parameters, _requestedTags, and nidas::core::getSample().

◆ SampleOutputBase() [3/4]

SampleOutputBase::SampleOutputBase	(	SampleOutputBase &	x,
		IOChannel *	ioc )

protected

Protected copy constructor, with a new, connected IOChannel.

References _iochan, addRequestedSampleTag(), addSourceSampleTag(), getDSMConfig(), nidas::core::getSample(), and nidas::core::IOChannel::setDSMConfig().

◆ SampleOutputBase() [4/4]

nidas::core::SampleOutputBase::SampleOutputBase ( const SampleOutputBase & )

private

No copy.

Member Function Documentation

◆ addParameter()

void SampleOutputBase::addParameter ( Parameter * val )

Add a parameter to this DSMSensor.

DSMSensor 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.

References _constParameters, _parameters, and nidas::core::getSample().

Referenced by fromDOMElement().

◆ addRequestedSampleTag()

void SampleOutputBase::addRequestedSampleTag ( SampleTag * tag )

virtual

Exceptions

nidas::util::InvalidParameterException

Implements nidas::core::SampleOutput.

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

Referenced by nidas::dynld::raf::CVIOutput::addRequestedSampleTag(), and SampleOutputBase().

◆ addSourceSampleTag()

void SampleOutputBase::addSourceSampleTag ( const SampleTag * tag )

virtual

Exceptions

nidas::util::InvalidParameterException

Implements nidas::core::SampleOutput.

References _sourceTags, _tagsMutex, and nidas::core::getSample().

Referenced by addSourceSampleTags(), and SampleOutputBase().

◆ addSourceSampleTags()

void SampleOutputBase::addSourceSampleTags ( const std::list< const SampleTag * > & tags )

virtual

Exceptions

nidas::util::InvalidParameterException

Implements nidas::core::SampleOutput.

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

◆ clone()

virtual SampleOutput * nidas::core::SampleOutput::clone ( IOChannel * iochannel )

protectedpure virtualinherited

Implemented in nidas::dynld::AsciiOutput, nidas::dynld::RawSampleOutputStream, nidas::dynld::SampleOutputStream, nidas::dynld::raf::CVIOutput, and nidas::dynld::UDPSampleOutput.

Referenced by connected().

◆ close()

void SampleOutputBase::close ( )

virtual

Exceptions

nidas::util::IOException

Implements nidas::core::SampleOutput.

Reimplemented in nidas::dynld::SampleOutputStream, and nidas::dynld::UDPSampleOutput.

References _iochan, _nextFileTime, nidas::core::IOChannel::close(), DLOG, getName(), and nidas::core::getSample().

Referenced by nidas::dynld::SampleOutputStream::close(), nidas::dynld::UDPSampleOutput::close(), and disconnect().

◆ connected()

SampleOutput * SampleOutputBase::connected ( IOChannel * ochan )

virtual

Implementation of IOChannelRequester::connected().

How an IOChannel calls back to a SampleConnectionRequester that it is connected. The ConnectionRequester can then return a clone of itself if the IOChannel is a new instance.

Implements nidas::core::IOChannelRequester.

Reimplemented in nidas::dynld::SampleOutputStream, and nidas::dynld::UDPSampleOutput.

References _connectionRequester, _iochan, _nextFileTime, nidas::core::SampleOutput::clone(), nidas::core::IOChannel::close(), nidas::core::SampleConnectionRequester::connect(), nidas::core::getSample(), setIOChannel(), and setName().

Referenced by nidas::dynld::SampleOutputStream::connected(), and nidas::dynld::UDPSampleOutput::connected().

◆ createNextFile()

void SampleOutputBase::createNextFile ( dsm_time_t tt )

Exceptions

nidas::util::IOException

References _headerSource, _nextFileTime, nidas::core::IOChannel::createFile(), getIOChannel(), nidas::core::HeaderSource::sendDefaultHeader(), and nidas::core::HeaderSource::sendHeader().

Referenced by nidas::dynld::AsciiOutput::receive(), and nidas::dynld::raf::CVIOutput::receive().

◆ disconnect()

void SampleOutputBase::disconnect ( )

protected

Close the IOChannel and notify whoever did the requestConnection that it is time to disconnect, perhaps because of an IOException.

This is typically called in the receive() method of a SampleOutput if it gets an IOException when writing data. A common implementation of a connection requester is to delete this SampleOutput after the removing it from the sample stream. So the caller method should immediately return after calling disconnect().

Exceptions

nidas::util::IOException

References _connectionRequester, close(), nidas::core::SampleConnectionRequester::disconnect(), getName(), nidas::core::getSample(), and ILOG.

Referenced by nidas::dynld::AsciiOutput::receive(), and nidas::dynld::raf::CVIOutput::receive().

◆ flush()

virtual void nidas::core::SampleClient::flush ( )

pure virtualinherited

Ask that this SampleClient send out any buffered Samples that it may be holding.

Exceptions

)

Implemented in DumpClient, SampleDispatcher, DataStats, DumpClient, nidas::core::DSMSensor, nidas::core::NearestResampler, nidas::core::NearestResamplerAtRate, nidas::core::RemoteSerialConnection, nidas::core::SampleAverager, nidas::core::SampleBuffer, nidas::core::SampleSorter, nidas::dynld::AsciiOutput, nidas::dynld::raf::CVIOutput, nidas::dynld::raf::CVIProcessor, nidas::dynld::raf::SyncRecordReader, nidas::dynld::raf::SyncRecordSource, nidas::dynld::SampleOutputStream, nidas::dynld::StatisticsCruncher, nidas::dynld::UDPSampleOutput, nidas::core::Resampler, and nidas::core::SampleThread.

Referenced by nidas::core::DSMEngine::closeOutputs(), nidas::core::SampleArchiver::flush(), nidas::dynld::raf::CVIProcessor::flush(), nidas::dynld::SampleProcessor::flush(), nidas::dynld::StatisticsProcessor::flush(), nidas::dynld::raf::CVIProcessor::~CVIProcessor(), nidas::core::SampleArchiver::~SampleArchiver(), nidas::core::SampleIOProcessor::~SampleIOProcessor(), nidas::dynld::SampleProcessor::~SampleProcessor(), nidas::dynld::StatisticsProcessor::~StatisticsProcessor(), and nidas::dynld::raf::SyncRecordGenerator::~SyncRecordGenerator().

◆ fromDOMElement()

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

virtual

Exceptions

nidas::util::InvalidParameterException

Implements nidas::core::DOMable.

Reimplemented in nidas::dynld::UDPSampleOutput.

References addParameter(), nidas::core::IOChannel::createIOChannel(), nidas::core::Parameter::createParameter(), getDSMConfig(), nidas::core::Project::getInstance(), getIOChannel(), getName(), nidas::core::getSample(), setIOChannel(), setLatency(), setName(), and WLOG.

Referenced by nidas::dynld::UDPSampleOutput::fromDOMElement().

◆ getDSMConfig()

const DSMConfig * nidas::core::SampleOutputBase::getDSMConfig ( ) const

inlinevirtual

Implements nidas::core::SampleOutput.

References _dsm.

Referenced by fromDOMElement(), SampleOutputBase(), and setIOChannel().

◆ getFd()

int SampleOutputBase::getFd ( ) const

virtual

Implements nidas::core::SampleOutput.

References _iochan, and nidas::core::IOChannel::getFd().

◆ getIOChannel()

IOChannel * nidas::core::SampleOutputBase::getIOChannel ( ) const

inlinevirtual

Implements nidas::core::SampleOutput.

References _iochan.

Referenced by nidas::dynld::AsciiOutput::AsciiOutput(), nidas::dynld::AsciiOutput::AsciiOutput(), nidas::dynld::AsciiOutput::connect(), createNextFile(), nidas::dynld::raf::CVIOutput::CVIOutput(), nidas::dynld::raf::CVIOutput::CVIOutput(), fromDOMElement(), nidas::dynld::RawSampleOutputStream::fromDOMElement(), nidas::dynld::UDPSampleOutput::fromDOMElement(), nidas::dynld::AsciiOutput::printHeader(), nidas::dynld::RawSampleOutputStream::RawSampleOutputStream(), nidas::dynld::RawSampleOutputStream::RawSampleOutputStream(), nidas::dynld::AsciiOutput::receive(), nidas::dynld::raf::CVIOutput::receive(), nidas::dynld::raf::CVIOutput::requestConnection(), nidas::dynld::SampleOutputStream::SampleOutputStream(), nidas::dynld::SampleOutputStream::SampleOutputStream(), nidas::dynld::raf::CVIOutput::setIOChannel(), and nidas::dynld::UDPSampleOutput::write().

◆ getLatency()

float nidas::core::SampleOutputBase::getLatency ( ) const

inlinevirtual

Implements nidas::core::SampleOutput.

References _latency.

Referenced by nidas::dynld::SampleOutputStream::SampleOutputStream(), and nidas::dynld::SampleOutputStream::SampleOutputStream().

◆ getName()

const std::string & nidas::core::SampleOutputBase::getName ( ) const

inlinevirtual

Implements nidas::core::SampleOutput.

References _name.

Referenced by nidas::dynld::UDPSampleOutput::ConnectionMonitor::addConnection(), nidas::dynld::AsciiOutput::AsciiOutput(), nidas::dynld::AsciiOutput::AsciiOutput(), nidas::dynld::UDPSampleOutput::XMLSocketListener::checkWorkers(), close(), nidas::dynld::raf::CVIOutput::CVIOutput(), nidas::dynld::raf::CVIOutput::CVIOutput(), disconnect(), nidas::dynld::UDPSampleOutput::XMLSocketListener::fireWorkers(), nidas::dynld::SampleOutputStream::flush(), fromDOMElement(), nidas::dynld::UDPSampleOutput::fromDOMElement(), nidas::dynld::RawSampleOutputStream::RawSampleOutputStream(), nidas::dynld::RawSampleOutputStream::RawSampleOutputStream(), nidas::dynld::AsciiOutput::receive(), nidas::dynld::raf::CVIOutput::receive(), nidas::dynld::UDPSampleOutput::ConnectionMonitor::removeConnection(), nidas::dynld::SampleOutputStream::SampleOutputStream(), nidas::dynld::SampleOutputStream::SampleOutputStream(), nidas::dynld::raf::CVIOutput::setIOChannel(), and nidas::dynld::SampleOutputStream::setLatency().

◆ getNamespaceURI()

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

inlinestaticinherited

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

◆ getNextFileTime()

dsm_time_t nidas::core::SampleOutputBase::getNextFileTime ( ) const

inline

References _nextFileTime.

Referenced by nidas::dynld::AsciiOutput::receive(), and nidas::dynld::raf::CVIOutput::receive().

◆ getNumDiscardedSamples()

size_t nidas::core::SampleOutputBase::getNumDiscardedSamples ( ) const

inline

References _nsamplesDiscarded.

◆ getOriginal()

SampleOutput * nidas::core::SampleOutputBase::getOriginal ( ) const

inlinevirtual

Get pointer to SampleOutput that was cloned.

Will be NULL if this SampleOutput is an un-cloned original.

Implements nidas::core::SampleOutput.

References _original.

◆ getParameter()

const Parameter * SampleOutputBase::getParameter ( const std::string & name ) const

Fetch a parameter by name.

Returns a NULL pointer if no such parameter exists.

References _parameters.

◆ getParameters()

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

inline

Get list of parameters.

References _constParameters.

Referenced by nidas::dynld::UDPSampleOutput::fromDOMElement().

◆ getReconnectDelaySecs()

int SampleOutputBase::getReconnectDelaySecs ( ) const

virtual

Base class implementation.

If setReconnectDelaySecs() has been called on this SampleOutput, then that value will be returned. Otherwise this will return the value of the IOChannel.

Implements nidas::core::SampleOutput.

References _iochan, _reconnectDelaySecs, and nidas::core::IOChannel::getReconnectDelaySecs().

◆ getRequestedSampleTags()

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

virtual

Implements nidas::core::SampleOutput.

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

◆ getSampleConnectionRequester()

SampleConnectionRequester * nidas::core::SampleOutputBase::getSampleConnectionRequester ( )

inlineprotected

References _connectionRequester.

◆ getSourceSampleTags()

list< const SampleTag * > SampleOutputBase::getSourceSampleTags ( ) const

virtual

Implements nidas::core::SampleOutput.

References _sourceTags, _tagsMutex, and nidas::core::getSample().

◆ incrementDiscardedSamples()

size_t nidas::core::SampleOutputBase::incrementDiscardedSamples ( )

inlineprotected

References _nsamplesDiscarded.

◆ isRaw()

bool nidas::core::SampleOutputBase::isRaw ( ) const

inlinevirtual

Implements nidas::core::SampleOutput.

◆ operator=()

SampleOutputBase & nidas::core::SampleOutputBase::operator= ( const SampleOutputBase & )

private

No assignment.

◆ receive()

bool SampleOutputBase::receive ( const Sample * s )

virtual

Return true if SampleOutputBase considers the sample handled, such as if it is outside the clipping window.

Otherwise return false to indicate the subclass should handle the sample.

Implements nidas::core::SampleClient.

Reimplemented in nidas::dynld::UDPSampleOutput, and nidas::dynld::SampleOutputStream.

References _endTime, and _startTime.

◆ requestConnection()

void SampleOutputBase::requestConnection ( SampleConnectionRequester * requester )

virtual

Request a connection, but don't wait for it.

Requester will be notified via SampleConnectionRequester interface when the connection has been made. It is not necessary to call this method if a SampleOutput is constructed with a connected IOChannel.

Exceptions

nidas::util::IOException

Implements nidas::core::SampleOutput.

References _connectionRequester, _iochan, nidas::core::getSample(), and nidas::core::IOChannel::requestConnection().

Referenced by nidas::dynld::AsciiOutput::requestConnection(), and nidas::dynld::raf::CVIOutput::requestConnection().

◆ setDSMConfig()

void nidas::core::SampleOutputBase::setDSMConfig ( const DSMConfig * val )

inlinevirtual

Implements nidas::core::SampleOutput.

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

◆ setHeaderSource()

void nidas::core::SampleOutputBase::setHeaderSource ( HeaderSource * val )

inlinevirtual

Implements nidas::core::SampleOutput.

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

Referenced by ARLIngest::run(), NidsMerge::run(), and SensorExtract::run().

◆ setIOChannel()

void SampleOutputBase::setIOChannel ( IOChannel * val )

virtual

Set the IOChannel for this SampleOutput.

This IOChannel is not yet connected. The IOChannel must be connected before the SampleOutput is used for I/O, using the requestConnection() method, or by IOChannel::connect() followed by SampleOutput::connected(IOChannel*).

Reimplemented in nidas::dynld::raf::CVIOutput.

References _iochan, getDSMConfig(), nidas::core::getSample(), and nidas::core::IOChannel::setDSMConfig().

Referenced by nidas::dynld::AsciiOutput::connect(), connected(), fromDOMElement(), and nidas::dynld::raf::CVIOutput::setIOChannel().

◆ setLatency()

void nidas::core::SampleOutputBase::setLatency ( float val )

inlinevirtual

Set desired latency, providing some control over the response time vs buffer efficiency tradeoff.

Setting a latency of 1/10 sec means buffer data in the IOStream for a 1/10 sec, then send the data to the physical device.

Parameters

val	Latency, in seconds.

Exceptions

nidas::util::InvalidParameterException

Implements nidas::core::SampleOutput.

Reimplemented in nidas::dynld::SampleOutputStream.

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

Referenced by fromDOMElement(), and nidas::dynld::SampleOutputStream::setLatency().

◆ setName()

void nidas::core::SampleOutputBase::setName ( const std::string & val )

inlinevirtual

Implements nidas::core::SampleOutput.

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

Referenced by nidas::dynld::AsciiOutput::AsciiOutput(), nidas::dynld::AsciiOutput::AsciiOutput(), connected(), nidas::dynld::raf::CVIOutput::CVIOutput(), nidas::dynld::raf::CVIOutput::CVIOutput(), fromDOMElement(), nidas::dynld::RawSampleOutputStream::RawSampleOutputStream(), nidas::dynld::RawSampleOutputStream::RawSampleOutputStream(), nidas::dynld::SampleOutputStream::SampleOutputStream(), nidas::dynld::SampleOutputStream::SampleOutputStream(), and nidas::dynld::raf::CVIOutput::setIOChannel().

◆ setReconnectDelaySecs()

void SampleOutputBase::setReconnectDelaySecs ( int val )

virtual

Implements nidas::core::SampleOutput.

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

Referenced by nidas::dynld::raf::SyncServer::init().

◆ setTimeClippingWindow()

void SampleOutputBase::setTimeClippingWindow	(	const nidas::util::UTime &	startTime,
		const nidas::util::UTime &	endTime )

The sample output can have a time window which clips the samples outside the window.

Only samples at or after startTime and before endTime will be passed along. One or both of start and end time can be zero, in which case only the non-zero times are used to clip samples.

References _endTime, _startTime, and nidas::util::UTime::toUsecs().

Referenced by nidas::core::NidasApp::setOutputClipping().

◆ 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.

◆ write()

size_t SampleOutputBase::write	(	const void *	buf,
		size_t	len )

virtual

Raw write method, typically used to write the initial header.

Exceptions

nidas::util::IOException

Implements nidas::core::SampleOutput.

References _iochan, nidas::core::getSample(), len, and nidas::core::IOChannel::write().

Member Data Documentation

◆ _connectionRequester

SampleConnectionRequester* nidas::core::SampleOutputBase::_connectionRequester

private

Referenced by connected(), disconnect(), getSampleConnectionRequester(), and requestConnection().

◆ _constParameters

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

private

List of const pointers to Parameters for providing via getParameters().

Referenced by addParameter(), and getParameters().

◆ _constRequestedTags

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

private

Referenced by addRequestedSampleTag(), and getRequestedSampleTags().

◆ _dsm

const DSMConfig* nidas::core::SampleOutputBase::_dsm

private

Referenced by getDSMConfig(), and setDSMConfig().

◆ _endTime

dsm_time_t nidas::core::SampleOutputBase::_endTime

private

Referenced by receive(), and setTimeClippingWindow().

◆ _headerSource

HeaderSource* nidas::core::SampleOutputBase::_headerSource

private

Referenced by createNextFile(), and setHeaderSource().

◆ _iochan

IOChannel* nidas::core::SampleOutputBase::_iochan

private

Referenced by close(), connected(), getFd(), getIOChannel(), getReconnectDelaySecs(), requestConnection(), SampleOutputBase(), setIOChannel(), write(), and ~SampleOutputBase().

◆ _latency

float nidas::core::SampleOutputBase::_latency

private

Referenced by getLatency(), and setLatency().

◆ _name

std::string nidas::core::SampleOutputBase::_name

protected

Referenced by getName(), and setName().

◆ _nextFileTime

dsm_time_t nidas::core::SampleOutputBase::_nextFileTime

private

Referenced by close(), connected(), createNextFile(), and getNextFileTime().

◆ _nsamplesDiscarded

size_t nidas::core::SampleOutputBase::_nsamplesDiscarded

private

Referenced by getNumDiscardedSamples(), and incrementDiscardedSamples().

◆ _original

SampleOutput* nidas::core::SampleOutputBase::_original

private

Pointer to the SampleOutput that I was cloned from.

Referenced by getOriginal().

◆ _parameters

std::map<std::string,Parameter*> nidas::core::SampleOutputBase::_parameters

private

Map of parameters by name.

Referenced by addParameter(), getParameter(), and ~SampleOutputBase().

◆ _reconnectDelaySecs

int nidas::core::SampleOutputBase::_reconnectDelaySecs

private

Referenced by getReconnectDelaySecs(), and setReconnectDelaySecs().

◆ _requestedTags

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

private

Referenced by addRequestedSampleTag(), and ~SampleOutputBase().

◆ _sourceTags

std::list<const SampleTag*> nidas::core::SampleOutputBase::_sourceTags

private

Referenced by addSourceSampleTag(), and getSourceSampleTags().

◆ _startTime

dsm_time_t nidas::core::SampleOutputBase::_startTime

private

Clipping time window.

Samples outside the given time window will not pass.

Referenced by receive(), and setTimeClippingWindow().

◆ _tagsMutex

nidas::util::Mutex nidas::core::SampleOutputBase::_tagsMutex

mutableprivate

Referenced by addRequestedSampleTag(), addSourceSampleTag(), getRequestedSampleTags(), and getSourceSampleTags().

◆ 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/SampleOutput.h
nidas/core/SampleOutput.cc

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ SampleOutputBase() [1/4]

◆ SampleOutputBase() [2/4]

◆ ~SampleOutputBase()

◆ SampleOutputBase() [3/4]

◆ SampleOutputBase() [4/4]

Member Function Documentation

◆ addParameter()

◆ addRequestedSampleTag()

◆ addSourceSampleTag()

◆ addSourceSampleTags()

◆ clone()

◆ close()

◆ connected()

◆ createNextFile()

◆ disconnect()

◆ flush()

◆ fromDOMElement()

◆ getDSMConfig()

◆ getFd()

◆ getIOChannel()

◆ getLatency()

◆ getName()

◆ getNamespaceURI()

◆ getNextFileTime()

◆ getNumDiscardedSamples()

◆ getOriginal()

◆ getParameter()

◆ getParameters()

◆ getReconnectDelaySecs()

◆ getRequestedSampleTags()

◆ getSampleConnectionRequester()

◆ getSourceSampleTags()

◆ incrementDiscardedSamples()

◆ isRaw()

◆ operator=()

◆ receive()

◆ requestConnection()

◆ setDSMConfig()

◆ setHeaderSource()

◆ setIOChannel()

◆ setLatency()

◆ setName()

◆ setReconnectDelaySecs()

◆ setTimeClippingWindow()

◆ toDOMElement()

◆ toDOMParent()

◆ write()

Member Data Documentation

◆ _connectionRequester

◆ _constParameters

◆ _constRequestedTags

◆ _dsm

◆ _endTime

◆ _headerSource

◆ _iochan

◆ _latency

◆ _name

◆ _nextFileTime

◆ _nsamplesDiscarded

◆ _original

◆ _parameters

◆ _reconnectDelaySecs

◆ _requestedTags

◆ _sourceTags

◆ _startTime

◆ _tagsMutex

◆ namespaceURI