blob: 4e10be4a79a1d826e17b2f63c046e90f173914e8 (
plain)
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
|
/* -*- C++ -*- */
/**
* @file Object.h
*
* $Id$
*
* @author Pradeep Gore <pradeep@oomworks.com>
*
*
*/
#ifndef TAO_Notify_OBJECT_H
#define TAO_Notify_OBJECT_H
#include /**/ "ace/pre.h"
#include "notify_serv_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "QoSProperties.h"
#include "AdminProperties.h"
#include "Worker_Task.h"
#include "Refcountable.h"
#include "Name_Value_Pair.h"
#include "Event_Manager.h"
#include "orbsvcs/NotifyExtC.h"
#include "tao/PortableServer/Servant_Base.h"
class TAO_Notify_POA_Helper;
class TAO_Notify_Timer;
class TAO_Notify_RT_Builder;
/**
* @class TAO_Notify_Object
*
* @brief Base Object for RT_Notify's CORBA Objects.
*
*/
class TAO_Notify_Serv_Export TAO_Notify_Object : public TAO_Notify_Refcountable
{
friend class TAO_Notify_Builder;
friend class TAO_Notify_RT_Builder;
public:
/// Id for Objects.
typedef CORBA::Long ID;
/// Destructor
virtual ~TAO_Notify_Object (void);
/// This Object's ID
ID id (void) const;
/// Activate
virtual CORBA::Object_ptr activate (PortableServer::Servant servant ACE_ENV_ARG_DECL);
/// Activate with existing id
virtual CORBA::Object_ptr activate (
PortableServer::Servant servant,
CORBA::Long id
ACE_ENV_ARG_DECL);
/// Deactivate
void deactivate (ACE_ENV_SINGLE_ARG_DECL);
/// Have we been shutdown. returns 1 if shutdown.
int has_shutdown (void);
void execute_task (TAO_Notify_Method_Request& method_request ACE_ENV_ARG_DECL);
/// Get CORBA Ref.
CORBA::Object_ptr ref (ACE_ENV_SINGLE_ARG_DECL);
/// Set the QoS Properties.
virtual void set_qos (const CosNotification::QoSProperties & qos ACE_ENV_ARG_DECL);
/// Get the QoS Properties.
CosNotification::QoSProperties* get_qos (ACE_ENV_SINGLE_ARG_DECL);
bool find_qos_property_value (
const char * name,
CosNotification::PropertyValue & value)const;
/// Obtain the Timer manager associated with this object.
virtual TAO_Notify_Timer* timer (void);
/// Accessor for the Event Manager
TAO_Notify_Event_Manager& event_manager (void);
/// shutdown. Returns 1 ifif the shutdown was already run once before.
virtual int shutdown (ACE_ENV_SINGLE_ARG_DECL);
/// Load our attributes. Each derived type should call the superclass
/// load first before loading its own attributes.
virtual void load_attrs(const TAO_Notify::NVPList& attrs);
protected:
/// Constructor
TAO_Notify_Object (void);
/// Init this object with data from <rhs>.
void initialize (TAO_Notify_Object* parent);
/// Uses the poas from the supplied object
void inherit_poas (TAO_Notify_Object& parent);
/// Adopts the supplied poa as all are poas
void adopt_poa (TAO_Notify_POA_Helper* single);
/// Changes the primary poa to the current proxy poa
void set_primary_as_proxy_poa();
/// Accessor for the proxy_poa_
TAO_Notify_POA_Helper* proxy_poa (void);
/// Accessor for the object_poa_
TAO_Notify_POA_Helper* object_poa (void);
/// Get the POA assigned to us.
TAO_Notify_POA_Helper* poa (void);
// Sets the admin properties
void set_event_manager( TAO_Notify_Event_Manager* event_manager );
// Sets the admin properties
void set_admin_properties( TAO_Notify_AdminProperties* admin_properties );
/// Accessor for the Admin Properties
TAO_Notify_AdminProperties& admin_properties (void);
/// Notification that can be overridden by subclasses to be informed that <qos_properties_> have been modified.
virtual void qos_changed (const TAO_Notify_QoSProperties& qos_properties);
/// Called by derived types to save their attributes. Each
/// derived type should call its superclass version before
/// saving its own attrs.
virtual void save_attrs(TAO_Notify::NVPList& attrs);
///= Protected data members.
/// QoS Properties.
TAO_Notify_QoSProperties qos_properties_;
private:
/// Set Worker Task. This object assume ownership of the set object.
void set_worker_task (TAO_Notify_Worker_Task* worker_task);
/// Setting the proxy_poa_ gives ownership to this class.
void set_proxy_poa (TAO_Notify_POA_Helper* proxy_poa);
/// Setting the object_poa_ gives ownership to this class.
void set_object_poa (TAO_Notify_POA_Helper* object_poa);
/// Setting the object_poa_ gives ownership to this class.
void set_poa (TAO_Notify_POA_Helper* object_poa);
/// Shutdown the current worker task and delete it if we own it.
void shutdown_worker_task (void);
/// Shutdown the current proxy poa.
void destroy_proxy_poa (void);
/// Shutdown the current object poa.
void destroy_object_poa (void);
/// Shutdown the current poa.
void destroy_poa (void);
///= Private data members.
/// The POA in which the object is activated.
TAO_Notify_POA_Helper* poa_;
/// The POA in which the proxys are activated.
TAO_Notify_POA_Helper* proxy_poa_;
bool own_proxy_poa_;
/// The POA in which the object's children are activated.
TAO_Notify_POA_Helper* object_poa_;
bool own_object_poa_;
/// Id assigned to this object
ID id_;
/// The event manager.
//TAO_Notify_Event_Manager inl includes Object.h
TAO_Notify_Refcountable_Guard_T< TAO_Notify_Event_Manager > event_manager_;
/// Admin Properties.
TAO_Notify_AdminProperties::Ptr admin_properties_;
/// Worker Task.
TAO_Notify_Worker_Task::Ptr worker_task_;
bool own_worker_task_;
/// Are we shutdown (i,e. scheduled for destroy).
bool shutdown_;
};
#if defined (__ACE_INLINE__)
#include "Object.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TAO_Notify_OBJECT_H */
|
