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
229
230
231
232
233
|
// -*- C++ -*-
//=============================================================================
/**
* @file CEC_ProxyPushSupplier.h
*
* $Id$
*
* @author Carlos O'Ryan (coryan@cs.wustl.edu)
* @author Jon Astle (jon@astle45.fsnet.co.uk)
*/
//=============================================================================
#ifndef TAO_CEC_PROXYPUSHSUPPLIER_H
#define TAO_CEC_PROXYPUSHSUPPLIER_H
#include /**/ "ace/pre.h"
#include "orbsvcs/CosEventChannelAdminS.h"
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
#include "orbsvcs/CosTypedEventChannelAdminS.h"
#endif /* TAO_HAS_TYPED_EVENT_CHANNEL */
#include "orbsvcs/CosEvent/event_serv_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
class TAO_CEC_EventChannel;
class TAO_CEC_ProxyPushConsumer;
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
class TAO_CEC_TypedEvent;
class TAO_CEC_TypedEventChannel;
#endif /* TAO_HAS_TYPED_EVENT_CHANNEL */
/**
* @class TAO_CEC_ProxyPushSupplier
*
* @brief ProxyPushSupplier
*
* Implement the CosEventChannelAdmin::ProxyPushSupplier interface,
* remember that this class is used to communicate with a
* PushConsumer, so, in effect, this is the ambassador for a
* consumer inside the event channel.
* = MEMORY MANAGMENT
* It does not assume ownership of the TAO_CEC_Dispatching object.
* It makes a copy of the ConsumerQOS and the consumer object
* reference.
* = LOCKING
* Locking is strategized, the event channel acts as a factory for
* the locking strategies.
*/
class TAO_Event_Serv_Export TAO_CEC_ProxyPushSupplier : public POA_CosEventChannelAdmin::ProxyPushSupplier
{
public:
typedef CosEventChannelAdmin::ProxyPushSupplier_ptr _ptr_type;
typedef CosEventChannelAdmin::ProxyPushSupplier_var _var_type;
/// constructor...
TAO_CEC_ProxyPushSupplier (TAO_CEC_EventChannel* event_channel,
const ACE_Time_Value &timeout);
/// typed ec constructor
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
TAO_CEC_ProxyPushSupplier (TAO_CEC_TypedEventChannel* typed_event_channel,
const ACE_Time_Value &timeout);
#endif /* TAO_HAS_TYPED_EVENT_CHANNEL */
/// destructor...
virtual ~TAO_CEC_ProxyPushSupplier (void);
/// Activate in the POA
virtual void activate (
CosEventChannelAdmin::ProxyPushSupplier_ptr &
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Deactivate from the POA
virtual void deactivate (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Return 0 if no consumer is connected...
CORBA::Boolean is_connected (void) const;
/**
* Return the consumer object reference. It returns nil() if it has
* not connected yet.
* NOTE: This method does not return a new reference!!! Doing so
* will increase the locking overhead on the critical path.
*/
CosEventComm::PushConsumer_ptr consumer (void) const;
/// The event channel is shutting down
virtual void shutdown (ACE_ENV_SINGLE_ARG_DECL);
/// Internal methods to push an event to each consumer.
virtual void push (const CORBA::Any &event
ACE_ENV_ARG_DECL);
virtual void push_nocopy (CORBA::Any &event
ACE_ENV_ARG_DECL);
/// Internal methods to invoke a typed event to each consumer.
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
virtual void invoke (const TAO_CEC_TypedEvent& typed_event
ACE_ENV_ARG_DECL);
#endif /* TAO_HAS_TYPED_EVENT_CHANNEL */
/// Pushes to the consumer, verifies that it is connected.
void push_to_consumer (const CORBA::Any &event
ACE_ENV_ARG_DECL);
void reactive_push_to_consumer (const CORBA::Any &event
ACE_ENV_ARG_DECL);
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
void invoke_to_consumer (const TAO_CEC_TypedEvent &typed_event
ACE_ENV_ARG_DECL);
void reactive_invoke_to_consumer (const TAO_CEC_TypedEvent &typed_event
ACE_ENV_ARG_DECL);
#endif /* TAO_HAS_TYPED_EVENT_CHANNEL */
/**
* Invoke the _non_existent() pseudo-operation on the consumer. If
* it is disconnected then it returns true and sets the
* <disconnected> flag.
*/
CORBA::Boolean consumer_non_existent (CORBA::Boolean_out disconnected
ACE_ENV_ARG_DECL);
// = The CosEventChannelAdmin::ProxyPushSupplier methods...
virtual void connect_push_consumer (
CosEventComm::PushConsumer_ptr push_consumer
ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException,
CosEventChannelAdmin::AlreadyConnected,
CosEventChannelAdmin::TypeError));
virtual void disconnect_push_supplier (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
/// Increment and decrement the reference count.
CORBA::ULong _incr_refcnt (void);
CORBA::ULong _decr_refcnt (void);
// = The Servant methods
virtual PortableServer::POA_ptr _default_POA (ACE_ENV_SINGLE_ARG_DECL);
virtual void _add_ref (ACE_ENV_SINGLE_ARG_DECL);
virtual void _remove_ref (ACE_ENV_SINGLE_ARG_DECL);
protected:
/// Set the consumer, used by some implementations to change the
/// policies used when invoking operations on the consumer.
void consumer (CosEventComm::PushConsumer_ptr consumer);
void consumer_i (CosEventComm::PushConsumer_ptr consumer);
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
void consumer (CosTypedEventComm::TypedPushConsumer_ptr typed_consumer);
void consumer_i (CosTypedEventComm::TypedPushConsumer_ptr typed_consumer);
#endif /* TAO_HAS_TYPED_EVENT_CHANNEL */
/// The private version (without locking) of is_connected().
CORBA::Boolean is_connected_i (void) const;
/// Release the child and the consumer
void cleanup_i (void);
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
CORBA::Boolean is_typed_ec (void) const;
#endif /* TAO_HAS_TYPED_EVENT_CHANNEL */
/// Assigns the parameter to both consumer_ and nopolicy_consumer_, and
/// applies policies (when appropriate) to consumer_.
CosEventComm::PushConsumer_ptr apply_policy
(CosEventComm::PushConsumer_ptr c);
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
CosTypedEventComm::TypedPushConsumer_ptr apply_policy
(CosTypedEventComm::TypedPushConsumer_ptr c);
#endif
CORBA::Object_ptr apply_policy_obj (CORBA::Object_ptr c);
private:
/// The Event Channel that owns this object.
TAO_CEC_EventChannel* event_channel_;
ACE_Time_Value timeout_;
/// The Typed Event Channel that owns this object.
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
TAO_CEC_TypedEventChannel *typed_event_channel_;
#endif /* TAO_HAS_TYPED_EVENT_CHANNEL */
/// The locking strategy.
ACE_Lock* lock_;
/// The reference count.
CORBA::ULong refcount_;
/// The consumer -- use apply_policy() instead of assigning directly to
/// consumer_. This will keep consumer_ and nopolicy_consumer_ in sync.
CosEventComm::PushConsumer_var consumer_;
/// The consumer without any policies applied
CosEventComm::PushConsumer_var nopolicy_consumer_;
#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
/// The typed consumer -- use apply_policy() instead of assigning directly to
/// typed_consumer_. This will keep typed_consumer_ and
/// nopolicy_typed_consumer_ in sync.
CosTypedEventComm::TypedPushConsumer_var typed_consumer_;
/// The consumer object returned from get_typed_consumer()
CORBA::Object_var typed_consumer_obj_;
/// The typed consumer without any policies applied
CosTypedEventComm::TypedPushConsumer_var nopolicy_typed_consumer_;
#endif /* TAO_HAS_TYPED_EVENT_CHANNEL */
/// Store the default POA.
PortableServer::POA_var default_POA_;
};
TAO_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
#include "orbsvcs/CosEvent/CEC_ProxyPushSupplier.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TAO_CEC_PROXYPUSHSUPPLIER_H */
|
