TAO/tao/RTCORBA/RT_Protocols_Hooks.h

   1 // -*- C++ -*-
   2
   3 // ===================================================================
   4 /**
   5  *  @file   RT_Protocols_Hooks.h
   6  *
   7  *  @author Priyanka Gontla <pgontla@ece.uci.edu>
   8  */
   9 // ===================================================================
  10
  11 #ifndef TAO_RT_PROTOCOLS_HOOKS_H
  12 #define TAO_RT_PROTOCOLS_HOOKS_H
  13
  14 #include /**/ "ace/pre.h"
  15
  16 #include "tao/orbconf.h"
  17
  18 #if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
  19
  20 #include "tao/RTCORBA/rtcorba_export.h"
  21 #include "tao/RTCORBA/Priority_Mapping_Manager.h"
  22 #include "tao/RTCORBA/Network_Priority_Mapping_Manager.h"
  23
  24 #include "tao/Protocols_Hooks.h"
  25
  26 #include "ace/Service_Config.h"
  27
  28 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  29 # pragma once
  30 #endif /* ACE_LACKS_PRAGMA_ONCE */
  31
  32 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  33
  34 class TAO_RTCORBA_Export TAO_RT_Protocols_Hooks : public TAO_Protocols_Hooks
  35 {
  36 public:
  37   /// Constructor
  38   TAO_RT_Protocols_Hooks ();
  39
  40   /// Destructor
  41   virtual ~TAO_RT_Protocols_Hooks ();
  42
  43   /// Initialize the protocols hooks instance.
  44   void init_hooks (TAO_ORB_Core *orb_core);
  45
  46   CORBA::Boolean set_client_network_priority (IOP::ProfileId protocol_tag,
  47                                               TAO_Stub *stub);
  48
  49   CORBA::Boolean set_server_network_priority (IOP::ProfileId protocol_tag,
  50                                               CORBA::Policy *policy);
  51
  52   void server_protocol_properties_at_orb_level (TAO_IIOP_Protocol_Properties &protocol_properties);
  53
  54   void client_protocol_properties_at_orb_level (TAO_IIOP_Protocol_Properties &protocol_properties);
  55
  56   void server_protocol_properties_at_orb_level (TAO_UIOP_Protocol_Properties &protocol_properties);
  57
  58   void client_protocol_properties_at_orb_level (TAO_UIOP_Protocol_Properties &protocol_properties);
  59
  60   void server_protocol_properties_at_orb_level (TAO_SHMIOP_Protocol_Properties &protocol_properties);
  61
  62   void client_protocol_properties_at_orb_level (TAO_SHMIOP_Protocol_Properties &protocol_properties);
  63
  64   void server_protocol_properties_at_orb_level (TAO_DIOP_Protocol_Properties &protocol_properties);
  65
  66   void client_protocol_properties_at_orb_level (TAO_DIOP_Protocol_Properties &protocol_properties);
  67
  68   void server_protocol_properties_at_orb_level (TAO_SCIOP_Protocol_Properties &protocol_properties);
  69
  70   void client_protocol_properties_at_orb_level (TAO_SCIOP_Protocol_Properties &protocol_properties);
  71
  72   CORBA::Long get_dscp_codepoint ();
  73
  74   void get_selector_hook (CORBA::Policy *model_policy,
  75                           CORBA::Boolean
  76                           &is_client_propagated,
  77                           CORBA::Short &server_priority);
  78
  79   void get_selector_bands_policy_hook (CORBA::Policy *bands_policy,
  80                                        CORBA::Short priority,
  81                                        CORBA::Short &min_priority,
  82                                        CORBA::Short &max_priority,
  83                                        bool &in_range);
  84
  85   /**
  86    * Accessor and modifier to the current thread priority, used to
  87    * implement the RTCORBA::Current interface, but it is faster for
  88    * some critical components.
  89    */
  90   //@{
  91   int get_thread_CORBA_priority (CORBA::Short &priority);
  92
  93   int get_thread_native_priority (CORBA::Short &);
  94
  95   int get_thread_CORBA_and_native_priority (CORBA::Short &, CORBA::Short &);
  96
  97   int get_thread_implicit_CORBA_priority (CORBA::Short&);
  98
  99   int set_thread_CORBA_priority (CORBA::Short);
 100
 101   int restore_thread_CORBA_and_native_priority (CORBA::Short, CORBA::Short);
 102   //@}
 103
 104 protected:
 105   int set_thread_native_priority (CORBA::Short);
 106
 107   RTCORBA::ProtocolProperties_ptr server_protocol_properties (IOP::ProfileId protocol_tag,
 108                                                               CORBA::Policy_ptr policy);
 109
 110   RTCORBA::ProtocolProperties_ptr client_protocol_properties (IOP::ProfileId protocol_tag,
 111                                                               CORBA::Policy_ptr policy);
 112
 113   RTCORBA::ProtocolProperties_ptr server_protocol_properties_at_orb_level (IOP::ProfileId protocol_tag);
 114
 115   RTCORBA::ProtocolProperties_ptr client_protocol_properties_at_orb_level (IOP::ProfileId protocol_tag);
 116
 117   RTCORBA::ProtocolProperties_ptr client_protocol_properties_at_object_level (IOP::ProfileId protocol_tag,
 118                                                                               TAO_Stub *stub);
 119
 120   void extract_protocol_properties (TAO_IIOP_Protocol_Properties &to,
 121                                     RTCORBA::ProtocolProperties_ptr from);
 122
 123   void extract_protocol_properties (TAO_UIOP_Protocol_Properties &to,
 124                                     RTCORBA::ProtocolProperties_ptr from);
 125
 126   void extract_protocol_properties (TAO_SHMIOP_Protocol_Properties &to,
 127                                     RTCORBA::ProtocolProperties_ptr from);
 128
 129   void extract_protocol_properties (TAO_DIOP_Protocol_Properties &to,
 130                                     RTCORBA::ProtocolProperties_ptr from);
 131
 132   void extract_protocol_properties (TAO_SCIOP_Protocol_Properties &to,
 133                                     RTCORBA::ProtocolProperties_ptr from);
 134
 135   CORBA::Boolean set_network_priority (IOP::ProfileId protocol_tag,
 136                                        RTCORBA::ProtocolProperties_ptr protocol_properties);
 137
 138 protected:
 139   TAO_ORB_Core *orb_core_;
 140
 141   // Save a reference to the priority mapping manager.
 142   TAO_Priority_Mapping_Manager_var mapping_manager_;
 143   TAO_Network_Priority_Mapping_Manager_var network_mapping_manager_;
 144
 145   RTCORBA::Current_var current_;
 146 };
 147
 148 ACE_STATIC_SVC_DECLARE_EXPORT (TAO_RTCORBA, TAO_RT_Protocols_Hooks)
 149 ACE_FACTORY_DECLARE (TAO_RTCORBA, TAO_RT_Protocols_Hooks)
 150
 151 TAO_END_VERSIONED_NAMESPACE_DECL
 152
 153
 154 #endif /* TAO_HAS_CORBA_MESSAGING && TAO_HAS_CORBA_MESSAGING != 0 */
 155
 156 #include /**/ "ace/post.h"
 157 #endif /* TAO_RT_PROTOCOLS_HOOKS_H */