Class AsyncRunLevelContext

java.lang.Object

org.glassfish.hk2.runlevel.internal.AsyncRunLevelContext

@Service
@Visibility(LOCAL)
public class AsyncRunLevelContext
extends Object

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	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
private static final Logger	logger
private int	maxThreads
private Integer	modeOverride
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

Constructors

Modifier	Constructor	Description
private	AsyncRunLevelContext(ServiceLocator locator)	Constructor for the guy who does the work

Method Summary

Modifier and Type	Method	Description
(package private) void	clearErrors()
boolean	containsKey(ActiveDescriptor<?> descriptor)	The Context API for discovering if a descriptor has been created
void	destroyOne(ActiveDescriptor<?> descriptor)	The Context API.
<U> U	findOrCreate(ActiveDescriptor<U> activeDescriptor, ServiceHandle<?> root)	This is from the Context API, called by the wrapper
(package private) long	getCancelTimeout()
RunLevelFuture	getCurrentFuture()	Gets the current task
(package private) int	getCurrentLevel()
(package private) Executor	getExecutor()
(package private) int	getMaximumThreads()
(package private) Integer	getModeOverride()
(package private) List<ActiveDescriptor<?>>	getOrderedListOfServicesAtLevel(int level)
(package private) RunLevelController.ThreadingPolicy	getPolicy()
(package private) void	hardCancelOne(ActiveDescriptor<?> descriptor)	No need to lock this, it is called with the lock already held
(package private) void	jobDone()
(package private) void	levelCancelled()
private static String	oneLineDescriptor(ActiveDescriptor<?> descriptor)
private static String	oneLineRoot(ServiceHandle<?> root)
RunLevelFuture	proceedTo(int level)	This method is called to change the proceedTo level of the system
(package private) void	setCancelTimeout(long cancelTimeout)
(package private) void	setCurrentLevel(int currentLevel)
(package private) void	setExecutor(Executor executor)
(package private) void	setMaximumThreads(int maximum)
(package private) void	setModeOverride(Integer modeOverride)
(package private) void	setPolicy(RunLevelController.ThreadingPolicy policy)
private void	validate(ActiveDescriptor<?> descriptor, int currentLevel)	Verifies that the run level value of the RunLevel annotated service described by the given descriptor is valid for activation.
(package private) boolean	wouldBlockRightNow(ActiveDescriptor<?> desc)

Methods inherited from class Object

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

Field Details

DEBUG_CONTEXT_PROPERTY

private static final String DEBUG_CONTEXT_PROPERTY

See Also:

• Constant Field Values

DEBUG_CONTEXT

private static final boolean DEBUG_CONTEXT

logger

private static final Logger logger

timer

private static final Timer timer

THREAD_FACTORY

private static final ThreadFactory THREAD_FACTORY

hk2Logger

private final Logger hk2Logger

currentLevel

private int currentLevel

currentTask

private CurrentTaskFutureWrapper currentTask

DEFAULT_EXECUTOR

private static final Executor DEFAULT_EXECUTOR

backingMap

private final Map<ActiveDescriptor<?>, Object> backingMap

The backing maps for this context.

levelErrorMap

private final Map<ActiveDescriptor<?>, Throwable> levelErrorMap

wasCancelled

private boolean wasCancelled

creatingDescriptors

private final HashMap<ActiveDescriptor<?>, Long> creatingDescriptors

The set of services currently being created

hardCancelledDescriptors

private final HashSet<ActiveDescriptor<?>> hardCancelledDescriptors

The set of descriptors that have been hard cancelled

orderedCreationList

private final LinkedList<ActiveDescriptor<?>> orderedCreationList

executor

private Executor executor

locator

private final ServiceLocator locator

maxThreads

private int maxThreads

policy

private RunLevelController.ThreadingPolicy policy

cancelTimeout

private long cancelTimeout

modeOverride

private Integer modeOverride

Constructor Details

AsyncRunLevelContext

@Inject
private AsyncRunLevelContext(ServiceLocator locator)

Constructor for the guy who does the work

Parameters:

locator - The locator to use

Method Details

findOrCreate

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

This is from the Context API, called by the wrapper

Parameters:

activeDescriptor - the descriptor to create

root - The root descriptor

Returns:

The object created

containsKey

public boolean containsKey(ActiveDescriptor<?> descriptor)

The Context API for discovering if a descriptor has been created

Parameters:

descriptor - The descriptor to find

Returns:

true if already created, false otherwise

wouldBlockRightNow

boolean wouldBlockRightNow(ActiveDescriptor<?> desc)

hardCancelOne

void hardCancelOne(ActiveDescriptor<?> descriptor)

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

Parameters:

descriptor - the non-null descriptor to hard cancel

destroyOne

public void destroyOne(ActiveDescriptor<?> descriptor)

The Context API. Removes a descriptor from the set

Parameters:

descriptor - The descriptor to destroy

validate

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 RunLevelController.

Parameters:

descriptor - the descriptor of the service being activated

service - the run level service

getCurrentLevel

int getCurrentLevel()

levelCancelled

void levelCancelled()

setCurrentLevel

void setCurrentLevel(int currentLevel)

setPolicy

void setPolicy(RunLevelController.ThreadingPolicy policy)

setExecutor

void setExecutor(Executor executor)

getExecutor

Executor getExecutor()

getPolicy

RunLevelController.ThreadingPolicy getPolicy()

getOrderedListOfServicesAtLevel

List<ActiveDescriptor<?>> getOrderedListOfServicesAtLevel(int level)

proceedTo

public RunLevelFuture proceedTo(int level)
                         throws CurrentlyRunningException

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

Parameters:

level - The level to change to

Returns:

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

Throws:

CurrentlyRunningException - If there is already a running job

jobDone

void jobDone()

getCurrentFuture

public RunLevelFuture getCurrentFuture()

Gets the current task

Returns:

The current task, may be null if there is no current task

setMaximumThreads

void setMaximumThreads(int maximum)

getMaximumThreads

int getMaximumThreads()

clearErrors

void clearErrors()

setCancelTimeout

void setCancelTimeout(long cancelTimeout)

getCancelTimeout

long getCancelTimeout()

getModeOverride

Integer getModeOverride()

setModeOverride

void setModeOverride(Integer modeOverride)

oneLineDescriptor

private static String oneLineDescriptor(ActiveDescriptor<?> descriptor)

oneLineRoot

private static String oneLineRoot(ServiceHandle<?> root)