TAO/tao/Strategies/SCIOP_Connection_Handler.h

   1 // -*- C++ -*-
   2
   3 // ===================================================================
   4 /**
   5  *  @file   SCIOP_Connection_Handler.h
   6  *
   7  *  @author  Jason Cohen, Lockheed Martin ATL  <jcohen@atl.lmco.com>
   8  *  @author  Keith O'Hara, Lockheed Martin ATL
   9  */
  10 // ===================================================================
  11
  12 #ifndef TAO_SCIOP_CONNECTION_HANDLER_H
  13 #define TAO_SCIOP_CONNECTION_HANDLER_H
  14
  15 #include /**/ "ace/pre.h"
  16
  17 #include "tao/orbconf.h"
  18
  19 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  20 #pragma once
  21 #endif /* ACE_LACKS_PRAGMA_ONCE */
  22
  23 #if TAO_HAS_SCIOP == 1
  24
  25 #include "tao/Strategies/strategies_export.h"
  26 #include "tao/Connection_Handler.h"
  27 #include "tao/IIOPC.h"
  28 #include "tao/TimeBaseC.h"
  29
  30 #include "ace/Reactor.h"
  31 #include "ace/Svc_Handler.h"
  32 #include "ace/SOCK_SEQPACK_Association.h"
  33
  34 #if defined ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION_EXPORT
  35 template class TAO_Strategies_Export ACE_Svc_Handler<ACE_SOCK_SEQPACK_ASSOCIATION, ACE_NULL_SYNCH>;
  36 #endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION_EXPORT */
  37
  38 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  39
  40 // Service Handler for this transport
  41 typedef ACE_Svc_Handler<ACE_SOCK_SEQPACK_ASSOCIATION, ACE_NULL_SYNCH>
  42         TAO_SCIOP_SVC_HANDLER;
  43
  44 // ****************************************************************
  45
  46 /**
  47  * @class TAO_SCIOP_Connection_Handler
  48  *
  49  * @brief  Handles requests on a single connection.
  50  *
  51  * The Connection handler which is common for the Acceptor and
  52  * the Connector
  53  */
  54
  55
  56 class TAO_Strategies_Export TAO_SCIOP_Connection_Handler
  57   : public TAO_SCIOP_SVC_HANDLER,
  58     public TAO_Connection_Handler
  59 {
  60 public:
  61   TAO_SCIOP_Connection_Handler (ACE_Thread_Manager* t = 0);
  62
  63   /// Constructor.
  64   TAO_SCIOP_Connection_Handler (TAO_ORB_Core *orb_core);
  65
  66   /// Destructor.
  67   ~TAO_SCIOP_Connection_Handler ();
  68
  69   //@{
  70   /**
  71    * Connection_Handler overloads
  72    */
  73   virtual int open_handler (void *);
  74   //@}
  75
  76   /// Called by the <Strategy_Acceptor> when the handler is completely
  77   /// connected.  Argument is unused.
  78   virtual int open (void *);
  79
  80   /// Close called by the Acceptor or Connector when connection
  81   /// establishment fails.
  82   int close (u_long = 0);
  83
  84   //@{
  85   /** @name Event Handler overloads
  86    */
  87   virtual int resume_handler ();
  88   virtual int close_connection ();
  89   virtual int handle_input (ACE_HANDLE);
  90   virtual int handle_output (ACE_HANDLE);
  91   virtual int handle_close (ACE_HANDLE, ACE_Reactor_Mask);
  92   virtual int handle_timeout (const ACE_Time_Value &current_time,
  93                               const void *act = 0);
  94   //@}
  95
  96   /// Add ourselves to Cache.
  97   int add_transport_to_cache ();
  98
  99   /// Process the <listen_list>
 100   int process_listen_point_list (IIOP::ListenPointList &listen_list);
 101
 102   /// Set Diff-Serv codepoint on outgoing packets.
 103   int set_dscp_codepoint (CORBA::Boolean set_network_priority);
 104   int set_dscp_codepoint (CORBA::Long dscp);
 105
 106 protected:
 107   /// Helper method needed by the set_dscp_codepoint () methods
 108   int set_tos (int tos);
 109
 110   //@{
 111   /**
 112    * @name TAO_Connection Handler overloads
 113    */
 114   //  void handle_close_i ();
 115   virtual int release_os_resources ();
 116   virtual int handle_write_ready (const ACE_Time_Value *timeout);
 117   //@}
 118
 119 private:
 120   /// Stores the type of service value.
 121   int dscp_codepoint_;
 122 };
 123
 124 TAO_END_VERSIONED_NAMESPACE_DECL
 125
 126 #endif /* TAO_HAS_SCIOP == 1 */
 127
 128 #include /**/ "ace/post.h"
 129
 130 #endif /* TAO_SCIOP_CONNECTION_HANDLER_H */