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, Closeable, 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 Details

    • pingCount

      private int pingCount

  • Constructor Details

    • PingCountingFrameWriter

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

  • Method Details

    • 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