org.apache.giraph.comm.requests

Class SaslTokenMessageRequest

java.lang.Object

org.apache.giraph.comm.requests.WritableRequest

org.apache.giraph.comm.requests.SaslTokenMessageRequest

All Implemented Interfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, org.apache.hadoop.io.Writable

public class SaslTokenMessageRequest
extends WritableRequest

Send and receive SASL tokens.

Field Summary

Fields inherited from class org.apache.giraph.comm.requests.WritableRequest

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor and Description
SaslTokenMessageRequest() Constructor used for reflection only.
SaslTokenMessageRequest(byte[] token) Constructor used to send request.

Method Summary

Modifier and Type	Method and Description
byte[]	getSaslToken() Read accessor for SASL token
int	getSerializedSize() Get the size of the request in serialized form.
RequestType	getType() Get the type of the request
void	processToken(SaslNettyServer saslNettyServer) Update server's token in response to the SASL token received from client.
void	readFieldsRequest(DataInput input) Serialize the request
void	setSaslToken(byte[] token) Write accessor for SASL token
void	writeRequest(DataOutput output) Deserialize the request

Methods inherited from class org.apache.giraph.comm.requests.WritableRequest

getClientId, getConf, getRequestId, readFields, setClientId, setConf, setRequestId, write

Methods inherited from class java.lang.Object

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

Constructor Detail

SaslTokenMessageRequest

public SaslTokenMessageRequest()

Constructor used for reflection only.

SaslTokenMessageRequest

public SaslTokenMessageRequest(byte[] token)

Constructor used to send request.

Parameters:

token - the SASL token, generated by a SaslClient or SaslServer.

Method Detail

getSaslToken

public byte[] getSaslToken()

Read accessor for SASL token

Returns:

saslToken SASL token

setSaslToken

public void setSaslToken(byte[] token)

Write accessor for SASL token

Parameters:

token - SASL token

getType

public RequestType getType()

Description copied from class: WritableRequest

Get the type of the request

Specified by:

getType in class WritableRequest

Returns:

Request type

readFieldsRequest

public void readFieldsRequest(DataInput input)
                       throws IOException

Description copied from class: WritableRequest

Serialize the request

Parameters:

input - Input to read fields from

Throws:

IOException

processToken

public void processToken(SaslNettyServer saslNettyServer)

Update server's token in response to the SASL token received from client. Updated token is sent to client by SaslServerHandler.messageReceived().

Parameters:

saslNettyServer - used to create response.

writeRequest

public void writeRequest(DataOutput output)
                  throws IOException

Description copied from class: WritableRequest

Deserialize the request

Parameters:

output - Output to write the request to

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Description copied from class: WritableRequest

Get the size of the request in serialized form. The number returned by this function can't be less than the actual size - if the size can't be calculated correctly return WritableRequest.UNKNOWN_SIZE.

Overrides:

getSerializedSize in class WritableRequest

Returns:

The size (in bytes) of serialized request, or WritableRequest.UNKNOWN_SIZE if the size is not known or too expensive to calculate.