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
|
/* -*- C++ -*- */
// $Id$
//
// ============================================================================
//
// = LIBRARY
// ORBSVCS Real-time Event Channel
//
// = FILENAME
// EC_ProxyConsumer
//
// = AUTHOR
// Carlos O'Ryan (coryan@cs.wustl.edu)
//
// = CREDITS
// Based on previous work by Tim Harrison (harrison@cs.wustl.edu)
// and other members of the DOC group.
// More details can be found in:
// http://www.cs.wustl.edu/~schmidt/oopsla.ps.gz
// http://www.cs.wustl.edu/~schmidt/JSAC-98.ps.gz
//
//
// ============================================================================
#ifndef TAO_EC_PROXYCONSUMER_H
#define TAO_EC_PROXYCONSUMER_H
#include "orbsvcs/RtecEventChannelAdminS.h"
#include "orbsvcs/Event/EC_Filter.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
class TAO_EC_Event_Channel;
class TAO_EC_ProxyPushSupplier;
class TAO_EC_SupplierFiltering;
class TAO_ORBSVCS_Export TAO_EC_ProxyPushConsumer : public POA_RtecEventChannelAdmin::ProxyPushConsumer
{
// = TITLE
// ProxyPushConsumer
//
// = DESCRIPTION
// Implement the RtecEventChannelAdmin::ProxyPushConsumer interface,
// remember that this class is used to communicate with a
// PushSupplier, so, in effect, this is the ambassador for a
// supplier inside the event channel.
//
// = MEMORY MANAGMENT
// It makes a copy of the SupplierQOS and the supplier object
// reference.
// It uses bind/unbind to control the lifetime of the
// SupplierFiltering object.
// The object commits suicide when disconnect_push_consumer() is
// called.
//
// = LOCKING
// No provisions for locking, access must be serialized
// externally.
//
public:
TAO_EC_ProxyPushConsumer (TAO_EC_Event_Channel* event_channel);
// constructor...
virtual ~TAO_EC_ProxyPushConsumer (void);
// destructor...
CORBA::Boolean is_connected (void) const;
// Return 0 if no supplier is connected...
RtecEventComm::PushSupplier_ptr supplier (void) const;
// Return the consumer object reference. It returns nil() if it has
// not connected yet.
const RtecEventChannelAdmin::SupplierQOS& publications (void) const;
// The QoS (subscription) used to connect to the EC.
virtual void connected (TAO_EC_ProxyPushSupplier* supplier,
CORBA::Environment &env);
virtual void disconnected (TAO_EC_ProxyPushSupplier* supplier,
CORBA::Environment &env);
// Concrete implementations can use this methods to keep track of
// the consumers interested in this events.
virtual void connected (TAO_EC_ProxyPushConsumer* consumer,
CORBA::Environment &env);
virtual void disconnected (TAO_EC_ProxyPushConsumer* consumer,
CORBA::Environment &env);
// Usually implemented as no-ops, but some configurations may
// require this methods.
virtual void shutdown (CORBA::Environment&);
// The event channel is shutting down
const RtecEventChannelAdmin::SupplierQOS& publications_i (void) const;
// The QoS (subscription) used to connect to the EC, assumes the
// locks are held, use with care!
CORBA::ULong _incr_refcnt (void);
CORBA::ULong _decr_refcnt (void);
// Increment and decrement the reference count.
// = The RtecEventChannelAdmin::ProxyPushConsumer methods...
virtual void connect_push_supplier (
RtecEventComm::PushSupplier_ptr push_supplier,
const RtecEventChannelAdmin::SupplierQOS& qos,
CORBA::Environment &)
ACE_THROW_SPEC ((CORBA::SystemException,
RtecEventChannelAdmin::AlreadyConnected));
virtual void push (const RtecEventComm::EventSet& event,
CORBA::Environment &)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void disconnect_push_consumer (CORBA::Environment &)
ACE_THROW_SPEC ((CORBA::SystemException));
// = The Servant methods
virtual PortableServer::POA_ptr _default_POA (CORBA::Environment& env);
virtual void _add_ref (CORBA_Environment &ACE_TRY_ENV =
TAO_default_environment ());
virtual void _remove_ref (CORBA_Environment &ACE_TRY_ENV =
TAO_default_environment ());
private:
CORBA::Boolean is_connected_i (void) const;
// The private version (without locking) of is_connected().
void cleanup_i (void);
// Release the filter and the supplier
void deactivate (CORBA::Environment &ACE_TRY_ENV);
// Deactivate from the POA
private:
TAO_EC_Event_Channel* event_channel_;
// The supplier admin, used for activation and memory managment.
ACE_Lock* lock_;
// The locking strategy.
CORBA::ULong refcount_;
// The reference count.
RtecEventComm::PushSupplier_var supplier_;
// The supplier....
RtecEventChannelAdmin::SupplierQOS qos_;
// The publication and QoS information...
PortableServer::POA_var default_POA_;
// Store the default POA.
TAO_EC_SupplierFiltering* filter_;
// The strategy to do filtering close to the supplier
};
#if defined (__ACE_INLINE__)
#include "EC_ProxyConsumer.i"
#endif /* __ACE_INLINE__ */
#endif /* TAO_EC_PROXYCONSUMER_H */
|
