diff options
Diffstat (limited to 'target_explorer/plugins/org.eclipse.tcf.te.tcf.locator/src/org/eclipse/tcf/te/tcf/locator/nodes/LocatorModel.java')
| -rw-r--r-- | target_explorer/plugins/org.eclipse.tcf.te.tcf.locator/src/org/eclipse/tcf/te/tcf/locator/nodes/LocatorModel.java | 785 |
1 files changed, 0 insertions, 785 deletions
diff --git a/target_explorer/plugins/org.eclipse.tcf.te.tcf.locator/src/org/eclipse/tcf/te/tcf/locator/nodes/LocatorModel.java b/target_explorer/plugins/org.eclipse.tcf.te.tcf.locator/src/org/eclipse/tcf/te/tcf/locator/nodes/LocatorModel.java deleted file mode 100644 index 45a47c802..000000000 --- a/target_explorer/plugins/org.eclipse.tcf.te.tcf.locator/src/org/eclipse/tcf/te/tcf/locator/nodes/LocatorModel.java +++ /dev/null @@ -1,785 +0,0 @@ -/******************************************************************************* - * 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.nodes; - -import java.util.ArrayList; -import java.util.Arrays; -import java.util.Collections; -import java.util.HashMap; -import java.util.List; -import java.util.Map; -import java.util.UUID; -import java.util.concurrent.atomic.AtomicReference; - -import org.eclipse.core.runtime.Assert; -import org.eclipse.core.runtime.PlatformObject; -import org.eclipse.core.runtime.jobs.Job; -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.core.Tcf; -import org.eclipse.tcf.te.tcf.core.listeners.interfaces.IChannelStateChangeListener; -import org.eclipse.tcf.te.tcf.locator.Scanner; -import org.eclipse.tcf.te.tcf.locator.activator.CoreBundleActivator; -import org.eclipse.tcf.te.tcf.locator.interfaces.IModelListener; -import org.eclipse.tcf.te.tcf.locator.interfaces.IScanner; -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.nodes.IPeerModel; -import org.eclipse.tcf.te.tcf.locator.interfaces.services.ILocatorModelLookupService; -import org.eclipse.tcf.te.tcf.locator.interfaces.services.ILocatorModelPeerNodeQueryService; -import org.eclipse.tcf.te.tcf.locator.interfaces.services.ILocatorModelRefreshService; -import org.eclipse.tcf.te.tcf.locator.interfaces.services.ILocatorModelService; -import org.eclipse.tcf.te.tcf.locator.interfaces.services.ILocatorModelUpdateService; -import org.eclipse.tcf.te.tcf.locator.listener.ChannelStateChangeListener; -import org.eclipse.tcf.te.tcf.locator.listener.LocatorListener; -import org.eclipse.tcf.te.tcf.locator.services.LocatorModelLookupService; -import org.eclipse.tcf.te.tcf.locator.services.LocatorModelPeerNodeQueryService; -import org.eclipse.tcf.te.tcf.locator.services.LocatorModelRefreshService; -import org.eclipse.tcf.te.tcf.locator.services.LocatorModelUpdateService; - - -/** - * Default locator model implementation. - */ -public class LocatorModel extends PlatformObject implements ILocatorModel { - // The unique model id - private final UUID uniqueId = UUID.randomUUID(); - // Flag to mark the model disposed - private boolean disposed; - - // The list of known peers - /* default */ final Map<String, IPeerModel> peers = new HashMap<String, IPeerModel>(); - // The list of "proxied" peers per proxy peer id - /* default */ final Map<String, List<IPeerModel>> peerChildren = new HashMap<String, List<IPeerModel>>(); - - // Reference to the scanner - private IScanner scanner = null; - - // Reference to the model locator listener - private ILocator.LocatorListener locatorListener = null; - // Reference to the model channel state change listener - private IChannelStateChangeListener channelStateChangeListener = null; - - // The list of registered model listeners - private final List<IModelListener> modelListener = new ArrayList<IModelListener>(); - - // Reference to the refresh service - private final ILocatorModelRefreshService refreshService = new LocatorModelRefreshService(this); - // Reference to the lookup service - private final ILocatorModelLookupService lookupService = new LocatorModelLookupService(this); - // Reference to the update service - private final ILocatorModelUpdateService updateService = new LocatorModelUpdateService(this); - // Reference to the query service - private final ILocatorModelPeerNodeQueryService queryService = new LocatorModelPeerNodeQueryService(this); - - /** - * Constructor. - */ - public LocatorModel() { - super(); - disposed = false; - - channelStateChangeListener = new ChannelStateChangeListener(this); - Tcf.addChannelStateChangeListener(channelStateChangeListener); - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.core.interfaces.nodes.ILocatorModel#addListener(org.eclipse.tcf.te.tcf.locator.core.interfaces.IModelListener) - */ - @Override - public void addListener(IModelListener listener) { - Assert.isNotNull(listener); - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.addListener( " + listener + " )", ITracing.ID_TRACE_LOCATOR_MODEL, this); //$NON-NLS-1$ //$NON-NLS-2$ - } - - if (!modelListener.contains(listener)) modelListener.add(listener); - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.core.interfaces.nodes.ILocatorModel#removeListener(org.eclipse.tcf.te.tcf.locator.core.interfaces.IModelListener) - */ - @Override - public void removeListener(IModelListener listener) { - Assert.isNotNull(listener); - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.removeListener( " + listener + " )", ITracing.ID_TRACE_LOCATOR_MODEL, this); //$NON-NLS-1$ //$NON-NLS-2$ - } - - modelListener.remove(listener); - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.interfaces.nodes.ILocatorModel#getListener() - */ - @Override - public IModelListener[] getListener() { - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - return modelListener.toArray(new IModelListener[modelListener.size()]); - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.core.interfaces.nodes.ILocatorModel#dispose() - */ - @Override - public void dispose() { - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.dispose()", ITracing.ID_TRACE_LOCATOR_MODEL, this); //$NON-NLS-1$ - } - - // If already disposed, we are done immediately - if (disposed) return; - - disposed = true; - - final IModelListener[] listeners = getListener(); - if (listeners.length > 0) { - Protocol.invokeLater(new Runnable() { - @Override - public void run() { - for (IModelListener listener : listeners) { - listener.locatorModelDisposed(LocatorModel.this); - } - } - }); - } - modelListener.clear(); - - if (locatorListener != null) { - Protocol.getLocator().removeListener(locatorListener); - locatorListener = null; - } - - if (channelStateChangeListener != null) { - Tcf.removeChannelStateChangeListener(channelStateChangeListener); - channelStateChangeListener = null; - } - - if (scanner != null) { - stopScanner(); - scanner = null; - } - - peers.clear(); - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.core.interfaces.nodes.ILocatorModel#isDisposed() - */ - @Override - public boolean isDisposed() { - return disposed; - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.core.interfaces.nodes.ILocatorModel#getPeers() - */ - @Override - public IPeerModel[] getPeers() { - final AtomicReference<IPeerModel[]> result = new AtomicReference<IPeerModel[]>(); - - Runnable runnable = new Runnable() { - @Override - public void run() { - result.set(peers.values().toArray(new IPeerModel[peers.values().size()])); - } - }; - - if (Protocol.isDispatchThread()) runnable.run(); - else Protocol.invokeAndWait(runnable); - - return result.get(); - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.interfaces.nodes.ILocatorModel#getChildren(java.lang.String) - */ - @Override - public List<IPeerModel> getChildren(final String parentPeerID) { - Assert.isNotNull(parentPeerID); - - final AtomicReference<List<IPeerModel>> result = new AtomicReference<List<IPeerModel>>(); - - Runnable runnable = new Runnable() { - @Override - public void run() { - List<IPeerModel> children = peerChildren.get(parentPeerID); - if (children == null) children = Collections.emptyList(); - result.set(children); - } - }; - - if (Protocol.isDispatchThread()) runnable.run(); - else Protocol.invokeAndWait(runnable); - - return Collections.unmodifiableList(result.get()); - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.interfaces.nodes.ILocatorModel#setChildren(java.lang.String, java.util.List) - */ - @Override - public void setChildren(String parentPeerID, List<IPeerModel> children) { - Assert.isNotNull(parentPeerID); - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - - if (children == null || children.size() == 0) { - peerChildren.remove(parentPeerID); - } else { - peerChildren.put(parentPeerID, new ArrayList<IPeerModel>(children)); - } - } - - /* (non-Javadoc) - * @see org.eclipse.core.runtime.PlatformObject#getAdapter(java.lang.Class) - */ - @Override - public Object getAdapter(Class adapter) { - if (adapter.isAssignableFrom(ILocator.LocatorListener.class)) { - return locatorListener; - } - if (adapter.isAssignableFrom(IScanner.class)) { - return scanner; - } - if (adapter.isAssignableFrom(ILocatorModelRefreshService.class)) { - return refreshService; - } - if (adapter.isAssignableFrom(ILocatorModelLookupService.class)) { - return lookupService; - } - if (adapter.isAssignableFrom(ILocatorModelUpdateService.class)) { - return updateService; - } - if (adapter.isAssignableFrom(ILocatorModelPeerNodeQueryService.class)) { - return queryService; - } - if (adapter.isAssignableFrom(Map.class)) { - return peers; - } - - return super.getAdapter(adapter); - } - - /* (non-Javadoc) - * @see java.lang.Object#hashCode() - */ - @Override - public int hashCode() { - return uniqueId.hashCode(); - } - - /* (non-Javadoc) - * @see java.lang.Object#equals(java.lang.Object) - */ - @Override - public final boolean equals(Object obj) { - if (obj instanceof LocatorModel) { - return uniqueId.equals(((LocatorModel)obj).uniqueId); - } - return super.equals(obj); - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.core.interfaces.nodes.ILocatorModel#getService(java.lang.Class) - */ - @Override - @SuppressWarnings("unchecked") - public <V extends ILocatorModelService> V getService(Class<V> serviceInterface) { - Assert.isNotNull(serviceInterface); - return (V)getAdapter(serviceInterface); - } - - /** - * Check if the locator listener has been created and registered - * to the global locator service. - * <p> - * <b>Note:</b> This method is not intended to be call from clients. - */ - public void checkLocatorListener() { - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - Assert.isNotNull(Protocol.getLocator()); - - if (locatorListener == null) { - locatorListener = doCreateLocatorListener(this); - Protocol.getLocator().addListener(locatorListener); - } - } - - /** - * Creates the locator listener instance. - * - * @param model The parent model. Must not be <code>null</code>. - * @return The locator listener instance. - */ - protected ILocator.LocatorListener doCreateLocatorListener(ILocatorModel model) { - Assert.isNotNull(model); - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - - return new LocatorListener(model); - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.core.interfaces.nodes.ILocatorModel#getScanner() - */ - @Override - public IScanner getScanner() { - if (scanner == null) scanner = new Scanner(this); - return scanner; - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.core.interfaces.nodes.ILocatorModel#startScanner(long, long) - */ - @Override - public void startScanner(long delay, long schedule) { - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.startScanner( " + delay + ", " + schedule + " )", ITracing.ID_TRACE_LOCATOR_MODEL, this); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ - } - - IScanner scanner = getScanner(); - Assert.isNotNull(scanner); - - // Pass on the schedule parameter - Map<String, Object> config = new HashMap<String, Object>(scanner.getConfiguration()); - config.put(IScanner.PROP_SCHEDULE, Long.valueOf(schedule)); - scanner.setConfiguration(config); - - // The default scanner implementation is a job. - // -> schedule here if it is a job - if (scanner instanceof Job) { - Job job = (Job)scanner; - job.setSystem(true); - job.setPriority(Job.DECORATE); - job.schedule(delay); - } - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.core.interfaces.nodes.ILocatorModel#stopScanner() - */ - @Override - public void stopScanner() { - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.stopScanner()", ITracing.ID_TRACE_LOCATOR_MODEL, this); //$NON-NLS-1$ - } - - if (scanner != null) { - // Terminate the scanner - scanner.terminate(); - // Reset the scanner reference - scanner = null; - } - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.interfaces.nodes.ILocatorModel#validatePeer(org.eclipse.tcf.protocol.IPeer) - */ - @Override - public IPeer validatePeer(IPeer peer) { - Assert.isNotNull(peer); - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.validatePeer( " + peer.getID() + " )", ITracing.ID_TRACE_LOCATOR_MODEL, this); //$NON-NLS-1$ //$NON-NLS-2$ - } - - IPeer result = peer; - - // Get the loopback address - String loopback = IPAddressUtil.getInstance().getIPv4LoopbackAddress(); - // Get the peer IP - String peerIP = peer.getAttributes().get(IPeer.ATTR_IP_HOST); - - // If the peer node is for local host, we ignore all peers not being - // associated with the loopback address. - if (IPAddressUtil.getInstance().isLocalHost(peerIP) && !loopback.equals(peerIP)) { - // Not loopback address -> drop the peer - result = null; - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.validatePeer: local host peer but not loopback address -> peer node dropped" //$NON-NLS-1$ - , ITracing.ID_TRACE_LOCATOR_MODEL, this); - } - } - - return result; - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.core.interfaces.nodes.ILocatorModel#validatePeerNodeForAdd(org.eclipse.tcf.te.tcf.locator.core.interfaces.nodes.IPeerModel) - */ - @Override - public IPeerModel validatePeerNodeForAdd(IPeerModel node) { - Assert.isNotNull(node); - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - - // Get the peer from the peer node - IPeer peer = node.getPeer(); - if (peer == null) return node; - - // Skip static peer IP address validation - boolean isStatic = node.isStatic(); - if (isStatic) return node; - - // Skip validation if the transport type is not TCP or SSL - String transport = peer.getTransportName(); - if (transport == null || !"TCP".equals(transport) && !"SSL".equals(transport)){ //$NON-NLS-1$ //$NON-NLS-2$ - return node; - } - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.validatePeerNodeForAdd( " + peer.getID() + " )", ITracing.ID_TRACE_LOCATOR_MODEL, this); //$NON-NLS-1$ //$NON-NLS-2$ - } - - IPeerModel result = node; - - // Get the loopback address - String loopback = IPAddressUtil.getInstance().getIPv4LoopbackAddress(); - // Get the peer IP - String peerIP = peer.getAttributes().get(IPeer.ATTR_IP_HOST); - - // If the peer node is for local host, we ignore all peers not being - // associated with the loopback address. - if (IPAddressUtil.getInstance().isLocalHost(peerIP) && !loopback.equals(peerIP)) { - boolean drop = true; - - // Simulator nodes appears on local host IP addresses too, but does not have - // a loopback peer available. We have to check the agent ID to determine if - // a specific node can be dropped - String agentID = peer.getAgentID(); - if (agentID != null) { - // Get all discovered peers - Map<String, IPeer> peers = Protocol.getLocator().getPeers(); - // Sort them by agent id - Map<String, List<IPeer>> byAgentID = new HashMap<String, List<IPeer>>(); - - for (IPeer candidate : peers.values()) { - if (candidate.getAgentID() == null) continue; - - List<IPeer> l = byAgentID.get(candidate.getAgentID()); - if (l == null) { - l = new ArrayList<IPeer>(); - byAgentID.put(candidate.getAgentID(), l); - } - Assert.isNotNull(l); - if (!l.contains(candidate)) l.add(candidate); - } - - // Check all peers found for the same agent ID as the current peer to validate - List<IPeer> candidates = byAgentID.get(agentID); - if (candidates != null && candidates.size() > 1) { - // Check if the found peers contains one with the loopback address - drop = false; - for (IPeer candidate : candidates) { - String ip = candidate.getAttributes().get(IPeer.ATTR_IP_HOST); - if (IPAddressUtil.getInstance().isLocalHost(ip) && loopback.equals(ip)) { - drop = true; - break; - } - } - } else { - // No other node for this agent ID -> do not drop the peer - drop = false; - } - } - - - if (drop) { - // Not loopback address -> drop the peer - result = null; - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.validatePeerNodeForAdd: local host peer but not loopback address -> peer node dropped", //$NON-NLS-1$ - ITracing.ID_TRACE_LOCATOR_MODEL, this); - } - } - } - - // Continue filtering if the node is not yet dropped - if (result != null) { - List<IPeerModel> previousNodes = new ArrayList<IPeerModel>(); - - // Peers are filtered by agent id. Don't add the peer node if we have another peer - // node already having the same agent id - String agentId = peer.getAgentID(); - if (agentId != null) { - previousNodes.addAll(Arrays.asList(getService(ILocatorModelLookupService.class).lkupPeerModelByAgentId(agentId))); - } - - // Lookup for matching static peer nodes not found by the agent id lookup - IPeerModel[] candidates = getService(ILocatorModelLookupService.class).lkupMatchingStaticPeerModels(peer); - for (IPeerModel candidate : candidates) { - if (!previousNodes.contains(candidate)) previousNodes.add(candidate); - } - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.validatePeerNodeForAdd: agentId=" + agentId + ", Matching peer nodes " //$NON-NLS-1$ //$NON-NLS-2$ - + (previousNodes.size() > 0 ? "found (" + previousNodes.size() +")" : "not found --> DONE") //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ - , ITracing.ID_TRACE_LOCATOR_MODEL, this); - } - - for (IPeerModel previousNode : previousNodes) { - // Get the peer for the previous node - IPeer previousPeer = previousNode.getPeer(); - if (previousPeer != null) { - // Get the IP address of the previous node - String previousPeerIP = previousPeer.getAttributes().get(IPeer.ATTR_IP_HOST); - if (IPAddressUtil.getInstance().isLocalHost(previousPeerIP) && !loopback.equals(previousPeerIP) && loopback.equals(peerIP)) { - // Remove the previous node from the model - getService(ILocatorModelUpdateService.class).remove(previousNode); - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.validatePeerNodeForAdd: Previous peer removed and replaced by new peer representing the loopback address" //$NON-NLS-1$ - , ITracing.ID_TRACE_LOCATOR_MODEL, this); - } - - continue; - } - - // Get the ports - String peerPort = peer.getAttributes().get(IPeer.ATTR_IP_PORT); - String previousPeerPort = previousPeer.getAttributes().get(IPeer.ATTR_IP_PORT); - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.validatePeerNodeForAdd: peerIP=" + peerIP //$NON-NLS-1$ - + ", peerPort=" + peerPort + ", previousPeerPort=" + previousPeerPort //$NON-NLS-1$ //$NON-NLS-2$ - , ITracing.ID_TRACE_LOCATOR_MODEL, this); - } - - // If the ports of the agent instances are identical, - // than try to find the best representation of the agent instance - if (peerPort != null && peerPort.equals(previousPeerPort)) { - // Drop the current node - result = null; - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.validatePeerNodeForAdd: Previous peer node kept, new peer node dropped" //$NON-NLS-1$ - , ITracing.ID_TRACE_LOCATOR_MODEL, this); - } - - - // Break the loop if the ports matched - break; - } - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.validatePeerNodeForAdd: Previous peer node kept, new peer node added (Port mismatch)" //$NON-NLS-1$ - , ITracing.ID_TRACE_LOCATOR_MODEL, this); - } - } - } - } - - return result; - } - - /* (non-Javadoc) - * @see org.eclipse.tcf.te.tcf.locator.interfaces.nodes.ILocatorModel#validateChildPeerNodeForAdd(org.eclipse.tcf.te.tcf.locator.interfaces.nodes.IPeerModel) - */ - @Override - public IPeerModel validateChildPeerNodeForAdd(final IPeerModel node) { - Assert.isNotNull(node); - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.validateChildPeerNodeForAdd( " + node.getPeerId() + " )", ITracing.ID_TRACE_LOCATOR_MODEL, this); //$NON-NLS-1$ //$NON-NLS-2$ - } - - // Determine the parent node. If null, the child node is invalid - // and cannot be added - final IPeerModel parent = node.getParent(IPeerModel.class); - if (parent == null) return null; - - return validateChildPeerNodeForAdd(parent, node); - } - - /** - * Validates the given child peer model node in relation to the given parent peer model node - * hierarchy. - * <p> - * The method is recursive. - * - * @param parent The parent model node. Must not be <code>null</code>. - * @param node The child model node. Must not be <code>null</code>. - * - * @return The validated child peer model node, or <code>null</code>. - */ - protected IPeerModel validateChildPeerNodeForAdd(IPeerModel parent, IPeerModel node) { - Assert.isNotNull(parent); - Assert.isNotNull(node); - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.validateChildPeerNodeForAdd( " + parent.getPeerId() + ", " + node.getPeerId() + " )", ITracing.ID_TRACE_LOCATOR_MODEL, this); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ - } - - // Validate against the given parent - if (doValidateChildPeerNodeForAdd(parent, node) == null) { - return null; - } - - // If the parent node is child node by itself, validate the - // child node against the parent parent node. - if (parent.getParent(IPeerModel.class) != null) { - IPeerModel parentParentNode = parent.getParent(IPeerModel.class); - if (doValidateChildPeerNodeForAdd(parentParentNode, node) == null) { - return null; - } - - // And validate the child node against all child nodes of the parent parent. - List<IPeerModel> childrenList = getChildren(parentParentNode.getPeerId()); - IPeerModel[] children = childrenList.toArray(new IPeerModel[childrenList.size()]); - for (IPeerModel parentParentChild : children) { - if (node.equals(parentParentChild) || parent.equals(parentParentChild)) { - return null; - } - if (doValidateChildPeerNodeForAdd(parentParentChild, node) == null) { - return null; - } - } - } - - return node; - } - - /** - * Validates the given child peer model node in relation to the given parent peer model node. - * <p> - * The method is non-recursive. - * - * @param parent The parent model node. Must not be <code>null</code>. - * @param node The child model node. Must not be <code>null</code>. - * - * @return The validated child peer model node, or <code>null</code>. - */ - protected IPeerModel doValidateChildPeerNodeForAdd(IPeerModel parent, IPeerModel node) { - Assert.isNotNull(parent); - Assert.isNotNull(node); - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - - if (CoreBundleActivator.getTraceHandler().isSlotEnabled(0, ITracing.ID_TRACE_LOCATOR_MODEL)) { - CoreBundleActivator.getTraceHandler().trace("LocatorModel.doValidateChildPeerNodeForAdd( " + parent.getPeerId() + ", " + node.getPeerId() + " )", ITracing.ID_TRACE_LOCATOR_MODEL, this); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ - } - - // If the child node is already visible as root node, drop the child node - String id = node.getPeerId(); - if (isRootNode(id)) { - return null; - } - - int beginIndex = id.indexOf(':'); - int endIndex = id.lastIndexOf(':'); - String ip = beginIndex != -1 && endIndex != -1 ? id.substring(beginIndex+1, endIndex) : ""; //$NON-NLS-1$ - - // Get the loopback address - String loopback = IPAddressUtil.getInstance().getIPv4LoopbackAddress(); - // Empty IP address means loopback - if ("".equals(ip)) ip = loopback; //$NON-NLS-1$ - - // If the IP is a localhost IP, try the loopback IP - if (IPAddressUtil.getInstance().isLocalHost(ip)) { - // Build up the new id to lookup - StringBuilder newId = new StringBuilder(); - newId.append(id.substring(0, beginIndex)); - newId.append(':'); - newId.append(loopback); - newId.append(':'); - newId.append(id.substring(endIndex + 1)); - - // Try the lookup again - if (isRootNode(newId.toString())) { - return null; - } - } - - // Get the peer from the peer node - IPeer peer = node.getPeer(); - - // If the child peer represents the same agent as the parent peer, - // drop the child peer - String parentAgentID = parent.getPeer().getAgentID(); - if (parentAgentID != null && parentAgentID.equals(peer.getAgentID())) { - return null; - } - // If the child peer represents the same agent as another child peer, - // drop the child peer - String agentID = node.getPeer().getAgentID(); - if (agentID != null) { - IPeerModel[] matches = getService(ILocatorModelLookupService.class).lkupPeerModelByAgentId(parent.getPeerId(), agentID); - for (IPeerModel match : matches) { - if (agentID.equals(match.getPeer().getAgentID())) { - // Try to keep the peer with the real IP, filter the "127.0.0.1" peer - if ("127.0.0.1".equals(node.getPeer().getAttributes().get(IPeer.ATTR_IP_HOST)) //$NON-NLS-1$ - && !"127.0.0.1".equals(match.getPeer().getAttributes().get(IPeer.ATTR_IP_HOST))) { //$NON-NLS-1$ - // Keep the other child node - return null; - } - - if (!"127.0.0.1".equals(node.getPeer().getAttributes().get(IPeer.ATTR_IP_HOST)) //$NON-NLS-1$ - && "127.0.0.1".equals(match.getPeer().getAttributes().get(IPeer.ATTR_IP_HOST))) { //$NON-NLS-1$ - // Keep the node - getService(ILocatorModelUpdateService.class).removeChild(match); - } - - // If both nodes have a IP different from "127.0.0.1", keep the first node - if (!"127.0.0.1".equals(node.getPeer().getAttributes().get(IPeer.ATTR_IP_HOST)) //$NON-NLS-1$ - && !"127.0.0.1".equals(match.getPeer().getAttributes().get(IPeer.ATTR_IP_HOST))) { //$NON-NLS-1$ - // Keep the other child node - return null; - } - } - } - } - // If the child peer's IP address and port are the same as the parent's - // IP address and port, drop the child node - Map<String, String> parentPeerAttributes = parent.getPeer().getAttributes(); - if (parentPeerAttributes.get(IPeer.ATTR_IP_HOST) != null && parentPeerAttributes.get(IPeer.ATTR_IP_HOST).equals(peer.getAttributes().get(IPeer.ATTR_IP_HOST))) { - String parentPort = parentPeerAttributes.get(IPeer.ATTR_IP_PORT); - String port = peer.getAttributes().get(IPeer.ATTR_IP_PORT); - - if (parentPort != null && parentPort.equals(port)) return null; - } - - return node; - } - - /** - * Checks if the given peer id belongs to an already known root node - * or to one of the discovered nodes. - * - * @param id The peer id. Must not be <code>null</code>. - * @return <code>True</code> if the given id belongs to a root node, <code>false</code> otherwise. - */ - private boolean isRootNode(String id) { - Assert.isTrue(Protocol.isDispatchThread(), "Illegal Thread Access"); //$NON-NLS-1$ - Assert.isNotNull(id); - - boolean isRoot = false; - - if (getService(ILocatorModelLookupService.class).lkupPeerModelById(id) != null) { - isRoot = true; - } else { - Map<String, IPeer> peers = Protocol.getLocator().getPeers(); - if (peers.containsKey(id)) { - isRoot = true; - } - } - - return isRoot; - } -} |