Code polish
This commit is contained in:
parent
c4fa7253ea
commit
58a20b2913
@ -45,7 +45,6 @@ class KryoDecoderUdpCrypto extends MessageToMessageDecoder<DatagramPacket> {
|
|||||||
ChannelHandler last = ctx.pipeline()
|
ChannelHandler last = ctx.pipeline()
|
||||||
.last();
|
.last();
|
||||||
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
ByteBuf data = in.content();
|
ByteBuf data = in.content();
|
||||||
Object object = serializationManager.readWithCrypto((ConnectionImpl) last, data, data.readableBytes());
|
Object object = serializationManager.readWithCrypto((ConnectionImpl) last, data, data.readableBytes());
|
||||||
|
@ -63,10 +63,9 @@ class KryoEncoderUdp extends MessageToMessageEncoder<Object> {
|
|||||||
writeObject(this.serializationManager, ctx, msg, outBuffer);
|
writeObject(this.serializationManager, ctx, msg, outBuffer);
|
||||||
|
|
||||||
// have to check to see if we are too big for UDP!
|
// have to check to see if we are too big for UDP!
|
||||||
if (outBuffer.readableBytes() > EndPoint.udpMaxSize) {
|
if (outBuffer.readableBytes() > maxSize) {
|
||||||
System.err.println("Object larger than MAX udp size! " + EndPoint.udpMaxSize + "/" + outBuffer.readableBytes());
|
|
||||||
|
|
||||||
String message = "Object is TOO BIG FOR UDP! " + msg.toString() + " (" + EndPoint.udpMaxSize + "/" +
|
String message = "Object is TOO BIG FOR UDP! " + msg.toString() + " (Max " + maxSize + ", was " +
|
||||||
outBuffer.readableBytes() + ")";
|
outBuffer.readableBytes() + ")";
|
||||||
LoggerFactory.getLogger(this.getClass()).error(message);
|
LoggerFactory.getLogger(this.getClass()).error(message);
|
||||||
throw new IOException(message);
|
throw new IOException(message);
|
||||||
|
Loading…
Reference in New Issue
Block a user