diff options
Diffstat (limited to 'TAO/CIAO/DAnCE/Config_Handlers/CAD_Handler.cpp')
| -rw-r--r-- | TAO/CIAO/DAnCE/Config_Handlers/CAD_Handler.cpp | 310 |
1 files changed, 310 insertions, 0 deletions
diff --git a/TAO/CIAO/DAnCE/Config_Handlers/CAD_Handler.cpp b/TAO/CIAO/DAnCE/Config_Handlers/CAD_Handler.cpp new file mode 100644 index 00000000000..1f6464e6102 --- /dev/null +++ b/TAO/CIAO/DAnCE/Config_Handlers/CAD_Handler.cpp @@ -0,0 +1,310 @@ +// $Id$ + +#include "tao/Exception.h" +#include "ace/Auto_Ptr.h" +#include "ace/Log_Msg.h" +#include "ERE_Handler.h" +#include "CEPE_Handler.h" +#include "CPR_Handler.h" +#include "CAD_Handler.h" +#include "Property_Handler.h" +#include "Requirement_Handler.h" +#include "CompPkgDesc_Handler.h" +#include "Utils.h" +#include "Process_Element.h" +#include <iostream> + +BEGIN_DEPLOYMENT_NAMESPACE + +/// handle the connection resource deployment description and populate it +void CAD_Handler::process_ComponentAssemblyDescription + (::Deployment::ComponentAssemblyDescription& cad) +{ + for (DOMNode* node = this->iter_->nextNode(); + node != 0; + node = this->iter_->nextNode()) + { + XStr node_name (node->getNodeName()); + + if (node_name == XStr + (ACE_TEXT ("Deployment:ComponentAssemblyDescription"))) + { + } + else if + (process_sequence_local + <Deployment::SubcomponentInstantiationDescription> + (this->doc_, this->iter_, node, + node_name, "instance", cad.instance, + this, &CAD_Handler::process_instance)); + else if + (process_sequence_local<Deployment::AssemblyConnectionDescription> + (this->doc_, this->iter_, node, + node_name, "connection", cad.connection, + this, &CAD_Handler::process_connection)); + else if + (process_sequence_local<Deployment::AssemblyPropertyMapping> + (this->doc_, this->iter_, node, + node_name, "externalProperty", cad.externalProperty, + this, &CAD_Handler::process_property)); + else + { + this->iter_->previousNode (); + return; + } + } + + this->update_spe_refs (cad); + this->update_spr_refs (cad); + + return; +} + +void CAD_Handler::update_spe_refs (Deployment:: + ComponentAssemblyDescription& cad) +{ + CORBA::ULong x; + CORBA::ULong y; + int ref_value; + int value; + ACE_TString ref_name; + + for (x = 0; x < cad.connection.length (); ++x) + { + for (y = 0; y < cad.connection[x].internalEndpoint.length (); ++y) + { + ref_value = cad.connection[x].internalEndpoint[y].instanceRef; + if (idref_map_.find (ref_value, ref_name) == 0) + { + if (id_map_.find (ref_name, value) == 0) + { + cad.connection[x].internalEndpoint[y].instanceRef= value; + } + } + } + } +} + +void CAD_Handler::update_spr_refs (Deployment:: + ComponentAssemblyDescription& cad) +{ + CORBA::ULong x; + CORBA::ULong y; + int ref_value; + int value; + ACE_TString ref_name; + + for (x = 0; x < cad.externalProperty.length (); ++x) + { + for (y = 0; y < cad.externalProperty[x].delegatesTo.length (); ++y) + { + ref_value = cad.externalProperty[x].delegatesTo[y].instanceRef; + if (idref_map_.find (ref_value, ref_name) == 0) + { + if (id_map_.find (ref_name, value) == 0) + { + cad.externalProperty[x].delegatesTo[y].instanceRef = value; + } + } + } + } +} + +void CAD_Handler::process_instance (DOMNodeIterator* iter, + Deployment:: + SubcomponentInstantiationDescription& sid) +{ + char* root_node_name_ch = XMLString::transcode + (this->doc_->getDocumentElement ()->getNodeName ()); + ACE_TString root_node_name (root_node_name_ch); + + XMLString::release (&root_node_name_ch); + + for (DOMNode* node = iter->nextNode(); + node != 0; + node = iter->nextNode ()) + { + XStr node_name (node->getNodeName()); + + if (node_name == XStr + (ACE_TEXT ("Deployment:SubcomponentInstantiationDescription"))) + { + } + else if + (CIAO::Config_Handler::Utils::process_string + (iter, node_name, "name", sid.name)); + else if + (process_sequence_remote<Deployment::ComponentPackageDescription, + CompPkgDesc_Handler> + (this->doc_, this->iter_, node, + node_name, "package", sid.package, + &CompPkgDesc_Handler::process_ComponentPackageDescription, + this->id_map_)); + else if + (process_sequence_common<Deployment::Property> + (this->doc_, this->iter_, node, + node_name, "configProperty", sid.configProperty, + &Property_Handler::process_Property, + this->id_map_)); + else if + (process_sequence_common<Deployment::Requirement> + (this->doc_, this->iter_, node, + node_name, "selectRequirement", sid.selectRequirement, + &Requirement_Handler::process_Requirement, + this->id_map_)); + else if + (process_sequence_remote<Deployment::ComponentPackageReference, + CPR_Handler> + (this->doc_, this->iter_, node, + node_name, "reference", sid.reference, + &CPR_Handler::process_ComponentPackageReference, this->id_map_)); + else + { + iter->previousNode(); + return; + } + } +} + +void CAD_Handler::process_connection (DOMNodeIterator* iter, + Deployment:: + AssemblyConnectionDescription& acd) +{ + for (DOMNode* node = iter->nextNode(); + node != 0; + node = iter->nextNode ()) + { + XStr node_name (node->getNodeName()); + + if (node_name == XStr + (ACE_TEXT ("Deployment:AssemblyConnectionDescription"))) + { + } + else if + (CIAO::Config_Handler::Utils::process_string + (iter, node_name, "name", acd.name)); + else if + (process_sequence_common<Deployment::Requirement> + (node->getOwnerDocument(), iter, node, + node_name, "deployRequirement", acd.deployRequirement, + &Requirement_Handler::process_Requirement, + this->id_map_)); + else if + (process_sequence_common<Deployment::ComponentExternalPortEndpoint> + (node->getOwnerDocument(), iter, node, + node_name, "externalEndpoint", acd.externalEndpoint, + &CEPE_Handler::process_ComponentExternalPortEndpoint, + this->id_map_)); + else if + (process_sequence_local<Deployment::SubcomponentPortEndpoint> + (node->getOwnerDocument(), iter, node, + node_name, "internalEndpoint", acd.internalEndpoint, + this, &CAD_Handler::process_spe)); + else if + (process_sequence_common<Deployment::ExternalReferenceEndpoint> + (node->getOwnerDocument(), iter, node, + node_name, "externalReference", acd.externalReference, + &ERE_Handler::process_ExternalReferenceEndpoint, + this->id_map_)); + else + { + iter->previousNode(); + return; + } + } +} + +void CAD_Handler::process_spe (DOMNodeIterator* iter, + Deployment::SubcomponentPortEndpoint& spe) +{ + for (DOMNode* node = iter->nextNode(); + node != 0; + node = iter->nextNode ()) + { + XStr node_name (node->getNodeName()); + + if (node_name == XStr + (ACE_TEXT ("Deployment:SubcomponentPortEndpoint"))) + { + } + else if + (CIAO::Config_Handler::Utils::process_string + (iter, node_name, "portName", spe.portName)); + else if + (process_reference(node, node_name, "instance", + spe.instanceRef, + this->index_, this->idref_map_)) + { + this->index_ = this->index_ + 1; + } + else + { + iter->previousNode(); + return; + } + } +} + +void CAD_Handler::process_spr (DOMNodeIterator* iter, + Deployment::SubcomponentPropertyReference& spr) +{ + for (DOMNode* node = iter->nextNode(); + node != 0; + node = iter->nextNode ()) + { + XStr node_name (node->getNodeName()); + + if (node_name == XStr + (ACE_TEXT ("Deployment:SubcomponentPropertyReference"))) + { + } + else if + (CIAO::Config_Handler::Utils::process_string + (iter, node_name, "propertyName", spr.propertyName)); + else if + (process_reference(node, node_name, "instance", + spr.instanceRef, + this->index_, this->idref_map_)) + { + this->index_ = this->index_ + 1; + } + else + { + iter->previousNode(); + return; + } + } +} + +void CAD_Handler::process_property(DOMNodeIterator* iter, + Deployment::AssemblyPropertyMapping& apm) +{ + for (DOMNode* node = iter->nextNode(); + node != 0; + node = iter->nextNode ()) + { + XStr node_name (node->getNodeName()); + + if (node_name == XStr + (ACE_TEXT ("Deployment:AssemblyPropertyMapping"))) + { + } + else if + (CIAO::Config_Handler::Utils::process_string + (iter, node_name, "name", apm.name)); + else if + (CIAO::Config_Handler::Utils::process_string + (iter, node_name, "externalName", apm.externalName)); + else if + (process_sequence_local<Deployment::SubcomponentPropertyReference> + (node->getOwnerDocument(), iter, node, + node_name, "delegatesTo", apm.delegatesTo, + this, &CAD_Handler::process_spr)); + else + { + iter->previousNode(); + return; + } + } +} + +END_DEPLOYMENT_NAMESPACE |