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
|
/**
* $Id$
* @file Plan_Launcher_Impl.h
* @author Will Otte <wotte@dre.vanderbilt.edu>
*
* Contains the Plan_Launcher_i class, which can be used by
* applications to launch component assemblies.
*/
#ifndef PLAN_LAUNCHER_IMPL_H
#define PLAN_LAUNCHER_IMPL_H
#include "Plan_Launcher_Impl_Export.h"
#include "ciao/CIAO_common.h"
#include "DAnCE/ExecutionManager/DAM_Map.h"
#include "DAnCE/Interfaces/ExecutionManagerDaemonC.h"
#include "DAnCE/Plan_Generator/Plan_Generator_Impl.h"
namespace CIAO
{
namespace Plan_Launcher
{
/**
* @class Plan_Launcher_i
* @brief This class launches and manages deployment plans.
*/
class Plan_Launcher_Impl_Export Plan_Launcher_i
{
public:
class Deployment_Failure {
public:
Deployment_Failure (const ACE_CString &error)
: error_ (error)
{
}
ACE_CString error_;
};
Plan_Launcher_i ();
virtual ~Plan_Launcher_i ();
bool init (const char *em_ior,
CORBA::ORB_ptr orb,
bool use_repoman = false,
bool rm_use_naming = false,
const char *rm_name = 0,
CORBA::Short priority = 0,
size_t niterations = 0,
size_t nthreads = 1,
size_t total_nodes = 1,
size_t total_components = 1);
/**
* @brief Launch a plan, given a deployment plan URI
* @param deployment_plan_uri A uri that points ot a valid deployment plan
* @returns a string containing the UUID of the plan. Null indicates failure.
*/
const char * launch_plan (const char *deployment_plan_uri,
const char *package_uri = 0,
bool use_package_name = true,
bool use_repoman = false);
const char * re_launch_plan (const char *deployment_plan_uri,
const char *package_uri = 0,
bool use_package_name = true,
bool use_repoman = false);
/**
* @brief Launch a plan, given an IDL deployment plan
* @param plan A valid IDL deployment plan
* @returns a string containing the UUID of the plan. Null indicates failure.
*/
virtual const char * launch_plan (const ::Deployment::DeploymentPlan &plan);
virtual const char * re_launch_plan (const ::Deployment::DeploymentPlan &plan);
/// Returns the DAM associated with a given plan URI
::Deployment::DomainApplicationManager_ptr get_dam (const char *uuid);
/// Tears down a plan given the UUID
bool teardown_plan (const char *uuid);
bool teardown_plan (::Deployment::DomainApplicationManager_ptr dam);
void destroy_dam (::Deployment::DomainApplicationManager_ptr dam);
void destroy_dam_by_plan (const char * plan_uuid);
// Change the priority of this thread
bool set_current_priority (CORBA::Short priority);
protected:
// Check that the object is configured with CLIENT_PROPAGATED
// PriorityModelPolicy.
bool is_client_propagated_model (void);
/// Cached ORB pointer
CORBA::ORB_var orb_;
/// Object reference of the ExecutionManager
::CIAO::ExecutionManagerDaemon_var em_;
/// Local map for DAMs, to save expensive UUID lookups.
Execution_Manager::DAM_Map map_;
CIAO::Plan_Generator::Plan_Generator_i pg_;
/// Desired CORBA prioirty to be propagated to EM
CORBA::Short desired_priority_;
/// Number of iterations to run benchmarking, if specified
size_t niterations_;
/// Total number of threads to spawn inside plan_launcher
size_t nthreads_;
/// Total number of nodes
size_t total_nodes_;
/// Total number of components
size_t total_components_;
};
}
}
#endif /* PLAN_LAUNCHER_IMPL_H */
|
