Class HTTPMessageDecoder

java.lang.Object

com.biglybt.core.networkmanager.impl.http.HTTPMessageDecoder

All Implemented Interfaces:

MessageStreamDecoder

public class HTTPMessageDecoder
extends Object
implements MessageStreamDecoder

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	destroyed
private boolean	header_ready
private final StringBuffer	header_so_far
private HTTPNetworkConnection	http_connection
private static final int	MAX_HEADER
private final List	messages
private static final String	NL
private boolean	paused
private boolean	paused_internally
private int	protocol_bytes_read

Constructor Summary

Constructors

Constructor	Description
HTTPMessageDecoder()
HTTPMessageDecoder(String pre_read_header)

Method Summary

Modifier and Type	Method	Description
protected void	addMessage(Message message)
ByteBuffer	destroy()	Destroy this decoder, i.e.
int[]	getCurrentMessageProgress()	Get the details of the current message that is being received (read from the transport).
int	getDataBytesDecoded()	Get the number of (piece) data bytes decoded from the transport, from the last decode op.
int	getProtocolBytesDecoded()	Get the number of protocol (overhead) bytes decoded from the transport, from the last decode op.
protected int	getQueueSize()
void	pauseDecoding()	Pause message decoding.
protected void	pauseInternally()
long	performStreamDecode(Transport transport, long max_bytes)	Decode message stream from the given transport.
Message[]	removeDecodedMessages()	Get the messages decoded from the transport, if any, from the last decode op.
void	resumeDecoding()	Resume message decoding.
void	setConnection(HTTPNetworkConnection _http_connection)

Methods inherited from class Object

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

Field Details

MAX_HEADER

private static final int MAX_HEADER

See Also:

• Constant Field Values

NL

private static final String NL

See Also:

• Constant Field Values

http_connection

private HTTPNetworkConnection http_connection

paused

private volatile boolean paused

paused_internally

private volatile boolean paused_internally

destroyed

private volatile boolean destroyed

header_so_far

private final StringBuffer header_so_far

header_ready

private boolean header_ready

messages

private final List messages

protocol_bytes_read

private int protocol_bytes_read

Constructor Details

HTTPMessageDecoder

public HTTPMessageDecoder()

HTTPMessageDecoder

public HTTPMessageDecoder(String pre_read_header)

Method Details

setConnection

public void setConnection(HTTPNetworkConnection _http_connection)

performStreamDecode

public long performStreamDecode(Transport transport,
 long max_bytes)
                         throws IOException

Description copied from interface: MessageStreamDecoder

Decode message stream from the given transport.

Specified by:

performStreamDecode in interface MessageStreamDecoder

Parameters:

transport - to decode from

max_bytes - to decode/read from the stream

Returns:

number of bytes decoded

Throws:

IOException - on decoding error

addMessage

protected void addMessage(Message message)

removeDecodedMessages

public Message[] removeDecodedMessages()

Description copied from interface: MessageStreamDecoder

Get the messages decoded from the transport, if any, from the last decode op.

Specified by:

removeDecodedMessages in interface MessageStreamDecoder

Returns:

decoded messages, or null if no new complete messages were decoded

getProtocolBytesDecoded

public int getProtocolBytesDecoded()

Description copied from interface: MessageStreamDecoder

Get the number of protocol (overhead) bytes decoded from the transport, from the last decode op.

Specified by:

getProtocolBytesDecoded in interface MessageStreamDecoder

Returns:

number of protocol bytes received

getDataBytesDecoded

public int getDataBytesDecoded()

Description copied from interface: MessageStreamDecoder

Get the number of (piece) data bytes decoded from the transport, from the last decode op.

Specified by:

getDataBytesDecoded in interface MessageStreamDecoder

Returns:

number of data bytes received

getCurrentMessageProgress

public int[] getCurrentMessageProgress()

Description copied from interface: MessageStreamDecoder

Get the details of the current message that is being received (read from the transport).

Specified by:

getCurrentMessageProgress in interface MessageStreamDecoder

Returns:

[ size, done ] or null

pauseInternally

protected void pauseInternally()

pauseDecoding

public void pauseDecoding()

Description copied from interface: MessageStreamDecoder

Pause message decoding.

Specified by:

pauseDecoding in interface MessageStreamDecoder

resumeDecoding

public void resumeDecoding()

Description copied from interface: MessageStreamDecoder

Resume message decoding.

Specified by:

resumeDecoding in interface MessageStreamDecoder

getQueueSize

protected int getQueueSize()

destroy

public ByteBuffer destroy()

Description copied from interface: MessageStreamDecoder

Destroy this decoder, i.e. perform cleanup.

Specified by:

destroy in interface MessageStreamDecoder

Returns:

any bytes already-read and still remaining within the decoder