(dubbo) branch 3.2 updated: if SSL auth policy is set to AuthPolicy.NONE, SslServerTlsHandler#decode should remove and return instead of printing the error log. (#13507)

[albumenj]

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

albumenj pushed a commit to branch 3.2
in repository https://gitbox.apache.org/repos/asf/dubbo.git


The following commit(s) were added to refs/heads/3.2 by this push:
     new 365b805026 if SSL auth policy is set to AuthPolicy.NONE, 
SslServerTlsHandler#decode should remove and return instead of printing the 
error log. (#13507)
365b805026 is described below

commit 365b8050268b6d2dd319d9c266c76342b8d6e460
Author: yizhenqiang <manzhiz...@163.com>
AuthorDate: Wed Dec 20 20:58:44 2023 +0800

    if SSL auth policy is set to AuthPolicy.NONE, SslServerTlsHandler#decode 
should remove and return instead of printing the error log. (#13507)
    
    Co-authored-by: yizhenqiang <yizhenqi...@corp.netesase.com>
---
 .../dubbo/rpc/protocol/rest/netty/ssl/SslServerTlsHandler.java     | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/dubbo-rpc/dubbo-rpc-rest/src/main/java/org/apache/dubbo/rpc/protocol/rest/netty/ssl/SslServerTlsHandler.java
 
b/dubbo-rpc/dubbo-rpc-rest/src/main/java/org/apache/dubbo/rpc/protocol/rest/netty/ssl/SslServerTlsHandler.java
index e0dde1aa00..93a87baf78 100644
--- 
a/dubbo-rpc/dubbo-rpc-rest/src/main/java/org/apache/dubbo/rpc/protocol/rest/netty/ssl/SslServerTlsHandler.java
+++ 
b/dubbo-rpc/dubbo-rpc-rest/src/main/java/org/apache/dubbo/rpc/protocol/rest/netty/ssl/SslServerTlsHandler.java
@@ -105,8 +105,7 @@ public class SslServerTlsHandler extends 
ByteToMessageDecoder {
                 url, channelHandlerContext.channel().remoteAddress());
 
         if (providerConnectionConfig == null) {
-            ChannelPipeline p = channelHandlerContext.pipeline();
-            p.remove(this);
+            channelHandlerContext.pipeline().remove(this);
             return;
         }
 
@@ -117,8 +116,8 @@ public class SslServerTlsHandler extends 
ByteToMessageDecoder {
         }
 
         if (providerConnectionConfig.getAuthPolicy() == AuthPolicy.NONE) {
-            ChannelPipeline p = channelHandlerContext.pipeline();
-            p.remove(this);
+            channelHandlerContext.pipeline().remove(this);
+            return;
         }
 
         logger.error(INTERNAL_ERROR, "", "", "TLS negotiation failed when 
trying to accept new connection.");