Package io.netty.handler.codec.http.multipart

Class HttpPostStandardRequestDecoder

java.lang.Object

io.netty.handler.codec.http.multipart.HttpPostStandardRequestDecoder

All Implemented Interfaces:

InterfaceHttpPostRequestDecoder

public class HttpPostStandardRequestDecoder
extends Object
implements InterfaceHttpPostRequestDecoder

This decoder will decode Body and can handle POST BODY. You MUST call destroy() after completion to release all resources.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	HttpPostStandardRequestDecoder.UrlDecoder
private static final class	HttpPostStandardRequestDecoder.UrlEncodedDetector

Field Summary

Fields

Modifier and Type	Field	Description
private final List<InterfaceHttpData>	bodyListHttpData	HttpDatas from Body
private int	bodyListHttpDataRank	Body HttpDatas current position
private final Map<String,List<InterfaceHttpData>>	bodyMapHttpData	HttpDatas as Map from Body
private final Charset	charset	Default charset to use
private Attribute	currentAttribute	The current Attribute that is currently in decode process
private HttpPostRequestDecoder.MultiPartStatus	currentStatus	Current getStatus
private boolean	destroyed
private int	discardThreshold
private final HttpDataFactory	factory	Factory used to create InterfaceHttpData
private boolean	isLastChunk	Does the last chunk already received
private final int	maxBufferedBytes	The maximum number of accumulated bytes when decoding a field
private final int	maxFields	The maximum number of fields allows by the form
private final HttpRequest	request	Request to decode
private ByteBuf	undecodedChunk	The current channelBuffer

Constructor Summary

Constructors

Constructor	Description
HttpPostStandardRequestDecoder(HttpRequest request)
HttpPostStandardRequestDecoder(HttpDataFactory factory, HttpRequest request)
HttpPostStandardRequestDecoder(HttpDataFactory factory, HttpRequest request, Charset charset)
HttpPostStandardRequestDecoder(HttpDataFactory factory, HttpRequest request, Charset charset, int maxFields, int maxBufferedBytes)

Method Summary

Modifier and Type	Method	Description
protected void	addHttpData(InterfaceHttpData data)	Utility function to add a new decoded data
private void	checkDestroyed()
void	cleanFiles()	Clean all HttpDatas for the current request.
InterfaceHttpData	currentPartialHttpData()	Returns the current InterfaceHttpData if currently in decoding status, meaning all data are not yet within, or null if there is no InterfaceHttpData currently in decoding status (either because none yet decoded or none currently partially decoded).
private static ByteBuf	decodeAttribute(ByteBuf b, Charset charset)
private static String	decodeAttribute(String s, Charset charset)	Decode component
void	destroy()	Destroy the HttpPostStandardRequestDecoder and release all it resources.
InterfaceHttpData	getBodyHttpData(String name)	This getMethod returns the first InterfaceHttpData with the given name from body. If chunked, all chunks must have been offered using offer() getMethod.
List<InterfaceHttpData>	getBodyHttpDatas()	This getMethod returns a List of all HttpDatas from body. If chunked, all chunks must have been offered using offer() getMethod.
List<InterfaceHttpData>	getBodyHttpDatas(String name)	This getMethod returns a List of all HttpDatas with the given name from body. If chunked, all chunks must have been offered using offer() getMethod.
int	getDiscardThreshold()	Return the threshold in bytes after which read data in the buffer should be discarded.
private boolean	hasFormBody()	Check if request has headers indicating that it contains form body
boolean	hasNext()	True if at current getStatus, there is an available decoded InterfaceHttpData from the Body.
boolean	isMultipart()	True if this request is a Multipart request
InterfaceHttpData	next()	Returns the next available InterfaceHttpData or null if, at the time it is called, there is no more available InterfaceHttpData.
HttpPostStandardRequestDecoder	offer(HttpContent content)	Initialized the internals from a new chunk
private void	parseBody()	This getMethod will parse as much as possible data and fill the list and map
private void	parseBodyAttributes()	This getMethod fill the map and list with as much Attribute as possible from Body in not Multipart mode.
private void	parseBodyAttributesStandard()	This getMethod fill the map and list with as much Attribute as possible from Body in not Multipart mode.
void	removeHttpDataFromClean(InterfaceHttpData data)	Remove the given FileUpload from the list of FileUploads to clean
void	setDiscardThreshold(int discardThreshold)	Set the amount of bytes after which read bytes in the buffer should be discarded.
private void	setFinalBuffer(ByteBuf buffer)

Methods inherited from class java.lang.Object

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

Field Details

factory

private final HttpDataFactory factory

Factory used to create InterfaceHttpData

request

private final HttpRequest request

Request to decode

charset

private final Charset charset

Default charset to use

maxFields

private final int maxFields

The maximum number of fields allows by the form

maxBufferedBytes

private final int maxBufferedBytes

The maximum number of accumulated bytes when decoding a field

isLastChunk

private boolean isLastChunk

Does the last chunk already received

bodyListHttpData

private final List<InterfaceHttpData> bodyListHttpData

HttpDatas from Body

bodyMapHttpData

private final Map<String,List<InterfaceHttpData>> bodyMapHttpData

HttpDatas as Map from Body

undecodedChunk

private ByteBuf undecodedChunk

The current channelBuffer

bodyListHttpDataRank

private int bodyListHttpDataRank

Body HttpDatas current position

currentStatus

private HttpPostRequestDecoder.MultiPartStatus currentStatus

Current getStatus

currentAttribute

private Attribute currentAttribute

The current Attribute that is currently in decode process

destroyed

private boolean destroyed

discardThreshold

private int discardThreshold

Constructor Details

HttpPostStandardRequestDecoder

public HttpPostStandardRequestDecoder(HttpRequest request)

Parameters:

request - the request to decode

Throws:

NullPointerException - for request

HttpPostRequestDecoder.ErrorDataDecoderException - if the default charset was wrong when decoding or other errors

HttpPostStandardRequestDecoder

public HttpPostStandardRequestDecoder(HttpDataFactory factory,
 HttpRequest request)

Parameters:

factory - the factory used to create InterfaceHttpData

request - the request to decode

Throws:

NullPointerException - for request or factory

HttpPostRequestDecoder.ErrorDataDecoderException - if the default charset was wrong when decoding or other errors

HttpPostStandardRequestDecoder

public HttpPostStandardRequestDecoder(HttpDataFactory factory,
 HttpRequest request,
 Charset charset)

Parameters:

factory - the factory used to create InterfaceHttpData

request - the request to decode

charset - the charset to use as default

Throws:

NullPointerException - for request or charset or factory

HttpPostRequestDecoder.ErrorDataDecoderException - if the default charset was wrong when decoding or other errors

HttpPostStandardRequestDecoder

public HttpPostStandardRequestDecoder(HttpDataFactory factory,
 HttpRequest request,
 Charset charset,
 int maxFields,
 int maxBufferedBytes)

Parameters:

factory - the factory used to create InterfaceHttpData

request - the request to decode

charset - the charset to use as default

maxFields - the maximum number of fields the form can have, -1 to disable

maxBufferedBytes - the maximum number of bytes the decoder can buffer when decoding a field, -1 to disable

Throws:

NullPointerException - for request or charset or factory

HttpPostRequestDecoder.ErrorDataDecoderException - if the default charset was wrong when decoding or other errors

Method Details

checkDestroyed

private void checkDestroyed()

isMultipart

public boolean isMultipart()

True if this request is a Multipart request

Specified by:

isMultipart in interface InterfaceHttpPostRequestDecoder

Returns:

True if this request is a Multipart request

setDiscardThreshold

public void setDiscardThreshold(int discardThreshold)

Set the amount of bytes after which read bytes in the buffer should be discarded. Setting this lower gives lower memory usage but with the overhead of more memory copies. Use 0 to disable it.

Specified by:

setDiscardThreshold in interface InterfaceHttpPostRequestDecoder

getDiscardThreshold

public int getDiscardThreshold()

Return the threshold in bytes after which read data in the buffer should be discarded.

Specified by:

getDiscardThreshold in interface InterfaceHttpPostRequestDecoder

getBodyHttpDatas

public List<InterfaceHttpData> getBodyHttpDatas()

This getMethod returns a List of all HttpDatas from body.
If chunked, all chunks must have been offered using offer() getMethod. If not, NotEnoughDataDecoderException will be raised.

Specified by:

getBodyHttpDatas in interface InterfaceHttpPostRequestDecoder

Returns:

the list of HttpDatas from Body part for POST getMethod

Throws:

HttpPostRequestDecoder.NotEnoughDataDecoderException - Need more chunks

getBodyHttpDatas

public List<InterfaceHttpData> getBodyHttpDatas(String name)

This getMethod returns a List of all HttpDatas with the given name from body.
If chunked, all chunks must have been offered using offer() getMethod. If not, NotEnoughDataDecoderException will be raised.

Specified by:

getBodyHttpDatas in interface InterfaceHttpPostRequestDecoder

Returns:

All Body HttpDatas with the given name (ignore case)

Throws:

HttpPostRequestDecoder.NotEnoughDataDecoderException - need more chunks

getBodyHttpData

public InterfaceHttpData getBodyHttpData(String name)

This getMethod returns the first InterfaceHttpData with the given name from body.
If chunked, all chunks must have been offered using offer() getMethod. If not, NotEnoughDataDecoderException will be raised.

Specified by:

getBodyHttpData in interface InterfaceHttpPostRequestDecoder

Returns:

The first Body InterfaceHttpData with the given name (ignore case)

Throws:

HttpPostRequestDecoder.NotEnoughDataDecoderException - need more chunks

offer

public HttpPostStandardRequestDecoder offer(HttpContent content)

Initialized the internals from a new chunk

Specified by:

offer in interface InterfaceHttpPostRequestDecoder

Parameters:

content - the new received chunk

Throws:

HttpPostRequestDecoder.ErrorDataDecoderException - if there is a problem with the charset decoding or other errors

hasNext

public boolean hasNext()

True if at current getStatus, there is an available decoded InterfaceHttpData from the Body. This getMethod works for chunked and not chunked request.

Specified by:

hasNext in interface InterfaceHttpPostRequestDecoder

Returns:

True if at current getStatus, there is a decoded InterfaceHttpData

Throws:

HttpPostRequestDecoder.EndOfDataDecoderException - No more data will be available

next

public InterfaceHttpData next()

Returns the next available InterfaceHttpData or null if, at the time it is called, there is no more available InterfaceHttpData. A subsequent call to offer(httpChunk) could enable more data. Be sure to call ReferenceCounted.release() after you are done with processing to make sure to not leak any resources

Specified by:

next in interface InterfaceHttpPostRequestDecoder

Returns:

the next available InterfaceHttpData or null if none

Throws:

HttpPostRequestDecoder.EndOfDataDecoderException - No more data will be available

currentPartialHttpData

public InterfaceHttpData currentPartialHttpData()

Description copied from interface: InterfaceHttpPostRequestDecoder

Returns the current InterfaceHttpData if currently in decoding status, meaning all data are not yet within, or null if there is no InterfaceHttpData currently in decoding status (either because none yet decoded or none currently partially decoded). Full decoded ones are accessible through hasNext() and next() methods.

Specified by:

currentPartialHttpData in interface InterfaceHttpPostRequestDecoder

Returns:

the current InterfaceHttpData if currently in decoding status or null if none.

parseBody

private void parseBody()

This getMethod will parse as much as possible data and fill the list and map

Throws:

HttpPostRequestDecoder.ErrorDataDecoderException - if there is a problem with the charset decoding or other errors

addHttpData

protected void addHttpData(InterfaceHttpData data)

Utility function to add a new decoded data

parseBodyAttributesStandard

private void parseBodyAttributesStandard()

This getMethod fill the map and list with as much Attribute as possible from Body in not Multipart mode.

Throws:

HttpPostRequestDecoder.ErrorDataDecoderException - if there is a problem with the charset decoding or other errors

parseBodyAttributes

private void parseBodyAttributes()

This getMethod fill the map and list with as much Attribute as possible from Body in not Multipart mode.

Throws:

HttpPostRequestDecoder.ErrorDataDecoderException - if there is a problem with the charset decoding or other errors

setFinalBuffer

private void setFinalBuffer(ByteBuf buffer)
                     throws IOException

Throws:

IOException

decodeAttribute

private static String decodeAttribute(String s,
 Charset charset)

Decode component

Returns:

the decoded component

decodeAttribute

private static ByteBuf decodeAttribute(ByteBuf b,
 Charset charset)

destroy

public void destroy()

Destroy the HttpPostStandardRequestDecoder and release all it resources. After this method was called it is not possible to operate on it anymore.

Specified by:

destroy in interface InterfaceHttpPostRequestDecoder

cleanFiles

public void cleanFiles()

Clean all HttpDatas for the current request.

Specified by:

cleanFiles in interface InterfaceHttpPostRequestDecoder

removeHttpDataFromClean

public void removeHttpDataFromClean(InterfaceHttpData data)

Remove the given FileUpload from the list of FileUploads to clean

Specified by:

removeHttpDataFromClean in interface InterfaceHttpPostRequestDecoder

hasFormBody

private boolean hasFormBody()

Check if request has headers indicating that it contains form body