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
|
// **********************************************************************
//
// Copyright (c) 2003-2017 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.
//
// **********************************************************************
const Ice = require("../Ice/ModuleRegistry").Ice;
Ice._ModuleRegistry.require(module, ["../Ice/HashMap", "../Ice/Debug", "../Ice/IdentityUtil"]);
const HashMap = Ice.HashMap;
const Debug = Ice.Debug;
class EndpointTableEntry
{
constructor(time, endpoints)
{
this.time = time;
this.endpoints = endpoints;
}
}
class ReferenceTableEntry
{
constructor(time, reference)
{
this.time = time;
this.reference = reference;
}
}
class LocatorTable
{
constructor()
{
this._adapterEndpointsTable = new Map(); // Map<String, EndpointTableEntry>
this._objectTable = new HashMap(HashMap.compareEquals); // Map<Ice.Identity, ReferenceTableEntry>
}
clear()
{
this._adapterEndpointsTable.clear();
this._objectTable.clear();
}
getAdapterEndpoints(adapter, ttl, cached)
{
if(ttl === 0) // Locator cache disabled.
{
cached.value = false;
return null;
}
const entry = this._adapterEndpointsTable.get(adapter);
if(entry !== undefined)
{
cached.value = this.checkTTL(entry.time, ttl);
return entry.endpoints;
}
cached.value = false;
return null;
}
addAdapterEndpoints(adapter, endpoints)
{
this._adapterEndpointsTable.set(adapter, new EndpointTableEntry(Date.now(), endpoints));
}
removeAdapterEndpoints(adapter)
{
const entry = this._adapterEndpointsTable.get(adapter);
this._adapterEndpointsTable.delete(adapter);
return entry !== undefined ? entry.endpoints : null;
}
getObjectReference(id, ttl, cached)
{
if(ttl === 0) // Locator cache disabled.
{
cached.value = false;
return null;
}
const entry = this._objectTable.get(id);
if(entry !== undefined)
{
cached.value = this.checkTTL(entry.time, ttl);
return entry.reference;
}
cached.value = false;
return null;
}
addObjectReference(id, ref)
{
this._objectTable.set(id, new ReferenceTableEntry(Date.now(), ref));
}
removeObjectReference(id)
{
const entry = this._objectTable.get(id);
this._objectTable.delete(id);
return entry !== undefined ? entry.reference : null;
}
checkTTL(time, ttl)
{
Debug.assert(ttl !== 0);
if(ttl < 0) // TTL = infinite
{
return true;
}
else
{
return Date.now() - time <= (ttl * 1000);
}
}
}
Ice.LocatorTable = LocatorTable;
module.exports.Ice = Ice;
|
