blob: e004281aa003be017b5225d655dbc6ba9be78986 (
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
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
|
// **********************************************************************
//
// Copyright (c) 2003-2009 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 test.Ice.hold;
import test.Ice.hold.Test._HoldDisp;
public final class HoldI extends _HoldDisp
{
private static void
test(boolean b)
{
if(!b)
{
throw new RuntimeException();
}
}
HoldI(java.util.Timer timer, Ice.ObjectAdapter adapter)
{
_timer = timer;
_adapter = adapter;
_last = 0;
}
public void
putOnHold(int milliSeconds, Ice.Current current)
{
if(milliSeconds < 0)
{
_adapter.hold();
}
else if(milliSeconds == 0)
{
_adapter.hold();
_adapter.activate();
}
else
{
_timer.schedule(new java.util.TimerTask()
{
public void
run()
{
try
{
putOnHold(0, null);
}
catch(Ice.ObjectAdapterDeactivatedException ex)
{
}
}
}, milliSeconds);
}
}
public void
waitForHold(final Ice.Current current)
{
_timer.schedule(new java.util.TimerTask()
{
public void
run()
{
try
{
current.adapter.waitForHold();
current.adapter.activate();
}
catch(Ice.ObjectAdapterDeactivatedException ex)
{
//
// This shouldn't occur. The test ensures all the waitForHold timers are
// finished before shutting down the communicator.
//
test(false);
}
}
}, 0);
}
public int
set(int value, int delay, Ice.Current current)
{
try
{
Thread.sleep(delay);
}
catch(java.lang.InterruptedException ex)
{
}
synchronized(this)
{
int tmp = _last;
_last = value;
return tmp;
}
}
synchronized public void
setOneway(int value, int expected, Ice.Current current)
{
if(_last != expected)
{
System.err.println("_last = " + _last + " expected = " + expected);
_adapter.getCommunicator().shutdown();
test(false);
}
_last = value;
}
public void
shutdown(Ice.Current current)
{
_adapter.hold();
_adapter.getCommunicator().shutdown();
}
final private java.util.Timer _timer;
final private Ice.ObjectAdapter _adapter;
int _last = 0;
}
|
