#include <AVStreams_i.h>
Inheritance diagram for TAO_FlowProducer:
Public Member Functions | |
| TAO_FlowProducer (void) | |
| default constructor | |
| TAO_FlowProducer (const char *flowname, AVStreams::protocolSpec protocols, const char *format) | |
| virtual char * | get_rev_channel (const char *pcol_name ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException) |
| virtual void | stop (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException) |
| stop this flow, to be overridden by the application. | |
| virtual void | start (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException) |
| 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 ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException, AVStreams::failedToListen, AVStreams::FPError, AVStreams::QoSRequestFailed) |
| virtual CORBA::Boolean | connect_to_peer (AVStreams::QoS &the_qos, const char *address, const char *use_flow_protocol ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException, AVStreams::failedToConnect, AVStreams::FPError, AVStreams::QoSRequestFailed) |
| virtual char * | connect_mcast (AVStreams::QoS &the_qos, CORBA::Boolean_out is_met, const char *address, const char *use_flow_protocol ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException, AVStreams::failedToConnect, AVStreams::notSupported, AVStreams::FPError, AVStreams::QoSRequestFailed) |
| connect to the multicast address, not implemented. | |
| virtual void | set_key (const AVStreams::key &the_key ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException) |
| sets the public key to be used for encryption of the data. | |
| virtual void | set_source_id (CORBA::Long source_id ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException) |
Protected Attributes | |
| CORBA::Long | source_id_ |
| source id of this producer. | |
| CORBA::String_var | peer_address_ |
|
|
default constructor
Definition at line 4965 of file AVStreams_i.cpp.
04966 {
04967 }
|
|
||||||||||||||||
|
Definition at line 4969 of file AVStreams_i.cpp. References TAO_FlowEndPoint::open(), and AVStreams::protocolSpec.
04972 {
04973 this->open (flowname, protocols, format);
04974 }
|
|
||||||||||||||||||||
|
connect to the multicast address, not implemented.
|
|
||||||||||||||||
|
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. |
|
|
get the reverse channel, to be used for feedback for protocols like UDP. @Naga: In the spec this is defined in the TAO_FlowProducer but it seems more reasonable for this to be in a FlowEndPoint since any of the flowendpoints can be made to listen. So in the case of UDP if the producer is listening and the consumer connects (logically) then the producer needs to know the reverse channel on its peer fep to send data to. |
|
||||||||||||||||||||
|
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. |
|
|
sets the public key to be used for encryption of the data.
|
|
|
sets the source id of this flow producer so that it can be used to distinguish this producer from others in the multicast case. Definition at line 5126 of file AVStreams_i.cpp.
05129 {
05130 this->source_id_ = source_id;
05131 }
|
|
|
start this flow, to be overridden by the application.
|
|
|
stop this flow, to be overridden by the application.
|
|
|
Definition at line 1433 of file AVStreams_i.h. |
|
|
source id of this producer.
Definition at line 1432 of file AVStreams_i.h. |
1.3.6