1 files changed, 152 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/HTIOP/HTIOP_Acceptor_Impl.h b/TAO/orbsvcs/orbsvcs/HTIOP/HTIOP_Acceptor_Impl.h
new file mode 100644
index 00000000000..842d65a7e0d
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/HTIOP/HTIOP_Acceptor_Impl.h
@@ -0,0 +1,152 @@
+// This may look like C, but it's really -*- C++ -*-
+
+//=============================================================================
+/**
+ *  @file   HTIOP_Acceptor_Impl.h
+ *
+ *  $Id$
+ *
+ *  @author Priyanka Gontla <gontla_p@ociweb.com>
+ */
+//=============================================================================
+
+
+#ifndef HTIOP_ACCEPTOR_IMPL_H
+#define HTIOP_ACCEPTOR_IMPL_H
+#include /**/ "ace/pre.h"
+
+#include "ace/Acceptor.h"
+#include "ace/SOCK_Acceptor.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "tao/corbafwd.h"
+
+// Forward declarations.
+class TAO_ORB_Core;
+
+namespace TAO
+{
+  namespace HTIOP
+  {
+    /**
+     * @class Creation_Strategy
+     *
+     * @brief Creates a Svc_Handler and set the ORB_Core pointer on it.
+     */
+    template <class SVC_HANDLER>
+    class Creation_Strategy : public ACE_Creation_Strategy<SVC_HANDLER>
+    {
+    public:
+      /**
+       * Constructor. <arg> parameter is used to pass any special
+       * state/info to the service handler upon creation.
+
+      */
+      Creation_Strategy (TAO_ORB_Core *orb_core,
+                         CORBA::Boolean flag = 0);
+
+      /// Create a SVC_HANDLER  and set the ORB_Core pointer on it.
+      int make_svc_handler (SVC_HANDLER *&sh);
+
+    protected:
+      /// Pointer to the ORB Core.
+      TAO_ORB_Core *orb_core_;
+
+      /// Should we use the Lite version for any protocol?
+      CORBA::Boolean lite_flag_;
+    };
+
+    template <class SVC_HANDLER, ACE_PEER_ACCEPTOR_1>
+    class Accept_Strategy
+    {
+    public:
+
+      /// Constructor.
+      Accept_Strategy (TAO_ORB_Core *orb_core);
+
+      /// Initialize the <peer_acceptor_> with <local_addr>.  If the
+      /// process runs out of handles, purge some "old" connections.
+      int open (const ACE_PEER_ACCEPTOR_ADDR &local_addr,
+                int restart = 0);
+
+      /// Returns the underlying PEER_ACCEPTOR object
+      ACE_PEER_ACCEPTOR &acceptor (void) const;
+
+      /// Delegates to the <accept> method of the PEER_ACCEPTOR. If the
+      /// process runs out of handles, purge some "old" connections.
+      int accept_svc_handler (SVC_HANDLER *svc_handler);
+
+      ACE_HANDLE get_handle (void) const;
+
+    protected:
+
+      /// Pointer to the ORB Core.
+      TAO_ORB_Core *orb_core_;
+
+    private:
+
+      /// Factory that establishes connections passively
+      ACE_PEER_ACCEPTOR peer_acceptor_;
+    };
+
+
+    template <class SVC_HANDLER, ACE_PEER_ACCEPTOR_1>
+    class Strategy_Acceptor : public ACE_Service_Object
+    {
+    public:
+
+      /// Default constructor.
+      Strategy_Acceptor (const ACE_TCHAR service_name[] = 0,
+                                   const ACE_TCHAR service_description[] = 0,
+                                   int use_select = 1,
+                                   int reuse_addr = 1);
+
+      int open (const ACE_PEER_ACCEPTOR_ADDR &,
+                ACE_Reactor * = ACE_Reactor::instance (),
+                Creation_Strategy<SVC_HANDLER> * = 0,
+                Accept_Strategy<SVC_HANDLER, ACE_PEER_ACCEPTOR_2> * =0,
+                ACE_Concurrency_Strategy<SVC_HANDLER> * = 0,
+                int reuse_addr = 1);
+
+      int close ();
+
+      virtual ACE_HANDLE get_handle (void) const;
+
+
+    private:
+
+      int handle_input (ACE_HANDLE);
+
+      int activate_svc_handler (SVC_HANDLER *svc_handler);
+
+      int accept_svc_handler (SVC_HANDLER *svc_handler);
+
+      int make_svc_handler (SVC_HANDLER *&sh);
+
+      int shared_open (const ACE_PEER_ACCEPTOR_ADDR &,
+                       int protocol_family,
+                       int backlog);
+
+      Accept_Strategy<SVC_HANDLER, ACE_PEER_ACCEPTOR_2> *accept_strategy_;
+
+      Creation_Strategy<SVC_HANDLER> * creation_strategy_;
+
+      ACE_Concurrency_Strategy<SVC_HANDLER> * concurrency_strategy_;
+    };
+
+  }
+}
+
+#if defined (ACE_TEMPLATES_REQUIRE_SOURCE)
+#include "HTIOP_Acceptor_Impl.cpp"
+#endif /* ACE_TEMPLATES_REQUIRE_SOURCE */
+
+#if defined (ACE_TEMPLATES_REQUIRE_PRAGMA)
+#pragma implementation ("HTIOP_Acceptor_Impl.cpp")
+#endif /* ACE_TEMPLATES_REQUIRE_PRAGMA */
+
+#include /**/ "ace/post.h"
+#endif /* HTIOP_AccePTOR_IMPL_H */