Package org.jgroups.tests.perf

Class MPerf.MessageCounter

java.lang.Object

org.jgroups.tests.perf.MPerf.MessageCounter

Enclosing class:

MPerf

protected static class MPerf.MessageCounter
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected ConcurrentHashMap<Address,LongAdder>	countMap

Constructor Summary

Constructors

Constructor	Description
MessageCounter()

Method Summary

Modifier and Type	Method	Description
void	addMessage(Address source)
void	addMessage(Address source, long count)
String	printAverage(long start_time, int msg_size, boolean display_msg_src)
void	reset()
Map<Address,Long>	snapshot()
long	totalCount()
double	totalRate(long diff)

Methods inherited from class java.lang.Object

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

Field Details

countMap

protected ConcurrentHashMap<Address,LongAdder> countMap

Constructor Details

MessageCounter

public MessageCounter()

Method Details

addMessage

public void addMessage(Address source)

addMessage

public void addMessage(Address source,
 long count)

reset

public void reset()

totalCount

public long totalCount()

totalRate

public double totalRate(long diff)

snapshot

public Map<Address,Long> snapshot()

printAverage

public String printAverage(long start_time,
 int msg_size,
 boolean display_msg_src)