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
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
|
#ifndef _COS_EVENT_DOMAIN_ADMIN_IDL_
#define _COS_EVENT_DOMAIN_ADMIN_IDL_
#pragma prefix "omg.org"
// Event Domain Interface
#include "CosNotification.idl"
#include "CosEventComm.idl"
#include "CosNotifyComm.idl"
#include "CosNotifyChannelAdmin.idl"
module CosEventDomainAdmin {
// The following constant declarations define the Event Domain
// QoS property names and the associated values each property can
// take on. The name/value pairs for each Event Domain property
// are grouped, beginning with a string constant defined for the
// property name, followed by the values the property can take on.
const string CycleDetection = "CycleDetection";
const short AuthorizeCycles = 0; // Default value
const short ForbidCycles = 1;
const string DiamondDetection = "DiamondDetection";
const short AuthorizeDiamonds = 0; // Default value
const short ForbidDiamonds = 1;
// The following enum declaration defines the types that a channel
// can be of. It is used to specify channel types while externalizing
// and instantiating topologies.
enum ChannelType
{
CHANNEL,
TYPED_CHANNEL,
LOG_CHANNEL,
TYPED_LOG_CHANNEL
};
enum NotificationStyle {
Push,
Pull
};
typedef long MemberID;
typedef sequence <MemberID> MemberIDSeq;
typedef long ConnectionID;
typedef sequence <ConnectionID> ConnectionIDSeq;
struct Connection {
MemberID supplier_id;
MemberID consumer_id;
CosNotifyChannelAdmin::ClientType ctype;
NotificationStyle notification_style;
};
typedef MemberIDSeq Route;
typedef sequence<Route> RouteSeq;
typedef Route Cycle;
typedef sequence<Cycle> CycleSeq;
typedef RouteSeq Diamond;
typedef sequence<Diamond> DiamondSeq;
exception CycleCreationForbidden
{
Cycle cyc;
};
exception DiamondCreationForbidden
{
Diamond diam;
};
// Forward declarations
interface ConsumerAdmin;
interface SupplierAdmin;
typedef long DomainID;
typedef sequence <DomainID> DomainIDSeq;
typedef long ItemID;
// EventDomain administrates EventChannels that reside in the same
// administrative domain
exception ConnectionNotFound {};
exception AlreadyExists {};
interface EventDomain :
CosNotification::QoSAdmin ,
CosNotification::AdminPropertiesAdmin {
MemberID add_channel ( in CosNotifyChannelAdmin::EventChannel channel );
MemberIDSeq get_all_channels ();
CosNotifyChannelAdmin::EventChannel get_channel ( in MemberID channel )
raises ( CosNotifyChannelAdmin::ChannelNotFound );
void remove_channel ( in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
ConnectionID add_connection ( in Connection connection)
raises (CosNotifyChannelAdmin::ChannelNotFound,
CosEventChannelAdmin::TypeError,
AlreadyExists,
CycleCreationForbidden,
DiamondCreationForbidden);
ConnectionIDSeq get_all_connections ();
Connection get_connection ( in ConnectionID connection )
raises ( ConnectionNotFound );
void remove_connection ( in ConnectionID connection )
raises ( ConnectionNotFound );
CosNotifyChannelAdmin::ChannelIDSeq get_offer_channels ( in MemberID channel )
raises ( CosNotifyChannelAdmin::ChannelNotFound );
CosNotifyChannelAdmin::ChannelIDSeq get_subscription_channels ( in MemberID channel )
raises ( CosNotifyChannelAdmin::ChannelNotFound );
void destroy();
// Cycle and diamond configurations listing
CycleSeq get_cycles();
DiamondSeq get_diamonds();
// Connection of clients to the domain
// - using no specific information
// - for any clients
void set_default_consumer_channel(in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
void set_default_supplier_channel(in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::ProxyPushSupplier
connect_push_consumer(in CosEventComm::PushConsumer client)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::ProxyPullSupplier
connect_pull_consumer(in CosEventComm::PullConsumer client)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::ProxyPushConsumer
connect_push_supplier(in CosEventComm::PushSupplier client)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::ProxyPullConsumer
connect_pull_supplier(in CosEventComm::PullSupplier client)
raises (CosNotifyChannelAdmin::ChannelNotFound);
// - for structured clients
CosNotifyChannelAdmin::StructuredProxyPushSupplier
connect_structured_push_consumer(in CosNotifyComm::StructuredPushConsumer client)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::StructuredProxyPullSupplier
connect_structured_pull_consumer(in CosNotifyComm::StructuredPullConsumer client)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::StructuredProxyPushConsumer
connect_structured_push_supplier(in CosNotifyComm::StructuredPushSupplier client)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::StructuredProxyPullConsumer
connect_structured_pull_supplier(in CosNotifyComm::StructuredPullSupplier client)
raises (CosNotifyChannelAdmin::ChannelNotFound);
// - for sequence clients
CosNotifyChannelAdmin::SequenceProxyPushSupplier
connect_sequence_push_consumer(in CosNotifyComm::SequencePushConsumer client)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::SequenceProxyPullSupplier
connect_sequence_pull_consumer(in CosNotifyComm::SequencePullConsumer client)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::SequenceProxyPushConsumer
connect_sequence_push_supplier(in CosNotifyComm::SequencePushSupplier client)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::SequenceProxyPullConsumer
connect_sequence_pull_supplier(in CosNotifyComm::SequencePullSupplier client)
raises (CosNotifyChannelAdmin::ChannelNotFound);
// - using a channel id
// - for any clients
CosNotifyChannelAdmin::ProxyPushSupplier
connect_push_consumer_with_id(in CosEventComm::PushConsumer client,
in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::ProxyPullSupplier
connect_pull_consumer_with_id(in CosEventComm::PullConsumer client,
in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::ProxyPushConsumer
connect_push_supplier_with_id(in CosEventComm::PushSupplier client,
in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::ProxyPullConsumer
connect_pull_supplier_with_id(in CosEventComm::PullSupplier client,
in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
// - for structured clients
CosNotifyChannelAdmin::StructuredProxyPushSupplier
connect_structured_push_consumer_with_id(in CosNotifyComm::StructuredPushConsumer client,
in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::StructuredProxyPullSupplier
connect_structured_pull_consumer_with_id(in CosNotifyComm::StructuredPullConsumer client,
in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::StructuredProxyPushConsumer
connect_structured_push_supplier_with_id(in CosNotifyComm::StructuredPushSupplier client,
in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::StructuredProxyPullConsumer
connect_structured_pull_supplier_with_id(in CosNotifyComm::StructuredPullSupplier client,
in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
// - for sequence clients
CosNotifyChannelAdmin::SequenceProxyPushSupplier
connect_sequence_push_consumer_with_id(in CosNotifyComm::SequencePushConsumer client,
in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::SequenceProxyPullSupplier
connect_sequence_pull_consumer_with_id(in CosNotifyComm::SequencePullConsumer client,
in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::SequenceProxyPushConsumer
connect_sequence_push_supplier_with_id(in CosNotifyComm::SequencePushSupplier client,
in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
CosNotifyChannelAdmin::SequenceProxyPullConsumer
connect_sequence_pull_supplier_with_id(in CosNotifyComm::SequencePullSupplier client,
in MemberID channel)
raises (CosNotifyChannelAdmin::ChannelNotFound);
};
exception DomainNotFound {};
interface EventDomainFactory {
EventDomain create_event_domain( in CosNotification::QoSProperties initialQoS ,
in CosNotification::AdminProperties initialAdmin,
out DomainID id )
raises ( CosNotification::UnsupportedQoS,
CosNotification::UnsupportedAdmin );
DomainIDSeq get_all_domains ();
EventDomain get_event_domain (
in DomainID id )
raises ( DomainNotFound );
};
};
#endif // _COS_EVENT_DOMAIN_ADMIN_IDL_
|
