blob: 8bb9d9dddf9d6f1ac3a60d1cd1a201e782915e1a (
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
132
133
134
135
|
// **********************************************************************
//
// 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 IceGridGUI;
import javax.swing.SwingUtilities;
import IceGrid.*;
class NodeObserverI extends _NodeObserverDisp
{
NodeObserverI(Coordinator coordinator)
{
_coordinator = coordinator;
_trace = _coordinator.traceObservers();
}
@Override
public void nodeInit(final NodeDynamicInfo[] nodes, Ice.Current current)
{
if(_trace)
{
if(nodes.length == 0)
{
_coordinator.traceObserver("nodeInit (no node)");
}
else
{
String names = "";
for(NodeDynamicInfo node : nodes)
{
names += " " + node.info.name;
}
_coordinator.traceObserver("nodeInit for node" + (nodes.length == 1 ? "" : "s") + names);
}
}
SwingUtilities.invokeLater(new Runnable()
{
@Override
public void run()
{
for(NodeDynamicInfo node : nodes)
{
_coordinator.nodeUp(node);
}
}
});
}
@Override
public void nodeUp(final NodeDynamicInfo nodeInfo, Ice.Current current)
{
if(_trace)
{
_coordinator.traceObserver("nodeUp for node " + nodeInfo.info.name);
}
SwingUtilities.invokeLater(new Runnable()
{
@Override
public void run()
{
_coordinator.nodeUp(nodeInfo);
}
});
}
@Override
public void nodeDown(final String nodeName, Ice.Current current)
{
if(_trace)
{
_coordinator.traceObserver("nodeUp for node " + nodeName);
}
SwingUtilities.invokeLater(new Runnable()
{
@Override
public void run()
{
_coordinator.nodeDown(nodeName);
}
});
}
@Override
public void updateServer(final String node, final ServerDynamicInfo updatedInfo, Ice.Current current)
{
if(_trace)
{
_coordinator.traceObserver("updateServer for server " + updatedInfo.id
+ " on node " + node + "; new state is "
+ updatedInfo.state.toString());
}
SwingUtilities.invokeLater(new Runnable()
{
@Override
public void run()
{
_coordinator.updateServer(node, updatedInfo);
}
});
}
@Override
public void updateAdapter(final String node, final AdapterDynamicInfo updatedInfo, Ice.Current current)
{
if(_trace)
{
_coordinator.traceObserver("updateAdapter for adapter " + updatedInfo.id
+ " on node " + node + "; new proxy is "
+ (updatedInfo.proxy == null ? "null"
: updatedInfo.proxy.toString()));
}
SwingUtilities.invokeLater(new Runnable()
{
@Override
public void run()
{
_coordinator.updateAdapter(node, updatedInfo);
}
});
}
private final Coordinator _coordinator;
private final boolean _trace;
}
|
