diff options
Diffstat (limited to 'CIAO/DAnCE/FaultCorrelationManager/FaultCorrelationManager_Impl.cpp')
-rw-r--r-- | CIAO/DAnCE/FaultCorrelationManager/FaultCorrelationManager_Impl.cpp | 45 |
1 files changed, 43 insertions, 2 deletions
diff --git a/CIAO/DAnCE/FaultCorrelationManager/FaultCorrelationManager_Impl.cpp b/CIAO/DAnCE/FaultCorrelationManager/FaultCorrelationManager_Impl.cpp index 30ee3061e87..0c8af7563af 100644 --- a/CIAO/DAnCE/FaultCorrelationManager/FaultCorrelationManager_Impl.cpp +++ b/CIAO/DAnCE/FaultCorrelationManager/FaultCorrelationManager_Impl.cpp @@ -16,8 +16,10 @@ namespace DAnCE { FaultCorrelationManager_Impl::FaultCorrelationManager_Impl ( CORBA::ORB_ptr orb, + Deployment::ExecutionManager_ptr exec_mgr, const PROPERTY_MAP & options) : orb_ (CORBA::ORB::_duplicate (orb)), + exec_mgr_ (Deployment::ExecutionManager::_duplicate (exec_mgr)), properties_ (options.current_size ()) { } @@ -32,8 +34,47 @@ namespace DAnCE } void - FaultCorrelationManager_Impl::proc_failure (const char *, - const char *) + FaultCorrelationManager_Impl::proc_failure (const char * /* object_id */, + const char * /* node_id */) { } + + ::Deployment::DomainApplicationManager_ptr + FaultCorrelationManager_Impl::preparePlan ( + const ::Deployment::DeploymentPlan & plan, + ::Deployment::ResourceCommitmentManager_ptr resourceCommitment) + { + Deployment::DomainApplicationManager_var dam = + exec_mgr_->preparePlan (plan, resourceCommitment); + + dams_.bind (plan.UUID.in(), dam.in ()); + + this->process_deployment_plan (plan); + + return Deployment::DomainApplicationManager::_duplicate (dam.in ()); + } + + ::Deployment::DomainApplicationManagers * + FaultCorrelationManager_Impl::getManagers (void) + { + return exec_mgr_->getManagers (); + } + + void + FaultCorrelationManager_Impl::destroyManager ( + Deployment::DomainApplicationManager_ptr manager) + { + Deployment::DeploymentPlan_var plan = manager->getPlan (); + + dams_.unbind (plan->UUID.in ()); + + exec_mgr_->destroyManager (manager); + } + + void + FaultCorrelationManager_Impl::process_deployment_plan ( + const Deployment::DeploymentPlan & /* plan */) + { + } + }; |