Detailed Description

template<typename ProcessedDataType, typename ReadProcessedDataFunc>
class dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >

Definition at line 316 of file dwSensorDrainerTemplate.hpp.

Inheritance diagram for dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >:

[legend]

Collaboration diagram for dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >:

[legend]

Public Types
using	Base = dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >

Public Types inherited from dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >
using	OnDataDropped = dw::core::Function< void(dwTime_t const)>

Public Member Functions
	dwSensorDrainerTemplate (dwSensorDrainerParams params, std::unique_ptr< ReadProcessedDataFunc > readProcessedDataFunc, dwSensorHandle_t hsensor)

dwStatus	getNextTimestamp (dwTime_t &timestamp, dwTime_t timeout) override

dwStatus	readProcessedData (ProcessedDataType *outFrame, dwTime_t &latestTimestamp, dwTime_t timeout, bool isDroppingData=false) override

dwStatus	replayDroppedFrames (ProcessedDataType *processedOutput, SensorNode::DataEvent &dataEvent, SensorNode::DataEventReadCallback readCb)

virtual dwStatus	replayProcessedData (ProcessedDataType *processedOutput, dwTime_t &timestampOutput, SensorNode::DataEventReadCallback readCb)

virtual dwStatus	reset () override

virtual	~dwSensorDrainerTemplate ()=default

Public Member Functions inherited from dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >
virtual dwStatus	drainProcessedData (ProcessedDataType *processedOutput, dwTime_t &timestampOutput, dwTime_t &nextTimestampOutput, dwTime_t virtualSyncTime)

	dwBaseDrainerTemplate (dwSensorDrainerParams params, std::unique_ptr< ReadProcessedDataFunc > readProcessedDataFunc, dwSensorHandle_t dataSource)

virtual dwStatus	getNextData (ProcessedDataType *outFrame, dwTime_t timeout)

virtual dwStatus	getNextTimestamp (dwTime_t &timestamp, dwTime_t timeout)

virtual dwTime_t	getReadTimeout () const

virtual void	isLockstepDataAvailable (dwStatus &status, dwTime_t &readTimeout)

virtual bool	isVirtualDataReady (dwTime_t dataTime, dwTime_t timeout)

virtual dwStatus	readProcessedData (ProcessedDataType *outFrame, dwTime_t &latestTimestamp, dwTime_t timeout, bool isDroppingData=false)=0

virtual dwStatus	reset ()

void	setOnDataDropped (OnDataDropped onDataDropped)

virtual void	setVirtualSyncTime (dwTime_t virtualSyncTime)

virtual dwStatus	tryRead (ProcessedDataType *outFrame, dwTime_t &latestTimestamp, dwTime_t timeout, bool isDroppingData=false)

Static Public Attributes
static constexpr char	LOG_TAG [] = "dwSensorDrainerTemplate"

Static Public Attributes inherited from dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >
static constexpr int32_t	DRAIN_SENSOR_DATA_COUNT_MAX

static constexpr char	LOG_TAG []

Protected Attributes
bool	m_isLockstep = false

Protected Attributes inherited from dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >
dwTime_t	m_blockingTimeout

dwSensorHandle_t	m_dataSource

bool	m_dropStaleData

bool	m_isVirtual

Node::Name_t	m_name

bool	m_nextDataReady

dwTime_t	m_nonBlockingTimeout

OnDataDropped	m_onDataDropped

bool	m_outputAvailable

std::unique_ptr< ReadProcessedDataFunc >	m_readProcessedDataFunc

dwTime_t	m_virtualSyncTime

bool	m_waitForNewData

Additional Inherited Members
Static Protected Attributes inherited from dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >
static constexpr dwTime_t	REPLAY_SENSOR_READ_TIMEOUT

Member Typedef Documentation

◆ Base

template<typename ProcessedDataType , typename ReadProcessedDataFunc >

using dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >::Base = dwBaseDrainerTemplate<ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t>

Definition at line 320 of file dwSensorDrainerTemplate.hpp.

Constructor & Destructor Documentation

◆ dwSensorDrainerTemplate()

template<typename ProcessedDataType , typename ReadProcessedDataFunc >

dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >::dwSensorDrainerTemplate	(	dwSensorDrainerParams	params,
		std::unique_ptr< ReadProcessedDataFunc >	readProcessedDataFunc,
		dwSensorHandle_t	hsensor
	)

inlineexplicit

Definition at line 322 of file dwSensorDrainerTemplate.hpp.

◆ ~dwSensorDrainerTemplate()

template<typename ProcessedDataType , typename ReadProcessedDataFunc >

virtual dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >::~dwSensorDrainerTemplate ( )

virtualdefault

Member Function Documentation

◆ getNextTimestamp()

template<typename ProcessedDataType , typename ReadProcessedDataFunc >

dwStatus dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >::getNextTimestamp	(	dwTime_t &	timestamp,
		dwTime_t	timeout
	)

inlineoverridevirtual

Reimplemented from dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >.

Definition at line 330 of file dwSensorDrainerTemplate.hpp.

References dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >::getNextTimestamp(), dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >::m_dataSource, dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >::m_isVirtual, and dw::framework::timestamp.

◆ readProcessedData()

template<typename ProcessedDataType , typename ReadProcessedDataFunc >

dwStatus dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >::readProcessedData	(	ProcessedDataType *	outFrame,
		dwTime_t &	latestTimestamp,
		dwTime_t	timeout,
		bool	isDroppingData = `false`
	)

inlineoverridevirtual

Implements dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >.

Definition at line 365 of file dwSensorDrainerTemplate.hpp.

References dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >::m_blockingTimeout, dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >::reset(), dw::framework::status, and dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >::tryRead().

Referenced by dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >::replayDroppedFrames(), and dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >::replayProcessedData().

◆ replayDroppedFrames()

template<typename ProcessedDataType , typename ReadProcessedDataFunc >

dwStatus dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >::replayDroppedFrames	(	ProcessedDataType *	processedOutput,
		SensorNode::DataEvent &	dataEvent,
		SensorNode::DataEventReadCallback	readCb
	)

inline

Definition at line 388 of file dwSensorDrainerTemplate.hpp.

References dw::framework::ISensorNode::DataEvent::dataEventType, dw::framework::ISensorNode::DROP, FRWK_LOGE, FRWK_LOGW, dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >::readProcessedData(), dw::framework::dwBaseDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc, dwSensorHandle_t >::REPLAY_SENSOR_READ_TIMEOUT, dw::framework::status, and dw::framework::ISensorNode::DataEvent::timestamp.

Referenced by dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >::replayProcessedData().

◆ replayProcessedData()

template<typename ProcessedDataType , typename ReadProcessedDataFunc >

virtual dwStatus dw::framework::dwSensorDrainerTemplate< ProcessedDataType, ReadProcessedDataFunc >::replayProcessedData	(	ProcessedDataType *	processedOutput,
		dwTime_t &	timestampOutput,
		SensorNode::DataEventReadCallback	readCb
	)