Repo-Mirror/craft-engine
9
0
Fork 0
mirror of https://github.com/Xiao-MoMi/craft-engine.git synced 2025-12-29 03:49:15 +00:00
Code Issues Releases Activity

fix(bukkit): 修复receivePacket可能出现的潜在问题

Browse Source
This commit is contained in:
jhqwqmc
2025-03-23 00:35:19 +08:00
parent c09b987733
commit 8abcd9cbd0
1 changed files with 15 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
bukkit/src/main/java/net/momirealms/craftengine/bukkit/plugin/network/BukkitNetworkManager.java
View File

@@ -270,15 +270,23 @@ public class BukkitNetworkManager implements NetworkManager, Listener {
public void receivePacket(@NotNull NetWorkUser player, Object packet) {
Channel channel = player.nettyChannel();
List<String> handlerNames = channel.pipeline().names();
if (handlerNames.contains("decompress")) {
channel.pipeline().context("decompress").fireChannelRead(packet);
} else {
if (handlerNames.contains("decrypt")) {
channel.pipeline().context("decrypt").fireChannelRead(packet);
if (channel.isOpen()) {
List<String> handlerNames = channel.pipeline().names();
if (handlerNames.contains("via-encoder")) {
channel.pipeline().context("via-decoder").fireChannelRead(packet);
} else if (handlerNames.contains("ps_decoder_transformer")) {
channel.pipeline().context("ps_decoder_transformer").fireChannelRead(packet);
} else if (handlerNames.contains("decompress")) {
channel.pipeline().context("decompress").fireChannelRead(packet);
} else {
channel.pipeline().context("splitter").fireChannelRead(packet);
if (handlerNames.contains("decrypt")) {
channel.pipeline().context("decrypt").fireChannelRead(packet);
} else {
channel.pipeline().context("splitter").fireChannelRead(packet);
}
}
} else {
((ByteBuf) packet).release();
}
}