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
|
// -*- C++ -*-
//=============================================================================
/**
* @file ComponentServer_Impl.h
*
* $Id$
*
* This file contains implementation for the servant of
* Components::Deployment::ComponentServer interface.
*
* @author Nanbor Wang <nanbor@cs.wustl.edu>
*/
//=============================================================================
#ifndef CIAO_COMPONENTSERVER_IMPL_H
#define CIAO_COMPONENTSERVER_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 "CCM_DeploymentS.h"
#include "Object_Set_T.h"
namespace CIAO
{
struct Static_Config_EntryPoints_Maps;
/**
* @class ComponentServer_Impl
*
* @brief Servant implementation for Components::Deployment::ComponentServer
*
* This class implements the Components::Deployment::ComponentServer
* interface as defined by the CCM spcification. As the interface
* implies, this is actually part of the deployment interface and is
* used to manage the lifecycle of containers running on the server.
*/
class CIAO_SERVER_Export ComponentServer_Impl
: public virtual POA_Components::Deployment::ComponentServer,
public virtual PortableServer::RefCountServantBase
{
public:
/// Constructor
ComponentServer_Impl (CORBA::ORB_ptr o,
PortableServer::POA_ptr p,
int static_config_flag = 0,
const Static_Config_EntryPoints_Maps* static_entrypts_maps = 0
);
/// Destructor
virtual ~ComponentServer_Impl (void);
/// Get the containing POA. This operation does *not*
/// increase the reference count of the POA.
virtual PortableServer::POA_ptr _default_POA (void);
/// Initialize the ComponentServer with a name.
int init (::Components::ConfigValues &options
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Components::Deployment::ComponentServer defined attributes/operations.
virtual ::Components::ConfigValues *
configuration (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual ::Components::Deployment::ServerActivator_ptr
get_server_activator (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual ::Components::Deployment::Container_ptr
create_container (const Components::ConfigValues & config
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Components::CreateFailure,
Components::InvalidConfiguration));
virtual void remove_container (Components::Deployment::Container_ptr cref
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Components::RemoveFailure));
virtual ::Components::Deployment::Containers *
get_containers (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void remove (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
Components::RemoveFailure));
// ------------ CIAO Internal operations -------------
/// Set the cached object reference
void set_objref (Components::Deployment::ServerActivator_ptr act,
const Components::ConfigValues &config,
Components::Deployment::ComponentServer_ptr cs = 0
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Return the cached object reference of this ComponentServer object.
/// This operation does *NOT* increase the reference count.
Components::Deployment::ComponentServer_ptr
get_objref (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS);
/// Get the cached ComponentInstallation object reference.
/// This operation does *NOT* increase the reference count.
Components::Deployment::ComponentInstallation_ptr
get_component_installation (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS);
protected:
/// 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 ConfigValues.
Components::ConfigValues_var config_;
/// And a reference to the ServerActivator that created us.
Components::Deployment::ServerActivator_var activator_;
/// Cache the object reference to ourselves.
Components::Deployment::ComponentServer_var objref_;
/// And a reference to the ServerActivator that created us.
Components::Deployment::ComponentInstallation_var installation_;
/// Synchronize access to the object set.
TAO_SYNCH_MUTEX lock_;
/// Keep a list of managed Container objects.
Object_Set<Components::Deployment::Container, ::Components::Deployment::Container_var> container_set_;
/// Flag to indicate static configuration.
int static_config_flag_;
/// Reference to CIAO static config entry points map.
const Static_Config_EntryPoints_Maps* static_entrypts_maps_;
};
}
#if defined (__ACE_INLINE__)
# include "ComponentServer_Impl.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* CIAO_COMPONENTSERVER_IMPL_H */
|
