org.apache.giraph.comm.netty

Class SaslNettyClient

java.lang.Object

org.apache.giraph.comm.netty.SaslNettyClient

public class SaslNettyClient
extends Object

Implements SASL logic for Giraph BSP worker clients.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.log4j.Logger	LOG Class logger

Constructor Summary

Constructors

Constructor and Description
SaslNettyClient() Create a SaslNettyClient for authentication with BSP servers.

Method Summary

Modifier and Type	Method and Description
SaslTokenMessageRequest	firstToken() Used by authenticateOnChannel() to initiate SASL handshake with server.
Object	getAuthenticated()
boolean	isComplete()
byte[]	saslResponse(SaslTokenMessageRequest saslTokenMessage) Respond to server's SASL token.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.apache.log4j.Logger LOG

Class logger

Constructor Detail

SaslNettyClient

public SaslNettyClient()

Create a SaslNettyClient for authentication with BSP servers.

Method Detail

getAuthenticated

public Object getAuthenticated()

firstToken

public SaslTokenMessageRequest firstToken()
                                   throws IOException

Used by authenticateOnChannel() to initiate SASL handshake with server.

Returns:

SaslTokenMessageRequest message to be sent to server.

Throws:

IOException

isComplete

public boolean isComplete()

saslResponse

public byte[] saslResponse(SaslTokenMessageRequest saslTokenMessage)

Respond to server's SASL token.

Parameters:

saslTokenMessage - contains server's SASL token

Returns:

client's response SASL token