TAO_FlowConsumer Class Reference

#include <AVStreams_i.h>

Inheritance diagram for TAO_FlowConsumer:

[legend]Collaboration diagram for TAO_FlowConsumer:

[legend]List of all members.

Public Member Functions
	TAO_FlowConsumer (void)
	default constructor.
	TAO_FlowConsumer (const char *flowname, AVStreams::protocolSpec protocols, const char *format)
virtual void	stop (void)
	stop this flow, to be overridden by the application.
virtual void	start (void)
	start this flow, to be overridden by the application.
virtual char *	go_to_listen (AVStreams::QoS &the_qos, CORBA::Boolean is_mcast, AVStreams::FlowEndPoint_ptr peer, char *&flowProtocol)
virtual CORBA::Boolean	connect_to_peer (AVStreams::QoS &the_qos, const char *address, const char *use_flow_protocol)

---

Detailed Description

Definition at line 1085 of file AVStreams_i.h.

---

Constructor & Destructor Documentation

TAO_FlowConsumer::TAO_FlowConsumer

(

void

)

default constructor.

Definition at line 4418 of file AVStreams_i.cpp.

{
}

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

Definition at line 4422 of file AVStreams_i.cpp.

References TAO_FlowEndPoint::open().

{
  this->open (flowname, protocols, format);
}

---

Member Function Documentation

CORBA::Boolean TAO_FlowConsumer::connect_to_peer	(	AVStreams::QoS &	the_qos,
		const char *	address,
		const char *	use_flow_protocol
	)			[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.

Implements TAO_FlowEndPoint.

Definition at line 4464 of file AVStreams_i.cpp.

References TAO_FlowEndPoint::connect_to_peer_i(), and TAO_FlowSpec_Entry::TAO_AV_CONSUMER.

{
  return this->connect_to_peer_i (TAO_FlowSpec_Entry::TAO_AV_CONSUMER,
                                  the_qos,
                                  address,
                                  use_flow_protocol);
}

char * TAO_FlowConsumer::go_to_listen	(	AVStreams::QoS &	the_qos,
		CORBA::Boolean	is_mcast,
		AVStreams::FlowEndPoint_ptr	peer,
		char *&	flowProtocol
	)			[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.

Implements TAO_FlowEndPoint.

Definition at line 4451 of file AVStreams_i.cpp.

References TAO_FlowEndPoint::go_to_listen_i(), and TAO_FlowSpec_Entry::TAO_AV_CONSUMER.

{
  return this->go_to_listen_i (TAO_FlowSpec_Entry::TAO_AV_CONSUMER,
                               the_qos,
                               is_mcast,
                               peer_fep,
                               flowProtocol);
}

void TAO_FlowConsumer::start

(

void

)

[virtual]

start this flow, to be overridden by the application.

Definition at line 4440 of file AVStreams_i.cpp.

References ACE_Unbounded_Set_Ex< T, C >::end(), TAO_FlowEndPoint::flow_spec_set_, and TAO_FlowSpec_Entry::TAO_AV_CONSUMER.

{
  TAO_AV_FlowSpecSetItor end = this->flow_spec_set_.end ();
  for (TAO_AV_FlowSpecSetItor begin = this->flow_spec_set_.begin ();
       begin != end; ++begin)
    {
      (*begin)->handler ()->start (TAO_FlowSpec_Entry::TAO_AV_CONSUMER);
    }
}

void TAO_FlowConsumer::stop

(

void

)

[virtual]

stop this flow, to be overridden by the application.

Definition at line 4431 of file AVStreams_i.cpp.

References ACE_Unbounded_Set_Ex< T, C >::end(), TAO_FlowEndPoint::flow_spec_set_, and TAO_FlowSpec_Entry::TAO_AV_CONSUMER.

{
  TAO_AV_FlowSpecSetItor end = this->flow_spec_set_.end ();
  for (TAO_AV_FlowSpecSetItor begin = this->flow_spec_set_.begin ();
       begin != end; ++begin)
    (*begin)->handler ()->stop (TAO_FlowSpec_Entry::TAO_AV_CONSUMER);
}

---

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

• AVStreams_i.h
• AVStreams_i.cpp

---