From 29c98f4b37d1e5f477f47f950624c560b334fe5d Mon Sep 17 00:00:00 2001 From: Simone Bordet Date: Fri, 27 Jan 2012 13:42:13 +0100 Subject: [PATCH] Processing of frames is now done only if we did not send go_away. --- .../org/eclipse/jetty/spdy/StandardSession.java | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/eclipse/jetty/spdy/StandardSession.java b/src/main/java/org/eclipse/jetty/spdy/StandardSession.java index d8881e786b7..f0b6c07abd1 100644 --- a/src/main/java/org/eclipse/jetty/spdy/StandardSession.java +++ b/src/main/java/org/eclipse/jetty/spdy/StandardSession.java @@ -215,12 +215,17 @@ public class StandardSession implements ISession, Parser.Listener, ISession.Cont { logger.debug("Processing {}", frame); + if (closed.get()) + { + logger.debug("Skipped processing of {}", frame); + return; + } + switch (frame.getType()) { case SYN_STREAM: { - if (!closed.get()) - onSyn((SynStreamFrame)frame); + onSyn((SynStreamFrame)frame); break; } case SYN_REPLY: @@ -275,6 +280,12 @@ public class StandardSession implements ISession, Parser.Listener, ISession.Cont { logger.debug("Processing {}, {} data bytes", frame, data.remaining()); + if (closed.get()) + { + logger.debug("Skipped processing of {}", frame); + return; + } + int streamId = frame.getStreamId(); IStream stream = streams.get(streamId); if (stream == null)