Class 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 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
    • Constructor Detail

      • MsgStats

        public MsgStats()
    • 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)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object