Package org.jgroups.protocols

Class MsgStats

java.lang.Object

org.jgroups.protocols.MsgStats

public class MsgStats
extends java.lang.Object

Class which has all the stats about received/sent messages etc. (in TP)

Since:

4.0

Author:

Bela Ban

Field Summary

Fields

Modifier and Type	Field	Description
protected AverageMinMax	avg_batch_size	The average number of messages in a received MessageBatch
protected boolean	enabled
protected java.util.concurrent.atomic.LongAdder	num_batches_received
protected java.util.concurrent.atomic.LongAdder	num_batches_sent
protected java.util.concurrent.atomic.LongAdder	num_mcast_bytes_received
protected java.util.concurrent.atomic.LongAdder	num_mcast_bytes_sent
protected java.util.concurrent.atomic.LongAdder	num_mcasts_received
protected java.util.concurrent.atomic.LongAdder	num_mcasts_sent
protected java.util.concurrent.atomic.LongAdder	num_single_msgs_received
protected java.util.concurrent.atomic.LongAdder	num_single_msgs_sent
protected java.util.concurrent.atomic.LongAdder	num_ucast_bytes_received
protected java.util.concurrent.atomic.LongAdder	num_ucast_bytes_sent
protected java.util.concurrent.atomic.LongAdder	num_ucasts_received
protected java.util.concurrent.atomic.LongAdder	num_ucasts_sent

Constructor Summary

Constructors

Constructor	Description
MsgStats()

Method Summary

Modifier and Type	Method	Description
protected MsgStats	add(java.util.concurrent.atomic.LongAdder msgs, int num_msgs, java.util.concurrent.atomic.LongAdder bytes, int length)
MsgStats	enable(boolean b)
boolean	enabled()
AverageMinMax	getAvgBatchSize()
long	getNumBatchesReceived()
long	getNumBatchesSent()
long	getNumBytesReceived()
long	getNumBytesSent()
long	getNumMcastBytesReceived()
long	getNumMcastBytesSent()
long	getNumMcastsReceived()
long	getNumMcastsSent()
long	getNumMsgsReceived()
long	getNumMsgsSent()
long	getNumSingleMsgsSent()
long	getNumUcastBytesReceived()
long	getNumUcastBytesSent()
long	getNumUcastsReceived()
long	getNumUcastsSent()
MsgStats	incrNumBatchesSent()
MsgStats	incrNumBatchesSent(int n)
MsgStats	incrNumSingleMsgsSent()
MsgStats	received(Address dest, int length)
MsgStats	received(Message msg)
MsgStats	received(MessageBatch batch)
MsgStats	reset()
MsgStats	sent(Address dest, int length)
MsgStats	sent(Message msg)
java.lang.String	toString()
java.lang.String	toString(boolean details)

Methods inherited from class java.lang.Object

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

Field Detail

enabled

protected boolean enabled

num_ucasts_sent

protected final java.util.concurrent.atomic.LongAdder num_ucasts_sent

num_ucasts_received

protected final java.util.concurrent.atomic.LongAdder num_ucasts_received

num_mcasts_sent

protected final java.util.concurrent.atomic.LongAdder num_mcasts_sent

num_mcasts_received

protected final java.util.concurrent.atomic.LongAdder num_mcasts_received

num_single_msgs_sent

protected final java.util.concurrent.atomic.LongAdder num_single_msgs_sent

num_single_msgs_received

protected final java.util.concurrent.atomic.LongAdder num_single_msgs_received

num_batches_sent

protected final java.util.concurrent.atomic.LongAdder num_batches_sent

num_batches_received

protected final java.util.concurrent.atomic.LongAdder num_batches_received

avg_batch_size

protected final AverageMinMax avg_batch_size

The average number of messages in a received MessageBatch

num_mcast_bytes_sent

protected final java.util.concurrent.atomic.LongAdder num_mcast_bytes_sent

num_mcast_bytes_received

protected final java.util.concurrent.atomic.LongAdder num_mcast_bytes_received

num_ucast_bytes_sent

protected final java.util.concurrent.atomic.LongAdder num_ucast_bytes_sent

num_ucast_bytes_received

protected final java.util.concurrent.atomic.LongAdder num_ucast_bytes_received

Constructor Detail

MsgStats

public MsgStats()

Method Detail

enabled

public boolean enabled()

enable

public MsgStats enable(boolean b)

getNumMsgsSent

public long getNumMsgsSent()

getNumMsgsReceived

public long getNumMsgsReceived()

getAvgBatchSize

public AverageMinMax getAvgBatchSize()

getNumBytesSent

public long getNumBytesSent()

getNumBytesReceived

public long getNumBytesReceived()

getNumUcastsSent

public long getNumUcastsSent()

getNumMcastsSent

public long getNumMcastsSent()

getNumUcastsReceived

public long getNumUcastsReceived()

getNumMcastsReceived

public long getNumMcastsReceived()

getNumSingleMsgsSent

public long getNumSingleMsgsSent()

incrNumSingleMsgsSent

public MsgStats incrNumSingleMsgsSent()

getNumBatchesSent

public long getNumBatchesSent()

incrNumBatchesSent

public MsgStats incrNumBatchesSent()

incrNumBatchesSent

public MsgStats incrNumBatchesSent(int n)

getNumBatchesReceived

public long getNumBatchesReceived()

getNumUcastBytesSent

public long getNumUcastBytesSent()

getNumMcastBytesSent

public long getNumMcastBytesSent()

getNumUcastBytesReceived

public long getNumUcastBytesReceived()

getNumMcastBytesReceived

public long getNumMcastBytesReceived()

sent

public MsgStats sent(Address dest,
                     int length)

sent

public MsgStats sent(Message msg)

received

public MsgStats received(Address dest,
                         int length)

received

public MsgStats received(Message msg)

received

public MsgStats received(MessageBatch batch)

reset

public MsgStats reset()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

toString

public java.lang.String toString(boolean details)

add

protected MsgStats add(java.util.concurrent.atomic.LongAdder msgs,
                       int num_msgs,
                       java.util.concurrent.atomic.LongAdder bytes,
                       int length)