Class MessageTracker


  • public class MessageTracker
    extends Object
    This class provides a way of buffering sentBuffer and receivedBuffer messages in order. It uses EvictingQueue of size BUFFERED_MESSAGE_SIZE to store the messages. When the queue is full it overrides the oldest in a circular manner. This class does doe not provide thread safety.
    • Field Detail

      • BUFFERED_MESSAGE_SIZE

        public static final int BUFFERED_MESSAGE_SIZE
    • Constructor Detail

      • MessageTracker

        public MessageTracker​(int buffer_size)
    • Method Detail

      • trackSent

        public void trackSent​(long timestamp)
      • trackSent

        public void trackSent​(int packetType)
      • trackReceived

        public void trackReceived​(long timestamp)
      • trackReceived

        public void trackReceived​(int packetType)
      • peekSent

        public final org.apache.zookeeper.server.util.MessageTracker.BufferedMessage peekSent()
      • peekReceived

        public final org.apache.zookeeper.server.util.MessageTracker.BufferedMessage peekReceived()
      • peekSentTimestamp

        public final long peekSentTimestamp()
      • peekReceivedTimestamp

        public final long peekReceivedTimestamp()
      • dumpToLog

        public void dumpToLog​(String serverAddress)