TAO/tao/Strategies/UIOP_Transport.h

   1 // -*- C++ -*-
   2
   3 // ===================================================================
   4 /**
   5  *  @file   UIOP_Transport.h
   6  *
   7  *  @author Originally by Fred Kuhns <fredk@cs.wustl.edu>
   8  *  @author Ossama Othman <ossama@ece.uci.edu>
   9  *  @author Modified by Balachandran Natarajan <bala@cs.wustl.edu>
  10  */
  11 // ===================================================================
  12
  13 #ifndef TAO_UIOP_TRANSPORT_H
  14 #define TAO_UIOP_TRANSPORT_H
  15
  16 #include /**/ "ace/pre.h"
  17
  18 #include "tao/orbconf.h"
  19
  20 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  21 # pragma once
  22 #endif /* ACE_LACKS_PRAGMA_ONCE */
  23
  24 # if TAO_HAS_UIOP == 1
  25
  26 #include "tao/Strategies/strategies_export.h"
  27 #include "ace/LSOCK_Acceptor.h"
  28 #include "ace/Svc_Handler.h"
  29 #include "tao/Transport.h"
  30
  31 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  32
  33 // Forward decls.
  34
  35 class TAO_ORB_Core;
  36 class TAO_UIOP_Connection_Handler;
  37
  38 typedef ACE_Svc_Handler<ACE_LSOCK_STREAM, ACE_NULL_SYNCH>
  39         TAO_UIOP_SVC_HANDLER;
  40
  41 /**
  42  * @class TAO_UIOP_Transport
  43  *
  44  * @brief Specialization of the base TAO_Transport class to handle the
  45  *  UIOP protocol.
  46  */
  47
  48 class TAO_Strategies_Export TAO_UIOP_Transport : public TAO_Transport
  49 {
  50 public:
  51   /// Constructor.
  52   TAO_UIOP_Transport (TAO_UIOP_Connection_Handler *handler,
  53                       TAO_ORB_Core *orb_core);
  54
  55   /// Default destructor.
  56   ~TAO_UIOP_Transport ();
  57
  58 protected:
  59   /** @name Overridden Template Methods
  60    *
  61    * These are implementations of template methods declared by TAO_Transport.
  62    */
  63   //@{
  64   virtual ACE_Event_Handler * event_handler_i ();
  65   virtual TAO_Connection_Handler *connection_handler_i ();
  66
  67   /// Write the complete Message_Block chain to the connection.
  68   virtual ssize_t send (iovec *iov, int iovcnt,
  69                         size_t &bytes_transferred,
  70                         const ACE_Time_Value *timeout = 0);
  71
  72   /// Read len bytes from into buf.
  73   virtual ssize_t recv (char *buf,
  74                         size_t len,
  75                         const ACE_Time_Value *s = 0);
  76
  77 public:
  78   /// @todo These methods IMHO should have more meaningful names.
  79   /// The names seem to indicate nothing.
  80   virtual int send_request (TAO_Stub *stub,
  81                             TAO_ORB_Core *orb_core,
  82                             TAO_OutputCDR &stream,
  83                             TAO_Message_Semantics message_semantics,
  84                             ACE_Time_Value *max_wait_time);
  85
  86   virtual int send_message (TAO_OutputCDR &stream,
  87                             TAO_Stub *stub = 0,
  88                             TAO_ServerRequest *request = 0,
  89                             TAO_Message_Semantics message_semantics = TAO_Message_Semantics (),
  90                             ACE_Time_Value *max_time_wait = 0);
  91   //@}
  92
  93 private:
  94   /// The connection service handler used for accessing lower layer
  95   /// communication protocols.
  96   TAO_UIOP_Connection_Handler *connection_handler_;
  97 };
  98
  99 TAO_END_VERSIONED_NAMESPACE_DECL
 100
 101 # endif  /* TAO_HAS_UIOP == 1 */
 102
 103 #include /**/ "ace/post.h"
 104
 105 #endif  /* TAO_UIOP_TRANSPORT_H */