Package io.netty.handler.codec.http2
Class Http2EmptyDataFrameListener
- java.lang.Object
-
- io.netty.handler.codec.http2.Http2FrameListenerDecorator
-
- io.netty.handler.codec.http2.Http2EmptyDataFrameListener
-
- All Implemented Interfaces:
Http2FrameListener
final class Http2EmptyDataFrameListener extends Http2FrameListenerDecorator
Enforce a limit on the maximum number of consecutive empty DATA frames (without end_of_stream flag) that are allowed before the connection will be closed.
-
-
Field Summary
Fields Modifier and Type Field Description private int
emptyDataFrames
private int
maxConsecutiveEmptyFrames
private boolean
violationDetected
-
Fields inherited from class io.netty.handler.codec.http2.Http2FrameListenerDecorator
listener
-
-
Constructor Summary
Constructors Constructor Description Http2EmptyDataFrameListener(Http2FrameListener listener, int maxConsecutiveEmptyFrames)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream)
Handles an inboundDATA
frame.void
onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream)
Handles an inboundHEADERS
frame.void
onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream)
Handles an inboundHEADERS
frame with priority information specified.-
Methods inherited from class io.netty.handler.codec.http2.Http2FrameListenerDecorator
onGoAwayRead, onPingAckRead, onPingRead, onPriorityRead, onPushPromiseRead, onRstStreamRead, onSettingsAckRead, onSettingsRead, onUnknownFrame, onWindowUpdateRead
-
-
-
-
Constructor Detail
-
Http2EmptyDataFrameListener
Http2EmptyDataFrameListener(Http2FrameListener listener, int maxConsecutiveEmptyFrames)
-
-
Method Detail
-
onDataRead
public int onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) throws Http2Exception
Description copied from interface:Http2FrameListener
Handles an inboundDATA
frame.- Specified by:
onDataRead
in interfaceHttp2FrameListener
- Overrides:
onDataRead
in classHttp2FrameListenerDecorator
- Parameters:
ctx
- the context from the handler where the frame was read.streamId
- the subject stream for the frame.data
- payload buffer for the frame. This buffer will be released by the codec.padding
- additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive).endOfStream
- Indicates whether this is the last frame to be sent from the remote endpoint for this stream.- Returns:
- the number of bytes that have been processed by the application. The returned bytes are used by the
inbound flow controller to determine the appropriate time to expand the inbound flow control window (i.e. send
WINDOW_UPDATE
). Returning a value equal to the length ofdata
+padding
will effectively opt-out of application-level flow control for this frame. Returning a value less than the length ofdata
+padding
will defer the returning of the processed bytes, which the application must later return viaHttp2LocalFlowController.consumeBytes(Http2Stream, int)
. The returned value must be >=0
and <=data.readableBytes()
+padding
. - Throws:
Http2Exception
-
onHeadersRead
public void onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) throws Http2Exception
Description copied from interface:Http2FrameListener
Handles an inboundHEADERS
frame.Only one of the following methods will be called for each
HEADERS
frame sequence. One will be called when theEND_HEADERS
flag has been received.Http2FrameListener.onHeadersRead(ChannelHandlerContext, int, Http2Headers, int, boolean)
Http2FrameListener.onHeadersRead(ChannelHandlerContext, int, Http2Headers, int, short, boolean, int, boolean)
Http2FrameListener.onPushPromiseRead(ChannelHandlerContext, int, int, Http2Headers, int)
To say it another way; the
Http2Headers
will contain all of the headers for the current message exchange step (additional queuing is not necessary).- Specified by:
onHeadersRead
in interfaceHttp2FrameListener
- Overrides:
onHeadersRead
in classHttp2FrameListenerDecorator
- Parameters:
ctx
- the context from the handler where the frame was read.streamId
- the subject stream for the frame.headers
- the received headers.padding
- additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive).endStream
- Indicates whether this is the last frame to be sent from the remote endpoint for this stream.- Throws:
Http2Exception
-
onHeadersRead
public void onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) throws Http2Exception
Description copied from interface:Http2FrameListener
Handles an inboundHEADERS
frame with priority information specified. Only called ifEND_HEADERS
encountered.Only one of the following methods will be called for each
HEADERS
frame sequence. One will be called when theEND_HEADERS
flag has been received.Http2FrameListener.onHeadersRead(ChannelHandlerContext, int, Http2Headers, int, boolean)
Http2FrameListener.onHeadersRead(ChannelHandlerContext, int, Http2Headers, int, short, boolean, int, boolean)
Http2FrameListener.onPushPromiseRead(ChannelHandlerContext, int, int, Http2Headers, int)
To say it another way; the
Http2Headers
will contain all of the headers for the current message exchange step (additional queuing is not necessary).- Specified by:
onHeadersRead
in interfaceHttp2FrameListener
- Overrides:
onHeadersRead
in classHttp2FrameListenerDecorator
- Parameters:
ctx
- the context from the handler where the frame was read.streamId
- the subject stream for the frame.headers
- the received headers.streamDependency
- the stream on which this stream depends, or 0 if dependent on the connection.weight
- the new weight for the stream.exclusive
- whether or not the stream should be the exclusive dependent of its parent.padding
- additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive).endStream
- Indicates whether this is the last frame to be sent from the remote endpoint for this stream.- Throws:
Http2Exception
-
-