io.netty.handler.codec.http2

Class DefaultHttp2ConnectionEncoder

java.lang.Object

io.netty.handler.codec.http2.DefaultHttp2ConnectionEncoder

All Implemented Interfaces:

Http2ConnectionEncoder, Http2DataWriter, Http2FrameWriter, Closeable, AutoCloseable

Direct Known Subclasses:

CompressorHttp2ConnectionEncoder

public class DefaultHttp2ConnectionEncoder
extends Object
implements Http2ConnectionEncoder

Default implementation of Http2ConnectionEncoder.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DefaultHttp2ConnectionEncoder.Builder Builder for new instances of DefaultHttp2ConnectionEncoder.
class	DefaultHttp2ConnectionEncoder.FlowControlledBase Common base type for payloads to deliver via flow-control.

Nested classes/interfaces inherited from interface io.netty.handler.codec.http2.Http2FrameWriter

Http2FrameWriter.Configuration

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DefaultHttp2ConnectionEncoder(DefaultHttp2ConnectionEncoder.Builder builder)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes this writer and frees any allocated resources.
Http2FrameWriter.Configuration	configuration() Get the configuration related elements for this Http2FrameWriter
Http2Connection	connection() Provides direct access to the underlying connection.
Http2RemoteFlowController	flowController() Provides the remote flow controller for managing outbound traffic.
Http2FrameWriter	frameWriter() Provides direct access to the underlying frame writer object.
static DefaultHttp2ConnectionEncoder.Builder	newBuilder()
Http2Settings	pollSentSettings() Gets the local settings on the top of the queue that has been sent but not ACKed.
void	remoteSettings(Http2Settings settings) Sets the settings for the remote endpoint of the HTTP/2 connection.
ChannelFuture	writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) Writes a DATA frame to the remote endpoint.
ChannelFuture	writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) Writes the given data to the internal Http2FrameWriter without performing any state checks on the connection/stream.
ChannelFuture	writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) Writes a GO_AWAY frame to the remote endpoint.
ChannelFuture	writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) Writes a HEADERS frame to the remote endpoint.
ChannelFuture	writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) Writes a HEADERS frame with priority specified to the remote endpoint.
ChannelFuture	writePing(ChannelHandlerContext ctx, boolean ack, ByteBuf data, ChannelPromise promise) Writes a PING frame to the remote endpoint.
ChannelFuture	writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) Writes a PRIORITY frame to the remote endpoint.
ChannelFuture	writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) Writes a PUSH_PROMISE frame to the remote endpoint.
ChannelFuture	writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) Writes a RST_STREAM frame to the remote endpoint.
ChannelFuture	writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise, boolean writeIfNoStream) Writes a RST_STREAM frame to the remote endpoint.
ChannelFuture	writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) Writes a SETTINGS frame to the remote endpoint.
ChannelFuture	writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) Writes a SETTINGS acknowledgment to the remote endpoint.
ChannelFuture	writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) Writes a WINDOW_UPDATE frame to the remote endpoint.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultHttp2ConnectionEncoder

protected DefaultHttp2ConnectionEncoder(DefaultHttp2ConnectionEncoder.Builder builder)

Method Detail

newBuilder

public static DefaultHttp2ConnectionEncoder.Builder newBuilder()

frameWriter

public Http2FrameWriter frameWriter()

Description copied from interface: Http2ConnectionEncoder

Provides direct access to the underlying frame writer object.

Specified by:

frameWriter in interface Http2ConnectionEncoder

connection

public Http2Connection connection()

Description copied from interface: Http2ConnectionEncoder

Provides direct access to the underlying connection.

Specified by:

connection in interface Http2ConnectionEncoder

flowController

public final Http2RemoteFlowController flowController()

Description copied from interface: Http2ConnectionEncoder

Provides the remote flow controller for managing outbound traffic.

Specified by:

flowController in interface Http2ConnectionEncoder

remoteSettings

public void remoteSettings(Http2Settings settings)
                    throws Http2Exception

Description copied from interface: Http2ConnectionEncoder

Sets the settings for the remote endpoint of the HTTP/2 connection.

Specified by:

remoteSettings in interface Http2ConnectionEncoder

Throws:

Http2Exception

writeData

public ChannelFuture writeData(ChannelHandlerContext ctx,
                      int streamId,
                      ByteBuf data,
                      int padding,
                      boolean endOfStream,
                      ChannelPromise promise)

Description copied from interface: Http2DataWriter

Writes a DATA frame to the remote endpoint.

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 - the amount of padding to be added to the end of the frame

endOfStream - 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 - the amount of padding to be added 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 streamDependency,
                         short weight,
                         boolean exclusive,
                         int padding,
                         boolean endOfStream,
                         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 - the amount of padding to be added to the end of the frame

endOfStream - 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.

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.

writeRstStream

public ChannelFuture writeRstStream(ChannelHandlerContext ctx,
                           int streamId,
                           long errorCode,
                           ChannelPromise promise,
                           boolean writeIfNoStream)

Writes a RST_STREAM frame to the remote endpoint.

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.

writeIfNoStream -

• true will force a write of a RST_STREAM even if the stream object does not exist locally.
• false will only send a RST_STREAM only if the stream is known about locally

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,
                      ByteBuf 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. This will be released by this method.

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 - the amount of padding to be added to the end of the frame

promise - the promise for the write.

Returns:

the future for the write.

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: Http2ConnectionEncoder

Writes the given data to the internal Http2FrameWriter without performing any state checks on the connection/stream.

Specified by:

writeFrame in interface Http2ConnectionEncoder

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.

close

public void close()

Description copied from interface: Http2FrameWriter

Closes this writer and frees any allocated resources.

Specified by:

close in interface Http2FrameWriter

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

pollSentSettings

public Http2Settings pollSentSettings()

Description copied from interface: Http2ConnectionEncoder

Gets the local settings on the top of the queue that has been sent but not ACKed. This may return null.

Specified by:

pollSentSettings in interface Http2ConnectionEncoder

configuration

public Http2FrameWriter.Configuration configuration()

Description copied from interface: Http2FrameWriter

Get the configuration related elements for this Http2FrameWriter

Specified by:

configuration in interface Http2FrameWriter