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
|
//$Id$
/**========================================================
*
* @file NodeApplication_Impl.h
*
* @Brief This file contains the implementation of
* the NodeApplication interface.
*
* @author Tao Lu <lu@dre.vanderbilt.edu>
* @author Gan Deng <dengg@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 "ace/SString.h"
#include "Container_Base.h"
#include "Deployment_CoreS.h"
#include "Server_init.h"
#include "CIAO_common.h"
#include "Object_Set_T.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. Now the implementation is not thread safe.
**/
namespace CIAO
{
class CIAO_SERVER_Export NodeApplication_Impl
: public virtual POA_Deployment::NodeApplication,
public virtual PortableServer::RefCountServantBase
{
public:
/// Default constructor.
NodeApplication_Impl (CORBA::ORB_ptr o,
PortableServer::POA_ptr p);
/// Default destructor.
virtual ~NodeApplication_Impl (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 IDL 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::NodeImplementationInfo & node_impl_info
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
::Deployment::UnknownImplId,
::Deployment::ImplEntryPointNotFound,
::Deployment::InstallationFailure,
::Components::InvalidConfiguration));
/// Get the object reference of the NodeApplicationManager.
/// This might come in handy later.
virtual ::CORBA::Object_ptr
get_node_application_manager (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
// Access the readonly attribute.
virtual ::Deployment::Properties *
properties (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
// Remove everything inside including all components and homes.
virtual void remove (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Create a container interface, which will be hosted in this NodeApplication.
virtual ::Deployment::Container_ptr
create_container (const ::Deployment::Properties &properties
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
::Components::CreateFailure,
::Components::InvalidConfiguration));
/// Remove a container interface.
virtual void remove_container (::Deployment::Container_ptr cref
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
::Components::RemoveFailure));
/// Get all container object refs
virtual ::Deployment::Containers * get_containers (
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);
/// Return the cached object reference of this NodeApplication object.
/// This operation does *NOT* increase the reference count.
::Deployment::NodeApplication_ptr
get_objref (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS);
protected:
/// Create and initialize all the containers
virtual CORBA::Long create_all_containers (
const ::Deployment::NodeImplementationInfo & node_impl_info
ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/// 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);
virtual void start_i (Funct_Ptr functor
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Deployment::StartError));
/// 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_;
/// Synchronize access to the object set.
TAO_SYNCH_MUTEX lock_;
/// Keep a list of managed Container objects.
Object_Set<Deployment::Container, Deployment::Container_var> container_set_;
/// 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_;
/// Cached properties
Deployment::Properties properties_;
/// And a reference to the NodeApplicationManager that created us.
::CORBA::Object_var node_app_manager_;
/// Cache the object reference (of ourselves).
::Deployment::NodeApplication_var objref_;
};
}
#if defined (__ACE_INLINE__)
# include "NodeApplication_Impl.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* NODEAPPLICATION_IMPL_H */
|
