1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
|
/*=======================================================================
*
* @file Execution_Manager_Impl.h
*
* $Id$
*
* @brief This file contains implementation for
* Deployment::ExecutionManager interface.
*
* @author Arvind S. Krishna <arvindk@dre.vanderbilt.edu>
* @auther Tao Lu <lu@dre.vanderbilt.edu>
*
*======================================================================*/
#ifndef CIAO_EXECUTION_MANAGER_IMPL_H
#define CIAO_EXECUTION_MANAGER_IMPL_H
#include /**/ "ace/pre.h"
#include "Interfaces/ExecutionManagerDaemonS.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "DAM_Map.h"
#include "ace/SString.h"
#include "ciao/Deployment_common.h"
namespace CIAO
{
namespace Execution_Manager
{
/**
*
* @class Execution_Manager_Impl
*
* @brief This class implements the
* ExecutionManger. ExecutionManager starts the execution process
* after the planning stage.
*
*/
class Execution_Manager_Impl
: public virtual POA_CIAO::ExecutionManagerDaemon
{
public:
/// Constructor
Execution_Manager_Impl (CORBA::ORB_ptr orb,
PortableServer::POA_ptr poa,
const char * init_file);
/// Template methods from ExecutionManagerDaemon, please see
/// $CIAO_ROOT/ciao/Deployment.idl for documentation
virtual Deployment::DomainApplicationManager_ptr
preparePlan (const Deployment::DeploymentPlan & plan,
CORBA::Boolean commitResources)
ACE_THROW_SPEC ((CORBA::SystemException,
Deployment::ResourceNotAvailable,
Deployment::PlanError,
Deployment::StartError));
virtual Deployment::DomainApplicationManagers *
getManagers ()
ACE_THROW_SPEC ((CORBA::SystemException));
// Below method is CIAO specific extension
virtual Deployment::DomainApplicationManager_ptr
getManager (const char * plan_uuid)
ACE_THROW_SPEC ((CORBA::SystemException, Deployment::PlanNotExist));
virtual void
destroyManager (Deployment::DomainApplicationManager_ptr manager)
ACE_THROW_SPEC ((CORBA::SystemException,
Deployment::StopError));
// Below method is CIAO specific extension, please see the IDL
// definition for more details.
virtual void
destroyManagerByPlan (const char * plan_uuid)
ACE_THROW_SPEC ((::CORBA::SystemException,
::Deployment::StopError));
virtual void shutdown ()
ACE_THROW_SPEC ((CORBA::SystemException));
// The input parameter is a *new_plan* which has the
// same UUID of the existing running plan.
virtual void
perform_redeployment (
const Deployment::DeploymentPlan & plan)
ACE_THROW_SPEC ((::CORBA::SystemException,
::Deployment::PlanError,
::Deployment::InstallationFailure,
::Deployment::UnknownImplId,
::Deployment::ImplEntryPointNotFound,
::Deployment::InvalidConnection,
::Deployment::InvalidProperty,
::Components::RemoveFailure));
virtual Deployment::DeploymentPlan * getPlan (
const char * plan_uuid)
ACE_THROW_SPEC ((::CORBA::SystemException));
/// ****************** C++ Methods *************************
/// If input <add_connection> is true, then it will add new
/// connections which are across different assemblies. Otherwise
/// it will remove the specified connections of this component.
///
/// @@GD: Later we can add another method which could accept
/// a list of bindings and do the batch job.
virtual void finalize_global_binding (
const Component_Binding_Info & binding,
CORBA::Boolean add_connection)
ACE_THROW_SPEC ((
::CORBA::SystemException,
::Deployment::InvalidConnection));
virtual void passivate_shared_components (
const Component_Binding_Info & binding)
ACE_THROW_SPEC ((CORBA::SystemException,
Deployment::StartError));
virtual void activate_shared_components (
const Component_Binding_Info & binding)
ACE_THROW_SPEC ((CORBA::SystemException,
Deployment::StartError));
/// Add shared component information.
/// This call will be made by DomainApplicationManager.
virtual void
add_shared_component (const Component_Binding_Info & binding);
/// Remove shared component
virtual void
remove_shared_component (const Component_Binding_Info & binding);
/// If the input component <name> was found in the internal
/// cached shared component list, and the plan_uuid also matches,
/// then this member function returns <true>, otherwise it
/// returns <false>.
virtual bool
is_component_running (const char * name, const char * plan_uuid);
protected:
/// Return the NodeApplication hosting the given biding
virtual Deployment::NodeApplication_ptr
find_node_application (const Component_Binding_Info & binding)
ACE_THROW_SPEC ((
::CORBA::SystemException,
::Deployment::InvalidConnection));
protected:
/// Destructor.
virtual ~Execution_Manager_Impl (void);
/// Cached ORB pointer
CORBA::ORB_var orb_;
/// Cached POA pointer
PortableServer::POA_var poa_;
/// Path to the initialization file
ACE_CString const init_file_;
/// A map which caches the DomainApplicationManager object ref.
DAM_Map map_;
/// A set of shared components and their location info.
ACE_Unbounded_Set<Component_Binding_Info> shared_components_;
};
}
}
#include /**/ "ace/post.h"
#endif /* EXECUTIONMANAGER_IMPL_H */
|
