adtf::streaming::ant::cSampleStreamingSource Class Reference

#include <streaming_source.h>

Inherits adtf::streaming::ant::cRuntimeBehaviour, adtf::streaming::ant::streaming_level_machine, and adtf::ucom::catwo::object< ucom::ant::cClassInfo, base::ant::configuration<>, IDynamicDataBinding, IStreamingService, IStreamingSource, data_binding< named_graph_object< ISampleStreamingSource > > >.

Public Member Functions
	cSampleStreamingSource (const char *strName)
tResult	SetState (IStreamingSource::tStreamingState eState) override
IStreamingSource::tStreamingState	GetState () override
tResult	RegisterPin (const ucom::ant::iobject_ptr< IPin > &pPin)
tResult	RequestPin (const char *strName, const adtf::ucom::ant::iobject_ptr< const IStreamType > &pType, adtf::ucom::ant::iobject_ptr< IInPin > &pInPin) override
tResult	RequestPin (const char *strName, const adtf::ucom::ant::iobject_ptr< const IStreamType > &pType, adtf::ucom::ant::iobject_ptr< IOutPin > &pOutPin) override
tResult	Destruct () override
tResult	StartStreaming () override
tResult	StopStreaming () override
tResult	RegisterPin (const ucom::ant::iobject_ptr< IInPin > &pIInPin)
tResult	RegisterPin (const ucom::ant::iobject_ptr< IOutPin > &pIOutPin)
Public Member Functions inherited from adtf::streaming::ant::cRuntimeBehaviour
tResult	GetRunners (ucom::ant::iobject_list< IRunner > &lstRunners) const
	copydoc IRuntimeBehaviour::GetRunners
tResult	FindRunner (const char *strName, ucom::ant::iobject_ptr< ucom::ant::IObject > &pRunner) const
	copydoc IRuntimeBehaviour::FindRunner
tResult	GetInnerPipes (ucom::ant::iobject_list< ITriggerPipe > &lstInnerpTriggerPipe) const
	copydoc IRuntimeBehaviour::GetInnerPipes
virtual tResult	RegisterRunner (const ucom::ant::iobject_ptr< IRunner > &pRunner)
virtual tResult	RegisterRunner (const char *strName, base::ant::IRunnable &oRunnable)
virtual tResult	UnregisterRunner (const ucom::ant::iobject_ptr< IRunner > &pRunner)
tResult	ReleaseRunners ()
virtual tResult	RegisterInnerPipe (const ucom::ant::iobject_ptr< ITriggerPipe > &pTriggerPipe)
virtual tResult	UnregisterInnerPipe (const ucom::ant::iobject_ptr< ITriggerPipe > &pTriggerPipe)
tResult	ReleaseTriggerPipes ()
Public Member Functions inherited from adtf::ucom::ant::level_machine< Subclass, LevelType, START_LEVEL >
template<typename ... InnerHandlers>
tResult	ChangeLevel (LevelType eLevel)
Public Member Functions inherited from adtf::ucom::catwo::object< ucom::ant::cClassInfo, base::ant::configuration<>, IDynamicDataBinding, IStreamingService, IStreamingSource, data_binding< named_graph_object< ISampleStreamingSource > > >
tResult	GetInterface (const char *i_strIID, void *&o_pInterface) override
	Query interfaces on an object.
tResult	GetInterface (const char *i_strIID, const void *&o_pInterface) const override
	Provides const correct interface querying.
void	Destroy () const override
	Switch from non-virtual destructor to virtual destructor.
tResult	GetInterface (const char *i_strIID, void *&o_pInterface) override
	Query interfaces on an object.
tResult	GetInterface (const char *i_strIID, const void *&o_pInterface) const override
	Provides const correct interface querying.
void	Destroy () const override
	Switch from non-virtual destructor to virtual destructor.
tResult	GetInterface (const char *i_strIID, void *&o_pInterface) override
	Query interfaces on an object.
tResult	GetInterface (const char *i_strIID, const void *&o_pInterface) const override
	Provides const correct interface querying.
void	Destroy () const override
	Switch from non-virtual destructor to virtual destructor.
Public Member Functions inherited from adtf::ucom::ant::IObject
	ADTF_IID (IObject, "object.ant.ucom.adtf.iid")

Additional Inherited Members
Protected Types inherited from adtf::ucom::ant::level_machine< Subclass, LevelType, START_LEVEL >
enum	tDirection : uint8_t { Inc = 0 , Dec = 1 }
	Direction of entering a new Level. More...
typedef tResult(Subclass::*	tChangeMethod) ()
	Defintion of function type called within the handler implementation.
Protected Member Functions inherited from adtf::streaming::ant::cRuntimeBehaviour
	cRuntimeBehaviour ()
	private _d-pointer
virtual	~cRuntimeBehaviour ()
	DTOR.
Protected Member Functions inherited from adtf::streaming::ant::streaming_level_machine
	streaming_level_machine (const streaming_level_machine &)=delete
	streaming_level_machine (streaming_level_machine &&)=delete
streaming_level_machine &	operator= (const streaming_level_machine &)=delete
streaming_level_machine &	operator= (streaming_level_machine &&)=delete
tResult	SetLevel (IStreamingService::tStreamingState eStreamingState)
virtual tResult	Construct ()
virtual tResult	Init ()
virtual tResult	Shutdown ()
Protected Member Functions inherited from adtf::ucom::ant::level_machine< Subclass, LevelType, START_LEVEL >
virtual	~level_machine ()=default
	DTOR.
LevelType	GetLevel () const
Protected Member Functions inherited from adtf::ucom::ant::IObject
	~IObject ()=default
	Protected destructor --> Only the final implementation can be destroyed!

Detailed Description

Basic implementation for a streaming source.

This has been superseeded by adtf::filter::flash::cSampleStreamingSource.

This implementation is able to:

• RegisterPin with the help of the data_binding and the common adtf::streaming::ant::create_pin methods.
• Implements a INamedGraphObject to add it to the streaming graph
• is configurable by properties
• Implements all required function calls to intanciate it.

Use the provided transition callbacks to override the behaviour but do not forget to call the base type implementation.

• Construct
• Destruct
• Init
• Shutdown
• StartStreaming
• StopStreaming

See also

subsection_sample_stream_source

adtf::filter::flash::cSampleStreamingSource

Member Function Documentation

Destruct()

tResult adtf::streaming::ant::cSampleStreamingSource::Destruct ( )

overridevirtual

Destruct transition while changing from tStreamingState::State_Constructed to tStreamState::State_Shutdown.

Returns

Returns a standard result code which depends on the implementation.

Reimplemented from adtf::streaming::ant::streaming_level_machine.

RegisterPin() [1/2]

tResult adtf::streaming::ant::cDataBinding::RegisterPin

(

const ucom::ant::iobject_ptr< IInPin > &

pIInPin

)

Registers a InPin in a pin list.

Parameters

pIInPin

[in] Pin to register.

Returns

Standard result code.

RegisterPin() [2/2]

tResult adtf::streaming::ant::cDataBinding::RegisterPin

(

const ucom::ant::iobject_ptr< IOutPin > &

pIOutPin

)

Registers a InPin in a pin list.

Parameters

pIOutPin

[in] Pin to register.

Returns

Standard result code.

StartStreaming()

tResult adtf::streaming::ant::cSampleStreamingSource::StartStreaming ( )

overridevirtual

StatrStreaming transition while changing from tStreamState::State_Initialized to tStreamingState::State_Streaming.

Use this transition callback to initalize and start threads and timers.

Note

Make sure to call the parent implementation of the used base class at the beginning within your overriding function!

Returns

Returns a standard result code which depends on the implementation.

Reimplemented from adtf::streaming::ant::streaming_level_machine.

StopStreaming()

tResult adtf::streaming::ant::cSampleStreamingSource::StopStreaming ( )

overridevirtual

StopStreaming transition while changing from tStreamingState::State_Streaming to tStreamState::State_Initialized.

Use this transition callback to stop and destroy threads and timers.

Keep in mind, that streaming and triggers might still occur during and after this function is called. Streaming will only have stopped completely before any other following state change. If your streaming service has any blocking operations during the handling of triggers, make sure that you cancel them in this function.

Note

Make sure to call the parent implementation of the used base class at the end within your overriding function!

Returns

Returns a standard result code which depends on the implementation.

Return values

ERR_NOERROR	Successfully constructed
any	Error The Streaming Graph will stop starting.

Reimplemented from adtf::streaming::ant::streaming_level_machine.

---

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

• src/libraries/streaming3/include/adtfstreaming3/streaming_source.h