Package io.grpc.netty

Class AbstractNettyHandler.FlowControlPinger

java.lang.Object
io.grpc.netty.AbstractNettyHandler.FlowControlPinger
Enclosing class:
AbstractNettyHandler

final class AbstractNettyHandler.FlowControlPinger extends Object
Class for handling flow control pinging and flow control window updates as necessary.
  • Field Details

    • MAX_WINDOW_SIZE

      private static final int MAX_WINDOW_SIZE
      See Also:
    • MAX_BACKOFF

      public static final int MAX_BACKOFF
      See Also:
    • pingLimiter

      private final AbstractNettyHandler.PingLimiter pingLimiter
    • pingCount

      private int pingCount
    • pingReturn

      private int pingReturn
    • pinging

      private boolean pinging
    • dataSizeSincePing

      private int dataSizeSincePing
    • lastBandwidth

      private long lastBandwidth
    • lastPingTime

      private long lastPingTime
    • lastTargetWindow

      private int lastTargetWindow
    • pingFrequencyMultiplier

      private int pingFrequencyMultiplier
  • Constructor Details

  • Method Details

    • payload

      public long payload()
    • maxWindow

      public int maxWindow()
    • onDataRead

      public void onDataRead(int dataLength, int paddingLength)
    • updateWindow

      public void updateWindow() throws io.netty.handler.codec.http2.Http2Exception
      Throws:
      io.netty.handler.codec.http2.Http2Exception
    • isPinging

      private boolean isPinging()
    • setPinging

      private void setPinging(boolean pingOut)
    • sendPing

      private void sendPing(io.netty.channel.ChannelHandlerContext ctx)
    • incrementDataSincePing

      private void incrementDataSincePing(int increase)
    • getPingCount

      int getPingCount()
    • getPingReturn

      int getPingReturn()
    • getDataSincePing

      int getDataSincePing()
    • setDataSizeSincePing

      private void setDataSizeSincePing(int dataSize)
    • setDataSizeAndSincePing

      void setDataSizeAndSincePing(int dataSize)