1 files changed, 174 insertions, 0 deletions
diff --git a/TAO/CIAO/DAnCE/NodeManager/NodeDaemon_Impl.cpp b/TAO/CIAO/DAnCE/NodeManager/NodeDaemon_Impl.cpp
new file mode 100644
index 00000000000..1012a9bf4b3
--- /dev/null
+++ b/TAO/CIAO/DAnCE/NodeManager/NodeDaemon_Impl.cpp
@@ -0,0 +1,174 @@
+// $Id$
+
+#include "NodeDaemon_Impl.h"
+#include "../NodeApplicationManager/NodeApplicationManager_Impl.h"
+
+// @@ (OO) Method definitions should never use "_WITH_DEFAULTS"
+//         versions of emulated exception parameters.  Please remove
+//         the "_WITH_DEFAULTS"
+CIAO::NodeDaemon_Impl::NodeDaemon_Impl (const char *name,
+                                        CORBA::ORB_ptr orb,
+                                        PortableServer::POA_ptr poa,
+                                        const char * nodapp_loc,
+                                        int spawn_delay)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+  : orb_ (CORBA::ORB::_duplicate (orb)),
+    poa_ (PortableServer::POA::_duplicate (poa)),
+    name_ (CORBA::string_dup (name)),
+    nodeapp_location_ (CORBA::string_dup (nodapp_loc)),
+    callback_poa_ (PortableServer::POA::_nil ()),
+    spawn_delay_ (spawn_delay),
+    manager_ (Deployment::NodeApplicationManager::_nil ())
+{
+  ACE_TRY
+  {
+    //create the call back poa for NAM.
+    PortableServer::POAManager_var mgr
+      = this->poa_->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    this->callback_poa_ =
+      this->poa_->create_POA ("callback_poa",
+                              mgr.in (),
+                              0
+                              ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+  }
+  ACE_CATCHANY
+  {
+    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
+                         "NodeDaemon_Impl::constructor\t\n");
+    ACE_RE_THROW;
+  }
+  ACE_ENDTRY;
+}
+
+CIAO::NodeDaemon_Impl::~NodeDaemon_Impl ()
+{
+
+}
+
+PortableServer::POA_ptr
+CIAO::NodeDaemon_Impl::_default_POA (void)
+{
+  return PortableServer::POA::_duplicate (this->poa_.in ());
+}
+
+
+char *
+CIAO::NodeDaemon_Impl::name (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  return CORBA::string_dup (this->name_.in ());
+}
+
+void
+CIAO::NodeDaemon_Impl::shutdown (ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  this->orb_->shutdown (0 ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+}
+
+void
+CIAO::NodeDaemon_Impl::joinDomain (const Deployment::Domain & ,
+                                   Deployment::TargetManager_ptr ,
+                                   Deployment::Logger_ptr)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  ACE_THROW (CORBA::NO_IMPLEMENT ());
+}
+
+void
+CIAO::NodeDaemon_Impl::leaveDomain (ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  //Implementation undefined.
+  ACE_THROW (CORBA::NO_IMPLEMENT ());
+}
+
+
+Deployment::NodeApplicationManager_ptr
+CIAO::NodeDaemon_Impl::preparePlan (const Deployment::DeploymentPlan &plan)
+  ACE_THROW_SPEC ((CORBA::SystemException,
+                   Deployment::StartError,
+                   Deployment::PlanError))
+{
+  // Return cached manager
+  ACE_TRY
+  {
+    if (CORBA::is_nil (this->manager_.in ()))
+    {
+      //Implementation undefined.
+      CIAO::NodeApplicationManager_Impl *app_mgr;
+      ACE_NEW_THROW_EX (app_mgr,
+                        CIAO::NodeApplicationManager_Impl (this->orb_.in (),
+                                                       this->poa_.in ()),
+                        CORBA::NO_MEMORY ());
+      ACE_TRY_CHECK;
+
+      PortableServer::ServantBase_var safe (app_mgr);
+
+     //@@ Note: after the init call the servant ref count would become 2. so
+     //   we can leave the safeservant along and be dead. Also note that I added
+      this->manager_ =
+            app_mgr->init (this->nodeapp_location_,
+                     this->spawn_delay_,
+                     plan,
+                     this->callback_poa_.in ()
+                     ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      // Obtain the Object Reference
+      //CORBA::Object_var obj =
+      //  this->poa_->servant_to_reference (app_mgr ACE_ENV_ARG_PARAMETER);
+      //ACE_TRY_CHECK;
+
+      //this->manager_ =
+      //  Deployment::NodeApplicationManager::_narrow (obj.in ());
+      if (CORBA::is_nil (this->manager_.in ()))
+        {
+          ACE_DEBUG ((LM_DEBUG, "NodeDaemon_Impl:preparePlan: NodeApplicationManager ref is nil\n"));
+          ACE_THROW (Deployment::StartError ());
+        }
+    }
+
+    // Duplicate this reference to the caller
+    return
+      Deployment::NodeApplicationManager::_duplicate (this->manager_.in ());
+  }
+  ACE_CATCHANY
+  {
+    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
+                         "NodeDaemon_Impl::preparePlan\t\n");
+    ACE_RE_THROW;
+  }
+  ACE_ENDTRY;
+  ACE_CHECK_RETURN (0);
+}
+
+void
+CIAO::NodeDaemon_Impl::destroyManager (Deployment::NodeApplicationManager_ptr)
+  ACE_THROW_SPEC ((CORBA::SystemException, Deployment::StopError))
+{
+  ACE_TRY
+  {
+    // Deactivate this object
+    PortableServer::ObjectId_var id =
+          this->poa_->reference_to_id (this->manager_.in () ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    this->poa_->deactivate_object (id.in () ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK;
+
+    this->manager_ = Deployment::NodeApplicationManager::_nil ();
+  }
+  ACE_CATCHANY
+  {
+    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
+                         "NodeDaemon_Impl::destroyManager\t\n");
+    ACE_RE_THROW;
+  }
+  ACE_ENDTRY;
+}