TAO_AV_UDP_Flow_Handler Class Reference

Flow Handler for UDP flows. More...

#include <UDP.h>

Inheritance diagram for TAO_AV_UDP_Flow_Handler:

Inheritance graph
[legend]
Collaboration diagram for TAO_AV_UDP_Flow_Handler:

Collaboration graph
[legend]
List of all members.

Public Member Functions

 TAO_AV_UDP_Flow_Handler (void)
virtual ~TAO_AV_UDP_Flow_Handler (void)
int open (ACE_Addr &address)
int close (void)
virtual TAO_AV_Transport * transport (void)
 get the transport.
virtual int set_remote_address (ACE_Addr *address)
 set the remote address.
virtual ACE_HANDLE get_handle (void) const
virtual int handle_input (ACE_HANDLE fd)
virtual int handle_timeout (const ACE_Time_Value &tv, const void *arg=0)
const ACE_SOCK_Dgram * get_socket (void) const
virtual ACE_Event_Handler * event_handler (void)
 get the underlying event handler. To be overridden by the derived clases.
virtual int change_qos (AVStreams::QoS)
 Change the QoS.

Protected Attributes

TAO_AV_Core * av_core_
ACE_INET_Addr peer_addr_
ACE_SOCK_Dgram sock_dgram_

Detailed Description

Flow Handler for UDP flows.

Definition at line 110 of file UDP.h.

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_AV_UDP_Flow_Handler::TAO_AV_UDP_Flow_Handler ( void   ) 

Ctor Dtor

Definition at line 24 of file UDP.cpp.

References ACE_NEW.

00025 {
00026   ACE_NEW (this->transport_,
00027            TAO_AV_UDP_Transport (this));
00028 }

TAO_AV_UDP_Flow_Handler::~TAO_AV_UDP_Flow_Handler ( void   )  [virtual]

Definition at line 30 of file UDP.cpp.

References close(), ACE_Singleton< TYPE, ACE_LOCK >::instance(), ACE_Event_Handler::READ_MASK, and TAO_AV_Flow_Handler::transport_.

00031 {
00032   // remove the event handler from the reactor.
00033   TAO_AV_CORE::instance()->reactor ()->remove_handler (this->event_handler(),
00034                                               ACE_Event_Handler::READ_MASK);
00035 
00036   // close the socket.
00037   this->close ();
00038   delete this->transport_;
00039 }

Member Function Documentation

int TAO_AV_UDP_Flow_Handler::change_qos ( AVStreams::QoS   )  [virtual]

Change the QoS.

Reimplemented from TAO_AV_Flow_Handler.

Definition at line 86 of file UDP.cpp.

References ACE_DEBUG, IPPROTO_IP, LM_DEBUG, AVStreams::QoS::QoSParams, ACE_SOCK::set_option(), sock_dgram_, ACE_OS::strcmp(), and TAO_debug_level.

00087 {
00088   if( TAO_debug_level > 0 )
00089     {
00090       ACE_DEBUG ((LM_DEBUG,
00091                   "(%N,%l) TAO_AV_UDP_Flow_Handler::change_qos\n"));
00092     }
00093 
00094   unsigned int i=0;
00095 
00096   int ret = 0;
00097   CORBA::Long dscp = 0;
00098   CORBA::Long ecn = 0;
00099   int dscp_flag=0;
00100   for(i=0; i < qos.QoSParams.length(); i++)
00101     {
00102 
00103       if( ACE_OS::strcmp( qos.QoSParams[i].property_name.in(), "Diffserv_Codepoint") == 0)
00104         {
00105           qos.QoSParams[i].property_value >>= dscp;
00106           dscp_flag=1;
00107           // DSCP value can only be 6 bits wide
00108           if(!((dscp >= 0) && (dscp <= 63)))
00109             {
00110               dscp_flag = 0;
00111               ACE_DEBUG((LM_DEBUG, "(%N,%l) ECN value can only be (0-3) not %d\n", ecn));
00112               return -1;
00113             }
00114         }
00115 
00116       if( ACE_OS::strcmp( qos.QoSParams[i].property_name.in(), "ECN") == 0)
00117         {
00118           qos.QoSParams[i].property_value >>= ecn;
00119           // ECN value can only occupy bits 6 and 7 of the
00120           // IP Diffserv byte
00121           if(!((ecn >= 0) && (ecn <= 3)))
00122             {
00123               ACE_DEBUG((LM_DEBUG, "(%N,%l) ECN value can only be (0-3) not %d\n", ecn));
00124               ecn = 0;
00125             }
00126 
00127         }
00128     }
00129       // Set the Diffserv byte only if we specified
00130       // the Diffserv Codepoint (DSCP) or ECN via QoSParams
00131       // passed into this method
00132       if(dscp_flag || ecn)
00133         {
00134           int tos;
00135           tos = (int)(dscp << 2);
00136           if(ecn)
00137             {
00138               tos |= ecn;
00139             }
00140           ret = sock_dgram_.set_option(IPPROTO_IP, IP_TOS, (int *)&tos , (int)sizeof(tos));
00141 
00142           if(TAO_debug_level > 1)
00143             {
00144               ACE_DEBUG((LM_DEBUG, "(%N,%l) set tos: ret: %d\n", ret));
00145             }
00146         }
00147 
00148       if(TAO_debug_level > 1)
00149         {
00150            if(ret < 0 )
00151              {
00152                 ACE_DEBUG((LM_DEBUG, "(%N,%l) errno: %p\n"));
00153              }
00154         }
00155       return ret;
00156 }

ACE_INLINE int TAO_AV_UDP_Flow_Handler::close ( void   ) 

Definition at line 27 of file UDP.inl.

References ACE_SOCK::close(), and sock_dgram_.

Referenced by ~TAO_AV_UDP_Flow_Handler().

00028 {
00029   return  this->sock_dgram_.close ();
00030 }

virtual ACE_Event_Handler* TAO_AV_UDP_Flow_Handler::event_handler ( void   )  [inline, virtual]

get the underlying event handler. To be overridden by the derived clases.

Implements TAO_AV_Flow_Handler.

Definition at line 127 of file UDP.h.

00127 { return this; }

ACE_HANDLE TAO_AV_UDP_Flow_Handler::get_handle ( void   )  const [virtual]

Reimplemented from ACE_Event_Handler.

Definition at line 75 of file UDP.cpp.

References ACE_DEBUG, ACE_IPC_SAP::get_handle(), LM_DEBUG, sock_dgram_, and TAO_debug_level.

00076 {
00077   if (TAO_debug_level > 0)
00078     ACE_DEBUG ((LM_DEBUG,
00079                 "TAO_AV_UDP_Flow_Handler::get_handle:%d\n",
00080                 this->sock_dgram_.get_handle ()));
00081 
00082   return this->sock_dgram_.get_handle () ;
00083 }

TAO_BEGIN_VERSIONED_NAMESPACE_DECL ACE_INLINE const ACE_SOCK_Dgram * TAO_AV_UDP_Flow_Handler::get_socket ( void   )  const

Definition at line 13 of file UDP.inl.

References sock_dgram_.

Referenced by TAO_AV_UDP_Transport::recv(), TAO_AV_UDP_Transport::send(), and TAO_AV_UDP_Connection_Setup::setup().

00014 {
00015   return &this->sock_dgram_;
00016 }

int TAO_AV_UDP_Flow_Handler::handle_input ( ACE_HANDLE  fd  )  [virtual]

Reimplemented from ACE_Event_Handler.

Definition at line 48 of file UDP.cpp.

References TAO_AV_Protocol_Object::handle_input(), and TAO_AV_Flow_Handler::protocol_object_.

00049 {
00050   return this->protocol_object_->handle_input ();
00051 }

int TAO_AV_UDP_Flow_Handler::handle_timeout ( const ACE_Time_Value &  tv,
const void *  arg = 0 
) [virtual]

Reimplemented from ACE_Event_Handler.

Definition at line 54 of file UDP.cpp.

References TAO_AV_Flow_Handler::handle_timeout().

00056 {
00057   return TAO_AV_Flow_Handler::handle_timeout (tv,arg);
00058 }

ACE_INLINE int TAO_AV_UDP_Flow_Handler::open ( ACE_Addr &  address  ) 

Definition at line 20 of file UDP.inl.

References ACE_SOCK_Dgram::open(), and sock_dgram_.

Referenced by TAO_AV_UDP_Connection_Setup::setup().

00021 {
00022   return this->sock_dgram_.open (address);
00023 }

int TAO_AV_UDP_Flow_Handler::set_remote_address ( ACE_Addr *  address  )  [virtual]

set the remote address.

Reimplemented from TAO_AV_Flow_Handler.

Definition at line 61 of file UDP.cpp.

References ACE_DEBUG, inet_addr(), LM_DEBUG, peer_addr_, TAO_debug_level, transport(), and TAO_AV_Flow_Handler::transport_.

Referenced by TAO_AV_UDP_Connection_Setup::setup().

00062 {
00063   if (TAO_debug_level > 0)
00064     ACE_DEBUG ((LM_DEBUG,"TAO_AV_UDP_Flow_Handler::set_remote_address\n"));
00065 
00066   ACE_INET_Addr *inet_addr = dynamic_cast<ACE_INET_Addr*> (address);
00067   this->peer_addr_ = *inet_addr;
00068   TAO_AV_UDP_Transport *transport = dynamic_cast<TAO_AV_UDP_Transport*> (this->transport_);
00069 
00070   return transport->set_remote_address (*inet_addr);
00071 }

TAO_AV_Transport * TAO_AV_UDP_Flow_Handler::transport ( void   )  [virtual]

get the transport.

Reimplemented from TAO_AV_Flow_Handler.

Definition at line 42 of file UDP.cpp.

References TAO_AV_Flow_Handler::transport_.

Referenced by set_remote_address().

00043 {
00044   return this->transport_;
00045 }

Member Data Documentation

TAO_AV_Core* TAO_AV_UDP_Flow_Handler::av_core_ [protected]

Definition at line 132 of file UDP.h.

ACE_INET_Addr TAO_AV_UDP_Flow_Handler::peer_addr_ [protected]

Definition at line 133 of file UDP.h.

Referenced by set_remote_address().

ACE_SOCK_Dgram TAO_AV_UDP_Flow_Handler::sock_dgram_ [protected]

Definition at line 134 of file UDP.h.

Referenced by change_qos(), close(), get_handle(), get_socket(), and open().

The documentation for this class was generated from the following files:
Generated on Tue Feb 2 17:48:07 2010 for TAO_AV by  doxygen 1.4.7