AdlC/PicoLimbo
AdlC/PicoLimbo
1
0
Fork 0
mirror of https://github.com/Nan1t/NanoLimbo.git synced 2025-07-18 06:50:17 +02:00
Code Issues Packages Projects Releases Wiki Activity

Moved refs to encoder and decoder to connection to speed up access

Browse Source
This commit is contained in:
Nanit 2021-10-29 13:57:01 +03:00
parent 574261ef1e
commit cc5f92086a
2 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/ru/nanit/limbo/connection/ClientChannelInitializer.java
View File

@ -24,13 +24,16 @@ public class ClientChannelInitializer extends ChannelInitializer<Channel> {
protected void initChannel(Channel channel) { protected void initChannel(Channel channel) {
ChannelPipeline pipeline = channel.pipeline(); ChannelPipeline pipeline = channel.pipeline();
PacketDecoder decoder = new PacketDecoder();
PacketEncoder encoder = new PacketEncoder();
pipeline.addLast("timeout", new ReadTimeoutHandler(server.getConfig().getReadTimeout(), pipeline.addLast("timeout", new ReadTimeoutHandler(server.getConfig().getReadTimeout(),
TimeUnit.MILLISECONDS)); TimeUnit.MILLISECONDS));
pipeline.addLast("frame_decoder", new VarIntFrameDecoder()); pipeline.addLast("frame_decoder", new VarIntFrameDecoder());
pipeline.addLast("frame_encoder", new VarIntLengthEncoder()); pipeline.addLast("frame_encoder", new VarIntLengthEncoder());
pipeline.addLast("decoder", new PacketDecoder()); pipeline.addLast("decoder", decoder);
pipeline.addLast("encoder", new PacketEncoder()); pipeline.addLast("encoder", encoder);
pipeline.addLast("handler", new ClientConnection(channel, server)); pipeline.addLast("handler", new ClientConnection(channel, server, decoder, encoder));
} }
} }

19
src/main/java/ru/nanit/limbo/connection/ClientConnection.java
View File

@ -47,15 +47,20 @@ public class ClientConnection extends ChannelInboundHandlerAdapter {
private final Channel channel; private final Channel channel;
private final GameProfile gameProfile; private final GameProfile gameProfile;
private final PacketDecoder decoder;
private final PacketEncoder encoder;
private State state; private State state;
private Version clientVersion; private Version clientVersion;
private SocketAddress address; private SocketAddress address;
private int velocityLoginMessageId = -1; private int velocityLoginMessageId = -1;
public ClientConnection(Channel channel, LimboServer server) { public ClientConnection(Channel channel, LimboServer server, PacketDecoder decoder, PacketEncoder encoder) {
this.server = server; this.server = server;
this.channel = channel; this.channel = channel;
this.decoder = decoder;
this.encoder = encoder;
this.address = channel.remoteAddress(); this.address = channel.remoteAddress();
this.gameProfile = new GameProfile(); this.gameProfile = new GameProfile();
} }
@ -244,18 +249,12 @@ public class ClientConnection extends ChannelInboundHandlerAdapter {
private void setPlayState() { private void setPlayState() {
this.state = State.PLAY; this.state = State.PLAY;
channel.pipeline().get(PacketDecoder.class) decoder.updateState(this.state);
.updateState(this.state); encoder.updateState(this.state);
channel.pipeline().get(PacketEncoder.class)
.updateState(this.state);
} }
public void updateStateAndVersion(State state, Version version){ public void updateStateAndVersion(State state, Version version) {
this.state = state; this.state = state;
PacketDecoder decoder = channel.pipeline().get(PacketDecoder.class);
PacketEncoder encoder = channel.pipeline().get(PacketEncoder.class);
decoder.updateVersion(version); decoder.updateVersion(version);
decoder.updateState(state); decoder.updateState(state);
encoder.updateVersion(version); encoder.updateVersion(version);