1 files changed, 165 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/HTIOP/HTIOP_Transport.h b/TAO/orbsvcs/orbsvcs/HTIOP/HTIOP_Transport.h
new file mode 100644
index 00000000000..209622ac41a
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/HTIOP/HTIOP_Transport.h
@@ -0,0 +1,165 @@
+
+// This may look like C, but it's really -*- C++ -*-
+// -*- C++ -*-
+// ===================================================================
+/**
+ *  @file   HTIOP_Transport.h
+ *
+ *  $Id$
+ *
+ *  @author Originally by Fred Kuhns <fredk@cs.wustl.edu>
+ *  @author Modified by Balachandran Natarajan <bala@cs.wustl.edu>
+ */
+// ===================================================================
+
+#ifndef TAO_HTIOP_TRANSPORT_H
+#define TAO_HTIOP_TRANSPORT_H
+#include /**/ "ace/pre.h"
+
+#include "HTIOP_Export.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "orbsvcs/HTIOPC.h"
+
+#include "ace/HTBP/HTBP_Stream.h"
+
+#include "tao/Transport.h"
+
+#include "ace/Synch.h"
+#include "ace/Svc_Handler.h"
+//#include "HTIOP/HTIOPC.h"
+
+// Forward decls.
+class TAO_ORB_Core;
+class TAO_Operation_Details;
+class TAO_Pluggable_Messaging;
+class TAO_Acceptor;
+class TAO_Adapter;
+
+# if defined (ACE_HAS_TEMPLATE_TYPEDEFS)
+#   define ACE_HTBP_STREAM ACE::HTBP::Stream
+# else /* If TEMPLATES are broken in some form or another */
+#   define ACE_HTBP_STREAM ACE::HTBP::Stream, ACE::HTBP::Addr
+#endif /* ACE_HAS_TEMPLATE_TYPEDEFS */
+
+namespace TAO
+{
+  namespace HTIOP
+  {
+    class Connection_Handler;
+
+    // Service Handler for this transport
+    typedef ACE_Svc_Handler<ACE_HTBP_STREAM, ACE_NULL_SYNCH>
+    SVC_HANDLER;
+
+    /**
+     * @class Transport
+     *
+     * @brief Specialization of the base Transport class to handle the
+     *  HTIOP protocol.
+     *
+     *
+     *
+     */
+
+    class HTIOP_Export Transport : public TAO_Transport
+    {
+    public:
+
+      /// Constructor.
+      Transport (Connection_Handler *handler,
+                 TAO_ORB_Core *orb_core,
+                 CORBA::Boolean flag);
+
+      /// Default destructor.
+      ~Transport (void);
+
+    protected:
+
+      /** @name Overridden Template Methods
+       *
+       * Please check the documentation in "tao/Transport.h" for more
+       * details.
+       */
+      //@{
+
+      virtual ACE_Event_Handler * event_handler_i (void);
+      virtual TAO_Connection_Handler * invalidate_event_handler_i (void);
+
+      /// Access the underlying messaging object
+      virtual TAO_Pluggable_Messaging *messaging_object (void);
+
+      virtual ssize_t send (iovec *iov, int iovcnt,
+                            size_t &bytes_transferred,
+                            const ACE_Time_Value *timeout = 0);
+
+      virtual ssize_t recv (char *buf,
+                            size_t len,
+                            const ACE_Time_Value *s = 0);
+
+      virtual int register_handler (void);
+
+      virtual int send_message_shared (TAO_Stub *stub,
+                                       int message_semantics,
+                                       const ACE_Message_Block *message_block,
+                                       ACE_Time_Value *max_wait_time);
+
+
+    public:
+      /// @@TODO: These methods IMHO should have more meaningful
+      /// names. The names seem to indicate nothing.
+      virtual int send_request (TAO_Stub *stub,
+                                TAO_ORB_Core *orb_core,
+                                TAO_OutputCDR &stream,
+                                int message_semantics,
+                                ACE_Time_Value *max_wait_time);
+
+      virtual int send_message (TAO_OutputCDR &stream,
+                                TAO_Stub *stub = 0,
+                                int message_semantics =
+                                Transport::TAO_TWOWAY_REQUEST,
+                                ACE_Time_Value *max_time_wait = 0);
+
+      // @@ This is probably not needed - Priyanka
+      // This is needed because we want to send additional information
+      // such as session id etc. in the header.
+      virtual int generate_request_header (TAO_Operation_Details &opdetails,
+                                           TAO_Target_Specification &spec,
+                                           TAO_OutputCDR &msg);
+
+
+      virtual int messaging_init (CORBA::Octet major,
+                                  CORBA::Octet minor);
+
+      virtual int tear_listen_point_list (TAO_InputCDR &cdr);
+
+      virtual TAO_Connection_Handler * connection_handler_i (void);
+
+      //@}
+
+    private:
+
+      /// Set the Bidirectional context info in the service context list
+      void set_bidir_context_info (TAO_Operation_Details &opdetails);
+
+      /// Add the listen points in <acceptor> to the <listen_point_list>
+      /// if this connection is in the same interface as that of the
+      /// endpoints in the <acceptor>
+      int get_listen_point (::HTIOP::ListenPointList &listen_point_list,
+                            TAO_Acceptor *acceptor);
+
+      /// The connection service handler used for accessing lower layer
+      /// communication protocols.
+      Connection_Handler *connection_handler_;
+
+      /// Our messaging object.
+      TAO_Pluggable_Messaging *messaging_object_;
+    };
+  }
+}
+
+#include /**/ "ace/post.h"
+#endif  /* TRANSPORT_H */