blob: f7dcf5653cb5439d42a869d644025b1eb1a0465e (
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
75
76
77
78
79
80
81
82
|
// **********************************************************************
//
// 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;
public final class ACMConfig implements java.lang.Cloneable
{
ACMConfig(boolean server)
{
timeout = 60 * 1000;
heartbeat = Ice.ACMHeartbeat.HeartbeatOnInvocation;
close = server ? Ice.ACMClose.CloseOnInvocation : Ice.ACMClose.CloseOnInvocationAndIdle;
}
public ACMConfig(Ice.Properties p, Ice.Logger l, String prefix, ACMConfig dflt)
{
assert(prefix != null);
String timeoutProperty;
if((prefix.equals("Ice.ACM.Client") || prefix.equals("Ice.ACM.Server")) &&
p.getProperty(prefix + ".Timeout").isEmpty())
{
timeoutProperty = prefix; // Deprecated property.
}
else
{
timeoutProperty = prefix + ".Timeout";
};
timeout = p.getPropertyAsIntWithDefault(timeoutProperty, dflt.timeout / 1000) * 1000; // To milliseconds
int hb = p.getPropertyAsIntWithDefault(prefix + ".Heartbeat", dflt.heartbeat.ordinal());
Ice.ACMHeartbeat[] heartbeatValues = Ice.ACMHeartbeat.values();
if(hb >= 0 && hb < heartbeatValues.length)
{
heartbeat = heartbeatValues[hb];
}
else
{
l.warning("invalid value for property `" + prefix + ".Heartbeat" + "', default value will be used instead");
heartbeat = dflt.heartbeat;
}
Ice.ACMClose[] closeValues = Ice.ACMClose.values();
int cl = p.getPropertyAsIntWithDefault(prefix + ".Close", dflt.close.ordinal());
if(cl >= 0 && cl < closeValues.length)
{
close = closeValues[cl];
}
else
{
l.warning("invalid value for property `" + prefix + ".Close" + "', default value will be used instead");
close = dflt.close;
}
}
@Override
public java.lang.Object
clone()
{
java.lang.Object o = null;
try
{
o = super.clone();
}
catch(CloneNotSupportedException ex)
{
assert false; // impossible
}
return o;
}
public int timeout;
public Ice.ACMHeartbeat heartbeat;
public Ice.ACMClose close;
};
|
