diff options
Diffstat (limited to 'ACE/TAO/orbsvcs/orbsvcs/IFRService/InterfaceAttrExtension_i.cpp')
| -rw-r--r-- | ACE/TAO/orbsvcs/orbsvcs/IFRService/InterfaceAttrExtension_i.cpp | 320 |
1 files changed, 320 insertions, 0 deletions
diff --git a/ACE/TAO/orbsvcs/orbsvcs/IFRService/InterfaceAttrExtension_i.cpp b/ACE/TAO/orbsvcs/orbsvcs/IFRService/InterfaceAttrExtension_i.cpp new file mode 100644 index 00000000000..6865c8e0262 --- /dev/null +++ b/ACE/TAO/orbsvcs/orbsvcs/IFRService/InterfaceAttrExtension_i.cpp @@ -0,0 +1,320 @@ +// $Id$ + +#include "orbsvcs/IFRService/InterfaceAttrExtension_i.h" +#include "orbsvcs/IFRService/Repository_i.h" +#include "orbsvcs/IFRService/InterfaceDef_i.h" +#include "orbsvcs/IFRService/OperationDef_i.h" +#include "orbsvcs/IFRService/AttributeDef_i.h" +#include "orbsvcs/IFRService/ExtAttributeDef_i.h" +#include "orbsvcs/IFRService/IFR_Service_Utils.h" + +#include "ace/SString.h" + + +ACE_RCSID (IFRService, + InterfaceAttrExtension_i, + "$Id$") + +// ===================================================================== + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +TAO_InterfaceAttrExtension_i::TAO_InterfaceAttrExtension_i ( + TAO_Repository_i *repo + ) + : TAO_IRObject_i (repo) +{ +} + +TAO_InterfaceAttrExtension_i::~TAO_InterfaceAttrExtension_i (void) +{ +} + + +CORBA::InterfaceAttrExtension::ExtFullInterfaceDescription * +TAO_InterfaceAttrExtension_i::describe_ext_interface ( + ) +{ + TAO_IFR_READ_GUARD_RETURN (0); + + this->update_key (); + + return this->describe_ext_interface_i (); +} + +CORBA::InterfaceAttrExtension::ExtFullInterfaceDescription * +TAO_InterfaceAttrExtension_i::describe_ext_interface_i ( + ) +{ + CORBA::InterfaceAttrExtension::ExtFullInterfaceDescription *fifd = 0; + ACE_NEW_RETURN (fifd, + CORBA::InterfaceAttrExtension::ExtFullInterfaceDescription, + 0); + + CORBA::InterfaceAttrExtension::ExtFullInterfaceDescription_var retval = + fifd; + + ACE_TString holder; + + this->repo_->config ()->get_string_value (this->section_key_, + "name", + holder); + fifd->name = holder.fast_rep (); + this->repo_->config ()->get_string_value (this->section_key_, + "id", + holder); + fifd->id = holder.fast_rep (); + + this->repo_->config ()->get_string_value (this->section_key_, + "container_id", + holder); + + fifd->defined_in = holder.fast_rep (); + this->repo_->config ()->get_string_value (this->section_key_, + "version", + holder); + fifd->version = holder.fast_rep (); + + CORBA::ULong i = 0; + CORBA::ULong j = 0; + ACE_Unbounded_Queue<ACE_Configuration_Section_Key> key_queue; + + // Store our section key for later restoration after we have + // traversed entries for inherited interfaces. + ACE_Configuration_Section_Key key_holder = this->section_key_; + + // Operations + TAO_InterfaceDef_i iface (this->repo_); + iface.section_key (this->section_key_); + iface.inherited_operations (key_queue); + + // Restore our original section key. + // I am not sure this is needed but it will not hurt. + this->section_key (key_holder); + + ACE_Configuration_Section_Key ops_key, op_key; + int status = + this->repo_->config ()->open_section (this->section_key_, + "ops", + 0, + ops_key); + + CORBA::ULong count = 0; + + if (status == 0) + { + this->repo_->config ()->get_integer_value (ops_key, + "count", + count); + + for (j = 0; j < count; ++j) + { + char *stringified = TAO_IFR_Service_Utils::int_to_string (j); + status = + this->repo_->config ()->open_section (ops_key, + stringified, + 0, + op_key); + + if (status == 0) + { + key_queue.enqueue_tail (op_key); + } + } + } + + CORBA::ULong size = static_cast<CORBA::ULong> (key_queue.size ()); + fifd->operations.length (size); + + for (i = 0; i < size; ++i) + { + ACE_Configuration_Section_Key key; + key_queue.dequeue_head (key); + + TAO_OperationDef_i op (this->repo_); + op.section_key (key); + + op.make_description (fifd->operations[i]); + } + + // Restore our original section key. + // It may have been overwritten by a superclass key as part of the + // make_description() call. + this->section_key (key_holder); + + // Attributes. + iface.inherited_attributes (key_queue); + + // Restore our original section key. + // I am not sure this is needed but it will not hurt. + this->section_key (key_holder); + + ACE_Configuration_Section_Key attrs_key; + status = + this->repo_->config ()->open_section (this->section_key_, + "attrs", + 0, + attrs_key); + + count = 0; + + if (status == 0) + { + this->repo_->config ()->get_integer_value (attrs_key, + "count", + count); + + for (j = 0; j < count; ++j) + { + ACE_Configuration_Section_Key attr_key; + char *stringified = TAO_IFR_Service_Utils::int_to_string (j); + status = + this->repo_->config ()->open_section (attrs_key, + stringified, + 0, + attr_key); + + if (status == 0) + { + key_queue.enqueue_tail (attr_key); + } + } + } + + size = static_cast<CORBA::ULong> (key_queue.size ()); + fifd->attributes.length (size); + + for (i = 0; i < size; ++i) + { + ACE_Configuration_Section_Key key; + key_queue.dequeue_head (key); + + TAO_ExtAttributeDef_i attr (this->repo_); + attr.section_key (key); + + attr.fill_description (fifd->attributes[i]); + } + + // Restore our original section key. + // It may have been overwritten by a superclass key as part of the + // fill_description() call. + this->section_key (key_holder); + + CORBA::InterfaceDefSeq_var bases = + iface.base_interfaces_i (); + + CORBA::ULong length = bases->length (); + CORBA::RepositoryIdSeq repo_ids (length); + repo_ids.length (length); + + PortableServer::ObjectId_var oid; + char *base_path = 0; + ACE_Configuration_Section_Key base_key; + + for (i = 0; i < length; ++i) + { + base_path = TAO_IFR_Service_Utils::reference_to_path (bases[i]); + + this->repo_->config ()->expand_path (this->repo_->root_key (), + base_path, + base_key, + 0); + this->repo_->config ()->get_string_value (base_key, + "id", + holder); + repo_ids[i] = holder.fast_rep (); + } + + fifd->base_interfaces = repo_ids; + + fifd->type = iface.type_i (); + + return retval._retn (); +} + +CORBA::ExtAttributeDef_ptr +TAO_InterfaceAttrExtension_i::create_ext_attribute ( + const char *id, + const char *name, + const char *version, + CORBA::IDLType_ptr type, + CORBA::AttributeMode mode, + const CORBA::ExceptionDefSeq &get_exceptions, + const CORBA::ExceptionDefSeq &set_exceptions + ) +{ + TAO_IFR_WRITE_GUARD_RETURN (CORBA::ExtAttributeDef::_nil ()); + + this->update_key (); + + return this->create_ext_attribute_i (id, + name, + version, + type, + mode, + get_exceptions, + set_exceptions); +} + +CORBA::ExtAttributeDef_ptr +TAO_InterfaceAttrExtension_i::create_ext_attribute_i ( + const char *id, + const char *name, + const char *version, + CORBA::IDLType_ptr type, + CORBA::AttributeMode mode, + const CORBA::ExceptionDefSeq &get_exceptions, + const CORBA::ExceptionDefSeq &set_exceptions + ) +{ + TAO_Container_i::tmp_name_holder (name); + ACE_Configuration_Section_Key new_key; + + // Common to all IR objects created in CORBA::Container. + ACE_TString path = + TAO_IFR_Service_Utils::create_common (CORBA::dk_Interface, + CORBA::dk_Attribute, + this->section_key_, + new_key, + this->repo_, + id, + name, + &TAO_Container_i::same_as_tmp_name, + version, + "attrs"); + + // Store the path to the attribute's type definition. + char *type_path = TAO_IFR_Service_Utils::reference_to_path (type); + + this->repo_->config ()->set_string_value (new_key, + "type_path", + type_path); + + // Store the attribute's mode. + this->repo_->config ()->set_integer_value (new_key, + "mode", + mode); + + TAO_IFR_Service_Utils::set_exceptions (this->repo_->config (), + new_key, + "get_excepts", + get_exceptions); + + TAO_IFR_Service_Utils::set_exceptions (this->repo_->config (), + new_key, + "put_excepts", + set_exceptions); + + // Create the object reference. + CORBA::Object_var obj = + TAO_IFR_Service_Utils::create_objref (CORBA::dk_Attribute, + path.c_str (), + this->repo_); + + CORBA::ExtAttributeDef_var retval = + CORBA::ExtAttributeDef::_narrow (obj.in ()); + + return retval._retn (); +} + +TAO_END_VERSIONED_NAMESPACE_DECL |