blob: cf1f1044fac1e219ab74944d3efdc595a3cd2e4a (
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
|
/* -*- 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 "tao/PortableServer/Servant_Base.h"
#include "orbsvcs/NotifyExtC.h"
#include "QoSProperties.h"
#include "AdminProperties.h"
#include "Refcountable.h"
class TAO_Notify_POA_Helper;
class TAO_Notify_Worker_Task;
class TAO_Notify_Event_Manager;
class TAO_Notify_Timer;
/**
* @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;
public:
/// Id for Objects.
typedef CORBA::Long ID;
/// Constuctor
TAO_Notify_Object (void);
/// Destructor
virtual ~TAO_Notify_Object (void);
/// This Object's ID
ID id (void);
/// Activate
virtual CORBA::Object_ptr activate (PortableServer::Servant servant ACE_ENV_ARG_DECL);
/// Deactivate
void deactivate (ACE_ENV_SINGLE_ARG_DECL);
/// Have we been shutdown. returns 1 if shutdown.
int has_shutdown (void);
/// Get CORBA Ref.
CORBA::Object_ptr ref (ACE_ENV_SINGLE_ARG_DECL);
/// Get Worker Task.
TAO_Notify_Worker_Task* worker_task (void);
/// Get the POA assigned to us.
TAO_Notify_POA_Helper* poa (void);
/// Setting the proxy_poa_ gives ownership to this class.
void proxy_poa_own (TAO_Notify_POA_Helper* proxy_poa);
/// Accessor for the proxy_poa_
TAO_Notify_POA_Helper* proxy_poa (void);
/// Setting the object_poa_ gives ownership to this class.
void object_poa_own (TAO_Notify_POA_Helper* object_poa);
/// Accessor for the object_poa_
TAO_Notify_POA_Helper* object_poa (void);
/// Set Worker Task. This object assume ownership of the set object.
void worker_task_own (TAO_Notify_Worker_Task* worker_task);
/// Set Worker Task. Does not assume ownership.
void worker_task (TAO_Notify_Worker_Task* worker_task);
/// 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);
/// Obtain the Timer manager associated with this object.
virtual TAO_Notify_Timer* timer (void);
/// shutdown. Returns 1 ifif the shutdown was already run once before.
virtual int shutdown (ACE_ENV_SINGLE_ARG_DECL);
/// Accessor for the Event Manager
TAO_Notify_Event_Manager* event_manager (void);
protected:
/// Init this object with data from <rhs>.
void init (TAO_Notify_Object* parent);
/// Shutdown the current worker task and delete it if we own it.
void shutdown_worker_task (void);
/// Shutdown the current proxy poa.
void shutdown_proxy_poa (void);
/// Shutdown the current object poa.
void shutdown_object_poa (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);
///= Protected data members.
/// The event manager.
TAO_Notify_Event_Manager* event_manager_;
/// Admin Properties.
TAO_Notify_AdminProperties_var admin_properties_;
/// QoS Properties.
TAO_Notify_QoSProperties qos_properties_;
/// Id assigned to this object
ID id_;
/// 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_;
/// Flag that indicates if we own <proxy_poa_>
int own_proxy_poa_;
/// The POA in which the object's children are activated.
TAO_Notify_POA_Helper* object_poa_;
/// Flag that indicates if we own <object_poa_>
int own_object_poa_;
/// Worker Task.
TAO_Notify_Worker_Task* worker_task_;
/// Ownership flag
int own_worker_task_;
/// Are we shutdown (i,e. scheduled for destroy).
int shutdown_;
};
#if defined (__ACE_INLINE__)
#include "Object.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TAO_Notify_OBJECT_H */
|
