Package org.infinispan.stats.container

Class ConcurrentGlobalContainer

java.lang.Object

org.infinispan.stats.container.ConcurrentGlobalContainer

public final class ConcurrentGlobalContainer
extends Object

Thread safe cache statistics that allows multiple writers and reader at the same time.

Since:

5.2

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor	Description
ConcurrentGlobalContainer(TimeService timeService)

Method Summary

Modifier and Type	Method	Description
void	add(ExtendedStatistic stat, double value, boolean local)
void	dumpTo(PrintWriter writer)
AtomicBoolean	flushing()
static int	getLocalIndex(ExtendedStatistic stat)
static int	getRemoteIndex(ExtendedStatistic stat)
StatisticsSnapshot	getSnapshot()
boolean	isReset()
void	merge(double[] toMerge, boolean local)
BlockingQueue<?>	queue()
void	reset()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentGlobalContainer

public ConcurrentGlobalContainer(TimeService timeService)

Method Detail

add

public final void add(ExtendedStatistic stat,
                      double value,
                      boolean local)

merge

public final void merge(double[] toMerge,
                        boolean local)

getSnapshot

public final StatisticsSnapshot getSnapshot()

reset

public final void reset()

getLocalIndex

public static int getLocalIndex(ExtendedStatistic stat)

getRemoteIndex

public static int getRemoteIndex(ExtendedStatistic stat)

queue

public final BlockingQueue<?> queue()

Returns:

TEST ONLY!!

flushing

public final AtomicBoolean flushing()

Returns:

TEST ONLY!!

isReset

public final boolean isReset()

Returns:

TEST ONLY!!

dumpTo

public final void dumpTo(PrintWriter writer)