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
|
#include "orbsvcs/LoadBalancing/LB_LoadManager.h"
#include "orbsvcs/LoadBalancing/LB_MemberLocator.h"
#include "tao/debug.h"
ACE_RCSID (LoadBalancing,
LB_MemberLocator,
"$Id$")
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
TAO_LB_MemberLocator::TAO_LB_MemberLocator (
TAO_LB_LoadManager * lm)
: load_manager_ (lm)
{
ACE_ASSERT (lm != 0);
}
PortableServer::Servant
TAO_LB_MemberLocator::preinvoke (
const PortableServer::ObjectId & oid,
PortableServer::POA_ptr /* adapter */,
const char * /* operation */,
PortableServer::ServantLocator::Cookie & /* the_cookie */
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableServer::ForwardRequest))
{
ACE_TRY
{
CORBA::Object_var member =
this->load_manager_->next_member (oid
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// ACE_DEBUG ((LM_DEBUG, "%N:%l\n"));
// ACE_DEBUG ((LM_DEBUG,
// "FORWARDED\n"));
ACE_ASSERT (!CORBA::is_nil (member.in ()));
// Throw a forward exception to force the client to redirect its
// requests to the member chosen by the LoadBalancer.
ACE_TRY_THROW (PortableServer::ForwardRequest (member.in ()));
}
ACE_CATCH (PortableGroup::ObjectGroupNotFound, ex)
{
if (TAO_debug_level > 0)
ACE_PRINT_EXCEPTION (ex,
"LoadManager::next_member()");
}
ACE_CATCH (PortableGroup::MemberNotFound, ex)
{
if (TAO_debug_level > 0)
ACE_PRINT_EXCEPTION (ex,
"LoadManager::next_member()");
}
ACE_ENDTRY;
ACE_CHECK_RETURN (0);
ACE_THROW_RETURN (CORBA::OBJECT_NOT_EXIST (), 0);
}
void
TAO_LB_MemberLocator::postinvoke (
const PortableServer::ObjectId & /* oid */,
PortableServer::POA_ptr /* adapter */,
const char * /* operation */,
PortableServer::ServantLocator::Cookie /* the_cookie */,
PortableServer::Servant /* the_servant */
ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException))
{
}
TAO_END_VERSIONED_NAMESPACE_DECL
|
