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
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO/orbsvcs/orbsvcs
//
// = FILENAME
// CosEvent_Utilities.h
//
// = DESCRIPTION
// A few utility classes to make it easier to write EC applications.
//
// = AUTHOR
// Pradeep Gore <pradeep@cs.wustl.edu>
//
// ============================================================================
#ifndef TAO_COSEVENT_UTILITIES_H
#define TAO_COSEVENT_UTILITIES_H
#include /**/ "ace/pre.h"
#include "orbsvcs/RtecBaseC.h"
#include "orbsvcs/RtecEventChannelAdminS.h"
#include "orbsvcs/CosEventChannelAdminS.h"
#include "orbsvcs/Event_Utilities.h"
#include "rtec_cosec_export.h"
class TAO_CosEC_EventChannel_i;
class TAO_RTEC_COSEC_Export CosEC_ServantBase :
public virtual POA_CosEventChannelAdmin::EventChannel
{
// = TITLE
// A generic servant base class.
// = DESCRIPTION
// This class contains all the member data and methods required to
// create and manage a CosEC servant.
// Clients can derive from this class and create servants.
public:
// = Initialization method.
CosEC_ServantBase (void);
// Constructor.
virtual ~CosEC_ServantBase (void);
// Destructor.
virtual void init (PortableServer::POA_ptr thispoa,
PortableServer::POA_ptr poa,
char *eventTypeIds,
char *eventSourceIds,
char *source_type_pairs);
// This method creates a local scheduler, rtec and cosec.
// The POA <poa> specified here is used when <activate> is called to
// activate the contained servants.
// The POA <thispoa> is used to activate this.
int activate (void);
// Activates the CosEC with <thispoa_> and friends with the <poa_>
int activate (const char* servant_id);
// If the servant_id is not nil then it is used to supply the object id
// for <this> servant.
void deactivate (void);
// Deactivates the CosEC and friends with the POA.
// = POA_CosEventChannelAdmin::EventChannel methods.
virtual CosEventChannelAdmin::ConsumerAdmin_ptr for_consumers (void)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual CosEventChannelAdmin::SupplierAdmin_ptr for_suppliers (void)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void destroy (void)
ACE_THROW_SPEC ((CORBA::SystemException));
// Destroys this Event Channel object.
protected:
// = RtEC creation, activation and deactivation methods.
virtual POA_RtecEventChannelAdmin::EventChannel_ptr
create_rtec (void);
// Create a local rtec.
virtual void activate_rtec (void);
// Activates the rtec.
virtual void deactivate_rtec (void);
// Deactivates the rtec.
// = CosEC creation, activation and deactivation methods.
TAO_CosEC_EventChannel_i*
create_cosec (void);
// Create a local cosec.
int activate_cosec (void);
// Activates the cosec.
void deactivate_cosec (void);
// Deactivates the cosec.
void init_SupplierQOS (RtecBase::handle_t supp_handle,
ACE_SupplierQOS_Factory &supplier_qos,
char *source_type_pairs);
// Initialize the SupplierQOS Factory.
void init_ConsumerQOS (RtecBase::handle_t cons_handle,
ACE_ConsumerQOS_Factory &consumer_qos,
char *eventTypeIds,
char *eventSourceIds);
// Initialize the ConsumerQOS Factory.
// = Protected Data members.
PortableServer::POA_var thispoa_;
// The poa that we use to activate ourselves.
PortableServer::POA_var poa_;
// The poa that we use to activate others
POA_RtecEventChannelAdmin::EventChannel_ptr rtec_servant_;
// The Event Channel servant.
TAO_CosEC_EventChannel_i *cosec_servant_;
// The servant object of the COS Event Channel.
RtecEventChannelAdmin::EventChannel_var rtec_;
// Ref to the Rtec.
CosEventChannelAdmin::EventChannel_var cosec_;
// Ref to the cosec.
ACE_ConsumerQOS_Factory consumer_qos_;
// The Consumer QOS.
ACE_SupplierQOS_Factory supplier_qos_;
// The Supplier QOS.
char *eventTypeIds_;
// The list of EventTypeIDs (for ConsumerQOS) seperated by spaces.
// e.g. "1 2 3 4"
char *eventSourceIds_;
// The list of EventSourceIDs (for ConsumerQOS) seperated by spaces.
// e.g. "1 2 3 4"
char *source_type_pairs_;
// The pairs of Source and EventType Ids (for the SupplierQOS).
// e.g "1 4 2 5 3 6" where (1,4) (2,5) and (3,6) from source id,
// event id pairs.
};
#include /**/ "ace/post.h"
#endif /* TAO_COSEVENT_UTILITIES_H */
|
