AstralTransRocketries/minosoft
1
0
Fork 0
mirror of https://gitlab.bixilon.de/bixilon/minosoft.git synced 2025-09-18 20:05:02 -04:00
Code Issues Packages Projects Releases Wiki Activity

network: fix packet inflater

Browse Source
This commit is contained in:
Bixilon 2022-01-31 10:21:05 +01:00
parent a041b20904
commit 10c3b93976
No known key found for this signature in database
GPG Key ID: 5CAD791931B09AC4
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/de/bixilon/minosoft/protocol/network/network/client/pipeline/compression/PacketInflater.kt
View File

@ -15,7 +15,6 @@ package de.bixilon.minosoft.protocol.network.network.client.pipeline.compression
import de.bixilon.kutil.compression.zlib.ZlibUtil.compress import de.bixilon.kutil.compression.zlib.ZlibUtil.compress
import de.bixilon.minosoft.protocol.protocol.OutByteBuffer import de.bixilon.minosoft.protocol.protocol.OutByteBuffer
import de.bixilon.minosoft.util.KUtil.withLengthPrefix
import io.netty.channel.ChannelHandlerContext import io.netty.channel.ChannelHandlerContext
import io.netty.handler.codec.MessageToMessageEncoder import io.netty.handler.codec.MessageToMessageEncoder
@ -27,17 +26,17 @@ class PacketInflater(
override fun encode(context: ChannelHandlerContext, data: ByteArray, out: MutableList<Any>) { override fun encode(context: ChannelHandlerContext, data: ByteArray, out: MutableList<Any>) {
val compress = data.size >= threshold val compress = data.size >= threshold
if (!compress) {
val prefixed = OutByteBuffer() val prefixed = OutByteBuffer()
if (compress) {
val compressed = data.compress()
prefixed.writeVarInt(data.size)
prefixed.writeUnprefixedByteArray(compressed)
} else {
prefixed.writeVarInt(0) prefixed.writeVarInt(0)
prefixed.writeUnprefixedByteArray(data) prefixed.writeUnprefixedByteArray(data)
out += prefixed.toArray()
return
} }
val compressed = data.compress() out += prefixed.toArray()
out += compressed.withLengthPrefix()
} }
companion object { companion object {