(zookeeper) branch branch-3.9 updated: ZOOKEEPER-4907: Stop client packets processing after server channel closed

[kezhuw]

This is an automated email from the ASF dual-hosted git repository.

kezhuw pushed a commit to branch branch-3.9
in repository https://gitbox.apache.org/repos/asf/zookeeper.git


The following commit(s) were added to refs/heads/branch-3.9 by this push:
     new cdfe09746 ZOOKEEPER-4907: Stop client packets processing after server 
channel closed
cdfe09746 is described below

commit cdfe09746cc7a3c222c94ec2ead0385c70d0cf45
Author: stroller <fujian1...@gmail.com>
AuthorDate: Tue Mar 25 18:39:53 2025 +0800

    ZOOKEEPER-4907: Stop client packets processing after server channel closed
    
    Reviewers: kezhuw, tisonkun
    Author: jiafu1115
    Closes #2236 from jiafu1115/jiafu1115-patch-1
    
    (cherry picked from commit 6e4ec270ceff046151c740783e7249d57b98e521)
    Signed-off-by: Kezhu Wang <kez...@apache.org>
---
 .../src/main/java/org/apache/zookeeper/server/NettyServerCnxn.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/zookeeper-server/src/main/java/org/apache/zookeeper/server/NettyServerCnxn.java
 
b/zookeeper-server/src/main/java/org/apache/zookeeper/server/NettyServerCnxn.java
index 4f25c1730..cd8b04dba 100644
--- 
a/zookeeper-server/src/main/java/org/apache/zookeeper/server/NettyServerCnxn.java
+++ 
b/zookeeper-server/src/main/java/org/apache/zookeeper/server/NettyServerCnxn.java
@@ -367,6 +367,11 @@ void processMessage(ByteBuf buf) {
         checkIsInEventLoop("processMessage");
         LOG.debug("0x{} queuedBuffer: {}", Long.toHexString(sessionId), 
queuedBuffer);
 
+        if (closingChannel) {
+            LOG.debug("Drop incoming message during connection closing for 
session 0x{}", Long.toHexString(sessionId));
+            return;
+        }
+
         if (LOG.isTraceEnabled()) {
             LOG.trace("0x{} buf {}", Long.toHexString(sessionId), 
ByteBufUtil.hexDump(buf));
         }