org.eclipse.jetty.server

Class LowResourceMonitor

java.lang.Object

AbstractLifeCycle

org.eclipse.jetty.server.LowResourceMonitor

public class LowResourceMonitor
extends AbstractLifeCycle

A monitor for low resources

An instance of this class will monitor all the connectors of a server (or a set of connectors configured with setMonitoredConnectors(Collection)) for a low resources state.

Low resources can be detected by:

• ThreadPool#isLowOnThreads() if Connector.getExecutor() is an instance of ThreadPool and setMonitorThreads(boolean) is true.
• If setMaxMemory(long) is non zero then low resources is detected if the JVMs Runtime instance has Runtime.totalMemory() minus Runtime.freeMemory() greater than getMaxMemory()
• If setMaxConnections(int) is non zero then low resources is dected if the total number of connections exceeds getMaxConnections()

Once low resources state is detected, the cause is logged and all existing connections returned by Connector.getConnectedEndPoints() have EndPoint#setIdleTimeout(long) set to getLowResourcesIdleTimeout(). New connections are not affected, however if the low resources state persists for more than getMaxLowResourcesTime(), then the getLowResourcesIdleTimeout() to all connections again. Once the low resources state is cleared, the idle timeout is reset to the connector default given by Connector.getIdleTimeout().

If setAcceptingInLowResources(boolean) is set to false (Default is true), then no new connections are accepted when in low resources state.

Constructor Summary

Constructors

Constructor and Description
LowResourceMonitor(Server server)

Method Summary

Modifier and Type	Method and Description
protected void	clearLowResources()
protected void	doStart()
protected void	doStop()
int	getLowResourcesIdleTimeout()
java.lang.String	getLowResourcesReasons()
long	getLowResourcesStarted()
int	getMaxConnections()
int	getMaxLowResourcesTime()
long	getMaxMemory()
java.util.Collection<Connector>	getMonitoredConnectors()
protected Connector[]	getMonitoredOrServerConnectors()
boolean	getMonitorThreads()
int	getPeriod()
boolean	isAcceptingInLowResources()
boolean	isLowOnResources()
protected void	monitor()
void	setAcceptingInLowResources(boolean acceptingInLowResources)
protected void	setLowResources()
void	setLowResourcesIdleTimeout(int lowResourcesIdleTimeoutMS)
void	setMaxConnections(int maxConnections)
void	setMaxLowResourcesTime(int maxLowResourcesTimeMS)
void	setMaxMemory(long maxMemoryBytes)
void	setMonitoredConnectors(java.util.Collection<Connector> monitoredConnectors)
void	setMonitorThreads(boolean monitorThreads)
void	setPeriod(int periodMS)

Methods inherited from class java.lang.Object

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

Constructor Detail

LowResourceMonitor

public LowResourceMonitor(Server server)

Method Detail

isLowOnResources

public boolean isLowOnResources()

getLowResourcesReasons

public java.lang.String getLowResourcesReasons()

getLowResourcesStarted

public long getLowResourcesStarted()

getMonitoredConnectors

public java.util.Collection<Connector> getMonitoredConnectors()

setMonitoredConnectors

public void setMonitoredConnectors(java.util.Collection<Connector> monitoredConnectors)

Parameters:

monitoredConnectors - The collections of Connectors that should be monitored for low resources.

isAcceptingInLowResources

public boolean isAcceptingInLowResources()

setAcceptingInLowResources

public void setAcceptingInLowResources(boolean acceptingInLowResources)

getPeriod

public int getPeriod()

setPeriod

public void setPeriod(int periodMS)

Parameters:

periodMS - The period in ms to monitor for low resources

getMonitorThreads

public boolean getMonitorThreads()

setMonitorThreads

public void setMonitorThreads(boolean monitorThreads)

Parameters:

monitorThreads - If true, check connectors executors to see if they are ThreadPool instances that are low on threads.

getMaxConnections

public int getMaxConnections()

setMaxConnections

public void setMaxConnections(int maxConnections)

Parameters:

maxConnections - The maximum connections before low resources state is triggered

getMaxMemory

public long getMaxMemory()

setMaxMemory

public void setMaxMemory(long maxMemoryBytes)

Parameters:

maxMemoryBytes - The maximum memory in bytes in use before low resources is triggered.

getLowResourcesIdleTimeout

public int getLowResourcesIdleTimeout()

setLowResourcesIdleTimeout

public void setLowResourcesIdleTimeout(int lowResourcesIdleTimeoutMS)

Parameters:

lowResourcesIdleTimeoutMS - The timeout in ms to apply to EndPoints when in the low resources state.

getMaxLowResourcesTime

public int getMaxLowResourcesTime()

setMaxLowResourcesTime

public void setMaxLowResourcesTime(int maxLowResourcesTimeMS)

Parameters:

maxLowResourcesTimeMS - The time in milliseconds that a low resource state can persist before the low resource idle timeout is reapplied to all connections

doStart

protected void doStart()
                throws java.lang.Exception

Throws:

java.lang.Exception

doStop

protected void doStop()
               throws java.lang.Exception

Throws:

java.lang.Exception

getMonitoredOrServerConnectors

protected Connector[] getMonitoredOrServerConnectors()

monitor

protected void monitor()

setLowResources

protected void setLowResources()

clearLowResources

protected void clearLowResources()