TAO/tao/Strategies/DIOP_Connection_Handler.h

   1 // -*- C++ -*-
   2
   3 // ===================================================================
   4 /**
   5  *  @file   DIOP_Connection_Handler.h
   6  *
   7  *  @author  Michael Kircher
   8  */
   9 // ===================================================================
  10
  11 #ifndef TAO_DIOP_CONNECTION_HANDLER_H
  12 #define TAO_DIOP_CONNECTION_HANDLER_H
  13
  14 #include /**/ "ace/pre.h"
  15
  16 #include "tao/orbconf.h"
  17
  18 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  19 #pragma once
  20 #endif /* ACE_LACKS_PRAGMA_ONCE */
  21
  22 #if defined (TAO_HAS_DIOP) && (TAO_HAS_DIOP != 0)
  23
  24 #include "tao/Strategies/strategies_export.h"
  25 #include "tao/Wait_Strategy.h"
  26 #include "tao/Connection_Handler.h"
  27 #include "tao/Strategies/DIOP_Transport.h"
  28 #include "ace/SOCK_Dgram.h"
  29 #include "ace/Reactor.h"
  30 #include "ace/Acceptor.h"
  31
  32 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  33
  34 // ****************************************************************
  35
  36 /**
  37  * @class TAO_DIOP_Connection_Handler
  38  *
  39  * @brief  Handles requests on a single connection.
  40  *
  41  * The Connection handler which is common for the Acceptor and
  42  * the Connector
  43  */
  44 class TAO_Strategies_Export TAO_DIOP_Connection_Handler
  45   : public TAO_DIOP_SVC_HANDLER
  46   , public TAO_Connection_Handler
  47 {
  48 public:
  49   TAO_DIOP_Connection_Handler (ACE_Thread_Manager* t = 0);
  50
  51   /// Constructor.
  52   TAO_DIOP_Connection_Handler (TAO_ORB_Core *orb_core);
  53
  54   /// Destructor.
  55   ~TAO_DIOP_Connection_Handler ();
  56
  57   /// Called by the <Strategy_Acceptor> when the handler is completely
  58   /// connected.  Argument is unused.
  59   virtual int open (void *);
  60
  61   // @@ Frank: Similar to open, but called on server
  62   virtual int open_server ();
  63
  64   //@{
  65   /**
  66    * Connection_Handler overloads
  67    */
  68   virtual int open_handler (void *);
  69   //@}
  70
  71   /// Close called by the Acceptor or Connector when connection
  72   /// establishment fails.
  73   int close (u_long = 0);
  74
  75   //@{
  76   /** @name Event Handler overloads
  77    */
  78   virtual int resume_handler ();
  79   virtual int close_connection ();
  80   virtual int handle_input (ACE_HANDLE);
  81   virtual int handle_output (ACE_HANDLE);
  82   virtual int handle_close (ACE_HANDLE, ACE_Reactor_Mask);
  83   virtual int handle_timeout (const ACE_Time_Value &current_time,
  84                               const void *act = 0);
  85   //@}
  86
  87   /// Add ourselves to Cache.
  88   int add_transport_to_cache ();
  89
  90   // @@ Frank: Not needed
  91   /*
  92   /// Process the <listen_list>
  93   int process_listen_point_list (DIOP::ListenPointList &listen_list);
  94   */
  95
  96   // DIOP Additions - Begin
  97   /**
  98    * @name The DIOP Additions
  99    *
 100    */
 101   //@{
 102   const ACE_INET_Addr &addr ();
 103
 104   void addr (const ACE_INET_Addr &addr);
 105
 106   const ACE_INET_Addr &local_addr ();
 107
 108   void local_addr (const ACE_INET_Addr &addr);
 109   //@}
 110   // DIOP Additions - End
 111
 112   /// Set Diff-Serv codepoint on outgoing packets.
 113   int set_dscp_codepoint (CORBA::Boolean set_network_priority);
 114   int set_dscp_codepoint (CORBA::Long dscp_codepoint);
 115
 116 protected:
 117   //@{
 118   /**
 119    * @name TAO_Connection Handler overloads
 120    */
 121   virtual int release_os_resources ();
 122   virtual int handle_write_ready (const ACE_Time_Value *timeout);
 123   //@}
 124
 125   /// Helper method used by the set_dscp_codepoint () methods
 126   int set_tos (int tos);
 127
 128   // DIOP Additions - Begin
 129   /**
 130    * @name The DIOP Additions
 131    *
 132    */
 133   //@{
 134   /// This is always the remote address
 135   ACE_INET_Addr addr_;
 136
 137   /// This is always the local address for the connector
 138   ACE_INET_Addr local_addr_;
 139   //@}
 140   // DIOP Additions - End
 141
 142 private:
 143   /// Stores the type of service value.
 144   int dscp_codepoint_;
 145 };
 146
 147 TAO_END_VERSIONED_NAMESPACE_DECL
 148
 149 #endif /* TAO_HAS_DIOP && TAO_HAS_DIOP != 0 */
 150
 151 #include /**/ "ace/post.h"
 152
 153 #endif /* TAO_DIOP_CONNECTION_HANDLER_H */