Class SimpleStatistics
- java.lang.Object
-
- com.google.code.yanf4j.statistics.impl.SimpleStatistics
-
- All Implemented Interfaces:
Statistics
public class SimpleStatistics extends java.lang.Object implements Statistics
A simple statistics implementation
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.atomic.AtomicLong
acceptCount
private java.util.concurrent.atomic.AtomicLong
processMessageCount
private java.util.concurrent.atomic.AtomicLong
processMessageTotalTime
private double
receiveThroughputLimit
private java.util.concurrent.atomic.AtomicLong
recvMessageCount
private java.util.concurrent.atomic.AtomicLong
recvMessageTotalSize
private double
sendThroughputLimit
private boolean
started
private long
startTime
private long
stopTime
private java.util.concurrent.atomic.AtomicLong
writeMessageCount
private java.util.concurrent.atomic.AtomicLong
writeMessageTotalSize
-
Constructor Summary
Constructors Constructor Description SimpleStatistics()
-
Method Summary
-
-
-
Field Detail
-
started
private boolean started
-
receiveThroughputLimit
private double receiveThroughputLimit
-
sendThroughputLimit
private double sendThroughputLimit
-
startTime
private long startTime
-
stopTime
private long stopTime
-
recvMessageCount
private java.util.concurrent.atomic.AtomicLong recvMessageCount
-
recvMessageTotalSize
private java.util.concurrent.atomic.AtomicLong recvMessageTotalSize
-
writeMessageCount
private java.util.concurrent.atomic.AtomicLong writeMessageCount
-
writeMessageTotalSize
private java.util.concurrent.atomic.AtomicLong writeMessageTotalSize
-
processMessageCount
private java.util.concurrent.atomic.AtomicLong processMessageCount
-
acceptCount
private java.util.concurrent.atomic.AtomicLong acceptCount
-
processMessageTotalTime
private java.util.concurrent.atomic.AtomicLong processMessageTotalTime
-
-
Method Detail
-
isStatistics
public boolean isStatistics()
- Specified by:
isStatistics
in interfaceStatistics
-
reset
public void reset()
- Specified by:
reset
in interfaceStatistics
-
setReceiveThroughputLimit
public void setReceiveThroughputLimit(double receivePacketRate)
- Specified by:
setReceiveThroughputLimit
in interfaceStatistics
-
isReceiveOverFlow
public boolean isReceiveOverFlow()
Check session if receive bytes per second is over flow controll- Specified by:
isReceiveOverFlow
in interfaceStatistics
- Returns:
-
isSendOverFlow
public boolean isSendOverFlow()
Check session if receive bytes per second is over flow controll- Specified by:
isSendOverFlow
in interfaceStatistics
- Returns:
-
getSendThroughputLimit
public double getSendThroughputLimit()
- Specified by:
getSendThroughputLimit
in interfaceStatistics
-
setSendThroughputLimit
public void setSendThroughputLimit(double sendThroughputLimit)
- Specified by:
setSendThroughputLimit
in interfaceStatistics
-
getReceiveThroughputLimit
public final double getReceiveThroughputLimit()
- Specified by:
getReceiveThroughputLimit
in interfaceStatistics
-
restart
public void restart()
- Specified by:
restart
in interfaceStatistics
-
getStartedTime
public long getStartedTime()
- Specified by:
getStartedTime
in interfaceStatistics
-
getProcessedMessageAverageTime
public double getProcessedMessageAverageTime()
- Specified by:
getProcessedMessageAverageTime
in interfaceStatistics
-
getProcessedMessageCount
public long getProcessedMessageCount()
- Specified by:
getProcessedMessageCount
in interfaceStatistics
-
statisticsProcess
public void statisticsProcess(long n)
- Specified by:
statisticsProcess
in interfaceStatistics
-
start
public void start()
- Specified by:
start
in interfaceStatistics
-
stop
public void stop()
- Specified by:
stop
in interfaceStatistics
-
statisticsRead
public void statisticsRead(long n)
- Specified by:
statisticsRead
in interfaceStatistics
-
getRecvMessageCount
public long getRecvMessageCount()
- Specified by:
getRecvMessageCount
in interfaceStatistics
-
getRecvMessageTotalSize
public long getRecvMessageTotalSize()
- Specified by:
getRecvMessageTotalSize
in interfaceStatistics
-
getWriteMessageCount
public long getWriteMessageCount()
- Specified by:
getWriteMessageCount
in interfaceStatistics
-
getWriteMessageTotalSize
public long getWriteMessageTotalSize()
- Specified by:
getWriteMessageTotalSize
in interfaceStatistics
-
statisticsWrite
public void statisticsWrite(long n)
- Specified by:
statisticsWrite
in interfaceStatistics
-
getRecvMessageAverageSize
public long getRecvMessageAverageSize()
- Specified by:
getRecvMessageAverageSize
in interfaceStatistics
-
getRecvMessageCountPerSecond
public double getRecvMessageCountPerSecond()
- Specified by:
getRecvMessageCountPerSecond
in interfaceStatistics
-
getWriteMessageCountPerSecond
public double getWriteMessageCountPerSecond()
- Specified by:
getWriteMessageCountPerSecond
in interfaceStatistics
-
getWriteMessageAverageSize
public long getWriteMessageAverageSize()
- Specified by:
getWriteMessageAverageSize
in interfaceStatistics
-
getAcceptCountPerSecond
public double getAcceptCountPerSecond()
- Specified by:
getAcceptCountPerSecond
in interfaceStatistics
-
getReceiveBytesPerSecond
public double getReceiveBytesPerSecond()
- Specified by:
getReceiveBytesPerSecond
in interfaceStatistics
-
getSendBytesPerSecond
public double getSendBytesPerSecond()
- Specified by:
getSendBytesPerSecond
in interfaceStatistics
-
statisticsAccept
public void statisticsAccept()
- Specified by:
statisticsAccept
in interfaceStatistics
-
-