blob: f8e89fb78579b5c426b17d06d4340c331d12ebb2 (
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
|
#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 */)
{
try
{
CORBA::Object_var member =
this->load_manager_->next_member (oid);
// 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.
throw PortableServer::ForwardRequest (member.in ());
}
catch (const PortableGroup::ObjectGroupNotFound& ex)
{
if (TAO_debug_level > 0)
ex._tao_print_exception ("LoadManager::next_member()");
}
catch (const PortableGroup::MemberNotFound& ex)
{
if (TAO_debug_level > 0)
ex._tao_print_exception ("LoadManager::next_member()");
}
throw CORBA::OBJECT_NOT_EXIST ();
}
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 */)
{
}
TAO_END_VERSIONED_NAMESPACE_DECL
|
