TAO/tao/Strategies/advanced_resource.h

   1 // -*- C++ -*-
   2 #ifndef TAO_ADVANCED_RESOURCE_H
   3 #define TAO_ADVANCED_RESOURCE_H
   4 #include /**/ "ace/pre.h"
   5
   6 #include "tao/Strategies/strategies_export.h"
   7 #include "tao/default_resource.h"
   8
   9 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  10 # pragma once
  11 #endif /* ACE_LACKS_PRAGMA_ONCE */
  12
  13 #include "tao/ORB_Core.h"
  14
  15 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  16
  17 class TAO_Connection_Purging_Strategy;
  18
  19 class TAO_Strategies_Export TAO_Resource_Factory_Changer
  20 {
  21 public:
  22   TAO_Resource_Factory_Changer ();
  23 };
  24
  25 /**
  26  * @class TAO_Advanced_Resource_Factory
  27  *
  28  * @brief TAO's default resource factory
  29  *
  30  * Using a <{resource source specifier}> as a discriminator, the
  31  * factory can return resource instances which are, e.g., global,
  32  * stored in thread-specific storage, stored in shared memory,
  33  * etc.
  34  */
  35 class TAO_Strategies_Export TAO_Advanced_Resource_Factory :
  36   public TAO_Default_Resource_Factory
  37 {
  38 public:
  39   /// Constructor.
  40   TAO_Advanced_Resource_Factory ();
  41
  42   /// Destructor.
  43   virtual ~TAO_Advanced_Resource_Factory ();
  44
  45   // = Service Configurator hooks.
  46   /// Dynamic linking hook
  47   virtual int init (int argc, ACE_TCHAR* argv[]);
  48
  49   /// Type of lock used for the allocators
  50   enum Allocator_Lock_Type
  51   {
  52     TAO_ALLOCATOR_NULL_LOCK,
  53     TAO_ALLOCATOR_THREAD_LOCK
  54   };
  55
  56   /// Type of Reactor
  57   enum
  58   {
  59     /// Use ACE_Token
  60     TAO_REACTOR_SELECT_MT = 1,
  61
  62     /// Use ACE_Noop_Token
  63     TAO_REACTOR_SELECT_ST = 2,
  64     TAO_REACTOR_WFMO      = 3,
  65     TAO_REACTOR_MSGWFMO   = 4,
  66     TAO_REACTOR_TP        = 5,
  67     TAO_REACTOR_DEV_POLL  = 6
  68   };
  69
  70   /// Thread queueing Strategy
  71   enum
  72   {
  73     /// Not set, use LIFO.
  74     TAO_THREAD_QUEUE_NOT_SET,
  75
  76     /// FIFO, first-in-first-out.
  77     TAO_THREAD_QUEUE_FIFO,
  78
  79     /// LIFO, last-in-first-out (default).
  80     TAO_THREAD_QUEUE_LIFO
  81   };
  82
  83   /**
  84    * @name Resource Retrieval
  85    */
  86   //@{
  87   virtual int init_protocol_factories ();
  88   virtual ACE_Allocator* input_cdr_dblock_allocator ();
  89   virtual ACE_Allocator* input_cdr_buffer_allocator ();
  90   virtual ACE_Allocator* input_cdr_msgblock_allocator ();
  91   virtual ACE_Allocator* amh_response_handler_allocator ();
  92   virtual ACE_Allocator* ami_response_handler_allocator ();
  93   virtual int input_cdr_allocator_type_locked ();
  94   virtual TAO_ProtocolFactorySet *get_protocol_factories ();
  95   //@}
  96
  97   virtual TAO_Connection_Purging_Strategy *create_purging_strategy ();
  98   virtual TAO_LF_Strategy *create_lf_strategy ();
  99
 100 protected:
 101   /// Obtain the reactor implementation
 102   virtual ACE_Reactor_Impl *allocate_reactor_impl () const;
 103
 104   void report_option_value_error (const ACE_TCHAR* option_name,
 105                                   const ACE_TCHAR* option_value);
 106
 107   void report_unsupported_error (const ACE_TCHAR* option_name);
 108
 109   /// List of loaded protocol factories.
 110   TAO_ProtocolFactorySet protocol_factories_;
 111
 112   /// Flag indicating which kind of reactor we should use.
 113   int reactor_type_;
 114
 115   /// The type of queueing strategy to use for multi-threaded
 116   /// select reactors, TAO_REACTOR_SELECT_MT and TAO_REACTOR_TP.
 117   int threadqueue_type_;
 118
 119   /// The type of CDR allocators.
 120   Allocator_Lock_Type cdr_allocator_type_;
 121
 122   /// Type of lock used by AMH response handler allocator.
 123   Allocator_Lock_Type amh_response_handler_allocator_lock_type_;
 124
 125   /// Type of lock used by AMI response handler allocator.
 126   Allocator_Lock_Type ami_response_handler_allocator_lock_type_;
 127
 128   virtual int load_default_protocols ();
 129 };
 130
 131 static TAO_Resource_Factory_Changer TAO_changer;
 132
 133
 134 ACE_STATIC_SVC_DECLARE_EXPORT (TAO_Strategies, TAO_Advanced_Resource_Factory)
 135 ACE_FACTORY_DECLARE (TAO_Strategies, TAO_Advanced_Resource_Factory)
 136
 137 TAO_END_VERSIONED_NAMESPACE_DECL
 138
 139 #include /**/ "ace/post.h"
 140 #endif /* TAO_ADVANCED_RESOURCE_H */