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 java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.ConcurrentHashMap<Address,java.util.concurrent.atomic.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)
java.lang.String	printAverage(long start_time, int msg_size, boolean display_msg_src)
void	reset()
java.util.Map<Address,java.lang.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 Detail

countMap

protected java.util.concurrent.ConcurrentHashMap<Address,java.util.concurrent.atomic.LongAdder> countMap

Constructor Detail

MessageCounter

public MessageCounter()

Method Detail

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 java.util.Map<Address,java.lang.Long> snapshot()

printAverage

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