Package org.apache.zookeeper.server.util
Class MessageTracker
java.lang.Object
org.apache.zookeeper.server.util.MessageTracker
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 Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
final org.apache.zookeeper.server.util.MessageTracker.BufferedMessage
final long
final org.apache.zookeeper.server.util.MessageTracker.BufferedMessage
peekSent()
final long
void
trackReceived
(int packetType) void
trackReceived
(long timestamp) void
trackSent
(int packetType) void
trackSent
(long timestamp)
-
Field Details
-
MESSAGE_TRACKER_BUFFER_SIZE
- See Also:
-
MESSAGE_TRACKER_ENABLED
- See Also:
-
BUFFERED_MESSAGE_SIZE
public static final int BUFFERED_MESSAGE_SIZE
-
-
Constructor Details
-
MessageTracker
public MessageTracker(int buffer_size)
-
-
Method Details
-
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
-