blob: 482ce0a9f18612333c5f13fdb5a7abfa650b9226 (
plain)
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
|
// -*- C++ -*-
//=============================================================================
/**
* @file Profile_Transport_Resolver.h
*
* $Id$
*
*
* @author Balachandran Natarajan <bala@dre.vanderbilt.edu>
*/
//=============================================================================
#ifndef TAO_PROFILE_TRANSPORT_RESOLVER_H
#define TAO_PROFILE_TRANSPORT_RESOLVER_H
#include /**/ "ace/pre.h"
#include "ace/Global_Macros.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/CORBA_macros.h"
#include "tao/Exception.h"
class TAO_Stub;
class TAO_Profile;
class TAO_Transport;
class TAO_Endpoint;
class ACE_Time_Value;
class TAO_Transport_Descriptor_Interface;
namespace CORBA
{
class SystemException;
class Environment;
class Object;
class PolicyList;
class Object;
typedef Object *Object_ptr;
}
namespace TAO
{
class Synch_Twoway_Invocation;
/**
* @class Profile_Transport_Resolver
*
* @brief Chooses the profile and a transport for a target object on
* which an invocation can be made.
*
* A target object is represented by multiple profiles, which
* theoretically provides multiple paths to the same target
* object. This class helps in choosing the right profile, and pick
* a transport from cache (or create a new transport if needed) that
* represents the profile.
*
*/
class TAO_Export Profile_Transport_Resolver
{
public:
Profile_Transport_Resolver (CORBA::Object *ep,
TAO_Stub *);
~Profile_Transport_Resolver (void);
/// Method where the bunch of the action takes place.
/**
* This is the entry point from the TAO::Invocation_Adapter
* class. This method accesses the endpoint selector factory from
* the ORB_Core to decide on the strategy to be used for selecting
* the profile.
*/
void resolve (ACE_Time_Value *val
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
//@{
/**
* Accessors and mutators for this class. The following methods
* are used by the clients of this class to access.
*/
/// Mutator for profile.
void profile (TAO_Profile *pfile);
/// Accessor for profile.
TAO_Profile *profile (void) const;
/// Accessor for TAO_Stub
TAO_Stub *stub (void) const;
/// Accessor for the target in use
CORBA::Object *object (void) const;
/// Accessor for the transport reserved for this invocation.
TAO_Transport *transport (void) const;
//@}
/// Signal to let the resolver know that the transport has been
/// released back to the cache.
void transport_released (void) const;
/// This is a callback method used by the endpoint selectors, to
/// delegate the responsibility of reserving a transport from the
/// connection cache for this invocation.
bool try_connect (TAO_Transport_Descriptor_Interface *desc,
ACE_Time_Value *val
ACE_ENV_ARG_DECL);
/// Initialize the inconsistent policy list that this object has
/// cached.
void init_inconsistent_policies (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
CORBA::PolicyList *inconsistent_policies (void) const;
CORBA::PolicyList *steal_inconsistent_policies (void);
private:
/// Helper method to access get the connection timeout from the
/// ORB.
bool get_connection_timeout (ACE_Time_Value &max_wait_time);
private:
/// Target object
mutable CORBA::Object *obj_;
/// Stub object for the target object.
TAO_Stub *stub_;
/// The transport selected for this invocation.
TAO_Transport *transport_;
/// The profile that has been selected for this invocation.
TAO_Profile *profile_;
/// Has the transport been idle?
mutable bool is_released_;
/// List of inconsistent policies
/**
* If current effective policies cause the invocation to raise
* CORBA::INV_POLICY exception, the conflicting/problematic policies
* are stored in this list. This is used by \param
* Object::_validate_connection method to inform clients about
* causes of invocation failure.
* @par
* Conflicting policies are only stored in this list if \param
* init_inconsistent_policies method has been called prior to the
* beginning of invocation. This saves extra work of conflicting
* policies 'logging' when it's not needed.
*
* @note We don't use _var with a reason. Using _var would
* involve including the header file for at least
* Policy_ForwardC.h, and that is what we precisely want to
* avoid.
*/
CORBA::PolicyList *inconsistent_policies_;
};
} // TAO namespace end
#if defined (__ACE_INLINE__)
# include "Profile_Transport_Resolver.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /*TAO_PROFILE_TRANSPORT_RESOLVER_H*/
|
