[hbase] branch master updated: HBASE-27185 Addendum fix TestShadeSaslAuthenticationProvider

[zhangduo]

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

zhangduo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/master by this push:
     new 811f0e7d2af HBASE-27185 Addendum fix 
TestShadeSaslAuthenticationProvider
811f0e7d2af is described below

commit 811f0e7d2afba0dee8cf6401153caf9ec9b716ec
Author: Duo Zhang <zhang...@apache.org>
AuthorDate: Thu Jul 28 17:20:13 2022 +0800

    HBASE-27185 Addendum fix TestShadeSaslAuthenticationProvider
---
 .../main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java
 
b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java
index d211b1b98e5..dd34856f564 100644
--- 
a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java
+++ 
b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java
@@ -35,6 +35,7 @@ import 
org.apache.hadoop.hbase.ipc.HBaseRpcController.CancellationCallback;
 import org.apache.hadoop.hbase.security.NettyHBaseRpcConnectionHeaderHandler;
 import org.apache.hadoop.hbase.security.NettyHBaseSaslRpcClientHandler;
 import org.apache.hadoop.hbase.security.SaslChallengeDecoder;
+import org.apache.hadoop.hbase.util.NettyFutureUtils;
 import org.apache.hadoop.hbase.util.Threads;
 import org.apache.hadoop.security.UserGroupInformation;
 import org.apache.yetus.audience.InterfaceAudience;
@@ -216,8 +217,9 @@ class NettyRpcConnection extends RpcConnection {
       failInit(ch, e);
       return;
     }
-    ch.pipeline().addFirst(new SaslChallengeDecoder(), saslHandler);
-    saslPromise.addListener(new FutureListener<Boolean>() {
+    ch.pipeline().addFirst("SaslDecoder", new 
SaslChallengeDecoder()).addAfter("SaslDecoder",
+      "SaslHandler", saslHandler);
+    NettyFutureUtils.addListener(saslPromise, new FutureListener<Boolean>() {
 
       @Override
       public void operationComplete(Future<Boolean> future) throws Exception {