alluxio.security.authentication

Class SaslStreamClientDriver

java.lang.Object

alluxio.security.authentication.SaslStreamClientDriver

All Implemented Interfaces:

io.grpc.stub.StreamObserver<SaslMessage>

public class SaslStreamClientDriver
extends Object
implements io.grpc.stub.StreamObserver<SaslMessage>

Responsible for driving sasl traffic from client-side. Acts as a client's Sasl stream. A Sasl authentication between client and server is managed by SaslStreamClientDriver and SaslStreamServerDriver respectively. This drivers are wrappers over gRPC StreamObservers that manages the stream traffic destined for the other participant. They make sure messages are exchanged between client and server one by one synchronously. Sasl handshake is initiated by the client. Following the initiate call, depending on the scheme, one or more messages are exchanged to establish authenticated session between client and server. After the authentication is established, client and server streams are not closed in order to use them as long polling on authentication state changes. Client closing the stream means that it doesn't want to be authenticated anymore. Server closing the stream means the client is not authenticated at the server anymore.

Constructor Summary

Constructors

Constructor and Description
SaslStreamClientDriver(SaslHandshakeClientHandler handshakeClient, AtomicBoolean authenticated, UUID channelId, long grpcAuthTimeoutMs) Creates client driver with given handshake handler.

Method Summary

Modifier and Type	Method and Description
void	onCompleted()
void	onError(Throwable throwable)
void	onNext(SaslMessage saslMessage)
void	setServerObserver(io.grpc.stub.StreamObserver<SaslMessage> requestObserver) Sets the server's Sasl stream.
void	start() Starts authentication with the server and wait until completion.
void	stop() Stops authenticated session with the server by releasing the long poll.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SaslStreamClientDriver

public SaslStreamClientDriver(SaslHandshakeClientHandler handshakeClient,
                              AtomicBoolean authenticated,
                              UUID channelId,
                              long grpcAuthTimeoutMs)

Creates client driver with given handshake handler.

Parameters:

handshakeClient - client handshake handler

authenticated - boolean reference to receive authentication state changes

channelId - channel Id for authentication

grpcAuthTimeoutMs - authentication timeout in milliseconds

Method Detail

setServerObserver

public void setServerObserver(io.grpc.stub.StreamObserver<SaslMessage> requestObserver)

Sets the server's Sasl stream.

Parameters:

requestObserver - server Sasl stream

onNext

public void onNext(SaslMessage saslMessage)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<SaslMessage>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface io.grpc.stub.StreamObserver<SaslMessage>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<SaslMessage>

start

public void start()
           throws AlluxioStatusException

Starts authentication with the server and wait until completion.

Throws:

UnauthenticatedException

AlluxioStatusException

stop

public void stop()

Stops authenticated session with the server by releasing the long poll.