TAO_IIOP_Connection_Handler Class Reference

Handles requests on a single connection. More...

#include <IIOP_Connection_Handler.h>

Inheritance diagram for TAO_IIOP_Connection_Handler:

[legend]Collaboration diagram for TAO_IIOP_Connection_Handler:

[legend]List of all members.

Public Member Functions
	TAO_IIOP_Connection_Handler (ACE_Thread_Manager *=0)
	TAO_IIOP_Connection_Handler (TAO_ORB_Core *orb_core, CORBA::Boolean flag)
	Constructor.
	~TAO_IIOP_Connection_Handler (void)
	Destructor.
virtual int	open (void *)
int	close (u_long=0)
int	add_transport_to_cache (void)
	Add ourselves to Cache.
int	process_listen_point_list (IIOP::ListenPointList &listen_list)
	Process the listen_list.
int	enable_network_priority (void)
	Check if network priority needs to be enabled.
int	set_dscp_codepoint (CORBA::Boolean set_network_priority)
	Set Diff-Serv codepoint on outgoing packets.
virtual int	open_handler (void *)
	A open () hook.
void	abort (void)
Event Handler overloads
virtual int	resume_handler (void)
virtual int	close_connection (void)
	Close the underlying connection.
virtual int	handle_input (ACE_HANDLE)
virtual int	handle_output (ACE_HANDLE)
virtual int	handle_close (ACE_HANDLE, ACE_Reactor_Mask)
virtual int	handle_timeout (const ACE_Time_Value &current_time, const void *act=0)
Protected Member Functions
	TAO_IIOP_Connection_Handler (TAO_ORB_Core *orb_core)
	Constructor that could be used by the derived classes.
TAO_Connection Handler overloads
virtual int	release_os_resources (void)
	Release the OS resources related to this handler.
Private Attributes
int	dscp_codepoint_
	Stores the type of service value.

---

Detailed Description

Handles requests on a single connection.

The Connection handler which is common for the Acceptor and the Connector

Definition at line 61 of file IIOP_Connection_Handler.h.

---

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_IIOP_Connection_Handler::TAO_IIOP_Connection_Handler (  ACE_Thread_Manager *  = 0  )

Definition at line 24 of file IIOP_Connection_Handler.cpp. References ACE_ASSERT, IPDSFIELD_DSCP_DEFAULT, and TAO_IIOP_SVC_HANDLER. : TAO_IIOP_SVC_HANDLER (t, 0 , 0), TAO_Connection_Handler (0), dscp_codepoint_ (IPDSFIELD_DSCP_DEFAULT << 2) { // This constructor should *never* get called, it is just here to // make the compiler happy: the default implementation of the // Creation_Strategy requires a constructor with that signature, we // don't use that implementation, but some (most?) compilers // instantiate it anyway. ACE_ASSERT (0); }

TAO_IIOP_Connection_Handler::TAO_IIOP_Connection_Handler (  TAO_ORB_Core *  orb_core, CORBA::Boolean  flag )

Constructor. Definition at line 38 of file IIOP_Connection_Handler.cpp. References ACE_NEW, IPDSFIELD_DSCP_DEFAULT, TAO_IIOP_SVC_HANDLER, and TAO_Connection_Handler::transport(). : TAO_IIOP_SVC_HANDLER (orb_core->thr_mgr (), 0, 0), TAO_Connection_Handler (orb_core), dscp_codepoint_ (IPDSFIELD_DSCP_DEFAULT << 2) { TAO_IIOP_Transport* specific_transport = 0; ACE_NEW (specific_transport, TAO_IIOP_Transport (this, orb_core, flag)); // store this pointer (indirectly increment ref count) this->transport (specific_transport); }

TAO_IIOP_Connection_Handler::~TAO_IIOP_Connection_Handler (  void   )

Destructor. Definition at line 60 of file IIOP_Connection_Handler.cpp. References TAO_Connection_Handler::transport(). { delete this->transport (); }

TAO_IIOP_Connection_Handler::TAO_IIOP_Connection_Handler (  TAO_ORB_Core *  orb_core  )  [protected]

Constructor that could be used by the derived classes. Sometimes new pluggable protocols which have similarities with IIOP may be tempted to this class for their use. Classical example being that of IIOP_SSL_Connection_Handler. This constructor just initializes its base class and sets all of its contents to the default value, if any Definition at line 53 of file IIOP_Connection_Handler.cpp. References IPDSFIELD_DSCP_DEFAULT, and TAO_IIOP_SVC_HANDLER. : TAO_IIOP_SVC_HANDLER (orb_core->thr_mgr (), 0, 0), TAO_Connection_Handler (orb_core), dscp_codepoint_ (IPDSFIELD_DSCP_DEFAULT << 2) { }

---

Member Function Documentation

void TAO_IIOP_Connection_Handler::abort (  void   )

This is used during a canceled connection attempt. Force the SO_LINGER timeout to 0 so that when the peer is closed, it won't hang around. Definition at line 501 of file IIOP_Connection_Handler.cpp. References ACE_DEBUG, ACE_TEXT, LM_DEBUG, and TAO_debug_level. Referenced by TAO_IIOP_Connector::cancel_svc_handler(). { struct linger lval; lval.l_onoff = 1; lval.l_linger = 0; if (this->peer ().set_option(SOL_SOCKET, SO_LINGER, (void*) &lval, sizeof (lval)) == -1) { if (TAO_debug_level) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TAO (%P|%t) Unable to set ") ACE_TEXT ("SO_LINGER on %d\n"), this->peer ().get_handle ())); } } }

int TAO_IIOP_Connection_Handler::add_transport_to_cache (  void   )

Add ourselves to Cache. Definition at line 349 of file IIOP_Connection_Handler.cpp. References TAO::Transport_Cache_Manager::cache_idle_transport(), TAO_ORB_Core::lane_resources(), TAO_Connection_Handler::orb_core(), and TAO_Thread_Lane_Resources::transport_cache(). { ACE_INET_Addr addr; // Get the peername. if (this->peer ().get_remote_addr (addr) == -1) return -1; // Construct an IIOP_Endpoint object TAO_IIOP_Endpoint endpoint ( addr, this->orb_core()->orb_params()->cache_incoming_by_dotted_decimal_address ()); // Construct a property object TAO_Base_Transport_Property prop (&endpoint); TAO::Transport_Cache_Manager &cache = this->orb_core ()->lane_resources ().transport_cache (); // Idle the transport.. return cache.cache_idle_transport (&prop, this->transport ()); }

int TAO_IIOP_Connection_Handler::close (  u_long  = 0  )

Close called by the Acceptor or Connector when connection establishment fails. Definition at line 337 of file IIOP_Connection_Handler.cpp. References TAO_Connection_Handler::close_handler(). Referenced by TAO_IIOP_Connector::complete_connection(), and handle_timeout(). { return this->close_handler (); }

int TAO_IIOP_Connection_Handler::close_connection (  void   )  [virtual]

Close the underlying connection. Used by the ORB to actively close connections that are idle, stale or somehow are determined to be broken before the Reactor does. Returns: Return 0 if the connection was already closed, non-zero otherwise. Implements TAO_Connection_Handler. Definition at line 268 of file IIOP_Connection_Handler.cpp. References ACE_DEBUG, ACE_TEXT, TAO_Connection_Handler::close_connection_eh(), TAO_ORB_Parameters::linger(), LM_DEBUG, TAO_Connection_Handler::orb_core(), TAO_ORB_Core::orb_params(), and TAO_debug_level. Referenced by handle_output(). { // To maintain maximum compatibility, we only set this socket option // if the user has provided a linger timeout. int linger = this->orb_core()->orb_params()->linger (); if (linger != -1) { struct linger lval; lval.l_onoff = 1; lval.l_linger = (u_short)linger; if (this->peer ().set_option(SOL_SOCKET, SO_LINGER, (void*) &lval, sizeof (lval)) == -1) { if (TAO_debug_level) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TAO (%P|%t) Unable to set ") ACE_TEXT ("SO_LINGER on %d\n"), this->peer ().get_handle ())); } } } return this->close_connection_eh (this); }

int TAO_IIOP_Connection_Handler::enable_network_priority (  void   )

Check if network priority needs to be enabled.

int TAO_IIOP_Connection_Handler::handle_close (  ACE_HANDLE  , ACE_Reactor_Mask  )  [virtual]

Definition at line 329 of file IIOP_Connection_Handler.cpp. References ACE_ASSERT. { ACE_ASSERT (0); return 0; }

int TAO_IIOP_Connection_Handler::handle_input (  ACE_HANDLE   )  [virtual]

The event handler calls, here so that other objects who hold a reference to this object can call the event handler methods. Implements TAO_Connection_Handler. Definition at line 298 of file IIOP_Connection_Handler.cpp. References TAO_Connection_Handler::handle_input_eh(). { return this->handle_input_eh (h, this); }

int TAO_IIOP_Connection_Handler::handle_output (  ACE_HANDLE   )  [virtual]

Definition at line 304 of file IIOP_Connection_Handler.cpp. References close_connection(), and TAO_Connection_Handler::handle_output_eh(). { const int result = this->handle_output_eh (handle, this); if (result == -1) { this->close_connection (); return 0; } return result; }

int TAO_IIOP_Connection_Handler::handle_timeout (  const ACE_Time_Value &  current_time, const void *  act = 0 )  [virtual]

Definition at line 319 of file IIOP_Connection_Handler.cpp. References close(). { // We don't use this upcall for I/O. This is only used by the // Connector to indicate that the connection timedout. Therefore, // we should call close(). return this->close (); }

int TAO_IIOP_Connection_Handler::open (  void *   )  [virtual]

Called by the Strategy_Acceptor when the handler is completely connected. Argument is unused. Definition at line 79 of file IIOP_Connection_Handler.cpp. References ACE_CATCHANY, ACE_CHECK_RETURN, ACE_DEBUG, ACE_DECLARE_NEW_CORBA_ENV, ACE_ENDTRY, ACE_ENV_ARG_PARAMETER, ACE_ERROR, ACE_IPPROTO_TCP, ACE_NONBLOCK, ACE_TCHAR, ACE_TEXT, ACE_TRY, ACE_TRY_CHECK, ACE_INET_Addr::addr_to_string(), TAO_Protocols_Hooks::client_protocol_properties_at_orb_level(), TAO_ORB_Parameters::connect_ipv6_only(), TAO_IIOP_Protocol_Properties::dont_route_, ENOTSUP, ACE_INET_Addr::get_host_addr(), ACE_INET_Addr::get_port_number(), TAO_ORB_Core::get_protocols_hooks(), ACE_INET_Addr::is_ipv4_mapped_ipv6(), TAO_IIOP_Protocol_Properties::keep_alive_, LM_DEBUG, LM_ERROR, LM_WARNING, MAXHOSTNAMELEN, TAO_IIOP_Protocol_Properties::no_delay_, TAO_ORB_Parameters::nodelay(), TAO_Wait_Strategy::non_blocking(), TAO_Transport::opened_as(), TAO_Connection_Handler::orb_core(), TAO_ORB_Core::orb_params(), TAO_Transport::post_open(), TAO_IIOP_Protocol_Properties::recv_buffer_size_, TAO_IIOP_Protocol_Properties::send_buffer_size_, TAO_Protocols_Hooks::server_protocol_properties_at_orb_level(), TAO_Connection_Handler::set_socket_option(), TAO_ORB_Parameters::sock_dontroute(), TAO_ORB_Parameters::sock_keepalive(), TAO_ORB_Parameters::sock_rcvbuf_size(), TAO_ORB_Parameters::sock_sndbuf_size(), TAO_LF_Event::state_changed(), TAO_debug_level, TAO_Connection_Handler::transport(), and TAO_Transport::wait_strategy(). Referenced by open_handler(). { TAO_IIOP_Protocol_Properties protocol_properties; // Initialize values from ORB params. protocol_properties.send_buffer_size_ = this->orb_core ()->orb_params ()->sock_sndbuf_size (); protocol_properties.recv_buffer_size_ = this->orb_core ()->orb_params ()->sock_rcvbuf_size (); protocol_properties.no_delay_ = this->orb_core ()->orb_params ()->nodelay (); protocol_properties.keep_alive_ = this->orb_core ()->orb_params ()->sock_keepalive (); protocol_properties.dont_route_ = this->orb_core ()->orb_params ()->sock_dontroute (); TAO_Protocols_Hooks *tph = this->orb_core ()->get_protocols_hooks (); bool const client = this->transport ()->opened_as () == TAO::TAO_CLIENT_ROLE; ACE_DECLARE_NEW_CORBA_ENV; ACE_TRY { if (client) { tph->client_protocol_properties_at_orb_level ( protocol_properties ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; } else { tph->server_protocol_properties_at_orb_level ( protocol_properties ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; } } ACE_CATCHANY { return -1; } ACE_ENDTRY; ACE_CHECK_RETURN (-1); if (this->set_socket_option (this->peer (), protocol_properties.send_buffer_size_, protocol_properties.recv_buffer_size_) == -1) return -1; #if !defined (ACE_LACKS_TCP_NODELAY) if (this->peer ().set_option (ACE_IPPROTO_TCP, TCP_NODELAY, (void *) &protocol_properties.no_delay_, sizeof (protocol_properties.no_delay_)) == -1) return -1; #endif /* ! ACE_LACKS_TCP_NODELAY */ if (protocol_properties.keep_alive_) { if (this->peer (). set_option (SOL_SOCKET, SO_KEEPALIVE, (void *) &protocol_properties.keep_alive_, sizeof (protocol_properties.keep_alive_)) == -1 && errno != ENOTSUP) { return -1; } } #if !defined (ACE_LACKS_SO_DONTROUTE) if (protocol_properties.dont_route_) { if (this->peer (). set_option (SOL_SOCKET, SO_DONTROUTE, (void *) &protocol_properties.dont_route_, sizeof (protocol_properties.dont_route_)) == -1 && errno != ENOTSUP) { return -1; } } #endif /* ! ACE_LACKS_SO_DONTROUTE */ if (this->transport ()->wait_strategy ()->non_blocking () || this->transport ()->opened_as () == TAO::TAO_SERVER_ROLE) { if (this->peer ().enable (ACE_NONBLOCK) == -1) return -1; } // Called by the <Strategy_Acceptor> when the handler is // completely connected. ACE_INET_Addr remote_addr; if (this->peer ().get_remote_addr (remote_addr) == -1) return -1; ACE_INET_Addr local_addr; if (this->peer ().get_local_addr (local_addr) == -1) return -1; if (TAO_debug_level > 2) ACE_DEBUG ((LM_DEBUG, ACE_TEXT("TAO (%P|%t) - IIOP_Connection_Handler::open, ") ACE_TEXT("The local addr is <%s:%d> \n"), local_addr.get_host_addr (), local_addr.get_port_number())); if (local_addr == remote_addr) { if (TAO_debug_level > 0) { ACE_TCHAR remote_as_string[MAXHOSTNAMELEN + 16]; ACE_TCHAR local_as_string[MAXHOSTNAMELEN + 16]; (void) remote_addr.addr_to_string (remote_as_string, sizeof(remote_as_string)); (void) local_addr.addr_to_string (local_as_string, sizeof(local_as_string)); ACE_ERROR ((LM_ERROR, ACE_TEXT("TAO(%P|%t) - IIOP_Connection_Handler::open, ") ACE_TEXT("Holy Cow! The remote addr and ") ACE_TEXT("local addr are identical (%s == %s)\n"), remote_as_string, local_as_string)); } return -1; } #if defined (ACE_HAS_IPV6) && !defined (ACE_HAS_IPV6_V6ONLY) // Check if we need to invalidate accepted connections // from IPv4 mapped IPv6 addresses if (this->orb_core ()->orb_params ()->connect_ipv6_only () && remote_addr.is_ipv4_mapped_ipv6 ()) { if (TAO_debug_level > 0) { ACE_TCHAR remote_as_string[MAXHOSTNAMELEN + 16]; (void) remote_addr.addr_to_string (remote_as_string, sizeof(remote_as_string)); ACE_ERROR ((LM_WARNING, ACE_TEXT("TAO (%P|%t) - IIOP_Connection_Handler::open, ") ACE_TEXT("invalid connection from IPv4 mapped IPv6 interface <%s>!\n"), remote_as_string)); } return -1; } #endif /* ACE_HAS_IPV6 && ACE_HAS_IPV6_V6ONLY */ if (TAO_debug_level > 0) { ACE_TCHAR client_addr[MAXHOSTNAMELEN + 16]; // Verify that we can resolve the peer hostname. if (remote_addr.addr_to_string (client_addr, sizeof (client_addr)) == -1) return -1; ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("TAO (%P|%t) - IIOP_Connection_Handler::open, IIOP ") ACE_TEXT ("connection to peer <%s> on %d\n"), client_addr, this->peer ().get_handle ())); } // Set that the transport is now connected, if fails we return -1 // Use C-style cast b/c otherwise we get warnings on lots of // compilers if (!this->transport ()->post_open ((size_t) this->get_handle ())) return -1; this->state_changed (TAO_LF_Event::LFS_SUCCESS, this->orb_core ()->leader_follower ()); return 0; }

int TAO_IIOP_Connection_Handler::open_handler (  void *   )  [virtual]

A open () hook. See Thread_Per_Connection_Handler for a use case Implements TAO_Connection_Handler. Definition at line 73 of file IIOP_Connection_Handler.cpp. References open(), and v. { return this->open (v); }

int TAO_IIOP_Connection_Handler::process_listen_point_list (  IIOP::ListenPointList &  listen_list  )

Process the listen_list. Definition at line 374 of file IIOP_Connection_Handler.cpp. References ACE_DEBUG, ACE_ERROR, ACE_TEXT, ACE_TEXT_CHAR_TO_TCHAR, IIOP::ListenPoint::host, TAO::unbounded_value_sequence< ListenPoint >::length(), LM_DEBUG, LM_ERROR, TAO_Transport::make_idle(), IIOP::ListenPoint::port, TAO_Transport::recache_transport(), TAO_Transport_Descriptor_Interface::set_bidir_flag(), TAO_debug_level, and TAO_Connection_Handler::transport(). Referenced by TAO_IIOP_Transport::tear_listen_point_list(). { // Get the size of the list const CORBA::ULong len = listen_list.length (); if (TAO_debug_level > 0 && len == 0) { ACE_ERROR ((LM_ERROR, ACE_TEXT("TAO (%P|%t) - IIOP_Connection_Handler::") ACE_TEXT("process_listen_point_list, ") ACE_TEXT("Received list of size 0, check client config.\n"))); } for (CORBA::ULong i = 0; i < len; ++i) { IIOP::ListenPoint listen_point = listen_list[i]; ACE_INET_Addr addr (listen_point.port, listen_point.host.in ()); if (TAO_debug_level > 0) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT("TAO (%P|%t) - IIOP_Connection_Handler::") ACE_TEXT("process_listen_point_list, ") ACE_TEXT("Listening port [%d] on [%s]\n"), listen_point.port, ACE_TEXT_CHAR_TO_TCHAR(listen_point.host.in ()))); } // Construct an IIOP_Endpoint object using the host as provided // in the listen point list. We must use host in that form because // that's also how the ORB on the other side will advertise the host // in an IOR. TAO_IIOP_Endpoint endpoint (listen_point.host.in (), listen_point.port, addr); // Construct a property object TAO_Base_Transport_Property prop (&endpoint); // Mark the connection as bidirectional prop.set_bidir_flag (1); // The property for this handler has changed. Recache the // handler with this property int retval = this->transport ()->recache_transport (&prop); if (retval == -1) return retval; // Make the handler idle and ready for use this->transport ()->make_idle (); } return 0; }

int TAO_IIOP_Connection_Handler::release_os_resources (  void   )  [protected, virtual]

Release the OS resources related to this handler. Reimplemented from TAO_Connection_Handler. Definition at line 343 of file IIOP_Connection_Handler.cpp. { return this->peer ().close (); }

int TAO_IIOP_Connection_Handler::resume_handler (  void   )  [virtual]

Definition at line 262 of file IIOP_Connection_Handler.cpp. { return ACE_Event_Handler::ACE_APPLICATION_RESUMES_HANDLER; }

int TAO_IIOP_Connection_Handler::set_dscp_codepoint (  CORBA::Boolean  set_network_priority  )  [virtual]

Set Diff-Serv codepoint on outgoing packets. Reimplemented from TAO_Connection_Handler. Definition at line 433 of file IIOP_Connection_Handler.cpp. References ACE_DEBUG, dscp_codepoint_, TAO_Protocols_Hooks::get_dscp_codepoint(), TAO_ORB_Core::get_protocols_hooks(), ACE_Addr::get_type(), IPDSFIELD_DSCP_DEFAULT, LM_DEBUG, TAO_Connection_Handler::orb_core(), and TAO_debug_level. { int tos = IPDSFIELD_DSCP_DEFAULT << 2; if (set_network_priority) { TAO_Protocols_Hooks *tph = this->orb_core ()->get_protocols_hooks (); CORBA::Long codepoint = tph->get_dscp_codepoint (); tos = static_cast<int> (codepoint) << 2; } if (tos != this->dscp_codepoint_) { int result = 0; #if defined (ACE_HAS_IPV6) ACE_INET_Addr local_addr; if (this->peer ().get_local_addr (local_addr) == -1) return -1; else if (local_addr.get_type () == AF_INET6) # if !defined (IPV6_TCLASS) // IPv6 defines option IPV6_TCLASS for specifying traffic class/priority // but not many implementations yet (very new;-). { if (TAO_debug_level) { ACE_DEBUG ((LM_DEBUG, "TAO (%P|%t) - IIOP_Connection_Handler::" "set_dscp_codepoint -> IPV6_TCLASS not supported yet\n")); } return 0; } # else /* !IPV6_TCLASS */ result = this->peer ().set_option (IPPROTO_IPV6, IPV6_TCLASS, (int *) &tos , (int) sizeof (tos)); else # endif /* IPV6_TCLASS */ #endif /* ACE_HAS_IPV6 */ result = this->peer ().set_option (IPPROTO_IP, IP_TOS, (int *) &tos , (int) sizeof (tos)); if (TAO_debug_level) { ACE_DEBUG ((LM_DEBUG, "TAO (%P|%t) - IIOP_Connection_Handler::" "set_dscp_codepoint -> dscp: %x; result: %d; %s\n", tos, result, result == -1 ? "try running as superuser" : "")); } // On successful setting of TOS field. if (result == 0) this->dscp_codepoint_ = tos; } return 0; }

---

Member Data Documentation

int TAO_IIOP_Connection_Handler::dscp_codepoint_ [private]

Stores the type of service value. Definition at line 137 of file IIOP_Connection_Handler.h. Referenced by set_dscp_codepoint().

---

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

• IIOP_Connection_Handler.h
• IIOP_Connection_Handler.cpp

---