geforkt von Mirrors/Velocity
Merge pull request #85 from PurpleIsEverything/master
Add CONNECT_TIMEOUT_MILLIS to fix timeout errors.
Dieser Commit ist enthalten in:
Commit
7b8a215078
@ -33,6 +33,7 @@ import static com.velocitypowered.proxy.network.Connections.HANDLER;
|
|||||||
import static com.velocitypowered.proxy.network.Connections.MINECRAFT_DECODER;
|
import static com.velocitypowered.proxy.network.Connections.MINECRAFT_DECODER;
|
||||||
import static com.velocitypowered.proxy.network.Connections.MINECRAFT_ENCODER;
|
import static com.velocitypowered.proxy.network.Connections.MINECRAFT_ENCODER;
|
||||||
import static com.velocitypowered.proxy.network.Connections.READ_TIMEOUT;
|
import static com.velocitypowered.proxy.network.Connections.READ_TIMEOUT;
|
||||||
|
import static com.velocitypowered.proxy.network.Connections.CONNECTION_TIMEOUT_SECONDS;
|
||||||
import static com.velocitypowered.proxy.network.Connections.SERVER_READ_TIMEOUT_SECONDS;
|
import static com.velocitypowered.proxy.network.Connections.SERVER_READ_TIMEOUT_SECONDS;
|
||||||
|
|
||||||
public class VelocityServerConnection implements MinecraftConnectionAssociation, ServerConnection {
|
public class VelocityServerConnection implements MinecraftConnectionAssociation, ServerConnection {
|
||||||
@ -56,6 +57,7 @@ public class VelocityServerConnection implements MinecraftConnectionAssociation,
|
|||||||
CompletableFuture<ConnectionRequestBuilder.Result> result = new CompletableFuture<>();
|
CompletableFuture<ConnectionRequestBuilder.Result> result = new CompletableFuture<>();
|
||||||
server.initializeGenericBootstrap()
|
server.initializeGenericBootstrap()
|
||||||
.option(ChannelOption.TCP_NODELAY, true)
|
.option(ChannelOption.TCP_NODELAY, true)
|
||||||
|
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, CONNECTION_TIMEOUT_SECONDS * 1000)
|
||||||
.handler(new ChannelInitializer<Channel>() {
|
.handler(new ChannelInitializer<Channel>() {
|
||||||
@Override
|
@Override
|
||||||
protected void initChannel(Channel ch) throws Exception {
|
protected void initChannel(Channel ch) throws Exception {
|
||||||
|
@ -89,6 +89,7 @@ public final class ConnectionManager {
|
|||||||
ch.pipeline().addLast(Connections.HANDLER, connection);
|
ch.pipeline().addLast(Connections.HANDLER, connection);
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
.childOption(ChannelOption.CONNECT_TIMEOUT_MILLIS, CONNECTION_TIMEOUT_SECONDS * 1000)
|
||||||
.childOption(ChannelOption.TCP_NODELAY, true)
|
.childOption(ChannelOption.TCP_NODELAY, true)
|
||||||
.childOption(ChannelOption.IP_TOS, 0x18)
|
.childOption(ChannelOption.IP_TOS, 0x18)
|
||||||
.localAddress(address);
|
.localAddress(address);
|
||||||
|
@ -16,4 +16,5 @@ public interface Connections {
|
|||||||
|
|
||||||
int CLIENT_READ_TIMEOUT_SECONDS = 30; // client -> proxy
|
int CLIENT_READ_TIMEOUT_SECONDS = 30; // client -> proxy
|
||||||
int SERVER_READ_TIMEOUT_SECONDS = 30; // proxy -> server
|
int SERVER_READ_TIMEOUT_SECONDS = 30; // proxy -> server
|
||||||
|
int CONNECTION_TIMEOUT_SECONDS = 5;
|
||||||
}
|
}
|
||||||
|
Laden…
In neuem Issue referenzieren
Einen Benutzer sperren