org.infinispan.stats.impl

Class ClusterCacheStatsImpl

java.lang.Object

org.infinispan.stats.impl.ClusterCacheStatsImpl

All Implemented Interfaces:

JmxStatisticsExposer, ClusterCacheStats, Stats

public class ClusterCacheStatsImpl
extends Object
implements ClusterCacheStats, JmxStatisticsExposer

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_STALE_STATS_THRESHOLD

Constructor Summary

Constructors

Constructor and Description
ClusterCacheStatsImpl()

Method Summary

Modifier and Type	Method and Description
protected void	fetchClusterWideStatsIfNeeded()
long	getActivations()
long	getAverageReadTime()
long	getAverageRemoveTime()
long	getAverageWriteTime()
long	getCacheLoaderLoads()
long	getCacheLoaderMisses()
int	getCurrentNumberOfEntries() Returns the number of entries currently in this cache instance.
long	getEvictions()
static <T extends CommandInterceptor> T	getFirstInterceptorWhichExtends(AdvancedCache<?,?> cache, Class<T> interceptorClass)
double	getHitRatio()
long	getHits()
long	getInvalidations()
long	getMisses()
int	getNumberOfEntries()
int	getNumberOfLocksAvailable()
int	getNumberOfLocksHeld()
long	getPassivations()
double	getReadWriteRatio()
long	getRemoveHits()
long	getRemoveMisses()
long	getRetrievals()
long	getStaleStatsTreshold()
boolean	getStatisticsEnabled() Returns whether an interceptor's statistics are being captured.
long	getStores()
long	getStoreWrites()
long	getTimeSinceReset()
long	getTimeSinceStart()
long	getTotalNumberOfEntries() Number of entries stored in cache since the cache started running.
void	injectDependencies(Cache<?,?> cache, TimeService ts, Configuration configuration)
boolean	isStatisticsEnabled()
protected boolean	launchNewDistTask()
void	reset() Reset statistics
void	resetStatistics() Resets an interceptor's cache statistics
void	setStaleStatsTreshold(long staleStatsTreshold)
void	setStatisticsEnabled(boolean enabled) Enables or disables statistics at runtime.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_STALE_STATS_THRESHOLD

public static final long DEFAULT_STALE_STATS_THRESHOLD

See Also:

Constant Field Values

Constructor Detail

ClusterCacheStatsImpl

public ClusterCacheStatsImpl()

Method Detail

injectDependencies

public void injectDependencies(Cache<?,?> cache,
                               TimeService ts,
                               Configuration configuration)

start

public void start()

stop

public void stop()

getStaleStatsTreshold

public long getStaleStatsTreshold()

setStaleStatsTreshold

public void setStaleStatsTreshold(long staleStatsTreshold)

resetStatistics

public void resetStatistics()

Description copied from interface: JmxStatisticsExposer

Resets an interceptor's cache statistics

Specified by:

resetStatistics in interface JmxStatisticsExposer

setStatisticsEnabled

public void setStatisticsEnabled(boolean enabled)

Description copied from interface: Stats

Enables or disables statistics at runtime.

Specified by:

setStatisticsEnabled in interface JmxStatisticsExposer

Specified by:

setStatisticsEnabled in interface Stats

Parameters:

enabled - boolean indicating whether statistics should be enable or not

getStatisticsEnabled

public boolean getStatisticsEnabled()

Description copied from interface: JmxStatisticsExposer

Returns whether an interceptor's statistics are being captured.

Specified by:

getStatisticsEnabled in interface JmxStatisticsExposer

Returns:

true if statistics are captured

isStatisticsEnabled

public boolean isStatisticsEnabled()

getAverageReadTime

public long getAverageReadTime()

Specified by:

getAverageReadTime in interface Stats

Returns:

Average number of milliseconds for a cache get on the cache

getAverageRemoveTime

public long getAverageRemoveTime()

Specified by:

getAverageRemoveTime in interface Stats

Returns:

Average number of milliseconds for a cache put on the cache

getAverageWriteTime

public long getAverageWriteTime()

Specified by:

getAverageWriteTime in interface Stats

Returns:

Average number of milliseconds for a cache put on the cache

getEvictions

public long getEvictions()

Specified by:

getEvictions in interface Stats

Returns:

Number of cache eviction.

getHits

public long getHits()

Specified by:

getHits in interface Stats

Returns:

Number of cache get hits.

getHitRatio

public double getHitRatio()

Specified by:

getHitRatio in interface ClusterCacheStats

Returns:

cluster wide total percentage hit/(hit+miss) ratio for this cache

getMisses

public long getMisses()

Specified by:

getMisses in interface Stats

Returns:

Number of cache get misses.

getNumberOfEntries

public int getNumberOfEntries()

getReadWriteRatio

public double getReadWriteRatio()

Specified by:

getReadWriteRatio in interface ClusterCacheStats

Returns:

cluster wide read/writes ratio for the cache

getRemoveHits

public long getRemoveHits()

Specified by:

getRemoveHits in interface Stats

Returns:

Number of cache removal hits.

getRemoveMisses

public long getRemoveMisses()

Specified by:

getRemoveMisses in interface Stats

Returns:

Number of cache removal misses.

getStores

public long getStores()

Specified by:

getStores in interface Stats

Returns:

Number of put operations on the cache.

getTimeSinceStart

public long getTimeSinceStart()

Specified by:

getTimeSinceStart in interface Stats

Returns:

Number of seconds since cache started.

getTimeSinceReset

public long getTimeSinceReset()

Specified by:

getTimeSinceReset in interface Stats

Returns:

Number of seconds since stats where reset

getCurrentNumberOfEntries

public int getCurrentNumberOfEntries()

Description copied from interface: Stats

Returns the number of entries currently in this cache instance. When the cache is configured with distribution, this method only returns the number of entries in the local cache instance. In other words, it does not attempt to communicate with other nodes to find out about the data stored in other nodes in the cluster that is not available locally.

Specified by:

getCurrentNumberOfEntries in interface Stats

Returns:

Number of entries currently in the cache.

getTotalNumberOfEntries

public long getTotalNumberOfEntries()

Description copied from interface: Stats

Number of entries stored in cache since the cache started running.

Specified by:

getTotalNumberOfEntries in interface Stats

getRetrievals

public long getRetrievals()

Specified by:

getRetrievals in interface Stats

Returns:

Number of get operations.

reset

public void reset()

Description copied from interface: Stats

Reset statistics

Specified by:

reset in interface Stats

getNumberOfLocksAvailable

public int getNumberOfLocksAvailable()

Specified by:

getNumberOfLocksAvailable in interface ClusterCacheStats

Returns:

the total number of exclusive locks available in the cluster

getNumberOfLocksHeld

public int getNumberOfLocksHeld()

Specified by:

getNumberOfLocksHeld in interface ClusterCacheStats

Returns:

the total number of exclusive locks held in the cluster

getInvalidations

public long getInvalidations()

Specified by:

getInvalidations in interface ClusterCacheStats

Returns:

the total number of invalidations in the cluster

getActivations

public long getActivations()

Specified by:

getActivations in interface ClusterCacheStats

Returns:

the total number of actiavtions in the cluster

getPassivations

public long getPassivations()

Specified by:

getPassivations in interface ClusterCacheStats

Returns:

the total number of passivations in the cluster

getCacheLoaderLoads

public long getCacheLoaderLoads()

Specified by:

getCacheLoaderLoads in interface ClusterCacheStats

Returns:

the total number of cacheloader load operations in the cluster

getCacheLoaderMisses

public long getCacheLoaderMisses()

Specified by:

getCacheLoaderMisses in interface ClusterCacheStats

Returns:

the total number of cacheloader misses in the cluster

getStoreWrites

public long getStoreWrites()

Specified by:

getStoreWrites in interface ClusterCacheStats

Returns:

the total number of cachewriter store operations in the cluster

launchNewDistTask

protected boolean launchNewDistTask()

fetchClusterWideStatsIfNeeded

protected void fetchClusterWideStatsIfNeeded()

getFirstInterceptorWhichExtends

public static <T extends CommandInterceptor> T getFirstInterceptorWhichExtends(AdvancedCache<?,?> cache,
                                                                               Class<T> interceptorClass)