TAO/tao/Dynamic_TP/DTP_Config.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  *  @file
   6  *
   7  *   Header file for Loading DynamicTP Configurations.
   8  *
   9  *  @author
  10  */
  11 //=============================================================================
  12
  13 #ifndef TAO_DYNAMIC_TP_CONFIG_H
  14 #define TAO_DYNAMIC_TP_CONFIG_H
  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/Dynamic_TP/dynamic_tp_export.h"
  22 #include "ace/Service_Object.h"
  23 #include "ace/Service_Config.h"
  24 #include "ace/RB_Tree.h"
  25 #include "ace/Synch.h"
  26
  27 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  28 # pragma once
  29 #endif /* ACE_LACKS_PRAGMA_ONCE */
  30
  31 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  32
  33 struct TAO_Dynamic_TP_Export TAO_DTP_Definition
  34 {
  35   int min_threads_;  // a default of -1 implies Lifespan of INFINITE, > 0 implies IDLE
  36   int init_threads_; // default to 5
  37   int max_threads_;  // a default of -1 implies no limit.
  38   size_t stack_size_;
  39   ACE_Time_Value timeout_;   // default to 60 seconds
  40   int queue_depth_;
  41
  42   // Create explicit constructor to eliminate issues with non-initialized struct values.
  43   TAO_DTP_Definition() :
  44     min_threads_(-1),
  45     init_threads_(5),
  46     max_threads_(-1),
  47     stack_size_(ACE_DEFAULT_THREAD_STACKSIZE),
  48     timeout_(60,0),
  49     queue_depth_(0){}
  50 };
  51
  52 class TAO_Dynamic_TP_Export TAO_DTP_Config_Registry_Installer
  53 {
  54  public:
  55   TAO_DTP_Config_Registry_Installer ();
  56 };
  57
  58 class TAO_Dynamic_TP_Export TAO_DTP_Config_Registry : public ACE_Service_Object
  59 {
  60 public:
  61   TAO_DTP_Config_Registry ();
  62   virtual ~TAO_DTP_Config_Registry ();
  63
  64   virtual int init (int argc, ACE_TCHAR* []);
  65
  66   /// initializes the supplied set value with the configuration associated with the name, or returns false.
  67   bool find (const ACE_CString& name, TAO_DTP_Definition &entry);
  68
  69   int bind (const ACE_CString& name, TAO_DTP_Definition &entry);
  70   int rebind (const ACE_CString& name, TAO_DTP_Definition &entry);
  71
  72  private:
  73   typedef ACE_RB_Tree<ACE_CString, TAO_DTP_Definition, ACE_Less_Than<ACE_CString>, ACE_Null_Mutex> Registry;
  74   Registry registry_;
  75 };
  76
  77 class TAO_Dynamic_TP_Export TAO_DTP_Config : public ACE_Service_Object
  78 {
  79 public:
  80   /// Constructor.
  81   TAO_DTP_Config ();
  82
  83   /// Destructor.
  84   virtual ~TAO_DTP_Config ();
  85
  86   /// Read a definition parameter set from the supplied args.
  87   /// There must be a -TPName argument, which, if replicated will cause the set to be ignored, unless -TPOverwrite is also set
  88   /// constriants: min threads <= initial threads <= max_threads.
  89   /// defaults: min threads = initial = max = 5
  90   /// default lifespan = infinite
  91   /// idle timeout is in secondes, default = 60
  92   /// default stack size = 0, system defined default used.
  93   /// queue depth is in number of messages, default is infinite
  94   /// Init can be called multiple times,
  95   virtual int init (int argc, ACE_TCHAR* []);
  96
  97 private:
  98   int parse_long (int &curarg, int argc, ACE_TCHAR* argv[], const ACE_TCHAR *match, long &value);
  99   int parse_bool (int &curarg, int argc, ACE_TCHAR* argv[], const ACE_TCHAR *match, bool &value);
 100   int parse_string (int &curarg, int argc, ACE_TCHAR* argv[], const ACE_TCHAR *match, ACE_TCHAR *&value);
 101   void report_option_value_error (const ACE_TCHAR* option_name,
 102                                   const ACE_TCHAR* option_value);
 103 };
 104
 105 static TAO_DTP_Config_Registry_Installer config_installer;
 106
 107
 108 ACE_STATIC_SVC_DECLARE_EXPORT (TAO_Dynamic_TP, TAO_DTP_Config_Registry)
 109 ACE_FACTORY_DECLARE (TAO_Dynamic_TP, TAO_DTP_Config_Registry)
 110
 111 ACE_STATIC_SVC_DECLARE_EXPORT (TAO_Dynamic_TP, TAO_DTP_Config)
 112 ACE_FACTORY_DECLARE (TAO_Dynamic_TP, TAO_DTP_Config)
 113
 114 TAO_END_VERSIONED_NAMESPACE_DECL
 115
 116 #endif /* (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0 */
 117
 118 #include /**/ "ace/post.h"
 119 #endif /* TAO_DYNAMIC_TP_CONFIG_H */