Package io.grpc.netty

Class NettyClientHandler.PingCountingFrameWriter

java.lang.Object

io.netty.handler.codec.http2.DecoratingHttp2FrameWriter

io.grpc.netty.NettyClientHandler.PingCountingFrameWriter

All Implemented Interfaces:

AbstractNettyHandler.PingLimiter, io.netty.handler.codec.http2.Http2DataWriter, io.netty.handler.codec.http2.Http2FrameWriter, java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

NettyClientHandler

private static class NettyClientHandler.PingCountingFrameWriter
extends io.netty.handler.codec.http2.DecoratingHttp2FrameWriter
implements AbstractNettyHandler.PingLimiter

Nested Class Summary

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

io.netty.handler.codec.http2.Http2FrameWriter.Configuration

Field Summary

Fields

Modifier and Type	Field	Description
private int	pingCount

Constructor Summary

Constructors

Constructor	Description
PingCountingFrameWriter(io.netty.handler.codec.http2.Http2FrameWriter delegate)

Method Summary

Modifier and Type	Method	Description
boolean	isPingAllowed()
io.netty.channel.ChannelFuture	writeData(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.buffer.ByteBuf data, int padding, boolean endStream, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeHeaders(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.handler.codec.http2.Http2Headers headers, int padding, boolean endStream, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeHeaders(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.handler.codec.http2.Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writePing(io.netty.channel.ChannelHandlerContext ctx, boolean ack, long data, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeWindowUpdate(io.netty.channel.ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, io.netty.channel.ChannelPromise promise)

Methods inherited from class io.netty.handler.codec.http2.DecoratingHttp2FrameWriter

close, configuration, writeFrame, writeGoAway, writePriority, writePushPromise, writeRstStream, writeSettings, writeSettingsAck

Methods inherited from class java.lang.Object

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

Field Detail

pingCount

private int pingCount

Constructor Detail

PingCountingFrameWriter

public PingCountingFrameWriter(io.netty.handler.codec.http2.Http2FrameWriter delegate)

Method Detail

isPingAllowed

public boolean isPingAllowed()

Specified by:

isPingAllowed in interface AbstractNettyHandler.PingLimiter

writeHeaders

public io.netty.channel.ChannelFuture writeHeaders(io.netty.channel.ChannelHandlerContext ctx,
                                                   int streamId,
                                                   io.netty.handler.codec.http2.Http2Headers headers,
                                                   int padding,
                                                   boolean endStream,
                                                   io.netty.channel.ChannelPromise promise)

Specified by:

writeHeaders in interface io.netty.handler.codec.http2.Http2FrameWriter

Overrides:

writeHeaders in class io.netty.handler.codec.http2.DecoratingHttp2FrameWriter

writeHeaders

public io.netty.channel.ChannelFuture writeHeaders(io.netty.channel.ChannelHandlerContext ctx,
                                                   int streamId,
                                                   io.netty.handler.codec.http2.Http2Headers headers,
                                                   int streamDependency,
                                                   short weight,
                                                   boolean exclusive,
                                                   int padding,
                                                   boolean endStream,
                                                   io.netty.channel.ChannelPromise promise)

Specified by:

writeHeaders in interface io.netty.handler.codec.http2.Http2FrameWriter

Overrides:

writeHeaders in class io.netty.handler.codec.http2.DecoratingHttp2FrameWriter

writeWindowUpdate

public io.netty.channel.ChannelFuture writeWindowUpdate(io.netty.channel.ChannelHandlerContext ctx,
                                                        int streamId,
                                                        int windowSizeIncrement,
                                                        io.netty.channel.ChannelPromise promise)

Specified by:

writeWindowUpdate in interface io.netty.handler.codec.http2.Http2FrameWriter

Overrides:

writeWindowUpdate in class io.netty.handler.codec.http2.DecoratingHttp2FrameWriter

writePing

public io.netty.channel.ChannelFuture writePing(io.netty.channel.ChannelHandlerContext ctx,
                                                boolean ack,
                                                long data,
                                                io.netty.channel.ChannelPromise promise)

Specified by:

writePing in interface io.netty.handler.codec.http2.Http2FrameWriter

Overrides:

writePing in class io.netty.handler.codec.http2.DecoratingHttp2FrameWriter

writeData

public io.netty.channel.ChannelFuture writeData(io.netty.channel.ChannelHandlerContext ctx,
                                                int streamId,
                                                io.netty.buffer.ByteBuf data,
                                                int padding,
                                                boolean endStream,
                                                io.netty.channel.ChannelPromise promise)

Specified by:

writeData in interface io.netty.handler.codec.http2.Http2DataWriter

Overrides:

writeData in class io.netty.handler.codec.http2.DecoratingHttp2FrameWriter