MiniDay/Velocity
1
0
Fork 0
Code Issues Pull Requests Packages Releases Wiki Activity

untested control handler

Browse Source
This commit is contained in:
creeper123123321
2019-03-08 08:33:28 -03:00
parent fa9d5f6499
commit b5d228028c
2 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
proxy/src/main/java/com/velocitypowered/proxy/connection/backend/VelocityServerConnection.java
View File

@@ -2,6 +2,7 @@ package com.velocitypowered.proxy.connection.backend;
import static com.velocitypowered.proxy.VelocityServer.GSON; import static com.velocitypowered.proxy.VelocityServer.GSON;
import static com.velocitypowered.proxy.connection.forge.legacy.LegacyForgeConstants.HANDSHAKE_HOSTNAME_TOKEN; import static com.velocitypowered.proxy.connection.forge.legacy.LegacyForgeConstants.HANDSHAKE_HOSTNAME_TOKEN;
import static com.velocitypowered.proxy.network.Connections.FLOW_HANDLER;
import static com.velocitypowered.proxy.network.Connections.FRAME_DECODER; import static com.velocitypowered.proxy.network.Connections.FRAME_DECODER;
import static com.velocitypowered.proxy.network.Connections.FRAME_ENCODER; import static com.velocitypowered.proxy.network.Connections.FRAME_ENCODER;
import static com.velocitypowered.proxy.network.Connections.HANDLER; import static com.velocitypowered.proxy.network.Connections.HANDLER;
@@ -34,6 +35,7 @@ import com.velocitypowered.proxy.server.VelocityRegisteredServer;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import io.netty.channel.ChannelFutureListener; import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelInitializer;
import io.netty.handler.flow.FlowControlHandler;
import io.netty.handler.timeout.ReadTimeoutHandler; import io.netty.handler.timeout.ReadTimeoutHandler;
import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@@ -83,6 +85,7 @@ public class VelocityServerConnection implements MinecraftConnectionAssociation,
TimeUnit.MILLISECONDS)) TimeUnit.MILLISECONDS))
.addLast(FRAME_DECODER, new MinecraftVarintFrameDecoder()) .addLast(FRAME_DECODER, new MinecraftVarintFrameDecoder())
.addLast(FRAME_ENCODER, MinecraftVarintLengthEncoder.INSTANCE) .addLast(FRAME_ENCODER, MinecraftVarintLengthEncoder.INSTANCE)
.addLast(FLOW_HANDLER, new FlowControlHandler())
.addLast(MINECRAFT_DECODER, .addLast(MINECRAFT_DECODER,
new MinecraftDecoder(ProtocolUtils.Direction.CLIENTBOUND)) new MinecraftDecoder(ProtocolUtils.Direction.CLIENTBOUND))
.addLast(MINECRAFT_ENCODER, .addLast(MINECRAFT_ENCODER,

1
proxy/src/main/java/com/velocitypowered/proxy/network/Connections.java
View File

@@ -6,6 +6,7 @@ public class Connections {
public static final String CIPHER_ENCODER = "cipher-encoder"; public static final String CIPHER_ENCODER = "cipher-encoder";
public static final String COMPRESSION_DECODER = "compression-decoder"; public static final String COMPRESSION_DECODER = "compression-decoder";
public static final String COMPRESSION_ENCODER = "compression-encoder"; public static final String COMPRESSION_ENCODER = "compression-encoder";
public static final String FLOW_HANDLER = "flow-handler";
public static final String FRAME_DECODER = "frame-decoder"; public static final String FRAME_DECODER = "frame-decoder";
public static final String FRAME_ENCODER = "frame-encoder"; public static final String FRAME_ENCODER = "frame-encoder";
public static final String HANDLER = "handler"; public static final String HANDLER = "handler";