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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
// **********************************************************************
//
// Copyright (c) 2003-2014 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
package IceInternal;
final class LocatorTable
{
LocatorTable()
{
}
synchronized void
clear()
{
_adapterEndpointsTable.clear();
_objectTable.clear();
}
synchronized IceInternal.EndpointI[]
getAdapterEndpoints(String adapter, int ttl, Ice.BooleanHolder cached)
{
if(ttl == 0) // Locator cache disabled.
{
cached.value = false;
return null;
}
EndpointTableEntry entry = _adapterEndpointsTable.get(adapter);
if(entry != null)
{
cached.value = checkTTL(entry.time, ttl);
return entry.endpoints;
}
cached.value = false;
return null;
}
synchronized void
addAdapterEndpoints(String adapter, IceInternal.EndpointI[] endpoints)
{
_adapterEndpointsTable.put(adapter,
new EndpointTableEntry(IceInternal.Time.currentMonotonicTimeMillis(), endpoints));
}
synchronized IceInternal.EndpointI[]
removeAdapterEndpoints(String adapter)
{
EndpointTableEntry entry = _adapterEndpointsTable.remove(adapter);
return entry != null ? entry.endpoints : null;
}
synchronized Reference
getObjectReference(Ice.Identity id, int ttl, Ice.BooleanHolder cached)
{
if(ttl == 0) // Locator cache disabled.
{
cached.value = false;
return null;
}
ReferenceTableEntry entry = _objectTable.get(id);
if(entry != null)
{
cached.value = checkTTL(entry.time, ttl);
return entry.reference;
}
cached.value = false;
return null;
}
synchronized void
addObjectReference(Ice.Identity id, Reference ref)
{
_objectTable.put(id, new ReferenceTableEntry(IceInternal.Time.currentMonotonicTimeMillis(), ref));
}
synchronized Reference
removeObjectReference(Ice.Identity id)
{
ReferenceTableEntry entry = _objectTable.remove(id);
return entry != null ? entry.reference : null;
}
private boolean
checkTTL(long time, int ttl)
{
assert(ttl != 0);
if(ttl < 0) // TTL = infinite
{
return true;
}
else
{
return IceInternal.Time.currentMonotonicTimeMillis() - time <= ((long)ttl * 1000);
}
}
private static final class EndpointTableEntry
{
public EndpointTableEntry(long time, IceInternal.EndpointI[] endpoints)
{
this.time = time;
this.endpoints = endpoints;
}
final public long time;
final public IceInternal.EndpointI[] endpoints;
}
private static final class ReferenceTableEntry
{
public ReferenceTableEntry(long time, Reference reference)
{
this.time = time;
this.reference = reference;
}
final public long time;
final public Reference reference;
}
private java.util.Map<String, EndpointTableEntry> _adapterEndpointsTable =
new java.util.HashMap<String, EndpointTableEntry>();
private java.util.Map<Ice.Identity, ReferenceTableEntry> _objectTable =
new java.util.HashMap<Ice.Identity, ReferenceTableEntry>();
}
|
