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
|
/* -*- C++ -*- */
// $Id$
//
// ============================================================================
//
// = LIBRARY
// ORBSVCS Cos Event Channel
//
// = FILENAME
// CEC_ProxyPushSupplier
//
// = AUTHOR
// Carlos O'Ryan (coryan@cs.wustl.edu)
//
// ============================================================================
#ifndef TAO_CEC_PROXYPULLSUPPLIER_H
#define TAO_CEC_PROXYPULLSUPPLIER_H
#include "ace/pre.h"
#include "orbsvcs/CosEventChannelAdminS.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Message_Queue.h"
#include "event_export.h"
class TAO_CEC_EventChannel;
class TAO_CEC_ProxyPullConsumer;
class TAO_Event_Export TAO_CEC_ProxyPullSupplier : public POA_CosEventChannelAdmin::ProxyPullSupplier
{
// = TITLE
// ProxyPullSupplier
//
// = DESCRIPTION
// Implement the CosEventChannelAdmin::ProxyPullSupplier interface,
// remember that this class is used to communicate with a
// PullConsumer, 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.
//
public:
typedef CosEventChannelAdmin::ProxyPullSupplier_ptr _ptr_type;
typedef CosEventChannelAdmin::ProxyPullSupplier_var _var_type;
TAO_CEC_ProxyPullSupplier (TAO_CEC_EventChannel* event_channel);
// constructor...
virtual ~TAO_CEC_ProxyPullSupplier (void);
// destructor...
virtual CosEventChannelAdmin::ProxyPullSupplier_ptr activate (CORBA::Environment &ACE_TRY_ENV) ACE_THROW_SPEC (());
// Activate in the POA
virtual void deactivate (CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC (());
// Deactivate from the POA
CORBA::Boolean is_connected (void) const;
// Return 0 if no consumer is connected...
CosEventComm::PullConsumer_ptr consumer (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.
virtual void shutdown (CORBA::Environment &env);
// The event channel is shutting down
CORBA::Boolean consumer_non_existent (CORBA::Boolean_out disconnected,
CORBA::Environment &ACE_TRY_ENV);
// Invoke the _non_existent() pseudo-operation on the consumer. If
// it is disconnected then it returns true and sets the
// <disconnected> flag.
void push (const CORBA::Any &event,
CORBA::Environment &ACE_TRY_ENV);
// Push an event into the queue.
// = The CosEventChannelAdmin::ProxyPullSupplier methods...
virtual void connect_pull_consumer (
CosEventComm::PullConsumer_ptr pull_consumer,
CORBA::Environment &)
ACE_THROW_SPEC ((CORBA::SystemException,
CosEventChannelAdmin::AlreadyConnected));
virtual CORBA::Any * pull (CORBA::Environment &)
ACE_THROW_SPEC ((CORBA::SystemException,CosEventComm::Disconnected));
virtual CORBA::Any * try_pull (CORBA::Boolean_out has_event,
CORBA::Environment &)
ACE_THROW_SPEC ((CORBA::SystemException,CosEventComm::Disconnected));
virtual void disconnect_pull_supplier (CORBA::Environment &)
ACE_THROW_SPEC ((CORBA::SystemException));
CORBA::ULong _incr_refcnt (void);
CORBA::ULong _decr_refcnt (void);
// Increment and decrement the reference count.
// = The Servant methods
virtual PortableServer::POA_ptr _default_POA (CORBA::Environment &env);
virtual void _add_ref (CORBA_Environment &ACE_TRY_ENV);
virtual void _remove_ref (CORBA_Environment &ACE_TRY_ENV);
protected:
void consumer (CosEventComm::PullConsumer_ptr consumer);
void consumer_i (CosEventComm::PullConsumer_ptr consumer);
// Set the consumer, used by some implementations to change the
// policies used when invoking operations on the consumer.
CORBA::Boolean is_connected_i (void) const;
// The private version (without locking) of is_connected().
void cleanup_i (void);
// Release the child and the consumer
private:
TAO_CEC_EventChannel* event_channel_;
// The Event Channel that owns this object.
ACE_Lock* lock_;
// The locking strategy.
CORBA::ULong refcount_;
// The reference count.
CosEventComm::PullConsumer_var consumer_;
// The consumer....
int connected_;
// If the flag is not zero then we are connected, notice that the
// consumer can be nil.
PortableServer::POA_var default_POA_;
// Store the default POA.
ACE_SYNCH_MUTEX queue_lock_;
ACE_SYNCH_CONDITION wait_not_empty_;
ACE_Unbounded_Queue<CORBA::Any> queue_;
// Use a message queue to pass the
};
#if defined (__ACE_INLINE__)
#include "CEC_ProxyPullSupplier.i"
#endif /* __ACE_INLINE__ */
#include "ace/post.h"
#endif /* TAO_CEC_PROXYPULLSUPPLIER_H */
|
