blob: 7012d1ab668020bec7c7504a08758f8a4c156b86 (
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
|
#include "LB_MemberLocator.h"
#include "LB_LoadManager.h"
ACE_RCSID (LoadBalancing,
LB_MemberLocator,
"$Id$")
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))
{
CORBA::Object_var member =
this->load_manager_->next_member (oid
ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (0);
// ACE_DEBUG ((LM_DEBUG,
// "FORWARDED\n"));
// Throw a forward exception to force the client to redirect its
// requests to the member chosen by the LoadBalancer.
ACE_THROW_RETURN (PortableServer::ForwardRequest (member.in ()),
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))
{
}
|
