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
|
/* -*- 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,
TAO_EC_SupplierFiltering* filtering);
// 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.
void set_default_POA (PortableServer::POA_ptr poa);
// Set this servant's default POA
virtual PortableServer::POA_ptr _default_POA (CORBA::Environment& env);
// Override the ServantBase method.
// = The RtecEventChannelAdmin::ProxyPushConsumer methods...
virtual void connect_push_supplier (
RtecEventComm::PushSupplier_ptr push_supplier,
const RtecEventChannelAdmin::SupplierQOS& qos,
CORBA::Environment &);
virtual void push (const RtecEventComm::EventSet& event,
CORBA::Environment &);
virtual void disconnect_push_consumer (CORBA::Environment &);
private:
TAO_EC_Event_Channel* event_channel_;
// The supplier admin, used for activation and memory managment.
TAO_EC_SupplierFiltering* supplier_filtering_;
// The strategy to do filtering close to the supplier
RtecEventComm::PushSupplier_var supplier_;
// The supplier....
RtecEventChannelAdmin::SupplierQOS qos_;
// The publication and QoS information...
PortableServer::POA_var default_POA_;
// Store the default POA.
};
#if defined (__ACE_INLINE__)
#include "EC_ProxyConsumer.i"
#endif /* __ACE_INLINE__ */
#endif /* TAO_EC_PROXYCONSUMER_H */
|
