TAO/tao/RTCORBA/RT_ORBInitializer.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  *  @file RT_ORBInitializer.h
   6  *
   7  *  @author Ossama Othman <ossama@uci.edu>
   8  */
   9 //=============================================================================
  10
  11
  12 #ifndef TAO_RT_ORB_INITIALIZER_H
  13 #define TAO_RT_ORB_INITIALIZER_H
  14
  15 #include /**/ "ace/pre.h"
  16
  17 #include "tao/orbconf.h"
  18
  19 #if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
  20
  21 #include "tao/RTCORBA/rtcorba_export.h"
  22
  23 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  24 # pragma once
  25 #endif /* ACE_LACKS_PRAGMA_ONCE */
  26
  27 #include "tao/PI/PI.h"
  28 #include "tao/LocalObject.h"
  29
  30 // This is to remove "inherits via dominance" warnings from MSVC.
  31 // MSVC is being a little too paranoid.
  32 #if defined(_MSC_VER)
  33 #pragma warning(push)
  34 #pragma warning(disable:4250)
  35 #endif /* _MSC_VER */
  36
  37 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  38
  39 /// RTCORBA ORB initializer.
  40 class TAO_RT_ORBInitializer
  41   : public virtual PortableInterceptor::ORBInitializer
  42   , public virtual ::CORBA::LocalObject
  43 {
  44 public:
  45   /// Priority mapping types
  46   enum
  47     {
  48       TAO_PRIORITY_MAPPING_CONTINUOUS,
  49       TAO_PRIORITY_MAPPING_LINEAR,
  50       TAO_PRIORITY_MAPPING_DIRECT
  51     };
  52
  53   enum
  54     {
  55       TAO_NETWORK_PRIORITY_MAPPING_LINEAR
  56     };
  57
  58   /**
  59    * Lifespan of the dynamic threads
  60    * TAO_RTCORBA_DT_INFINITIVE When the Dynamic Thread is created it will run
  61    * forever
  62    * TAO_RTCORBA_DT_IDLE When the Dynamic Thread is created it will run until
  63    * it has been idle for the specified amount of time
  64    * TAO_RTCORBA_DT_FIXED When the Dynamic Thread is created it will run for
  65    * the specified fix amount of time
  66    */
  67   enum TAO_RTCORBA_DT_LifeSpan
  68   {
  69     TAO_RTCORBA_DT_INFINITIVE,
  70     TAO_RTCORBA_DT_IDLE,
  71     TAO_RTCORBA_DT_FIXED
  72   };
  73
  74   TAO_RT_ORBInitializer (int priority_mapping_type,
  75                          int network_priority_mapping_type,
  76                          int ace_sched_policy,
  77                          long sched_policy,
  78                          long scope_policy,
  79                          TAO_RT_ORBInitializer::TAO_RTCORBA_DT_LifeSpan lifespan,
  80                          ACE_Time_Value const &dynamic_thread_time);
  81
  82   virtual void pre_init (PortableInterceptor::ORBInitInfo_ptr info);
  83
  84   virtual void post_init (PortableInterceptor::ORBInitInfo_ptr info);
  85
  86 private:
  87   /// Register RTCORBA policy factories.
  88   void register_policy_factories (PortableInterceptor::ORBInitInfo_ptr info);
  89
  90 private:
  91   /// Instance of the RTCorba policy factory.
  92   /**
  93    * The RTCorba policy factory is stateless and reentrant, so share
  94    * a single instance between all ORBs.
  95    */
  96   PortableInterceptor::PolicyFactory_var policy_factory_;
  97
  98   /// Priority mapping type.
  99   int const priority_mapping_type_;
 100
 101   /// Network Priority mapping type.
 102   int const network_priority_mapping_type_;
 103
 104   /// Scheduling policy.
 105   /**
 106    * Scheduling policy specified by the user through the
 107    * -ORBSchedPolicy option.  This value is typically used by
 108    * functions like ACE_OS::thr_setprio() and
 109    * ACE_Sched_Params::priority_min(). Legal values are ACE_SCHED_RR,
 110    * ACE_SCHED_FIFO, and ACE_SCHED_OTHER.
 111    */
 112   int const ace_sched_policy_;
 113
 114   /// Scheduling policy flag.
 115   /**
 116    * Scheduling policy specified by the user through the
 117    * -ORBSchedPolicy option.  This value is typically used by ACE
 118    * thread creation functions. Legal values are THR_SCHED_RR,
 119    * THR_SCHED_FIFO, and THR_SCHED_DEFAULT.
 120    */
 121   long const sched_policy_;
 122
 123   /// Scheduling scope flag.
 124   /**
 125    * Scheduling policy specified by the user through the
 126    * -ORBScopePolicy option.  This value is typically used by ACE
 127    * thread creation functions. Legal values are THR_SCOPE_SYSTEM and
 128    * THR_SCOPE_PROCESS.
 129    */
 130   long const scope_policy_;
 131
 132   /// Dynamic thread lifespan policy
 133   TAO_RT_ORBInitializer::TAO_RTCORBA_DT_LifeSpan lifespan_;
 134
 135   /// Dynamic thread time
 136   /**
 137    * When using thread pool a certain number of dynamic threads can be created.
 138    * By default these threads are created when needed but never end. Optionally
 139    * a time can be specified
 140    */
 141   ACE_Time_Value const dynamic_thread_time_;
 142 };
 143
 144 TAO_END_VERSIONED_NAMESPACE_DECL
 145
 146 #if defined(_MSC_VER)
 147 #pragma warning(pop)
 148 #endif /* _MSC_VER */
 149
 150 #endif /* TAO_HAS_CORBA_MESSAGING && TAO_HAS_CORBA_MESSAGING != 0 */
 151
 152 #include /**/ "ace/post.h"
 153
 154 #endif /* TAO_RT_ORB_INITIALIZER_H */