Class DefaultStatistics
java.lang.Object
com.google.code.yanf4j.statistics.impl.DefaultStatistics
- All Implemented Interfaces:
Statistics
Default statistics implementation
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptiondouble
double
long
double
final double
long
long
double
long
double
double
long
long
long
double
long
boolean
Check session if receive bytes per second is over flow controllboolean
Check session if receive bytes per second is over flow controllboolean
void
reset()
void
restart()
void
setReceiveThroughputLimit
(double receivePacketRate) void
setSendThroughputLimit
(double sendThroughputLimit) void
start()
void
void
statisticsProcess
(long n) void
statisticsRead
(long n) void
statisticsWrite
(long n) void
stop()
-
Constructor Details
-
DefaultStatistics
public DefaultStatistics()
-
-
Method Details
-
start
public void start()- Specified by:
start
in interfaceStatistics
-
getSendBytesPerSecond
public double getSendBytesPerSecond()- Specified by:
getSendBytesPerSecond
in interfaceStatistics
-
getReceiveBytesPerSecond
public double getReceiveBytesPerSecond()- Specified by:
getReceiveBytesPerSecond
in interfaceStatistics
-
isStatistics
public boolean isStatistics()- Specified by:
isStatistics
in interfaceStatistics
-
getStartedTime
public long getStartedTime()- Specified by:
getStartedTime
in interfaceStatistics
-
reset
public void reset()- Specified by:
reset
in interfaceStatistics
-
restart
public void restart()- Specified by:
restart
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
-
stop
public void stop()- Specified by:
stop
in interfaceStatistics
-
getRecvMessageCount
public long getRecvMessageCount()- Specified by:
getRecvMessageCount
in interfaceStatistics
-
getRecvMessageTotalSize
public long getRecvMessageTotalSize()- Specified by:
getRecvMessageTotalSize
in interfaceStatistics
-
getRecvMessageAverageSize
public long getRecvMessageAverageSize()- Specified by:
getRecvMessageAverageSize
in interfaceStatistics
-
getRecvMessageCountPerSecond
public double getRecvMessageCountPerSecond()- Specified by:
getRecvMessageCountPerSecond
in interfaceStatistics
-
getWriteMessageCount
public long getWriteMessageCount()- Specified by:
getWriteMessageCount
in interfaceStatistics
-
getWriteMessageTotalSize
public long getWriteMessageTotalSize()- Specified by:
getWriteMessageTotalSize
in interfaceStatistics
-
getWriteMessageAverageSize
public long getWriteMessageAverageSize()- Specified by:
getWriteMessageAverageSize
in interfaceStatistics
-
statisticsRead
public void statisticsRead(long n) - Specified by:
statisticsRead
in interfaceStatistics
-
statisticsWrite
public void statisticsWrite(long n) - Specified by:
statisticsWrite
in interfaceStatistics
-
getWriteMessageCountPerSecond
public double getWriteMessageCountPerSecond()- Specified by:
getWriteMessageCountPerSecond
in interfaceStatistics
-
getAcceptCountPerSecond
public double getAcceptCountPerSecond()- Specified by:
getAcceptCountPerSecond
in interfaceStatistics
-
statisticsAccept
public void statisticsAccept()- Specified by:
statisticsAccept
in interfaceStatistics
-
setReceiveThroughputLimit
public void setReceiveThroughputLimit(double receivePacketRate) - Specified by:
setReceiveThroughputLimit
in interfaceStatistics
-
isReceiveOverFlow
public boolean isReceiveOverFlow()Description copied from interface:Statistics
Check session if receive bytes per second is over flow controll- Specified by:
isReceiveOverFlow
in interfaceStatistics
- Returns:
-
isSendOverFlow
public boolean isSendOverFlow()Description copied from interface:Statistics
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
-