Mirrors/Velocity
3
0
Fork 1
Mirror von https://github.com/PaperMC/Velocity.git synchronisiert 2024-11-17 05:20:14 +01:00
Code Issues Pakete Projekte Releases Wiki Aktivität

Use just one byte array in the varint frame decoder.

Quellcode durchsuchen
Dieser Commit ist enthalten in:
Andrew Steinborn 2019-01-11 18:04:51 -05:00
Ursprung f77384d32e
Commit 1e041963f0
1 geänderte Dateien mit 4 neuen und 1 gelöschten Zeilen
Statistiken anzeigen Patch-Datei herunterladen Vergleichs-Datei herunterladen Alle Dateien ausklappen Alle Dateien einklappen

5
proxy/src/main/java/com/velocitypowered/proxy/protocol/netty/MinecraftVarintFrameDecoder.java
Datei anzeigen

@ -6,19 +6,22 @@ import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder; import io.netty.handler.codec.ByteToMessageDecoder;
import io.netty.handler.codec.CorruptedFrameException; import io.netty.handler.codec.CorruptedFrameException;
import java.util.Arrays;
import java.util.List; import java.util.List;
public class MinecraftVarintFrameDecoder extends ByteToMessageDecoder { public class MinecraftVarintFrameDecoder extends ByteToMessageDecoder {
private final byte[] lenBuf = new byte[3];
@Override @Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception { protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
if (!in.isReadable()) { if (!in.isReadable()) {
return; return;
} }
Arrays.fill(lenBuf, (byte) 0);
int origReaderIndex = in.readerIndex(); int origReaderIndex = in.readerIndex();
byte[] lenBuf = new byte[3];
ByteBuf wrappedBuf = Unpooled.wrappedBuffer(lenBuf); ByteBuf wrappedBuf = Unpooled.wrappedBuffer(lenBuf);
for (int i = 0; i < lenBuf.length; i++) { for (int i = 0; i < lenBuf.length; i++) {
if (!in.isReadable()) { if (!in.isReadable()) {