We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 599750d commit cdfe097Copy full SHA for cdfe097
zookeeper-server/src/main/java/org/apache/zookeeper/server/NettyServerCnxn.java
@@ -367,6 +367,11 @@ void processMessage(ByteBuf buf) {
367
checkIsInEventLoop("processMessage");
368
LOG.debug("0x{} queuedBuffer: {}", Long.toHexString(sessionId), queuedBuffer);
369
370
+ if (closingChannel) {
371
+ LOG.debug("Drop incoming message during connection closing for session 0x{}", Long.toHexString(sessionId));
372
+ return;
373
+ }
374
+
375
if (LOG.isTraceEnabled()) {
376
LOG.trace("0x{} buf {}", Long.toHexString(sessionId), ByteBufUtil.hexDump(buf));
377
}
0 commit comments