Modifier and Type	Class and Description
private static class	AsyncRunLevelContext.RunLevelControllerThread
private static class	AsyncRunLevelContext.RunLevelThreadFactory

Field Summary

Modifier and Type	Field and Description
private final Map<ActiveDescriptor<?>, Object>	backingMap The backing maps for this context.
private long	cancelTimeout
private final HashMap<ActiveDescriptor<?>, Long>	creatingDescriptors The set of services currently being created
private int	currentLevel
private CurrentTaskFutureWrapper	currentTask
private static final boolean	DEBUG_CONTEXT
private static final String	DEBUG_CONTEXT_PROPERTY
private static final Executor	DEFAULT_EXECUTOR
private Executor	executor
private final HashSet<ActiveDescriptor<?>>	hardCancelledDescriptors The set of descriptors that have been hard cancelled
private final Logger	hk2Logger
private final Map<ActiveDescriptor<?>, Throwable>	levelErrorMap
private final ServiceLocator	locator
pack-priv final ReentrantLock	lock
private static final Logger	logger
private int	maxThreads
private Integer	modeOverride
private final Condition	notEmpty
private final LinkedList<ActiveDescriptor<?>>	orderedCreationList
private RunLevelController.ThreadingPolicy	policy
private static final ThreadFactory	THREAD_FACTORY
private static final Timer	TIMER
private boolean	wasCancelled

Constructor Summary

Access	Constructor and Description
private	AsyncRunLevelContext(ServiceLocator The locator to use locator) Constructor for the guy who does the work

Method Summary

Modifier and Type	Method and Description
pack-priv void	clearErrors()
public boolean	Returns: true if already created, false otherwise containsKey(ActiveDescriptor<?> The descriptor to find descriptor) The `Context` API for discovering if a descriptor has been created
public void	destroyOne(ActiveDescriptor<?> The descriptor to destroy descriptor) The `Context` API.
public <U> U	Returns: The object created findOrCreate(ActiveDescriptor<U> the descriptor to create activeDescriptor, ServiceHandle<?> The root descriptor root) This is from the `Context` API, called by the wrapper
pack-priv long	getCancelTimeout()
public RunLevelFuture	Returns: The current task, may be null if there is no current task getCurrentFuture() Gets the current task
pack-priv int	getCurrentLevel()
pack-priv Executor	getExecutor()
pack-priv int	getMaximumThreads()
pack-priv Integer	getModeOverride()
pack-priv List<ActiveDescriptor<?>>	getOrderedListOfServicesAtLevel(int level)
pack-priv RunLevelController.ThreadingPolicy	getPolicy()
pack-priv void	hardCancelOne(ActiveDescriptor<?> the non-null descriptor to hard cancel descriptor) No need to lock this, it is called with the lock already held
pack-priv void	jobDone()
pack-priv void	levelCancelled()
private static String	oneLineDescriptor(ActiveDescriptor<?> descriptor)
private static String	oneLineRoot(ServiceHandle<?> root)
public RunLevelFuture	Returns: A non-null RunLevelFuture that is the handle to give the caller proceedTo(int The level to change to level) This method is called to change the proceedTo level of the system
pack-priv void	setCancelTimeout(long cancelTimeout)
pack-priv void	setCurrentLevel(int currentLevel)
pack-priv void	setExecutor(Executor executor)
pack-priv void	setMaximumThreads(int maximum)
pack-priv void	setModeOverride(Integer modeOverride)
pack-priv void	setPolicy(RunLevelController.ThreadingPolicy policy)
private void	validate(ActiveDescriptor<?> the descriptor of the service being activated descriptor, int currentLevel) Verifies that the run level value of the `RunLevel` annotated service described by the given descriptor is valid for activation.
pack-priv boolean	wouldBlockRightNow(ActiveDescriptor<?> desc)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

backingMap	back to summary
private final Map<ActiveDescriptor<?>, Object> backingMap The backing maps for this context.

cancelTimeout	back to summary
private long cancelTimeout

creatingDescriptors	back to summary
private final HashMap<ActiveDescriptor<?>, Long> creatingDescriptors The set of services currently being created

currentLevel	back to summary
private int currentLevel

currentTask	back to summary
private CurrentTaskFutureWrapper currentTask

DEBUG_CONTEXT	back to summary
private static final boolean DEBUG_CONTEXT

DEBUG_CONTEXT_PROPERTY	back to summary
private static final String DEBUG_CONTEXT_PROPERTY

DEFAULT_EXECUTOR	back to summary
private static final Executor DEFAULT_EXECUTOR

executor	back to summary
private Executor executor

hardCancelledDescriptors	back to summary
private final HashSet<ActiveDescriptor<?>> hardCancelledDescriptors The set of descriptors that have been hard cancelled

hk2Logger	back to summary
private final Logger hk2Logger

levelErrorMap	back to summary
private final Map<ActiveDescriptor<?>, Throwable> levelErrorMap

locator	back to summary
private final ServiceLocator locator

lock	back to summary
pack-priv final ReentrantLock lock

logger	back to summary
private static final Logger logger

maxThreads	back to summary
private int maxThreads

modeOverride	back to summary
private Integer modeOverride

notEmpty	back to summary
private final Condition notEmpty

orderedCreationList	back to summary
private final LinkedList<ActiveDescriptor<?>> orderedCreationList

policy	back to summary
private RunLevelController.ThreadingPolicy policy

THREAD_FACTORY	back to summary
private static final ThreadFactory THREAD_FACTORY

TIMER	back to summary
private static final Timer TIMER

wasCancelled	back to summary
private boolean wasCancelled

Constructor Detail

AsyncRunLevelContext	back to summary
private AsyncRunLevelContext(ServiceLocator locator) Constructor for the guy who does the work Parameters locator:ServiceLocator The locator to use Annotations @Inject

AsyncRunLevelContext

back to summary

private AsyncRunLevelContext(ServiceLocator locator)

Constructor for the guy who does the work

Parameters

locator:ServiceLocator: The locator to use

Annotations

@Inject

Method Detail

clearErrors	back to summary
pack-priv void clearErrors()

containsKey back to summary

containsKey	back to summary
public boolean containsKey(ActiveDescriptor<?> descriptor) The `Context` API for discovering if a descriptor has been created Parameters descriptor:ActiveDescriptor<?> The descriptor to find Returns:boolean true if already created, false otherwise

public boolean containsKey(ActiveDescriptor<?> descriptor)

The Context API for discovering if a descriptor has been created

Parameters

descriptor:ActiveDescriptor<?>: The descriptor to find

Returns:boolean

true if already created, false otherwise

destroyOne back to summary

destroyOne	back to summary
public void destroyOne(ActiveDescriptor<?> descriptor) The `Context` API. Removes a descriptor from the set Parameters descriptor:ActiveDescriptor<?> The descriptor to destroy Annotations @SuppressWarnings:unchecked

public void destroyOne(ActiveDescriptor<?> descriptor)

The Context API. Removes a descriptor from the set

Parameters

descriptor:ActiveDescriptor<?>: The descriptor to destroy

Annotations

@SuppressWarnings:unchecked

findOrCreate back to summary

findOrCreate	back to summary
public <U> U findOrCreate(ActiveDescriptor<U> activeDescriptor, ServiceHandle<?> root) This is from the `Context` API, called by the wrapper Parameters activeDescriptor:ActiveDescriptor<U> the descriptor to create root:ServiceHandle<?> The root descriptor Returns:U The object created Annotations @SuppressWarnings:unchecked

public <U> U findOrCreate(ActiveDescriptor<U> activeDescriptor, ServiceHandle<?> root)

This is from the Context API, called by the wrapper

Parameters

activeDescriptor:ActiveDescriptor<U>: the descriptor to create
root:ServiceHandle<?>: The root descriptor

Returns:U

The object created

Annotations

@SuppressWarnings:unchecked

getCancelTimeout	back to summary
pack-priv long getCancelTimeout()

getCurrentFuture	back to summary
public RunLevelFuture getCurrentFuture() Gets the current task Returns:RunLevelFuture The current task, may be null if there is no current task

getCurrentFuture

back to summary

public RunLevelFuture getCurrentFuture()

Gets the current task

Returns:RunLevelFuture: The current task, may be null if there is no current task

getCurrentLevel	back to summary
pack-priv int getCurrentLevel()

getExecutor	back to summary
pack-priv Executor getExecutor()

getMaximumThreads	back to summary
pack-priv int getMaximumThreads()

getModeOverride	back to summary
pack-priv Integer getModeOverride()

getOrderedListOfServicesAtLevel	back to summary
pack-priv List<ActiveDescriptor<?>> getOrderedListOfServicesAtLevel(int level)

getPolicy	back to summary
pack-priv RunLevelController.ThreadingPolicy getPolicy()

hardCancelOne	back to summary
pack-priv void hardCancelOne(ActiveDescriptor<?> descriptor) No need to lock this, it is called with the lock already held Parameters descriptor:ActiveDescriptor<?> the non-null descriptor to hard cancel

hardCancelOne

back to summary

pack-priv void hardCancelOne(ActiveDescriptor<?> descriptor)

No need to lock this, it is called with the lock already held

Parameters

descriptor:ActiveDescriptor<?>: the non-null descriptor to hard cancel

jobDone	back to summary
pack-priv void jobDone()

levelCancelled	back to summary
pack-priv void levelCancelled()

oneLineDescriptor	back to summary
private static String oneLineDescriptor(ActiveDescriptor<?> descriptor)

oneLineRoot	back to summary
private static String oneLineRoot(ServiceHandle<?> root)

proceedTo	back to summary
public RunLevelFuture proceedTo(int level) throws CurrentlyRunningException This method is called to change the proceedTo level of the system Parameters level:int The level to change to Returns:RunLevelFuture A non-null RunLevelFuture that is the handle to give the caller Exceptions CurrentlyRunningException: If there is already a running job

proceedTo

back to summary

public RunLevelFuture proceedTo(int level) throws CurrentlyRunningException

This method is called to change the proceedTo level of the system

Parameters

level:int: The level to change to

Returns:RunLevelFuture

A non-null RunLevelFuture that is the handle to give the caller

Exceptions

CurrentlyRunningException:: If there is already a running job

setCancelTimeout	back to summary
pack-priv void setCancelTimeout(long cancelTimeout)

setCurrentLevel	back to summary
pack-priv void setCurrentLevel(int currentLevel)

setExecutor	back to summary
pack-priv void setExecutor(Executor executor)

setMaximumThreads	back to summary
pack-priv void setMaximumThreads(int maximum)

setModeOverride	back to summary
pack-priv void setModeOverride(Integer modeOverride)

setPolicy	back to summary
pack-priv void setPolicy(RunLevelController.ThreadingPolicy policy)

validate back to summary

private void validate(ActiveDescriptor<?> descriptor, int currentLevel) throws IllegalStateException

Verifies that the run level value of the RunLevel annotated service described by the given descriptor is valid for activation. Valid means that the run level value is less than or equal to the current or planned run level of the given org.glassfish.hk2.runlevel.RunLevelController.

Parameters

descriptor:ActiveDescriptor<?>: the descriptor of the service being activated

Exceptions

RunLevelException:: if the validation fails

wouldBlockRightNow	back to summary
pack-priv boolean wouldBlockRightNow(ActiveDescriptor<?> desc)

org.glassfish.hk2.runlevel.internal back to summary

private Class AsyncRunLevelContext.RunLevelControllerThread

Class Inheritance

extends Thread

java.lang.Object
java.lang.Thread
org.glassfish.hk2.runlevel.internal.AsyncRunLevelContext.RunLevelControllerThread

Field Summary

Inherited from java.lang.Thread:: MAX_PRIORITY MIN_PRIORITY NORM_PRIORITY

Constructor Summary

Access	Constructor and Description
private	RunLevelControllerThread(Runnable r)

Method Summary

Constructor Detail

RunLevelControllerThread	back to summary
private RunLevelControllerThread(Runnable r)

org.glassfish.hk2.runlevel.internal back to summary

private Class AsyncRunLevelContext.RunLevelThreadFactory

Class Inheritance

extends Object
implements ThreadFactory

java.lang.Object
org.glassfish.hk2.runlevel.internal.AsyncRunLevelContext.RunLevelThreadFactory

All Implemented Interfaces

java.util.concurrent.ThreadFactory

Constructor Summary

Access	Constructor and Description
private	RunLevelThreadFactory()

Method Summary

Modifier and Type	Method and Description
public Thread	newThread(Runnable runnable) Implements java.util.concurrent.ThreadFactory.newThread. Constructs a new unstarted `Thread` to run the given runnable.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

RunLevelThreadFactory	back to summary
private RunLevelThreadFactory()

Method Detail

newThread back to summary

public Thread newThread(Runnable runnable)

Implements java.util.concurrent.ThreadFactory.newThread.

Doc from java.util.concurrent.ThreadFactory.newThread.

Constructs a new unstarted Thread to run the given runnable.

Annotations

@Override

public Class AsyncRunLevelContext

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class AsyncRunLevelContext.RunLevelControllerThread

Field Summary

Constructor Summary

Method Summary

Constructor Detail

private Class AsyncRunLevelContext.RunLevelThreadFactory

Constructor Summary

Method Summary

Constructor Detail

Method Detail