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)