org.eclipse.gemini.blueprint.extender.internal.dependencies.startup

Class DependencyServiceManager

java.lang.Object

org.eclipse.gemini.blueprint.extender.internal.dependencies.startup.DependencyServiceManager

public class DependencyServiceManager
extends java.lang.Object

ServiceListener used for tracking dependent services. Even if the ServiceListener receives event synchronously, mutable properties should be synchronized to guarantee safe publishing between threads.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	DependencyServiceManager.DependencyServiceListener Actual ServiceListener.

Field Summary

Fields

Modifier and Type	Field and Description
private org.osgi.framework.BundleContext	bundleContext
private DelegatedExecutionOsgiBundleApplicationContext	context
private ContextExecutorAccessor	contextStateAccessor
protected java.util.Map<MandatoryServiceDependency,java.lang.String>	dependencies
private java.util.List<OsgiServiceDependencyFactory>	dependencyFactories dependency factories
private java.lang.Runnable	executeIfDone Task to execute if all dependencies are met.
private org.osgi.framework.ServiceListener	listener
private static org.apache.commons.logging.Log	log
private java.lang.Object	monitor
private static java.util.Map<MandatoryServiceDependency,java.lang.String>	UNMODIFIABLE_DEPENDENCY_MAP
protected java.util.Map<MandatoryServiceDependency,java.lang.String>	unsatisfiedDependencies
private long	waitTime Maximum waiting time used in events when waiting for dependencies

Constructor Summary

Constructors

Constructor and Description
DependencyServiceManager(ContextExecutorAccessor executor, DelegatedExecutionOsgiBundleApplicationContext context, java.util.List<OsgiServiceDependencyFactory> dependencyFactories, java.lang.Runnable executeIfDone, long maxWaitTime) Create a dependency manager, indicating the executor bound to, the context that contains the dependencies and the task to execute if all dependencies are met.

Method Summary

Modifier and Type	Method and Description
boolean	allDependenciesSatisfied()
private java.lang.String	createDependencyFilter() Look at all dependencies and create an appropriate filter.
private java.lang.String	createDependencyFilter(java.util.Collection<MandatoryServiceDependency> dependencies)
(package private) java.lang.String	createUnsatisfiedDependencyFilter()
protected void	deregister()
private void	doFindDependencies()
protected void	findServiceDependencies()
private java.security.AccessControlContext	getAcc()
java.util.Map<MandatoryServiceDependency,java.lang.String>	getUnsatisfiedDependencies()
(package private) java.util.List<OsgiServiceDependencyEvent>	getUnsatisfiedDependenciesAsEvents()
private java.util.List<OsgiServiceDependencyEvent>	getUnsatisfiedDependenciesAsEvents(java.util.Collection<MandatoryServiceDependency> deps)
boolean	isSatisfied()
private void	publishEvent(OsgiBundleApplicationContextEvent dependencyEvent)
protected void	register()
private void	sendBootstrappingDependenciesEvent(java.util.Set<MandatoryServiceDependency> deps)
private void	sendDependencySatisfiedEvent(MandatoryServiceDependency dependency)
private void	sendDependencyUnsatisfiedEvent(MandatoryServiceDependency dependency)
private void	sendInitialBootstrappingEvents(java.util.Set<MandatoryServiceDependency> deps)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

UNMODIFIABLE_DEPENDENCY_MAP

private static final java.util.Map<MandatoryServiceDependency,java.lang.String> UNMODIFIABLE_DEPENDENCY_MAP

log

private static final org.apache.commons.logging.Log log

monitor

private final java.lang.Object monitor

dependencies

protected final java.util.Map<MandatoryServiceDependency,java.lang.String> dependencies

unsatisfiedDependencies

protected final java.util.Map<MandatoryServiceDependency,java.lang.String> unsatisfiedDependencies

contextStateAccessor

private final ContextExecutorAccessor contextStateAccessor

bundleContext

private final org.osgi.framework.BundleContext bundleContext

listener

private final org.osgi.framework.ServiceListener listener

context

private final DelegatedExecutionOsgiBundleApplicationContext context

executeIfDone

private final java.lang.Runnable executeIfDone

Task to execute if all dependencies are met.

waitTime

private final long waitTime

Maximum waiting time used in events when waiting for dependencies

dependencyFactories

private java.util.List<OsgiServiceDependencyFactory> dependencyFactories

dependency factories

Constructor Detail

DependencyServiceManager

public DependencyServiceManager(ContextExecutorAccessor executor,
                                DelegatedExecutionOsgiBundleApplicationContext context,
                                java.util.List<OsgiServiceDependencyFactory> dependencyFactories,
                                java.lang.Runnable executeIfDone,
                                long maxWaitTime)

Create a dependency manager, indicating the executor bound to, the context that contains the dependencies and the task to execute if all dependencies are met.

Parameters:

executor -

context -

executeIfDone -

Method Detail

findServiceDependencies

protected void findServiceDependencies()
                                throws java.lang.Exception

Throws:

java.lang.Exception

doFindDependencies

private void doFindDependencies()
                         throws java.lang.Exception

Throws:

java.lang.Exception

isSatisfied

public boolean isSatisfied()

getUnsatisfiedDependencies

public java.util.Map<MandatoryServiceDependency,java.lang.String> getUnsatisfiedDependencies()

register

protected void register()

createDependencyFilter

private java.lang.String createDependencyFilter()

Look at all dependencies and create an appropriate filter. This method concatenates the filters into one. Note that not just unsatisfied dependencies are considered since their number can grow.

Returns:

createUnsatisfiedDependencyFilter

java.lang.String createUnsatisfiedDependencyFilter()

createDependencyFilter

private java.lang.String createDependencyFilter(java.util.Collection<MandatoryServiceDependency> dependencies)

deregister

protected void deregister()

getUnsatisfiedDependenciesAsEvents

java.util.List<OsgiServiceDependencyEvent> getUnsatisfiedDependenciesAsEvents()

getUnsatisfiedDependenciesAsEvents

private java.util.List<OsgiServiceDependencyEvent> getUnsatisfiedDependenciesAsEvents(java.util.Collection<MandatoryServiceDependency> deps)

sendDependencyUnsatisfiedEvent

private void sendDependencyUnsatisfiedEvent(MandatoryServiceDependency dependency)

sendDependencySatisfiedEvent

private void sendDependencySatisfiedEvent(MandatoryServiceDependency dependency)

sendInitialBootstrappingEvents

private void sendInitialBootstrappingEvents(java.util.Set<MandatoryServiceDependency> deps)

sendBootstrappingDependenciesEvent

private void sendBootstrappingDependenciesEvent(java.util.Set<MandatoryServiceDependency> deps)

publishEvent

private void publishEvent(OsgiBundleApplicationContextEvent dependencyEvent)

getAcc

private java.security.AccessControlContext getAcc()

allDependenciesSatisfied

public boolean allDependenciesSatisfied()