[pulsar] branch master updated: fix the bug of authenticationData is't initialized. (#6440)

[zhaijia]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new b8f0ca0  fix the bug of authenticationData is't initialized. (#6440)
b8f0ca0 is described below

commit b8f0ca092b6c6cbd04525fb81ea55ba516a06cf7
Author: bilahepan <ytgaotia...@gmail.com>
AuthorDate: Sat Feb 29 08:59:08 2020 +0800

    fix the bug of authenticationData is't initialized. (#6440)
    
    Motivation
    fix the bug of authenticationData is't initialized.
    
    the method org.apache.pulsar.proxy.server.ProxyConnection#handleConnect 
can't init the value of authenticationData.
    cause of the bug that you will get the null value form the method 
org.apache.pulsar.broker.authorization.AuthorizationProvider#canConsumeAsync
    when implements 
org.apache.pulsar.broker.authorization.AuthorizationProvider interface.
    
    Modifications
    init the value of authenticationData from the method 
org.apache.pulsar.proxy.server.ProxyConnection#handleConnect.
    
    Verifying this change
    implements org.apache.pulsar.broker.authorization.AuthorizationProvider 
interface， and get the value of authenticationData.
---
 .../src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java
 
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java
index d9960c5..9b8b7fb 100644
--- 
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java
+++ 
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java
@@ -327,6 +327,7 @@ public class ProxyConnection extends PulsarHandler 
implements FutureListener<Voi
             }
 
             authState = authenticationProvider.newAuthState(clientData, 
remoteAddress, sslSession);
+            authenticationData = authState.getAuthDataSource();
             doAuthentication(clientData);
         } catch (Exception e) {
             LOG.warn("[{}] Unable to authenticate: ", remoteAddress, e);