debug info
This commit is contained in:
@@ -25,9 +25,12 @@ public class PacketDecoder extends ReplayingDecoder<Packet> {
|
|||||||
int id = netStream.readVarInt();
|
int id = netStream.readVarInt();
|
||||||
log.debug("PktLEN: {} | PktID: {}", length, id);
|
log.debug("PktLEN: {} | PktID: {}", length, id);
|
||||||
|
|
||||||
Optional<Class<? extends Packet>> packetClass = context.channel().attr(State.ATTR_STATE).get().getPacketClass(id);
|
State state = context.channel().attr(State.ATTR_STATE).get();
|
||||||
|
log.debug("Current state: {}:{}", state.getId(), state.name());
|
||||||
|
Optional<Class<? extends Packet>> packetClass = state.getPacketClass(id);
|
||||||
|
|
||||||
if (packetClass.isPresent()) {
|
if (packetClass.isPresent()) {
|
||||||
|
log.debug("Detect packet: {}", packetClass.get().getSimpleName());
|
||||||
Packet packet = packetClass.get().newInstance();
|
Packet packet = packetClass.get().newInstance();
|
||||||
packet.readSelf(netStream);
|
packet.readSelf(netStream);
|
||||||
list.add(packet);
|
list.add(packet);
|
||||||
|
|||||||
Reference in New Issue
Block a user