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
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
|
// This may look like C, but it's really -*- C++ -*-
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO
//
// = FILENAME
// Pluggable.h
//
// = DESCRIPTION
// Interface for the TAO pluggable protocol frameowrk.
//
// = AUTHOR
// Fred Kuhns <fredk@cs.wustl.edu>
//
// ============================================================================
#ifndef TAO_PLUGGABLE_H
#define TAO_PLUGGABLE_H
#include "tao/corbafwd.h"
#include "tao/Typecode.h"
class ACE_Addr;
class ACE_Reactor;
class TAO_ORB_Core;
class STUB_Object;
class TAO_Profile;
class TAO_MProfile;
class TAO_Resource_Factory;
class TAO_Export TAO_Transport
{
// = TITLE
// Generic definitions for the new Transport class.
//
// = DESCRIPTION
// The transport object is created in the Service handler
// constructor and deleted in the service handlers destructor!!
public:
virtual CORBA::ULong tag (void) = 0;
// The tag, each concrete class will have a specific tag value.
// @@ Fred, can you please add comments describing each of the
// following methods?
virtual int idle (void) = 0;
virtual void close_conn() = 0;
virtual void resume_conn (ACE_Reactor *reactor) = 0;
// @@ Fred, can you please add the ACE_Time_Value *s to the
// interfaces of send() and recv() in preparation for the timer
// support?
virtual ssize_t send (const ACE_Message_Block *mblk) = 0;
virtual ssize_t send (const u_char *buf, size_t len) = 0;
virtual ssize_t send (const iovec *iov, int iovcnt) = 0;
// @@ Fred, can you please call this "recv()" to be consistent with
// the "ACE way" of naming?
virtual ssize_t receive (char *buf, size_t len) = 0;
virtual ssize_t receive (iovec *iov, int iovcnt) = 0;
virtual TAO_Transport *_nil (void) = 0;
virtual int is_nil (TAO_Transport *obj) = 0;
virtual int send_request (TAO_ORB_Core *orb_core,
TAO_OutputCDR &stream,
int twoway) = 0;
// virtual int send_response (TAO_OutputCDR &response) = 0;
virtual ACE_HANDLE handle (void) = 0;
// This is primarily used for error and debugging messages!
virtual ~TAO_Transport (void);
};
class TAO_Export TAO_Profile
{
// = TITLE
// Generic Profile definitions.
// @@ Fred, please add more "meat" here.
//
// = DESCRIPTION
// @@ Fred, please fill in here.
public:
virtual CORBA::ULong tag (void) = 0;
// The tag, each concrete class will have a specific tag value.
virtual ASYS_TCHAR *addr_to_string(void) = 0;
// @@ Fred, please fill in here.
virtual int parse (TAO_InputCDR& cdr,
CORBA::Boolean& continue_decoding,
CORBA::Environment &env) = 0;
// @@ Fred, please fill in here.
virtual int parse_string (const char *string,
CORBA::Environment &env) = 0;
// Parse the CDR encapsulation in <body>...
virtual CORBA::TypeCode::traverse_status encode (TAO_OutputCDR *&stream,
CORBA::Environment &env) = 0;
// @@ Fred, please fill in here.
virtual CORBA::String to_string (CORBA::Environment &env) = 0;
// @@ Fred, please fill in here.
virtual const TAO_opaque &body (void) const = 0;
// The body, an octet sequence that represent the marshaled
// profile...
virtual TAO_ObjectKey *_key (CORBA::Environment &env) = 0;
// @@ Fred, please fill in here.
virtual const TAO_ObjectKey &object_key (void) const = 0;
// Obtain the object key, return 0 if the profile cannot be parsed.
// The memory is owned by this object (not given to the caller).
virtual ACE_Addr &object_addr (const ACE_Addr *addr) = 0;
// @@ Fred, please fill in here.
virtual ACE_Addr &object_addr (void) = 0;
// @@ Fred, please fill in here.
virtual TAO_Transport *transport (void) = 0;
// @@ Fred, please fill in here.
virtual TAO_Profile *_nil (void) = 0;
// @@ Fred, please fill in here.
virtual CORBA::ULong hash (CORBA::ULong max,
CORBA::Environment &env) = 0;
// @@ Fred, please fill in here.
virtual CORBA::Boolean is_equivalent (TAO_Profile* other_profile,
CORBA::Environment &env) = 0;
// @@ Fred, please fill in here.
virtual void reset_hint (void) = 0;
// this methoid is used with a connection has been reset requiring the
// hint to be cleaned up and reset to NULL.
virtual void forward_to (TAO_MProfile *mprofiles) = 0;
// object will assume ownership for this object!!
virtual TAO_MProfile *get_forward_to (void) = 0;
// copy of MProfile, user must delete.
virtual CORBA::ULong _incr_refcnt (void) = 0;
virtual CORBA::ULong _decr_refcnt (void) = 0;
protected:
virtual TAO_MProfile *forward_to (void) = 0;
// this object keeps ownership of this object
virtual ~TAO_Profile (void);
// If you have a virtual method you need a virtual dtor.
};
class Version
{
// = TITLE
// @@ Fred, please fill in here.
//
// = DESCRIPTION
// @@ Fred, please fill in here.
public:
CORBA::Octet major;
// @@ Fred, please fill in here.
CORBA::Octet minor;
// @@ Fred, please fill in here.
Version (const Version &src);
// @@ Fred, please fill in here.
Version (CORBA::Octet maj = 0,
CORBA::Octet min = 0);
// @@ Fred, please fill in here.
~Version (void);
// @@ Fred, please fill in here.
void set_version (CORBA::Octet maj, CORBA::Octet min);
// @@ Fred, please fill in here.
Version &operator= (const Version &src);
// @@ Fred, please fill in here.
int operator== (const Version &src);
// @@ Fred, please fill in here.
int operator== (const Version *&src);
// @@ Fred, please fill in here.
};
class TAO_Export TAO_Acceptor
{
// = TITLE
// Abstract Acceptor class used for pluggable protocols.
//
// = DESCRIPTION
// @@ Fred, please fill in here.
public:
virtual TAO_Profile *create_profile (TAO_ObjectKey& object_key) = 0;
// @@ Fred, please fill in here.
virtual ACE_Event_Handler* acceptor (void) = 0;
// Return the ACE acceptor...
virtual CORBA::ULong tag (void) = 0;
// The tag, each concrete class will have a specific tag value.
virtual ~TAO_Acceptor (void);
// @@ Fred, please fill in here.
};
class TAO_Export TAO_Connector
{
// = TITLE
// Connector Registry and Generic Connector interface definitions.
//
// = DESCRIPTION
// @@ Fred, please fill in here.
public:
virtual int preconnect (char *preconnections) = 0;
// @@ Fred, please fill in here.
virtual int open (TAO_Resource_Factory *trf,
ACE_Reactor *reactor) = 0;
// @@ Fred, please fill in here.
virtual int close (void) = 0;
// @@ Fred, please fill in here.
virtual CORBA::ULong tag (void) = 0;
// The tag identifying the specific ORB transport layer protocol.
// For example TAO_IOP_TAG_INTERNET_IOP = 0. The tag is used in the
// IOR to identify the type of profile included. IOR -> {{tag0,
// profile0} {tag1, profole1} ...} GIOP.h defines typedef
// CORBA::ULong TAO_IOP_Profile_ID;
virtual TAO_Transport *connect(TAO_Profile *profile,
CORBA::Environment &env) = 0;
// In order to support pluggable we need to abstract away the
// connect() method so it can be called from the GIOP code
// independant of the actual transport protocol in use.
virtual ~TAO_Connector (void);
// the destructor.
};
class TAO_Export TAO_Connector_Registry
{
// = TITLE
// @@ Fred, please fill in here.
//
// = DESCRIPTION
// @@ Fred, please fill in here.
public:
TAO_Connector_Registry (void);
// @@ Fred, please fill in here.
~TAO_Connector_Registry (void);
// @@ Fred, please fill in here.
TAO_Connector *get_connector (CORBA::ULong tag);
// @@ Fred, please fill in here.
CORBA::Boolean add_connector (TAO_Connector *connector);
// All TAO_Connectors will have a tag() member which will be
// used for registering object, as well as type checking.
int open(TAO_Resource_Factory *trf,
ACE_Reactor *reactor);
// @@ Fred, please fill in here.
int close_all (void);
// @@ Fred, please fill in here.
int preconnect (const char *the_preconnections);
// @@ Fred, please fill in here.
TAO_Profile *connect (STUB_Object *&obj,
CORBA::Environment &env);
// This is where the transport protocol is selected based on some
// policy. This member will call the connect member of the
// TAO_Connector class which in turn will call the concrete
// connector.
private:
TAO_Connector *iiop_connector_;
// @@ for now this is all we support! This next iteration will be a
// bit more generic. Something like a key, value pair with key
// equil to the IOP_TYPE and value a pointer to the Connector.
};
#endif /* TAO_PLUGGABLE_H */
|
