Package com.google.code.yanf4j.statistics.impl

Class SimpleStatistics

java.lang.Object

com.google.code.yanf4j.statistics.impl.SimpleStatistics

All Implemented Interfaces:

Statistics

public class SimpleStatistics
extends Object
implements Statistics

A simple statistics implementation

Field Summary

Fields

Modifier and Type	Field	Description
private AtomicLong	acceptCount
private AtomicLong	processMessageCount
private AtomicLong	processMessageTotalTime
private double	receiveThroughputLimit
private AtomicLong	recvMessageCount
private AtomicLong	recvMessageTotalSize
private double	sendThroughputLimit
private boolean	started
private long	startTime
private long	stopTime
private AtomicLong	writeMessageCount
private AtomicLong	writeMessageTotalSize

Constructor Summary

Constructors

Constructor	Description
SimpleStatistics()

Method Summary

Modifier and Type	Method	Description
double	getAcceptCountPerSecond()
double	getProcessedMessageAverageTime()
long	getProcessedMessageCount()
double	getReceiveBytesPerSecond()
final double	getReceiveThroughputLimit()
long	getRecvMessageAverageSize()
long	getRecvMessageCount()
double	getRecvMessageCountPerSecond()
long	getRecvMessageTotalSize()
double	getSendBytesPerSecond()
double	getSendThroughputLimit()
long	getStartedTime()
long	getWriteMessageAverageSize()
long	getWriteMessageCount()
double	getWriteMessageCountPerSecond()
long	getWriteMessageTotalSize()
boolean	isReceiveOverFlow()	Check session if receive bytes per second is over flow controll
boolean	isSendOverFlow()	Check session if receive bytes per second is over flow controll
boolean	isStatistics()
void	reset()
void	restart()
void	setReceiveThroughputLimit(double receivePacketRate)
void	setSendThroughputLimit(double sendThroughputLimit)
void	start()
void	statisticsAccept()
void	statisticsProcess(long n)
void	statisticsRead(long n)
void	statisticsWrite(long n)
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

started

private boolean started

receiveThroughputLimit

private double receiveThroughputLimit

sendThroughputLimit

private double sendThroughputLimit

startTime

private long startTime

stopTime

private long stopTime

recvMessageCount

private AtomicLong recvMessageCount

recvMessageTotalSize

private AtomicLong recvMessageTotalSize

writeMessageCount

private AtomicLong writeMessageCount

writeMessageTotalSize

private AtomicLong writeMessageTotalSize

processMessageCount

private AtomicLong processMessageCount

acceptCount

private AtomicLong acceptCount

processMessageTotalTime

private AtomicLong processMessageTotalTime

Constructor Details

SimpleStatistics

public SimpleStatistics()

Method Details

isStatistics

public boolean isStatistics()

Specified by:

isStatistics in interface Statistics

reset

public void reset()

Specified by:

reset in interface Statistics

setReceiveThroughputLimit

public void setReceiveThroughputLimit(double receivePacketRate)

Specified by:

setReceiveThroughputLimit in interface Statistics

isReceiveOverFlow

public boolean isReceiveOverFlow()

Check session if receive bytes per second is over flow controll

Specified by:

isReceiveOverFlow in interface Statistics

Returns:

isSendOverFlow

public boolean isSendOverFlow()

Check session if receive bytes per second is over flow controll

Specified by:

isSendOverFlow in interface Statistics

Returns:

getSendThroughputLimit

public double getSendThroughputLimit()

Specified by:

getSendThroughputLimit in interface Statistics

setSendThroughputLimit

public void setSendThroughputLimit(double sendThroughputLimit)

Specified by:

setSendThroughputLimit in interface Statistics

getReceiveThroughputLimit

public final double getReceiveThroughputLimit()

Specified by:

getReceiveThroughputLimit in interface Statistics

restart

public void restart()

Specified by:

restart in interface Statistics

getStartedTime

public long getStartedTime()

Specified by:

getStartedTime in interface Statistics

getProcessedMessageAverageTime

public double getProcessedMessageAverageTime()

Specified by:

getProcessedMessageAverageTime in interface Statistics

getProcessedMessageCount

public long getProcessedMessageCount()

Specified by:

getProcessedMessageCount in interface Statistics

statisticsProcess

public void statisticsProcess(long n)

Specified by:

statisticsProcess in interface Statistics

start

public void start()

Specified by:

start in interface Statistics

stop

public void stop()

Specified by:

stop in interface Statistics

statisticsRead

public void statisticsRead(long n)

Specified by:

statisticsRead in interface Statistics

getRecvMessageCount

public long getRecvMessageCount()

Specified by:

getRecvMessageCount in interface Statistics

getRecvMessageTotalSize

public long getRecvMessageTotalSize()

Specified by:

getRecvMessageTotalSize in interface Statistics

getWriteMessageCount

public long getWriteMessageCount()

Specified by:

getWriteMessageCount in interface Statistics

getWriteMessageTotalSize

public long getWriteMessageTotalSize()

Specified by:

getWriteMessageTotalSize in interface Statistics

statisticsWrite

public void statisticsWrite(long n)

Specified by:

statisticsWrite in interface Statistics

getRecvMessageAverageSize

public long getRecvMessageAverageSize()

Specified by:

getRecvMessageAverageSize in interface Statistics

getRecvMessageCountPerSecond

public double getRecvMessageCountPerSecond()

Specified by:

getRecvMessageCountPerSecond in interface Statistics

getWriteMessageCountPerSecond

public double getWriteMessageCountPerSecond()

Specified by:

getWriteMessageCountPerSecond in interface Statistics

getWriteMessageAverageSize

public long getWriteMessageAverageSize()

Specified by:

getWriteMessageAverageSize in interface Statistics

getAcceptCountPerSecond

public double getAcceptCountPerSecond()

Specified by:

getAcceptCountPerSecond in interface Statistics

getReceiveBytesPerSecond

public double getReceiveBytesPerSecond()

Specified by:

getReceiveBytesPerSecond in interface Statistics

getSendBytesPerSecond

public double getSendBytesPerSecond()

Specified by:

getSendBytesPerSecond in interface Statistics

statisticsAccept

public void statisticsAccept()

Specified by:

statisticsAccept in interface Statistics