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
|
/*=======================================================================
*
* @file ExecutionManager_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 EXECUTIONMANAGER_IMPL_H
#define EXECUTIONMANAGER_IMPL_H
#include /**/ "ace/pre.h"
#include "ExecutionManagerS.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Synch.h"
#include "ace/Hash_Map_Manager.h"
#include "tao/Utils/Servant_Var.h"
#include "DomainApplicationManager/DomainApplicationManager_Impl.h"
/**
*
* @class ExecutionManager_Impl
*
* @brief This class implements the ExecutionManger. ExecutionManager starts
* the execution process after the planning stage.
*
* Serval assumptions I made now:
*
* 1. There is an ExecutionManager per application. => AssemblyFactory
* 2. This interface will be brought up at or before the actual execution
* of an application starts.
* 3. No XML parsing is be done in this interface, the requrest will be
* forwarded to the DomainApplicationManager.
*
*/
namespace CIAO
{
class ExecutionManager_Impl
: public virtual POA_CIAO::ExecutionManagerDaemon,
public virtual PortableServer::RefCountServantBase
{
public:
/// Constructor.
ExecutionManager_Impl (CORBA::ORB_ptr orb,
PortableServer::POA_ptr poa,
const char * init_file
ACE_ENV_ARG_DECL_WITH_DEFAULTS);
/// Generate an ApplicationManager factory.
virtual Deployment::DomainApplicationManager_ptr
preparePlan
(
const Deployment::DeploymentPlan & plan,
CORBA::Boolean commitResources
ACE_ENV_ARG_DECL_WITH_DEFAULTS
)
ACE_THROW_SPEC ((CORBA::SystemException,
Deployment::ResourceNotAvailable,
Deployment::PlanError,
Deployment::StartError
));
/// Return a set of the currently held DomainApplicationMnager.
virtual Deployment::DomainApplicationManagers *
getManagers (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Destroy a specific manager.
virtual void
destroyManager
(
Deployment::DomainApplicationManager_ptr manager
ACE_ENV_ARG_DECL_WITH_DEFAULTS
)
ACE_THROW_SPEC ((
CORBA::SystemException,
Deployment::StopError
));
virtual void
shutdown (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
protected:
/*typedef
ACE_Hash_Map_Manager_Ex
< ACE_CString,
Deployment::DomainApplicationManager_var,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
TAO_SYNCH_MUTEX
>
Table;
typedef Table::iterator Iterator;
*/
/// Destructor.
~ExecutionManager_Impl ();
/// Cached ORB pointer
CORBA::ORB_var orb_;
/// Cached POA pointer
PortableServer::POA_var poa_;
// Internal Hashtable
// Table table_;
// Path to the initialization file
ACE_CString init_file_;
Deployment::DomainApplicationManager_var dam_;
/// Cached servant of the DomainApplicaitonmanager.
TAO::Utils::Servant_Var<CIAO::DomainApplicationManager_Impl> dam_servant_;
};
}
#include /**/ "ace/post.h"
#endif /* EXECUTIONMANAGER_IMPL_H */
|
