This class is used per flow e.g video flow and an audio flow to encapsulate the transport details. More...

#include <AVStreams_i.h>

Inheritance diagram for TAO_FlowEndPoint:

[legend]

Collaboration diagram for TAO_FlowEndPoint:

[legend]

Public Member Functions
	TAO_FlowEndPoint ()
	default constructor.

	TAO_FlowEndPoint (const char flowname, AVStreams::protocolSpec &protocols, const char format)

int	open (const char flowname, AVStreams::protocolSpec &protocols, const char format)

int	set_flowname (const char *flowname)

virtual void	set_flow_handler (const char flowname, TAO_AV_Flow_Handler handler)

virtual int	set_protocol_object (const char flowname, TAO_AV_Protocol_Object object)

virtual CORBA::Boolean	lock ()
	lock the flow endpoint for a particular flow.

virtual void	unlock ()
	unlock the flow endpoint for subsequent use.

virtual void	destroy ()
	destroy this flow.

virtual AVStreams::StreamEndPoint_ptr	related_sep ()

virtual void	related_sep (AVStreams::StreamEndPoint_ptr related_sep)

virtual AVStreams::FlowConnection_ptr	related_flow_connection ()

virtual void	related_flow_connection (AVStreams::FlowConnection_ptr related_flow_connection)
	set method for the related flow connection attribute.

virtual AVStreams::FlowEndPoint_ptr	get_connected_fep ()
	returns the other flowendpoint to which this is connected.

virtual CORBA::Boolean	use_flow_protocol (const char *fp_name, const CORBA::Any &fp_settings)

virtual void	set_format (const char *format)
	sets the data format.

virtual void	set_dev_params (const CosPropertyService::Properties &new_settings)
	sets the device parameters.

virtual void	set_protocol_restriction (const AVStreams::protocolSpec &the_spec)
	sets the list of protocols to be used.

virtual CORBA::Boolean	is_fep_compatible (AVStreams::FlowEndPoint_ptr fep)
	checks whether the passed flowendpoint is compatible with this.

virtual CORBA::Boolean	set_peer (AVStreams::FlowConnection_ptr the_fc, AVStreams::FlowEndPoint_ptr the_peer_fep, AVStreams::QoS &the_qos)
	sets the peer flowendpoint.

virtual CORBA::Boolean	set_Mcast_peer (AVStreams::FlowConnection_ptr the_fc, AVStreams::MCastConfigIf_ptr a_mcastconfigif, AVStreams::QoS &the_qos)
	sets the multicast peer flowendpoint, not implemented.

virtual CORBA::Boolean	connect_to_peer (AVStreams::QoS &the_qos, const char address, const char use_flow_protocol)=0

virtual CORBA::Boolean	connect_to_peer_i (TAO_FlowSpec_Entry::Role role, AVStreams::QoS &the_qos, const char address, const char use_flow_protocol)
	connect to the peer endpoint.

virtual char *	go_to_listen (AVStreams::QoS &the_qos, CORBA::Boolean is_mcast, AVStreams::FlowEndPoint_ptr peer, char *&flowProtocol)=0

virtual char *	go_to_listen_i (TAO_FlowSpec_Entry::Role role, AVStreams::QoS &the_qos, CORBA::Boolean is_mcast, AVStreams::FlowEndPoint_ptr peer, char *&flowProtocol)
	listen request from the peer.

Public Member Functions inherited from TAO_Base_StreamEndPoint
	TAO_Base_StreamEndPoint ()

virtual	~TAO_Base_StreamEndPoint ()

virtual int	handle_open ()
	called when streamendpoint is instantiated

virtual int	handle_close ()
	called when streamendpoint is being destructed

virtual int	handle_stop (const AVStreams::flowSpec &the_spec)
	Application needs to define this.

virtual int	handle_start (const AVStreams::flowSpec &the_spec)
	Application needs to define this.

virtual int	handle_destroy (const AVStreams::flowSpec &the_spec)
	Application needs to define this.

virtual CORBA::Boolean	handle_preconnect (AVStreams::flowSpec &the_spec)
	Application needs to define this.

virtual CORBA::Boolean	handle_postconnect (AVStreams::flowSpec &the_spec)
	Application needs to define this.

virtual CORBA::Boolean	handle_connection_requested (AVStreams::flowSpec &the_spec)
	Application needs to define this.

virtual int	get_callback (const char flowname, TAO_AV_Callback &callback)

virtual int	get_control_callback (const char flowname, TAO_AV_Callback &callback)

virtual void	set_control_flow_handler (const char flowname, TAO_AV_Flow_Handler handler)

TAO_AV_QoS &	qos ()

void	protocol_object_set ()

int	is_protocol_object_set ()

Protected Attributes
AVStreams::StreamEndPoint_var	related_sep_
	The related streamendpoint.

AVStreams::FlowConnection_var	related_flow_connection_
	The related flow connection reference.

AVStreams::FlowEndPoint_var	peer_fep_
	The peer flowendpoint reference.

AVStreams::protocolSpec	protocols_
	Available protocols for this flowendpoint.

AVStreams::protocolSpec	protocol_addresses_
	Address information for the protocols.

AVStreams::MCastConfigIf_var	mcast_peer_
	The multicast peer endpoint.

CORBA::Boolean	lock_
	Lock.

CORBA::String_var	format_

CORBA::String_var	flowname_

CosPropertyService::Properties	dev_params_

TAO_AV_FlowSpecSet	flow_spec_set_

CORBA::String_var	reverse_channel_

Protected Attributes inherited from TAO_Base_StreamEndPoint
TAO_AV_QoS	qos_

Flow_Handler_Map	flow_handler_map_

Flow_Handler_Map	control_flow_handler_map_

int	protocol_object_set_

Detailed Description

This class is used per flow e.g video flow and an audio flow to encapsulate the transport details.

Constructor & Destructor Documentation

◆ TAO_FlowEndPoint() [1/2]

TAO_FlowEndPoint::TAO_FlowEndPoint ( )

default constructor.

◆ TAO_FlowEndPoint() [2/2]

TAO_FlowEndPoint::TAO_FlowEndPoint	(	const char *	flowname,
		AVStreams::protocolSpec &	protocols,
		const char *	format )

Member Function Documentation

◆ connect_to_peer()

virtual CORBA::Boolean TAO_FlowEndPoint::connect_to_peer	(	AVStreams::QoS &	the_qos,
		const char *	address,
		const char *	use_flow_protocol )

pure virtual

This should be implemented in both the FlowProducer and consumer and hence is pure virtual since we need to know the role of the flowendpoint to create appropriate protocol objects. eg. in SFP to create Producer Object/ Consumer Object.

Implemented in TAO_FlowProducer, and TAO_FlowConsumer.

◆ connect_to_peer_i()

CORBA::Boolean TAO_FlowEndPoint::connect_to_peer_i	(	TAO_FlowSpec_Entry::Role	role,
		AVStreams::QoS &	the_qos,
		const char *	address,
		const char *	use_flow_protocol )

virtual

connect to the peer endpoint.

◆ destroy()

void TAO_FlowEndPoint::destroy ( )

virtual

destroy this flow.

◆ get_connected_fep()

AVStreams::FlowEndPoint_ptr TAO_FlowEndPoint::get_connected_fep ( )

virtual

returns the other flowendpoint to which this is connected.

◆ go_to_listen()

virtual char * TAO_FlowEndPoint::go_to_listen	(	AVStreams::QoS &	the_qos,
		CORBA::Boolean	is_mcast,
		AVStreams::FlowEndPoint_ptr	peer,
		char *&	flowProtocol )

pure virtual

This should be implemented in both the FlowProducer and consumer and hence is pure virtual since we need to know the role of the flowendpoint to create appropriate protocol objects. eg. in SFP to create Producer Object/ Consumer Object.

Implemented in TAO_FlowProducer, and TAO_FlowConsumer.

◆ go_to_listen_i()

char * TAO_FlowEndPoint::go_to_listen_i	(	TAO_FlowSpec_Entry::Role	role,
		AVStreams::QoS &	the_qos,
		CORBA::Boolean	is_mcast,
		AVStreams::FlowEndPoint_ptr	peer,
		char *&	flowProtocol )

virtual

listen request from the peer.

◆ is_fep_compatible()

CORBA::Boolean TAO_FlowEndPoint::is_fep_compatible ( AVStreams::FlowEndPoint_ptr fep )

virtual

checks whether the passed flowendpoint is compatible with this.

◆ lock()

CORBA::Boolean TAO_FlowEndPoint::lock ( )

virtual

lock the flow endpoint for a particular flow.

◆ open()

int TAO_FlowEndPoint::open	(	const char *	flowname,
		AVStreams::protocolSpec &	protocols,
		const char *	format )

◆ related_flow_connection() [1/2]

AVStreams::FlowConnection_ptr TAO_FlowEndPoint::related_flow_connection ( )

virtual

◆ related_flow_connection() [2/2]

void TAO_FlowEndPoint::related_flow_connection ( AVStreams::FlowConnection_ptr related_flow_connection )

virtual

set method for the related flow connection attribute.

◆ related_sep() [1/2]

AVStreams::StreamEndPoint_ptr TAO_FlowEndPoint::related_sep ( )

virtual

get method for the related streamendpoint under which this flowendpoint is.

◆ related_sep() [2/2]

void TAO_FlowEndPoint::related_sep ( AVStreams::StreamEndPoint_ptr related_sep )

virtual

set method for the related streamendpoint under which this flowendpoint is.

◆ set_dev_params()

void TAO_FlowEndPoint::set_dev_params ( const CosPropertyService::Properties & new_settings )

virtual

sets the device parameters.

◆ set_flow_handler()

void TAO_FlowEndPoint::set_flow_handler	(	const char *	flowname,
		TAO_AV_Flow_Handler *	handler )

virtual

Reimplemented from TAO_Base_StreamEndPoint.

◆ set_flowname()

int TAO_FlowEndPoint::set_flowname ( const char * flowname )

◆ set_format()

void TAO_FlowEndPoint::set_format ( const char * format )

virtual

sets the data format.

◆ set_Mcast_peer()

CORBA::Boolean TAO_FlowEndPoint::set_Mcast_peer	(	AVStreams::FlowConnection_ptr	the_fc,
		AVStreams::MCastConfigIf_ptr	a_mcastconfigif,
		AVStreams::QoS &	the_qos )

virtual

sets the multicast peer flowendpoint, not implemented.

◆ set_peer()

CORBA::Boolean TAO_FlowEndPoint::set_peer	(	AVStreams::FlowConnection_ptr	the_fc,
		AVStreams::FlowEndPoint_ptr	the_peer_fep,
		AVStreams::QoS &	the_qos )

virtual

sets the peer flowendpoint.

◆ set_protocol_object()

int TAO_FlowEndPoint::set_protocol_object	(	const char *	flowname,
		TAO_AV_Protocol_Object *	object )

virtual

Reimplemented from TAO_Base_StreamEndPoint.

◆ set_protocol_restriction()

void TAO_FlowEndPoint::set_protocol_restriction ( const AVStreams::protocolSpec & the_spec )

virtual

sets the list of protocols to be used.

◆ unlock()

void TAO_FlowEndPoint::unlock ( )

virtual

unlock the flow endpoint for subsequent use.

◆ use_flow_protocol()

CORBA::Boolean TAO_FlowEndPoint::use_flow_protocol	(	const char *	fp_name,
		const CORBA::Any &	fp_settings )

virtual

Member Data Documentation

◆ dev_params_

CosPropertyService::Properties TAO_FlowEndPoint::dev_params_

protected

◆ flow_spec_set_

TAO_AV_FlowSpecSet TAO_FlowEndPoint::flow_spec_set_

protected

◆ flowname_

CORBA::String_var TAO_FlowEndPoint::flowname_

protected

◆ format_

CORBA::String_var TAO_FlowEndPoint::format_

protected

◆ lock_

CORBA::Boolean TAO_FlowEndPoint::lock_

protected

Lock.

◆ mcast_peer_

AVStreams::MCastConfigIf_var TAO_FlowEndPoint::mcast_peer_

protected

The multicast peer endpoint.

◆ peer_fep_

AVStreams::FlowEndPoint_var TAO_FlowEndPoint::peer_fep_

protected

The peer flowendpoint reference.

◆ protocol_addresses_

AVStreams::protocolSpec TAO_FlowEndPoint::protocol_addresses_

protected

Address information for the protocols.

◆ protocols_

AVStreams::protocolSpec TAO_FlowEndPoint::protocols_

protected

Available protocols for this flowendpoint.

◆ related_flow_connection_

AVStreams::FlowConnection_var TAO_FlowEndPoint::related_flow_connection_

protected

The related flow connection reference.

◆ related_sep_

AVStreams::StreamEndPoint_var TAO_FlowEndPoint::related_sep_

protected

The related streamendpoint.

◆ reverse_channel_

CORBA::String_var TAO_FlowEndPoint::reverse_channel_

protected

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

Public Member Functions

Protected Attributes

Detailed Description

Constructor & Destructor Documentation

◆ TAO_FlowEndPoint() [1/2]

◆ TAO_FlowEndPoint() [2/2]

Member Function Documentation

◆ connect_to_peer()

◆ connect_to_peer_i()

◆ destroy()

◆ get_connected_fep()

◆ go_to_listen()

◆ go_to_listen_i()

◆ is_fep_compatible()

◆ lock()

◆ open()

◆ related_flow_connection() [1/2]

◆ related_flow_connection() [2/2]

◆ related_sep() [1/2]

◆ related_sep() [2/2]

◆ set_dev_params()

◆ set_flow_handler()

◆ set_flowname()

◆ set_format()

◆ set_Mcast_peer()

◆ set_peer()

◆ set_protocol_object()

◆ set_protocol_restriction()

◆ unlock()

◆ use_flow_protocol()

Member Data Documentation

◆ dev_params_

◆ flow_spec_set_

◆ flowname_

◆ format_

◆ lock_

◆ mcast_peer_

◆ peer_fep_

◆ protocol_addresses_

◆ protocols_

◆ related_flow_connection_

◆ related_sep_

◆ reverse_channel_