blob: becce777cb31592b573be1948242ac11282467bd (
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
|
// -*- C++ -*-
// $Id$
#include "ReplicaLocator.h"
#include "LoadBalancer_i.h"
ACE_RCSID(orbsvcs, ReplicaLocator, "$Id$")
TAO_LB_ReplicaLocator::TAO_LB_ReplicaLocator (TAO_LB_LoadBalancer *lb)
: load_balancer_ (lb) // This pointer shouldn't be zero!
{
// Nothing else
}
PortableServer::Servant
TAO_LB_ReplicaLocator::preinvoke (
const PortableServer::ObjectId & /* oid */,
PortableServer::POA_ptr /* adapter */,
const char * /* operation */,
PortableServer::ServantLocator::Cookie & /* the_cookie */
TAO_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableServer::ForwardRequest))
{
TAO_ENV_ARG_DEFN;
if (this->load_balancer_ == 0)
ACE_THROW_RETURN (CORBA::INTERNAL (), 0);
CORBA::Object_ptr replica =
this->load_balancer_->replica (ACE_TRY_ENV);
ACE_CHECK_RETURN (0);
// Throw a ForwardRequest exception to force the client to redirect its
// requests to the Replica chosen by the LoadBalancer.
ACE_THROW_RETURN (PortableServer::ForwardRequest (
CORBA::Object::_duplicate (replica)),
0);
}
void
TAO_LB_ReplicaLocator::postinvoke (
const PortableServer::ObjectId & /* oid */,
PortableServer::POA_ptr /* adapter */,
const char * /* operation */,
PortableServer::ServantLocator::Cookie /* the_cookie */,
PortableServer::Servant /* the_servant */
TAO_ENV_ARG_DECL_NOT_USED)
{
// No-op
}
|
