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
|
// -*- C++ -*-
// $Id$
#include "ReplicaProxy.h"
#include "LoadBalancer_i.h"
#if !defined(__ACE_INLINE__)
#include "ReplicaProxy.i"
#endif /* __ACE_INLINE__ */
ACE_RCSID(orbsvcs, ReplicaProxy, "$Id$")
TAO_LB_ReplicaProxy::TAO_LB_ReplicaProxy (void)
: has_high_load_ (0),
lock_ (),
balancer_ (0),
current_load_ (0),
connected_ (0)
{
// Nothing as yet
}
void
TAO_LB_ReplicaProxy::current_load (CORBA::Float load,
CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException))
{
// @@ Ossama: this is the point were the load dampening should
// happen. Probably strategized....
// Do not lock here. Locking is done in the load_changed() method,
// below.
this->current_load_ = load;
// ACE_DEBUG ((LM_DEBUG, "Load[%x] = %f\n", long(this), load));
this->balancer_->load_changed (this, ACE_TRY_ENV);
}
void
TAO_LB_ReplicaProxy::disconnect (CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((PortableGroup::ReplicaProxy::NotConnected,
CORBA::SystemException))
{
ACE_MT (ACE_GUARD (TAO_SYNCH_MUTEX,
guard,
this->lock_));
if (this->connected_)
{
this->balancer_->disconnect (this, ACE_TRY_ENV);
ACE_CHECK;
this->connected_ = 0;
}
else
{
ACE_THROW (PortableGroup::ReplicaProxy::NotConnected ());
}
}
void
TAO_LB_ReplicaProxy::connect (TAO_LB_LoadBalancer *balancer,
PortableGroup::ReplicaControl_ptr control,
CORBA::Object_ptr replica,
CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((PortableGroup::ReplicaProxy::NilControl,
PortableGroup::ReplicaProxy::NilReplica,
CORBA::SystemException))
{
ACE_MT (ACE_GUARD (TAO_SYNCH_MUTEX,
guard,
this->lock_));
if (balancer == 0)
ACE_THROW (CORBA::BAD_PARAM (
CORBA_SystemException::_tao_minor_code (
TAO_DEFAULT_MINOR_CODE,
EINVAL),
CORBA::COMPLETED_NO));
else
this->balancer_ = balancer;
if (!CORBA::is_nil (control))
this->control_ = PortableGroup::ReplicaControl::_duplicate (control);
else
ACE_THROW (PortableGroup::ReplicaProxy::NilControl ());
if (!CORBA::is_nil (control))
this->replica_ = CORBA::Object::_duplicate (replica);
else
ACE_THROW (PortableGroup::ReplicaProxy::NilReplica ());
// Now indicate that connection to LoadBalancer has been made.
this->connected_ = 1;
}
|
