nitro/Arcturus-Community
1
0
Fork 0
mirror of https://git.krews.org/morningstar/Arcturus-Community.git synced 2024-06-30 12:45:34 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'patch-netty-memory-leak' into 'dev'

Browse Source 
Fix #915 : netty memory leak

See merge request morningstar/Arcturus-Community!338
This commit is contained in:
skeletor 2020-11-29 16:03:50 -05:00
commit 1bb8719cab
2 changed files with 12 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/eu/habbo/networking/gameserver/decoders/GameByteDecryption.java
View File

@ -17,13 +17,13 @@ public class GameByteDecryption extends ByteToMessageDecoder {
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) {
// Read all available bytes.
byte[] data = in.readBytes(in.readableBytes()).array();
ByteBuf data = in.readBytes(in.readableBytes());
// Decrypt.
ctx.channel().attr(GameServerAttributes.CRYPTO_CLIENT).get().parse(data);
ctx.channel().attr(GameServerAttributes.CRYPTO_CLIENT).get().parse(data.array());
// Continue in the pipeline.
out.add(Unpooled.wrappedBuffer(data));
out.add(data);
}
}

21
src/main/java/com/eu/habbo/networking/gameserver/encoders/GameByteEncryption.java
View File

@ -6,28 +6,25 @@ import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelOutboundHandlerAdapter;
import io.netty.channel.ChannelPromise;
import io.netty.util.ReferenceCountUtil;
public class GameByteEncryption extends ChannelOutboundHandlerAdapter {
@Override
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
// Convert msg to ByteBuf.
ByteBuf out = (ByteBuf) msg;
// convert to Bytebuf
ByteBuf in = (ByteBuf) msg;
// Read all available bytes.
byte[] data;
// read available bytes
ByteBuf data = (in).readBytes(in.readableBytes());
if (out.hasArray()) {
data = out.array();
} else {
data = out.readBytes(out.readableBytes()).array();
}
//release old object
ReferenceCountUtil.release(in);
// Encrypt.
ctx.channel().attr(GameServerAttributes.CRYPTO_SERVER).get().parse(data);
ctx.channel().attr(GameServerAttributes.CRYPTO_SERVER).get().parse(data.array());
// Continue in the pipeline.
ctx.write(Unpooled.wrappedBuffer(data));
ctx.write(data, promise);
}
}