TAO/tao/PortableServer/RequestProcessingStrategyFactoryImpl.cpp

   1 #include "tao/PortableServer/RequestProcessingStrategyFactoryImpl.h"
   2 #include "tao/PortableServer/RequestProcessingStrategyAOMOnly.h"
   3 #include "tao/PortableServer/RequestProcessingStrategyDefaultServant.h"
   4 #include "tao/PortableServer/RequestProcessingStrategyServantLocator.h"
   5 #include "tao/PortableServer/RequestProcessingStrategyServantActivator.h"
   6 #include "ace/Dynamic_Service.h"
   7 #include "ace/Log_Msg.h"
   8
   9 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  10
  11 namespace TAO
  12 {
  13   namespace Portable_Server
  14   {
  15     RequestProcessingStrategy*
  16     RequestProcessingStrategyFactoryImpl::create (
  17         ::PortableServer::RequestProcessingPolicyValue value,
  18         ::PortableServer::ServantRetentionPolicyValue srvalue)
  19     {
  20       RequestProcessingStrategy* strategy = 0;
  21       RequestProcessingStrategyFactory *strategy_factory = 0;
  22
  23       switch (value)
  24       {
  25         case ::PortableServer::USE_ACTIVE_OBJECT_MAP_ONLY :
  26         {
  27           strategy_factory =
  28             ACE_Dynamic_Service<RequestProcessingStrategyFactory>::instance ("RequestProcessingStrategyAOMOnlyFactory");
  29
  30           break;
  31         }
  32         case ::PortableServer::USE_DEFAULT_SERVANT :
  33         {
  34           strategy_factory =
  35             ACE_Dynamic_Service<RequestProcessingStrategyFactory>::instance ("RequestProcessingStrategyDefaultServantFactory");
  36
  37           break;
  38         }
  39         case ::PortableServer::USE_SERVANT_MANAGER :
  40         {
  41 #if (TAO_HAS_MINIMUM_POA == 0)
  42           switch (srvalue)
  43           {
  44             case ::PortableServer::RETAIN :
  45             {
  46               strategy_factory =
  47                 ACE_Dynamic_Service<RequestProcessingStrategyFactory>::instance ("RequestProcessingStrategyServantActivatorFactory");
  48
  49               break;
  50             }
  51             case ::PortableServer::NON_RETAIN :
  52             {
  53               strategy_factory =
  54                 ACE_Dynamic_Service<RequestProcessingStrategyFactory>::instance ("RequestProcessingStrategyServantLocatorFactory");
  55
  56               break;
  57             }
  58           }
  59 #endif /* TAO_HAS_MINIMUM_POA == 0 */
  60           break;
  61         }
  62       }
  63
  64       if (strategy_factory != 0)
  65         strategy = strategy_factory->create (value, srvalue);
  66       else
  67         TAOLIB_ERROR ((LM_ERROR,
  68                     ACE_TEXT ("(%P|%t) %p\n"),
  69                     ACE_TEXT ("ERROR, Unable to get ")
  70                     ACE_TEXT ("RequestProcessingStrategyFactory")));
  71
  72       return strategy;
  73     }
  74
  75     void
  76     RequestProcessingStrategyFactoryImpl::destroy (
  77       RequestProcessingStrategy *strategy)
  78     {
  79       RequestProcessingStrategyFactory *strategy_factory = 0;
  80
  81       switch (strategy->type ())
  82       {
  83         case ::PortableServer::USE_ACTIVE_OBJECT_MAP_ONLY :
  84         {
  85           strategy_factory =
  86             ACE_Dynamic_Service<RequestProcessingStrategyFactory>::instance ("RequestProcessingStrategyAOMOnlyFactory");
  87
  88           break;
  89         }
  90         case ::PortableServer::USE_DEFAULT_SERVANT :
  91         {
  92           strategy_factory =
  93             ACE_Dynamic_Service<RequestProcessingStrategyFactory>::instance ("RequestProcessingStrategyDefaultServantFactory");
  94
  95           break;
  96         }
  97         case ::PortableServer::USE_SERVANT_MANAGER :
  98         {
  99 #if (TAO_HAS_MINIMUM_POA == 0)
 100           switch (strategy->sr_type ())
 101           {
 102             case ::PortableServer::RETAIN :
 103             {
 104               strategy_factory =
 105                 ACE_Dynamic_Service<RequestProcessingStrategyFactory>::instance ("RequestProcessingStrategyServantActivatorFactory");
 106
 107               break;
 108             }
 109             case ::PortableServer::NON_RETAIN :
 110             {
 111               strategy_factory =
 112                 ACE_Dynamic_Service<RequestProcessingStrategyFactory>::instance ("RequestProcessingStrategyServantLocatorFactory");
 113               break;
 114             }
 115           }
 116 #endif /* TAO_HAS_MINIMUM_POA == 0 */
 117           break;
 118         }
 119       }
 120
 121       if (strategy_factory != 0)
 122         {
 123           strategy_factory->destroy (strategy);
 124         }
 125     }
 126   }
 127 }
 128
 129 ACE_STATIC_SVC_DEFINE (
 130   RequestProcessingStrategyFactoryImpl,
 131   ACE_TEXT ("RequestProcessingStrategyFactory"),
 132   ACE_SVC_OBJ_T,
 133   &ACE_SVC_NAME (RequestProcessingStrategyFactoryImpl),
 134   ACE_Service_Type::DELETE_THIS | ACE_Service_Type::DELETE_OBJ,
 135   0)
 136
 137 ACE_FACTORY_NAMESPACE_DEFINE (
 138   ACE_Local_Service,
 139   RequestProcessingStrategyFactoryImpl,
 140   TAO::Portable_Server::RequestProcessingStrategyFactoryImpl)
 141 TAO_END_VERSIONED_NAMESPACE_DECL