- java.lang.Object
-
- io.netty5.handler.codec.http2.DefaultHttp2FrameWriter
-
- All Implemented Interfaces:
Http2DataWriter
,Http2FrameSizePolicy
,Http2FrameWriter
,Http2FrameWriter.Configuration
,Closeable
,AutoCloseable
@UnstableApi public class DefaultHttp2FrameWriter extends Object implements Http2FrameWriter, Http2FrameSizePolicy, Http2FrameWriter.Configuration
AHttp2FrameWriter
that supports all frame types defined by the HTTP/2 specification.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface io.netty5.handler.codec.http2.Http2FrameWriter
Http2FrameWriter.Configuration
-
-
Constructor Summary
Constructors Constructor Description DefaultHttp2FrameWriter()
DefaultHttp2FrameWriter(Http2HeadersEncoder headersEncoder)
DefaultHttp2FrameWriter(Http2HeadersEncoder.SensitivityDetector headersSensitivityDetector)
DefaultHttp2FrameWriter(Http2HeadersEncoder.SensitivityDetector headersSensitivityDetector, boolean ignoreMaxHeaderListSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Closes this writer and frees any allocated resources.Http2FrameWriter.Configuration
configuration()
Get the configuration related elements for thisHttp2FrameWriter
Http2FrameSizePolicy
frameSizePolicy()
Get theHttp2FrameSizePolicy
for thisHttp2FrameWriter
Http2HeadersEncoder.Configuration
headersConfiguration()
Get theHttp2HeadersEncoder.Configuration
for thisHttp2FrameWriter
int
maxFrameSize()
Gets the maximum allowed frame size.void
maxFrameSize(int max)
Sets the maximum allowed frame size.Future<Void>
writeData(ChannelHandlerContext ctx, int streamId, Buffer data, int padding, boolean endStream)
Writes aDATA
frame to the remote endpoint.Future<Void>
writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, Buffer payload)
Generic write method for any HTTP/2 frame.Future<Void>
writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, Buffer debugData)
Writes a GO_AWAY frame to the remote endpoint.Future<Void>
writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream)
Writes a HEADERS frame to the remote endpoint.Future<Void>
writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream)
Writes a HEADERS frame with priority specified to the remote endpoint.Future<Void>
writePing(ChannelHandlerContext ctx, boolean ack, long data)
Writes a PING frame to the remote endpoint.Future<Void>
writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive)
Writes a PRIORITY frame to the remote endpoint.Future<Void>
writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding)
Writes a PUSH_PROMISE frame to the remote endpoint.Future<Void>
writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode)
Writes a RST_STREAM frame to the remote endpoint.Future<Void>
writeSettings(ChannelHandlerContext ctx, Http2Settings settings)
Writes a SETTINGS frame to the remote endpoint.Future<Void>
writeSettingsAck(ChannelHandlerContext ctx)
Writes a SETTINGS acknowledgment to the remote endpoint.Future<Void>
writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement)
Writes a WINDOW_UPDATE frame to the remote endpoint.
-
-
-
Constructor Detail
-
DefaultHttp2FrameWriter
public DefaultHttp2FrameWriter()
-
DefaultHttp2FrameWriter
public DefaultHttp2FrameWriter(Http2HeadersEncoder.SensitivityDetector headersSensitivityDetector)
-
DefaultHttp2FrameWriter
public DefaultHttp2FrameWriter(Http2HeadersEncoder.SensitivityDetector headersSensitivityDetector, boolean ignoreMaxHeaderListSize)
-
DefaultHttp2FrameWriter
public DefaultHttp2FrameWriter(Http2HeadersEncoder headersEncoder)
-
-
Method Detail
-
configuration
public Http2FrameWriter.Configuration configuration()
Description copied from interface:Http2FrameWriter
Get the configuration related elements for thisHttp2FrameWriter
- Specified by:
configuration
in interfaceHttp2FrameWriter
-
headersConfiguration
public Http2HeadersEncoder.Configuration headersConfiguration()
Description copied from interface:Http2FrameWriter.Configuration
Get theHttp2HeadersEncoder.Configuration
for thisHttp2FrameWriter
- Specified by:
headersConfiguration
in interfaceHttp2FrameWriter.Configuration
-
frameSizePolicy
public Http2FrameSizePolicy frameSizePolicy()
Description copied from interface:Http2FrameWriter.Configuration
Get theHttp2FrameSizePolicy
for thisHttp2FrameWriter
- Specified by:
frameSizePolicy
in interfaceHttp2FrameWriter.Configuration
-
maxFrameSize
public void maxFrameSize(int max) throws Http2Exception
Description copied from interface:Http2FrameSizePolicy
Sets the maximum allowed frame size. Attempts to write frames longer than this maximum will fail.This value is used to represent SETTINGS_MAX_FRAME_SIZE. This method should only be called by Netty (not users) as a result of a receiving a
SETTINGS
frame.- Specified by:
maxFrameSize
in interfaceHttp2FrameSizePolicy
- Throws:
Http2Exception
-
maxFrameSize
public int maxFrameSize()
Description copied from interface:Http2FrameSizePolicy
Gets the maximum allowed frame size.This value is used to represent SETTINGS_MAX_FRAME_SIZE. The initial value defined by the RFC is unlimited but enforcing a lower limit is generally permitted.
Http2CodecUtil.DEFAULT_MAX_FRAME_SIZE
can be used as a more conservative default.- Specified by:
maxFrameSize
in interfaceHttp2FrameSizePolicy
-
close
public void close()
Description copied from interface:Http2FrameWriter
Closes this writer and frees any allocated resources.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfaceHttp2FrameWriter
-
writeData
public Future<Void> writeData(ChannelHandlerContext ctx, int streamId, Buffer data, int padding, boolean endStream)
Description copied from interface:Http2DataWriter
Writes aDATA
frame to the remote endpoint. This will result in one or more frames being written to the context.- Specified by:
writeData
in interfaceHttp2DataWriter
- Parameters:
ctx
- the context to use for writing.streamId
- the stream for which to send the frame.data
- the payload of the frame. This will be released by this method.padding
- additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive). A 1 byte padding is encoded as just the pad length field with value 0. A 256 byte padding is encoded as the pad length field with value 255 and 255 padding bytes appended to the end of the frame.endStream
- indicates if this is the last frame to be sent for the stream.- Returns:
- the future for the write.
-
writeHeaders
public Future<Void> writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream)
Description copied from interface:Http2FrameWriter
Writes a HEADERS frame to the remote endpoint.- Specified by:
writeHeaders
in interfaceHttp2FrameWriter
- Parameters:
ctx
- the context to use for writing.streamId
- the stream for which to send the frame.headers
- the headers to be sent.padding
- additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive).endStream
- indicates if this is the last frame to be sent for the stream.- Returns:
- the future for the write.
Section 10.5.1 states the following:
The header block MUST be processed to ensure a consistent connection state, unless the connection is closed.
If this call has modified the HPACK header state you MUST throw a connection error.If this call has NOT modified the HPACK header state you are free to throw a stream error.
-
writeHeaders
public Future<Void> writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream)
Description copied from interface:Http2FrameWriter
Writes a HEADERS frame with priority specified to the remote endpoint.- Specified by:
writeHeaders
in interfaceHttp2FrameWriter
- Parameters:
ctx
- the context to use for writing.streamId
- the stream for which to send the frame.headers
- the headers to be sent.streamDependency
- the stream on which this stream should depend, or 0 if it should depend on the connection.weight
- the weight for this stream.exclusive
- whether this stream should be the exclusive dependant 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 if this is the last frame to be sent for the stream.- Returns:
- the future for the write.
Section 10.5.1 states the following:
The header block MUST be processed to ensure a consistent connection state, unless the connection is closed.
If this call has modified the HPACK header state you MUST throw a connection error.If this call has NOT modified the HPACK header state you are free to throw a stream error.
-
writePriority
public Future<Void> writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive)
Description copied from interface:Http2FrameWriter
Writes a PRIORITY frame to the remote endpoint.- Specified by:
writePriority
in interfaceHttp2FrameWriter
- Parameters:
ctx
- the context to use for writing.streamId
- the stream for which to send the frame.streamDependency
- the stream on which this stream should depend, or 0 if it should depend on the connection.weight
- the weight for this stream.exclusive
- whether this stream should be the exclusive dependant of its parent.- Returns:
- the future for the write.
-
writeRstStream
public Future<Void> writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode)
Description copied from interface:Http2FrameWriter
Writes a RST_STREAM frame to the remote endpoint.- Specified by:
writeRstStream
in interfaceHttp2FrameWriter
- Parameters:
ctx
- the context to use for writing.streamId
- the stream for which to send the frame.errorCode
- the error code indicating the nature of the failure.- Returns:
- the future for the write.
-
writeSettings
public Future<Void> writeSettings(ChannelHandlerContext ctx, Http2Settings settings)
Description copied from interface:Http2FrameWriter
Writes a SETTINGS frame to the remote endpoint.- Specified by:
writeSettings
in interfaceHttp2FrameWriter
- Parameters:
ctx
- the context to use for writing.settings
- the settings to be sent.- Returns:
- the future for the write.
-
writeSettingsAck
public Future<Void> writeSettingsAck(ChannelHandlerContext ctx)
Description copied from interface:Http2FrameWriter
Writes a SETTINGS acknowledgment to the remote endpoint.- Specified by:
writeSettingsAck
in interfaceHttp2FrameWriter
- Parameters:
ctx
- the context to use for writing.- Returns:
- the future for the write.
-
writePing
public Future<Void> writePing(ChannelHandlerContext ctx, boolean ack, long data)
Description copied from interface:Http2FrameWriter
Writes a PING frame to the remote endpoint.- Specified by:
writePing
in interfaceHttp2FrameWriter
- Parameters:
ctx
- the context to use for writing.ack
- indicates whether this is an ack of a PING frame previously received from the remote endpoint.data
- the payload of the frame.- Returns:
- the future for the write.
-
writePushPromise
public Future<Void> writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding)
Description copied from interface:Http2FrameWriter
Writes a PUSH_PROMISE frame to the remote endpoint.- Specified by:
writePushPromise
in interfaceHttp2FrameWriter
- Parameters:
ctx
- the context to use for writing.streamId
- the stream for which to send the frame.promisedStreamId
- the ID of the promised stream.headers
- the headers to be sent.padding
- additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive).- Returns:
- the future for the write.
Section 10.5.1 states the following:
The header block MUST be processed to ensure a consistent connection state, unless the connection is closed.
If this call has modified the HPACK header state you MUST throw a connection error.If this call has NOT modified the HPACK header state you are free to throw a stream error.
-
writeGoAway
public Future<Void> writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, Buffer debugData)
Description copied from interface:Http2FrameWriter
Writes a GO_AWAY frame to the remote endpoint.- Specified by:
writeGoAway
in interfaceHttp2FrameWriter
- Parameters:
ctx
- the context to use for writing.lastStreamId
- the last known stream of this endpoint.errorCode
- the error code, if the connection was abnormally terminated.debugData
- application-defined debug data. This will be released by this method.- Returns:
- the future for the write.
-
writeWindowUpdate
public Future<Void> writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement)
Description copied from interface:Http2FrameWriter
Writes a WINDOW_UPDATE frame to the remote endpoint.- Specified by:
writeWindowUpdate
in interfaceHttp2FrameWriter
- Parameters:
ctx
- the context to use for writing.streamId
- the stream for which to send the frame.windowSizeIncrement
- the number of bytes by which the local inbound flow control window is increasing.- Returns:
- the future for the write.
-
writeFrame
public Future<Void> writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, Buffer payload)
Description copied from interface:Http2FrameWriter
Generic write method for any HTTP/2 frame. This allows writing of non-standard frames.- Specified by:
writeFrame
in interfaceHttp2FrameWriter
- Parameters:
ctx
- the context to use for writing.frameType
- the frame type identifier.streamId
- the stream for which to send the frame.flags
- the flags to write for this frame.payload
- the payload to write for this frame. This will be released by this method.- Returns:
- the future for the write.
-
-