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

      • 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
      • 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()
      • 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()
      • 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)