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
|
// This may look like C, but it's really -*- C++ -*-
//=============================================================================
/**
* @file Transport_Connector.h
*
* $Id$
*
* Define the interface for the Connector component in TAO's
* pluggable protocol framework.
*
* @author Fred Kuhns <fredk@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_CONNECTOR_H
#define TAO_CONNECTOR_H
#include /**/ "ace/pre.h"
#include "ace/CORBA_macros.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "TAO_Export.h"
#include "Basic_Types.h"
class ACE_Time_Value;
class TAO_Transport_Descriptor_Interface;
class TAO_InputCDR;
class TAO_Endpoint;
class TAO_Profile;
class TAO_MProfile;
class TAO_ORB_Core;
class TAO_Connect_Strategy;
class TAO_Transport;
class TAO_Connection_Handler;
namespace TAO
{
class Profile_Transport_Resolver;
}
namespace CORBA
{
class Environment;
}
/**
* @class TAO_Connector
*
* @brief Generic Connector interface definitions.
*
* Base class for connector bridge object.
*
* @todo Need to rename the class as TAO_Transport_Connector.
*/
class TAO_Export TAO_Connector
{
public:
/// Default constructor.
TAO_Connector (CORBA::ULong tag);
/// The destructor.
virtual ~TAO_Connector (void);
/**
* The tag identifying the specific ORB transport layer protocol.
* For example IOP::TAG_INTERNET_IOP == 0. The tag is used in the
* IOR to identify the type of profile included. IOR -> {{tag0,
* profile0} {tag1, profile1} ...}. The IOP module defines the
* ProfileId typedef to be a CORBA::ULong.
*/
CORBA::ULong tag (void) const;
/// Parse a string containing a URL style IOR and return an
/// MProfile.
int make_mprofile (
const char *ior,
TAO_MProfile &mprofile
ACE_ENV_ARG_DECL);
/// Initialize object and register with reactor.
virtual int open (
TAO_ORB_Core *orb_core) = 0;
/// Shutdown Connector bridge and concrete Connector.
virtual int close (void) = 0;
/**
* To support pluggable we need to abstract away the details of the
* connect () method so it can be called from the invocation code
* independent of the actual transport protocol in use.
*/
virtual TAO_Transport* connect (
TAO::Profile_Transport_Resolver *r,
TAO_Transport_Descriptor_Interface *desc,
ACE_Time_Value *timeout
ACE_ENV_ARG_DECL);
/// Create a profile for this protocol and initialize it based on the
/// encapsulation in @a cdr
virtual TAO_Profile *create_profile (
TAO_InputCDR& cdr) = 0;
/// Check that the prefix of the provided endpoint is valid for use
/// with a given pluggable protocol.
virtual int check_prefix (
const char *endpoint) = 0;
/// Return the object key delimiter to use or expect.
virtual char object_key_delimiter (void) const = 0;
protected:
/// Create a profile with a given endpoint.
virtual TAO_Profile *make_profile (ACE_ENV_SINGLE_ARG_DECL) = 0;
/// Set and validate endpoint. We need to do this to initialize our
/// remote *_Addr's which have not been done during IOR decode.
virtual int set_validate_endpoint (TAO_Endpoint *endpoint) = 0;
/// Make a connection
virtual TAO_Transport* make_connection (
TAO::Profile_Transport_Resolver *r,
TAO_Transport_Descriptor_Interface &desc,
ACE_Time_Value *timeout) = 0;
/// Cancel the passed cvs handler from the connector
virtual int cancel_svc_handler (
TAO_Connection_Handler *svc_handler) = 0;
/// Check whether the connection is not closed
/**
* @retval 0 The connection happens to be not closed, but is now open
* because an other thread managed to open the handler
* @retval -1 The connection is closed
*/
virtual int check_connection_closure (
TAO_Connection_Handler *connection_handler);
/**
* Wait for connection completion. We have a transport that is not
* connected yet, wait until it is connected.
* @retval true When we could use @a transport
* @return false When we can't use the @a transport
*/
virtual bool wait_for_connection_completion(
TAO::Profile_Transport_Resolver *r,
TAO_Transport *&transport,
ACE_Time_Value *timeout);
/// Set the ORB Core pointer
void orb_core (TAO_ORB_Core *orb_core);
/// Create a connect strategy
int create_connect_strategy (void);
/// Return the TAO_ORB_Core pointer
TAO_ORB_Core *orb_core (void);
protected:
/// The (a)synch connect strategy
TAO_Connect_Strategy *active_connect_strategy_;
private:
/// IOP protocol tag.
CORBA::ULong tag_;
/// Pointer to our ORB core
TAO_ORB_Core *orb_core_;
};
#if defined (__ACE_INLINE__)
# include "Transport_Connector.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /*TAO_CONNECTOR_H*/
|
