blob: d4246736ab0bd5de89370b0409b22f578b2d69be (
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
66
67
68
69
70
71
72
73
74
|
// -*- C++ -*-
#include "orbsvcs/Naming/FaultTolerant/FT_Round_Robin.h"
#include "orbsvcs/Naming/FaultTolerant/FT_Naming_Manager.h"
#include "orbsvcs/PortableGroup/PG_conf.h"
#include "tao/debug.h"
#include "tao/ORB_Constants.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
TAO_FT_Round_Robin::TAO_FT_Round_Robin ()
: lock_ (),
location_index_map_ (TAO_PG_MAX_OBJECT_GROUPS)
{
}
TAO_FT_Round_Robin::~TAO_FT_Round_Robin ()
{
}
bool
TAO_FT_Round_Robin::next_location (
PortableGroup::ObjectGroup_ptr object_group,
TAO_FT_Naming_Manager *naming_manager,
PortableGroup::Location& location)
{
const PortableGroup::ObjectGroupId id =
naming_manager->get_object_group_id (object_group);
ACE_GUARD_RETURN (TAO_SYNCH_MUTEX,
monitor,
this->lock_,
0);
PortableGroup::Locations_var locations =
naming_manager->locations_of_members (object_group);
const CORBA::ULong len = locations->length ();
// No locations exist, so we can't get the next one
if (len == 0)
return false;
TAO_FT_Location_Index_Map::ENTRY * entry;
if (this->location_index_map_.find (id, entry) == 0)
{
CORBA::ULong & i = entry->int_id_;
if (len <= i)
i = 0; // Reset, i.e. wrap around
location = locations[i];
// Increment index to point to next location.
++i;
return true;
}
// Could not find an entry
// Create an entry at location 0
CORBA::ULong start = 0;
location = locations[start++];
if (this->location_index_map_.bind (id, start) != 0)
{ // The location was already bound or some failure occurred. Should not happen.
throw CORBA::INTERNAL ();
}
return true;
}
TAO_END_VERSIONED_NAMESPACE_DECL
|
