#include <AVStreams_i.h>
Public Member Functions | |
| TAO_StreamEndPoint (void) | |
| Constructor. | |
| virtual void | stop (const AVStreams::flowSpec &the_spec) |
| Stop the stream. Empty the_spec means, for all the flows. | |
| virtual void | start (const AVStreams::flowSpec &the_spec) |
| Start the stream, Empty the_spec means, for all the flows. | |
| virtual void | destroy (const AVStreams::flowSpec &the_spec) |
| Destroy the stream, Empty the_spec means, for all the flows. | |
| virtual CORBA::Boolean | connect (AVStreams::StreamEndPoint_ptr responder, AVStreams::streamQoS &qos_spec, const AVStreams::flowSpec &the_spec) |
| Called by StreamCtrl. responder is the peer to connect to. | |
| virtual CORBA::Boolean | request_connection (AVStreams::StreamEndPoint_ptr initiator, CORBA::Boolean is_mcast, AVStreams::streamQoS &qos, AVStreams::flowSpec &the_spec) |
| virtual CORBA::Boolean | modify_QoS (AVStreams::streamQoS &new_qos, const AVStreams::flowSpec &the_flows) |
| Change the transport qos on a stream. | |
| virtual int | change_qos (AVStreams::streamQoS &new_qos, const AVStreams::flowSpec &the_flows) |
| virtual CORBA::Boolean | set_protocol_restriction (const AVStreams::protocolSpec &the_pspec) |
| Used to restrict the set of protocols. | |
| virtual void | disconnect (const AVStreams::flowSpec &the_spec) |
| disconnect the flows | |
| virtual void | set_FPStatus (const AVStreams::flowSpec &the_spec, const char *fp_name, const CORBA::Any &fp_settings) |
| Used to control the flow. | |
| virtual CORBA::Object_ptr | get_fep (const char *flow_name) |
| Not implemented in the light profile, throws notsupported. | |
| virtual char * | add_fep (CORBA::Object_ptr the_fep) |
| Not implemented in the light profile, throws notsupported. | |
| virtual void | remove_fep (const char *fep_name) |
| Not implemented in the light profile, throws notsupported. | |
| virtual void | set_negotiator (AVStreams::Negotiator_ptr new_negotiator) |
| Used to "attach" a negotiator to the endpoint. | |
| virtual void | set_key (const char *flow_name, const AVStreams::key &the_key) |
| Used for public key encryption. | |
| virtual void | set_source_id (CORBA::Long source_id) |
| Used to set a unique id for packets sent by this streamendpoint. | |
| virtual | ~TAO_StreamEndPoint (void) |
| Destructor. | |
| CORBA::Boolean | multiconnect (AVStreams::streamQoS &the_qos, AVStreams::flowSpec &the_spec) |
Protected Member Functions | |
| char * | add_fep_i (AVStreams::FlowEndPoint_ptr fep) |
| Helper methods to implement add_fep(). | |
| char * | add_fep_i_add_property (AVStreams::FlowEndPoint_ptr fep) |
| int | translate_qos (const AVStreams::streamQoS &application_qos, AVStreams::streamQoS &network_qos) |
| translate from application level to network level qos. | |
Protected Attributes | |
| u_int | flow_count_ |
| u_int | flow_num_ |
| current flow number used for system generation of flow names. | |
| FlowEndPoint_Map | fep_map_ |
| hash table for the flownames and its corresponding flowEndpoint reference. | |
| AVStreams::flowSpec | flows_ |
| sequence of supported flow names. | |
| CORBA::Long | source_id_ |
| source id used for multicast. | |
| AVStreams::Negotiator_var | negotiator_ |
| our local negotiator for QoS. | |
| AVStreams::protocolSpec | protocols_ |
| Our available list of protocols. | |
| CORBA::String_var | protocol_ |
| Chosen protocol for this streamendpoint based on availableprotocols property. | |
| AVStreams::key | key_ |
| Key used for encryption. | |
| u_short | mcast_port_ |
| ACE_CString | mcast_addr_ |
| ACE_Hash_Map_Manager < ACE_CString, TAO_FlowSpec_Entry *, ACE_Null_Mutex > | mcast_entry_map_ |
| TAO_AV_FlowSpecSet | forward_flow_spec_set |
| TAO_AV_FlowSpecSet | reverse_flow_spec_set |
| AVStreams::StreamEndPoint_var | peer_sep_ |
| AVStreams::SFPStatus * | sfp_status_ |
| AVStreams::StreamCtrl_var | streamctrl_ |
| TAO_StreamEndPoint::TAO_StreamEndPoint | ( | void | ) |
Constructor.
| TAO_StreamEndPoint::~TAO_StreamEndPoint | ( | void | ) | [virtual] |
Destructor.
| void TAO_StreamEndPoint::stop | ( | const AVStreams::flowSpec & | the_spec | ) | [virtual] |
Stop the stream. Empty the_spec means, for all the flows.
| void TAO_StreamEndPoint::start | ( | const AVStreams::flowSpec & | the_spec | ) | [virtual] |
Start the stream, Empty the_spec means, for all the flows.
| void TAO_StreamEndPoint::destroy | ( | const AVStreams::flowSpec & | the_spec | ) | [virtual] |
Destroy the stream, Empty the_spec means, for all the flows.
| CORBA::Boolean TAO_StreamEndPoint::connect | ( | AVStreams::StreamEndPoint_ptr | responder, | |
| AVStreams::streamQoS & | qos_spec, | |||
| const AVStreams::flowSpec & | the_spec | |||
| ) | [virtual] |
Called by StreamCtrl. responder is the peer to connect to.
| CORBA::Boolean TAO_StreamEndPoint::request_connection | ( | AVStreams::StreamEndPoint_ptr | initiator, | |
| CORBA::Boolean | is_mcast, | |||
| AVStreams::streamQoS & | qos, | |||
| AVStreams::flowSpec & | the_spec | |||
| ) | [virtual] |
Called by the peer StreamEndPoint. The flow_spec indicates the flows (which contain transport addresses etc.)
| CORBA::Boolean TAO_StreamEndPoint::modify_QoS | ( | AVStreams::streamQoS & | new_qos, | |
| const AVStreams::flowSpec & | the_flows | |||
| ) | [virtual] |
Change the transport qos on a stream.
| int TAO_StreamEndPoint::change_qos | ( | AVStreams::streamQoS & | new_qos, | |
| const AVStreams::flowSpec & | the_flows | |||
| ) | [virtual] |
| CORBA::Boolean TAO_StreamEndPoint::set_protocol_restriction | ( | const AVStreams::protocolSpec & | the_pspec | ) | [virtual] |
Used to restrict the set of protocols.
| void TAO_StreamEndPoint::disconnect | ( | const AVStreams::flowSpec & | the_spec | ) | [virtual] |
disconnect the flows
| void TAO_StreamEndPoint::set_FPStatus | ( | const AVStreams::flowSpec & | the_spec, | |
| const char * | fp_name, | |||
| const CORBA::Any & | fp_settings | |||
| ) | [virtual] |
Used to control the flow.
| CORBA::Object_ptr TAO_StreamEndPoint::get_fep | ( | const char * | flow_name | ) | [virtual] |
Not implemented in the light profile, throws notsupported.
| char * TAO_StreamEndPoint::add_fep | ( | CORBA::Object_ptr | the_fep | ) | [virtual] |
Not implemented in the light profile, throws notsupported.
| void TAO_StreamEndPoint::remove_fep | ( | const char * | fep_name | ) | [virtual] |
Not implemented in the light profile, throws notsupported.
| void TAO_StreamEndPoint::set_negotiator | ( | AVStreams::Negotiator_ptr | new_negotiator | ) | [virtual] |
Used to "attach" a negotiator to the endpoint.
| void TAO_StreamEndPoint::set_key | ( | const char * | flow_name, | |
| const AVStreams::key & | the_key | |||
| ) | [virtual] |
Used for public key encryption.
| void TAO_StreamEndPoint::set_source_id | ( | CORBA::Long | source_id | ) | [virtual] |
Used to set a unique id for packets sent by this streamendpoint.
| CORBA::Boolean TAO_StreamEndPoint::multiconnect | ( | AVStreams::streamQoS & | the_qos, | |
| AVStreams::flowSpec & | the_spec | |||
| ) |
Reimplemented in TAO_StreamEndPoint_A, and TAO_StreamEndPoint_B.
| char * TAO_StreamEndPoint::add_fep_i | ( | AVStreams::FlowEndPoint_ptr | fep | ) | [protected] |
Helper methods to implement add_fep().
| char * TAO_StreamEndPoint::add_fep_i_add_property | ( | AVStreams::FlowEndPoint_ptr | fep | ) | [protected] |
| int TAO_StreamEndPoint::translate_qos | ( | const AVStreams::streamQoS & | application_qos, | |
| AVStreams::streamQoS & | network_qos | |||
| ) | [protected] |
translate from application level to network level qos.
u_int TAO_StreamEndPoint::flow_count_ [protected] |
Count of the number of flows in this streamendpoint, used to generate unique names for the flows.
u_int TAO_StreamEndPoint::flow_num_ [protected] |
current flow number used for system generation of flow names.
FlowEndPoint_Map TAO_StreamEndPoint::fep_map_ [protected] |
hash table for the flownames and its corresponding flowEndpoint reference.
AVStreams::flowSpec TAO_StreamEndPoint::flows_ [protected] |
sequence of supported flow names.
CORBA::Long TAO_StreamEndPoint::source_id_ [protected] |
source id used for multicast.
AVStreams::Negotiator_var TAO_StreamEndPoint::negotiator_ [protected] |
our local negotiator for QoS.
Our available list of protocols.
CORBA::String_var TAO_StreamEndPoint::protocol_ [protected] |
Chosen protocol for this streamendpoint based on availableprotocols property.
AVStreams::key TAO_StreamEndPoint::key_ [protected] |
Key used for encryption.
u_short TAO_StreamEndPoint::mcast_port_ [protected] |
TAO_Forward_FlowSpec_Entry forward_entries_ [FLOWSPEC_MAX]; TAO_Reverse_FlowSpec_Entry reverse_entries_ [FLOWSPEC_MAX];
ACE_CString TAO_StreamEndPoint::mcast_addr_ [protected] |
ACE_Hash_Map_Manager<ACE_CString, TAO_FlowSpec_Entry*,ACE_Null_Mutex> TAO_StreamEndPoint::mcast_entry_map_ [protected] |
AVStreams::StreamEndPoint_var TAO_StreamEndPoint::peer_sep_ [protected] |
AVStreams::SFPStatus* TAO_StreamEndPoint::sfp_status_ [protected] |
AVStreams::StreamCtrl_var TAO_StreamEndPoint::streamctrl_ [protected] |
1.5.3-6