diff options
Diffstat (limited to 'bundles/org.eclipse.equinox.ds/src/org/eclipse')
| -rw-r--r-- | bundles/org.eclipse.equinox.ds/src/org/eclipse/equinox/internal/ds/Activator.java | 33 | ||||
| -rw-r--r-- | bundles/org.eclipse.equinox.ds/src/org/eclipse/equinox/internal/ds/ScrServiceImpl.java | 346 |
2 files changed, 378 insertions, 1 deletions
diff --git a/bundles/org.eclipse.equinox.ds/src/org/eclipse/equinox/internal/ds/Activator.java b/bundles/org.eclipse.equinox.ds/src/org/eclipse/equinox/internal/ds/Activator.java index 6c8e325c1..509d77514 100644 --- a/bundles/org.eclipse.equinox.ds/src/org/eclipse/equinox/internal/ds/Activator.java +++ b/bundles/org.eclipse.equinox.ds/src/org/eclipse/equinox/internal/ds/Activator.java @@ -11,18 +11,26 @@ package org.eclipse.equinox.internal.ds; import java.util.List; +import org.apache.felix.scr.ScrService; import org.eclipse.osgi.service.environment.EnvironmentInfo; import org.osgi.framework.*; import org.osgi.framework.namespace.BundleNamespace; import org.osgi.framework.startlevel.BundleStartLevel; import org.osgi.framework.wiring.BundleWire; import org.osgi.framework.wiring.BundleWiring; +import org.osgi.service.component.runtime.ServiceComponentRuntime; +import org.osgi.util.tracker.ServiceTracker; +import org.osgi.util.tracker.ServiceTrackerCustomizer; -public class Activator implements BundleActivator { +@SuppressWarnings("deprecation") +public class Activator implements BundleActivator, ServiceTrackerCustomizer<ServiceComponentRuntime, ServiceRegistration<ScrService>> { + private BundleContext bc; private Bundle scr; + private ServiceTracker<ServiceComponentRuntime, ServiceRegistration<ScrService>> tracker; public void start(BundleContext context) throws Exception { + this.bc = context; ServiceReference<EnvironmentInfo> envInfoRef = context.getServiceReference(EnvironmentInfo.class); EnvironmentInfo envInfo = null; if (envInfoRef != null) { @@ -50,10 +58,33 @@ public class Activator implements BundleActivator { BundleStartLevel scrStartLevel = scr.adapt(BundleStartLevel.class); scrStartLevel.setStartLevel(equinoxSDstartLevel.getStartLevel()); scr.start(Bundle.START_TRANSIENT); + tracker = new ServiceTracker<ServiceComponentRuntime, ServiceRegistration<ScrService>>(context, ServiceComponentRuntime.class, this); + tracker.open(); } public void stop(BundleContext context) throws Exception { + tracker.close(); scr.stop(Bundle.STOP_TRANSIENT); } + @Override + public ServiceRegistration<ScrService> addingService(ServiceReference<ServiceComponentRuntime> reference) { + ServiceComponentRuntime scrService = bc.getService(reference); + if (scr != null) { + return bc.registerService(ScrService.class, new ScrServiceImpl(scrService, bc), null); + } + return null; + } + + @Override + public void modifiedService(ServiceReference<ServiceComponentRuntime> reference, ServiceRegistration<ScrService> reg) { + // do nothing + } + + @Override + public void removedService(ServiceReference<ServiceComponentRuntime> reference, ServiceRegistration<ScrService> reg) { + reg.unregister(); + bc.ungetService(reference); + } + } diff --git a/bundles/org.eclipse.equinox.ds/src/org/eclipse/equinox/internal/ds/ScrServiceImpl.java b/bundles/org.eclipse.equinox.ds/src/org/eclipse/equinox/internal/ds/ScrServiceImpl.java new file mode 100644 index 000000000..7f5a97f35 --- /dev/null +++ b/bundles/org.eclipse.equinox.ds/src/org/eclipse/equinox/internal/ds/ScrServiceImpl.java @@ -0,0 +1,346 @@ +/******************************************************************************* + * Copyright (c) 2017 IBM Corporation 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: + * IBM Corporation - initial API and implementation + *******************************************************************************/ +package org.eclipse.equinox.internal.ds; + +import java.util.*; +import java.util.Map.Entry; +import org.apache.felix.scr.*; +import org.osgi.framework.*; +import org.osgi.framework.dto.ServiceReferenceDTO; +import org.osgi.service.component.ComponentConstants; +import org.osgi.service.component.ComponentInstance; +import org.osgi.service.component.runtime.ServiceComponentRuntime; +import org.osgi.service.component.runtime.dto.*; + +@Deprecated +public class ScrServiceImpl implements ScrService { + final ServiceComponentRuntime scr; + final BundleContext context; + + ScrServiceImpl(ServiceComponentRuntime scr, BundleContext context) { + this.scr = scr; + this.context = context.getBundle(Constants.SYSTEM_BUNDLE_LOCATION).getBundleContext(); + } + + @Override + public Component[] getComponents() { + return toComponents(scr.getComponentDescriptionDTOs()); + } + + private Component[] toComponents(Collection<ComponentDescriptionDTO> componentDescriptionDTOs) { + // TODO Auto-generated method stub + return null; + } + + @Override + public Component getComponent(long componentId) { + for (ComponentDescriptionDTO dto : scr.getComponentDescriptionDTOs()) { + Long id = (Long) dto.properties.get(ComponentConstants.COMPONENT_ID); + if (componentId == id) { + return toComponent(dto); + } + } + return null; + } + + private Component toComponent(ComponentDescriptionDTO dto) { + // TODO Auto-generated method stub + return null; + } + + @Override + public Component[] getComponents(String componentName) { + Collection<ComponentDescriptionDTO> dtos = new ArrayList<ComponentDescriptionDTO>(); + for (ComponentDescriptionDTO dto : scr.getComponentDescriptionDTOs()) { + if (componentName.equals(dto.name)) { + dtos.add(dto); + } + } + return toComponents(dtos); + } + + @Override + public Component[] getComponents(Bundle bundle) { + return toComponents(scr.getComponentDescriptionDTOs(bundle)); + } + + ServiceReference<?> getServiceReference(long id) { + try { + ServiceReference<?>[] refs = context.getServiceReferences((String) null, "(" + Constants.SERVICE_ID + "=" + id + ")"); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ + if (refs != null && refs.length > 0) { + return refs[0]; + } + } catch (InvalidSyntaxException e) { + throw new RuntimeException(e); + } + return null; + } + + class ComponentImpl implements Component { + private final ComponentConfigurationDTO config; + + ComponentImpl(ComponentConfigurationDTO config) { + this.config = config; + } + + @Override + public long getId() { + return config.id; + } + + @Override + public String getName() { + return config.description.name; + } + + @Override + public int getState() { + switch (config.state) { + case ComponentConfigurationDTO.ACTIVE : + return Component.STATE_ACTIVE; + case ComponentConfigurationDTO.SATISFIED : + return Component.STATE_REGISTERED; + case ComponentConfigurationDTO.UNSATISFIED_CONFIGURATION : + return Component.STATE_UNSATISFIED; + case ComponentConfigurationDTO.UNSATISFIED_REFERENCE : + return Component.STATE_UNSATISFIED; + default : + break; + } + return Component.STATE_DISABLED; + } + + @Override + public Bundle getBundle() { + return context.getBundle(config.description.bundle.id); + } + + @Override + public String getFactory() { + return config.description.factory; + } + + @Override + public boolean isServiceFactory() { + return Constants.SCOPE_BUNDLE.equals(config.description.scope); + } + + @Override + public String getClassName() { + return config.description.implementationClass; + } + + @Override + public boolean isDefaultEnabled() { + return config.description.defaultEnabled; + } + + @Override + public boolean isImmediate() { + return config.description.immediate; + } + + @Override + public String[] getServices() { + return config.description.serviceInterfaces; + } + + @SuppressWarnings({"rawtypes", "unchecked"}) + @Override + public Dictionary getProperties() { + return new Hashtable(config.description.properties); + } + + @Override + public Reference[] getReferences() { + if (config.description.references.length == 0) { + return null; + } + Map<String, ReferenceDTO> referenceDTOs = new HashMap<String, ReferenceDTO>(); + for (ReferenceDTO reference : config.description.references) { + referenceDTOs.put(reference.name, reference); + } + Map<String, SatisfiedReferenceDTO> satisfiedDTOs = new HashMap<String, SatisfiedReferenceDTO>(); + for (SatisfiedReferenceDTO satisfied : config.satisfiedReferences) { + satisfiedDTOs.put(satisfied.name, satisfied); + } + Map<String, UnsatisfiedReferenceDTO> unsatisfiedDTOs = new HashMap<String, UnsatisfiedReferenceDTO>(); + for (UnsatisfiedReferenceDTO unsatisfied : config.unsatisfiedReferences) { + unsatisfiedDTOs.put(unsatisfied.name, unsatisfied); + } + return toReferences(referenceDTOs, satisfiedDTOs, unsatisfiedDTOs); + } + + private Reference[] toReferences(Map<String, ReferenceDTO> referenceDTOs, Map<String, SatisfiedReferenceDTO> satisfiedDTOs, Map<String, UnsatisfiedReferenceDTO> unsatisfiedDTOs) { + Collection<Reference> references = new ArrayList<Reference>(); + for (Entry<String, SatisfiedReferenceDTO> satisfied : satisfiedDTOs.entrySet()) { + references.add(new SatsifiedReference(satisfied.getValue(), referenceDTOs.get(satisfied.getValue().name))); + } + for (Entry<String, UnsatisfiedReferenceDTO> unsatisfied : unsatisfiedDTOs.entrySet()) { + references.add(new UnsatsifiedReference(unsatisfied.getValue(), referenceDTOs.get(unsatisfied.getValue().name))); + } + return references.toArray(new Reference[0]); + } + + @Override + public ComponentInstance getComponentInstance() { + throw new UnsupportedOperationException("Not supported."); //$NON-NLS-1$ + } + + @Override + public String getActivate() { + return config.description.activate; + } + + @Override + public boolean isActivateDeclared() { + return config.description.activate != null; + } + + @Override + public String getDeactivate() { + return config.description.deactivate; + } + + @Override + public boolean isDeactivateDeclared() { + return config.description.deactivate != null; + } + + @Override + public String getModified() { + return config.description.modified; + } + + @Override + public String getConfigurationPolicy() { + return config.description.configurationPolicy; + } + + @Override + public void enable() { + scr.disableComponent(config.description); + } + + @Override + public void disable() { + scr.disableComponent(config.description); + } + } + + abstract class ReferenceBase implements Reference { + protected final ReferenceDTO reference; + + ReferenceBase(ReferenceDTO reference) { + this.reference = reference; + } + + @Override + public String getName() { + return reference.name; + } + + @Override + public String getServiceName() { + return reference.interfaceName; + } + + @Override + public boolean isOptional() { + return reference.cardinality.startsWith("0"); //$NON-NLS-1$ + } + + @Override + public boolean isMultiple() { + return reference.cardinality.startsWith("1"); //$NON-NLS-1$ + } + + @Override + public boolean isStatic() { + return "static".equals(reference.policy); //$NON-NLS-1$ + } + + @Override + public String getTarget() { + return reference.target; + } + + @Override + public String getBindMethodName() { + return reference.bind; + } + + @Override + public String getUnbindMethodName() { + return reference.unbind; + } + + @Override + public String getUpdatedMethodName() { + return reference.updated; + } + } + + class SatsifiedReference extends ReferenceBase { + private final SatisfiedReferenceDTO satisfied; + + SatsifiedReference(SatisfiedReferenceDTO satisifed, ReferenceDTO reference) { + super(reference); + this.satisfied = satisifed; + } + + @SuppressWarnings("rawtypes") + @Override + public ServiceReference[] getServiceReferences() { + Collection<ServiceReference<?>> serviceReferences = new ArrayList<ServiceReference<?>>(); + for (ServiceReferenceDTO serviceRefDTO : satisfied.boundServices) { + ServiceReference<?> ref = getServiceReference(serviceRefDTO.id); + if (ref != null) { + serviceReferences.add(ref); + } + } + return serviceReferences.isEmpty() ? null : serviceReferences.toArray(new ServiceReference[0]); + } + + @Override + public boolean isSatisfied() { + return true; + } + } + + class UnsatsifiedReference extends ReferenceBase { + private final UnsatisfiedReferenceDTO unsatisfied; + + UnsatsifiedReference(UnsatisfiedReferenceDTO unsatisifed, ReferenceDTO reference) { + super(reference); + this.unsatisfied = unsatisifed; + } + + @SuppressWarnings("rawtypes") + @Override + public ServiceReference[] getServiceReferences() { + Collection<ServiceReference<?>> serviceReferences = new ArrayList<ServiceReference<?>>(); + for (ServiceReferenceDTO serviceRefDTO : unsatisfied.targetServices) { + ServiceReference<?> ref = getServiceReference(serviceRefDTO.id); + if (ref != null) { + serviceReferences.add(ref); + } + } + return serviceReferences.isEmpty() ? null : serviceReferences.toArray(new ServiceReference[0]); + } + + @Override + public boolean isSatisfied() { + return false; + } + } + +} |