*** empty log message ***

1 files changed, 336 insertions, 0 deletions

diff --git a/TAO/CIAO/tools/Assembly_Deployer/Assembly_Visitors.cpp b/TAO/CIAO/tools/Assembly_Deployer/Assembly_Visitors.cpp
new file mode 100644
index 00000000000..f49eb6524c1
--- /dev/null
+++ b/TAO/CIAO/tools/Assembly_Deployer/Assembly_Visitors.cpp
@@ -0,0 +1,336 @@
+// $Id$
+
+#include "Assembly_Visitors.h"
+#include "../XML_Helpers/XML_Utils.h"
+
+#if !defined (__ACE_INLINE__)
+# include "Assembly_Visitors.inl"
+#endif /* __ACE_INLINE__ */
+
+CIAO::Assembly_Builder_Visitor::~Assembly_Builder_Visitor (void)
+{
+}
+
+int
+CIAO::Assembly_Builder_Visitor::visit_Container
+(CIAO::Assembly_Placement::Container *c
+ ACE_ENV_ARG_DECL)
+{
+  ACE_DEBUG ((LM_DEBUG, "partitioning %s\n", c->id ()));
+
+  // This can only happen when we hit a partitioning (root) node.
+  CIAO::Assembly_Placement::Container::ITERATOR iter (*c);
+  CIAO::Assembly_Placement::Node *node = 0;
+
+  while (iter.next (node))
+    {
+      int retv = node->accept (*this
+                               ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (-1);
+
+      if (retv != 0)
+        return -1;
+      iter.advance ();
+    }
+  return 0;
+}
+
+int
+CIAO::Assembly_Builder_Visitor::visit_hostcollocation
+(CIAO::Assembly_Placement::hostcollocation *hc
+ ACE_ENV_ARG_DECL)
+{
+  ACE_DEBUG ((LM_DEBUG, "hostcollocation %s\n", hc->id ()));
+
+
+
+  CIAO::Assembly_Placement::Container::ITERATOR iter (*hc);
+  CIAO::Assembly_Placement::Node *node = 0;
+
+  while (iter.next (node))
+    {
+      int retv = node->accept (*this
+                               ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (-1);
+
+      if (retv != 0)
+        return -1;
+      iter.advance ();
+    }
+  return 0;
+}
+
+int
+CIAO::Assembly_Builder_Visitor::visit_processcollocation
+(CIAO::Assembly_Placement::processcollocation *pc
+ ACE_ENV_ARG_DECL)
+{
+  ACE_DEBUG ((LM_DEBUG, "processcollocation %s\n", pc->id ()));
+
+  if (pc->destination () != 0)
+    {
+      Components::Deployment::ServerActivator_var activator =
+        this->deployment_config_.get_activator (pc->destination ());
+
+      if (CORBA::is_nil (activator.in ()))
+        ACE_ERROR_RETURN ((LM_ERROR, "Fail to acquire ServerActivator (%s)\n",
+                           pc->destination ()),
+                          -1);
+
+      Components::ConfigValues server_config;
+      // @@ Nothing to config yet.
+
+      this->compserv_ =
+        activator->create_component_server (server_config
+                                            ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (-1);
+
+      this->context_.component_servers_.enqueue_tail (this->compserv_);
+
+      Components::ConfigValues container_config;
+      // @@ Should we get the config value from Softpkg_Info?
+      this->container_ =
+        this->compserv_->create_container (container_config
+                                           ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (-1);
+    }
+
+  CIAO::Assembly_Placement::Container::ITERATOR iter (*pc);
+  CIAO::Assembly_Placement::Node *node = 0;
+
+  while (iter.next (node))
+    {
+      int retv = node->accept (*this
+                               ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (-1);
+
+      if (retv != 0)
+        return -1;
+      iter.advance ();
+    }
+  return 0;
+}
+
+int
+CIAO::Assembly_Builder_Visitor::visit_homeplacement
+(CIAO::Assembly_Placement::homeplacement *hp
+ ACE_ENV_ARG_DECL)
+{
+  ACE_DEBUG ((LM_DEBUG, "homeplacement %s\n", hp->id ()));
+
+  // @@ Create and register home before creating components.
+  ACE_CString csd_file;
+
+  if (this->impl_idref_map_.find (hp->componentfileref (),
+                                  csd_file) != 0)
+    ACE_ERROR_RETURN ((LM_DEBUG,
+                       "Unable to find implementation reference: %s",
+                       hp->componentfileref ()),
+                      -1);
+
+  CIAO::Softpkg_Handler::Softpkg_Info info;
+  info.csd_path_ = csd_file.c_str ();
+
+  if (CIAO::XML_Utils::parse_softpkg (&info) == 0)
+    {
+      //      info.dump ();             // For debug purpose.
+
+      // install home
+      Components::ConfigValues home_config;
+      // Setting home config value here:
+      home_config.length (2);
+
+      Components::ConfigValue_ptr item = new OBV_Components::ConfigValue ();
+      item->name (CORBA::string_dup ("CIAO-servant-UUID"));
+      item->value () <<= CORBA::string_dup (info.servant_UUID_.c_str ());
+      home_config[0] = item;
+
+      item = new OBV_Components::ConfigValue ();
+      item->name (CORBA::string_dup ("CIAO-servant-entrypt"));
+      item->value () <<= CORBA::string_dup (info.servant_entrypt_.c_str ());
+      home_config[1] = item;
+
+      Components::Deployment::Container_var container
+        = this->get_current_container (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_CHECK_RETURN (-1);
+
+      if (CORBA::is_nil (container.in ()))
+        ACE_ERROR_RETURN ((LM_DEBUG,
+                           "Unable to acquire a reference to ServerActivator\n"),
+                          -1);
+
+      Components::CCMHome_var home =
+        container->install_home (info.executor_UUID_.c_str (),
+                                 info.executor_entrypt_.c_str (),
+                                 home_config
+                                 ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (-1);
+
+      Components::KeylessCCMHome_var klhome =
+        Components::KeylessCCMHome::_narrow (home.in ()
+                                             ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (-1);
+
+      if (CORBA::is_nil (klhome.in ()))
+        return -1;
+
+      // register home with context
+      if (this->context_.installed_homes_.bind (hp->id (),
+                                                home) != 0)
+        ACE_ERROR_RETURN ((LM_DEBUG,
+                           "Failed to register home\n"),
+                          -1);
+      // Save the home for component instantiation.
+      this->home_ = klhome;
+
+      // @@ Register home according to register spec.
+      // @@ Not implemented yet.
+    }
+
+  CIAO::Assembly_Placement::Container::ITERATOR iter (*hp);
+  CIAO::Assembly_Placement::Node *node = 0;
+
+  while (iter.next (node))
+    {
+      int retv = node->accept (*this
+                               ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (-1);
+
+      if (retv != 0)
+        return -1;
+      iter.advance ();
+    }
+
+  // Reset current home
+  this->home_ = 0;
+  return 0;
+}
+
+int
+CIAO::Assembly_Builder_Visitor::visit_componentinstantiation
+(CIAO::Assembly_Placement::componentinstantiation *ci
+ ACE_ENV_ARG_DECL)
+{
+  // @@ instantiation and register component.
+  ACE_DEBUG ((LM_DEBUG, "ComponentInstantiation %s\n", ci->id ()));
+
+  Components::CCMObject_var comp
+    = this->home_->create_component (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK_RETURN (-1);
+
+  this->context_.instantiated_components_.bind (ci->id (),
+                                                comp);
+
+  // Registering component.
+  CIAO::Assembly_Placement::componentinstantiation::REGISTRATION_QUEUE::ITERATOR
+    iter (ci->register_info_);
+
+  while (!iter.done ())
+    {
+      CIAO::Assembly_Placement::componentinstantiation::Register_Info *info;
+      iter.next (info);
+
+      this->register_component (info,
+                                comp.in ()
+                                ACE_ENV_ARG_PARAMETER);
+
+      iter.advance ();
+    }
+  return 0;
+}
+
+Components::Deployment::Container_ptr
+CIAO::Assembly_Builder_Visitor::get_current_container (ACE_ENV_SINGLE_ARG_DECL)
+{
+  if (CORBA::is_nil (this->compserv_.in ()))
+    {
+      Components::Deployment::ServerActivator_var activator =
+        this->deployment_config_.get_default_activator ();
+
+      if (CORBA::is_nil (activator.in ()))
+        ACE_ERROR_RETURN ((LM_ERROR, "Fail to acquire default ServerActivator\n"),
+                          0);
+
+      Components::ConfigValues server_config;
+      // @@ Nothing to config yet.
+
+      this->compserv_ =
+        activator->create_component_server (server_config
+                                            ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (0);
+
+      this->context_.component_servers_.enqueue_tail (this->compserv_);
+
+      Components::ConfigValues container_config;
+      // @@ Should we get the config value from Softpkg_Info?
+      this->container_ =
+        this->compserv_->create_container (container_config
+                                           ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK_RETURN (0);
+    }
+
+  return Components::Deployment::Container::_duplicate
+    (this->container_.in ());
+}
+
+void
+CIAO::Assembly_Builder_Visitor::register_component
+(Assembly_Placement::componentinstantiation::Register_Info *i,
+ Components::CCMObject_ptr c
+ ACE_ENV_ARG_DECL)
+{
+  CORBA::Object_ptr reg_obj;
+
+  // Extract the right interface to register:
+  switch (i->type_)
+    {
+    case CIAO::Assembly_Placement::componentinstantiation::COMPONENT:
+      reg_obj = c;
+      break;
+
+    case CIAO::Assembly_Placement::componentinstantiation::PROVIDESID:
+      reg_obj = c->provide_facet (i->port_id_.c_str ()
+                                  ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+      break;
+
+    case CIAO::Assembly_Placement::componentinstantiation::CONSUMESID:
+      reg_obj = c->get_consumer (i->port_id_.c_str ()
+                                 ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+      break;
+
+    default:
+      ACE_THROW (CORBA::INTERNAL ());
+    }
+
+  // Now actually register the interface
+  switch (i->method_)
+    {
+    case CIAO::Assembly_Placement::componentinstantiation::NAMINGSERVICE:
+      ACE_THROW (CORBA::NO_IMPLEMENT ());
+
+    case CIAO::Assembly_Placement::componentinstantiation::IORFILE:
+      {
+        CORBA::String_var ior
+          = this->orb_->object_to_string (reg_obj
+                                          ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK;
+
+        FILE* ior_output_file_ =
+          ACE_OS::fopen (i->name_.c_str (), "w");
+
+        if (ior_output_file_)
+          {
+            ACE_OS::fprintf (ior_output_file_,
+                             "%s",
+                             ior.in ());
+            ACE_OS::fclose (ior_output_file_);
+          }
+      }
+    break;
+
+    default:
+      ACE_THROW (CORBA::INTERNAL ());
+    }
+}