TAO::PG_FactoryRegistry Class Reference

#include <PG_FactoryRegistry.h>

Collaboration diagram for TAO::PG_FactoryRegistry:

[legend]List of all members.

Public Member Functions
	PG_FactoryRegistry (const char *name="FactoryRegistry")
	Constructor.
virtual	~PG_FactoryRegistry (void)
	virtual Destructor
int	parse_args (int argc, char *argv[])
int	init (CORBA::ORB_ptr orb)
void	init (CORBA::ORB_ptr orb, PortableServer::POA_ptr poa)
int	fini (void)
int	idle (int &result)
const char *	identity () const
::PortableGroup::FactoryRegistry_ptr	reference ()
virtual void	_remove_ref (void)
virtual void	register_factory (const char *role, const char *type_id, const PortableGroup::FactoryInfo &factory_info)
virtual void	unregister_factory (const char *role, const PortableGroup::Location &location)
virtual void	unregister_factory_by_role (const char *role)
virtual void	unregister_factory_by_location (const PortableGroup::Location &location)
virtual::PortableGroup::FactoryInfos *	list_factories_by_role (const char *role, CORBA::String_out type_id)
virtual::PortableGroup::FactoryInfos *	list_factories_by_location (const PortableGroup::Location &location)
Private Types
typedef ACE_Null_Mutex	MapMutex
typedef ACE_Hash_Map_Manager< ACE_CString, RoleInfo *, MapMutex >	RegistryType
typedef ACE_Hash_Map_Entry< ACE_CString, RoleInfo * >	RegistryType_Entry
typedef ACE_Hash_Map_Iterator< ACE_CString, RoleInfo *, MapMutex >	RegistryType_Iterator
typedef ACE_Guard< TAO_SYNCH_MUTEX >	InternalGuard
enum	{ LIVE, DEACTIVATED, GONE }
Private Member Functions
int	write_ior_file (const char *outputFile, const char *ior)
Private Attributes
ACE_CString	identity_
TAO_SYNCH_MUTEX	internals_
CORBA::ORB_var	orb_
PortableServer::POA_var	poa_
PortableServer::ObjectId_var	object_id_
CORBA::Object_var	this_obj_
CORBA::String_var	ior_
const char *	ior_output_file_
const char *	ns_name_
CosNaming::NamingContext_var	naming_context_
CosNaming::Name	this_name_
int	quit_on_idle_
enum TAO::PG_FactoryRegistry:: { ... }	quit_state_
int	linger_
RegistryType	registry_

---

Detailed Description

Implement the PortableGroup::FactoryRegistry interface Note FactoryRegistry is not part of the OMG standard. It was added as part of the TAO implementation of Fault Tolerant CORBA

Definition at line 54 of file PG_FactoryRegistry.h.

---

Member Typedef Documentation

typedef ACE_Guard<TAO_SYNCH_MUTEX> TAO::PG_FactoryRegistry::InternalGuard [private]

Definition at line 186 of file PG_FactoryRegistry.h.

typedef ACE_Null_Mutex TAO::PG_FactoryRegistry::MapMutex [private]

Definition at line 64 of file PG_FactoryRegistry.h.

typedef ACE_Hash_Map_Manager<ACE_CString, RoleInfo *, MapMutex> TAO::PG_FactoryRegistry::RegistryType [private]

Definition at line 65 of file PG_FactoryRegistry.h.

typedef ACE_Hash_Map_Entry<ACE_CString, RoleInfo *> TAO::PG_FactoryRegistry::RegistryType_Entry [private]

Definition at line 66 of file PG_FactoryRegistry.h. Referenced by list_factories_by_location(), and unregister_factory_by_location().

typedef ACE_Hash_Map_Iterator<ACE_CString, RoleInfo *, MapMutex> TAO::PG_FactoryRegistry::RegistryType_Iterator [private]

Definition at line 67 of file PG_FactoryRegistry.h. Referenced by list_factories_by_location(), and unregister_factory_by_location().

---

Member Enumeration Documentation

anonymous enum [private]

State of the quit process Enumeration values: LIVE  DEACTIVATED  GONE  Definition at line 235 of file PG_FactoryRegistry.h. {LIVE, DEACTIVATED, GONE} quit_state_;

---

Constructor & Destructor Documentation

TAO::PG_FactoryRegistry::PG_FactoryRegistry (  const char *  name = "FactoryRegistry"  )

Constructor. Definition at line 45 of file PG_FactoryRegistry.cpp. : identity_(name) , orb_ (0) , poa_ (0) , object_id_ (0) , this_obj_ (0) , ior_output_file_(0) , ns_name_(0) , naming_context_(0) , this_name_(1) , quit_on_idle_(0) , quit_state_(LIVE) , linger_(0) { }

TAO::PG_FactoryRegistry::~PG_FactoryRegistry (  void   )  [virtual]

virtual Destructor Definition at line 61 of file PG_FactoryRegistry.cpp. { }

---

Member Function Documentation

void TAO::PG_FactoryRegistry::_remove_ref (  void   )  [virtual]

Definition at line 116 of file PG_FactoryRegistry.cpp. References GONE, and quit_state_. { this->quit_state_ = GONE; }

int TAO::PG_FactoryRegistry::fini (  void   )

Prepare to exit. Returns: zero for success; nonzero is process return code for failure. Definition at line 140 of file PG_FactoryRegistry.cpp. References ior_output_file_, naming_context_, ns_name_, this_name_, and ACE_OS::unlink(). { if (this->ior_output_file_ != 0) { ACE_OS::unlink (this->ior_output_file_); this->ior_output_file_ = 0; } if (this->ns_name_ != 0) { this->naming_context_->unbind (this_name_); this->ns_name_ = 0; } return 0; }

const char * TAO::PG_FactoryRegistry::identity (   )  const

Identify this object. Returns: a string to identify this object for logging/console message purposes. Definition at line 111 of file PG_FactoryRegistry.cpp. References identity_. Referenced by unregister_factory(), unregister_factory_by_location(), and unregister_factory_by_role(). { return this->identity_.c_str(); }

int TAO::PG_FactoryRegistry::idle (  int &  result  )

Processing to happen when the ORB's event loop is idle. Parameters: result  is a place to return status to be returned by the process Returns: 0 to continue. 1 to quit. Definition at line 121 of file PG_FactoryRegistry.cpp. References GONE, and quit_state_. { result = 0; int quit = 0; if (this->quit_state_ == GONE) { if (linger_ < 2) { ++linger_; } else { quit = 1; } } return quit; }

void TAO::PG_FactoryRegistry::init (  CORBA::ORB_ptr  orb, PortableServer::POA_ptr  poa )

alternative init using designated poa Definition at line 156 of file PG_FactoryRegistry.cpp. References CORBA::ORB::_duplicate(), ACE_ASSERT, and this_obj_. { ACE_ASSERT (CORBA::is_nil (this->orb_.in ())); ACE_ASSERT (CORBA::is_nil (this->poa_.in ())); this->orb_ = CORBA::ORB::_duplicate (orb); this->poa_ = PortableServer::POA::_duplicate (poa); ACE_ASSERT ( ! CORBA::is_nil (this->orb_.in ())); ACE_ASSERT ( ! CORBA::is_nil (this->poa_.in ())); // Register with the POA. this->object_id_ = this->poa_->activate_object (this); // find my identity as a corba object this->this_obj_ = this->poa_->id_to_reference (object_id_.in ()); // and create a ior string this->ior_ = this->orb_->object_to_string (this->this_obj_.in ()); }

int TAO::PG_FactoryRegistry::init (  CORBA::ORB_ptr  orb  )

Initialize this object. Parameters: orbManager  our ORB -- we keep var to it. Returns: zero for success; nonzero is process return code for failure. Definition at line 177 of file PG_FactoryRegistry.cpp. References CORBA::ORB::_duplicate(), ACE_ERROR_RETURN, ACE_TEXT(), identity_, ior_output_file_, CORBA::is_nil(), LM_ERROR, naming_context_, ns_name_, CORBA::string_dup(), TAO_OBJID_ROOTPOA, this_name_, this_obj_, and write_ior_file(). { int result = 0; this->orb_ = CORBA::ORB::_duplicate (orb); // Use the ROOT POA for now CORBA::Object_var poa_object = this->orb_->resolve_initial_references (TAO_OBJID_ROOTPOA); if (CORBA::is_nil (poa_object.in ())) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT (" (%P|%t) Unable to initialize the POA.\n")), -1); // Get the POA object. this->poa_ = PortableServer::POA::_narrow (poa_object.in ()); if (CORBA::is_nil (this->poa_.in())) { ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT (" (%P|%t) Unable to narrow the POA.\n")), -1); } PortableServer::POAManager_var poa_manager = this->poa_->the_POAManager (); poa_manager->activate (); // Register with the POA. this->object_id_ = this->poa_->activate_object (this); // find my identity as a corba object this->this_obj_ = this->poa_->id_to_reference (object_id_.in ()); // and create a ior string this->ior_ = this->orb_->object_to_string (this->this_obj_.in ()); if (this->ior_output_file_ != 0) { this->identity_ = "file:"; this->identity_ += this->ior_output_file_; result = write_ior_file (this->ior_output_file_, this->ior_.in ()); } if (this->ns_name_ != 0) { this->identity_ = "name:"; this->identity_ += this->ns_name_; CORBA::Object_var naming_obj = this->orb_->resolve_initial_references ("NameService"); if (CORBA::is_nil(naming_obj.in ())){ ACE_ERROR_RETURN ((LM_ERROR, "%T %n (%P|%t) Unable to find the Naming Service\n"), 1); } this->naming_context_ = CosNaming::NamingContext::_narrow (naming_obj.in ()); this->this_name_.length (1); this->this_name_[0].id = CORBA::string_dup (this->ns_name_); this->naming_context_->rebind (this->this_name_, this->this_obj_.in() //CORBA::Object::_duplicate(this_obj) ); } return result; }

PortableGroup::FactoryInfos * TAO::PG_FactoryRegistry::list_factories_by_location (  const PortableGroup::Location &  location  )

Definition at line 630 of file PG_FactoryRegistry.cpp. References ACE_NEW_THROW_EX, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::begin(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::end(), PortableGroup::FactoryInfos, TAO::PG_FactoryRegistry::RoleInfo::infos_, ACE_Hash_Map_Entry< ACE_CString, RoleInfo * >::int_id_, list_factories_by_location(), PortableGroup::Location, METHOD_ENTRY, METHOD_RETURN, registry_, RegistryType_Entry, RegistryType_Iterator, and PortableGroup::FactoryInfo::the_location. Referenced by list_factories_by_location(). { METHOD_ENTRY(TAO::PG_FactoryRegistry::list_factories_by_location); ::PortableGroup::FactoryInfos_var result; ACE_NEW_THROW_EX (result, ::PortableGroup::FactoryInfos(this->registry_.current_size()), CORBA::NO_MEMORY (TAO::VMCID, CORBA::COMPLETED_NO)); size_t result_length = 0; // iterate through the registery for (RegistryType_Iterator it = this->registry_.begin(); it != this->registry_.end(); ++it) { RegistryType_Entry & entry = *it; RoleInfo * role_info = entry.int_id_; PortableGroup::FactoryInfos & found_infos = role_info->infos_; // iterate through the entry for this type int found = 0; size_t length = found_infos.length(); for (size_t nInfo = 0; !found && nInfo < length; ++nInfo) { PortableGroup::FactoryInfo & info = found_infos[nInfo]; if (info.the_location == location) { found = 1; result_length += 1; result->length(result_length); (*result)[result_length-1] = info; } } } METHOD_RETURN(TAO::PG_FactoryRegistry::list_factories_by_location) result._retn(); }

PortableGroup::FactoryInfos * TAO::PG_FactoryRegistry::list_factories_by_role (  const char *  role, CORBA::String_out  type_id )

Definition at line 599 of file PG_FactoryRegistry.cpp. References ACE_ERROR, ACE_NEW_THROW_EX, PortableGroup::FactoryInfos, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::find(), TAO::PG_FactoryRegistry::RoleInfo::infos_, list_factories_by_role(), LM_INFO, METHOD_ENTRY, METHOD_RETURN, registry_, CORBA::string_dup(), and TAO::PG_FactoryRegistry::RoleInfo::type_id_. Referenced by list_factories_by_role(). { METHOD_ENTRY(TAO::PG_FactoryRegistry::list_factories_by_role); // allocate stucture to be returned. PortableGroup::FactoryInfos_var result = 0; ACE_NEW_THROW_EX (result, ::PortableGroup::FactoryInfos(), CORBA::NO_MEMORY (TAO::VMCID, CORBA::COMPLETED_NO)); RoleInfo * role_info = 0; if (this->registry_.find(role, role_info) == 0) { type_id = CORBA::string_dup(role_info->type_id_.c_str()); (*result) = role_info->infos_; } else { type_id = CORBA::string_dup(""); ACE_ERROR(( LM_INFO, "%s: list_factories_by_role: unknown role %s\n", this->identity_.c_str(), role )); } METHOD_RETURN(TAO::PG_FactoryRegistry::list_factories_by_role) result._retn(); }

int TAO::PG_FactoryRegistry::parse_args (  int  argc, char *  argv[] )

Parse command line arguments. Parameters: argc  traditional C argc argv  traditional C argv Returns: zero for success; nonzero is process return code for failure. Definition at line 68 of file PG_FactoryRegistry.cpp. References ACE_ERROR_RETURN, ior_output_file_, LM_ERROR, ns_name_, and quit_on_idle_. { ACE_Get_Opt get_opts (argc, argv, "o:n:q"); int c; while ((c = get_opts ()) != -1) { switch (c) { case 'o': { this->ior_output_file_ = get_opts.opt_arg (); break; } case 'n': { this->ns_name_ = get_opts.opt_arg(); break; } case 'q': { this->quit_on_idle_ = 1; break; } case '?': // fall thru default: ACE_ERROR_RETURN ((LM_ERROR, "usage: %s" " -o <registry ior file>" " -n <name to use to register with name service>" " -q{uit on idle}" "\n", argv [0]), -1); break; } } // Indicates sucessful parsing of the command line return 0; }

PortableGroup::FactoryRegistry_ptr TAO::PG_FactoryRegistry::reference (   )

An object reference to the this object. Duplicated by the call so it may (and probably should) be assigned to a _var.. Definition at line 257 of file PG_FactoryRegistry.cpp. { // narrow and duplicate return ::PortableGroup::FactoryRegistry::_narrow(this->this_obj_.in ()); }

void TAO::PG_FactoryRegistry::register_factory (  const char *  role, const char *  type_id, const PortableGroup::FactoryInfo &  factory_info )  [virtual]

Definition at line 284 of file PG_FactoryRegistry.cpp. References ACE_AUTO_PTR_RESET, ACE_DEBUG, ACE_ERROR, ACE_NEW_THROW_EX, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::bind(), PortableGroup::FactoryInfos, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::find(), ACE_Auto_Basic_Ptr< X >::get(), TAO::PG_FactoryRegistry::RoleInfo::infos_, LM_DEBUG, LM_ERROR, METHOD_ENTRY, METHOD_RETURN, register_factory(), registry_, ACE_Auto_Basic_Ptr< X >::release(), PortableGroup::FactoryInfo::the_location, and TAO::PG_FactoryRegistry::RoleInfo::type_id_. Referenced by register_factory(). { METHOD_ENTRY(TAO::PG_FactoryRegistry::register_factory); RoleInfo * role_info = 0; auto_ptr<RoleInfo> safe_entry; if (this->registry_.find(role, role_info) != 0) { ACE_DEBUG(( LM_DEBUG, "%s: adding new role: %s:%s\n", this->identity_.c_str(), role, type_id)); // Note the 5. It's a guess about the number of factories // that might exist for any particular role object. // todo: make it a parameter. ACE_NEW_THROW_EX (role_info, RoleInfo(5), CORBA::NO_MEMORY()); ACE_AUTO_PTR_RESET (safe_entry, role_info, RoleInfo); role_info->type_id_ = type_id; } else { if (role_info->type_id_ != type_id) { throw PortableGroup::TypeConflict(); } } PortableGroup::FactoryInfos & infos = role_info->infos_;; size_t length = infos.length(); for (size_t nInfo = 0; nInfo < length; ++nInfo) { PortableGroup::FactoryInfo & info = infos[nInfo]; if (info.the_location == factory_info.the_location) { ACE_ERROR(( LM_ERROR, "%s: Attempt to register duplicate location %s for role: %s\n" , this->identity_.c_str(), static_cast<const char *> (info.the_location[0].id), role)); throw PortableGroup::MemberAlreadyPresent(); } } infos.length(length + 1); infos[length] = factory_info; if (safe_entry.get() != 0) { this->registry_.bind(role, safe_entry.release()); } ACE_DEBUG(( LM_DEBUG, "%s: Added factory: [%d] %s@%s \n", this->identity_.c_str(), static_cast<int> (length + 1), role, static_cast<const char *> (factory_info.the_location[0].id) )); METHOD_RETURN(TAO::PG_FactoryRegistry::register_factory); }

void TAO::PG_FactoryRegistry::unregister_factory (  const char *  role, const PortableGroup::Location &  location )  [virtual]

Definition at line 353 of file PG_FactoryRegistry.cpp. References ACE_ASSERT, ACE_DEBUG, ACE_ERROR, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::current_size(), PortableGroup::FactoryInfos, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::find(), identity(), TAO::PG_FactoryRegistry::RoleInfo::infos_, LIVE, LM_ERROR, LM_INFO, PortableGroup::Location, METHOD_ENTRY, METHOD_RETURN, quit_on_idle_, quit_state_, registry_, PortableGroup::FactoryInfo::the_location, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::unbind(), and unregister_factory(). Referenced by unregister_factory(). { METHOD_ENTRY(TAO::PG_FactoryRegistry::unregister_factory); RoleInfo * role_info = 0; if (this->registry_.find(role, role_info) == 0) { PortableGroup::FactoryInfos & infos = role_info->infos_; int found = 0; size_t length = infos.length(); for (size_t nInfo = 0; !found && nInfo < length; ++nInfo) { PortableGroup::FactoryInfo & info = infos[nInfo]; if (info.the_location == location) { found = 1; ACE_ERROR(( LM_INFO, "%s: Unregistering factory %s@%s\n", this->identity_.c_str(), role, static_cast<const char *> (location[0].id) )); if (length > 1) { // if this is not the last entry if (nInfo + 1 < length) { // move last entry into newly-emptied slot infos[nInfo] = infos[length - 1]; nInfo = length -1; } infos.length(nInfo); } else { ACE_ASSERT ( length == 1 ); if (this->registry_.unbind (role) == 0) { ACE_DEBUG(( LM_INFO, "%s: No more factories registered for %s\n", this->identity_.c_str(), role )); delete role_info; } else { ACE_ERROR ((LM_ERROR, "%s: LOGIC ERROR AT " __FILE__ " (%d): Entry to be deleted disappeared\n", this->identity_.c_str(), __LINE__)); } } } } } else { ACE_ERROR(( LM_ERROR, "%s, Attempt to unregister factory for unknown role %s\n", this->identity_.c_str(), role )); throw PortableGroup::MemberNotFound(); } ////////////////////// // request complete // check quit-on-idle if (registry_.current_size() == 0 && quit_state_ == LIVE) { ACE_ERROR(( LM_INFO, "%s is idle\n", identity() )); if (quit_on_idle_) { this->poa_->deactivate_object (this->object_id_.in ()); quit_state_ = DEACTIVATED; } } METHOD_RETURN(TAO::PG_FactoryRegistry::unregister_factory); }

void TAO::PG_FactoryRegistry::unregister_factory_by_location (  const PortableGroup::Location &  location  )  [virtual]

Definition at line 487 of file PG_FactoryRegistry.cpp. References ACE_ASSERT, ACE_CString, ACE_ERROR, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::begin(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::current_size(), ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::end(), ACE_Hash_Map_Entry< ACE_CString, RoleInfo * >::ext_id_, PortableGroup::FactoryInfos, identity(), TAO::PG_FactoryRegistry::RoleInfo::infos_, ACE_Hash_Map_Entry< ACE_CString, RoleInfo * >::int_id_, LIVE, LM_ERROR, LM_INFO, PortableGroup::Location, METHOD_ENTRY, METHOD_RETURN, ACE_Vector< T, DEFAULT_SIZE >::push_back(), quit_on_idle_, quit_state_, registry_, RegistryType_Entry, RegistryType_Iterator, ACE_Vector< T, DEFAULT_SIZE >::size(), PortableGroup::FactoryInfo::the_location, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::unbind(), and unregister_factory_by_location(). Referenced by unregister_factory_by_location(). { METHOD_ENTRY(TAO::PG_FactoryRegistry::unregister_factory_by_location); //////////////////////////////////////////// // a vector of roles that need to be deleted. ACE_Vector<ACE_CString> emptyRoles; // iterate through the registery for (RegistryType_Iterator it = this->registry_.begin(); it != this->registry_.end(); ++it) { RegistryType_Entry & entry = *it; ACE_CString & role = entry.ext_id_; RoleInfo * role_info = entry.int_id_; PortableGroup::FactoryInfos & infos = role_info->infos_; // ACE_ERROR((LM_INFO, "unregister_factory_by_location: Checking role %s\n", role.c_str() )); int found = 0; size_t length = infos.length(); for (size_t nInfo = 0; !found && nInfo < length; ++nInfo) { PortableGroup::FactoryInfo & info = infos[nInfo]; if (info.the_location == location) { ACE_ERROR((LM_INFO, "%s: Unregister_factory_by_location: Removing: [%d] %s@%s\n", this->identity_.c_str(), static_cast<int> (nInfo), role.c_str(), static_cast<const char *> (location[0].id) )); found = 1; if (length > 1) { while (nInfo + 1 < length) { ACE_ERROR((LM_INFO, "%s: Unregister_factory_by_location: Move: [%d] %s to [%d]\n", this->identity_.c_str(), (int)nInfo + 1, role.c_str(), (int)nInfo )); infos[nInfo] = infos[nInfo + 1]; nInfo += 1; } ACE_ERROR((LM_INFO, "%s: unregister_factory_by_location: New length [%d] %s\n", this->identity_.c_str(), (int)nInfo, role.c_str() )); infos.length(nInfo); } else { ACE_ERROR((LM_INFO, "%s: Removed all entries for %s\n", this->identity_.c_str(), role.c_str() )); ACE_ASSERT ( length == 1 ); // remember entries to be deleted emptyRoles.push_back(entry.ext_id_); } } } } // now remove any roles that became empty for (size_t nRole = 0; nRole < emptyRoles.size(); ++nRole) { ACE_ERROR((LM_INFO, "%s: Remove role %s\n", this->identity_.c_str(), emptyRoles[nRole].c_str() )); RoleInfo * role_info; if (this->registry_.unbind(emptyRoles[nRole], role_info) == 0) { delete role_info; } else { ACE_ERROR ((LM_ERROR, "%s: LOGIC ERROR AT " __FILE__ " (%d): Role to be deleted disappeared\n", this->identity_.c_str(), __LINE__)); } } ////////////////////////// // If all types are gone... if (registry_.current_size() == 0 && quit_state_ == LIVE) { ACE_ERROR(( LM_INFO, "%s is idle\n", identity() )); if (quit_on_idle_) { this->poa_->deactivate_object (this->object_id_.in ()); quit_state_ = DEACTIVATED; } } METHOD_RETURN(TAO::PG_FactoryRegistry::unregister_factory_by_location); }

void TAO::PG_FactoryRegistry::unregister_factory_by_role (  const char *  role  )  [virtual]

Definition at line 442 of file PG_FactoryRegistry.cpp. References ACE_DEBUG, ACE_ERROR, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::current_size(), identity(), LIVE, LM_DEBUG, LM_INFO, METHOD_ENTRY, METHOD_RETURN, quit_on_idle_, quit_state_, registry_, ACE_Hash_Map_Manager_Ex< EXT_ID, INT_ID, ACE_Hash< EXT_ID >, ACE_Equal_To< EXT_ID >, ACE_LOCK >::unbind(), and unregister_factory_by_role(). Referenced by unregister_factory_by_role(). { METHOD_ENTRY(TAO::PG_FactoryRegistry::unregister_factory_by_role); RoleInfo * role_info = 0; if (this->registry_.unbind(role, role_info) == 0) { ACE_DEBUG(( LM_DEBUG, "%s: Unregistering all factories for role %s\n", this->identity_.c_str(), role )); // delete the entire set of factories for this location. delete role_info; } else { ACE_ERROR(( LM_INFO, "%s: Unregister_factory_by_role: unknown role: %s\n", this->identity_.c_str(), role )); } ///////////////////// // Function complete // check quit options if (registry_.current_size() == 0 && quit_state_ == LIVE) { ACE_ERROR(( LM_INFO, "%s is idle\n", identity() )); if (quit_on_idle_) { this->poa_->deactivate_object (this->object_id_.in ()); quit_state_ = DEACTIVATED; } } METHOD_RETURN(TAO::PG_FactoryRegistry::unregister_factory_by_role); }

int TAO::PG_FactoryRegistry::write_ior_file (  const char *  outputFile, const char *  ior )  [private]

Write this factory's IOR to a file Definition at line 673 of file PG_FactoryRegistry.cpp. References ACE_ERROR, ACE_OS::fclose(), ACE_OS::fopen(), ACE_OS::fprintf(), and LM_ERROR. Referenced by init(). { int result = -1; FILE* out = ACE_OS::fopen (outputFile, "w"); if (out) { ACE_OS::fprintf (out, "%s", ior); ACE_OS::fclose (out); result = 0; } else { ACE_ERROR ((LM_ERROR, "Open failed for %s\n", outputFile )); } return result; }

---

Member Data Documentation

ACE_CString TAO::PG_FactoryRegistry::identity_ [private]

A human-readable string to distinguish this from other Notifiers. Definition at line 175 of file PG_FactoryRegistry.h. Referenced by identity(), and init().

TAO_SYNCH_MUTEX TAO::PG_FactoryRegistry::internals_ [private]

Protect internal state. Mutex should be locked by corba methods, or by external (public) methods before calling implementation methods. Implementation methods should assume the mutex is locked if necessary. Definition at line 185 of file PG_FactoryRegistry.h.

CORBA::String_var TAO::PG_FactoryRegistry::ior_ [private]

IOR of this object as assigned by poa. Definition at line 211 of file PG_FactoryRegistry.h.

const char* TAO::PG_FactoryRegistry::ior_output_file_ [private]

A file to which the factory's IOR should be written. Definition at line 216 of file PG_FactoryRegistry.h. Referenced by fini(), init(), and parse_args().

int TAO::PG_FactoryRegistry::linger_ [private]

Definition at line 237 of file PG_FactoryRegistry.h.

CosNaming::NamingContext_var TAO::PG_FactoryRegistry::naming_context_ [private]

Definition at line 223 of file PG_FactoryRegistry.h. Referenced by fini(), and init().

const char* TAO::PG_FactoryRegistry::ns_name_ [private]

A name to be used to register the factory with the name service. Definition at line 221 of file PG_FactoryRegistry.h. Referenced by fini(), init(), and parse_args().

PortableServer::ObjectId_var TAO::PG_FactoryRegistry::object_id_ [private]

The CORBA object id assigned to this object. Definition at line 201 of file PG_FactoryRegistry.h.

CORBA::ORB_var TAO::PG_FactoryRegistry::orb_ [private]

The orb Definition at line 191 of file PG_FactoryRegistry.h.

PortableServer::POA_var TAO::PG_FactoryRegistry::poa_ [private]

The POA used to activate this object. Definition at line 196 of file PG_FactoryRegistry.h.

int TAO::PG_FactoryRegistry::quit_on_idle_ [private]

Quit on idle flag. Definition at line 230 of file PG_FactoryRegistry.h. Referenced by parse_args(), unregister_factory(), unregister_factory_by_location(), and unregister_factory_by_role().

enum { ... } TAO::PG_FactoryRegistry::quit_state_ [private]

State of the quit process Referenced by _remove_ref(), idle(), unregister_factory(), unregister_factory_by_location(), and unregister_factory_by_role().

RegistryType TAO::PG_FactoryRegistry::registry_ [private]

Definition at line 239 of file PG_FactoryRegistry.h. Referenced by list_factories_by_location(), list_factories_by_role(), register_factory(), unregister_factory(), unregister_factory_by_location(), and unregister_factory_by_role().

CosNaming::Name TAO::PG_FactoryRegistry::this_name_ [private]

Definition at line 225 of file PG_FactoryRegistry.h. Referenced by fini(), and init().

CORBA::Object_var TAO::PG_FactoryRegistry::this_obj_ [private]

This objects identity as a CORBA object. Definition at line 206 of file PG_FactoryRegistry.h. Referenced by init().

---

The documentation for this class was generated from the following files:

• PG_FactoryRegistry.h
• PG_FactoryRegistry.cpp

---