Package io.grpc.netty

Class AbstractNettyHandler.FlowControlPinger

  • Enclosing class:
    AbstractNettyHandler

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

      • 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
    • Method Detail

      • 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)