Package org.jgroups.protocols
Class MsgStats
- java.lang.Object
- 
- org.jgroups.protocols.MsgStats
 
- 
 public class MsgStats extends java.lang.ObjectClass which has all the stats about received/sent messages etc (in TP)- Since:
- 4.0
- Author:
- Bela Ban
 
- 
- 
Field SummaryFields Modifier and Type Field Description protected java.util.concurrent.atomic.LongAddernum_batches_receivedprotected java.util.concurrent.atomic.LongAddernum_batches_sentprotected java.util.concurrent.atomic.LongAddernum_bytes_receivedprotected java.util.concurrent.atomic.LongAddernum_bytes_sentprotected java.util.concurrent.atomic.LongAddernum_internal_msgs_receivedprotected java.util.concurrent.atomic.LongAddernum_msgs_receivedprotected java.util.concurrent.atomic.LongAddernum_msgs_sentprotected java.util.concurrent.atomic.LongAddernum_oob_msgs_receivedprotected java.util.concurrent.atomic.AtomicIntegernum_rejected_msgsprotected java.util.concurrent.atomic.LongAddernum_single_msgs_sentprotected java.util.concurrent.atomic.AtomicIntegernum_threads_spawned
 - 
Constructor SummaryConstructors Constructor Description MsgStats()
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description longgetNumBatchesReceived()longgetNumBatchesSent()longgetNumBytesReceived()longgetNumBytesSent()longgetNumInternalMsgsReceived()longgetNumMsgsReceived()longgetNumMsgsSent()longgetNumOOBMsgsReceived()intgetNumRejectedMsgs()longgetNumSingleMsgsSent()intgetNumThreadsSpawned()MsgStatsincrNumBatchesReceived(int d)MsgStatsincrNumBatchesSent(int d)MsgStatsincrNumBytesReceived(int d)MsgStatsincrNumBytesSent(int d)MsgStatsincrNumInternalMsgsReceived(int d)MsgStatsincrNumMsgsReceived(int d)MsgStatsincrNumMsgsSent(int d)MsgStatsincrNumOOBMsgsReceived(int d)MsgStatsincrNumRejectedMsgs(int d)MsgStatsincrNumSingleMsgsSent(int d)MsgStatsincrNumThreadsSpawned(int d)MsgStatsreset()java.lang.StringtoString()
 
- 
- 
- 
Field Detail- 
num_msgs_sentprotected final java.util.concurrent.atomic.LongAdder num_msgs_sent 
 - 
num_msgs_receivedprotected final java.util.concurrent.atomic.LongAdder num_msgs_received 
 - 
num_single_msgs_sentprotected final java.util.concurrent.atomic.LongAdder num_single_msgs_sent 
 - 
num_oob_msgs_receivedprotected final java.util.concurrent.atomic.LongAdder num_oob_msgs_received 
 - 
num_internal_msgs_receivedprotected final java.util.concurrent.atomic.LongAdder num_internal_msgs_received 
 - 
num_batches_sentprotected final java.util.concurrent.atomic.LongAdder num_batches_sent 
 - 
num_batches_receivedprotected final java.util.concurrent.atomic.LongAdder num_batches_received 
 - 
num_bytes_sentprotected final java.util.concurrent.atomic.LongAdder num_bytes_sent 
 - 
num_bytes_receivedprotected final java.util.concurrent.atomic.LongAdder num_bytes_received 
 - 
num_rejected_msgsprotected final java.util.concurrent.atomic.AtomicInteger num_rejected_msgs 
 - 
num_threads_spawnedprotected final java.util.concurrent.atomic.AtomicInteger num_threads_spawned 
 
- 
 - 
Method Detail- 
getNumMsgsSentpublic long getNumMsgsSent() 
 - 
incrNumMsgsSentpublic MsgStats incrNumMsgsSent(int d) 
 - 
getNumMsgsReceivedpublic long getNumMsgsReceived() 
 - 
incrNumMsgsReceivedpublic MsgStats incrNumMsgsReceived(int d) 
 - 
getNumOOBMsgsReceivedpublic long getNumOOBMsgsReceived() 
 - 
incrNumOOBMsgsReceivedpublic MsgStats incrNumOOBMsgsReceived(int d) 
 - 
getNumInternalMsgsReceivedpublic long getNumInternalMsgsReceived() 
 - 
incrNumInternalMsgsReceivedpublic MsgStats incrNumInternalMsgsReceived(int d) 
 - 
getNumSingleMsgsSentpublic long getNumSingleMsgsSent() 
 - 
incrNumSingleMsgsSentpublic MsgStats incrNumSingleMsgsSent(int d) 
 - 
getNumBatchesSentpublic long getNumBatchesSent() 
 - 
incrNumBatchesSentpublic MsgStats incrNumBatchesSent(int d) 
 - 
getNumBatchesReceivedpublic long getNumBatchesReceived() 
 - 
incrNumBatchesReceivedpublic MsgStats incrNumBatchesReceived(int d) 
 - 
getNumBytesSentpublic long getNumBytesSent() 
 - 
incrNumBytesSentpublic MsgStats incrNumBytesSent(int d) 
 - 
getNumBytesReceivedpublic long getNumBytesReceived() 
 - 
incrNumBytesReceivedpublic MsgStats incrNumBytesReceived(int d) 
 - 
getNumRejectedMsgspublic int getNumRejectedMsgs() 
 - 
incrNumRejectedMsgspublic MsgStats incrNumRejectedMsgs(int d) 
 - 
getNumThreadsSpawnedpublic int getNumThreadsSpawned() 
 - 
incrNumThreadsSpawnedpublic MsgStats incrNumThreadsSpawned(int d) 
 - 
resetpublic MsgStats reset() 
 - 
toStringpublic java.lang.String toString() - Overrides:
- toStringin class- java.lang.Object
 
 
- 
 
-