diff options
| author | Greg Wilkins | 2009-04-14 03:00:19 +0000 |
|---|---|---|
| committer | Greg Wilkins | 2009-04-14 03:00:19 +0000 |
| commit | 1e0009aa321000c339fa46d2fdc68b90c78690ec (patch) | |
| tree | 166003d6249643e4bc9f86e71f82cb01f8a6a099 /jetty-io | |
| parent | 68403f43e9feb05345cc140bbbb88aaf8da0a05a (diff) | |
| download | org.eclipse.jetty.project-1e0009aa321000c339fa46d2fdc68b90c78690ec.tar.gz org.eclipse.jetty.project-1e0009aa321000c339fa46d2fdc68b90c78690ec.tar.xz org.eclipse.jetty.project-1e0009aa321000c339fa46d2fdc68b90c78690ec.zip | |
removed HTTP specifics from connection dispatching
git-svn-id: svn+ssh://dev.eclipse.org/svnroot/rt/org.eclipse.jetty/jetty/trunk@143 7e9141cc-0065-0410-87d8-b60c137991c4
Diffstat (limited to 'jetty-io')
| -rw-r--r-- | jetty-io/src/main/java/org/eclipse/jetty/io/Connection.java | 1 | ||||
| -rw-r--r-- | jetty-io/src/main/java/org/eclipse/jetty/io/nio/SelectChannelEndPoint.java | 5 |
2 files changed, 5 insertions, 1 deletions
diff --git a/jetty-io/src/main/java/org/eclipse/jetty/io/Connection.java b/jetty-io/src/main/java/org/eclipse/jetty/io/Connection.java index 5545ddddea..1c8b2a38a0 100644 --- a/jetty-io/src/main/java/org/eclipse/jetty/io/Connection.java +++ b/jetty-io/src/main/java/org/eclipse/jetty/io/Connection.java @@ -20,4 +20,5 @@ public interface Connection void handle() throws IOException; boolean isIdle(); + boolean isSuspended(); } diff --git a/jetty-io/src/main/java/org/eclipse/jetty/io/nio/SelectChannelEndPoint.java b/jetty-io/src/main/java/org/eclipse/jetty/io/nio/SelectChannelEndPoint.java index 8b5ff04a5b..e07e2fab34 100644 --- a/jetty-io/src/main/java/org/eclipse/jetty/io/nio/SelectChannelEndPoint.java +++ b/jetty-io/src/main/java/org/eclipse/jetty/io/nio/SelectChannelEndPoint.java @@ -216,7 +216,10 @@ public class SelectChannelEndPoint extends ChannelEndPoint implements Runnable, /* ------------------------------------------------------------ */ public boolean isReadyForDispatch() { - return !_dispatched; + synchronized (this) + { + return !(_dispatched || getConnection().isSuspended()); + } } /* ------------------------------------------------------------ */ |