Processing of frames is now done only if we did not send go_away.
This commit is contained in:
parent
2b6d997320
commit
29c98f4b37
|
@ -215,11 +215,16 @@ public class StandardSession implements ISession, Parser.Listener, ISession.Cont
|
||||||
{
|
{
|
||||||
logger.debug("Processing {}", frame);
|
logger.debug("Processing {}", frame);
|
||||||
|
|
||||||
|
if (closed.get())
|
||||||
|
{
|
||||||
|
logger.debug("Skipped processing of {}", frame);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
switch (frame.getType())
|
switch (frame.getType())
|
||||||
{
|
{
|
||||||
case SYN_STREAM:
|
case SYN_STREAM:
|
||||||
{
|
{
|
||||||
if (!closed.get())
|
|
||||||
onSyn((SynStreamFrame)frame);
|
onSyn((SynStreamFrame)frame);
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
@ -275,6 +280,12 @@ public class StandardSession implements ISession, Parser.Listener, ISession.Cont
|
||||||
{
|
{
|
||||||
logger.debug("Processing {}, {} data bytes", frame, data.remaining());
|
logger.debug("Processing {}, {} data bytes", frame, data.remaining());
|
||||||
|
|
||||||
|
if (closed.get())
|
||||||
|
{
|
||||||
|
logger.debug("Skipped processing of {}", frame);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
int streamId = frame.getStreamId();
|
int streamId = frame.getStreamId();
|
||||||
IStream stream = streams.get(streamId);
|
IStream stream = streams.get(streamId);
|
||||||
if (stream == null)
|
if (stream == null)
|
||||||
|
|
Loading…
Reference in New Issue