diff --git a/router/java/src/net/i2p/router/transport/tcp/TCPConnection.java b/router/java/src/net/i2p/router/transport/tcp/TCPConnection.java index 3d1d959f9..77e60b60a 100644 --- a/router/java/src/net/i2p/router/transport/tcp/TCPConnection.java +++ b/router/java/src/net/i2p/router/transport/tcp/TCPConnection.java @@ -393,7 +393,7 @@ class TCPConnection implements I2NPMessageReader.I2NPMessageEventListener { if (_log.shouldLog(Log.DEBUG)) _log.debug("Message received from " + _remoteIdentity.getHash().toBase64()); try { - ByteArrayOutputStream baos = new ByteArrayOutputStream(32*1024); + ByteArrayOutputStream baos = new ByteArrayOutputStream(2*1024); message.writeBytes(baos); int size = baos.size(); // this is called by the I2NPMessageReader's thread, so it delays the reading from this peer only