Fixed infinite loop when receiving a SETTINGS frame.
This commit is contained in:
parent
2b494fde0e
commit
82a2dfd03a
|
@ -103,7 +103,7 @@ public class FlowControlTest extends AbstractTest
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
// Two SETTINGS frames, the initial one and the one we send.
|
// Two SETTINGS frames, the initial one and the one we send from the server.
|
||||||
final CountDownLatch settingsLatch = new CountDownLatch(2);
|
final CountDownLatch settingsLatch = new CountDownLatch(2);
|
||||||
Session client = newClient(new Session.Listener.Adapter()
|
Session client = newClient(new Session.Listener.Adapter()
|
||||||
{
|
{
|
||||||
|
|
|
@ -163,6 +163,10 @@ public abstract class HTTP2Session implements ISession, Parser.Listener
|
||||||
{
|
{
|
||||||
if (LOG.isDebugEnabled())
|
if (LOG.isDebugEnabled())
|
||||||
LOG.debug("Received {}", frame);
|
LOG.debug("Received {}", frame);
|
||||||
|
|
||||||
|
if (frame.isReply())
|
||||||
|
return false;
|
||||||
|
|
||||||
Map<Integer, Integer> settings = frame.getSettings();
|
Map<Integer, Integer> settings = frame.getSettings();
|
||||||
if (settings.containsKey(SettingsFrame.MAX_CONCURRENT_STREAMS))
|
if (settings.containsKey(SettingsFrame.MAX_CONCURRENT_STREAMS))
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in New Issue