Class DefaultHttp2FrameWriter

java.lang.Object
io.netty.handler.codec.http2.DefaultHttp2FrameWriter
All Implemented Interfaces:
Http2DataWriter, Http2FrameSizePolicy, Http2FrameWriter, Http2FrameWriter.Configuration, Closeable, AutoCloseable

public class DefaultHttp2FrameWriter extends Object implements Http2FrameWriter, Http2FrameSizePolicy, Http2FrameWriter.Configuration
A Http2FrameWriter that supports all frame types defined by the HTTP/2 specification.
  • Field Details

    • STREAM_ID

      private static final String STREAM_ID
      See Also:
    • STREAM_DEPENDENCY

      private static final String STREAM_DEPENDENCY
      See Also:
    • ZERO_BUFFER

      private static final ByteBuf ZERO_BUFFER
      This buffer is allocated to the maximum size of the padding field, and filled with zeros. When padding is needed it can be taken as a slice of this buffer. Users should call ByteBuf.retain() before using their slice.
    • headersEncoder

      private final Http2HeadersEncoder headersEncoder
    • maxFrameSize

      private int maxFrameSize
  • Constructor Details

  • Method Details

    • configuration

      public Http2FrameWriter.Configuration configuration()
      Description copied from interface: Http2FrameWriter
      Get the configuration related elements for this Http2FrameWriter
      Specified by:
      configuration in interface Http2FrameWriter
    • headersConfiguration

      public Http2HeadersEncoder.Configuration headersConfiguration()
      Description copied from interface: Http2FrameWriter.Configuration
      Specified by:
      headersConfiguration in interface Http2FrameWriter.Configuration
    • frameSizePolicy

      public Http2FrameSizePolicy frameSizePolicy()
      Description copied from interface: Http2FrameWriter.Configuration
      Specified by:
      frameSizePolicy in interface Http2FrameWriter.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 interface Http2FrameSizePolicy
      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 interface Http2FrameSizePolicy
    • close

      public void close()
      Description copied from interface: Http2FrameWriter
      Closes this writer and frees any allocated resources.
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface Http2FrameWriter
    • writeData

      public ChannelFuture writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise)
      Description copied from interface: Http2DataWriter
      Writes a DATA frame to the remote endpoint. This will result in one or more frames being written to the context.
      Specified by:
      writeData in interface Http2DataWriter
      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.
      promise - the promise for the write.
      Returns:
      the future for the write.
    • writeHeaders

      public ChannelFuture writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)
      Description copied from interface: Http2FrameWriter
      Writes a HEADERS frame to the remote endpoint.
      Specified by:
      writeHeaders in interface Http2FrameWriter
      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.
      promise - the promise for the write.
      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 ChannelFuture writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise)
      Description copied from interface: Http2FrameWriter
      Writes a HEADERS frame with priority specified to the remote endpoint.
      Specified by:
      writeHeaders in interface Http2FrameWriter
      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.
      promise - the promise for the write.
      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 ChannelFuture writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)
      Description copied from interface: Http2FrameWriter
      Writes a PRIORITY frame to the remote endpoint.
      Specified by:
      writePriority in interface Http2FrameWriter
      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.
      promise - the promise for the write.
      Returns:
      the future for the write.
    • writeRstStream

      public ChannelFuture writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
      Description copied from interface: Http2FrameWriter
      Writes a RST_STREAM frame to the remote endpoint.
      Specified by:
      writeRstStream in interface Http2FrameWriter
      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.
      promise - the promise for the write.
      Returns:
      the future for the write.
    • writeSettings

      public ChannelFuture writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)
      Description copied from interface: Http2FrameWriter
      Writes a SETTINGS frame to the remote endpoint.
      Specified by:
      writeSettings in interface Http2FrameWriter
      Parameters:
      ctx - the context to use for writing.
      settings - the settings to be sent.
      promise - the promise for the write.
      Returns:
      the future for the write.
    • writeSettingsAck

      public ChannelFuture writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)
      Description copied from interface: Http2FrameWriter
      Writes a SETTINGS acknowledgment to the remote endpoint.
      Specified by:
      writeSettingsAck in interface Http2FrameWriter
      Parameters:
      ctx - the context to use for writing.
      promise - the promise for the write.
      Returns:
      the future for the write.
    • writePing

      public ChannelFuture writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)
      Description copied from interface: Http2FrameWriter
      Writes a PING frame to the remote endpoint.
      Specified by:
      writePing in interface Http2FrameWriter
      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.
      promise - the promise for the write.
      Returns:
      the future for the write.
    • writePushPromise

      public ChannelFuture writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)
      Description copied from interface: Http2FrameWriter
      Writes a PUSH_PROMISE frame to the remote endpoint.
      Specified by:
      writePushPromise in interface Http2FrameWriter
      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).
      promise - the promise for the write.
      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 ChannelFuture writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
      Description copied from interface: Http2FrameWriter
      Writes a GO_AWAY frame to the remote endpoint.
      Specified by:
      writeGoAway in interface Http2FrameWriter
      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.
      promise - the promise for the write.
      Returns:
      the future for the write.
    • writeWindowUpdate

      public ChannelFuture writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)
      Description copied from interface: Http2FrameWriter
      Writes a WINDOW_UPDATE frame to the remote endpoint.
      Specified by:
      writeWindowUpdate in interface Http2FrameWriter
      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.
      promise - the promise for the write.
      Returns:
      the future for the write.
    • writeFrame

      public ChannelFuture writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
      Description copied from interface: Http2FrameWriter
      Generic write method for any HTTP/2 frame. This allows writing of non-standard frames.
      Specified by:
      writeFrame in interface Http2FrameWriter
      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.
      promise - the promise for the write.
      Returns:
      the future for the write.
    • writeHeadersInternal

      private ChannelFuture writeHeadersInternal(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, boolean hasPriority, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)
    • writeContinuationFrames

      private ChannelFuture writeContinuationFrames(ChannelHandlerContext ctx, int streamId, ByteBuf headerBlock, Http2CodecUtil.SimpleChannelPromiseAggregator promiseAggregator)
      Writes as many continuation frames as needed until padding and headerBlock are consumed.
    • paddingBytes

      private static int paddingBytes(int padding)
      Returns the number of padding bytes that should be appended to the end of a frame.
    • writePaddingLength

      private static void writePaddingLength(ByteBuf buf, int padding)
    • verifyStreamId

      private static void verifyStreamId(int streamId, String argumentName)
    • verifyStreamOrConnectionId

      private static void verifyStreamOrConnectionId(int streamId, String argumentName)
    • verifyWeight

      private static void verifyWeight(short weight)
    • verifyErrorCode

      private static void verifyErrorCode(long errorCode)
    • verifyWindowSizeIncrement

      private static void verifyWindowSizeIncrement(int windowSizeIncrement)