TAO/tao/PortableServer/POAManagerFactory.cpp

   1 // -*- C++ -*-
   2 #include "tao/PortableServer/POAManagerFactory.h"
   3 #include "tao/PortableServer/POAManager.h"
   4
   5 #include "ace/OS_NS_string.h"
   6 #include "ace/CORBA_macros.h"
   7
   8 #if (TAO_HAS_MINIMUM_POA == 0) && !defined (CORBA_E_COMPACT) && !defined (CORBA_E_MICRO)
   9
  10 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  11
  12 TAO_POAManager_Factory::TAO_POAManager_Factory (TAO_Object_Adapter &object_adapter) :
  13   object_adapter_ (object_adapter)
  14 {
  15 }
  16
  17 TAO_POAManager_Factory::~TAO_POAManager_Factory ()
  18 {
  19   this->remove_all_poamanagers ();
  20 }
  21
  22 ::PortableServer::POAManager_ptr
  23 TAO_POAManager_Factory::create_POAManager (
  24   const char * id,
  25   const ::CORBA::PolicyList & policies
  26   )
  27 {
  28   // Validate the policy.
  29   TAO_POA_Policy_Set tao_policies (TAO_POA_Policy_Set (this->object_adapter_.default_poa_policies ()));
  30
  31   // Merge policies from the ORB level.
  32   this->object_adapter_.validator ().merge_policies (tao_policies.policies ());
  33
  34   // Merge in any policies that the user may have specified.
  35   tao_policies.merge_policies (policies);
  36
  37   // If any of the policy objects specified are not valid for the ORB
  38   // implementation, if conflicting policy objects are specified, or
  39   // if any of the specified policy objects require prior
  40   // administrative action that has not been performed, an
  41   // InvalidPolicy exception is raised containing the index in the
  42   // policies parameter value of the first offending policy object.
  43   tao_policies.validate_policies (this->object_adapter_.validator (),
  44                                   this->object_adapter_.orb_core ());
  45
  46   PortableServer::POAManager_var poamanager;
  47
  48   if (id != 0)
  49   {
  50     poamanager = this->find (id);
  51
  52     // If we already have a manager with the same name throw an exception
  53     if (!CORBA::is_nil (poamanager.in()))
  54       {
  55         throw ::PortableServer::POAManagerFactory::ManagerAlreadyExists ();
  56       }
  57   }
  58
  59   // this indirection brought to you by borland's compiler and its refusal
  60   // to directly assign the newly created TAO_POA_Manager to a POAManager_var.
  61   {
  62     PortableServer::POAManager_ptr pm = 0;
  63     ACE_NEW_THROW_EX (pm,
  64                       TAO_POA_Manager (object_adapter_, id, policies, this),
  65                       CORBA::NO_MEMORY
  66                       (CORBA::SystemException::_tao_minor_code (0, ENOMEM),
  67                        CORBA::COMPLETED_NO));
  68     poamanager = pm;
  69   }
  70
  71   this->register_poamanager (poamanager.in ());
  72
  73   return poamanager._retn ();
  74 }
  75
  76 ::PortableServer::POAManagerFactory::POAManagerSeq *
  77 TAO_POAManager_Factory::list ()
  78 {
  79   ::PortableServer::POAManagerFactory::POAManagerSeq_var poamanagers;
  80   CORBA::ULong number_of_poamanagers = static_cast <CORBA::ULong>
  81                                               (this->poamanager_set_.size ());
  82   ACE_NEW_THROW_EX (poamanagers,
  83                     PortableServer::POAManagerFactory::POAManagerSeq (
  84                       number_of_poamanagers),
  85                     CORBA::NO_MEMORY ());
  86
  87   poamanagers->length (number_of_poamanagers);
  88
  89   CORBA::ULong index = 0;
  90   for (POAMANAGERSET::iterator iterator = this->poamanager_set_.begin ();
  91         iterator != this->poamanager_set_.end ();
  92         ++iterator, ++index)
  93     {
  94       ::PortableServer::POAManager_ptr poamanager = (*iterator);
  95       poamanagers[index] =
  96         PortableServer::POAManager::_duplicate (poamanager);
  97     }
  98
  99   return poamanagers._retn ();
 100 }
 101
 102 ::PortableServer::POAManager_ptr
 103 TAO_POAManager_Factory::find (const char * id)
 104 {
 105   ::PortableServer::POAManager_ptr poamanager =
 106     ::PortableServer::POAManager::_nil();
 107
 108   for (POAMANAGERSET::iterator iterator = this->poamanager_set_.begin ();
 109         iterator != this->poamanager_set_.end ();
 110         ++iterator)
 111     {
 112       CORBA::String_var poamanagerid = (*iterator)->get_id ();
 113
 114       if (ACE_OS::strcmp (id, poamanagerid.in()) == 0)
 115         {
 116           poamanager = PortableServer::POAManager::_duplicate (*iterator);
 117           break;
 118         }
 119     }
 120
 121   return poamanager;
 122 }
 123
 124 void
 125 TAO_POAManager_Factory::remove_all_poamanagers ()
 126 {
 127   for (POAMANAGERSET::iterator iterator = this->poamanager_set_.begin ();
 128         iterator != this->poamanager_set_.end ();
 129         ++iterator)
 130     {
 131       ::PortableServer::POAManager_ptr poamanager = (*iterator);
 132       CORBA::release (poamanager);
 133     }
 134   this->poamanager_set_.reset ();
 135 }
 136
 137 int
 138 TAO_POAManager_Factory::remove_poamanager (
 139   ::PortableServer::POAManager_ptr poamanager)
 140 {
 141   int retval = this->poamanager_set_.remove (poamanager);
 142
 143   if (retval == 0)
 144     {
 145       CORBA::release (poamanager);
 146     }
 147
 148   return retval;
 149 }
 150
 151 int
 152 TAO_POAManager_Factory::register_poamanager (
 153   ::PortableServer::POAManager_ptr poamanager)
 154 {
 155   return this->poamanager_set_.insert (
 156     PortableServer::POAManager::_duplicate (poamanager));
 157 }
 158
 159
 160 TAO_END_VERSIONED_NAMESPACE_DECL
 161
 162 #endif