Package emissary.core

Class ResourceWatcher

java.lang.Object

emissary.core.ResourceWatcher

All Implemented Interfaces:

Runnable

public class ResourceWatcher
extends Object
implements Runnable

Track mobile agents and make them obey resource limitations

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEFAULT_NAMESPACE_NAME
protected static org.slf4j.Logger	LOG
protected com.codahale.metrics.MetricRegistry	metrics
protected MetricsFormatter	metricsFormatter
protected Thread	monitor
protected Map<String,Long>	placeTimeLimits
protected long	timeLimitMillis
protected boolean	timeToQuit
protected Queue<TimedResource>	tracking

Constructor Summary

Constructors

Constructor	Description
ResourceWatcher()
ResourceWatcher(MetricsManager metricsManager)	Create a resource watcher set it running and bind into the NamespaceException

Method Summary

Modifier and Type	Method	Description
com.codahale.metrics.Timer	getStat(String statKey)
SortedMap<String,com.codahale.metrics.Timer>	getStats()
long	getTimeLimitMillis()	Get the default time limit in millis
void	logStats(org.slf4j.Logger loggerArg)
static ResourceWatcher	lookup()	Lookup the default ResourceWatcher in the Namespace
void	quit()	Safely stop the monitoring Thread
void	resetStats()
void	run()	Runnable interface where we get to monitor stuff
void	setTimeLimitMillis(long limit)	Set the default time limit in millis
TimedResource	starting(IMobileAgent agent, IServiceProviderPlace place)	Register an agent to start tracking it
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

DEFAULT_NAMESPACE_NAME

public static final String DEFAULT_NAMESPACE_NAME

See Also:

Constant Field Values

timeLimitMillis

protected long timeLimitMillis

placeTimeLimits

protected Map<String,Long> placeTimeLimits

monitor

@Nullable
protected transient Thread monitor

timeToQuit

protected boolean timeToQuit

metrics

protected com.codahale.metrics.MetricRegistry metrics

metricsFormatter

protected MetricsFormatter metricsFormatter

tracking

protected Queue<TimedResource> tracking

Constructor Detail

ResourceWatcher

public ResourceWatcher()

ResourceWatcher

public ResourceWatcher(MetricsManager metricsManager)

Create a resource watcher set it running and bind into the NamespaceException

Method Detail

starting

public TimedResource starting(IMobileAgent agent,
                              IServiceProviderPlace place)

Register an agent to start tracking it

Parameters:

agent - the agent to track

place - place executing

Returns:

TimedResource for the place and agent

lookup

public static ResourceWatcher lookup()
                              throws NamespaceException

Lookup the default ResourceWatcher in the Namespace

Returns:

The registered ResourceWatcher

Throws:

NamespaceException

quit

public void quit()

Safely stop the monitoring Thread

setTimeLimitMillis

public void setTimeLimitMillis(long limit)

Set the default time limit in millis

Parameters:

limit - the new value

getTimeLimitMillis

public long getTimeLimitMillis()

Get the default time limit in millis

Returns:

time limit

run

public void run()

Runnable interface where we get to monitor stuff

Specified by:

run in interface Runnable

logStats

public void logStats(org.slf4j.Logger loggerArg)

resetStats

public void resetStats()

getStats

public SortedMap<String,com.codahale.metrics.Timer> getStats()

getStat

public com.codahale.metrics.Timer getStat(String statKey)

toString

public String toString()

Overrides:

toString in class Object