Repo restructuring

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 */