org.apache.thrift.transport.sasl

Class FixedSizeHeaderReader

java.lang.Object

org.apache.thrift.transport.sasl.FixedSizeHeaderReader

All Implemented Interfaces:

FrameHeaderReader

Direct Known Subclasses:

DataFrameHeaderReader, SaslNegotiationHeaderReader

public abstract class FixedSizeHeaderReader
extends java.lang.Object
implements FrameHeaderReader

Headers' size should be predefined.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.nio.ByteBuffer	byteBuffer

Constructor Summary

Constructors

Constructor and Description
FixedSizeHeaderReader()

Method Summary

Modifier and Type	Method and Description
void	clear() Clear the header and make it available to read a new header.
protected abstract int	headerSize()
boolean	isComplete()
protected abstract void	onComplete() Actions (e.g.
boolean	read(TTransport transport) (Nonblocking) Read fields from underlying transport layer.
byte[]	toBytes()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.thrift.transport.sasl.FrameHeaderReader

payloadSize

Field Detail

byteBuffer

protected final java.nio.ByteBuffer byteBuffer

Constructor Detail

FixedSizeHeaderReader

public FixedSizeHeaderReader()

Method Detail

isComplete

public boolean isComplete()

Specified by:

isComplete in interface FrameHeaderReader

Returns:

true if this header has all its fields set.

clear

public void clear()

Description copied from interface: FrameHeaderReader

Clear the header and make it available to read a new header.

Specified by:

clear in interface FrameHeaderReader

toBytes

public byte[] toBytes()

Specified by:

toBytes in interface FrameHeaderReader

Returns:

The received bytes for the header.

read

public boolean read(TTransport transport)
             throws TTransportException

Description copied from interface: FrameHeaderReader

(Nonblocking) Read fields from underlying transport layer.

Specified by:

read in interface FrameHeaderReader

Parameters:

transport - underlying transport.

Returns:

true if header is complete after read.

Throws:

TSaslNegotiationException - if fail to read a valid header of a sasl negotiation message.

TTransportException - if io error.

headerSize

protected abstract int headerSize()

Returns:

Size of the header.

onComplete

protected abstract void onComplete()
                            throws TTransportException

Actions (e.g. validation) to carry out when the header is complete.

Throws:

TTransportException