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
|
/**
* $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 ();
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
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
/**
* @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
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((Deployment_Failure));
const char * re_launch_plan (const char *deployment_plan_uri,
const char *package_uri = 0,
bool use_package_name = true,
bool use_repoman = false
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((Deployment_Failure));
/**
* @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.
*/
const char * launch_plan (const ::Deployment::DeploymentPlan &plan
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((Deployment_Failure));
const char * re_launch_plan (const ::Deployment::DeploymentPlan &plan
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((Deployment_Failure));
/// Returns the DAM associated with a given plan URI
::Deployment::DomainApplicationManager_ptr get_dam (const char *uuid
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
/// Tears down a plan given the UUID
bool teardown_plan (const char *uuid ACE_ENV_ARG_DECL);
bool teardown_plan (::Deployment::DomainApplicationManager_ptr dam
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
void destroy_dam (::Deployment::DomainApplicationManager_ptr dam
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
void destroy_dam_by_plan (const char * plan_uuid
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
// 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);
private:
/// Cached ORB pointer
CORBA::ORB_var orb_;
::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_;
};
}
}
#endif /* PLAN_LAUNCHER_IMPL_H */
|
