summaryrefslogtreecommitdiff
path: root/CIAO/DAnCE/FaultCorrelationManager/FaultCorrelationManager_Impl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'CIAO/DAnCE/FaultCorrelationManager/FaultCorrelationManager_Impl.cpp')
-rw-r--r--CIAO/DAnCE/FaultCorrelationManager/FaultCorrelationManager_Impl.cpp45
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 */)
+ {
+ }
+
};