blob: 2bb8f1fc5f6bc28255d3c22aa36f5ae67b589e63 (
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 Invocation_Endpoint_Selectors.h
*
* $Id$
*
* Strategies for selecting profile/endpoint from an IOR for making an
* invocation.
*
* @author Marina Spivak <marina@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_INVOCATION_ENDPOINT_SELECTOR_H
#define TAO_INVOCATION_ENDPOINT_SELECTOR_H
#include "ace/pre.h"
#include "tao/corbafwd.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/CORBA_macros.h"
class TAO_MProfile;
class TAO_GIOP_Invocation;
class ACE_Time_Value;
namespace TAO
{
class Profile_Transport_Resolver;
}
/**
* @class TAO_Invocation_Endpoint_Selector
*
* @brief Defines the interface for policy-based endpoint selection
* strategies.
*
* Selects/reselects server endpoint for an Invocation. Different
* concrete strategies perform selection based on different
* policies.
* @par
* All endpoint selection strategies are stateless objects - any
* necessary state is stored in Invocation's
* @c endpoint_selection_state_.
*/
class TAO_Export TAO_Invocation_Endpoint_Selector
{
public:
/// Constructor.
TAO_Invocation_Endpoint_Selector (void);
/// Destructor.
virtual ~TAO_Invocation_Endpoint_Selector (void);
/// Select the endpoint and set @a invocation's @c profile_ and
/// @c endpoint_ data members accordingly.
virtual void select_endpoint (TAO_GIOP_Invocation *invocation
ACE_ENV_ARG_DECL) = 0;
virtual void select_endpoint (TAO::Profile_Transport_Resolver *r,
ACE_Time_Value *val
ACE_ENV_ARG_DECL) = 0;
/**
* This method must be called if the invocation attempt on a
* selected endpoint resulted in location forward. This method
* performs the necessary state updates, so that next @c
* select_endpoint call picks a new endpoint.
*/
virtual void forward (TAO_GIOP_Invocation *invocation,
const TAO_MProfile &mprofile
ACE_ENV_ARG_DECL) = 0;
/// Update the state to indicate that the selected endpoint/profile
/// were used successfully.
virtual void success (TAO_GIOP_Invocation *invocation) = 0;
/// Update the state to reflect that the connection being used for
/// the invocation has been closed by the server.
virtual void close_connection (TAO_GIOP_Invocation *invocation) = 0;
};
// ****************************************************************
/**
* @class TAO_Default_Endpoint_Selector
*
* @brief Default strategy for endpoint selection.
*
* This strategy is used when there are no policies set or when
* the only policy set is RTCORBA::PriorityModelPolicy and its
* value is RTCORBA::SERVER_DECLARED.
* The strategy is to try the first endpoint from the first
* profile in the IOR. If that doesn't work, try the next
* profile, and so on.
*/
class TAO_Export TAO_Default_Endpoint_Selector :
public TAO_Invocation_Endpoint_Selector
{
public:
/// Constructor.
TAO_Default_Endpoint_Selector (void);
/// Destructor.
virtual ~TAO_Default_Endpoint_Selector (void);
virtual void select_endpoint (TAO_GIOP_Invocation *invocation
ACE_ENV_ARG_DECL);
virtual void select_endpoint (TAO::Profile_Transport_Resolver *r,
ACE_Time_Value *val
ACE_ENV_ARG_DECL);
virtual void forward (TAO_GIOP_Invocation *invocation,
const TAO_MProfile &mprofile
ACE_ENV_ARG_DECL);
virtual void success (TAO_GIOP_Invocation *invocation);
virtual void close_connection (TAO_GIOP_Invocation *invocation);
protected:
/// This method selects an endpoint from the profile in the
/// invocation object.
virtual int endpoint_from_profile (TAO_GIOP_Invocation *invocation
ACE_ENV_ARG_DECL);
};
#if defined (__ACE_INLINE__)
# include "tao/Invocation_Endpoint_Selectors.i"
#endif /* __ACE_INLINE__ */
#include "ace/post.h"
#endif /* TAO_INVOCATION_ENDPOINT_SELECTOR_H */
|
