Package com.hypixel.hytale.server.core.io

Class PacketStatsRecorderImpl.PacketStatsEntry

java.lang.Object

com.hypixel.hytale.server.core.io.PacketStatsRecorderImpl.PacketStatsEntry

All Implemented Interfaces:

PacketStatsRecorder.PacketStatsEntry

Enclosing class:

PacketStatsRecorderImpl

public static class PacketStatsRecorderImpl.PacketStatsEntry
extends Object
implements PacketStatsRecorder.PacketStatsEntry

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	PacketStatsRecorderImpl.PacketStatsEntry.SizeRecord

Field Summary

Fields

Modifier and Type	Field	Description
static final MetricsRegistry<PacketStatsRecorderImpl.PacketStatsEntry>	METRICS_REGISTRY
private final int	packetId
private final AverageCollector	receivedCompressedAvg
private final AtomicLong	receivedCompressedMax
private final AtomicLong	receivedCompressedMin
private final AtomicLong	receivedCompressedTotal
private final AtomicInteger	receivedCount
private final Queue<PacketStatsRecorderImpl.PacketStatsEntry.SizeRecord>	receivedRecently
private final AverageCollector	receivedUncompressedAvg
private final AtomicLong	receivedUncompressedMax
private final AtomicLong	receivedUncompressedMin
private final AtomicLong	receivedUncompressedTotal
private final AverageCollector	sentCompressedAvg
private final AtomicLong	sentCompressedMax
private final AtomicLong	sentCompressedMin
private final AtomicLong	sentCompressedTotal
private final AtomicInteger	sentCount
private final Queue<PacketStatsRecorderImpl.PacketStatsEntry.SizeRecord>	sentRecently
private final AverageCollector	sentUncompressedAvg
private final AtomicLong	sentUncompressedMax
private final AtomicLong	sentUncompressedMin
private final AtomicLong	sentUncompressedTotal

Fields inherited from interface com.hypixel.hytale.protocol.io.PacketStatsRecorder.PacketStatsEntry

RECENT_SECONDS

Constructor Summary

Constructors

Constructor	Description
PacketStatsEntry(int packetId)

Method Summary

Modifier and Type	Method	Description
private PacketStatsRecorder.RecentStats	computeRecentStats(Queue<PacketStatsRecorderImpl.PacketStatsEntry.SizeRecord> queue)
String	getName()
int	getPacketId()
double	getReceivedCompressedAvg()
long	getReceivedCompressedMax()
long	getReceivedCompressedMin()
long	getReceivedCompressedTotal()
int	getReceivedCount()
PacketStatsRecorder.RecentStats	getReceivedRecently()
double	getReceivedUncompressedAvg()
long	getReceivedUncompressedMax()
long	getReceivedUncompressedMin()
long	getReceivedUncompressedTotal()
double	getSentCompressedAvg()
long	getSentCompressedMax()
long	getSentCompressedMin()
long	getSentCompressedTotal()
int	getSentCount()
PacketStatsRecorder.RecentStats	getSentRecently()
double	getSentUncompressedAvg()
long	getSentUncompressedMax()
long	getSentUncompressedMin()
long	getSentUncompressedTotal()
boolean	hasData()
private void	pruneOld(Queue<PacketStatsRecorderImpl.PacketStatsEntry.SizeRecord> queue, long now)
(package private) void	recordReceive(int uncompressedSize, int compressedSize)
(package private) void	recordSend(int uncompressedSize, int compressedSize)
void	reset()

Methods inherited from class java.lang.Object

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

Field Details

METRICS_REGISTRY

public static final MetricsRegistry<PacketStatsRecorderImpl.PacketStatsEntry> METRICS_REGISTRY

packetId

private final int packetId

sentCount

private final AtomicInteger sentCount

sentUncompressedTotal

private final AtomicLong sentUncompressedTotal

sentCompressedTotal

private final AtomicLong sentCompressedTotal

sentUncompressedMin

private final AtomicLong sentUncompressedMin

sentUncompressedMax

private final AtomicLong sentUncompressedMax

sentCompressedMin

private final AtomicLong sentCompressedMin

sentCompressedMax

private final AtomicLong sentCompressedMax

sentUncompressedAvg

private final AverageCollector sentUncompressedAvg

sentCompressedAvg

private final AverageCollector sentCompressedAvg

sentRecently

private final Queue<PacketStatsRecorderImpl.PacketStatsEntry.SizeRecord> sentRecently

receivedCount

private final AtomicInteger receivedCount

receivedUncompressedTotal

private final AtomicLong receivedUncompressedTotal

receivedCompressedTotal

private final AtomicLong receivedCompressedTotal

receivedUncompressedMin

private final AtomicLong receivedUncompressedMin

receivedUncompressedMax

private final AtomicLong receivedUncompressedMax

receivedCompressedMin

private final AtomicLong receivedCompressedMin

receivedCompressedMax

private final AtomicLong receivedCompressedMax

receivedUncompressedAvg

private final AverageCollector receivedUncompressedAvg

receivedCompressedAvg

private final AverageCollector receivedCompressedAvg

receivedRecently

private final Queue<PacketStatsRecorderImpl.PacketStatsEntry.SizeRecord> receivedRecently

Constructor Details

PacketStatsEntry

public PacketStatsEntry(int packetId)

Method Details

recordSend

void recordSend(int uncompressedSize,
 int compressedSize)

recordReceive

void recordReceive(int uncompressedSize,
 int compressedSize)

pruneOld

private void pruneOld(Queue<PacketStatsRecorderImpl.PacketStatsEntry.SizeRecord> queue,
 long now)

hasData

public boolean hasData()

Specified by:

hasData in interface PacketStatsRecorder.PacketStatsEntry

getPacketId

public int getPacketId()

Specified by:

getPacketId in interface PacketStatsRecorder.PacketStatsEntry

getName

@Nullable
public String getName()

Specified by:

getName in interface PacketStatsRecorder.PacketStatsEntry

getSentCount

public int getSentCount()

Specified by:

getSentCount in interface PacketStatsRecorder.PacketStatsEntry

getSentUncompressedTotal

public long getSentUncompressedTotal()

Specified by:

getSentUncompressedTotal in interface PacketStatsRecorder.PacketStatsEntry

getSentCompressedTotal

public long getSentCompressedTotal()

Specified by:

getSentCompressedTotal in interface PacketStatsRecorder.PacketStatsEntry

getSentUncompressedMin

public long getSentUncompressedMin()

Specified by:

getSentUncompressedMin in interface PacketStatsRecorder.PacketStatsEntry

getSentUncompressedMax

public long getSentUncompressedMax()

Specified by:

getSentUncompressedMax in interface PacketStatsRecorder.PacketStatsEntry

getSentCompressedMin

public long getSentCompressedMin()

Specified by:

getSentCompressedMin in interface PacketStatsRecorder.PacketStatsEntry

getSentCompressedMax

public long getSentCompressedMax()

Specified by:

getSentCompressedMax in interface PacketStatsRecorder.PacketStatsEntry

getSentUncompressedAvg

public double getSentUncompressedAvg()

Specified by:

getSentUncompressedAvg in interface PacketStatsRecorder.PacketStatsEntry

getSentCompressedAvg

public double getSentCompressedAvg()

Specified by:

getSentCompressedAvg in interface PacketStatsRecorder.PacketStatsEntry

getReceivedCount

public int getReceivedCount()

Specified by:

getReceivedCount in interface PacketStatsRecorder.PacketStatsEntry

getReceivedUncompressedTotal

public long getReceivedUncompressedTotal()

Specified by:

getReceivedUncompressedTotal in interface PacketStatsRecorder.PacketStatsEntry

getReceivedCompressedTotal

public long getReceivedCompressedTotal()

Specified by:

getReceivedCompressedTotal in interface PacketStatsRecorder.PacketStatsEntry

getReceivedUncompressedMin

public long getReceivedUncompressedMin()

Specified by:

getReceivedUncompressedMin in interface PacketStatsRecorder.PacketStatsEntry

getReceivedUncompressedMax

public long getReceivedUncompressedMax()

Specified by:

getReceivedUncompressedMax in interface PacketStatsRecorder.PacketStatsEntry

getReceivedCompressedMin

public long getReceivedCompressedMin()

Specified by:

getReceivedCompressedMin in interface PacketStatsRecorder.PacketStatsEntry

getReceivedCompressedMax

public long getReceivedCompressedMax()

Specified by:

getReceivedCompressedMax in interface PacketStatsRecorder.PacketStatsEntry

getReceivedUncompressedAvg

public double getReceivedUncompressedAvg()

Specified by:

getReceivedUncompressedAvg in interface PacketStatsRecorder.PacketStatsEntry

getReceivedCompressedAvg

public double getReceivedCompressedAvg()

Specified by:

getReceivedCompressedAvg in interface PacketStatsRecorder.PacketStatsEntry

getSentRecently

@Nonnull
public PacketStatsRecorder.RecentStats getSentRecently()

Specified by:

getSentRecently in interface PacketStatsRecorder.PacketStatsEntry

getReceivedRecently

@Nonnull
public PacketStatsRecorder.RecentStats getReceivedRecently()

Specified by:

getReceivedRecently in interface PacketStatsRecorder.PacketStatsEntry

computeRecentStats

private PacketStatsRecorder.RecentStats computeRecentStats(Queue<PacketStatsRecorderImpl.PacketStatsEntry.SizeRecord> queue)

reset

public void reset()