Modifier and Type	Class and Description
private abstract class	HAProxyMessageDecoder.HeaderExtractor HeaderExtractor create a header frame out of the `Buffer`.
private class	HAProxyMessageDecoder.LineHeaderExtractor
private class	HAProxyMessageDecoder.StructHeaderExtractor

Field Summary

Modifier and Type	Field and Description
private static final int	BINARY_PREFIX_LENGTH Binary header prefix length
private static final ProtocolDetectionResult<HAProxyProtocolVersion>	DETECTION_RESULT_V1 `ProtocolDetectionResult` for `HAProxyProtocolVersion#V1`.
private static final ProtocolDetectionResult<HAProxyProtocolVersion>	DETECTION_RESULT_V2 `ProtocolDetectionResult` for `HAProxyProtocolVersion#V2`.
private int	discardedBytes Number of discarded bytes
private boolean	discarding `true` if we're discarding input because we're already over maxLength
private final boolean	failFast Whether or not to throw an exception as soon as we exceed maxLength.
private boolean	finished `true` if we're finished decoding the proxy protocol header
private HAProxyMessageDecoder.HeaderExtractor	headerExtractor Used to extract a header frame out of the `Buffer` and return it.
private static final int	V1_MAX_LENGTH Maximum possible length of a v1 proxy protocol header per spec
private static final int	V2_MAX_LENGTH Maximum possible length of a v2 proxy protocol header (fixed 16 bytes + max unsigned short)
private static final int	V2_MAX_TLV Maximum possible length for v2 additional TLV data (max unsigned short - max v2 address info space)
private static final int	V2_MIN_LENGTH Minimum possible length of a fully functioning v2 proxy protocol header (fixed 16 bytes + v2 address info space)
private final int	v2MaxHeaderSize The latest v2 spec (2014/05/18) allows for additional data to be sent in the proxy protocol header beyond the address information block so now we need a configurable max header size
private int	version Protocol specification version

Inherited from io.netty5.handler.codec.ByteToMessageDecoder:: COMPOSITE_CUMULATOR MERGE_CUMULATOR

Constructor Summary

Access	Constructor and Description
public	HAProxyMessageDecoder() Creates a new decoder with no additional data (TLV) restrictions, and should throw an exception as soon as we exceed maxLength.
public	HAProxyMessageDecoder(boolean Whether or not to throw an exception as soon as we exceed maxLength failFast) Creates a new decoder with no additional data (TLV) restrictions, whether or not to throw an exception as soon as we exceed maxLength.
public	HAProxyMessageDecoder(int maximum number of bytes allowed for additional data (Type-Length-Value vectors) in a v2 header maxTlvSize) Creates a new decoder with restricted additional data (TLV) size, and should throw an exception as soon as we exceed maxLength.
public	HAProxyMessageDecoder(int maximum number of bytes allowed for additional data (Type-Length-Value vectors) in a v2 header maxTlvSize, boolean Whether or not to throw an exception as soon as we exceed maxLength failFast) Creates a new decoder with restricted additional data (TLV) size, whether or not to throw an exception as soon as we exceed maxLength.

Method Summary

Modifier and Type	Method and Description
public void	channelExceptionCaught(ChannelHandlerContext ctx, Throwable cause) Overrides default io.netty5.channel.ChannelHandler.channelExceptionCaught. Gets called if a `Throwable` was thrown when handling inbound events.
public void	channelRead(ChannelHandlerContext ctx, Object msg) Overrides io.netty5.handler.codec.ByteToMessageDecoder.channelRead. Overrides default io.netty5.channel.ChannelHandler.channelRead. Invoked when the current `Channel` has read a message from the peer.
protected final void	decode(ChannelHandlerContext the `ChannelHandlerContext` which this `ByteToMessageDecoder` belongs to ctx, Buffer the `Buffer` from which to read data in) Implements abstract io.netty5.handler.codec.ByteToMessageDecoder.decode. Decode the from one `Buffer` to another.
private Buffer	Returns: frame the `Buffer` which represent the frame or `null` if no frame could be created decodeLine(ChannelHandlerContext the `ChannelHandlerContext` which this `HAProxyMessageDecoder` belongs to ctx, Buffer the `Buffer` from which to read data buffer) Create a frame out of the `Buffer` and return it.
private Buffer	Returns: frame the `Buffer` which represent the frame or `null` if no frame could be created decodeStruct(ChannelHandlerContext the `ChannelHandlerContext` which this `HAProxyMessageDecoder` belongs to ctx, Buffer the `Buffer` from which to read data buffer) Create a frame out of the `Buffer` and return it.
public static ProtocolDetectionResult<HAProxyProtocolVersion>	detectProtocol(Buffer buffer) Returns the `ProtocolDetectionResult` for the given `Buffer`.
private void	fail(final ChannelHandlerContext ctx, String errMsg, Exception e)
private void	failOverLimit(final ChannelHandlerContext ctx, int length)
private void	failOverLimit(final ChannelHandlerContext ctx, String length)
private static int	findEndOfHeader(final Buffer buffer) Returns the index in the buffer of the end of header if found.
private static int	findEndOfLine(final Buffer buffer) Returns the index in the buffer of the end of line found.
private static int	findVersion(final Buffer buffer) Returns the proxy protocol specification version in the buffer if the version is found.
public boolean	isSingleDecode() Overrides io.netty5.handler.codec.ByteToMessageDecoder.isSingleDecode. If `true` then only one message is decoded on each `channelRead(ChannelHandlerContext, Object)` call.
private static boolean	match(byte[] prefix, Buffer buffer, int idx)

Inherited from io.netty5.handler.codec.ByteToMessageDecoder:: actualReadableBytes channelInactive channelReadComplete channelShutdown decodeLast discardSomeReadBytes handlerAdded handlerAdded0 handlerRemoved handlerRemoved0 internalBuffer isSharable setSingleDecode

Field Detail

BINARY_PREFIX_LENGTH	back to summary
private static final int BINARY_PREFIX_LENGTH Binary header prefix length

DETECTION_RESULT_V1	back to summary
private static final ProtocolDetectionResult<HAProxyProtocolVersion> DETECTION_RESULT_V1 `ProtocolDetectionResult` for `HAProxyProtocolVersion#V1`.

DETECTION_RESULT_V2	back to summary
private static final ProtocolDetectionResult<HAProxyProtocolVersion> DETECTION_RESULT_V2 `ProtocolDetectionResult` for `HAProxyProtocolVersion#V2`.

discardedBytes	back to summary
private int discardedBytes Number of discarded bytes

discarding	back to summary
private boolean discarding `true` if we're discarding input because we're already over maxLength

failFast	back to summary
private final boolean failFast Whether or not to throw an exception as soon as we exceed maxLength.

finished	back to summary
private boolean finished `true` if we're finished decoding the proxy protocol header

headerExtractor	back to summary
private HAProxyMessageDecoder.HeaderExtractor headerExtractor Used to extract a header frame out of the `Buffer` and return it.

V1_MAX_LENGTH	back to summary
private static final int V1_MAX_LENGTH Maximum possible length of a v1 proxy protocol header per spec

V2_MAX_LENGTH	back to summary
private static final int V2_MAX_LENGTH Maximum possible length of a v2 proxy protocol header (fixed 16 bytes + max unsigned short)

V2_MAX_TLV	back to summary
private static final int V2_MAX_TLV Maximum possible length for v2 additional TLV data (max unsigned short - max v2 address info space)

V2_MIN_LENGTH	back to summary
private static final int V2_MIN_LENGTH Minimum possible length of a fully functioning v2 proxy protocol header (fixed 16 bytes + v2 address info space)

v2MaxHeaderSize	back to summary
private final int v2MaxHeaderSize The latest v2 spec (2014/05/18) allows for additional data to be sent in the proxy protocol header beyond the address information block so now we need a configurable max header size

version	back to summary
private int version Protocol specification version

Constructor Detail

HAProxyMessageDecoder	back to summary
public HAProxyMessageDecoder() Creates a new decoder with no additional data (TLV) restrictions, and should throw an exception as soon as we exceed maxLength.

HAProxyMessageDecoder	back to summary
public HAProxyMessageDecoder(boolean failFast) Creates a new decoder with no additional data (TLV) restrictions, whether or not to throw an exception as soon as we exceed maxLength. Parameters failFast:boolean Whether or not to throw an exception as soon as we exceed maxLength

HAProxyMessageDecoder

back to summary

public HAProxyMessageDecoder(boolean failFast)

Creates a new decoder with no additional data (TLV) restrictions, whether or not to throw an exception as soon as we exceed maxLength.

Parameters

failFast:boolean: Whether or not to throw an exception as soon as we exceed maxLength

HAProxyMessageDecoder back to summary

HAProxyMessageDecoder	back to summary
public HAProxyMessageDecoder(int maxTlvSize) Creates a new decoder with restricted additional data (TLV) size, and should throw an exception as soon as we exceed maxLength. Note limiting TLV size only affects processing of v2, binary headers. Also, as allowed by the 1.5 spec TLV data is currently ignored. For maximum performance it would be best to configure your upstream proxy host to NOT send TLV data and instantiate with a max TLV size of `0`. Parameters maxTlvSize:int maximum number of bytes allowed for additional data (Type-Length-Value vectors) in a v2 header

public HAProxyMessageDecoder(int maxTlvSize)

Creates a new decoder with restricted additional data (TLV) size, and should throw an exception as soon as we exceed maxLength.

Note

limiting TLV size only affects processing of v2, binary headers. Also, as allowed by the 1.5 spec TLV data is currently ignored. For maximum performance it would be best to configure your upstream proxy host to NOT send TLV data and instantiate with a max TLV size of 0.

Parameters

maxTlvSize:int: maximum number of bytes allowed for additional data (Type-Length-Value vectors) in a v2 header

HAProxyMessageDecoder	back to summary
public HAProxyMessageDecoder(int maxTlvSize, boolean failFast) Creates a new decoder with restricted additional data (TLV) size, whether or not to throw an exception as soon as we exceed maxLength. Parameters maxTlvSize:int maximum number of bytes allowed for additional data (Type-Length-Value vectors) in a v2 header failFast:boolean Whether or not to throw an exception as soon as we exceed maxLength

HAProxyMessageDecoder

back to summary

public HAProxyMessageDecoder(int maxTlvSize, boolean failFast)

Creates a new decoder with restricted additional data (TLV) size, whether or not to throw an exception as soon as we exceed maxLength.

Parameters

maxTlvSize:int: maximum number of bytes allowed for additional data (Type-Length-Value vectors) in a v2 header
failFast:boolean: Whether or not to throw an exception as soon as we exceed maxLength

Method Detail

channelExceptionCaught back to summary

channelExceptionCaught	back to summary
public void channelExceptionCaught(ChannelHandlerContext ctx, Throwable cause) Overrides default io.netty5.channel.ChannelHandler.channelExceptionCaught. Doc from io.netty5.channel.ChannelHandler.channelExceptionCaught. Gets called if a `Throwable` was thrown when handling inbound events. Annotations @Override

public void channelExceptionCaught(ChannelHandlerContext ctx, Throwable cause)

Overrides default io.netty5.channel.ChannelHandler.channelExceptionCaught.

Doc from io.netty5.channel.ChannelHandler.channelExceptionCaught.

Gets called if a Throwable was thrown when handling inbound events.

Annotations

@Override

channelRead back to summary

channelRead	back to summary
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception Overrides io.netty5.handler.codec.ByteToMessageDecoder.channelRead. Overrides default io.netty5.channel.ChannelHandler.channelRead. Doc from io.netty5.channel.ChannelHandler.channelRead. Invoked when the current `Channel` has read a message from the peer. Annotations @Override

public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception

Overrides io.netty5.handler.codec.ByteToMessageDecoder.channelRead.

Overrides default io.netty5.channel.ChannelHandler.channelRead.

Doc from io.netty5.channel.ChannelHandler.channelRead.

Invoked when the current Channel has read a message from the peer.

Annotations

@Override

decode back to summary

decode	back to summary
protected final void decode(ChannelHandlerContext ctx, Buffer in) Implements abstract io.netty5.handler.codec.ByteToMessageDecoder.decode. Doc from io.netty5.handler.codec.ByteToMessageDecoder.decode. Decode the from one `Buffer` to another. This method will be called till either the input `Buffer` has nothing to read when return from this method or till nothing was read from the input `Buffer`. Parameters ctx:ChannelHandlerContext the `ChannelHandlerContext` which this `ByteToMessageDecoder` belongs to in:Buffer the `Buffer` from which to read data Annotations @Override

protected final void decode(ChannelHandlerContext ctx, Buffer in)

Implements abstract io.netty5.handler.codec.ByteToMessageDecoder.decode.

Doc from io.netty5.handler.codec.ByteToMessageDecoder.decode.

Decode the from one Buffer to another. This method will be called till either the input Buffer has nothing to read when return from this method or till nothing was read from the input Buffer.

Parameters

ctx:ChannelHandlerContext: the ChannelHandlerContext which this ByteToMessageDecoder belongs to
in:Buffer: the Buffer from which to read data

Annotations

@Override

decodeLine back to summary

decodeLine	back to summary
private Buffer decodeLine(ChannelHandlerContext ctx, Buffer buffer) Create a frame out of the `Buffer` and return it. Parameters ctx:ChannelHandlerContext the `ChannelHandlerContext` which this `HAProxyMessageDecoder` belongs to buffer:Buffer the `Buffer` from which to read data Returns:Buffer frame the `Buffer` which represent the frame or `null` if no frame could be created

private Buffer decodeLine(ChannelHandlerContext ctx, Buffer buffer)

Create a frame out of the Buffer and return it.

Parameters

ctx:ChannelHandlerContext: the ChannelHandlerContext which this HAProxyMessageDecoder belongs to
buffer:Buffer: the Buffer from which to read data

Returns:Buffer

frame the Buffer which represent the frame or null if no frame could be created

decodeStruct back to summary

decodeStruct	back to summary
private Buffer decodeStruct(ChannelHandlerContext ctx, Buffer buffer) Create a frame out of the `Buffer` and return it. Parameters ctx:ChannelHandlerContext the `ChannelHandlerContext` which this `HAProxyMessageDecoder` belongs to buffer:Buffer the `Buffer` from which to read data Returns:Buffer frame the `Buffer` which represent the frame or `null` if no frame could be created

private Buffer decodeStruct(ChannelHandlerContext ctx, Buffer buffer)

Create a frame out of the Buffer and return it.

Parameters

ctx:ChannelHandlerContext: the ChannelHandlerContext which this HAProxyMessageDecoder belongs to
buffer:Buffer: the Buffer from which to read data

Returns:Buffer

frame the Buffer which represent the frame or null if no frame could be created

detectProtocol	back to summary
public static ProtocolDetectionResult<HAProxyProtocolVersion> detectProtocol(Buffer buffer) Returns the `ProtocolDetectionResult` for the given `Buffer`.

fail	back to summary
private void fail(final ChannelHandlerContext ctx, String errMsg, Exception e)

failOverLimit	back to summary
private void failOverLimit(final ChannelHandlerContext ctx, int length)

failOverLimit	back to summary
private void failOverLimit(final ChannelHandlerContext ctx, String length)

findEndOfHeader	back to summary
private static int findEndOfHeader(final Buffer buffer) Returns the index in the buffer of the end of header if found. Returns -1 if no end of header was found in the buffer.

findEndOfLine	back to summary
private static int findEndOfLine(final Buffer buffer) Returns the index in the buffer of the end of line found. Returns -1 if no end of line was found in the buffer.

findVersion	back to summary
private static int findVersion(final Buffer buffer) Returns the proxy protocol specification version in the buffer if the version is found. Returns -1 if no version was found in the buffer.

isSingleDecode back to summary

isSingleDecode	back to summary
public boolean isSingleDecode() Overrides io.netty5.handler.codec.ByteToMessageDecoder.isSingleDecode. Doc from io.netty5.handler.codec.ByteToMessageDecoder.isSingleDecode. If `true` then only one message is decoded on each `channelRead(ChannelHandlerContext, Object)` call. Default is `false` as this has performance impacts. Annotations @Override

public boolean isSingleDecode()

Overrides io.netty5.handler.codec.ByteToMessageDecoder.isSingleDecode.

Doc from io.netty5.handler.codec.ByteToMessageDecoder.isSingleDecode.

If true then only one message is decoded on each channelRead(ChannelHandlerContext, Object) call. Default is false as this has performance impacts.

Annotations

@Override

match	back to summary
private static boolean match(byte[] prefix, Buffer buffer, int idx)

io.netty.contrib.handler.codec.haproxy back to summary

private abstract Class HAProxyMessageDecoder.HeaderExtractor

Class Inheritance

extends Object

java.lang.Object
io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor

Known Direct Subclasses

io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.LineHeaderExtractor, io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.StructHeaderExtractor

HeaderExtractor create a header frame out of the Buffer.

Field Summary

Modifier and Type	Field and Description
private final int	maxHeaderSize Header max size

Constructor Summary

Access	Constructor and Description
protected	HeaderExtractor(int maxHeaderSize)

Method Summary

Modifier and Type	Method and Description
protected abstract int	Returns: length of the delimiter delimiterLength(Buffer the buffer where delimiter is located buffer, int index of delimiter eoh) Get the length of the header delimiter.
public Buffer	Returns: frame the `Buffer` which represent the frame or `null` if no frame could be created extract(ChannelHandlerContext the `ChannelHandlerContext` which this `HAProxyMessageDecoder` belongs to ctx, Buffer the `Buffer` from which to read data buffer) Create a frame out of the `Buffer` and return it.
protected abstract int	Returns: `-1` if can not find the end, otherwise return the buffer index of end findEndOfHeader(Buffer the buffer to be searched buffer) Find the end of the header from the given `Buffer`，the end may be a CRLF, or the length given by the header.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

maxHeaderSize	back to summary
private final int maxHeaderSize Header max size

Constructor Detail

HeaderExtractor	back to summary
protected HeaderExtractor(int maxHeaderSize)

Method Detail

delimiterLength	back to summary
protected abstract int delimiterLength(Buffer buffer, int eoh) Get the length of the header delimiter. Parameters buffer:Buffer the buffer where delimiter is located eoh:int index of delimiter Returns:int length of the delimiter

delimiterLength

back to summary

protected abstract int delimiterLength(Buffer buffer, int eoh)

Get the length of the header delimiter.

Parameters

buffer:Buffer: the buffer where delimiter is located
eoh:int: index of delimiter

Returns:int

length of the delimiter

extract back to summary

extract	back to summary
public Buffer extract(ChannelHandlerContext ctx, Buffer buffer) Create a frame out of the `Buffer` and return it. Parameters ctx:ChannelHandlerContext the `ChannelHandlerContext` which this `HAProxyMessageDecoder` belongs to buffer:Buffer the `Buffer` from which to read data Returns:Buffer frame the `Buffer` which represent the frame or `null` if no frame could be created Exceptions Exception: if exceed maxLength

public Buffer extract(ChannelHandlerContext ctx, Buffer buffer)

Create a frame out of the Buffer and return it.

Parameters

ctx:ChannelHandlerContext: the ChannelHandlerContext which this HAProxyMessageDecoder belongs to
buffer:Buffer: the Buffer from which to read data

Returns:Buffer

frame the Buffer which represent the frame or null if no frame could be created

Exceptions

Exception:: if exceed maxLength

findEndOfHeader back to summary

findEndOfHeader	back to summary
protected abstract int findEndOfHeader(Buffer buffer) Find the end of the header from the given `Buffer`，the end may be a CRLF, or the length given by the header. Parameters buffer:Buffer the buffer to be searched Returns:int `-1` if can not find the end, otherwise return the buffer index of end

protected abstract int findEndOfHeader(Buffer buffer)

Find the end of the header from the given Buffer，the end may be a CRLF, or the length given by the header.

Parameters

buffer:Buffer: the buffer to be searched

Returns:int

-1 if can not find the end, otherwise return the buffer index of end

io.netty.contrib.handler.codec.haproxy back to summary

private final Class HAProxyMessageDecoder.LineHeaderExtractor

Class Inheritance

extends HeaderExtractor

java.lang.Object
io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor
io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.LineHeaderExtractor

Constructor Summary

Access	Constructor and Description
pack-priv	LineHeaderExtractor(int maxHeaderSize)

Method Summary

Modifier and Type	Method and Description
protected int	delimiterLength(Buffer the buffer where delimiter is located buffer, int index of delimiter eoh) Implements abstract io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.delimiterLength. Get the length of the header delimiter.
protected int	findEndOfHeader(Buffer the buffer to be searched buffer) Implements abstract io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.findEndOfHeader. Find the end of the header from the given `Buffer`，the end may be a CRLF, or the length given by the header.

Inherited from io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor:: extract

Constructor Detail

LineHeaderExtractor	back to summary
pack-priv LineHeaderExtractor(int maxHeaderSize)

Method Detail

delimiterLength	back to summary
protected int delimiterLength(Buffer buffer, int eoh) Implements abstract io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.delimiterLength. Doc from io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.delimiterLength. Get the length of the header delimiter. Parameters buffer:Buffer the buffer where delimiter is located eoh:int index of delimiter Returns:int length of the delimiter Annotations @Override

delimiterLength

back to summary

protected int delimiterLength(Buffer buffer, int eoh)

Implements abstract io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.delimiterLength.

Doc from io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.delimiterLength.

Get the length of the header delimiter.

Parameters

buffer:Buffer: the buffer where delimiter is located
eoh:int: index of delimiter

Returns:int

length of the delimiter

Annotations

@Override

findEndOfHeader back to summary

findEndOfHeader	back to summary
protected int findEndOfHeader(Buffer buffer) Implements abstract io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.findEndOfHeader. Doc from io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.findEndOfHeader. Find the end of the header from the given `Buffer`，the end may be a CRLF, or the length given by the header. Parameters buffer:Buffer the buffer to be searched Returns:int `-1` if can not find the end, otherwise return the buffer index of end Annotations @Override

protected int findEndOfHeader(Buffer buffer)

Implements abstract io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.findEndOfHeader.

Doc from io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.findEndOfHeader.

Find the end of the header from the given Buffer，the end may be a CRLF, or the length given by the header.

Parameters

buffer:Buffer: the buffer to be searched

Returns:int

-1 if can not find the end, otherwise return the buffer index of end

Annotations

@Override

io.netty.contrib.handler.codec.haproxy back to summary

private final Class HAProxyMessageDecoder.StructHeaderExtractor

Class Inheritance

extends HeaderExtractor

java.lang.Object
io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor
io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.StructHeaderExtractor

Constructor Summary

Access	Constructor and Description
pack-priv	StructHeaderExtractor(int maxHeaderSize)

Method Summary

Modifier and Type	Method and Description
protected int	delimiterLength(Buffer the buffer where delimiter is located buffer, int index of delimiter eoh) Implements abstract io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.delimiterLength. Get the length of the header delimiter.
protected int	findEndOfHeader(Buffer the buffer to be searched buffer) Implements abstract io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.findEndOfHeader. Find the end of the header from the given `Buffer`，the end may be a CRLF, or the length given by the header.

Inherited from io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor:: extract

Constructor Detail

StructHeaderExtractor	back to summary
pack-priv StructHeaderExtractor(int maxHeaderSize)

Method Detail

delimiterLength

back to summary

protected int delimiterLength(Buffer buffer, int eoh)

Implements abstract io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.delimiterLength.

Doc from io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.delimiterLength.

Get the length of the header delimiter.

Parameters

buffer:Buffer: the buffer where delimiter is located
eoh:int: index of delimiter

Returns:int

length of the delimiter

Annotations

@Override

findEndOfHeader back to summary

protected int findEndOfHeader(Buffer buffer)

Implements abstract io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.findEndOfHeader.

Doc from io.netty.contrib.handler.codec.haproxy.HAProxyMessageDecoder.HeaderExtractor.findEndOfHeader.

Find the end of the header from the given Buffer，the end may be a CRLF, or the length given by the header.

Parameters

buffer:Buffer: the buffer to be searched

Returns:int

-1 if can not find the end, otherwise return the buffer index of end

Annotations

@Override

public Class HAProxyMessageDecoder

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private abstract Class HAProxyMessageDecoder.HeaderExtractor

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class HAProxyMessageDecoder.LineHeaderExtractor

Constructor Summary

Method Summary

Constructor Detail

Method Detail

private final Class HAProxyMessageDecoder.StructHeaderExtractor

Constructor Summary

Method Summary

Constructor Detail

Method Detail