#include <AVStreams_i.h>
Inheritance diagram for TAO_Base_StreamEndPoint:
Public Member Functions | |
TAO_Base_StreamEndPoint (void) | |
virtual | ~TAO_Base_StreamEndPoint (void) |
virtual int | handle_open (void) |
called when streamendpoint is instantiated | |
virtual int | handle_close (void) |
called when streamendpoint is being destructed | |
virtual int | handle_stop (const AVStreams::flowSpec &the_spec ACE_ENV_ARG_DECL_WITH_DEFAULTS) |
Application needs to define this. | |
virtual int | handle_start (const AVStreams::flowSpec &the_spec ACE_ENV_ARG_DECL_WITH_DEFAULTS) |
Application needs to define this. | |
virtual int | handle_destroy (const AVStreams::flowSpec &the_spec ACE_ENV_ARG_DECL_WITH_DEFAULTS) |
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 ACE_ENV_ARG_DECL_WITH_DEFAULTS) |
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 int | set_protocol_object (const char *flowname, TAO_AV_Protocol_Object *object) |
virtual void | set_flow_handler (const char *flowname, TAO_AV_Flow_Handler *handler) |
virtual void | set_control_flow_handler (const char *flowname, TAO_AV_Flow_Handler *handler) |
TAO_AV_QoS & | qos (void) |
void | protocol_object_set (void) |
int | is_protocol_object_set (void) |
Protected Attributes | |
TAO_AV_QoS | qos_ |
Flow_Handler_Map | flow_handler_map_ |
Flow_Handler_Map | control_flow_handler_map_ |
int | protocol_object_set_ |
Definition at line 464 of file AVStreams_i.h.
|
Definition at line 1651 of file AVStreams_i.cpp.
01652 : protocol_object_set_ (0) 01653 { 01654 } |
|
Definition at line 1656 of file AVStreams_i.cpp.
01657 { 01658 } |
|
Definition at line 1741 of file AVStreams_i.cpp. Referenced by TAO_AV_UDP_Flow_Factory::make_protocol_object(), TAO_AV_TCP_Flow_Factory::make_protocol_object(), TAO_AV_SFP_Factory::make_protocol_object(), and TAO_AV_RTP_Flow_Factory::make_protocol_object().
01743 {
01744 return -1;
01745 }
|
|
Definition at line 1748 of file AVStreams_i.cpp.
01750 {
01751 return -1;
01752 }
|
|
called when streamendpoint is being destructed
Definition at line 1661 of file AVStreams_i.cpp.
01662 { 01663 // This method should not be defined, but EGCS complains endlessly 01664 // about it. 01665 return -1; 01666 } |
|
Application needs to define this.
|
|
Application needs to define this.
|
|
called when streamendpoint is instantiated
Definition at line 1669 of file AVStreams_i.cpp.
01670 {
01671 return 0;
01672 }
|
|
Application needs to define this.
Definition at line 1704 of file AVStreams_i.cpp. References AVStreams::flowSpec, ACE_Singleton< TYPE, ACE_LOCK >::instance(), and is_protocol_object_set().
01705 { 01706 01707 while (!this->is_protocol_object_set ()) 01708 TAO_AV_CORE::instance ()->orb ()->perform_work (); 01709 return 1; 01710 } |
|
Application needs to define this.
Definition at line 1697 of file AVStreams_i.cpp. References AVStreams::flowSpec.
01698 {
01699 return 1;
01700 }
|
|
Application needs to define this.
|
|
Application needs to define this.
|
|
Definition at line 1735 of file AVStreams_i.cpp. References protocol_object_set_. Referenced by handle_postconnect().
01736 { 01737 return this->protocol_object_set_; 01738 } |
|
Definition at line 1728 of file AVStreams_i.cpp. References protocol_object_set_. Referenced by TAO_AV_UDP_Flow_Factory::make_protocol_object(), TAO_AV_TCP_Flow_Factory::make_protocol_object(), and TAO_AV_RTP_Flow_Factory::make_protocol_object().
01729 { 01730 this->protocol_object_set_ = 1; 01731 } |
|
Definition at line 9 of file AVStreams_i.i.
00010 { 00011 return this->qos_; 00012 } |
|
Definition at line 1769 of file AVStreams_i.cpp. References ACE_CString, ACE_ERROR, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::bind(), control_flow_handler_map_, and LM_ERROR. Referenced by TAO_AV_UDP_Connector::connect(), and TAO_AV_UDP_Acceptor::open_i().
01771 { 01772 ACE_CString flow_name_key (flowname); 01773 if (this->control_flow_handler_map_.bind (flow_name_key, handler) != 0) 01774 ACE_ERROR ((LM_ERROR, 01775 "Error in storing control flow handler\n")); 01776 } |
|
Reimplemented in TAO_FlowEndPoint. Definition at line 1755 of file AVStreams_i.cpp. References ACE_CString, ACE_DEBUG, ACE_ERROR, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::bind(), flow_handler_map_, LM_DEBUG, LM_ERROR, and TAO_debug_level. Referenced by TAO_AV_UDP_Connector::connect(), TAO_AV_TCP_Acceptor::make_svc_handler(), TAO_AV_TCP_Connector::make_svc_handler(), and TAO_AV_UDP_Acceptor::open_i().
01757 { 01758 if(TAO_debug_level > 1) 01759 { 01760 ACE_DEBUG ((LM_DEBUG, "(%N,%l) TAO_Base_StreamEndPoint::set_flow_handler(), flowname: %s\n", flowname)); 01761 } 01762 ACE_CString flow_name_key (flowname); 01763 if (this->flow_handler_map_.bind (flow_name_key, handler) != 0) 01764 ACE_ERROR ((LM_ERROR, 01765 "Error in storing flow handler\n")); 01766 } |
|
Reimplemented in TAO_FlowEndPoint. Definition at line 1721 of file AVStreams_i.cpp. Referenced by TAO_AV_UDP_Flow_Factory::make_protocol_object(), TAO_AV_TCP_Flow_Factory::make_protocol_object(), TAO_AV_SFP_Factory::make_protocol_object(), and TAO_AV_RTP_Flow_Factory::make_protocol_object().
01723 {
01724 return -1;
01725 }
|
|
Definition at line 525 of file AVStreams_i.h. Referenced by set_control_flow_handler(). |
|
Definition at line 524 of file AVStreams_i.h. Referenced by set_flow_handler(). |
|
Definition at line 526 of file AVStreams_i.h. Referenced by is_protocol_object_set(), and protocol_object_set(). |
|
Definition at line 523 of file AVStreams_i.h. |