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_ProxySupplier
//
// = AUTHOR
// Carlos O'Ryan (coryan@cs.wustl.edu)
//
// = DESCRIPTION
// Implement the RtecEventChannelAdmin::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.
//
// = 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_PROXYSUPPLIER_H
#define TAO_EC_PROXYSUPPLIER_H
#include "orbsvcs/Event/EC_Filter.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
class TAO_EC_Dispatching;
class TAO_EC_Filter_Builder;
class TAO_EC_ProxyPushSupplier : public TAO_EC_Filter
{
// = TITLE
// ProxyPushSupplier
//
// = DESCRIPTION
// Implements the ProxyPushSupplier interface, i.e. the object
// used to communicate with a particular consumer.
//
// = MEMORY MANAGMENT
// This object is reference counted.
// It does not assume ownership of the TAO_EC_Dispatching object.
// It makes a copy of the ConsumerQOS and the consumer object
// reference.
//
// = LOCKING
// No provisions for locking, access must be serialized
// externally.
//
// = TODO
// We don't need to provide a trivial filter, the object itself
// could short-circuit the filter() ---> push() cycle when the EC
// is properly configured, we need to explore this...
//
public:
TAO_EC_ProxyPushSupplier (TAO_EC_ConsumerAdmin* consumer_admin,
TAO_EC_Dispatching* dispatching,
TAO_EC_Filter_Builder* builder);
// constructor...
virtual ~TAO_EC_ProxyPushSupplier (void);
// destructor...
CORBA::Boolean is_connected (void) const;
// Return 0 if no consumer is connected...
CORBA::Boolean is_suspended (void) const;
// Return 1 if it is suspended.
RtecEventComm::PushConsumer_ptr consumer (void) const;
// Return the consumer object reference. It returns nil() if it has
// not connected yet.
const RtecEventChannelAdmin::ConsumerQOS& subscriptions (void) const;
// The QoS (subscription) used to connect to the EC.
// = The RtecEventChannelAdmin::ProxyPushSupplier methods...
virtual void connect_push_consumer (
RtecEventComm::PushConsumer_ptr push_consumer,
const RtecEventChannelAdmin::ConsumerQOS& qos,
CORBA::Environment &);
virtual void disconnect_push_supplier (CORBA::Environment &);
virtual void suspend_connection (CORBA::Environment &);
virtual void resume_connection (CORBA::Environment &);
// = The TAO_EC_Filter methods, only push() is implemented...
virtual int filter (const RtecEventComm::EventSet& event,
const TAO_EC_QOS_Info& qos_info,
CORBA::Environment& env);
virtual void push (const RtecEventComm::EventSet& event,
const TAO_EC_QOS_Info& qos_info,
CORBA::Environment& env);
virtual void clear (void);
virtual CORBA::ULong max_event_size (void) const;
virtual void event_ids (RtecEventComm::EventHeaderSet& headerset);
private:
TAO_EC_ConsumerAdmin* consumer_admin_;
// The consumer admin, used for activation and memory managment.
TAO_EC_Dispatching *dispatching_;
// We delegate on this object to handle
RtecEventComm::PushConsumer_var consumer_;
// The consumer....
CORBA::Boolean suspended_;
// Is this consumer suspended?
RtecEventChannelAdmin::ConsumerQOS qos_;
// The subscription and QoS information...
};
#if defined (__ACE_INLINE__)
#include "EC_ProxySupplier.i"
#endif /* __ACE_INLINE__ */
#endif /* TAO_EC_PROXYSUPPLIER_H */
|
