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
|
// -*- C++ -*-
//=============================================================================
/**
* @file Transport_Acceptor.h
*
* $Id$
*
* Interface for the Acceptor component of the TAO pluggable protocol
* framework.
*
* @author Fred Kuhns <fredk@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_ACCEPTOR_H
#define TAO_ACCEPTOR_H
#include /**/ "ace/pre.h"
#include /**/ "tao/TAO_Export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Acceptor.h"
#include "tao/Basic_Types.h"
// Forward declarations.
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
class ACE_Addr;
class ACE_Reactor;
ACE_END_VERSIONED_NAMESPACE_DECL
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
class TAO_ORB_Core;
class TAO_MProfile;
class TAO_Endpoint;
class TAO_Transport;
namespace IOP
{
struct TaggedProfile;
}
namespace TAO
{
class ObjectKey;
}
//@@ TAO_ACCEPTOR_SPL_INCLUDE_FORWARD_DECL_ADD_HOOK
// ****************************************************************
/// The TAO-specific OMG assigned value for the TAG_ORB_TYPE tagged
/// component.
/**
* This number was assigned by the OMG. Do *NOT* change. The ASCII
* representation is "TA\x00". If necessary, we can request more ORB
* types later.
*/
const CORBA::ULong TAO_ORB_TYPE = 0x54414f00U;
// ****************************************************************
/**
* @class TAO_Acceptor
*
* @brief Abstract Acceptor class used for pluggable transports.
*
* Base class for the Acceptor bridge class.
*
* @todo Need to rename the class as TAO_Transport_Acceptor.
*/
class TAO_Export TAO_Acceptor
{
public:
TAO_Acceptor (CORBA::ULong tag);
/// Destructor
virtual ~TAO_Acceptor (void);
/// The tag, each concrete class will have a specific tag value.
CORBA::ULong tag (void) const;
/// Set the amount of time to delay accepting new connections in the
/// event that we encounter an error that may be transient.
void set_error_retry_delay (time_t delay);
/// Method to initialize acceptor for address.
virtual int open (TAO_ORB_Core *orb_core,
ACE_Reactor *reactor,
int version_major,
int version_minor,
const char *address,
const char *options = 0) = 0;
/**
* Open an acceptor with the given protocol version on a default
* endpoint
*/
virtual int open_default (TAO_ORB_Core *,
ACE_Reactor *reactor,
int version_major,
int version_minor,
const char *options = 0) = 0;
/// Closes the acceptor
virtual int close (void) = 0;
/**
* Create the corresponding profile for this endpoint.
* If share_profile is set to true, the pluggable protocol
* implementation should try to add the endpoint to a profile
* in the mprofile that is of the same type. Currently, this
* is used when RT CORBA is enabled.
*/
virtual int create_profile (const TAO::ObjectKey &object_key,
TAO_MProfile &mprofile,
CORBA::Short priority) = 0;
/// Return 1 if the @a endpoint has the same address as the acceptor.
virtual int is_collocated (const TAO_Endpoint *endpoint) = 0;
/**
* Returns the number of endpoints this acceptor is listening on. This
* is used for determining how many profiles will be generated
* for this acceptor.
*/
virtual CORBA::ULong endpoint_count (void) = 0;
/**
* This method fetches the @a key from the @a profile. Protocols that
* are pluggable can send data that are specific in the
* @c profile_data field encapsulated as a octet stream. This method
* allows those protocols to get the object key from the
* encapsulation.
*/
virtual int object_key (IOP::TaggedProfile &profile,
TAO::ObjectKey &key) = 0;
/// This method is not directly associated with the method of the same
/// name on the ACE_Acceptor template class. However, it is called by
/// the TAO_Strategy_Acceptor method of the same name.
int handle_accept_error (ACE_Event_Handler* base_acceptor);
/// Perform the handle_timeout functionality to put this acceptor back
/// into the reactor to try accepting again.
int handle_expiration (ACE_Event_Handler* base_acceptor);
/*
* Hook to add public methods from derived acceptor classes onto
* this class.
*/
//@@ TAO_ACCEPTOR_SPL_PUBLIC_METHODS_ADD_HOOK
private:
/// IOP protocol tag.
CORBA::ULong const tag_;
time_t error_retry_delay_;
/*
* Hook to add data members from concrete acceptor implementations onto
* the base class.
*/
//@@ TAO_ACCEPTOR_SPL_DATA_MEMBERS_ADD_HOOK
};
/// This is a drop-in replacement class for the ACE_Strategy_Acceptor.
/// It provides all of the same functionality and the additional
/// functionality of handling accept() errors with some sort of
/// configured action. All of the actual code is in the TAO_Acceptor
/// to avoid multiply-instantiated code that would be, in effect,
/// identical.
///
/// It is not declared nested within TAO_Acceptor as I originally wanted
/// because it caused an internal compiler error for the Tornado 2.2.1
/// compiler.
template <class SVC_HANDLER, ACE_PEER_ACCEPTOR_1>
class TAO_Strategy_Acceptor:
public ACE_Strategy_Acceptor<SVC_HANDLER, ACE_PEER_ACCEPTOR_2>
{
public:
TAO_Strategy_Acceptor (TAO_Acceptor* acceptor)
: acceptor_ (acceptor) {
}
virtual int handle_accept_error (void)
{
return this->acceptor_->handle_accept_error (this);
}
virtual int handle_timeout (const ACE_Time_Value&,
const void*)
{
return this->acceptor_->handle_expiration (this);
}
private:
TAO_Acceptor* acceptor_;
};
//@@ TAO_ACCEPTOR_SPL_EXTERN_ADD_HOOK
TAO_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
# include "tao/Transport_Acceptor.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TAO_ACCEPTOR_H */
|
