Repo restructuring

1 files changed, 145 insertions, 0 deletions

diff --git a/TAO/tao/IIOP_Connection_Handler.h b/TAO/tao/IIOP_Connection_Handler.h
new file mode 100644
index 00000000000..d00a736d5a4
--- /dev/null
+++ b/TAO/tao/IIOP_Connection_Handler.h
@@ -0,0 +1,145 @@
+// -*- C++ -*-
+
+// ===================================================================
+/**
+ *  @file   IIOP_Connection_Handler.h
+ *
+ *  $Id$
+ *
+ *  @author Originally by Chris Cleeland as IIOP_Connect.h
+ *  @author Balachandran Natarajan <bala@cs.wustl.edu>
+ */
+// ===================================================================
+
+#ifndef TAO_IIOP_CONNECTION_HANDLER_H
+#define TAO_IIOP_CONNECTION_HANDLER_H
+
+#include /**/ "ace/pre.h"
+
+#include "tao/orbconf.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+#pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#if defined (TAO_HAS_IIOP) && (TAO_HAS_IIOP != 0)
+
+#include "tao/Connection_Handler.h"
+#include "tao/Basic_Types.h"
+
+#include "ace/SOCK_Stream.h"
+#include "ace/Svc_Handler.h"
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+/// Service Handler for this transport
+typedef ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>
+        TAO_IIOP_SVC_HANDLER;
+
+#if defined ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION_EXPORT
+template class TAO_Export ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>;
+#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION_EXPORT */
+
+namespace IIOP
+{
+  class ListenPointList;
+}
+
+// Forward Decls
+class TAO_Pluggable_Messaging;
+
+// ****************************************************************
+
+/**
+ * @class TAO_IIOP_Connection_Handler
+ *
+ * @brief  Handles requests on a single connection.
+ *
+ * The Connection handler which is common for the Acceptor and
+ * the Connector
+ */
+class TAO_Export TAO_IIOP_Connection_Handler : public TAO_IIOP_SVC_HANDLER,
+                                               public TAO_Connection_Handler
+{
+
+public:
+
+  TAO_IIOP_Connection_Handler (ACE_Thread_Manager * = 0);
+
+  /// Constructor.
+  TAO_IIOP_Connection_Handler (TAO_ORB_Core *orb_core,
+                               CORBA::Boolean flag);
+
+  /// Destructor.
+  ~TAO_IIOP_Connection_Handler (void);
+
+  /// Called by the @c Strategy_Acceptor when the handler is completely
+  /// connected.  Argument is unused.
+  virtual int open (void *);
+
+  /// Close called by the Acceptor or Connector when connection
+  /// establishment fails.
+  int close (u_long = 0);
+
+  //@{
+  /** @name Event Handler overloads
+   */
+  virtual int resume_handler (void);
+  virtual int close_connection (void);
+  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);
+  //@}
+
+  /// Add ourselves to Cache.
+  int add_transport_to_cache (void);
+
+  /// Process the @a listen_list
+  int process_listen_point_list (IIOP::ListenPointList &listen_list);
+
+  /// Check if network priority needs to be enabled
+  int enable_network_priority (void);
+
+  /// Set Diff-Serv codepoint on outgoing packets.
+  int set_dscp_codepoint (CORBA::Boolean set_network_priority);
+
+  virtual int open_handler (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.
+  void abort (void);
+
+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
+   */
+  TAO_IIOP_Connection_Handler (TAO_ORB_Core *orb_core);
+
+  //@{
+  /**
+   * @name TAO_Connection Handler overloads
+   */
+  virtual int release_os_resources (void);
+  //@}
+
+private:
+
+  /// Stores the type of service value.
+  int dscp_codepoint_;
+};
+
+TAO_END_VERSIONED_NAMESPACE_DECL
+
+#endif /* TAO_HAS_IIOP && TAO_HAS_IIOP != 0 */
+
+#include /**/ "ace/post.h"
+#endif /* TAO_IIOP_CONNECTION_HANDLER_H */