Improved logging.
This commit is contained in:
parent
30694b675b
commit
7598062bbb
|
@ -155,14 +155,14 @@ public abstract class AbstractFlowControlStrategy implements FlowControlStrategy
|
||||||
int oldSessionWindow = session.updateSendWindow(-length);
|
int oldSessionWindow = session.updateSendWindow(-length);
|
||||||
int newSessionWindow = oldSessionWindow - length;
|
int newSessionWindow = oldSessionWindow - length;
|
||||||
if (LOG.isDebugEnabled())
|
if (LOG.isDebugEnabled())
|
||||||
LOG.debug("Updated session send window {} -> {} for {}", oldSessionWindow, newSessionWindow, session);
|
LOG.debug("Sending, session send window {} -> {} for {}", oldSessionWindow, newSessionWindow, session);
|
||||||
if (newSessionWindow <= 0)
|
if (newSessionWindow <= 0)
|
||||||
onSessionStalled(session);
|
onSessionStalled(session);
|
||||||
|
|
||||||
int oldStreamWindow = stream.updateSendWindow(-length);
|
int oldStreamWindow = stream.updateSendWindow(-length);
|
||||||
int newStreamWindow = oldStreamWindow - length;
|
int newStreamWindow = oldStreamWindow - length;
|
||||||
if (LOG.isDebugEnabled())
|
if (LOG.isDebugEnabled())
|
||||||
LOG.debug("Updated stream send window {} -> {} for {}", oldStreamWindow, newStreamWindow, stream);
|
LOG.debug("Sending, stream send window {} -> {} for {}", oldStreamWindow, newStreamWindow, stream);
|
||||||
if (newStreamWindow <= 0)
|
if (newStreamWindow <= 0)
|
||||||
onStreamStalled(stream);
|
onStreamStalled(stream);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue