Modifier and Type	Class and Description
public static class	StuckThreadDetectionHandler.Builder
private static class	StuckThreadDetectionHandler.CompletedStuckThread
private static class	StuckThreadDetectionHandler.MonitoredThread
private static enum	StuckThreadDetectionHandler.MonitoredThreadState
public static class	StuckThreadDetectionHandler.Wrapper

Field Summary

Modifier and Type	Field and Description
private final ConcurrentHashMap<Long, StuckThreadDetectionHandler.MonitoredThread>	activeThreads The only references we keep to actual running Thread objects are in this Map (which is automatically cleaned in invoke()s finally clause).
private final Queue<StuckThreadDetectionHandler.CompletedStuckThread>	completedStuckThreadsQueue
public static final int	DEFAULT_THRESHOLD
private final HttpHandler	next
private final AtomicInteger	stuckCount Keeps count of the number of stuck threads detected
private final Runnable	stuckThreadTask
private final int	threshold In seconds.
private volatile XnioExecutor.Key	timerKey

Constructor Summary

Access	Constructor and Description
public	StuckThreadDetectionHandler(HttpHandler next)
public	StuckThreadDetectionHandler(int threshold, HttpHandler next)

Method Summary

Modifier and Type	Method and Description
public long[]	getStuckThreadIds()
public int	Returns: The current threshold in seconds getThreshold()
public void	handleRequest(HttpServerExchange the HTTP request/response exchange exchange) Implements io.undertow.server.HttpHandler.handleRequest. Handle the request.
private void	notifyStuckThreadCompleted(StuckThreadDetectionHandler.CompletedStuckThread thread, int numStuckThreads)
private void	notifyStuckThreadDetected(StuckThreadDetectionHandler.MonitoredThread monitoredThread, long activeTime, int numStuckThreads)
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

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

Field Detail

activeThreads	back to summary
private final ConcurrentHashMap<Long, StuckThreadDetectionHandler.MonitoredThread> activeThreads The only references we keep to actual running Thread objects are in this Map (which is automatically cleaned in invoke()s finally clause). That way, Threads can be GC'ed, eventhough the Valve still thinks they are stuck (caused by a long monitor interval)

completedStuckThreadsQueue	back to summary
private final Queue<StuckThreadDetectionHandler.CompletedStuckThread> completedStuckThreadsQueue

DEFAULT_THRESHOLD	back to summary
public static final int DEFAULT_THRESHOLD

next	back to summary
private final HttpHandler next

stuckCount	back to summary
private final AtomicInteger stuckCount Keeps count of the number of stuck threads detected

stuckThreadTask	back to summary
private final Runnable stuckThreadTask

threshold	back to summary
private final int threshold In seconds. Default 600 (10 minutes).

timerKey	back to summary
private volatile XnioExecutor.Key timerKey

Constructor Detail

StuckThreadDetectionHandler	back to summary
public StuckThreadDetectionHandler(HttpHandler next)

StuckThreadDetectionHandler	back to summary
public StuckThreadDetectionHandler(int threshold, HttpHandler next)

Method Detail

getStuckThreadIds	back to summary
public long[] getStuckThreadIds()

getThreshold	back to summary
public int getThreshold() Returns:int The current threshold in seconds

handleRequest	back to summary
public void handleRequest(HttpServerExchange exchange) throws Exception Implements io.undertow.server.HttpHandler.handleRequest. Doc from io.undertow.server.HttpHandler.handleRequest. Handle the request. Parameters exchange:HttpServerExchange the HTTP request/response exchange Annotations @Override

handleRequest

back to summary

public void handleRequest(HttpServerExchange exchange) throws Exception

Implements io.undertow.server.HttpHandler.handleRequest.

Doc from io.undertow.server.HttpHandler.handleRequest.

Handle the request.

Parameters

exchange:HttpServerExchange: the HTTP request/response exchange

Annotations

@Override

notifyStuckThreadCompleted	back to summary
private void notifyStuckThreadCompleted(StuckThreadDetectionHandler.CompletedStuckThread thread, int numStuckThreads)

notifyStuckThreadDetected	back to summary
private void notifyStuckThreadDetected(StuckThreadDetectionHandler.MonitoredThread monitoredThread, long activeTime, int numStuckThreads)

toString back to summary

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Satisfying this method's contract implies a non-`null` result must be returned. Returns:String a string representation of the object Annotations @Override

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String

a string representation of the object

Annotations

@Override

io.undertow.server.handlers back to summary

public Class StuckThreadDetectionHandler.Builder

Class Inheritance

extends Object
implements HandlerBuilder

java.lang.Object
io.undertow.server.handlers.StuckThreadDetectionHandler.Builder

All Implemented Interfaces

io.undertow.server.handlers.builder.HandlerBuilder

Constructor Summary

Access	Constructor and Description
public	Builder()

Method Summary

Modifier and Type	Method and Description
public HandlerWrapper	build(Map<String, Object> The handler config config) Implements io.undertow.server.handlers.builder.HandlerBuilder.build. Creates the handler
public String	defaultParameter() Implements io.undertow.server.handlers.builder.HandlerBuilder.defaultParameter.
public String	name() Implements io.undertow.server.handlers.builder.HandlerBuilder.name. The string representation of the handler name.
public Map<String, Class<?>>	parameters() Implements io.undertow.server.handlers.builder.HandlerBuilder.parameters. Returns a map of parameters and their types.
public Set<String>	requiredParameters() Implements io.undertow.server.handlers.builder.HandlerBuilder.requiredParameters.

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

Constructor Detail

Builder	back to summary
public Builder()

Method Detail

build	back to summary
public HandlerWrapper build(Map<String, Object> config) Implements io.undertow.server.handlers.builder.HandlerBuilder.build. Doc from io.undertow.server.handlers.builder.HandlerBuilder.build. Creates the handler Parameters config:Map<String, Object> The handler config Returns:HandlerWrapper The new predicate Annotations @Override

build

back to summary

public HandlerWrapper build(Map<String, Object> config)

Implements io.undertow.server.handlers.builder.HandlerBuilder.build.

Doc from io.undertow.server.handlers.builder.HandlerBuilder.build.

Creates the handler

Parameters

config:Map<String, Object>: The handler config

Returns:HandlerWrapper

The new predicate

Annotations

@Override

defaultParameter	back to summary
public String defaultParameter() Implements io.undertow.server.handlers.builder.HandlerBuilder.defaultParameter. Returns:String Doc from io.undertow.server.handlers.builder.HandlerBuilder.defaultParameter. The default parameter name, or null if it does not have a default parameter Annotations @Override

defaultParameter

back to summary

public String defaultParameter()

Implements io.undertow.server.handlers.builder.HandlerBuilder.defaultParameter.

Returns:String

Doc from io.undertow.server.handlers.builder.HandlerBuilder.defaultParameter.

The default parameter name, or null if it does not have a default parameter

Annotations

@Override

name	back to summary
public String name() Implements io.undertow.server.handlers.builder.HandlerBuilder.name. Doc from io.undertow.server.handlers.builder.HandlerBuilder.name. The string representation of the handler name. Returns:String The handler name Annotations @Override

name

back to summary

public String name()

Implements io.undertow.server.handlers.builder.HandlerBuilder.name.

Doc from io.undertow.server.handlers.builder.HandlerBuilder.name.

The string representation of the handler name.

Returns:String

The handler name

Annotations

@Override

parameters	back to summary
public Map<String, Class<?>> parameters() Implements io.undertow.server.handlers.builder.HandlerBuilder.parameters. Doc from io.undertow.server.handlers.builder.HandlerBuilder.parameters. Returns a map of parameters and their types. Annotations @Override

parameters

back to summary

public Map<String, Class<?>> parameters()

Implements io.undertow.server.handlers.builder.HandlerBuilder.parameters.

Doc from io.undertow.server.handlers.builder.HandlerBuilder.parameters.

Returns a map of parameters and their types.

Annotations

@Override

requiredParameters	back to summary
public Set<String> requiredParameters() Implements io.undertow.server.handlers.builder.HandlerBuilder.requiredParameters. Returns:Set<String> Doc from io.undertow.server.handlers.builder.HandlerBuilder.requiredParameters. The required parameters Annotations @Override

requiredParameters

back to summary

public Set<String> requiredParameters()

Implements io.undertow.server.handlers.builder.HandlerBuilder.requiredParameters.

Returns:Set<String>

Doc from io.undertow.server.handlers.builder.HandlerBuilder.requiredParameters.

The required parameters

Annotations

@Override

io.undertow.server.handlers back to summary

private Class StuckThreadDetectionHandler.CompletedStuckThread

Class Inheritance

extends Object

java.lang.Object
io.undertow.server.handlers.StuckThreadDetectionHandler.CompletedStuckThread

Field Summary

Modifier and Type	Field and Description
private final long	threadId
private final String	threadName
private final long	totalActiveTime

Constructor Summary

Access	Constructor and Description
pack-priv	CompletedStuckThread(Thread thread, long totalActiveTime)

Method Summary

Modifier and Type	Method and Description
public long	getId()
public String	getName()
public long	getTotalActiveTime()

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

Field Detail

threadId	back to summary
private final long threadId

threadName	back to summary
private final String threadName

totalActiveTime	back to summary
private final long totalActiveTime

Constructor Detail

CompletedStuckThread	back to summary
pack-priv CompletedStuckThread(Thread thread, long totalActiveTime)

Method Detail

getId	back to summary
public long getId()

getName	back to summary
public String getName()

getTotalActiveTime	back to summary
public long getTotalActiveTime()

io.undertow.server.handlers back to summary

private Class StuckThreadDetectionHandler.MonitoredThread

Class Inheritance

extends Object

java.lang.Object
io.undertow.server.handlers.StuckThreadDetectionHandler.MonitoredThread

Field Summary

Modifier and Type	Field and Description
private final String	requestUri
private final long	start
private final AtomicInteger	state
private final Thread	thread Reference to the thread to get a stack trace from background task

Constructor Summary

Access	Constructor and Description
pack-priv	MonitoredThread(Thread thread, String requestUri)

Method Summary

Modifier and Type	Method and Description
public long	getActiveTimeInMillis()
public String	getRequestUri()
public Date	getStartTime()
public Thread	getThread()
pack-priv boolean	isMarkedAsStuck()
public StuckThreadDetectionHandler.MonitoredThreadState	markAsDone()
public boolean	markAsStuckIfStillRunning()

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

Field Detail

requestUri	back to summary
private final String requestUri

start	back to summary
private final long start

state	back to summary
private final AtomicInteger state

thread	back to summary
private final Thread thread Reference to the thread to get a stack trace from background task

Constructor Detail

MonitoredThread	back to summary
pack-priv MonitoredThread(Thread thread, String requestUri)

Method Detail

getActiveTimeInMillis	back to summary
public long getActiveTimeInMillis()

getRequestUri	back to summary
public String getRequestUri()

getStartTime	back to summary
public Date getStartTime()

getThread	back to summary
public Thread getThread()

isMarkedAsStuck	back to summary
pack-priv boolean isMarkedAsStuck()

markAsDone	back to summary
public StuckThreadDetectionHandler.MonitoredThreadState markAsDone()

markAsStuckIfStillRunning	back to summary
public boolean markAsStuckIfStillRunning()

io.undertow.server.handlers back to summary

private final Enum StuckThreadDetectionHandler.MonitoredThreadState

Class Inheritance

extends Enum<StuckThreadDetectionHandler.MonitoredThreadState>

java.lang.Object
java.lang.Enum
io.undertow.server.handlers.StuckThreadDetectionHandler.MonitoredThreadState

Field Summary

Modifier and Type	Field and Description
public static final StuckThreadDetectionHandler.MonitoredThreadState	DONE
public static final StuckThreadDetectionHandler.MonitoredThreadState	RUNNING
public static final StuckThreadDetectionHandler.MonitoredThreadState	STUCK

Constructor Summary

Access	Constructor and Description
private	MonitoredThreadState()

Method Summary

Modifier and Type	Method and Description
public static StuckThreadDetectionHandler.MonitoredThreadState	valueOf(String name)
public static StuckThreadDetectionHandler.MonitoredThreadState[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

DONE	back to summary
public static final StuckThreadDetectionHandler.MonitoredThreadState DONE

RUNNING	back to summary
public static final StuckThreadDetectionHandler.MonitoredThreadState RUNNING

STUCK	back to summary
public static final StuckThreadDetectionHandler.MonitoredThreadState STUCK

Constructor Detail

MonitoredThreadState	back to summary
private MonitoredThreadState()

Method Detail

valueOf	back to summary
public static StuckThreadDetectionHandler.MonitoredThreadState valueOf(String name)

values	back to summary
public static StuckThreadDetectionHandler.MonitoredThreadState[] values()

public Class StuckThreadDetectionHandler

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Class StuckThreadDetectionHandler.Builder

Constructor Summary

Method Summary

Constructor Detail

Method Detail

private Class StuckThreadDetectionHandler.CompletedStuckThread

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class StuckThreadDetectionHandler.MonitoredThread

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Enum StuckThreadDetectionHandler.MonitoredThreadState

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public final Class StuckThreadDetectionHandler.Wrapper

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail