blob: 7e1fde2c694cf536a1a47306cc4cd69a0ffceed2 (
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
|
// -*- 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 "tao/Exception.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/CORBA_macros.h"
#include "ace/Global_Macros.h"
class TAO_Stub;
class TAO_Profile;
class TAO_Transport;
class TAO_Endpoint;
class ACE_Time_Value;
namespace CORBA
{
class SystemException;
class Environment;
class Object;
}
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 muttators for this class. The following methods
* are used by the clients of this class to access.
*/
/// Accessors and mutators for profile.
void profile (TAO_Profile *pfile);
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_Endpoint *,
ACE_Time_Value *val
ACE_ENV_ARG_DECL);
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 idled?
mutable bool is_released_;
};
} // 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*/
|
