(zookeeper) branch master 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 master
in repository https://gitbox.apache.org/repos/asf/zookeeper.git


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

commit 6e4ec270ceff046151c740783e7249d57b98e521
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
---
 .../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 fe0380db1..d6acb90fb 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));
         }