Package io.grpc.netty
Class AbstractNettyHandler.FlowControlPinger
java.lang.Object
io.grpc.netty.AbstractNettyHandler.FlowControlPinger
- Enclosing class:
AbstractNettyHandler
Class for handling flow control pinging and flow control window updates as necessary.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate int
private long
private long
private int
static final int
private static final int
private int
private int
private boolean
private final AbstractNettyHandler.PingLimiter
private int
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) int
(package private) int
(package private) int
private void
incrementDataSincePing
(int increase) private boolean
int
void
onDataRead
(int dataLength, int paddingLength) long
payload()
private void
sendPing
(io.netty.channel.ChannelHandlerContext ctx) (package private) void
setDataSizeAndSincePing
(int dataSize) private void
setDataSizeSincePing
(int dataSize) private void
setPinging
(boolean pingOut) void
-
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
-
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
-
FlowControlPinger
-
-
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)
-