Open-source multiplayer game server compatible with the RuneScape client
https://www.openrs2.org/
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
48 lines
1.3 KiB
48 lines
1.3 KiB
2 years ago
|
package org.openrs2.protocol
|
||
|
|
||
|
import io.netty.buffer.ByteBuf
|
||
|
import io.netty.buffer.ByteBufAllocator
|
||
|
import io.netty.handler.codec.EncoderException
|
||
|
|
||
|
public abstract class VariableShortPacketCodec<T : Packet>(
|
||
|
type: Class<T>,
|
||
|
opcode: Int
|
||
|
) : PacketCodec<T>(type, opcode) {
|
||
|
override fun isLengthReadable(input: ByteBuf): Boolean {
|
||
|
return input.readableBytes() >= 2
|
||
|
}
|
||
|
|
||
|
override fun readLength(input: ByteBuf): Int {
|
||
|
return input.readUnsignedShort()
|
||
|
}
|
||
|
|
||
|
override fun writeLengthPlaceholder(output: ByteBuf) {
|
||
|
output.writeZero(2)
|
||
|
}
|
||
|
|
||
|
override fun setLength(output: ByteBuf, index: Int, written: Int) {
|
||
|
if (written >= 65536) {
|
||
|
throw EncoderException("Variable short payload too long: $written bytes")
|
||
|
}
|
||
|
|
||
|
output.setShort(index, written)
|
||
|
}
|
||
|
|
||
|
public open fun getLength(input: T): Int {
|
||
|
return -2
|
||
|
}
|
||
|
|
||
|
override fun allocateBuffer(alloc: ByteBufAllocator, input: T, preferDirect: Boolean): ByteBuf {
|
||
|
val length = getLength(input)
|
||
|
if (length < 0) {
|
||
|
return super.allocateBuffer(alloc, input, preferDirect)
|
||
|
}
|
||
|
|
||
|
return if (preferDirect) {
|
||
|
alloc.ioBuffer(3 + length, 3 + length)
|
||
|
} else {
|
||
|
alloc.heapBuffer(3 + length, 3 + length)
|
||
|
}
|
||
|
}
|
||
|
}
|