classpublicabstractPriority 2

PacketHandler

com.hypixel.hytale.server.core.io.PacketHandler

implements IPacketReceiver

Methods

Public Methods

Fields

Constructors

Constants

intFIVE_MINUTE_INDEX= 2

AttributeKey<Long>LOGIN_START_ATTRIBUTE_KEY= AttributeKey.newInstance("LOGIN_START")

HytaleLoggerLOGIN_TIMING_LOGGER= HytaleLogger.get("LoginTiming")

intMAX_PACKET_ID= 512

MetricsRegistry<PacketHandler.PingInfo>METRICS_REGISTRY= new MetricsRegistry<PacketHandler.PingInfo>() .register("PingType", pingInfo -> pingInfo...

intONE_MINUTE_INDEX= 1

intONE_SECOND_INDEX= 0

doublePERCENTILE= 0.9900000095367432

intPING_FREQUENCY= 1

intPING_FREQUENCY_MILLIS= 1000

TimeUnitPING_FREQUENCY_UNIT= TimeUnit.SECONDS

intPING_HISTORY_LENGTH= 15

intPING_HISTORY_MILLIS= 15000

TimeUnitTIME_UNIT= TimeUnit.MICROSECONDS

Constructors

public

PacketHandler(Channel channel, ProtocolVersion protocolVersion)

Methods

Public Methods (43)

public

void accept(Packet var1)

public

void clear()

public

void closed(ChannelHandlerContext ctx)

public

void disconnect(String message)

public

PlayerAuthentication getAuth()

@Nullable

public

Channel getChannel()

@Nonnull

public

DisconnectType getClientDisconnectType()

@Nullable

public

CompletableFuture<Void> getClientReadyForChunksFuture()

@Nullable

public

PacketHandler.DisconnectReason getDisconnectReason()

@Nonnull

public

String getIdentifier()

@Nonnull

public

long getOperationTimeoutThreshold()

public

Metric getPacketQueueMetric()

@Nonnull

public

PacketStatsRecorder getPacketStatsRecorder()

@Nullable

public

PacketHandler.PingInfo getPingInfo(PongType pongType)

@Nonnull

public

HistoricMetric getPingMetricSet()

@Nonnull

public

PongType getPingType()

public

ProtocolVersion getProtocolVersion()

@Nonnull

public

int getQueuedPacketsCount()

public

String getServerDisconnectReason()

@Nullable

public

void handle(Packet packet)

public

void handlePong(Pong packet)

public

boolean isCompressionEnabled()

public

boolean isLANConnection()

public

boolean isLocalConnection()

public

void logCloseMessage()

publicstatic

void logConnectionTimings(Channel channel, String message, Level level)

publicfinal

void registered(PacketHandler oldHandler)

public

void sendPing()

public

void setClientDisconnectType(DisconnectType clientDisconnectType)

public

void setClientReadyForChunksFuture(CompletableFuture<Void> clientReadyFuture)

public

void setCompressionEnabled(boolean compressionEnabled)

public

void setQueuePackets(boolean queuePackets)

public

void setServerDisconnectReason(String serverDisconnectReason)

public

boolean stillActive()

public

void tickPing(float dt)

public

String toString()

@Nonnull@Override

public

void tryFlush()

publicfinal

void unregistered(PacketHandler newHandler)

public

void write(Packet[] packets)

public

void write(Packet[] packets, Packet finalPacket)

public

void write(Packet packet)

@Override

public

void writeNoCache(Packet packet)

@Override

public

void writePacket(Packet packet, boolean cache)

Fields

Protected Fields (8)

protectedPlayerAuthentication auth

protectedChannel channel

protectedCompletableFuture<Void> clientReadyForChunksFuture

protectedThrowable clientReadyForChunksFutureStack

protectedPacketHandler.PingInfo[] pingInfo

protectedProtocolVersion protocolVersion

protectedboolean queuePackets

protectedboolean registered

Private/Package Fields (1)

privatefloat pingTimer

PacketHandler

Constants

Constructors

Methods

Public Methods (43)

Fields

Protected Fields (8)

Private/Package Fields (1)

Related Classes