You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zookeeper.apache.org by dd...@apache.org on 2021/03/06 20:01:42 UTC
[zookeeper] 01/03: ZOOKEEPER-4221: Improve the error message when
message goes above jute.maxbufer size
This is an automated email from the ASF dual-hosted git repository.
ddiederen pushed a commit to branch branch-3.7.0
in repository https://gitbox.apache.org/repos/asf/zookeeper.git
commit 4b27c62e866740c977837e52bd264c22afbe6376
Author: Mathieu Marie <mm...@salesforce.com>
AuthorDate: Fri Feb 26 09:35:02 2021 +0000
ZOOKEEPER-4221: Improve the error message when message goes above jute.maxbufer size
Author: Mathieu Marie <mm...@salesforce.com>
Reviewers: Damien Diederen <dd...@crosstwine.com>, Mate Szalay-Beko <sy...@apache.org>
Closes #1614 from mariemat/ZOOKEEPER-4221
(cherry picked from commit 94d0c4d8558e1b201665bb9dffd33dacbc7ca945)
Signed-off-by: Mate Szalay-Beko <sy...@apache.org>
---
.../src/main/java/org/apache/zookeeper/server/NIOServerCnxn.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/NIOServerCnxn.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/NIOServerCnxn.java
index 2e65da8..02cde23 100644
--- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/NIOServerCnxn.java
+++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/NIOServerCnxn.java
@@ -545,7 +545,10 @@ public class NIOServerCnxn extends ServerCnxn {
return false;
}
if (len < 0 || len > BinaryInputArchive.maxBuffer) {
- throw new IOException("Len error " + len);
+ throw new IOException("Len error. "
+ + "A message from " + this.getRemoteSocketAddress() + " with advertised length of " + len
+ + " is either a malformed message or too large to process"
+ + " (length is greater than jute.maxbuffer=" + BinaryInputArchive.maxBuffer + ")");
}
if (!isZKServerRunning()) {
throw new IOException("ZooKeeperServer not running");