|
@@ -79,13 +79,13 @@ public class DsrcTcpServerDecoder extends ByteToMessageDecoder {
|
|
|
pktLength = datexDataPacket.decode(new ByteArrayInputStream(inBytes, 0, inBytes.length));
|
|
|
}
|
|
|
catch(IOException e) {
|
|
|
- log.warn("DsrcTcpServerDecoder.decode: RECV: decode error. {}, {}, inBytes: {}, pktLength: {}", ipAddress, e.getMessage(), inBytes, inBytes.length);
|
|
|
+ //log.warn("DsrcTcpServerDecoder.decode: RECV: decode error. {}, {}, inBytes: {}, pktLength: {}", ipAddress, e.getMessage(), inBytes, inBytes.length);
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
if (pktLength > readableBytes) {
|
|
|
- log.warn("RECV: Decoder: {}. [pktLength > readableBytes]", ipAddress);
|
|
|
- log.warn("RECV: Decoder: {}. [Readable:{}, RIDX:{}-WIDX:{}]. Packet Remain.", ipAddress, readableBytes, byteBuf.readerIndex(), byteBuf.writerIndex());
|
|
|
+ //log.warn("RECV: Decoder: {}. [pktLength > readableBytes]", ipAddress);
|
|
|
+ //log.warn("RECV: Decoder: {}. [Readable:{}, RIDX:{}-WIDX:{}]. Packet Remain.", ipAddress, readableBytes, byteBuf.readerIndex(), byteBuf.writerIndex());
|
|
|
break;
|
|
|
}
|
|
|
|
|
@@ -105,7 +105,7 @@ public class DsrcTcpServerDecoder extends ByteToMessageDecoder {
|
|
|
readableBytes = byteBuf.readableBytes();
|
|
|
}
|
|
|
catch(Exception e) {
|
|
|
- log.error("TcpServerDecoder.decode: RECV: {}. Exception Error1: will be closed: {}. [{}]", ipAddress, e.toString(), obj.getLogKey());
|
|
|
+ //log.error("TcpServerDecoder.decode: RECV: {}. Exception Error1: will be closed: {}. [{}]", ipAddress, e.toString(), obj.getLogKey());
|
|
|
DsrcAsn1ServerIdleStatePacketHandler.disconnectChannel(obj, channel);
|
|
|
}
|
|
|
}
|