summaryrefslogtreecommitdiff
path: root/TAO/tao/IIOP_Connection_Handler.cpp
diff options
context:
space:
mode:
authorWilliam R. Otte <wotte@dre.vanderbilt.edu>2006-07-24 15:50:11 +0000
committerWilliam R. Otte <wotte@dre.vanderbilt.edu>2006-07-24 15:50:11 +0000
commit6b846cf03c0bcbd8c276cb0af61a181e5f98eaae (patch)
treeda50d054f9c761c3f6a5923f6979e93306c56d68 /TAO/tao/IIOP_Connection_Handler.cpp
parent0e555b9150d38e3b3473ba325b56db2642e6352b (diff)
downloadATCD-6b846cf03c0bcbd8c276cb0af61a181e5f98eaae.tar.gz
Repo restructuring
Diffstat (limited to 'TAO/tao/IIOP_Connection_Handler.cpp')
-rw-r--r--TAO/tao/IIOP_Connection_Handler.cpp531
1 files changed, 0 insertions, 531 deletions
diff --git a/TAO/tao/IIOP_Connection_Handler.cpp b/TAO/tao/IIOP_Connection_Handler.cpp
deleted file mode 100644
index 0f59383abe5..00000000000
--- a/TAO/tao/IIOP_Connection_Handler.cpp
+++ /dev/null
@@ -1,531 +0,0 @@
-#include "tao/IIOP_Connection_Handler.h"
-
-#if defined (TAO_HAS_IIOP) && (TAO_HAS_IIOP != 0)
-
-#include "tao/debug.h"
-#include "tao/ORB_Core.h"
-#include "tao/IIOP_Transport.h"
-#include "tao/IIOP_Endpoint.h"
-#include "tao/IIOPC.h"
-#include "tao/Thread_Lane_Resources.h"
-#include "tao/Base_Transport_Property.h"
-#include "tao/Protocols_Hooks.h"
-#include "tao/Wait_Strategy.h"
-
-#include "ace/os_include/netinet/os_tcp.h"
-#include "ace/os_include/os_netdb.h"
-
-ACE_RCSID (tao,
- IIOP_Connection_Handler,
- "$Id$")
-
-TAO_BEGIN_VERSIONED_NAMESPACE_DECL
-
-TAO_IIOP_Connection_Handler::TAO_IIOP_Connection_Handler (ACE_Thread_Manager *t)
- : 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)
- : 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 (TAO_ORB_Core *orb_core)
- : TAO_IIOP_SVC_HANDLER (orb_core->thr_mgr (), 0, 0),
- TAO_Connection_Handler (orb_core),
- dscp_codepoint_ (IPDSFIELD_DSCP_DEFAULT << 2)
-{
-}
-
-TAO_IIOP_Connection_Handler::~TAO_IIOP_Connection_Handler (void)
-{
- delete this->transport ();
-}
-
-/* Copy hook that copies over the concrete methods from this class
- * to the base Connection_Handler class as a part of the specialization
- * process. Add all concrete and virtual
- * methods implemented in this class within this hook.
- */
-//@@ CONNECTION_HANDLER_SPL_COPY_HOOK_START
-
-int
-TAO_IIOP_Connection_Handler::open_handler (void *v)
-{
- return this->open (v);
-}
-
-int
-TAO_IIOP_Connection_Handler::open (void*)
-{
- 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::resume_handler (void)
-{
- return ACE_Event_Handler::ACE_APPLICATION_RESUMES_HANDLER;
-}
-
-int
-TAO_IIOP_Connection_Handler::close_connection (void)
-{
- // 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::handle_input (ACE_HANDLE h)
-{
- return this->handle_input_eh (h, this);
-}
-
-int
-TAO_IIOP_Connection_Handler::handle_output (ACE_HANDLE handle)
-{
- 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 &,
- const void *)
-{
- // 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::handle_close (ACE_HANDLE,
- ACE_Reactor_Mask)
-{
- ACE_ASSERT (0);
- return 0;
-}
-
-int
-TAO_IIOP_Connection_Handler::close (u_long)
-{
- return this->close_handler ();
-}
-
-int
-TAO_IIOP_Connection_Handler::release_os_resources (void)
-{
- return this->peer ().close ();
-}
-
-int
-TAO_IIOP_Connection_Handler::add_transport_to_cache (void)
-{
- 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::process_listen_point_list (
- IIOP::ListenPointList &listen_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::set_dscp_codepoint (CORBA::Boolean set_network_priority)
-{
- 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;
-}
-
-void
-TAO_IIOP_Connection_Handler::abort (void)
-{
- 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 ()));
- }
- }
-}
-
-
-
-//@@ CONNECTION_HANDLER_SPL_COPY_HOOK_END
-/*
- * End copy hook
- */
-
-TAO_END_VERSIONED_NAMESPACE_DECL
-
-#endif /* TAO_HAS_IIOP && TAO_HAS_IIOP != 0 */