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
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
|
//$Id$
/**========================================================
*
* @file NodeApplication_Impl.h
*
* @Brief This file contains the implementation of
* the NodeApplication interface.
*
* @auther Tao Lu <lu@dre.vanderbilt.edu>
*========================================================*/
#ifndef NODEAPPLICATION_IMPL_H
#define NODEAPPLICATION_IMPL_H
#include /**/ "ace/pre.h"
#include "ace/config-all.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/ORB.h"
#include "ace/Synch.h"
#include "ace/Synch_Traits.h"
#include "Container_Base.h"
#include "Deployment_CoreS.h"
#include "Server_init.h"
#include "CIAO_common.h"
using CIAO::Utility::write_IOR;
/**
*
* @class NodeApplication_Impl
*
* @brief This class implements the NodeApplication interface.
* This interface is semantically very simillar to container
* in the old DnC spec. However this class will also be used
* as a Server for hosting home/component. This way we reduce the
* complexity of the framework by omitting the componentserver layer.
*
* @@TODO add configuration capabilities. Threading is one of them.
*
* @@Assumptions:
* 1. There is only 1 container for all components/homes associating
* with 1 NodeApplication
* 2. Now the implementation is not thread safe.
**/
namespace CIAO
{
class CIAO_SERVER_Export NodeApplication_Impl_Base
: public virtual POA_Deployment::NodeApplication
{
public:
// Default constructor.
NodeApplication_Impl_Base (CORBA::ORB_ptr o,
PortableServer::POA_ptr p);
// Default destructor.
virtual ~NodeApplication_Impl_Base (void);
/**
* @method finishLaunch
*
* @brief This operation dose 2 things.
* 1. Get the external connction (facet and Event source)
* and connect them to the local receptacle/event sink.
* 2. If the start augment is true, start the Components.
* @Note:
* The connection containes the object ref of the provided object
* reference (facet/event consumer) of components from other NodeApplications.
* However the name field stores the name of the port on the local component.
*
*/
virtual void
finishLaunch (const Deployment::Connections & providedReference,
CORBA::Boolean start
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Deployment::StartError,
Deployment::InvalidConnection));
/**
* @method start
*/
virtual void
start (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Deployment::StartError));
/*------------- CIAO specific helper operations (idl)--------
*
*-----------------------------------------------------------*/
// Initialize the NodeApplication
virtual CORBA::Long init (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
// Start install homes and components.
virtual ::Deployment::ComponentInfos *
install (const ::Deployment::ImplementationInfos & impl_infos
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
::Deployment::UnknownImplId,
::Deployment::ImplEntryPointNotFound,
::Deployment::InstallationFailure,
::Components::InvalidConfiguration));
// Access the readonly attribute.
virtual ::Deployment::Properties *
properties (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual ::Components::CCMHome_ptr
install_home (const ::Deployment::ImplementationInfo & impl_info
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Deployment::UnknownImplId,
Deployment::ImplEntryPointNotFound,
Deployment::InstallationFailure,
Components::InvalidConfiguration));
/**
* @@Note: I don't know how to remove a home right now.
* I assume that user will only call remove instead.
* This is true at least for DnC run time.
*
* Right now, in this implementation I assumpe that there will be
* same number of homes as the components even if the components
* are of the same type. I don't think that we have the modeling
* side support of this either. So bear me if you think I avoid
* the real thinking for easiness.
*/
virtual void remove_home (const char * comp_ins_name
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Components::RemoveFailure));
// Remove everything inside including all components and homes.
// User must be sure that no connection is active before calling this!!
virtual void remove (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Components::RemoveFailure));
// Return all homes.
virtual ::Components::CCMHomes *
get_homes (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/*------------- CIAO specific helper functions (C++)---------
*
*-----------------------------------------------------------*/
// Get the containing POA. This operation does *not*
// increase the reference count of the POA.
virtual PortableServer::POA_ptr _default_POA (void);
// Get the object reference of the NodeApplicationManager.
// This might comes in handy later.
virtual ::CORBA::Object_ptr
get_node_application_manager (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
protected:
virtual Container* create_container (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))=0;
// @@ (OO) Methods internal to the class, e.g. protected and not
// defined in IDL should not be using default arguments.
// Please drop the "_WITH_DEFAULTS" in all of the below
// protected methods.
// This is a helper method to clean up components
// should only be called when we are sure that there is no
// active connection on this component.
virtual void remove_components (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Components::RemoveFailure));
virtual void remove_component (const char * comp_ins_name
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Components::RemoveFailure));
// This function is a helper for start call. Bala's
// Idea of adding those pre/post activate calls doesn't work
// with the new sepc.
//@@ TODO. Come up with new ways of synchronized initialization process.
typedef void (Components::CCMObject::*Funct_Ptr)
(ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS);
virtual void start_i (Funct_Ptr functor
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Deployment::StartError));
// To store all created CCMHome object
typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
Components::CCMHome_ptr,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
ACE_Null_Mutex> CCMHome_Map;
typedef CCMHome_Map::iterator Home_Iterator;
CCMHome_Map home_map_;
// To sotre all created Component object.
typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
Components::CCMObject_ptr,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
ACE_Null_Mutex> CCMComponent_Map;
typedef CCMComponent_Map::iterator Component_Iterator;
CCMComponent_Map component_map_;
// Keep a pointer to the managing ORB serving this servant.
CORBA::ORB_var orb_;
// Keep a pointer to the managing POA.
PortableServer::POA_var poa_;
// Internal container implementation.
CIAO::Container *container_;
// Cached properties
Deployment::Properties properties_;
// And a reference to the NodeApplicationManager that created us.
::CORBA::Object_var node_app_manager_;
// Synchronize access to the object set.
// This will be needed in the case when component/home run in different thread
// TAO_SYNCH_MUTEX lock_;
//@@ As I have stated in the idl we are not going to use properties for now.
// parse The Properties
/*void parse_config_values (const ::Deployment::Properties & properties,
struct home_installation_info &component_install_info
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Deployment::UnknownImplId,
Deployment::ImplEntryPointNotFound,
Components::InvalidConfiguration));
*/
};
class CIAO_SERVER_Export NodeApplication_Impl
: public NodeApplication_Impl_Base
{
public:
// Default constructor.
NodeApplication_Impl (CORBA::ORB_ptr o,
PortableServer::POA_ptr p);
Container* create_container (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
// Default destructor.
virtual ~NodeApplication_Impl ();
};
class CIAO_SERVER_Export Static_NodeApplication_Impl
: public NodeApplication_Impl_Base
{
public:
// Default constructor.
Static_NodeApplication_Impl (CORBA::ORB_ptr o,
PortableServer::POA_ptr p,
Static_Config_EntryPoints_Maps* static_config_entrypoints_map);
Container* create_container (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
// Default destructor.
virtual ~Static_NodeApplication_Impl ();
protected:
Static_Config_EntryPoints_Maps* static_config_entrypoints_map_;
};
}
#if defined (__ACE_INLINE__)
# include "NodeApplication_Impl.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* NODEAPPLICATION_IMPL_H */
|
