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
|
// -*- C++ -*-
//=============================================================================
/**
* @file Session_Container.h
*
* $Id$
*
* Header file for CIAO's container implementations
*
* @author Nanbor Wang <nanbor@cs.wustl.edu>
* @author Gan Deng <dengg@dre.vanderbilt.edu>
*/
//=============================================================================
#ifndef CIAO_SESSION_CONTAINER_H
#define CIAO_SESSION_CONTAINER_H
#include /**/ "ace/pre.h"
#include "ciao/Containers/Session/Session_Container_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/PortableServer/Servant_Base.h"
#include "ciao/Containers/Container_Base.h"
#include "ccm/CCM_HomeExecutorBaseC.h"
#include "ccm/CCM_EnterpriseComponentC.h"
namespace CIAO
{
class Session_Container;
class Servant_Activator;
namespace Deployment
{
class CIAO_Container_i;
}
typedef ::Components::HomeExecutorBase_ptr (*HomeFactory) (void);
typedef ::PortableServer::Servant (*HomeServantFactory) (::Components::HomeExecutorBase_ptr p,
::CIAO::Container_ptr c,
const char *ins_name);
typedef ::Components::EnterpriseComponent_ptr (*ComponentFactory) (void);
typedef ::PortableServer::Servant (*ComponentServantFactory) (::Components::EnterpriseComponent_ptr,
::CIAO::Container_ptr,
const char *);
typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
HomeFactory,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
ACE_Null_Mutex>
HOMECREATOR_FUNCPTR_MAP;
typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
HomeServantFactory,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
ACE_Null_Mutex>
HOMESERVANTCREATOR_FUNCPTR_MAP;
typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
ComponentFactory,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
ACE_Null_Mutex>
COMPONENTCREATOR_FUNCPTR_MAP;
typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
ComponentServantFactory,
ACE_Hash<ACE_CString>,
ACE_Equal_To<ACE_CString>,
ACE_Null_Mutex>
COMPONENTSERVANTCREATOR_FUNCPTR_MAP;
struct SESSION_CONTAINER_Export Static_Config_EntryPoints_Maps
{
/// Map of home creator entry point name and func ptr
HOMECREATOR_FUNCPTR_MAP* home_creator_funcptr_map_;
/// Map of home servant creator entry point name and func ptr
HOMESERVANTCREATOR_FUNCPTR_MAP* home_servant_creator_funcptr_map_;
/// Map of home creator entry point name and func ptr
COMPONENTCREATOR_FUNCPTR_MAP* component_creator_funcptr_map_;
/// Map of home servant creator entry point name and func ptr
COMPONENTSERVANTCREATOR_FUNCPTR_MAP* component_servant_creator_funcptr_map_;
};
class SESSION_CONTAINER_Export Session_Container : public Container_i
{
public:
Session_Container (CORBA::ORB_ptr o,
PortableServer::POA_ptr poa,
Deployment::CIAO_Container_i *container_impl,
bool static_config_flag = false,
const Static_Config_EntryPoints_Maps* static_entrypts_maps =0,
const char *name = 0,
const CORBA::PolicyList *more_policies = 0);
virtual ~Session_Container (void);
/**
* @brief Simply installing a home executor into the component.
*
* This operation install a home executor into the component. It
* requires the name of the DLLs to executor and the servant glue
* code, and the entry points to the respective DLLs. Currently,
* we don't try to manage the lifetime of DLL objects, but we
* should at some later point.
*
* @retval Home objref of the installed home.
*/
/// Install a new home
virtual Components::CCMHome_ptr install_home (const char *primary_artifact,
const char *entry_point,
const char *servant_artifact,
const char *servant_entrypoint,
const char *name);
virtual void uninstall_home (Components::CCMHome_ptr homeref);
/// Install a new component
virtual Components::CCMObject_ptr install_component (const char *primary_artifact,
const char *entry_point,
const char *servant_artifact,
const char *servant_entrypoint,
const char *name);
/// Connect a local facet
virtual void connect_local_facet (::Components::CCMObject_ptr provider,
const char * provider_port,
::Components::CCMObject_ptr user,
const char * user_port);
/// Disconnect a local facet
virtual void disconnect_local_facet (::Components::CCMObject_ptr provider,
const char * provider_port,
::Components::CCMObject_ptr user,
const char * user_port);
/// Activate component
virtual void activate_component (Components::CCMObject_ptr compref);
/// Passivate a component
virtual void passivate_component (Components::CCMObject_ptr compref);
/// Uninstall a component
virtual void uninstall_component (Components::CCMObject_ptr compref);
/// Uninstall a servant
virtual void uninstall_servant (PortableServer::Servant objref,
Container_Types::OA_Type type,
PortableServer::ObjectId_out oid);
/// Install a servant for component or home.
virtual CORBA::Object_ptr install_servant (PortableServer::Servant p,
Container_Types::OA_Type type,
PortableServer::ObjectId_out oid);
/// Get an object reference to a component or home from the servant.
virtual CORBA::Object_ptr get_objref (PortableServer::Servant p);
/// Uninstall a servant for component or home.
void uninstall (CORBA::Object_ptr objref, Container_Types::OA_Type t);
/// Uninstall a servant for component or home.
void uninstall (PortableServer::Servant svt, Container_Types::OA_Type t);
/// Analog of the POA method that creates an object reference from
/// an object id string.
CORBA::Object_ptr generate_reference (const char *obj_id,
const char *repo_id,
Container_Types::OA_Type t);
/// Return the servant activator factory that activates the
/// servants for facets and consumers.
::CIAO::Servant_Activator_ptr ports_servant_activator (void);
private:
/// Initialize the container with a name.
virtual void init (const char *name = 0,
const CORBA::PolicyList *more_policies = 0);
/// Create POA for the component.
/**
* This is the POA that is returned to the component applications
* if they need one.
*/
void create_component_POA (const char *name,
const CORBA::PolicyList *p,
PortableServer::POA_ptr root);
/// Create POA for the facets and consumers alone.
void create_facet_consumer_POA (const char *name,
const CORBA::PolicyList *p,
PortableServer::POA_ptr root);
/// Not allowed to be
Session_Container (void);
protected:
/// Static variable to store the highest number we have given out until
/// now
static ACE_Atomic_Op <TAO_SYNCH_MUTEX, unsigned long> serial_number_;
bool const static_config_flag_;
const Static_Config_EntryPoints_Maps* static_entrypts_maps_;
/// The servant activator factory used to activate facets and
/// consumer servants.
Servant_Activator_var sa_;
};
}
#if defined (__ACE_INLINE__)
# include "Session_Container.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* CIAO_SESSION_CONTAINER_H */
|
