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
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
|
/*******************************************************************************
* Copyright (c) 2011, 2013 Wind River Systems, Inc. and others. All rights reserved.
* This program and the accompanying materials are made available under the terms
* of the Eclipse Public License v1.0 which accompanies this distribution, and is
* available at http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* Wind River Systems - initial API and implementation
*******************************************************************************/
package org.eclipse.tcf.te.tcf.locator.listener;
import org.eclipse.core.runtime.Assert;
import org.eclipse.tcf.protocol.IPeer;
import org.eclipse.tcf.protocol.Protocol;
import org.eclipse.tcf.services.ILocator;
import org.eclipse.tcf.te.runtime.utils.net.IPAddressUtil;
import org.eclipse.tcf.te.tcf.locator.activator.CoreBundleActivator;
import org.eclipse.tcf.te.tcf.locator.interfaces.ITracing;
import org.eclipse.tcf.te.tcf.locator.interfaces.nodes.ILocatorModel;
import org.eclipse.tcf.te.tcf.locator.interfaces.services.ILocatorModelLookupService;
import org.eclipse.tcf.te.tcf.locator.interfaces.services.ILocatorModelUpdateService;
/**
* Locator listener implementation.
*/
public final class LocatorListener implements ILocator.LocatorListener {
// Reference to the parent model
/* default */ final ILocatorModel model;
/**
* Constructor.
*
* @param model The parent locator model. Must not be <code>null</code>.
*/
public LocatorListener(ILocatorModel model) {
super();
Assert.isNotNull(model);
this.model = model;
}
/**
* Returns if or if not the given peer is filtered.
*
* @param peer The peer or <code>null</code>.
* @return <code>True</code> if the given peer is filtered, <code>false</code> otherwise.
*/
private boolean isFiltered(IPeer peer) {
boolean filtered = peer == null;
boolean hideValueAdds = CoreBundleActivator.getScopedPreferences().getBoolean(org.eclipse.tcf.te.tcf.locator.interfaces.preferences.IPreferenceKeys.PREF_HIDE_VALUEADDS);
if (!filtered) {
String value = peer.getAttributes().get("ValueAdd"); //$NON-NLS-1$
boolean isValueAdd = value != null && ("1".equals(value.trim()) || Boolean.parseBoolean(value.trim())); //$NON-NLS-1$
filtered |= isValueAdd && hideValueAdds;
filtered |= peer.getName() != null
&& peer.getName().endsWith("Command Server"); //$NON-NLS-1$
}
return filtered;
}
/* (non-Javadoc)
* @see org.eclipse.tcf.services.ILocator.LocatorListener#peerAdded(org.eclipse.tcf.protocol.IPeer)
*/
@Override
public void peerAdded(IPeer peer) {
Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$
if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_LISTENER)) {
CoreBundleActivator.getTraceHandler().trace("LocatorListener.peerAdded( " + (peer != null ? peer.getID() : null) + " )", ITracing.ID_TRACE_LOCATOR_LISTENER, this); //$NON-NLS-1$ //$NON-NLS-2$
}
if (isFiltered(peer)) return;
if (model != null && peer != null) {
IPeer lkupPeer = model.getService(ILocatorModelLookupService.class).lkupPeerById(peer.getID());
if (lkupPeer == null) {
// Double check with "ClientID" if set
String clientID = peer.getAttributes().get("ClientID"); //$NON-NLS-1$
if (clientID != null) {
lkupPeer = model.getService(ILocatorModelLookupService.class).lkupPeerById(clientID);
}
}
if (lkupPeer == null) {
model.getService(ILocatorModelUpdateService.class).add(peer);
}
}
}
/* (non-Javadoc)
* @see org.eclipse.tcf.services.ILocator.LocatorListener#peerChanged(org.eclipse.tcf.protocol.IPeer)
*/
@Override
public void peerChanged(IPeer peer) {
Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$
if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_LISTENER)) {
CoreBundleActivator.getTraceHandler().trace("LocatorListener.peerChanged( " + (peer != null ? peer.getID() : null) + " )", ITracing.ID_TRACE_LOCATOR_LISTENER, this); //$NON-NLS-1$ //$NON-NLS-2$
}
if (isFiltered(peer)) return;
if (model != null && peer != null) {
// find the corresponding model node to remove
IPeer lkupPeer = model.getService(ILocatorModelLookupService.class).lkupPeerById(peer.getID());
if (lkupPeer == null) {
// Double check with "ClientID" if set
String clientID = peer.getAttributes().get("ClientID"); //$NON-NLS-1$
if (clientID != null) {
lkupPeer = model.getService(ILocatorModelLookupService.class).lkupPeerById(clientID);
}
}
// Update the peer instance
if (lkupPeer != null) {
model.getService(ILocatorModelUpdateService.class).update(lkupPeer, peer);
}
}
}
/* (non-Javadoc)
* @see org.eclipse.tcf.services.ILocator.LocatorListener#peerRemoved(java.lang.String)
*/
@Override
public void peerRemoved(String id) {
Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$
if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_LISTENER)) {
CoreBundleActivator.getTraceHandler().trace("LocatorListener.peerRemoved( " + id + " )", ITracing.ID_TRACE_LOCATOR_LISTENER, this); //$NON-NLS-1$ //$NON-NLS-2$
}
if (model != null && id != null) {
// find the corresponding model node to remove
IPeer lkupPeer = model.getService(ILocatorModelLookupService.class).lkupPeerById(id);
// If we cannot find a model node, it is probably because the remove is sent for the
// non-loopback addresses of the localhost. We have to double check this.
if (lkupPeer == null) {
int beginIndex = id.indexOf(':');
int endIndex = id.lastIndexOf(':');
String ip = id.substring(beginIndex+1, endIndex);
// Get the loopback address
String loopback = IPAddressUtil.getInstance().getIPv4LoopbackAddress();
// Empty IP address means loopback
if ("".equals(ip)) ip = loopback; //$NON-NLS-1$
else {
if (IPAddressUtil.getInstance().isLocalHost(ip)) {
ip = loopback;
}
}
// Build up the new id to lookup
StringBuilder newId = new StringBuilder();
newId.append(id.substring(0, beginIndex));
newId.append(':');
newId.append(ip);
newId.append(':');
newId.append(id.substring(endIndex + 1));
// Try the lookup again
lkupPeer = model.getService(ILocatorModelLookupService.class).lkupPeerById(newId.toString());
}
// If the model node is found in the model, process the removal.
if (lkupPeer != null) {
model.getService(ILocatorModelUpdateService.class).remove(lkupPeer);
}
}
}
/* (non-Javadoc)
* @see org.eclipse.tcf.services.ILocator.LocatorListener#peerHeartBeat(java.lang.String)
*/
@Override
public void peerHeartBeat(String id) {
Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$
if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_LISTENER)) {
CoreBundleActivator.getTraceHandler().trace("LocatorListener.peerHeartBeat( " + id + " )", ITracing.ID_TRACE_LOCATOR_LISTENER, this); //$NON-NLS-1$ //$NON-NLS-2$
}
}
}
|
