diff options
Diffstat (limited to 'incubation/bundles/org.eclipse.ecf.osgi.services.remoteserviceadmin/src/org/eclipse/ecf/osgi/services/remoteserviceadmin/LocatorServiceListener.java')
| -rw-r--r-- | incubation/bundles/org.eclipse.ecf.osgi.services.remoteserviceadmin/src/org/eclipse/ecf/osgi/services/remoteserviceadmin/LocatorServiceListener.java | 168 |
1 files changed, 0 insertions, 168 deletions
diff --git a/incubation/bundles/org.eclipse.ecf.osgi.services.remoteserviceadmin/src/org/eclipse/ecf/osgi/services/remoteserviceadmin/LocatorServiceListener.java b/incubation/bundles/org.eclipse.ecf.osgi.services.remoteserviceadmin/src/org/eclipse/ecf/osgi/services/remoteserviceadmin/LocatorServiceListener.java deleted file mode 100644 index 66a3bc170..000000000 --- a/incubation/bundles/org.eclipse.ecf.osgi.services.remoteserviceadmin/src/org/eclipse/ecf/osgi/services/remoteserviceadmin/LocatorServiceListener.java +++ /dev/null @@ -1,168 +0,0 @@ -/******************************************************************************* - * Copyright (c) 2010-2011 Composent, 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: - * Composent, Inc. - initial API and implementation - ******************************************************************************/ -package org.eclipse.ecf.osgi.services.remoteserviceadmin; - -import java.util.ArrayList; -import java.util.Arrays; -import java.util.Collection; -import java.util.List; - -import org.eclipse.ecf.discovery.IDiscoveryLocator; -import org.eclipse.ecf.discovery.IServiceEvent; -import org.eclipse.ecf.discovery.IServiceInfo; -import org.eclipse.ecf.discovery.IServiceListener; -import org.eclipse.ecf.discovery.identity.IServiceID; -import org.eclipse.ecf.internal.osgi.services.remoteserviceadmin.DebugOptions; -import org.eclipse.ecf.internal.osgi.services.remoteserviceadmin.LogUtility; - -class LocatorServiceListener implements IServiceListener { - - private Object listenerLock = new Object(); - private IDiscoveryLocator locator; - private EndpointDescriptionLocator endpointDescriptionLocator; - - private List<org.osgi.service.remoteserviceadmin.EndpointDescription> discoveredEndpointDescriptions = new ArrayList(); - - public LocatorServiceListener( - EndpointDescriptionLocator endpointDescriptionLocator) { - this(endpointDescriptionLocator, null); - } - - public LocatorServiceListener( - EndpointDescriptionLocator endpointDescriptionLocator, - IDiscoveryLocator locator) { - this.endpointDescriptionLocator = endpointDescriptionLocator; - this.locator = locator; - if (locator != null) { - this.locator.addServiceListener(this); - } - } - - public void serviceDiscovered(IServiceEvent anEvent) { - handleService(anEvent.getServiceInfo(), true); - } - - public void serviceUndiscovered(IServiceEvent anEvent) { - handleService(anEvent.getServiceInfo(), false); - } - - private boolean matchServiceID(IServiceID serviceId) { - if (Arrays.asList(serviceId.getServiceTypeID().getServices()).contains( - RemoteConstants.SERVICE_TYPE)) - return true; - return false; - } - - void handleService(IServiceInfo serviceInfo, boolean discovered) { - IServiceID serviceID = serviceInfo.getServiceID(); - if (matchServiceID(serviceID)) - handleOSGiServiceEndpoint(serviceID, serviceInfo, discovered); - } - - private void handleOSGiServiceEndpoint(IServiceID serviceId, - IServiceInfo serviceInfo, boolean discovered) { - if (locator == null) - return; - DiscoveredEndpointDescription discoveredEndpointDescription = getDiscoveredEndpointDescription( - serviceId, serviceInfo, discovered); - if (discoveredEndpointDescription != null) { - handleEndpointDescription( - discoveredEndpointDescription.getEndpointDescription(), - discovered); - } else { - logWarning("handleOSGiServiceEvent", //$NON-NLS-1$ - "discoveredEndpointDescription is null for service info=" //$NON-NLS-1$ - + serviceInfo + ",discovered=" + discovered); //$NON-NLS-1$ - } - } - - public void handleEndpointDescription( - org.osgi.service.remoteserviceadmin.EndpointDescription endpointDescription, - boolean discovered) { - synchronized (listenerLock) { - if (discovered) - discoveredEndpointDescriptions.add(endpointDescription); - else - discoveredEndpointDescriptions.remove(endpointDescription); - - endpointDescriptionLocator.queueEndpointDescription( - endpointDescription, discovered); - } - } - - public Collection<org.osgi.service.remoteserviceadmin.EndpointDescription> getEndpointDescriptions() { - synchronized (listenerLock) { - Collection<org.osgi.service.remoteserviceadmin.EndpointDescription> result = new ArrayList<org.osgi.service.remoteserviceadmin.EndpointDescription>(); - result.addAll(discoveredEndpointDescriptions); - return result; - } - } - - private void logWarning(String methodName, String message) { - LogUtility.logWarning(methodName, DebugOptions.DISCOVERY, - this.getClass(), message); - } - - private void logError(String methodName, String message) { - logError(methodName, message, null); - } - - private void logError(String methodName, String message, Throwable t) { - LogUtility.logError(methodName, DebugOptions.DISCOVERY, - this.getClass(), message, t); - } - - private DiscoveredEndpointDescription getDiscoveredEndpointDescription( - IServiceID serviceId, IServiceInfo serviceInfo, boolean discovered) { - // Get IEndpointDescriptionFactory - final String methodName = "getDiscoveredEndpointDescription"; //$NON-NLS-1$ - IDiscoveredEndpointDescriptionFactory factory = endpointDescriptionLocator - .getDiscoveredEndpointDescriptionFactory(); - if (factory == null) { - logError( - methodName, - "No IEndpointDescriptionFactory found, could not create EndpointDescription for " //$NON-NLS-1$ - + (discovered ? "discovered" : "undiscovered") //$NON-NLS-1$ //$NON-NLS-2$ - + " serviceInfo=" + serviceInfo); //$NON-NLS-1$ - return null; - } - try { - // Else get endpoint description factory to create - // EndpointDescription - // for given serviceID and serviceInfo - return (discovered) ? factory.createDiscoveredEndpointDescription( - locator, serviceInfo) : factory - .getUndiscoveredEndpointDescription(locator, serviceId); - } catch (Exception e) { - logError( - methodName, - "Exception calling IEndpointDescriptionFactory." //$NON-NLS-1$ - + ((discovered) ? "createDiscoveredEndpointDescription" //$NON-NLS-1$ - : "getUndiscoveredEndpointDescription"), e); //$NON-NLS-1$ - return null; - } catch (NoClassDefFoundError e) { - logError( - methodName, - "NoClassDefFoundError calling IEndpointDescriptionFactory." //$NON-NLS-1$ - + ((discovered) ? "createDiscoveredEndpointDescription" //$NON-NLS-1$ - : "getUndiscoveredEndpointDescription"), e); //$NON-NLS-1$ - return null; - } - } - - public synchronized void close() { - if (locator != null) { - locator.removeServiceListener(this); - locator = null; - } - endpointDescriptionLocator = null; - discoveredEndpointDescriptions.clear(); - } -}
\ No newline at end of file |