diff --git a/src/dorkbox/network/pipeline/udp/KryoDecoderUdpCrypto.java b/src/dorkbox/network/pipeline/udp/KryoDecoderUdpCrypto.java index 1627b1c8..5380dc7a 100644 --- a/src/dorkbox/network/pipeline/udp/KryoDecoderUdpCrypto.java +++ b/src/dorkbox/network/pipeline/udp/KryoDecoderUdpCrypto.java @@ -45,7 +45,6 @@ class KryoDecoderUdpCrypto extends MessageToMessageDecoder { ChannelHandler last = ctx.pipeline() .last(); - try { ByteBuf data = in.content(); Object object = serializationManager.readWithCrypto((ConnectionImpl) last, data, data.readableBytes()); diff --git a/src/dorkbox/network/pipeline/udp/KryoEncoderUdp.java b/src/dorkbox/network/pipeline/udp/KryoEncoderUdp.java index 39adca93..e9a9cd97 100644 --- a/src/dorkbox/network/pipeline/udp/KryoEncoderUdp.java +++ b/src/dorkbox/network/pipeline/udp/KryoEncoderUdp.java @@ -63,10 +63,9 @@ class KryoEncoderUdp extends MessageToMessageEncoder { writeObject(this.serializationManager, ctx, msg, outBuffer); // have to check to see if we are too big for UDP! - if (outBuffer.readableBytes() > EndPoint.udpMaxSize) { - System.err.println("Object larger than MAX udp size! " + EndPoint.udpMaxSize + "/" + outBuffer.readableBytes()); + if (outBuffer.readableBytes() > maxSize) { - 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() + ")"; LoggerFactory.getLogger(this.getClass()).error(message); throw new IOException(message);