mirrors/riiablo
1
0
Fork 0
mirror of https://github.com/collinsmith/riiablo.git synced 2025-01-22 02:07:26 +07:00
Code Issues Actions Packages Projects Releases Wiki Activity

Moved ByteToMessageDecoder to it's own declared class

Browse Source
This commit is contained in:
Collin Smith 2020-06-27 16:39:48 -07:00
parent e05e9bebc6
commit 70cf9d016a
1 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
server/netty/src/com/riiablo/server/d2gs/Main.java
View File

@ -75,19 +75,7 @@ public class Main extends ApplicationAdapter implements PacketProcessor {
Main.this.endpoint = endpoint;
ch.pipeline()
.addFirst(connectionLimiter)
.addLast(new ByteToMessageDecoder() {
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
if (in.readableBytes() < 4) return;
in.markReaderIndex();
final int length = in.readIntLE();
if (in.readableBytes() < length) {
in.resetReaderIndex();
return;
}
out.add(in.readRetainedSlice(length));
}
})
.addLast(new SizePrefixedDecoder())
.addLast(new EndpointedChannelHandler<>(ByteBuf.class, endpoint))
;
}
@ -253,4 +241,18 @@ public class Main extends ApplicationAdapter implements PacketProcessor {
return this;
}
}
private static class SizePrefixedDecoder extends ByteToMessageDecoder {
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
if (in.readableBytes() < 4) return;
in.markReaderIndex();
final int length = in.readIntLE();
if (in.readableBytes() < length) {
in.resetReaderIndex();
return;
}
out.add(in.readRetainedSlice(length));
}
}
}