blob: cd655d1d64c02b13c707433b178018f4f940b517 (
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
|
// This may look like C, but it's really -*- 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 "tao/MProfile.h"
class TAO_GIOP_Invocation;
/**
* @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.
* All endpoint selection strategies are stateless objects - any
* necessary state is stored in Invocation's
* <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 <invocation>'s <profile_> and
/// <endpoint_> data members accordingly.
virtual void select_endpoint (TAO_GIOP_Invocation *invocation
TAO_ENV_ARG_DECL_WITH_DEFAULTS) = 0;
/**
* This method must be called when previously selected endpoint
* didn't work out, and we want to try another one, i.e., reselect.
* This method performs the necessary state updates, so that next
* <select_endpoint> call picks a new endpoint.
*/
virtual void next (TAO_GIOP_Invocation *invocation
TAO_ENV_ARG_DECL_WITH_DEFAULTS) = 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 <select_endpoint>
* call picks a new endpoint.
*/
virtual void forward (TAO_GIOP_Invocation *invocation,
const TAO_MProfile &mprofile
TAO_ENV_ARG_DECL_WITH_DEFAULTS) = 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_Export TAO_Default_Endpoint_Selector :
public TAO_Invocation_Endpoint_Selector
{
// = TITLE
// Default strategy for endpoint selection.
//
// = DESCRIPTION
// 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.
//
public:
/// Constructor.
TAO_Default_Endpoint_Selector (void);
/// Destructor.
virtual ~TAO_Default_Endpoint_Selector (void);
virtual void select_endpoint (TAO_GIOP_Invocation *invocation
TAO_ENV_ARG_DECL_WITH_DEFAULTS);
virtual void next (TAO_GIOP_Invocation *invocation
TAO_ENV_ARG_DECL_WITH_DEFAULTS);
virtual void forward (TAO_GIOP_Invocation *invocation,
const TAO_MProfile &mprofile
TAO_ENV_ARG_DECL_WITH_DEFAULTS);
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.
int endpoint_from_profile (TAO_GIOP_Invocation *invocation
TAO_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 */
|
