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 java.util.concurrent.atomic.LongAdder
num_batches_received
protected java.util.concurrent.atomic.LongAdder
num_batches_sent
protected java.util.concurrent.atomic.LongAdder
num_bytes_received
protected java.util.concurrent.atomic.LongAdder
num_bytes_sent
protected java.util.concurrent.atomic.LongAdder
num_internal_msgs_received
protected java.util.concurrent.atomic.LongAdder
num_msgs_received
protected java.util.concurrent.atomic.LongAdder
num_msgs_sent
protected java.util.concurrent.atomic.LongAdder
num_oob_msgs_received
protected java.util.concurrent.atomic.AtomicInteger
num_rejected_msgs
protected java.util.concurrent.atomic.LongAdder
num_single_msgs_sent
protected java.util.concurrent.atomic.AtomicInteger
num_threads_spawned
-
Constructor Summary
Constructors Constructor Description MsgStats()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
getNumBatchesReceived()
long
getNumBatchesSent()
long
getNumBytesReceived()
long
getNumBytesSent()
long
getNumInternalMsgsReceived()
long
getNumMsgsReceived()
long
getNumMsgsSent()
long
getNumOOBMsgsReceived()
int
getNumRejectedMsgs()
long
getNumSingleMsgsSent()
int
getNumThreadsSpawned()
MsgStats
incrNumBatchesReceived(int d)
MsgStats
incrNumBatchesSent(int d)
MsgStats
incrNumBytesReceived(int d)
MsgStats
incrNumBytesSent(int d)
MsgStats
incrNumInternalMsgsReceived(int d)
MsgStats
incrNumMsgsReceived(int d)
MsgStats
incrNumMsgsSent(int d)
MsgStats
incrNumOOBMsgsReceived(int d)
MsgStats
incrNumRejectedMsgs(int d)
MsgStats
incrNumSingleMsgsSent(int d)
MsgStats
incrNumThreadsSpawned(int d)
MsgStats
reset()
java.lang.String
toString()
-
-
-
Field Detail
-
num_msgs_sent
protected final java.util.concurrent.atomic.LongAdder num_msgs_sent
-
num_msgs_received
protected final java.util.concurrent.atomic.LongAdder num_msgs_received
-
num_single_msgs_sent
protected final java.util.concurrent.atomic.LongAdder num_single_msgs_sent
-
num_oob_msgs_received
protected final java.util.concurrent.atomic.LongAdder num_oob_msgs_received
-
num_internal_msgs_received
protected final java.util.concurrent.atomic.LongAdder num_internal_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
-
num_bytes_sent
protected final java.util.concurrent.atomic.LongAdder num_bytes_sent
-
num_bytes_received
protected final java.util.concurrent.atomic.LongAdder num_bytes_received
-
num_rejected_msgs
protected final java.util.concurrent.atomic.AtomicInteger num_rejected_msgs
-
num_threads_spawned
protected final java.util.concurrent.atomic.AtomicInteger num_threads_spawned
-
-
Method Detail
-
getNumMsgsSent
public long getNumMsgsSent()
-
incrNumMsgsSent
public MsgStats incrNumMsgsSent(int d)
-
getNumMsgsReceived
public long getNumMsgsReceived()
-
incrNumMsgsReceived
public MsgStats incrNumMsgsReceived(int d)
-
getNumOOBMsgsReceived
public long getNumOOBMsgsReceived()
-
incrNumOOBMsgsReceived
public MsgStats incrNumOOBMsgsReceived(int d)
-
getNumInternalMsgsReceived
public long getNumInternalMsgsReceived()
-
incrNumInternalMsgsReceived
public MsgStats incrNumInternalMsgsReceived(int d)
-
getNumSingleMsgsSent
public long getNumSingleMsgsSent()
-
incrNumSingleMsgsSent
public MsgStats incrNumSingleMsgsSent(int d)
-
getNumBatchesSent
public long getNumBatchesSent()
-
incrNumBatchesSent
public MsgStats incrNumBatchesSent(int d)
-
getNumBatchesReceived
public long getNumBatchesReceived()
-
incrNumBatchesReceived
public MsgStats incrNumBatchesReceived(int d)
-
getNumBytesSent
public long getNumBytesSent()
-
incrNumBytesSent
public MsgStats incrNumBytesSent(int d)
-
getNumBytesReceived
public long getNumBytesReceived()
-
incrNumBytesReceived
public MsgStats incrNumBytesReceived(int d)
-
getNumRejectedMsgs
public int getNumRejectedMsgs()
-
incrNumRejectedMsgs
public MsgStats incrNumRejectedMsgs(int d)
-
getNumThreadsSpawned
public int getNumThreadsSpawned()
-
incrNumThreadsSpawned
public MsgStats incrNumThreadsSpawned(int d)
-
reset
public MsgStats reset()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-